From 8b3fa609dd8808a71e712ae661c0234a384b3c61 Mon Sep 17 00:00:00 2001 From: Wil Simpson Date: Wed, 11 Dec 2024 15:53:47 -0500 Subject: [PATCH] feat: added types for bus writers and readers --- pkg/bus/character/characterbus/message.go | 3 +++ pkg/bus/gameserver/dimensionbus/message.go | 3 +++ pkg/bus/gameserver/mapbus/message.go | 3 +++ 3 files changed, 9 insertions(+) diff --git a/pkg/bus/character/characterbus/message.go b/pkg/bus/character/characterbus/message.go index e2c4c7d..158d2ed 100644 --- a/pkg/bus/character/characterbus/message.go +++ b/pkg/bus/character/characterbus/message.go @@ -19,6 +19,9 @@ type Message struct { Deleted bool `json:"deleted"` } +type BusReader bus.MessageBusReader[Message] +type BusWriter bus.MessageBusWriter[Message] + func (m Message) GetType() bus.BusMessageType { return bus.BusMessageType("sro.character") } diff --git a/pkg/bus/gameserver/dimensionbus/message.go b/pkg/bus/gameserver/dimensionbus/message.go index 9d474c2..661f184 100644 --- a/pkg/bus/gameserver/dimensionbus/message.go +++ b/pkg/bus/gameserver/dimensionbus/message.go @@ -10,6 +10,9 @@ type Message struct { Deleted bool `json:"deleted"` } +type BusReader bus.MessageBusReader[Message] +type BusWriter bus.MessageBusWriter[Message] + func (m Message) GetType() bus.BusMessageType { return bus.BusMessageType("sro.gameserver.dimension") } diff --git a/pkg/bus/gameserver/mapbus/message.go b/pkg/bus/gameserver/mapbus/message.go index 11130a5..f5d651e 100644 --- a/pkg/bus/gameserver/mapbus/message.go +++ b/pkg/bus/gameserver/mapbus/message.go @@ -17,6 +17,9 @@ type Message struct { UpdatedAt time.Time } +type BusReader bus.MessageBusReader[Message] +type BusWriter bus.MessageBusWriter[Message] + func (m Message) GetType() bus.BusMessageType { return bus.BusMessageType("sro.gameserver.map") }