aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--connector/external/config.go18
-rwxr-xr-xexternal/dummy.py38
-rw-r--r--test/main.go147
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()
-}