From d5da4fd9d6dc1a05faf9e4f8e611fa646ff7ae82 Mon Sep 17 00:00:00 2001 From: Ian Gulliver Date: Thu, 10 Mar 2016 17:59:24 -0800 Subject: [PATCH] Actually parsing packets --- sinks/adsb-ws/input.go | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/sinks/adsb-ws/input.go b/sinks/adsb-ws/input.go index ccfe0b4..7704008 100644 --- a/sinks/adsb-ws/input.go +++ b/sinks/adsb-ws/input.go @@ -5,6 +5,8 @@ import ( "errors" "log" "os" + + "github.com/adsb-tools/sinks/adsb-ws/proto" ) func decodeVarint(r *bufio.Reader) (n uint64, err error) { @@ -53,7 +55,13 @@ func readInput() { log.Printf("short read") break } - log.Println(buf) + packet := new(adsb.Adsb) + err = packet.Unmarshal(buf) + if err != nil { + log.Printf("error: %v", err) + break + } + log.Println(packet) } os.Exit(1) }