[_] feat: allow empty files in workspace

migrations/20260116150327-add-user-id-to-file-versions.js

@@ -0,0 +1,23 @@
+'use strict';
+
+const tableName = 'file_versions';
+
+/** @type {import('sequelize-cli').Migration} */
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    await queryInterface.addColumn(tableName, 'user_id', {
+      type: Sequelize.STRING(36),
+      allowNull: false,
+      references: {
+        model: 'users',
+        key: 'uuid',
+      },
+      onUpdate: 'CASCADE',
+      onDelete: 'CASCADE',
+    });
+  },
+
+  async down(queryInterface) {
+    await queryInterface.removeColumn(tableName, 'user_id');
+  },
+};

migrations/20260116150328-add-index-file-versions-user-id-status.js

@@ -0,0 +1,18 @@
+'use strict';
+
+/** @type {import('sequelize-cli').Migration} */
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    await queryInterface.sequelize.query(`
+      CREATE INDEX CONCURRENTLY file_versions_user_id_exists_idx
+      ON file_versions (user_id)
+      WHERE status = 'EXISTS';
+    `);
+  },
+
+  async down(queryInterface, Sequelize) {
+    await queryInterface.sequelize.query(`
+      DROP INDEX CONCURRENTLY IF EXISTS file_versions_user_id_exists_idx;
+    `);
+  }
+};

migrations/20260116154444-update-file-versioning-limits.js

@@ -0,0 +1,94 @@
+'use strict';
+
+const FILE_VERSION_LABELS = {
+  ENABLED: 'file-version-enabled',
+  MAX_SIZE: 'file-version-max-size',
+  RETENTION_DAYS: 'file-version-retention-days',
+  MAX_NUMBER: 'file-version-max-number',
+};
+
+/** @type {import('sequelize-cli').Migration} */
+module.exports = {
+  async up(queryInterface) {
+    await queryInterface.sequelize.query(
+      `UPDATE limits
+       SET value = 'false', updated_at = NOW()
+       FROM tiers_limits tl, tiers t
+       WHERE tl.limit_id = limits.id
+       AND t.id = tl.tier_id
+       AND t.label = 'essential_individual'
+       AND limits.label = :enabledLabel`,
+      { replacements: { enabledLabel: FILE_VERSION_LABELS.ENABLED } },
+    );
+
+    await queryInterface.sequelize.query(
+      `UPDATE limits
+       SET value = '0', updated_at = NOW()
+       FROM tiers_limits tl, tiers t
+       WHERE tl.limit_id = limits.id
+       AND t.id = tl.tier_id
+       AND t.label = 'essential_individual'
+       AND limits.label IN (:counterLabels)`,
+      {
+        replacements: {
+          counterLabels: [
+            FILE_VERSION_LABELS.MAX_SIZE,
+            FILE_VERSION_LABELS.RETENTION_DAYS,
+            FILE_VERSION_LABELS.MAX_NUMBER,
+          ],
+        },
+      },
+    );
+  },
+
+  async down(queryInterface) {
+    await queryInterface.sequelize.query(
+      `UPDATE limits
+       SET value = 'true', updated_at = NOW()
+       FROM tiers_limits tl, tiers t
+       WHERE tl.limit_id = limits.id
+       AND t.id = tl.tier_id
+       AND t.label = 'essential_individual'
+       AND limits.label = :enabledLabel`,
+      { replacements: { enabledLabel: FILE_VERSION_LABELS.ENABLED } },
+    );
+
+    await queryInterface.sequelize.query(
+      `UPDATE limits
+       SET value = :maxSize, updated_at = NOW()
+       FROM tiers_limits tl, tiers t
+       WHERE tl.limit_id = limits.id
+       AND t.id = tl.tier_id
+       AND t.label = 'essential_individual'
+       AND limits.label = :label`,
+      {
+        replacements: {
+          maxSize: String(1 * 1024 * 1024),
+          label: FILE_VERSION_LABELS.MAX_SIZE,
+        },
+      },
+    );
+
+    await queryInterface.sequelize.query(
+      `UPDATE limits
+       SET value = '10', updated_at = NOW()
+       FROM tiers_limits tl, tiers t
+       WHERE tl.limit_id = limits.id
+       AND t.id = tl.tier_id
+       AND t.label = 'essential_individual'
+       AND limits.label = :label`,
+      { replacements: { label: FILE_VERSION_LABELS.RETENTION_DAYS } },
+    );
+
+    await queryInterface.sequelize.query(
+      `UPDATE limits
+       SET value = '1', updated_at = NOW()
+       FROM tiers_limits tl, tiers t
+       WHERE tl.limit_id = limits.id
+       AND t.id = tl.tier_id
+       AND t.label = 'essential_individual'
+       AND limits.label = :label`,
+      { replacements: { label: FILE_VERSION_LABELS.MAX_NUMBER } },
+    );
+  },
+};

migrations/20260116154627-create-deleted-file-versions-table.js

@@ -10,21 +10,17 @@ module.exports = {
         allowNull: false,
         primaryKey: true,
       },
-      file_id: {
-        type: Sequelize.UUID,
-        allowNull: true,
-      },
       network_file_id: {
         type: Sequelize.STRING,
-        allowNull: true,
+        allowNull: false,
       },
       size: {
         type: Sequelize.BIGINT,
-        allowNull: true,
+        allowNull: false,
       },
       processed: {
         type: Sequelize.BOOLEAN,
-        allowNull: true,
+        allowNull: false,
         defaultValue: false,
       },
       created_at: {
@@ -41,7 +37,7 @@ module.exports = {
       },
       enqueued: {
         type: Sequelize.BOOLEAN,
-        allowNull: true,
+        allowNull: false,
         defaultValue: false,
       },
       enqueued_at: {

migrations/20260116154629-deleted-file-versions-function.js

@@ -9,11 +9,13 @@ module.exports = {
       LANGUAGE plpgsql
       AS $function$
       BEGIN
-          IF OLD.status != 'DELETED' AND NEW.status = 'DELETED' THEN
+          IF OLD.status != 'DELETED' AND NEW.status = 'DELETED'
+             AND NEW.network_file_id IS NOT NULL
+             AND NEW.size IS NOT NULL
+             AND NEW.size > 0 THEN
             IF NOT EXISTS (SELECT 1 FROM deleted_file_versions WHERE file_version_id = NEW.id) THEN
                 INSERT INTO deleted_file_versions (
                   file_version_id,
-                  file_id,
                   network_file_id,
                   size,
                   processed,
@@ -22,7 +24,6 @@ module.exports = {
                   updated_at
                 ) VALUES (
                   NEW.id,
-                  NEW.file_id,
                   NEW.network_file_id,
                   NEW.size,
                   false,

migrations/20260120204639-update-cli-access-limits.js

@@ -0,0 +1,140 @@
+'use strict';
+
+const CLI_LIMIT_LABEL = 'cli-access';
+
+const CLI_DISABLED_TIER_LABELS = [
+  // Legacy tiers
+  '200gb_individual',
+  '2tb_individual',
+  '5tb_individual',
+  '10tb_individual',
+  // Current tiers (except ultimate_individual and pro_business)
+  'essential_individual',
+  'premium_individual',
+  'standard_business',
+  'essential_lifetime_individual',
+  'premium_lifetime_individual',
+  'ultimate_lifetime_individual',
+];
+
+/** @type {import('sequelize-cli').Migration} */
+module.exports = {
+  async up(queryInterface) {
+    const transaction = await queryInterface.sequelize.transaction();
+
+    try {
+      const [limits] = await queryInterface.sequelize.query(
+        `SELECT id, value FROM limits WHERE label = :limitLabel`,
+        { replacements: { limitLabel: CLI_LIMIT_LABEL }, transaction },
+      );
+
+      if (limits.length === 0) {
+        throw new Error('CLI access limits not found in database');
+      }
+
+      const disabledLimitId = limits.find((l) => l.value === 'false')?.id;
+      const enabledLimitId = limits.find((l) => l.value === 'true')?.id;
+
+      if (!disabledLimitId || !enabledLimitId) {
+        throw new Error('CLI access enabled or disabled limit not found');
+      }
+
+      const [tiersToDisable] = await queryInterface.sequelize.query(
+        `SELECT id, label FROM tiers WHERE label IN (:labels)`,
+        {
+          replacements: { labels: CLI_DISABLED_TIER_LABELS },
+          transaction,
+        },
+      );
+
+      if (tiersToDisable.length === 0) {
+        console.log(
+          'No tiers found to restrict, skipping CLI access restriction',
+        );
+        await transaction.commit();
+        return;
+      }
+
+      const tierIds = tiersToDisable.map((t) => t.id);
+
+      console.log(
+        `Restricting CLI access for ${tiersToDisable.length} tiers: ${tiersToDisable.map((t) => t.label).join(', ')}`,
+      );
+
+      await queryInterface.sequelize.query(
+        `UPDATE tiers_limits
+         SET limit_id = :disabledLimitId, updated_at = NOW()
+         WHERE tier_id IN (:tierIds)
+           AND limit_id = :enabledLimitId`,
+        {
+          replacements: {
+            disabledLimitId,
+            enabledLimitId,
+            tierIds,
+          },
+          transaction,
+        },
+      );
+
+      await transaction.commit();
+
+      console.log('Successfully restricted CLI access for specified tiers');
+    } catch (error) {
+      await transaction.rollback();
+      throw error;
+    }
+  },
+
+  async down(queryInterface) {
+    const transaction = await queryInterface.sequelize.transaction();
+
+    try {
+      const [limits] = await queryInterface.sequelize.query(
+        `SELECT id, value FROM limits WHERE label = :limitLabel`,
+        { replacements: { limitLabel: CLI_LIMIT_LABEL }, transaction },
+      );
+
+      const disabledLimitId = limits.find((l) => l.value === 'false')?.id;
+      const enabledLimitId = limits.find((l) => l.value === 'true')?.id;
+
+      if (!disabledLimitId || !enabledLimitId) {
+        throw new Error('CLI access limits not found');
+      }
+
+      const [tiers] = await queryInterface.sequelize.query(
+        `SELECT id FROM tiers WHERE label IN (:labels)`,
+        {
+          replacements: { labels: CLI_DISABLED_TIER_LABELS },
+          transaction,
+        },
+      );
+
+      if (tiers.length === 0) {
+        await transaction.commit();
+        return;
+      }
+
+      const tierIds = tiers.map((t) => t.id);
+
+      await queryInterface.sequelize.query(
+        `UPDATE tiers_limits
+         SET limit_id = :enabledLimitId, updated_at = NOW()
+         WHERE tier_id IN (:tierIds)
+           AND limit_id = :disabledLimitId`,
+        {
+          replacements: {
+            disabledLimitId,
+            enabledLimitId,
+            tierIds,
+          },
+          transaction,
+        },
+      );
+
+      await transaction.commit();
+    } catch (error) {
+      await transaction.rollback();
+      throw error;
+    }
+  },
+};