initial server commit

.gitignore

@@ -10,3 +10,6 @@
 
 # Output of the go coverage tool, specifically when used with LiteIDE
 *.out
+
+.idea/
+go-backpressure

main.go

@@ -0,0 +1,27 @@
+package main
+
+import (
+	"os"
+	"fmt"
+	"github.com/domdom82/go-backpressure/server"
+)
+
+func main() {
+	var sconfig *server.ServerConfig
+	//var cconfig *client.ClientConfig
+	if len(os.Args) > 1 {
+		fmt.Printf("Loading sconfig from %q\n", os.Args[1])
+		s, err := server.NewServerConfigFromFile(os.Args[1])
+		if err != nil {
+			fmt.Println(err)
+			os.Exit(1)
+		}
+		sconfig = s
+	} else {
+		fmt.Printf("ERROR: No configuration file provided.\nUsage: %s <-client|-server> <configfile>", os.Args[0])
+		os.Exit(1)
+	}
+
+	fmt.Printf("Starting the server.\n")
+	sconfig.NewServer().Run()
+}

server/config.yml

@@ -0,0 +1,4 @@
+---
+port: 1234
+bufsize: 1500
+delay: 1000

server/server.go

@@ -0,0 +1,55 @@
+package server
+
+import (
+	"bufio"
+	"fmt"
+	"time"
+	"net"
+	"io/ioutil"
+	"gopkg.in/yaml.v2"
+)
+
+
+type ServerConfig struct {
+	Port string 		`yaml:"port"`
+	Bufsize int 		`yaml:"bufsize"`
+	Delay time.Duration	`yaml:"delay"`
+}
+
+type Server struct {
+	config *ServerConfig
+}
+
+
+func (cfg *ServerConfig) NewServer() *Server {
+	server := &Server{ config: cfg}
+
+	return server
+}
+
+func NewServerConfigFromFile(filename string) (*ServerConfig, error) {
+	data, err := ioutil.ReadFile(filename)
+	if err != nil {
+		return nil, err
+	}
+	var config *ServerConfig
+	err = yaml.Unmarshal(data, &config)
+	if err != nil {
+		return nil, err
+	}
+
+	return config, nil
+}
+
+
+// sync
+func (srv *Server) Run() {
+	listener, _ := net.Listen("tcp", fmt.Sprintf(":%s", srv.config.Port))
+	conn, _ := listener.Accept()
+
+	for {
+		msg, _ := bufio.NewReaderSize(conn, srv.config.Bufsize).ReadBytes('\n')
+		fmt.Println(string(msg))
+		time.Sleep(srv.config.Delay * time.Millisecond)
+	}
+}