go-xmpp/cmd/xmpp_component/xmpp_component.go
Mickael Remond 8cb1e1264e
Clean-up
2018-01-23 09:08:21 +01:00

82 lines
1.8 KiB
Go

package main
import (
"fmt"
"fluux.io/xmpp"
)
const (
localUser = "admin@localhost"
)
// TODO add webserver listener to support receiving message from facebook and replying
// Message will get to define localhost user and be routed only from local user
func main() {
component := MyComponent{Name: "Facebook Gateway", Category: "gateway", Type: "facebook"}
component.xmpp = &xmpp.Component{Host: "facebook.localhost", Secret: "mypass"}
component.xmpp.Connect("localhost:8888")
for {
packet, err := component.xmpp.ReadPacket()
if err != nil {
fmt.Println("read error", err)
return
}
switch p := packet.(type) {
case xmpp.IQ:
switch inner := p.Payload[0].(type) {
case *xmpp.DiscoInfo:
fmt.Println("Disco Info")
if p.Type == "get" {
DiscoResult(component, p.From, p.To, p.Id)
}
default:
fmt.Println("ignoring iq packet", inner)
xError := xmpp.Err{
Code: 501,
Reason: "feature-not-implemented",
Type: "cancel",
}
reply := p.MakeError(xError)
component.xmpp.Send(&reply)
}
case xmpp.Message:
fmt.Println("Received message:", p.Body)
case xmpp.Presence:
fmt.Println("Received presence:", p.Type)
default:
fmt.Println("ignoring packet:", packet)
}
}
}
type MyComponent struct {
Name string
// Typical categories and types: https://xmpp.org/registrar/disco-categories.html
Category string
Type string
xmpp *xmpp.Component
}
func DiscoResult(c MyComponent, from, to, id string) {
iq := xmpp.NewIQ("result", to, from, id, "en")
payload := xmpp.DiscoInfo{
Identity: xmpp.Identity{
Name: c.Name,
Category: c.Category,
Type: c.Type,
},
Features: []xmpp.Feature{
{Var: "http://jabber.org/protocol/disco#info"},
{Var: "http://jabber.org/protocol/disco#item"},
},
}
iq.AddPayload(&payload)
c.xmpp.Send(iq)
}