@@ -20,8 +20,8 @@ func APIKeyAuth(logger telemetry.Logger, tracer telemetry.Tracer, userRepository
 		ctxLogger := tracer.CtxLogger(logger, span)
 
 		apiKey := c.Get(authHeaderAPIKey)
-		if len(apiKey) == 0 {
-			span.AddEvent(fmt.Sprintf("the request header has no [%s] api key", authHeaderAPIKey))
+		if len(apiKey) == 0 || apiKey == "undefined" {
+			span.AddEvent(fmt.Sprintf("the request header has no [%s] header", authHeaderAPIKey))
 			return c.Next()
 		}
 
@@ -30,11 +30,8 @@ func APIKeyAuth(logger telemetry.Logger, tracer telemetry.Tracer, userRepository
 			ctxLogger.Error(stacktrace.Propagate(err, fmt.Sprintf("cannot load user with api key [%s]", apiKey)))
 			return c.Next()
 		}
-
 		c.Locals(ContextKeyAuthUserID, authUser)
-
 		ctxLogger.Info(fmt.Sprintf("[%T] set successfully for user with ID [%s]", authUser, authUser.ID))
-
 		return c.Next()
 	}
 }
@@ -33,8 +33,8 @@ func BearerAuth(logger telemetry.Logger, tracer telemetry.Tracer, authClient *au
 
 		token, err := authClient.VerifyIDToken(context.Background(), authToken)
 		if err != nil {
-			msg := fmt.Sprintf("invalid firebase id token %s", authToken)
-			ctxLogger.Error(tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg)))
+			msg := fmt.Sprintf("invalid firebase id token [%s]", authToken)
+			ctxLogger.Warn(tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg)))
 			return c.Next()
 		}
 
 
@@ -6,6 +6,7 @@ import (
 	"fmt"
 
 	"github.com/google/uuid"
+	"gorm.io/gorm/clause"
 
 	"github.com/NdoleStudio/httpsms/pkg/entities"
 	"github.com/NdoleStudio/httpsms/pkg/telemetry"
@@ -78,7 +79,12 @@ func (repository *gormPhoneRepository) Save(ctx context.Context, phone *entities
 	ctx, span := repository.tracer.Start(ctx)
 	defer span.End()
 
-	if err := repository.db.WithContext(ctx).Save(phone).Error; err != nil {
+	err := repository.db.
+		Clauses(clause.OnConflict{DoNothing: true, OnConstraint: "idx__phones__user_id__phone_number"}).
+		WithContext(ctx).
+		Save(phone).
+		Error
+	if err != nil {
 		msg := fmt.Sprintf("cannot save phone with ID [%s]", phone.ID)
 		return repository.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))
 	}
 
@@ -487,8 +487,8 @@ func (service *MessageService) HandleMessageDelivered(ctx context.Context, param
 		return service.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))
 	}
 
-	if !message.IsSent() && !message.IsSending() && !message.IsExpired() {
-		msg := fmt.Sprintf("message has wrong status [%s]. expected [%s, %s, %s]", message.Status, entities.MessageStatusSent, entities.MessageStatusSending, entities.MessageStatusExpired)
+	if !message.IsSent() && !message.IsSending() && !message.IsExpired() && !message.IsScheduled() {
+		msg := fmt.Sprintf("message has wrong status [%s]. expected [%s, %s, %s, %s]", message.Status, entities.MessageStatusSent, entities.MessageStatusScheduled, entities.MessageStatusSending, entities.MessageStatusExpired)
 		return service.tracer.WrapErrorSpan(span, stacktrace.NewError(msg))
 	}
Original file line number	Diff line number	Diff line change
`@@ -20,8 +20,8 @@ func APIKeyAuth(logger telemetry.Logger, tracer telemetry.Tracer, userRepository`
`20`	`20`	`ctxLogger := tracer.CtxLogger(logger, span)`
`21`	`21`
`22`	`22`	`apiKey := c.Get(authHeaderAPIKey)`
`23`		`- if len(apiKey) == 0 {`
`24`		`- span.AddEvent(fmt.Sprintf("the request header has no [%s] api key", authHeaderAPIKey))`
	`23`	`+ if len(apiKey) == 0 \|\| apiKey == "undefined" {`
	`24`	`+ span.AddEvent(fmt.Sprintf("the request header has no [%s] header", authHeaderAPIKey))`
`25`	`25`	`return c.Next()`
`26`	`26`	`}`
`27`	`27`
`@@ -30,11 +30,8 @@ func APIKeyAuth(logger telemetry.Logger, tracer telemetry.Tracer, userRepository`
`30`	`30`	`ctxLogger.Error(stacktrace.Propagate(err, fmt.Sprintf("cannot load user with api key [%s]", apiKey)))`
`31`	`31`	`return c.Next()`
`32`	`32`	`}`
`33`		`-`
`34`	`33`	`c.Locals(ContextKeyAuthUserID, authUser)`
`35`		`-`
`36`	`34`	`ctxLogger.Info(fmt.Sprintf("[%T] set successfully for user with ID [%s]", authUser, authUser.ID))`
`37`		`-`
`38`	`35`	`return c.Next()`
`39`	`36`	`}`
`40`	`37`	`}`
Original file line number	Diff line number	Diff line change
`@@ -33,8 +33,8 @@ func BearerAuth(logger telemetry.Logger, tracer telemetry.Tracer, authClient *au`
`33`	`33`
`34`	`34`	`token, err := authClient.VerifyIDToken(context.Background(), authToken)`
`35`	`35`	`if err != nil {`
`36`		`- msg := fmt.Sprintf("invalid firebase id token %s", authToken)`
`37`		`- ctxLogger.Error(tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg)))`
	`36`	`+ msg := fmt.Sprintf("invalid firebase id token [%s]", authToken)`
	`37`	`+ ctxLogger.Warn(tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg)))`
`38`	`38`	`return c.Next()`
`39`	`39`	`}`
`40`	`40`
Original file line number	Diff line number	Diff line change
`@@ -487,8 +487,8 @@ func (service *MessageService) HandleMessageDelivered(ctx context.Context, param`
`487`	`487`	`return service.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))`
`488`	`488`	`}`
`489`	`489`
`490`		`- if !message.IsSent() && !message.IsSending() && !message.IsExpired() {`
`491`		`- msg := fmt.Sprintf("message has wrong status [%s]. expected [%s, %s, %s]", message.Status, entities.MessageStatusSent, entities.MessageStatusSending, entities.MessageStatusExpired)`
	`490`	`+ if !message.IsSent() && !message.IsSending() && !message.IsExpired() && !message.IsScheduled() {`
	`491`	`+ msg := fmt.Sprintf("message has wrong status [%s]. expected [%s, %s, %s, %s]", message.Status, entities.MessageStatusSent, entities.MessageStatusScheduled, entities.MessageStatusSending, entities.MessageStatusExpired)`
`492`	`492`	`return service.tracer.WrapErrorSpan(span, stacktrace.NewError(msg))`
`493`	`493`	`}`
`494`	`494`