mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2024-11-13 16:14:07 -08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

revert this > context

Browse source
This commit is contained in:
Jonathan Bennetts 2024-11-08 14:35:59 +00:00
parent 05e529b423
commit 19736d6a76
No known key found for this signature in database
2 changed files with 30 additions and 28 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
packages/nodes-base/nodes/Gotify/GenericFunctions.ts
View file

@ -4,19 +4,21 @@ import type {
JsonObject,
IHttpRequestMethods,
IHttpRequestOptions,
ILoadOptionsFunctions,
} from 'n8n-workflow';
import { NodeApiError } from 'n8n-workflow';
export async function gotifyApiRequest(
context: IExecuteFunctions,
this: IExecuteFunctions | ILoadOptionsFunctions,
method: IHttpRequestMethods,
path: string,
body: any = {},
qs: IDataObject = {},
uri?: string | undefined,
_option = {},
): Promise<any> {
const credentials = await context.getCredentials('gotifyApi');
const credentials = await this.getCredentials('gotifyApi');
const options: IHttpRequestOptions = {
method,
@ -30,17 +32,18 @@ export async function gotifyApiRequest(
if (Object.keys(body as IDataObject).length === 0) {
delete options.body;
}
return await context.helpers.httpRequestWithAuthentication.call(context, 'gotifyApi', options);
return await this.helpers.httpRequestWithAuthentication.call(this, 'gotifyApi', options);
} catch (error) {
throw new NodeApiError(context.getNode(), error as JsonObject);
throw new NodeApiError(this.getNode(), error as JsonObject);
}
}
export async function gotifyApiRequestAllItems(
context: IExecuteFunctions,
this: IExecuteFunctions | ILoadOptionsFunctions,
propertyName: string,
method: IHttpRequestMethods,
endpoint: string,
body: any = {},
query: IDataObject = {},
): Promise<any> {
@ -50,7 +53,7 @@ export async function gotifyApiRequestAllItems(
let uri: string | undefined;
query.limit = 100;
do {
responseData = await gotifyApiRequest(context, method, endpoint, body, query, uri);
responseData = await gotifyApiRequest.call(this, method, endpoint, body, query, uri);
if (responseData.paging.next) {
uri = responseData.paging.next;
}

43
packages/nodes-base/nodes/Gotify/Gotify.node.ts
View file

@ -2,13 +2,14 @@ import type {
IExecuteFunctions,
IDataObject,
INodeExecutionData,
INodeType,
INodeTypeDescription,
} from 'n8n-workflow';
import { Node, NodeConnectionType } from 'n8n-workflow';
import { NodeConnectionType } from 'n8n-workflow';
import { gotifyApiRequest, gotifyApiRequestAllItems } from './GenericFunctions';
export class Gotify extends Node {
export class Gotify implements INodeType {
description: INodeTypeDescription = {
displayName: 'Gotify',
name: 'gotify',
@ -193,22 +194,22 @@ export class Gotify extends Node {
],
};
async execute(context: IExecuteFunctions): Promise<INodeExecutionData[][]> {
const items = context.getInputData();
async execute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
const items = this.getInputData();
const returnData: INodeExecutionData[] = [];
const length = items.length;
const qs: IDataObject = {};
let responseData;
const resource = context.getNodeParameter('resource', 0);
const operation = context.getNodeParameter('operation', 0);
const resource = this.getNodeParameter('resource', 0);
const operation = this.getNodeParameter('operation', 0);
for (let i = 0; i < length; i++) {
try {
if (resource === 'message') {
if (operation === 'create') {
const message = context.getNodeParameter('message', i) as string;
const message = this.getNodeParameter('message', i) as string;
const additionalFields = context.getNodeParameter('additionalFields', i);
const options = context.getNodeParameter('options', i);
const additionalFields = this.getNodeParameter('additionalFields', i);
const options = this.getNodeParameter('options', i);
const body: IDataObject = {
message,
@ -224,23 +225,21 @@ export class Gotify extends Node {
Object.assign(body, additionalFields);
responseData = await gotifyApiRequest(context, 'POST', '/message', body);
responseData = await gotifyApiRequest(context, 'POST', '/message', body);
responseData = await gotifyApiRequest.call(this, 'POST', '/message', body);
}
if (operation === 'delete') {
const messageId = context.getNodeParameter('messageId', i) as string;
const messageId = this.getNodeParameter('messageId', i) as string;
responseData = await gotifyApiRequest(context, 'DELETE', `/message/${messageId}`);
responseData = await gotifyApiRequest.call(this, 'DELETE', `/message/${messageId}`);
responseData = { success: true };
}
if (operation === 'getAll') {
const returnAll = context.getNodeParameter('returnAll', i);
const returnAll = this.getNodeParameter('returnAll', i);
if (returnAll) {
responseData = await gotifyApiRequestAllItems(
context,
responseData = await gotifyApiRequestAllItems.call(
this,
'messages',
'GET',
'/message',
@ -248,20 +247,20 @@ export class Gotify extends Node {
qs,
);
} else {
qs.limit = context.getNodeParameter('limit', i);
responseData = await gotifyApiRequest(context, 'GET', '/message', {}, qs);
qs.limit = this.getNodeParameter('limit', i);
responseData = await gotifyApiRequest.call(this, 'GET', '/message', {}, qs);
responseData = responseData.messages;
}
}
}
const executionData = context.helpers.constructExecutionMetaData(
context.helpers.returnJsonArray(responseData as IDataObject[]),
const executionData = this.helpers.constructExecutionMetaData(
this.helpers.returnJsonArray(responseData as IDataObject[]),
{ itemData: { item: i } },
);
returnData.push(...executionData);
} catch (error) {
if (context.continueOnFail()) {
if (this.continueOnFail()) {
returnData.push({ json: { error: error.message } });
continue;
}