fix: violation of users_email_key on pool users creation

internal/webhooks/serve.go

@@ -85,7 +85,13 @@ func (p *processor) Serve(amqpUrl, channel string) error {
 	for d := range msgs {
 		err := p.handler(d.Body)
 		if err != nil {
-			sentry.CaptureException(err)
+			sentry.CaptureEvent(&sentry.Event{
+				Level: sentry.LevelError,
+				Contexts: map[string]interface{}{
+					"message": string(d.Body),
+				},
+				Message: err.Error(),
+			})
 
 			if errors.Is(err, ErrInvalidWebhook) {
 				goto ACK
@@ -145,18 +151,18 @@ func (p *processor) handler(data []byte) error {
 		// Marshal the payload to the expected format for the github processor
 		// FUTURE: rework it
 		b, err := json.Marshal(md.Payload)
-    if err != nil {
+		if err != nil {
 			log.Error().Err(err).Msg("Failed to marshal payload")
-      return err
-    }
+			return err
+		}
 
 		return p.githubHandler(b)
 	}
 
 	return p.duoHandler(data)
 }
 
-// githubHandler is the processor for the github webhooks. 
+// githubHandler is the processor for the github webhooks.
 func (p *processor) githubHandler(data []byte) error {
 	webhookPayload := &GithubSponsorshipWebhook{}
 	if err := json.Unmarshal(data, &webhookPayload); err != nil {
@@ -207,7 +213,7 @@ func (p *processor) githubHandler(data []byte) error {
 	return err
 }
 
-// duoHandler is the processor for the duo webhooks. 
+// duoHandler is the processor for the duo webhooks.
 func (p *processor) duoHandler(data []byte) error {
 	mdDuo := &duoapi.Webhook{}
 	if err := json.Unmarshal(data, &mdDuo); err != nil {

internal/webhooks/user.go

@@ -21,7 +21,7 @@ func (p *userProcessor) Create(u *duoapi.User, metadata *duoapi.WebhookMetadata)
 		SetEmail(u.Email).
 		SetIsStaff(u.Staff).
 		SetNillableUsualFirstName(&u.UsualFirstName).
-		OnConflictColumns(user.FieldDuoID).
+		OnConflictColumns(user.FieldDuoID, user.FieldDuoLogin, user.FieldEmail).
 		UpdateNewValues().
 		Exec(p.ctx)
 }