From f38c183fe8b1e2f3cd0ad4c1bb043d5c1e71112e Mon Sep 17 00:00:00 2001 From: Bel LaPointe <153096461+breel-render@users.noreply.github.com> Date: Tue, 16 Apr 2024 06:53:30 -0600 Subject: [PATCH] stubbing --- model/event.go | 4 ++++ model/message.go | 4 ++++ model/thread.go | 4 ++++ slack.go | 8 ++++++++ 4 files changed, 20 insertions(+) diff --git a/model/event.go b/model/event.go index 0a117fb..81cff1e 100644 --- a/model/event.go +++ b/model/event.go @@ -28,6 +28,10 @@ func NewEvent(ID, URL string, TS uint64, Name, Asset, Datacenter, Team string, R } } +func (e Event) Empty() bool { + return e == (Event{}) +} + func updated() uint64 { return uint64(time.Now().UnixNano() / int64(time.Millisecond)) } diff --git a/model/message.go b/model/message.go index cbd1c36..28bb665 100644 --- a/model/message.go +++ b/model/message.go @@ -22,3 +22,7 @@ func NewMessage(ID, URL string, TS uint64, Author, Plaintext string, ThreadID st ThreadID: ThreadID, } } + +func (m Message) Empty() bool { + return m == (Message{}) +} diff --git a/model/thread.go b/model/thread.go index b5d3b5b..74574e8 100644 --- a/model/thread.go +++ b/model/thread.go @@ -20,3 +20,7 @@ func NewThread(ID, URL string, TS uint64, Channel string, EventID string) Thread EventID: EventID, } } + +func (t Thread) Empty() bool { + return t == (Thread{}) +} diff --git a/slack.go b/slack.go index e9cd912..028d1b7 100644 --- a/slack.go +++ b/slack.go @@ -4,12 +4,20 @@ import ( "context" "errors" "fmt" + + "github.com/breel-render/spoc-bot-vr/model" ) type SlackToModel struct { pipeline Pipeline } +type Models struct { + Event model.Event + Message model.Message + Thread model.Thread +} + func NewSlackToModelPipeline(ctx context.Context, cfg Config) (Pipeline, error) { reader, err := NewQueue(ctx, "slack_event", cfg.driver) if err != nil {