68 lines
1.7 KiB
Go
68 lines
1.7 KiB
Go
package xmpp
|
|
|
|
import (
|
|
"git.kingpenguin.tk/chteufleur/go-xmpp.git/src/xmpp"
|
|
|
|
"crypto/rand"
|
|
"log"
|
|
"strconv"
|
|
)
|
|
|
|
const (
|
|
dictionary = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz"
|
|
)
|
|
|
|
type Client struct {
|
|
JID string
|
|
Method string
|
|
Domain string
|
|
Transaction string
|
|
|
|
ChanReply chan bool
|
|
}
|
|
|
|
func (client *Client) QueryClient() {
|
|
log.Printf("%sQuery JID %s", LogInfo, client.JID)
|
|
clientJID, _ := xmpp.ParseJID(client.JID)
|
|
if clientJID.Resource == "" {
|
|
client.askViaMessage()
|
|
} else {
|
|
client.askViaIQ()
|
|
}
|
|
}
|
|
|
|
func (client *Client) askViaIQ() {
|
|
stanzaID++
|
|
stanzaIDstr := strconv.Itoa(stanzaID)
|
|
m := xmpp.Iq{Type: xmpp.IQTypeGet, To: client.JID, From: jid.Domain, Id: stanzaIDstr}
|
|
confirm := &xmpp.Confirm{Id: client.Transaction, Method: client.Method, URL: client.Domain}
|
|
m.PayloadEncode(confirm)
|
|
WaitIqMessages[stanzaIDstr] = client
|
|
comp.Out <- m
|
|
}
|
|
|
|
func (client *Client) askViaMessage() {
|
|
m := xmpp.Message{From: jid.Domain, To: client.JID, Type: "normal"}
|
|
|
|
m.Thread = xmpp.SessionID()
|
|
m.Body = "HTTP (" + client.Method + ") Authorization for " + client.Domain + " (id: " + client.Transaction + ")."
|
|
m.Body += "\nReply to this message to confirm the request."
|
|
m.Body += "\nIf your client doesn't support that functionnality, please send back the identifier to confirm the request."
|
|
m.Confir = &xmpp.Confirm{Id: client.Transaction, Method: client.Method, URL: client.Domain}
|
|
|
|
log.Printf("%sSenp message %v", LogInfo, m)
|
|
WaitMessageAnswers[client.Transaction] = client
|
|
comp.Out <- m
|
|
}
|
|
|
|
func SessionID() string {
|
|
var bytes = make([]byte, 8)
|
|
if _, err := rand.Read(bytes); err != nil {
|
|
panic(err)
|
|
}
|
|
for k, v := range bytes {
|
|
bytes[k] = dictionary[v%byte(len(dictionary))]
|
|
}
|
|
return string(bytes)
|
|
}
|