[pull] main from activepieces:main

packages/server/api/src/app/database/migration/postgres/1769084311004-AddEventStreaming.ts

@@ -82,10 +82,10 @@ export class AddEventStreaming1769084311004 implements MigrationInterface {
             ADD "todosEnabled" boolean NOT NULL
         `)
         await queryRunner.query(`
-            DROP INDEX "public"."idx_event_destination_project_scope"
+            DROP INDEX "idx_event_destination_project_scope"
         `)
         await queryRunner.query(`
-            DROP INDEX "public"."idx_event_destination_platform_scope"
+            DROP INDEX "idx_event_destination_platform_scope"
         `)
         await queryRunner.query(`
             DROP TABLE "event_destination"

packages/server/api/src/app/database/migration/postgres/1769084419658-AddEventStreaming.ts

@@ -71,10 +71,10 @@ export class AddEventStreaming1769084419658 implements MigrationInterface {
             ADD "todosEnabled" boolean NOT NULL
         `)
         await queryRunner.query(`
-            DROP INDEX "public"."idx_event_destination_project_scope"
+            DROP INDEX "idx_event_destination_project_scope"
         `)
         await queryRunner.query(`
-            DROP INDEX "public"."idx_event_destination_platform_scope"
+            DROP INDEX "idx_event_destination_platform_scope"
         `)
         await queryRunner.query(`
             DROP TABLE "event_destination"

packages/server/api/src/app/database/migration/postgres/1769136998805-AddRecordIdToCellEntity.ts

@@ -0,0 +1,18 @@
+import { MigrationInterface, QueryRunner } from 'typeorm'
+
+export class AddRecordIdToCellEntity1769136998805 implements MigrationInterface {
+    name = 'AddRecordIdToCellEntity1769136998805'
+
+    public async up(queryRunner: QueryRunner): Promise<void> {
+        await queryRunner.query(`
+            CREATE INDEX "idx_cell_record_id" ON "cell" ("recordId")
+        `)
+    }
+
+    public async down(queryRunner: QueryRunner): Promise<void> {
+        await queryRunner.query(`
+            DROP INDEX "idx_cell_record_id"
+        `)
+    }
+
+}

packages/server/api/src/app/ee/platform/platform-plan/platform-plan.entity.ts

@@ -119,7 +119,6 @@ export const PlatformPlanEntity = new EntitySchema<PlatformPlanSchema>({
         },
         tablesEnabled: {
             type: Boolean,
-            nullable: true,
         },
         activeFlowsLimit: {
             type: Number,

packages/server/api/src/app/pieces/metadata/local-piece-cache.ts

@@ -2,10 +2,10 @@ import path from 'path'
 import { pieceTranslation } from '@activepieces/pieces-framework'
 import { AppSystemProp, filePiecesUtils, memoryLock, rejectedPromiseHandler } from '@activepieces/server-shared'
 import { ApEnvironment, apId, isEmpty, isNil, LocalesEnum, PackageType, PieceType } from '@activepieces/shared'
+import KeyvSqlite from '@keyv/sqlite'
 import dayjs from 'dayjs'
 import { FastifyBaseLogger } from 'fastify'
 import Keyv from 'keyv'
-import KeyvSqlite from '@keyv/sqlite'
 import cron from 'node-cron'
 import semVer from 'semver'
 import { repoFactory } from '../../core/db/repo-factory'
@@ -233,7 +233,7 @@ async function getOrCreateCache(): Promise<KVCacheInstance> {
                 return cacheInstance
             }
             const baseDir = system.getOrThrow(AppSystemProp.CONFIG_PATH)
-            const dbPath = path.join(baseDir, 'pieces-cache-db.sqlite')
+            const dbPath = path.resolve(path.join(baseDir, 'pieces-cache-db.sqlite'))
             const db = new Keyv({
                 store: new KeyvSqlite(`sqlite://${dbPath}`),
             })

packages/server/api/src/app/tables/record/cell.entity.ts

@@ -34,6 +34,10 @@ export const CellEntity = new EntitySchema<CellSchema>({
             columns: ['projectId', 'fieldId', 'recordId'],
             unique: true,
         },
+        {
+            name: 'idx_cell_record_id',
+            columns: ['recordId'],
+        },
     ],
     relations: {
         record: {