diff --git a/server/internal/recordmanager/media.go b/server/internal/recordmanager/media.go index 850ad25..59e1aba 100644 --- a/server/internal/recordmanager/media.go +++ b/server/internal/recordmanager/media.go @@ -75,9 +75,21 @@ func (rm *RecordManager) postImageRecord(cs *atoauth.ClientSession, mr *types.Pa if err != nil { return errors.New("beeped that up!: " + err.Error()) } + err = rm.forwardImage(img, ctx) + if err != nil { + return errors.New("YIEKRSa, " + err.Error()) + } return nil } +func (rm *RecordManager) forwardImage(i *types.Image, ctx context.Context) error { + curi, err := rm.db.GetMsgChannelURI(i.SignetURI, ctx) + if err != nil { + return errors.New("failed to get curi: " + err.Error()) + } + return rm.broadcaster.BroadcastImage(curi, i) +} + func (rm *RecordManager) validateImageRecord(mr *types.ParseMediaRequest) (*lex.MediaRecord, *time.Time, error) { var imr lex.MediaRecord imr.SignetURI = mr.SignetURI diff --git a/server/internal/recordmanager/recordmanager.go b/server/internal/recordmanager/recordmanager.go index 055f835..60ea387 100644 --- a/server/internal/recordmanager/recordmanager.go +++ b/server/internal/recordmanager/recordmanager.go @@ -10,6 +10,7 @@ import ( type LexBroadcaster interface { BroadcastSignet(uri string, s *types.Signet) error BroadcastMessage(uri string, m *types.Message) error + BroadcastImage(uri string, i *types.Image) error AddChannel(c *types.Channel) error UpdateChannel(c *types.Channel) error DeleteChannel(uri string) error