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

fix(Strapi Node): Add support for Strapi v4

Browse Source 
* 🐛 Fix get all operation for v4

* 🔨 Fix create operation

* 🔨 Fix update operation

* 🔨 Fix delete operation

* 🔨 Fix get operation

* 🔨 Fix Return All

* 👕 Fix nodelinter issues

* ⚡ Add Credential Test

* 🔨 Code improvement

* 👕 Fix lint issue

* Removed extra /api from Get All on v4

Co-authored-by: Jan Oberhauser <jan.oberhauser@gmail.com>
Co-authored-by: Jonathan Bennetts <jonathan.bennetts@gmail.com>
This commit is contained in:
Harshil Agrawal
2022-03-12 10:56:34 +01:00
committed by GitHub
parent c11edb2521
commit 2a3cbf3fc8
5 changed files with 288 additions and 187 deletions
Download Patch File Download Diff File Expand all files Collapse all files

130
packages/nodes-base/nodes/Strapi/Strapi.node.ts
View File

@@ -3,7 +3,14 @@ import {
} from 'n8n-core';
import {
OptionsWithUri,
} from 'request';
import {
ICredentialsDecrypted,
ICredentialTestFunctions,
IDataObject,
INodeCredentialTestResult,
INodeExecutionData,
INodeType,
INodeTypeDescription,
@@ -40,12 +47,14 @@ export class Strapi implements INodeType {
{
name: 'strapiApi',
required: true,
testedBy: 'strapiApiTest',
},
],
properties: [
{
displayName: 'Resource',
name: 'resource',
noDataExpression: true,
type: 'options',
options: [
{
@@ -54,13 +63,47 @@ export class Strapi implements INodeType {
},
],
default: 'entry',
description: 'The resource to operate on.',
description: 'The resource to operate on',
},
...entryOperations,
...entryFields,
],
};
methods = {
credentialTest: {
async strapiApiTest(this: ICredentialTestFunctions, credential: ICredentialsDecrypted): Promise<INodeCredentialTestResult> {
const credentials = await credential.data as IDataObject;
let options = {} as OptionsWithUri;
options = {
headers: {
'content-type': `application/json`,
},
method: 'POST',
body: {
identifier: credentials.email,
password: credentials.password,
},
uri: credentials.apiVersion === 'v4' ? `${credentials.url}/api/auth/local`:`${credentials.url}/auth/local`,
json: true,
};
try {
await this.helpers.request(options);
return {
status: 'OK',
message: 'Authentication successful',
};
} catch (error) {
return {
status: 'Error',
message: `Auth settings are not valid: ${error}`,
};
}
},
},
};
async execute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
const items = this.getInputData();
const returnData: IDataObject[] = [];
@@ -71,6 +114,7 @@ export class Strapi implements INodeType {
const resource = this.getNodeParameter('resource', 0) as string;
const operation = this.getNodeParameter('operation', 0) as string;
const { apiVersion } = await this.getCredentials('strapiApi') as IDataObject;
const { jwt } = await getToken.call(this);
headers.Authorization = `Bearer ${jwt}`;
@@ -89,7 +133,7 @@ export class Strapi implements INodeType {
for (const key of Object.keys(items[i].json)) {
if (columnList.includes(key)) {
body[key] = items[i].json[key];
apiVersion === 'v4'? body.data = items[i].json: body[key] = items[i].json[key];
}
}
responseData = await strapiApiRequest.call(this, 'POST', `/${contentType}`, body, qs, undefined, headers);
@@ -115,30 +159,58 @@ export class Strapi implements INodeType {
const options = this.getNodeParameter('options', i) as IDataObject;
if (options.sort && (options.sort as string[]).length !== 0) {
const sortFields = options.sort as string[];
qs._sort = sortFields.join(',');
}
if (options.where) {
const query = validateJSON(options.where as string);
if (query !== undefined) {
qs._where = query;
} else {
throw new NodeOperationError(this.getNode(), 'Query must be a valid JSON');
if (apiVersion === 'v4') {
// Sort Option
if (options.sort && (options.sort as string[]).length !== 0) {
const sortFields = options.sort as string[];
qs.sort = sortFields.join(',');
}
// Filter Option
if (options.where) {
const query = validateJSON(options.where as string);
if (query !== undefined) {
qs.filters = query;
} else {
throw new NodeOperationError(this.getNode(), 'Query must be a valid JSON');
}
}
// Publication Option
if (options.publicationState) {
qs.publicationState = options.publicationState as string;
}
// Limit Option
if (returnAll) {
responseData = await strapiApiRequestAllItems.call(this, 'GET', `/${contentType}`, {}, qs, headers);
} else {
qs['pagination[pageSize]'] = this.getNodeParameter('limit', i) as number;
({ data:responseData } = await strapiApiRequest.call(this, 'GET', `/${contentType}`, {}, qs, undefined, headers));
}
}
if (options.publicationState) {
qs._publicationState = options.publicationState as string;
}
if (returnAll) {
responseData = await strapiApiRequestAllItems.call(this, 'GET', `/${contentType}`, {}, qs, headers);
} else {
qs._limit = this.getNodeParameter('limit', i) as number;
responseData = await strapiApiRequest.call(this, 'GET', `/${contentType}`, {}, qs, undefined, headers);
// Sort Option
if (options.sort && (options.sort as string[]).length !== 0) {
const sortFields = options.sort as string[];
qs._sort = sortFields.join(',');
}
// Filter Option
if (options.where) {
const query = validateJSON(options.where as string);
if (query !== undefined) {
qs._where = query;
} else {
throw new NodeOperationError(this.getNode(), 'Query must be a valid JSON');
}
}
// Publication Option
if (options.publicationState) {
qs._publicationState = options.publicationState as string;
}
// Limit Option
if (returnAll) {
responseData = await strapiApiRequestAllItems.call(this, 'GET', `/${contentType}`, {}, qs, headers);
} else {
qs._limit = this.getNodeParameter('limit', i) as number;
responseData = await strapiApiRequest.call(this, 'GET', `/${contentType}`, {}, qs, undefined, headers);
}
}
returnData.push.apply(returnData, responseData);
}
@@ -150,8 +222,7 @@ export class Strapi implements INodeType {
const entryId = this.getNodeParameter('entryId', i) as string;
responseData = await strapiApiRequest.call(this, 'GET', `/${contentType}/${entryId}`, {}, qs, undefined, headers);
returnData.push(responseData);
apiVersion === 'v4'? returnData.push(responseData.data): returnData.push(responseData);
}
if (operation === 'update') {
@@ -170,12 +241,13 @@ export class Strapi implements INodeType {
for (const key of Object.keys(items[i].json)) {
if (columnList.includes(key)) {
body[key] = items[i].json[key];
apiVersion === 'v4'? body.data = items[i].json:body[key] = items[i].json[key];
}
}
responseData = await strapiApiRequest.call(this, 'PUT', `/${contentType}/${entryId}`, body, qs, undefined, headers);
returnData.push(responseData);
responseData = await strapiApiRequest.call(this, 'PUT', `/${contentType}/${entryId}`, body, qs, undefined, headers);
apiVersion === 'v4'? returnData.push(responseData.data): returnData.push(responseData);
}
}
} catch (error) {