From 5def922d93a67d81bc8f2286e3d17f6cd0991bcd Mon Sep 17 00:00:00 2001 From: Joel Wetzell Date: Tue, 19 May 2026 21:27:21 -0500 Subject: [PATCH] add missing test module --- internal/test/module.go | 29 +++++++++++++++++++++++++++++ 1 file changed, 29 insertions(+) diff --git a/internal/test/module.go b/internal/test/module.go index 5e55883..1aee83b 100644 --- a/internal/test/module.go +++ b/internal/test/module.go @@ -111,3 +111,32 @@ func (m *TestDBModule) Type() string { func (m *TestDBModule) Id() string { return m.id } + +func NewTestPubSubModule(id string) *TestPubSubModule { + return &TestPubSubModule{ + id: id, + } +} + +type TestPubSubModule struct { + id string +} + +func (m *TestPubSubModule) Start(ctx context.Context, router common.RouteIO) error { + <-ctx.Done() + return nil +} + +func (m *TestPubSubModule) Publish(ctx context.Context, topic string, payload any) error { + return nil +} + +func (m *TestPubSubModule) Stop() {} + +func (m *TestPubSubModule) Type() string { + return "test.pubsub" +} + +func (m *TestPubSubModule) Id() string { + return m.id +}