diff --git a/internal/repositories/mediaRepository.go b/internal/repositories/mediaRepository.go index 971fd64..feb7ee1 100644 --- a/internal/repositories/mediaRepository.go +++ b/internal/repositories/mediaRepository.go @@ -165,6 +165,8 @@ func (r *mediaRepository) Create(ctx context.Context, params sqlc.CreateMediaPar _ = r.c.DelByPattern(bgCtx, "media:count*") }() + _ = r.c.Del(ctx, fmt.Sprintf("media:userId:%s", convert.UUIDToString(params.UserID))) + media := models.MediaEntity{ ID: convert.UUIDToString(row.ID), UserID: convert.UUIDToString(row.UserID), diff --git a/internal/repositories/verificationRepository.go b/internal/repositories/verificationRepository.go index ee29c99..2640cd8 100644 --- a/internal/repositories/verificationRepository.go +++ b/internal/repositories/verificationRepository.go @@ -212,6 +212,8 @@ func (v *verificationRepository) Create(ctx context.Context, params sqlc.CreateU _ = v.c.DelByPattern(bgCtx, "verification:count*") }() + _ = v.c.Del(ctx, fmt.Sprintf("verification:userId:%s", convert.UUIDToString(params.UserID))) + return &verification, nil } @@ -246,7 +248,7 @@ func (v *verificationRepository) BulkVerificationMediaByMediaId(ctx context.Cont if len(ids) == 0 { return nil } - + listCacheId := make([]string, 0) for _, it := range ids { id := convert.UUIDToString(it) diff --git a/internal/services/commitService.go b/internal/services/commitService.go index 6d21959..d00061e 100644 --- a/internal/services/commitService.go +++ b/internal/services/commitService.go @@ -172,7 +172,7 @@ func (s *commitService) RestoreCommit(ctx context.Context, userID string, projec return fiber.NewError(fiber.StatusInternalServerError, "Failed to restore commit") } - _ = s.c.Del(ctx, fmt.Sprintf("project:id:%s", projectID)) + _ = s.c.Del(ctx, fmt.Sprintf("project:id:%s", projectID), fmt.Sprintf("commit:project:%s", projectID)) return nil } diff --git a/internal/services/submissionService.go b/internal/services/submissionService.go index 8c9da85..a3ab209 100644 --- a/internal/services/submissionService.go +++ b/internal/services/submissionService.go @@ -175,6 +175,8 @@ func (s *submissionService) CreateSubmission(ctx context.Context, userID string, return nil, fiber.NewError(fiber.StatusInternalServerError, "Failed to create submission") } + _ = s.c.Del(ctx, fmt.Sprintf("project:id:%s", project.ID)) + return submission.ToResponse(), nil }