From 8367c7a9839db5520f9a5ff6deeca372391474de Mon Sep 17 00:00:00 2001
From: cheetah <git@cheetah.cat>
Date: Wed, 3 Mar 2021 10:12:39 +0100
Subject: [PATCH] added 'function' header param, 0-3

---
 main.go | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git a/main.go b/main.go
index c1fcf0d..63fbeb5 100644
--- a/main.go
+++ b/main.go
@@ -5,7 +5,8 @@ import (
 	"time"
 	"sync"
 	"log"
-	"github.com/kgolding/go-pocsagencode"
+	"github.com/RPIZeroDuplexPOCSAG/go-pocsagencode"
+//	"github.com/kgolding/go-pocsagencode"
 	"github.com/RPIZeroDuplexPOCSAG/rfm69"
 
 	"github.com/davecheney/gpio"
@@ -77,10 +78,15 @@ func main() {
 
 			for msg := range d {
 				if msg.Headers["ric"] == nil { continue }
-				log.Printf("ric: %s", string(msg.Headers["ric"].(int64)))
+				if msg.Headers["function"] == nil { continue }
+
+				log.Printf("ric: %d", uint32(msg.Headers["ric"].(int64)))
+				log.Printf("function %d", byte(msg.Headers["function"].(int64)))
 				log.Printf("msg: %s", string(msg.Body))
+
 				queueMessage(&pocsagencode.Message {
 					Addr: uint32(msg.Headers["ric"].(int64)),
+					Function: uint8(msg.Headers["function"].(int64)),
 					Content: string(msg.Body),
 					IsNumeric: (msg.Headers["numeric"] != nil),
 				})
@@ -175,7 +181,7 @@ func main() {
 		go func() {
 			lastTransmitBatch = time.Now().Unix()
 			for {
-				log.Println(time.Now().Unix(), lastTransmitBatch + 5)
+				//log.Println(time.Now().Unix(), lastTransmitBatch + 5)
 
 				time.Sleep(500 * time.Millisecond)
 				if len(messageQueue) > 0 && (time.Now().Unix() > lastTransmitBatch + 5) {
@@ -187,10 +193,10 @@ func main() {
 					data := &rfm69.Data{
 						Data: burst.Bytes(),
 					}
+					// Make Pocsag Burst
 					rfm.Send(data)
 					messageQueue = make([]*pocsagencode.Message, 0)
 					queueMutex.Unlock()
-					// Make Pocsag Burst
 				}
 			}
 		}()