From 54de3a7791300d6e8d39fbcebe44f3efaf7b8159 Mon Sep 17 00:00:00 2001
From: Philipinho <16838612+Philipinho@users.noreply.github.com>
Date: Mon, 27 Apr 2026 01:22:09 +0100
Subject: [PATCH] refactor(base): update task files to use renamed repo methods

---
 .../src/core/base/tasks/base-formula-recompute.task.ts      | 6 +++---
 .../server/src/core/base/tasks/base-type-conversion.task.ts | 4 ++--
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/apps/server/src/core/base/tasks/base-formula-recompute.task.ts b/apps/server/src/core/base/tasks/base-formula-recompute.task.ts
index a024c7793..6c27d9bd9 100644
--- a/apps/server/src/core/base/tasks/base-formula-recompute.task.ts
+++ b/apps/server/src/core/base/tasks/base-formula-recompute.task.ts
@@ -31,7 +31,7 @@ export async function processBaseFormulaRecompute(
   },
 ): Promise<{ processed: number; errored: number }> {
   const { baseId, workspaceId, propertyIds, rowIds } = data;
-  const properties = await basePropertyRepo.findByBaseId(baseId);
+  const properties = await basePropertyRepo.findByPageId(baseId);
   const targets = properties.filter(
     (p) => p.type === "formula" && propertyIds.includes(p.id),
   );
@@ -46,7 +46,7 @@ export async function processBaseFormulaRecompute(
   let processed = 0;
   let errored = 0;
 
-  for await (const chunk of baseRowRepo.streamByBaseId(baseId, {
+  for await (const chunk of baseRowRepo.streamByPageId(baseId, {
     workspaceId,
     chunkSize: CHUNK_SIZE,
     trx: opts?.trx,
@@ -90,7 +90,7 @@ export async function processBaseFormulaRecompute(
       // so passing actorId: undefined preserves last_updated_by_id while still
       // bumping updated_at — matches spec "only lastEditedAt moves".
       await baseRowRepo.batchUpdateCells(updates, {
-        baseId,
+        pageId: baseId,
         workspaceId,
         actorId: undefined,
         trx: opts?.trx,
diff --git a/apps/server/src/core/base/tasks/base-type-conversion.task.ts b/apps/server/src/core/base/tasks/base-type-conversion.task.ts
index c5fe8c7cc..fc1987b88 100644
--- a/apps/server/src/core/base/tasks/base-type-conversion.task.ts
+++ b/apps/server/src/core/base/tasks/base-type-conversion.task.ts
@@ -59,7 +59,7 @@ export async function processBaseTypeConversion(
   // rewriting — everything else is already consistent with the new type
   // (empty value → empty value). Skips the full-table scan on bases
   // where the property was only ever set on a few rows.
-  for await (const chunk of baseRowRepo.streamByBaseId(baseId, {
+  for await (const chunk of baseRowRepo.streamByPageId(baseId, {
     workspaceId,
     chunkSize: CHUNK_SIZE,
     trx,
@@ -105,7 +105,7 @@ export async function processBaseTypeConversion(
 
     if (updates.length > 0) {
       await baseRowRepo.batchUpdateCells(updates, {
-        baseId,
+        pageId: baseId,
         workspaceId,
         actorId,
         trx,