n8n/packages/nodes-base/nodes/Msg91/Msg91.node.ts

185 lines
3.6 KiB
TypeScript
Raw Normal View History

2019-12-13 03:29:33 -08:00
import { IExecuteFunctions } from 'n8n-core';
import {
IDataObject,
INodeExecutionData,
INodeType,
INodeTypeDescription,
} from 'n8n-workflow';
import {
msg91ApiRequest,
} from './GenericFunctions';
export class Msg91 implements INodeType {
description: INodeTypeDescription = {
displayName: 'MSG91',
2019-12-13 03:29:33 -08:00
name: 'msg91',
icon: 'file:msg91.png',
group: ['transform'],
version: 1,
subtitle: '={{$parameter["operation"] + ": " + $parameter["resource"]}}',
description: 'Send Transactional SMS',
defaults: {
name: 'Msg91',
color: '#0000ff',
},
inputs: ['main'],
outputs: ['main'],
credentials: [
{
name: 'msg91Api',
required: true,
}
],
properties: [
{
displayName: 'Resource',
name: 'resource',
type: 'options',
options: [
{
name: 'SMS',
value: 'sms',
},
],
default: 'sms',
description: 'The resource to operate on.',
},
{
displayName: 'Operation',
name: 'operation',
type: 'options',
displayOptions: {
show: {
resource: [
'sms',
],
},
},
options: [
{
name: 'Send',
value: 'send',
description: 'Send SMS',
},
],
default: 'send',
description: 'The operation to perform.',
},
{
displayName: 'Sender ID',
2019-12-20 14:35:00 -08:00
name: 'from',
2019-12-13 03:29:33 -08:00
type: 'string',
default: '',
2019-12-20 14:35:00 -08:00
placeholder: '4155238886',
2019-12-13 03:29:33 -08:00
required: true,
displayOptions: {
show: {
operation: [
'send',
],
resource: [
'sms',
],
},
},
2019-12-20 14:35:00 -08:00
description: 'The number from which to send the message.',
2019-12-13 03:29:33 -08:00
},
{
displayName: 'To',
2019-12-20 14:35:00 -08:00
name: 'to',
2019-12-13 03:29:33 -08:00
type: 'string',
default: '',
2019-12-20 14:35:00 -08:00
placeholder: '+14155238886',
2019-12-13 03:29:33 -08:00
required: true,
displayOptions: {
show: {
operation: [
'send',
],
resource: [
'sms',
],
},
},
2019-12-20 14:35:00 -08:00
description: 'The number, with coutry code, to which to send the message.',
2019-12-13 03:29:33 -08:00
},
{
displayName: 'Message',
name: 'message',
type: 'string',
default: '',
required: true,
displayOptions: {
show: {
operation: [
'send',
],
resource: [
'sms',
],
},
},
description: 'The message to send',
},
]
};
async execute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
const items = this.getInputData();
const returnData: IDataObject[] = [];
let operation: string;
let resource: string;
// For Post
let body: IDataObject;
// For Query string
let qs: IDataObject;
let requestMethod: string;
let endpoint: string;
for (let i = 0; i < items.length; i++) {
endpoint = '';
body = {};
qs = {};
resource = this.getNodeParameter('resource', i) as string;
operation = this.getNodeParameter('operation', i) as string;
if (resource === 'sms') {
if (operation === 'send') {
// ----------------------------------
// sms:send
// ----------------------------------
requestMethod = 'GET';
2019-12-20 14:35:00 -08:00
endpoint = '/sendhttp.php';
2019-12-13 03:29:33 -08:00
qs.route = 4;
qs.country = 0;
2019-12-20 14:35:00 -08:00
qs.sender = this.getNodeParameter('from', i) as string;
qs.mobiles = this.getNodeParameter('to', i) as string;
2019-12-13 03:29:33 -08:00
qs.message = this.getNodeParameter('message', i) as string;
} else {
throw new Error(`The operation "${operation}" is not known!`);
}
} else {
throw new Error(`The resource "${resource}" is not known!`);
}
const responseData = await msg91ApiRequest.call(this, requestMethod, endpoint, body, qs);
2019-12-20 14:35:00 -08:00
returnData.push({ requestId: responseData });
2019-12-13 03:29:33 -08:00
}
return [this.helpers.returnJsonArray(returnData)];
}
}