--- a/streams.go Sat Oct 21 21:18:11 2017 +0200
+++ b/streams.go Sat Oct 28 22:43:54 2017 +0200
@@ -129,13 +129,13 @@
}
obj = notif
case "delete":
- floatPayload, ok := msg.Payload.(float64)
+ strPayload, ok := msg.Payload.(string)
if !ok {
- e := errors.New("could not decode deletion: payload isn't a number")
+ e := errors.New("could not decode deletion: payload isn't a string")
events <- StreamEvent{Event: "error", Error: e}
continue
}
- obj = int64(floatPayload) // statusID
+ obj = strPayload // statusID
default:
e := errors.Errorf("unhandled event '%s'", msg.Event)
events <- StreamEvent{Event: "error", Error: e}