r3events package

[svn42.git] / go / r3-eventbroker_zmq / r3events / marshal_events.go

diff --git a/go/r3-eventbroker_zmq/r3events/marshal_events.go b/go/r3-eventbroker_zmq/r3events/marshal_events.go
new file mode 100644 (file)
index 0000000..d00d462
--- /dev/null
+++ b/go/r3-eventbroker_zmq/r3events/marshal_events.go
@@ -0,0 +1,66 @@
+// (c) Bernhard Tittelbach, 2013
+
+package r3events
+
+import (
+    "encoding/json"
+    "fmt"
+    "errors"
+    "strings"
+    )
+
+
+func MarshalEvent2ByteByte(event_interface interface{}) (data [][]byte, err error) {
+    var msg []byte
+    fmt.Printf("%T%+v\n", event_interface, event_interface)
+       msg, err = json.Marshal(event_interface)
+       if err != nil {
+               return
+       }
+    etype := fmt.Sprintf("%T", event_interface)
+    etype_lastsep := strings.LastIndex(etype,".")
+    data = [][]byte{[]byte(etype[etype_lastsep+1:]), msg} //works in all cases for etype_lastsep in range -1 to len(etype)-1
+    return
+}
+
+func UnmarshalByteByte2Event(data [][]byte) (event interface{}, err error) {
+    if len(data) != 2 {
+        return nil, errors.New("not a r3event message")
+    }
+    switch string(data[0]) {
+        case "DoorLockUpdate":
+            event = new(DoorLockUpdate)
+            err = json.Unmarshal(data[1],event)
+        case "DoorAjarUpdate":
+            event := new(DoorAjarUpdate)
+            err = json.Unmarshal(data[1], event)
+        case "DoorCommandEvent":
+            event := new(DoorCommandEvent)
+            err = json.Unmarshal(data[1], event)
+        case "ButtonPressUpdate":
+            event := new(ButtonPressUpdate)
+            err = json.Unmarshal(data[1], event)
+        case "TempSensorUpdate":
+            event := new(TempSensorUpdate)
+            err = json.Unmarshal(data[1], event)
+        case "IlluminationSensorUpdate":
+            event := new(IlluminationSensorUpdate)
+            err = json.Unmarshal(data[1], event)
+        case "TimeTick":
+            event := new(TimeTick)
+            err = json.Unmarshal(data[1], event)
+        case "MovementSensorUpdate":
+            event := new(MovementSensorUpdate)
+            err = json.Unmarshal(data[1], event)
+        case "PresenceUpdate":
+            event := new(PresenceUpdate)
+            err = json.Unmarshal(data[1], event)
+        case "SomethingReallyIsMoving":
+            event := new(SomethingReallyIsMoving)
+            err = json.Unmarshal(data[1], event)
+        default:
+            event = nil
+            err = errors.New("cannot unmarshal unknown type")
+    }
+    return
+}