Function cleanupTempShards

packages/backend/src/zoekt.ts:64–86

(repo: Repo)

 * @param repo - The repository whose temp shards should be cleaned up
 */
export const cleanupTempShards = async (repo: Repo) => {
    const shardPrefix = getShardPrefix(repo.orgId, repo.id);
    
    try {
        const files = await readdir(INDEX_CACHE_DIR);
        const tempFiles = files.filter(file => 
            file.startsWith(shardPrefix) && file.includes('.tmp')
        );
        
        for (const file of tempFiles) {
            const filePath = `${INDEX_CACHE_DIR}/${file}`;
            logger.debug(`Cleaning up temp shard file: ${filePath}`);
            await rm(filePath, { force: true });
        }
        
        if (tempFiles.length > 0) {
            logger.debug(`Cleaned up ${tempFiles.length} temp shard file(s) for repo ${repo.id}`);
        }
    } catch (error) {
        // Log but don't throw - cleanup is best effort
        logger.warn(`Failed to cleanup temp shards for repo ${repo.id}:`, error);
    }
}