diff --git a/lexicons.json b/lexicons.json index 94261f2ba..34aca92ef 100644 --- a/lexicons.json +++ b/lexicons.json @@ -217,4 +217,4 @@ "cid": "bafyreic3l2rmh2ugirt3jz372wcvy333m7t2ynlyzj2k54oshijs6lxdfu" } } -} +} \ No newline at end of file diff --git a/pkg/statedb/queue_processor.go b/pkg/statedb/queue_processor.go index 6121483ad..08e42a12b 100644 --- a/pkg/statedb/queue_processor.go +++ b/pkg/statedb/queue_processor.go @@ -507,8 +507,8 @@ func (state *StatefulDB) processStreamReceivedTask(ctx context.Context, task *Ap log.Error(ctx, "failed to convert webhook to lexicon", "err", err, "webhook_id", w.ID) continue } - go func(lexiconWebhook *streamplace.ServerDefs_Webhook, wid string) { - err := webhook.SendStreamReceivedWebhook(ctx, lexiconWebhook, streamReceivedTask.StreamerDID) + go func(lexiconWebhook placestream.ServerDefs_Webhook, wid string) { + err := webhook.SendStreamReceivedWebhook(ctx, &lexiconWebhook, streamReceivedTask.StreamerDID) if err != nil { log.Error(ctx, "failed to send stream.received webhook", "err", err, "webhook_id", wid) err = state.IncrementWebhookError(wid)