Function cleanupWorkspaceFileStorage

apps/sim/background/cleanup-soft-deletes.ts:101–129

(
  scope: WorkspaceFileScope
)

}

async function cleanupWorkspaceFileStorage(
  scope: WorkspaceFileScope
): Promise<{ filesDeleted: number; filesFailed: number }> {
  const stats = { filesDeleted: 0, filesFailed: 0 }
  if (!isUsingCloudStorage()) return stats

  const keysByContext = new Map<StorageContext, string[]>()
  for (const r of scope.legacyRows) {
    const bucket = keysByContext.get('workspace')
    if (bucket) bucket.push(r.key)
    else keysByContext.set('workspace', [r.key])
  }
  for (const r of scope.multiContextRows) {
    const bucket = keysByContext.get(r.context)
    if (bucket) bucket.push(r.key)
    else keysByContext.set(r.context, [r.key])
  }

  for (const [context, keys] of keysByContext) {
    const result = await StorageService.deleteFiles(keys, context)
    stats.filesDeleted += result.deleted
    stats.filesFailed += result.failed.length
    for (const { key, error } of result.failed) {
      logger.error(`Failed to delete storage file ${key} (context: ${context}):`, { error })
    }
  }

  return stats
}

/**
 * Tables cleaned by the generic workspace-scoped batched DELETE. Tables whose