From 3cea6ea2621a490fadf7f4d2d86d652b294430ae Mon Sep 17 00:00:00 2001
From: Ian Gulliver <flamingcow@gmail.com>
Date: Thu, 10 Mar 2016 17:07:44 -0800
Subject: [PATCH] Read input from stdin, push to stderr. Baby's first go

---
 sinks/adsb-ws/input.go | 18 ++++++++++++++++++
 sinks/adsb-ws/main.go  |  1 +
 2 files changed, 19 insertions(+)
 create mode 100644 sinks/adsb-ws/input.go

diff --git a/sinks/adsb-ws/input.go b/sinks/adsb-ws/input.go
new file mode 100644
index 0000000..7dbe818
--- /dev/null
+++ b/sinks/adsb-ws/input.go
@@ -0,0 +1,18 @@
+package main
+
+import (
+	"log"
+	"os"
+)
+
+func readInput() {
+	for {
+		b1 := make([]byte, 256)
+		n, err := os.Stdin.Read(b1)
+		if err != nil {
+			log.Printf("error: %v", err)
+			break
+		}
+		log.Println(n, b1)
+	}
+}
diff --git a/sinks/adsb-ws/main.go b/sinks/adsb-ws/main.go
index 522f35a..8737edc 100644
--- a/sinks/adsb-ws/main.go
+++ b/sinks/adsb-ws/main.go
@@ -10,6 +10,7 @@ var addr = flag.String("addr", ":8080", "http service address")
 
 func main() {
 	flag.Parse()
+	go readInput()
 	http.HandleFunc("/stream", serveStream)
 	err := http.ListenAndServe(*addr, nil)
 	if err != nil {