diff options
| -rw-r--r-- | connector/external/config.go | 18 | ||||
| -rwxr-xr-x | external/dummy.py | 38 | ||||
| -rw-r--r-- | test/main.go | 147 |
3 files changed, 0 insertions, 203 deletions
diff --git a/connector/external/config.go b/connector/external/config.go index 9c8e123..ae3cbdb 100644 --- a/connector/external/config.go +++ b/connector/external/config.go @@ -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{ diff --git a/external/dummy.py b/external/dummy.py deleted file mode 100755 index 2dc47ba..0000000 --- a/external/dummy.py +++ /dev/null @@ -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() diff --git a/test/main.go b/test/main.go deleted file mode 100644 index 1baa9df..0000000 --- a/test/main.go +++ /dev/null @@ -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() -} |