|
1 | 1 | import { IRequestParams, zbGetRequest, zbPostRequest } from '../utils/request.utils'; |
2 | 2 | import { |
| 3 | + getDateParameter, |
3 | 4 | getNumberParameter, |
4 | 5 | IAltErrorResponse, |
5 | 6 | IErrorResponse, |
6 | 7 | IOperationHandler, |
7 | 8 | isAltErrorResponse, |
8 | 9 | isErrorResponse, |
9 | | - toDate, |
10 | 10 | } from '../utils/handler.utils'; |
11 | 11 | import { IDataObject, IExecuteFunctions, INodeExecutionData, NodeOperationError } from 'n8n-workflow'; |
12 | 12 | import { BaseUrl, Endpoint, Operations } from '../enums'; |
@@ -81,7 +81,7 @@ interface IDeleteFilterResponse extends IDataObject { |
81 | 81 | */ |
82 | 82 | async function getCredits(context: IExecuteFunctions, i: number): Promise<INodeExecutionData[]> { |
83 | 83 | const baseUrl = context.getNodeParameter(ApiEndpoint.name, i) as BaseUrl; |
84 | | - const creditsRequired = getNumberParameter(context, i, CreditsRequired.name, 0); |
| 84 | + const creditsRequired = getNumberParameter(context, i, CreditsRequired, 0); |
85 | 85 |
|
86 | 86 | const fullResponse = await zbGetRequest(context, baseUrl, Endpoint.GetCredits); |
87 | 87 | const response = fullResponse.body as IGetCreditsResponse | IErrorResponse; |
@@ -127,13 +127,11 @@ async function getCredits(context: IExecuteFunctions, i: number): Promise<INodeE |
127 | 127 | * Dates are normalized to ISO yyyy-mm-dd. |
128 | 128 | */ |
129 | 129 | async function getApiUsage(context: IExecuteFunctions, i: number): Promise<INodeExecutionData[]> { |
130 | | - const startDate = context.getNodeParameter(StartDate.name, i) as string; |
131 | | - const endDate = context.getNodeParameter(EndDate.name, i) as string; |
132 | 130 | const baseUrl = context.getNodeParameter(ApiEndpoint.name, i) as BaseUrl; |
133 | 131 |
|
134 | 132 | const request = { |
135 | | - start_date: toDate(context, startDate), |
136 | | - end_date: toDate(context, endDate), |
| 133 | + start_date: getDateParameter(context, i, StartDate), |
| 134 | + end_date: getDateParameter(context, i, EndDate), |
137 | 135 | } as IGetApiUsageRequest; |
138 | 136 |
|
139 | 137 | const fullResponse = await zbGetRequest(context, baseUrl, Endpoint.GetApiUsage, request); |
@@ -225,7 +223,10 @@ class AccountHandler implements IOperationHandler { |
225 | 223 | case Operations.AccountDeleteFilter: |
226 | 224 | return addOrDeleteFilter(context, i, AddOrDelete.DELETE); |
227 | 225 | default: |
228 | | - throw new NodeOperationError(context.getNode(), `Operation ${operation} not supported`); |
| 226 | + throw new NodeOperationError(context.getNode(), `Operation ${operation} not supported`, { |
| 227 | + itemIndex: i, |
| 228 | + description: 'Please select an operation from the list', |
| 229 | + }); |
229 | 230 | } |
230 | 231 | } |
231 | 232 | } |
|
0 commit comments