diff --git a/router/websocket/websocket.go b/router/websocket/websocket.go index 3beb715..6298ffe 100644 --- a/router/websocket/websocket.go +++ b/router/websocket/websocket.go @@ -368,9 +368,9 @@ func (h *Handler) HandleInbound(ctx context.Context, m Message) error { return nil } - _ = h.ra.Save(h.server, server.ActivityPower, server.ActivityMeta{ - "signal": string(action), - }) + if err == nil { + _ = h.ra.Save(h.server, server.Event(server.ActivityPowerPrefix+action), nil) + } return err } diff --git a/server/activity.go b/server/activity.go index d15fc21..8396859 100644 --- a/server/activity.go +++ b/server/activity.go @@ -13,8 +13,9 @@ import ( type Event string type ActivityMeta map[string]interface{} +const ActivityPowerPrefix = "power_" + const ( - ActivityPower = Event("power") ActivityConsoleCommand = Event("console_command") )