backend for xcvr appview
some things
+68
-18
+68
-18
server/internal/atplistener/jetstream.go
+68
-18
server/internal/atplistener/jetstream.go
···
103
103
var pr lex.ProfileRecord
104
104
err := json.Unmarshal(event.Commit.Record, &pr)
105
105
if err != nil {
106
-
return errors.New("error unmarshaling: " + err.Error())
106
+
h.l.Println("error unmarshaling: " + err.Error())
107
+
return nil
108
+
}
109
+
err = h.rm.AcceptProfile(pr, event.Did, ctx)
110
+
if err != nil {
111
+
h.l.Println(err.Error())
107
112
}
108
-
return h.rm.AcceptProfile(pr, event.Did, ctx)
113
+
return nil
109
114
}
110
115
111
116
func (h *handler) handleProfileDelete(ctx context.Context, event *models.Event) error {
112
-
return h.rm.DeleteProfile(event.Did, event.Commit.CID, ctx)
117
+
err := h.rm.DeleteProfile(event.Did, event.Commit.CID, ctx)
118
+
if err != nil {
119
+
h.l.Println(err.Error())
120
+
}
121
+
return nil
113
122
}
114
123
115
124
func (h *handler) handleChannel(ctx context.Context, event *models.Event) error {
···
128
137
func (h *handler) handleChannelCreate(ctx context.Context, event *models.Event) error {
129
138
channel, err := parseChannelRecord(event)
130
139
if err != nil {
131
-
return errors.New("i couldn't create the channel: " + err.Error())
140
+
h.l.Println("i couldn't create the channel: " + err.Error())
141
+
return nil
142
+
}
143
+
err = h.rm.AcceptChannel(channel, ctx)
144
+
if err != nil {
145
+
h.l.Println(err.Error())
132
146
}
133
-
return h.rm.AcceptChannel(channel, ctx)
147
+
return nil
134
148
}
135
149
136
150
func (h *handler) handleChannelUpdate(ctx context.Context, event *models.Event) error {
137
151
channel, err := parseChannelRecord(event)
138
152
if err != nil {
139
-
return errors.New("i couldn't create the channel: " + err.Error())
153
+
h.l.Println("i couldn't create the channel: " + err.Error())
154
+
return nil
155
+
}
156
+
err = h.rm.AcceptChannelUpdate(channel, ctx)
157
+
if err != nil {
158
+
h.l.Println(err.Error())
140
159
}
141
-
return h.rm.AcceptChannelUpdate(channel, ctx)
160
+
return nil
142
161
}
143
162
144
163
func parseChannelRecord(event *models.Event) (*types.Channel, error) {
···
164
183
}
165
184
166
185
func (h *handler) handleChannelDelete(ctx context.Context, event *models.Event) error {
167
-
return h.rm.AcceptChannelDelete(URI(event), ctx)
186
+
err := h.rm.AcceptChannelDelete(URI(event), ctx)
187
+
if err != nil {
188
+
h.l.Println(err.Error())
189
+
}
190
+
return nil
168
191
}
169
192
170
193
func (h *handler) handleMessage(ctx context.Context, event *models.Event) error {
···
183
206
func (h *handler) handleMessageCreate(ctx context.Context, event *models.Event) error {
184
207
message, err := parseMessageRecord(event)
185
208
if err != nil {
186
-
return errors.New("error parsing: " + err.Error())
209
+
h.l.Println("error parsing: " + err.Error())
187
210
}
188
-
return h.rm.AcceptMessage(message, ctx)
211
+
err = h.rm.AcceptMessage(message, ctx)
212
+
if err != nil {
213
+
h.l.Println(err.Error())
214
+
}
215
+
return nil
189
216
}
190
217
191
218
func (h *handler) handleMessageUpdate(ctx context.Context, event *models.Event) error {
192
219
message, err := parseMessageRecord(event)
193
220
if err != nil {
194
-
return errors.New("error parsing: " + err.Error())
221
+
return nil
222
+
h.l.Println("error parsing: " + err.Error())
223
+
}
224
+
err = h.rm.AcceptMessageUpdate(message, event.Did, ctx)
225
+
if err != nil {
226
+
h.l.Println(err.Error())
195
227
}
196
-
return h.rm.AcceptMessageUpdate(message, event.Did, ctx)
228
+
return nil
197
229
}
198
230
199
231
func (h *handler) handleMessageDelete(ctx context.Context, event *models.Event) error {
200
-
return h.rm.AcceptMessageDelete(URI(event), ctx)
232
+
err := h.rm.AcceptMessageDelete(URI(event), ctx)
233
+
if err != nil {
234
+
h.l.Println(err.Error())
235
+
}
236
+
return nil
201
237
}
202
238
203
239
func parseMessageRecord(event *models.Event) (*types.Message, error) {
···
244
280
func (h *handler) handleSignetCreate(ctx context.Context, event *models.Event) error {
245
281
signet, err := parseSignetRecord(event)
246
282
if err != nil {
247
-
return errors.New("failed to parse: " + err.Error())
283
+
h.l.Println("failed to parse: " + err.Error())
284
+
return nil
285
+
}
286
+
err = h.rm.AcceptSignet(signet, ctx)
287
+
if err != nil {
288
+
h.l.Println(err.Error())
248
289
}
249
-
return h.rm.AcceptSignet(signet, ctx)
290
+
return nil
250
291
}
251
292
252
293
func (h *handler) handleSignetUpdate(ctx context.Context, event *models.Event) error {
253
294
signet, err := parseSignetRecord(event)
254
295
if err != nil {
255
-
return errors.New("failed to parse: " + err.Error())
296
+
h.l.Println("failed to parse: " + err.Error())
297
+
return nil
298
+
}
299
+
err = h.rm.AcceptSignetUpdate(signet, ctx)
300
+
if err != nil {
301
+
h.l.Println(err.Error())
256
302
}
257
-
return h.rm.AcceptSignetUpdate(signet, ctx)
303
+
return nil
258
304
}
259
305
func (h *handler) handleSignetDelete(ctx context.Context, event *models.Event) error {
260
-
return h.rm.AcceptSignetDelete(URI(event), ctx)
306
+
err := h.rm.AcceptSignetDelete(URI(event), ctx)
307
+
if err != nil {
308
+
h.l.Println(err.Error())
309
+
}
310
+
return nil
261
311
}
262
312
263
313
func parseSignetRecord(event *models.Event) (*types.Signet, error) {