admin/n8n-enterprise-unlocked
1
0
Fork 0
mirror of https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git synced 2025-12-17 18:12:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(Elasticsearch Node): Use POST instead of GET to allow request body in search API (#13302)

Browse Source 
Co-authored-by: Michael Kret <michael.k@radency.com>
This commit is contained in:
Haru
2025-03-07 16:28:49 +09:00
committed by GitHub
parent d2dd1796a8
commit 783bf7b3bc
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/nodes-base/nodes/Elastic/Elasticsearch/GenericFunctions.ts
View File

@@ -111,7 +111,7 @@ export async function elasticsearchApiRequestAllItems(
track_total_hits: false, //Disable the tracking of total hits to speed up pagination track_total_hits: false, //Disable the tracking of total hits to speed up pagination
}; };
responseData = await elasticsearchApiRequest.call(this, 'GET', '/_search', requestBody, qs); responseData = await elasticsearchApiRequest.call(this, 'POST', '/_search', requestBody, qs);
if (responseData?.hits?.hits) { if (responseData?.hits?.hits) {
returnData = returnData.concat(responseData.hits.hits as IDataObject[]); returnData = returnData.concat(responseData.hits.hits as IDataObject[]);
const lastHitIndex = responseData.hits.hits.length - 1; const lastHitIndex = responseData.hits.hits.length - 1;
@@ -127,7 +127,7 @@ export async function elasticsearchApiRequestAllItems(
requestBody.search_after = searchAfter; requestBody.search_after = searchAfter;
requestBody.pit = { id: pit, keep_alive: '1m' }; requestBody.pit = { id: pit, keep_alive: '1m' };
responseData = await elasticsearchApiRequest.call(this, 'GET', '/_search', requestBody, qs); responseData = await elasticsearchApiRequest.call(this, 'POST', '/_search', requestBody, qs);
if (responseData?.hits?.hits?.length) { if (responseData?.hits?.hits?.length) {
returnData = returnData.concat(responseData.hits.hits as IDataObject[]); returnData = returnData.concat(responseData.hits.hits as IDataObject[]);