feat: wip

apps/web/src/app/(private)/projects/[projectId]/versions/[commitUuid]/documents/[documentUuid]/evaluations/[evaluationId]/layout.tsx

@@ -36,12 +36,14 @@ export default async function ConnectedEvaluationLayout({
     projectId: Number(params.projectId),
     uuid: params.commitUuid,
   })
+
   const aggregationTotals = await getEvaluationTotalsQuery({
     workspaceId: workspace.id,
     documentUuid: params.documentUuid,
     evaluation,
     commit,
   })
+
   const evaluationResults = await computeEvaluationResultsWithMetadata({
     workspaceId: evaluation.workspaceId,
     evaluation,

packages/core/src/services/evaluationResults/aggregations/meanValueQuery.ts

@@ -1,14 +1,51 @@
+import { and, avg, eq, isNotNull, or, sum } from 'drizzle-orm'
+
 import { Commit, Evaluation } from '../../../browser'
+import { database } from '../../../client'
+import { DocumentLogsRepository, EvaluationResultsRepository } from '../../../repositories'
+import { commits } from '../../../schema'
+
+export async function getEvaluationMeanValueQuery(
+  {
+    workspaceId,
+    evaluation,
+    documentUuid,
+    commit,
+  }: {
+    workspaceId: number
+    evaluation: Evaluation
+    documentUuid: string
+    commit: Commit
+  },
+  db = database,
+) {
+  const { scope: evaluationResultsScope } = new EvaluationResultsRepository(
+    workspaceId,
+    db,
+  )
+  const { scope: documentLogsScope } = new DocumentLogsRepository(
+    workspaceId,
+    db,
+  )
+
 
-export async function getEvaluationMeanValueQuery({
-  workspaceId,
-  evaluation,
-  documentUuid,
-  commit,
-}: {
-  workspaceId: number
-  evaluation: Evaluation
-  documentUuid: string
-  commit: Commit
-}) {
+  const results = await db
+    .select({
+      meanValue: avg(evaluationResultsScope.result)
+        .mapWith(Number)
+        .as('meanValue'),
+    })
+    .from(evaluationResultsScope)
+    .innerJoin(commits, eq(commits.id, documentLogsScope.commitId))
+    .innerJoin(
+      documentLogsScope,
+      eq(documentLogsScope.id, evaluationResultsScope.documentLogId),
+    )
+    .where(
+      and(
+        eq(evaluationResultsScope.evaluationId, evaluation.id),
+        eq(evaluationResultsScope.documentUuid, documentUuid),
+        eq(evaluationResultsScope.commitId, commit.id),
+      ),
+    )
 }