debug: add check nil authCode

2024-05-30 21:16:31 +03:00 · 2024-05-30 21:16:31 +03:00 · 2185e3b438
commit 2185e3b438
parent e8fc02b128
1 changed files with 4 additions and 0 deletions
--- 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))