diff --git a/event_proxy/main.go b/event_proxy/main.go new file mode 100644 index 0000000..eeca53b --- /dev/null +++ b/event_proxy/main.go @@ -0,0 +1,52 @@ +package main + +import ( + "fmt" + "log" + "net" + "os" + "time" +) + +const ( + HOST = "0.0.0.0" + PORT = "8080" + TYPE = "tcp" +) + +func main() { + listen, err := net.Listen(TYPE, HOST+":"+PORT) + println("Listening on", HOST+":"+PORT) + if err != nil { + log.Fatal(err) + os.Exit(1) + } + // close listener + defer listen.Close() + for { + conn, err := listen.Accept() + if err != nil { + log.Fatal(err) + os.Exit(1) + } + go handleRequest(conn) + } +} + +func handleRequest(conn net.Conn) { + // incoming request + buffer := make([]byte, 1024) + _, err := conn.Read(buffer) + if err != nil { + log.Fatal(err) + } + + // write data to response + time := time.Now().Format(time.ANSIC) + fmt.Printf("Message recived: %v. Received time: %v", string(buffer[:]), time) + conn.Write([]byte("1")) + // conn.Write([]byte(responseStr)) + + // close conn + conn.Close() +}