From 2185e3b4387d22a511a8c765d8515edbeaf3ec31 Mon Sep 17 00:00:00 2001 From: skeris Date: Thu, 30 May 2024 21:16:31 +0300 Subject: [PATCH] debug: add check nil authCode --- internal/workers/queueUpdater/queue_updater.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/internal/workers/queueUpdater/queue_updater.go b/internal/workers/queueUpdater/queue_updater.go index 9c85e58..e010e10 100644 --- a/internal/workers/queueUpdater/queue_updater.go +++ b/internal/workers/queueUpdater/queue_updater.go @@ -129,6 +129,10 @@ func (wc *QueueUpdater) processMessages(ctx context.Context, message models.Kafk } case models.UserCreate: + if message.AuthCode == nil { + return nil + } + token, err := wc.methods.CreateUserFromWebHook(ctx, message.AccountID, *message.AuthCode) if err != nil { wc.logger.Error("error creating user from webhook request", zap.Error(err))