kopia lustrzana https://github.com/tmsmr/xmpp-webhook
master
rodzic
68f06691fd
commit
3a1fc29d0c
24
main.go
24
main.go
|
@ -13,11 +13,8 @@ func fatalOnErr(err error) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func main() {
|
func xmppLogin(id string, pass string) *xmpp.XMPP {
|
||||||
xi := os.Getenv("XMPP_ID")
|
jid, err := xmpp.ParseJID(id)
|
||||||
xp := os.Getenv("XMPP_PASS")
|
|
||||||
|
|
||||||
jid, err := xmpp.ParseJID(xi)
|
|
||||||
fatalOnErr(err)
|
fatalOnErr(err)
|
||||||
|
|
||||||
addr, err := xmpp.HomeServerAddrs(jid)
|
addr, err := xmpp.HomeServerAddrs(jid)
|
||||||
|
@ -26,13 +23,26 @@ func main() {
|
||||||
stream, err := xmpp.NewStream(addr[0], nil)
|
stream, err := xmpp.NewStream(addr[0], nil)
|
||||||
fatalOnErr(err)
|
fatalOnErr(err)
|
||||||
|
|
||||||
client, err := xmpp.NewClientXMPP(stream, jid, xp, nil)
|
client, err := xmpp.NewClientXMPP(stream, jid, pass, nil)
|
||||||
fatalOnErr(err)
|
fatalOnErr(err)
|
||||||
|
|
||||||
client.Out <- xmpp.Presence{}
|
client.Out <- xmpp.Presence{}
|
||||||
|
|
||||||
|
return client
|
||||||
|
}
|
||||||
|
|
||||||
|
func main() {
|
||||||
|
xi := os.Getenv("XMPP_ID")
|
||||||
|
xp := os.Getenv("XMPP_PASS")
|
||||||
|
|
||||||
|
if len(xi) < 1 || len(xp) < 1 {
|
||||||
|
log.Fatal("XMPP_ID or XMPP_PASS not set")
|
||||||
|
}
|
||||||
|
|
||||||
|
xc := xmppLogin(xi, xp)
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
for msg := range client.In {
|
for msg := range xc.In {
|
||||||
log.Printf("* recv: %v\n", msg)
|
log.Printf("* recv: %v\n", msg)
|
||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
|
|
Ładowanie…
Reference in New Issue