Add bufferflow timedraw

encodes data in base64 so it needs to be decoded on the other side

Author: facchinm

bufferflow.go

@@ -5,7 +5,7 @@ import (
 //"time"
 )
 
-var availableBufferAlgorithms = []string{"default", "timed"}
+var availableBufferAlgorithms = []string{"default", "timed", "timedraw"}
 
 type BufferMsg struct {
 	Cmd                string

bufferflow_timedraw.go

@@ -0,0 +1,102 @@
+package main
+
+import (
+	"encoding/json"
+	"time"
+
+	log "github.com/Sirupsen/logrus"
+)
+
+type BufferflowTimedRaw struct {
+	Name   string
+	Port   string
+	Output chan []byte
+	Input  chan string
+	ticker *time.Ticker
+}
+
+var (
+	bufferedOutputRaw []byte
+)
+
+func (b *BufferflowTimedRaw) Init() {
+	log.Println("Initting timed buffer flow (output once every 16ms)")
+
+	go func() {
+		for data := range b.Input {
+			bufferedOutputRaw = append(bufferedOutputRaw, []byte(data)...)
+		}
+	}()
+
+	go func() {
+		b.ticker = time.NewTicker(16 * time.Millisecond)
+		for _ = range b.ticker.C {
+			if len(bufferedOutputRaw) != 0 {
+				m := SpPortMessageRaw{bufferedOutputRaw}
+				buf, _ := json.Marshal(m)
+				// data is now encoded in base64 format
+				// need a decoder on the other side
+				b.Output <- []byte(buf)
+				bufferedOutputRaw = nil
+			}
+		}
+	}()
+
+}
+
+func (b *BufferflowTimedRaw) BlockUntilReady(cmd string, id string) (bool, bool) {
+	//log.Printf("BlockUntilReady() start\n")
+	return true, false
+}
+
+func (b *BufferflowTimedRaw) OnIncomingData(data string) {
+	b.Input <- data
+}
+
+// Clean out b.sem so it can truly block
+func (b *BufferflowTimedRaw) ClearOutSemaphore() {
+}
+
+func (b *BufferflowTimedRaw) BreakApartCommands(cmd string) []string {
+	return []string{cmd}
+}
+
+func (b *BufferflowTimedRaw) Pause() {
+	return
+}
+
+func (b *BufferflowTimedRaw) Unpause() {
+	return
+}
+
+func (b *BufferflowTimedRaw) SeeIfSpecificCommandsShouldSkipBuffer(cmd string) bool {
+	return false
+}
+
+func (b *BufferflowTimedRaw) SeeIfSpecificCommandsShouldPauseBuffer(cmd string) bool {
+	return false
+}
+
+func (b *BufferflowTimedRaw) SeeIfSpecificCommandsShouldUnpauseBuffer(cmd string) bool {
+	return false
+}
+
+func (b *BufferflowTimedRaw) SeeIfSpecificCommandsShouldWipeBuffer(cmd string) bool {
+	return false
+}
+
+func (b *BufferflowTimedRaw) SeeIfSpecificCommandsReturnNoResponse(cmd string) bool {
+	return false
+}
+
+func (b *BufferflowTimedRaw) ReleaseLock() {
+}
+
+func (b *BufferflowTimedRaw) IsBufferGloballySendingBackIncomingData() bool {
+	return true
+}
+
+func (b *BufferflowTimedRaw) Close() {
+	b.ticker.Stop()
+	close(b.Input)
+}

serialport.go

@@ -88,6 +88,11 @@ type SpPortMessage struct {
 	D string // the data, i.e. G0 X0 Y0
 }
 
+type SpPortMessageRaw struct {
+	// P string // the port, i.e. com22
+	D []byte // the data, i.e. G0 X0 Y0
+}
+
 func (p *serport) reader() {
 
 	//var buf bytes.Buffer
@@ -344,6 +349,8 @@ func spHandlerOpen(portname string, baud int, buftype string, isSecondary bool)
 
 	if buftype == "timed" {
 		bw = &BufferflowTimed{Name: "timed", Port: portname, Output: h.broadcastSys, Input: make(chan string)}
+	} else if buftype == "timedraw" {
+		bw = &BufferflowTimedRaw{Name: "timedraw", Port: portname, Output: h.broadcastSys, Input: make(chan string)}
 	} else {
 		bw = &BufferflowDefault{Port: portname}
 	}