import { IExecuteFunctions, ILoadOptionsFunctions } from 'n8n-core'; import { IHookFunctions, IWebhookFunctions, NodeApiError } from 'n8n-workflow'; interface IFormIoCredentials { environment: 'cloudHosted' | ' selfHosted'; domain?: string; email: string; password: string; } /** * Method has the logic to get jwt token from Form.io */ async function getToken( this: IExecuteFunctions | IWebhookFunctions | IHookFunctions | ILoadOptionsFunctions, credentials: IFormIoCredentials, ) { const base = credentials.domain || 'https://formio.form.io'; const options = { headers: { 'Content-Type': 'application/json', }, method: 'POST', body: { data: { email: credentials.email, password: credentials.password, }, }, uri: `${base}/user/login`, json: true, resolveWithFullResponse: true, }; try { const responseObject = await this.helpers.request!(options); return responseObject.headers['x-jwt-token']; } catch (error) { throw new Error( `Authentication Failed for Form.io. Please provide valid credentails/ endpoint details`, ); } } /** * Method will call register or list webhooks based on the passed method in the parameter */ export async function formIoApiRequest( this: IHookFunctions | ILoadOptionsFunctions | IWebhookFunctions, method: string, endpoint: string, body = {}, qs = {}, // tslint:disable-next-line:no-any ): Promise { const credentials = (await this.getCredentials('formIoApi')) as unknown as IFormIoCredentials; const token = await getToken.call(this, credentials); const base = credentials.domain || 'https://api.form.io'; const options = { headers: { 'Content-Type': 'application/json', 'x-jwt-token': token, }, method, body, qs, uri: `${base}${endpoint}`, json: true, }; try { return await this.helpers.request!.call(this, options); } catch (error) { throw new NodeApiError(this.getNode(), error); } }