PR suggestions

Author: Pascal-Delange

usecases/ai_agent/async_case_review.go

@@ -107,8 +107,7 @@ func (w *CaseReviewWorker) Work(ctx context.Context, job *river.Job[models.CaseR
 		return nil
 	}
 
-	var aiCaseReview models.AiCaseReview
-	aiCaseReview, err = w.repository.GetCaseReviewById(ctx, exec, job.Args.AiCaseReviewId)
+	aiCaseReview, err := w.repository.GetCaseReviewById(ctx, exec, job.Args.AiCaseReviewId)
 	switch {
 	case errors.Is(err, models.NotFoundError):
 		aiCaseReview = models.NewAiCaseReview(job.Args.CaseId, w.bucketUrl, job.Args.AiCaseReviewId)

usecases/case_usecase.go

@@ -86,6 +86,9 @@ type CaseUseCaseRepository interface {
 	ListContinuousScreeningsByCaseId(ctx context.Context, exec repositories.Executor, caseId string) ([]models.ContinuousScreening, error)
 	ListContinuousScreeningsByIds(ctx context.Context, exec repositories.Executor, ids []uuid.UUID) ([]models.ContinuousScreening, error)
 	UpdateContinuousScreeningsCaseId(ctx context.Context, exec repositories.Executor, ids []uuid.UUID, caseId string) error
+
+	// inboxes
+	GetInboxById(ctx context.Context, exec repositories.Executor, inboxId uuid.UUID) (models.Inbox, error)
 }
 
 type CaseUsecaseScreeningRepository interface {
@@ -1807,7 +1810,8 @@ func (usecase *CaseUseCase) EscalateCase(ctx context.Context, caseId string) err
 			return errors.Wrap(err, "error checking if AI case review is enabled")
 		}
 		if hasAiCaseReviewEnabled {
-			inbox, err := usecase.inboxReader.GetInboxById(ctx, targetInbox.Id)
+			// direct read through repository, because we may not have permission on this inbox in this situation.
+			inbox, err := usecase.repository.GetInboxById(ctx, exec, targetInbox.Id)
 			if err != nil {
 				return errors.Wrap(err, "error getting inbox")
 			}