Cache invalid API key

Author: AchoArnold

api/pkg/middlewares/http_request_logger_middleware.go

@@ -22,7 +22,7 @@ func HTTPRequestLogger(tracer telemetry.Tracer, logger telemetry.Logger) fiber.H
 
 		statusCode := c.Response().StatusCode()
 		span.AddEvent(fmt.Sprintf("finished handling request with traceID: [%s], statusCode: [%d]", span.SpanContext().TraceID().String(), statusCode))
-		if statusCode >= 300 && len(c.Request().Body()) > 0 {
+		if statusCode >= 300 && len(c.Request().Body()) > 0 && statusCode != 401 {
 			ctxLogger.Warn(stacktrace.NewError(fmt.Sprintf("http.status [%d], body [%s]", statusCode, string(c.Request().Body()))))
 		}
 

api/pkg/repositories/gorm_user_repository.go

@@ -154,12 +154,16 @@ func (repository *gormUserRepository) LoadAuthContext(ctx context.Context, apiKe
 	defer span.End()
 
 	if authUser, found := repository.cache.Get(apiKey); found {
+		if authUser.IsNoop() {
+			return authUser, repository.tracer.WrapErrorSpan(span, stacktrace.NewError(fmt.Sprintf("user with api key [%s] does not exist", apiKey)))
+		}
 		return authUser, nil
 	}
 
 	user := new(entities.User)
 	err := repository.db.WithContext(ctx).Where("api_key = ?", apiKey).First(user).Error
 	if errors.Is(err, gorm.ErrRecordNotFound) {
+		repository.cache.SetWithTTL(apiKey, entities.AuthContext{}, 1, 2*time.Hour)
 		msg := fmt.Sprintf("user with api key [%s] does not exist", apiKey)
 		return entities.AuthContext{}, repository.tracer.WrapErrorSpan(span, stacktrace.PropagateWithCode(err, ErrCodeNotFound, msg))
 	}