+12

server/internal/recordmanager/media.go

reviewed

··· 75 75 if err != nil { 76 76 return errors.New("beeped that up!: " + err.Error()) 77 77 } 78 78 + err = rm.forwardImage(img, ctx) 79 79 + if err != nil { 80 80 + return errors.New("YIEKRSa, " + err.Error()) 81 81 + } 78 82 return nil 83 83 + } 84 84 + 85 85 + func (rm *RecordManager) forwardImage(i *types.Image, ctx context.Context) error { 86 86 + curi, err := rm.db.GetMsgChannelURI(i.SignetURI, ctx) 87 87 + if err != nil { 88 88 + return errors.New("failed to get curi: " + err.Error()) 89 89 + } 90 90 + return rm.broadcaster.BroadcastImage(curi, i) 79 91 } 80 92 81 93 func (rm *RecordManager) validateImageRecord(mr *types.ParseMediaRequest) (*lex.MediaRecord, *time.Time, error) {

+1

server/internal/recordmanager/recordmanager.go

reviewed

··· 10 10 type LexBroadcaster interface { 11 11 BroadcastSignet(uri string, s *types.Signet) error 12 12 BroadcastMessage(uri string, m *types.Message) error 13 13 + BroadcastImage(uri string, i *types.Image) error 13 14 AddChannel(c *types.Channel) error 14 15 UpdateChannel(c *types.Channel) error 15 16 DeleteChannel(uri string) error