Skip to content

Commit

Permalink
feat: use the queue for interests created events
Browse files Browse the repository at this point in the history
  • Loading branch information
akurilov committed Aug 1, 2024
1 parent c177d3a commit d4f9e6a
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion main.go
Original file line number Diff line number Diff line change
Expand Up @@ -388,7 +388,7 @@ func consumeQueueInterestsCreated(ctx context.Context, svcReader reader.Service,
userId = userIdAttr.GetCeString()
}
if !strings.HasPrefix(userId, service.PrefixUserId) {
err = status.Error(codes.InvalidArgument, fmt.Sprintf("User id should have prefix: %s, got: %s", service.PrefixUserId, userId))
continue
}
var chatId int64
if err == nil {
Expand Down

0 comments on commit d4f9e6a

Please sign in to comment.