-1

server/internal/atplistener/jetstream.go

reviewed

··· 218 218 func (h *handler) handleMessageUpdate(ctx context.Context, event *models.Event) error { 219 219 message, err := parseMessageRecord(event) 220 220 if err != nil { 221 221 - return nil 222 221 h.l.Println("error parsing: " + err.Error()) 223 222 } 224 223 err = h.rm.AcceptMessageUpdate(message, event.Did, ctx)

+1 -1

server/internal/recordmanager/message.go

reviewed

··· 128 128 } 129 129 130 130 func (rm *RecordManager) createMyMessage(lmr *lex.MessageRecord, now *time.Time, ctx context.Context) (*types.Message, error) { 131 131 - uri, cid, err := rm.myClient.CreateXCVRMessage(lmr, ctx) 131 131 + cid, uri, err := rm.myClient.CreateXCVRMessage(lmr, ctx) 132 132 if err != nil { 133 133 return nil, errors.New("couldn't add to user repo: " + err.Error()) 134 134 }