go-xmpp4steam/xmpp/xmpp.go

package xmpp

import (
	"git.kingpenguin.tk/chteufleur/go-xmpp.git/src/xmpp"
	"git.kingpenguin.tk/chteufleur/go-xmpp4steam.git/database"
	"git.kingpenguin.tk/chteufleur/go-xmpp4steam.git/gateway"

	"log"
	"strings"
	"time"
)

const (
	ActionConnexion       = "action_xmpp_connexion"
	ActionDeconnexion     = "action_xmpp_deconnexion"
	ActionMainMethodEnded = "action_xmpp_main_method_ended"

	LogInfo  = "\t[XMPP COMPONENT INFO]\t"
	LogError = "\t[XMPP COMPONENT ERROR]\t"
	LogDebug = "\t[XMPP COMPONENT DEBUG]\t"
)

var (
	Addr   = "127.0.0.1:5347"
	JidStr = ""
	Secret = ""

	SoftVersion = ""

	jid    xmpp.JID
	stream = new(xmpp.Stream)
	comp   = new(xmpp.XMPP)

	ChanAction = make(chan string)

	Debug = true

	MapGatewayInfo = make(map[string]*gateway.GatewayInfo)
)

func Run() {
	log.Printf("%sRunning", LogInfo)
	// Create stream and configure it as a component connection.
	jid = must(xmpp.ParseJID(JidStr)).(xmpp.JID)
	stream = must(xmpp.NewStream(Addr, &xmpp.StreamConfig{LogStanzas: Debug})).(*xmpp.Stream)
	comp = must(xmpp.NewComponentXMPP(stream, jid, Secret)).(*xmpp.XMPP)

	mainXMPP()
	log.Printf("%sReach main method's end", LogInfo)
	go Run()
}

func mainXMPP() {
	// Define xmpp out for all users
	for _, u := range MapGatewayInfo {
		u.XMPP_Out = comp.Out
	}

	for x := range comp.In {
		switch v := x.(type) {
		case *xmpp.Presence:
			jidBareFrom := strings.SplitN(v.From, "/", 2)[0]
			g := MapGatewayInfo[jidBareFrom]
			if g != nil {
				log.Printf("%sPresence transfered to %s", LogDebug, jidBareFrom)
				g.ReceivedXMPP_Presence(v)
			} else {
				if v.Type != gateway.Type_error && v.Type != gateway.Type_probe {
					SendPresence(gateway.Status_offline, gateway.Type_unavailable, jid.Domain, v.From, "Your are not registred", "")
				}
			}

		case *xmpp.Message:
			jidBareFrom := strings.SplitN(v.From, "/", 2)[0]
			g := MapGatewayInfo[jidBareFrom]
			if g != nil {
				log.Printf("%sMessage transfered to %s", LogDebug, jidBareFrom)
				g.ReceivedXMPP_Message(v)
			} else {
				SendMessage(v.From, "", "Your are not registred. If you want to register, please, send an Ad-Hoc command.")
			}

		case *xmpp.Iq:
			jidBareTo := strings.SplitN(v.To, "/", 2)[0]

			switch v.PayloadName().Space {
			case xmpp.NSDiscoInfo:
				execDisco(v)

			case xmpp.NSDiscoItems:
				execDisco(v)

			case xmpp.NodeAdHocCommand:
				if jidBareTo == jid.Domain {
					execCommandAdHoc(v)
				} else {
					sendNotSupportedFeature(v)
				}

			case xmpp.NSVCardTemp:
				if jidBareTo == jid.Domain {
					reply := v.Response(xmpp.IQTypeResult)
					vcard := &xmpp.VCard{}
					reply.PayloadEncode(vcard)
					comp.Out <- reply
				} else {
					sendNotSupportedFeature(v)
				}

			case xmpp.NSJabberClient:
				if jidBareTo == jid.Domain {
					reply := v.Response(xmpp.IQTypeResult)
					reply.PayloadEncode(&xmpp.SoftwareVersion{Name: "go-xmpp4steam", Version: SoftVersion})
					comp.Out <- reply
				} else {
					sendNotSupportedFeature(v)
				}

			case xmpp.NSRegister:
				if jidBareTo == jid.Domain {
					reply := v.Response(xmpp.IQTypeResult)
					jidBareFrom := strings.SplitN(v.From, "/", 2)[0]
					registerQuery := &xmpp.RegisterQuery{}

					if v.Type == xmpp.IQTypeGet {
						registerQuery.Instructions = "Please provide your Steam login and password (Please, be aware that the given Steam account information will be saved into an un-encrypted SQLite database)."

						dbUser := database.GetLine(jidBareFrom)
						if dbUser != nil {
							// User already registered
							registerQuery.Registered = &xmpp.RegisterRegistered{}
							registerQuery.Username = dbUser.SteamLogin
							registerQuery.XForm = *getXFormRegistration(dbUser.SteamLogin)
						} else {
							registerQuery.XForm = *getXFormRegistration("")
						}
						reply.PayloadEncode(registerQuery)

					} else if v.Type == xmpp.IQTypeSet {
						v.PayloadDecode(registerQuery)

						if registerQuery.Remove != nil {
							RemoveUser(jidBareFrom)
						} else {
							dbUser := getUser(registerQuery.XForm.Fields, v)
							if dbUser != nil {
								if dbUser.UpdateUser() {
									AddNewUser(dbUser.Jid, dbUser.SteamLogin, dbUser.SteamPwd, dbUser.Debug)
								} else {
									reply.Type = xmpp.IQTypeError
									reply.Error = xmpp.NewErrorWithCode("406", "modify", xmpp.ErrorNotAcceptable, "")
								}
							} else {
								reply.Type = xmpp.IQTypeError
								reply.Error = xmpp.NewErrorWithCode("409", "cancel", xmpp.ErrorConflict, "")
							}
						}
					}
					comp.Out <- reply
				} else {
					sendNotSupportedFeature(v)
				}

			default:
				sendNotSupportedFeature(v)
			}

		default:
			log.Printf("%srecv: %v", LogDebug, x)
		}
	}

	// Send deconnexion
	SendPresence(gateway.Status_offline, gateway.Type_unavailable, "", "", "", "")
}

func must(v interface{}, err error) interface{} {
	if err != nil {
		log.Fatal(LogError, err)
	}
	return v
}

func sendNotSupportedFeature(iq *xmpp.Iq) {
	reply := iq.Response(xmpp.IQTypeError)
	reply.PayloadEncode(xmpp.NewError("cancel", xmpp.ErrorFeatureNotImplemented, ""))
	comp.Out <- reply
}

func Disconnect() {
	log.Printf("%sXMPP disconnect", LogInfo)
	for _, u := range MapGatewayInfo {
		u.SteamDisconnect()
	}
}

func SendPresence(status, tpye, from, to, message, nick string) {
	p := xmpp.Presence{}

	if status != "" {
		p.Show = status
	}
	if tpye != "" {
		p.Type = tpye
	}
	if message != "" {
		p.Status = message
	}
	if nick != "" {
		p.Nick = nick
	}
	if from == "" {
		p.From = jid.Domain
	} else {
		p.From = from
	}
	if to != "" {
		p.To = to
	}

	comp.Out <- p
}

func SendMessage(to, subject, message string) {
	m := xmpp.Message{From: jid.Domain, To: to, Body: message, Type: "chat"}

	if subject != "" {
		m.Subject = subject
	}

	log.Printf("%sSenp message %v", LogInfo, m)
	comp.Out <- m
}

func AddNewUser(jid, steamLogin, steamPwd string, debugMessage bool) {
	log.Printf("%sAdd user %s to the map", LogInfo, jid)

	g := new(gateway.GatewayInfo)
	g.SteamLogin = steamLogin
	g.SteamPassword = steamPwd
	g.XMPP_JID_Client = jid
	g.SentryFile = gateway.SentryDirectory + jid
	g.FriendSteamId = make(map[string]*gateway.StatusSteamFriend)
	g.Deleting = false

	g.XMPP_Out = comp.Out
	g.XMPP_Connected_Client = make(map[string]bool)
	g.XMPP_Composing_Timers = make(map[string]*time.Timer)
	g.DebugMessage = debugMessage

	MapGatewayInfo[jid] = g
	go g.Run()
}

func RemoveUser(jidBare string) bool {
	ret := database.RemoveLine(jidBare)

	if ret {
		g := MapGatewayInfo[jidBare]
		ret = g != nil
		if ret {
			g.Delete()
			MapGatewayInfo[jidBare] = nil
		}
	}

	return ret
}