Method processQueue

src/services/AutoArchiveService.ts:137–184

* Process the queue and archive tasks that are due

()

	 * Process the queue and archive tasks that are due
	 */
	private async processQueue(): Promise<void> {
		const queue = await this.getQueue();
		if (queue.length === 0) {
			return;
		}

		const now = Date.now();
		const toProcess: PendingAutoArchive[] = [];
		const toKeep: PendingAutoArchive[] = [];

		// Separate items that are due for processing
		for (const item of queue) {
			if (now >= item.archiveAfterTimestamp) {
				toProcess.push(item);
			} else {
				toKeep.push(item);
			}
		}

		if (toProcess.length === 0) {
			return;
		}

		// Process due items
		const remainingItems: PendingAutoArchive[] = [];

		for (const item of toProcess) {
			try {
				const processed = await this.processItem(item);
				if (!processed) {
					// Keep item if it couldn't be processed
					remainingItems.push(item);
				}
			} catch (error) {
				tasknotesLogger.error(`Error processing auto-archive for ${item.taskPath}:`, {
					category: "persistence",
					operation: "processing-auto-archive",
					error: error,
				});
				// Keep item for retry on next cycle
				remainingItems.push(item);
			}
		}

		// Save updated queue (items not processed + items to keep)
		const updatedQueue = [...remainingItems, ...toKeep];
		await this.saveQueue(updatedQueue);
	}

	/**
	 * Process a single auto-archive item