searxng.ts•2.41 kB
import url from 'node:url';
import { ISearchRequestOptions, ISearchResponse, ISearchResponseResult } from '../interface.js';
/**
* SearxNG Search API
* - https://docs.searxng.org/dev/search_api.html
*/
export async function searxngSearch(params: ISearchRequestOptions): Promise<ISearchResponse> {
try {
const {
query,
page = 1,
limit = 10,
categories = 'general',
engines = 'all',
safeSearch = 0,
format = 'json',
language = 'auto',
timeRange = '',
timeout = 10000,
apiKey,
apiUrl,
} = params;
if (!apiUrl) {
throw new Error('SearxNG API URL is required');
}
const controller = new AbortController();
const timeoutId = setTimeout(() => controller.abort(), Number(timeout));
const config = {
q: query,
pageno: page,
categories,
format,
safesearch: safeSearch,
language,
engines,
time_range: timeRange,
};
const endpoint = `${apiUrl}/search`;
const queryParams = url.format({ query: config });
const headers: HeadersInit = {
'Content-Type': 'application/json',
};
if (apiKey) {
headers['Authorization'] = `Bearer ${apiKey}`;
}
const res = await fetch(`${endpoint}${queryParams}`, {
method: 'POST',
headers,
signal: controller.signal,
});
clearTimeout(timeoutId);
const response = await res.json();
if (response.results) {
const list = (response.results as Array<Record<string, any>>).slice(0, limit);
const results: ISearchResponseResult[] = list.map((item: Record<string, any>) => {
const image = item.img_src ? {
thumbnail: item.thumbnail_src,
src: item.img_src,
} : null;
const video = item.iframe_src ? {
thumbnail: item.thumbnail_src,
src: item.iframe_src,
} : null;
return {
title: item.title,
snippet: item.content,
url: item.url,
source: item.source,
image,
video,
engine: item.engine,
};
});
return {
results,
success: true,
};
}
return {
results: [],
success: false,
};
} catch (err: unknown) {
const msg = err instanceof Error ? err.message : 'Searxng search error.';
process.stdout.write(msg);
throw err;
}
}