Function hardDeleteDocuments

apps/sim/lib/knowledge/documents/service.ts:1970–2007

(
  documentIds: string[],
  requestId: string
)

}

export async function hardDeleteDocuments(
  documentIds: string[],
  requestId: string
): Promise<number> {
  const ids = [...new Set(documentIds)]
  if (ids.length === 0) {
    return 0
  }

  const documentsToDelete = await db
    .select({
      id: document.id,
      fileUrl: document.fileUrl,
      workspaceId: knowledgeBase.workspaceId,
    })
    .from(document)
    .innerJoin(knowledgeBase, eq(document.knowledgeBaseId, knowledgeBase.id))
    .where(inArray(document.id, ids))

  if (documentsToDelete.length === 0) {
    return 0
  }

  const existingIds = documentsToDelete.map((doc) => doc.id)

  await db.transaction(async (tx) => {
    await tx.delete(embedding).where(inArray(embedding.documentId, existingIds))
    await tx.delete(document).where(inArray(document.id, existingIds))
  })

  await deleteDocumentStorageFiles(documentsToDelete, requestId)

  logger.info(`[${requestId}] Hard deleted ${existingIds.length} documents`, {
    documentIds: existingIds,
  })

  return existingIds.length
}

export async function deleteDocument(
  documentId: string,