Add --search-limit config flag to the search command

src/cmd.ts

@@ -334,6 +334,12 @@ createCommandWithSharedOptions("search", "Search for cross-seeds")
 			"torrent files separated by spaces"
 		).hideHelp()
 	)
+	.addOption(
+		new Option(
+			"--search-limit <number>",
+			"set the limit of searches for the running"
+		)
+	)
 	.action(async (options) => {
 		try {
 			const runtimeConfig = processOptions(options);

src/pipeline.ts

@@ -229,7 +229,7 @@ export async function checkNewCandidateMatch(
 }
 
 async function findSearchableTorrents() {
-	const { torrents, dataDirs, torrentDir } = getRuntimeConfig();
+	const { torrents, dataDirs, torrentDir, searchLimit } = getRuntimeConfig();
 	let allSearchees: Searchee[] = [];
 	if (Array.isArray(torrents)) {
 		const searcheeResults = await Promise.all(
@@ -255,7 +255,7 @@ async function findSearchableTorrents() {
 	}
 
 	const hashesToExclude = allSearchees.map((t) => t.infoHash).filter(Boolean);
-	const filteredTorrents = await filterAsync(
+	let filteredTorrents = await filterAsync(
 		filterDupes(allSearchees).filter(filterByContent),
 		filterTimestamps
 	);
@@ -265,6 +265,15 @@ async function findSearchableTorrents() {
 		message: `Found ${allSearchees.length} torrents, ${filteredTorrents.length} suitable to search for matches`,
 	});
 
+  if (searchLimit && filteredTorrents.length > searchLimit) {
+    logger.info({
+      label: Label.SEARCH,
+      message: `Limited to ${searchLimit} searches`,
+    });
+
+    filteredTorrents = filteredTorrents.slice(0, searchLimit);
+  }
+
 	return { samples: filteredTorrents, hashesToExclude };
 }
 

src/runtimeConfig.ts

@@ -1,4 +1,5 @@
 import { Action, LinkType, MatchMode } from "./constants.js";
+
 export interface RuntimeConfig {
 	offset: number;
 	delay: number;
@@ -30,6 +31,7 @@ export interface RuntimeConfig {
 	rssCadence: number;
 	snatchTimeout: number;
 	searchTimeout: number;
+	searchLimit: number;
 }
 
 let runtimeConfig: RuntimeConfig;