First commit

Makefile

@@ -0,0 +1,4 @@
+all: broker
+
+broker:
+	go build -o clessy-broker ./broker

broker/action.go

@@ -0,0 +1,9 @@
+package broker
+
+import (
+	"../tg"
+)
+
+func executeClientCommand(action tg.ClientCommand) {
+
+}

broker/clients.go

@@ -0,0 +1,67 @@
+package main
+
+import (
+	"bufio"
+	"encoding/json"
+	"fmt"
+	"log"
+	"net"
+
+	"../tg"
+)
+
+var clients []net.Conn
+
+func startClientsServer(bind string) {
+	listener, err := net.Listen("tcp", bind)
+	assert(err)
+
+	// Accept loop
+	for {
+		c, err := listener.Accept()
+		if err != nil {
+			log.Printf("Can't accept client: %s\n", err.Error())
+			continue
+		}
+		clients = append(clients, c)
+		go handleClient(c)
+	}
+}
+
+func handleClient(c net.Conn) {
+	b := bufio.NewReader(c)
+	defer c.Close()
+
+	// Start reading messages
+	for {
+		bytes, _, err := b.ReadLine()
+		if err != nil {
+			break
+		}
+		var cmd tg.ClientCommand
+		err = json.Unmarshal(bytes, &cmd)
+		if err != nil {
+			log.Printf("Can't parse JSON: %s\r\n", err.Error())
+			continue
+		}
+		executeClientCommand(cmd)
+	}
+	removeCon(c)
+}
+
+func removeCon(c net.Conn) {
+	for i, con := range Clients {
+		if c == con {
+			clients = append(clients[:i], clients[i+1:]...)
+		}
+	}
+}
+
+func broadcast(message string) {
+	for _, c := range clients {
+		_, err := fmt.Fprintf(c, message+"\r\n")
+		if err != nil {
+			removeCon(c)
+		}
+	}
+}

broker/main.go

@@ -0,0 +1,43 @@
+package main
+
+import (
+	"encoding/json"
+	"flag"
+	"net/http"
+	"os"
+)
+
+type Config struct {
+	BindServer  string /* Address:Port to bind for Telegram */
+	BindClients string /* Address:Port to bind for clients */
+	Token       string /* Telegram bot token */
+	WebhookURL  string /* Webhook URL */
+}
+
+func assert(err error) {
+	if err != nil {
+		panic(err)
+	}
+}
+
+func main() {
+	cfgpath := flag.String("config", "config.json", "Path to configuration file")
+	flag.Parse()
+
+	file, err := os.Open(*cfgpath)
+	assert(err)
+
+	var config Config
+	err = json.NewDecoder(file).Decode(&config)
+	assert(err)
+
+	// Setup webhook handler
+	go func() {
+		http.HandlerFunc(config.Token, webhook)
+		err := http.ListenAndServe(config.BindServer, nil)
+		assert(err)
+	}()
+
+	// Create server for clients
+	startClientsServer(config.BindClients)
+}

config.json.sample

@@ -0,0 +1,3 @@
+{
+	
+}

tg/command.go

@@ -0,0 +1,4 @@
+package tg
+
+type ClientCommand struct {
+}