mirror of
https://github.com/n8n-io/n8n.git
synced 2024-12-26 21:19:43 -08:00
79 lines
1.9 KiB
TypeScript
79 lines
1.9 KiB
TypeScript
import { parseString as parseXml } from 'xml2js';
|
|
|
|
import type {
|
|
IExecuteFunctions,
|
|
IHookFunctions,
|
|
ILoadOptionsFunctions,
|
|
IWebhookFunctions,
|
|
IHttpRequestOptions,
|
|
JsonObject,
|
|
} from 'n8n-workflow';
|
|
import { NodeApiError } from 'n8n-workflow';
|
|
|
|
export async function awsApiRequest(
|
|
this: IHookFunctions | IExecuteFunctions | ILoadOptionsFunctions | IWebhookFunctions,
|
|
service: string,
|
|
method: string,
|
|
path: string,
|
|
body?: string,
|
|
headers?: object,
|
|
): Promise<any> {
|
|
const credentials = await this.getCredentials('aws');
|
|
const requestOptions = {
|
|
qs: {
|
|
service,
|
|
path,
|
|
},
|
|
method,
|
|
body: service === 'lambda' ? body : JSON.stringify(body),
|
|
url: '',
|
|
headers,
|
|
region: credentials?.region as string,
|
|
} as IHttpRequestOptions;
|
|
|
|
try {
|
|
return await this.helpers.requestWithAuthentication.call(this, 'aws', requestOptions);
|
|
} catch (error) {
|
|
throw new NodeApiError(this.getNode(), error as JsonObject, { parseXml: true });
|
|
}
|
|
}
|
|
|
|
export async function awsApiRequestREST(
|
|
this: IHookFunctions | IExecuteFunctions | ILoadOptionsFunctions,
|
|
service: string,
|
|
method: string,
|
|
path: string,
|
|
body?: string,
|
|
headers?: object,
|
|
): Promise<any> {
|
|
const response = await awsApiRequest.call(this, service, method, path, body, headers);
|
|
try {
|
|
return JSON.parse(response as string);
|
|
} catch (error) {
|
|
return response;
|
|
}
|
|
}
|
|
|
|
export async function awsApiRequestSOAP(
|
|
this: IHookFunctions | IExecuteFunctions | ILoadOptionsFunctions | IWebhookFunctions,
|
|
service: string,
|
|
method: string,
|
|
path: string,
|
|
body?: string,
|
|
headers?: object,
|
|
): Promise<any> {
|
|
const response = await awsApiRequest.call(this, service, method, path, body, headers);
|
|
try {
|
|
return await new Promise((resolve, reject) => {
|
|
parseXml(response as string, { explicitArray: false }, (err, data) => {
|
|
if (err) {
|
|
return reject(err);
|
|
}
|
|
resolve(data);
|
|
});
|
|
});
|
|
} catch (error) {
|
|
return response;
|
|
}
|
|
}
|