lx/easybridge
0
0
Fork 0
Code Issues 1.6k Pull requests Releases Activity

Remove temporary test code

Browse source
This commit is contained in:
Alex 2020-03-11 08:53:23 +01:00
parent 15e3dc46cf
commit 6c118d651e
3 changed files with 0 additions and 203 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
connector/external/config.go vendored
View file

@ -6,27 +6,9 @@ import (
. "git.deuxfleurs.fr/Deuxfleurs/easybridge/connector"
)
const DUMMYEXT_PROTOCOL = "DummyExt"
const MESSENGER_PROTOCOL = "Messenger"
func init() {
Register(DUMMYEXT_PROTOCOL, Protocol{
NewConnector: func() Connector {
return &External{
protocol: DUMMYEXT_PROTOCOL,
command: "./external/dummy.py",
debug: true,
}
},
Schema: ConfigSchema{
&ConfigEntry{
Name: "user",
Description: "Username",
Required: true,
},
},
})
Register(MESSENGER_PROTOCOL, Protocol{
NewConnector: func() Connector {
return &External{

38
external/dummy.py vendored
View file

@ -1,38 +0,0 @@
#!/usr/bin/env python3
import sys
import json
sys.stderr.write("(python) dummy starting")
sys.stderr.flush()
if __name__ == "__main__":
username = ""
while True:
line = sys.stdin.readline()
sys.stderr.write("(python) got: {}\n".format(line))
sys.stderr.flush()
cmd = json.loads(line)
reply = {
"_type": "rep_ok",
"_id": cmd["_id"],
}
if cmd["_type"] == "configure":
username = cmd["data"]["user"]
if cmd["_type"] == "get_user":
reply["user"] = username
repline = json.dumps(reply)
sys.stderr.write("(python) sending: {}\n".format(repline))
sys.stderr.flush()
sys.stdout.write(repline + "\n")
sys.stdout.flush()
if cmd["_type"] == "close":
break
sys.stderr.write("(python) dummy stopping")
sys.stderr.flush()

147
test/main.go
View file

@ -1,147 +0,0 @@
package main
import (
"strings"
"time"
"fmt"
log "github.com/sirupsen/logrus"
"git.deuxfleurs.fr/Deuxfleurs/easybridge/connector"
"git.deuxfleurs.fr/Deuxfleurs/easybridge/connector/irc"
"git.deuxfleurs.fr/Deuxfleurs/easybridge/connector/xmpp"
)
type TmpHandler struct{
exit chan bool
}
func (h *TmpHandler) Joined(roomId connector.RoomID) {
fmt.Printf("C Joined: %s\n", roomId)
}
func (h *TmpHandler) Left(roomId connector.RoomID) {
fmt.Printf("C Joined: %s\n", roomId)
}
func (h *TmpHandler) UserInfoUpdated(u connector.UserID, i *connector.UserInfo) {
fmt.Printf("C User info: %s => %#v\n", u, i)
}
func (h *TmpHandler) RoomInfoUpdated(r connector.RoomID, i *connector.RoomInfo) {
fmt.Printf("C Room info: %s => %#v\n", r, i)
}
func (h *TmpHandler) Event(e *connector.Event) {
if e.Type == connector.EVENT_JOIN {
fmt.Printf("C E Join %s %s\n", e.Author, e.Room)
} else if e.Type == connector.EVENT_LEAVE {
fmt.Printf("C E Leave %s %s\n", e.Author, e.Room)
} else if e.Type == connector.EVENT_MESSAGE {
fmt.Printf("C E Message %s %s %s\n", e.Author, e.Room, e.Text)
if strings.Contains(e.Text, "ezbrexit") {
fmt.Printf("we have to exit\n")
h.exit <- true
}
} else if e.Type == connector.EVENT_ACTION {
fmt.Printf("C E Action %s %s %s\n", e.Author, e.Room, e.Text)
}
}
func testIrc() {
irc := &irc.IRC{}
h := TmpHandler{
exit: make(chan bool),
}
irc.SetHandler(&h)
err := irc.Configure(connector.Configuration{
"server": "irc.ulminfo.fr",
"port": "6666",
"ssl": "true",
"nick": "ezbr",
})
if err != nil {
log.Fatalf("Connect: %s", err)
}
err = irc.Join(connector.RoomID("#ezbrtest@irc.ulminfo.fr"))
if err != nil {
log.Fatalf("Join: %s", err)
}
time.Sleep(time.Duration(1)*time.Second)
err = irc.Send(&connector.Event{
Room: connector.RoomID("#ezbrtest@irc.ulminfo.fr"),
Type: connector.EVENT_MESSAGE,
Text: "EZBR TEST",
})
if err != nil {
log.Fatalf("Send: %s", err)
}
time.Sleep(time.Duration(1)*time.Second)
err = irc.Send(&connector.Event{
Recipient: connector.UserID("lx@irc.ulminfo.fr"),
Type: connector.EVENT_MESSAGE,
Text: "EZBR TEST direct message lol",
})
if err != nil {
log.Fatalf("Send: %s", err)
}
fmt.Printf("waiting exit signal\n")
<-h.exit
fmt.Printf("got exit signal\n")
irc.Close()
}
func testXmpp() {
xmpp := &xmpp.XMPP{}
h := TmpHandler{
exit: make(chan bool),
}
xmpp.SetHandler(&h)
err := xmpp.Configure(connector.Configuration{
"server": "jabber.fr",
"jid": "ezbr@jabber.fr",
"password": "azerty1234",
})
if err != nil {
log.Fatalf("Connect: %s", err)
}
err = xmpp.Join(connector.RoomID("ezbrtest@muc.linkmauve.fr"))
if err != nil {
log.Fatalf("Join: %s", err)
}
time.Sleep(time.Duration(1)*time.Second)
err = xmpp.Send(&connector.Event{
Room: connector.RoomID("ezbrtest@muc.linkmauve.fr"),
Type: connector.EVENT_MESSAGE,
Text: "EZBR TEST",
})
if err != nil {
log.Fatalf("Send: %s", err)
}
time.Sleep(time.Duration(1)*time.Second)
err = xmpp.Send(&connector.Event{
Recipient: connector.UserID("alexis211@jabber.fr"),
Type: connector.EVENT_MESSAGE,
Text: "EZBR TEST direct message lol",
})
if err != nil {
log.Fatalf("Send: %s", err)
}
fmt.Printf("waiting exit signal\n")
<-h.exit
fmt.Printf("got exit signal\n")
xmpp.Close()
}
func main() {
testXmpp()
}