1 files changed, 69 insertions, 0 deletions

diff --git a/inform/tx_messages.go b/inform/tx_messages.go
new file mode 100644
index 0000000..0021ef3
--- /dev/null
+++ b/inform/tx_messages.go
@@ -0,0 +1,69 @@
+package inform
+
+// Messages we send to devices
+
+import (
+        "strconv"
+        "time"
+)
+
+type CommandMessage struct {
+        Id         string `json:"_id,omitempty"`
+        Type       string `json:"_type"`
+        Command    string `json:"cmd"`
+        DateTime   string `json:"datetime"`
+        DeviceId   string `json:"device_id,omitempty"`
+        MacAddress string `json:"mac,omitempty"`
+        Model      string `json:"model,omitempty"`
+        OffVoltage int    `json:"off_volt,omitempty"`
+        Port       int    `json:"port"`
+        SensorId   string `json:"sId,omitempty"`
+        ServerTime string `json:"server_time_in_utc"`
+        Time       int64  `json:"time"`
+        Timer      int    `json:"timer"`
+        Value      int    `json:"val"`
+        Voltage    int    `json:"volt,omitempty"`
+}
+
+func NewOutputCommand(port, val, timer int) *CommandMessage {
+        return &CommandMessage{
+                Type:       "cmd",
+                Command:    "mfi-output",
+                DateTime:   time.Now().Format(time.RFC3339),
+                Port:       port,
+                ServerTime: unixMicroPSTString(),
+                Time:       unixMicroPST(),
+                Timer:      timer,
+                Value:      val,
+        }
+}
+
+type NoopMessage struct {
+        Type          string `json:"_type"`
+        Interval      int    `json:"interval"`
+        ServerTimeUTC string `json:"server_time_in_utc"`
+}
+
+func unixMicroPST() int64 {
+        l, _ := time.LoadLocation("America/Los_Angeles")
+        tnano := time.Now().In(l).UnixNano()
+        return tnano / int64(time.Millisecond)
+}
+
+func unixMicroPSTString() string {
+        return strconv.FormatInt(unixMicroPST(), 10)
+}
+
+func unixMicroUTCString() string {
+        tnano := time.Now().UTC().UnixNano()
+        t := tnano / int64(time.Millisecond)
+        return strconv.FormatInt(t, 10)
+}
+
+func NewNoop(interval int) *NoopMessage {
+        return &NoopMessage{
+                Type:          "noop",
+                Interval:      interval,
+                ServerTimeUTC: unixMicroUTCString(),
+        }
+}