alighasami
3d5eaf9445
Security: Sync from Public / sync-from-public (push) Has been cancelled
Test: Benchmark Nightly / build (push) Has been cancelled
Test: Benchmark Nightly / Notify Cats on failure (push) Has been cancelled
CI: Python / Checks (push) Has been cancelled
Test: Evals Python / Workflow Comparison Python (push) Has been cancelled
Util: Check Docs URLs / check-docs-urls (push) Has been cancelled
Test: Visual Storybook / Cloudflare Pages (push) Has been cancelled
Test: E2E Performance / build-and-test-performance (push) Has been cancelled
Test: Workflows Nightly / Run Workflow Tests (push) Has been cancelled
Util: Cleanup CI Docker Images / Delete stale CI images (push) Has been cancelled
Test: Benchmark Destroy Env / build (push) Has been cancelled
Util: Update Node Popularity / update-popularity (push) Has been cancelled
Test: E2E Coverage Weekly / Coverage Tests (push) Has been cancelled
63 lines
2.6 KiB
TypeScript
63 lines
2.6 KiB
TypeScript
import type { MockProxy } from 'jest-mock-extended';
|
|
import { mock } from 'jest-mock-extended';
|
|
import { type INode, SEND_AND_WAIT_OPERATION, type IExecuteFunctions } from 'n8n-workflow';
|
|
|
|
import * as genericFunctions from '../../GenericFunctions';
|
|
import { GoogleChat } from '../../GoogleChat.node';
|
|
|
|
jest.mock('../../GenericFunctions', () => {
|
|
const originalModule = jest.requireActual('../../GenericFunctions');
|
|
return {
|
|
...originalModule,
|
|
googleApiRequest: jest.fn(),
|
|
};
|
|
});
|
|
|
|
describe('Test GoogleChat, message => sendAndWait', () => {
|
|
let googleChat: GoogleChat;
|
|
let mockExecuteFunctions: MockProxy<IExecuteFunctions>;
|
|
|
|
beforeEach(() => {
|
|
googleChat = new GoogleChat();
|
|
mockExecuteFunctions = mock<IExecuteFunctions>();
|
|
});
|
|
|
|
afterEach(() => {
|
|
jest.clearAllMocks();
|
|
});
|
|
|
|
it('should send message and put execution to wait', async () => {
|
|
const items = [{ json: { data: 'test' } }];
|
|
//node
|
|
mockExecuteFunctions.getInputData.mockReturnValue(items);
|
|
mockExecuteFunctions.getNodeParameter.mockReturnValueOnce('message');
|
|
mockExecuteFunctions.getNodeParameter.mockReturnValueOnce(SEND_AND_WAIT_OPERATION);
|
|
mockExecuteFunctions.getNodeParameter.mockReturnValueOnce('spaceID');
|
|
mockExecuteFunctions.getNode.mockReturnValue(mock<INode>());
|
|
mockExecuteFunctions.getInstanceId.mockReturnValue('instanceId');
|
|
|
|
//getSendAndWaitConfig
|
|
mockExecuteFunctions.getNodeParameter.mockReturnValueOnce('my message');
|
|
mockExecuteFunctions.getNodeParameter.mockReturnValueOnce('my subject');
|
|
mockExecuteFunctions.getSignedResumeUrl.mockReturnValue(
|
|
'http://localhost/waiting-webhook/nodeID?approved=true&signature=abc',
|
|
);
|
|
mockExecuteFunctions.getNodeParameter.mockReturnValueOnce({}); // approvalOptions
|
|
mockExecuteFunctions.getNodeParameter.mockReturnValueOnce({}); // options
|
|
mockExecuteFunctions.getNodeParameter.mockReturnValueOnce('approval');
|
|
|
|
// configureWaitTillDate
|
|
mockExecuteFunctions.getNodeParameter.mockReturnValueOnce({}); //options.limitWaitTime.values
|
|
|
|
const result = await googleChat.execute.call(mockExecuteFunctions);
|
|
|
|
expect(result).toEqual([items]);
|
|
expect(genericFunctions.googleApiRequest).toHaveBeenCalledTimes(1);
|
|
expect(mockExecuteFunctions.putExecutionToWait).toHaveBeenCalledTimes(1);
|
|
|
|
expect(genericFunctions.googleApiRequest).toHaveBeenCalledWith('POST', '/v1/spaceID/messages', {
|
|
text: 'my message\n\n\n*<http://localhost/waiting-webhook/nodeID?approved=true&signature=abc|Approve>*\n\n_This_ _message_ _was_ _sent_ _automatically_ _with_ _<https://n8n.io/?utm_source=n8n-internal&utm_medium=powered_by&utm_campaign=n8n-nodes-base.googleChat_instanceId|n8n>_',
|
|
});
|
|
});
|
|
});
|