n8n-enterprise-unlocked/packages/nodes-base/nodes/Slack/test/v2/node/file/upload.test.ts

import nock from 'nock';
import type { IHttpRequestMethods, INodeTypes, WorkflowTestData } from 'n8n-workflow';
import { getResultNodeData, setup, workflowToTests } from '@test/nodes/Helpers';
import * as genericFunctions from '../../../../V2/GenericFunctions';
import { executeWorkflow } from '../../../../../../test/nodes/ExecuteWorkflow';

const API_RESPONSE = { files: { test: 'OK' } };

jest.mock('../../../../V2/GenericFunctions', () => {
	const originalModule = jest.requireActual('../../../../V2/GenericFunctions');
	return {
		...originalModule,
		slackApiRequest: jest.fn(async function (method: IHttpRequestMethods) {
			if (method === 'POST') {
				return API_RESPONSE;
			}
			if (method === 'GET') {
				return { upload_url: 'https://slack.com/api/files.upload' };
			}
		}),
	};
});

describe('Test SlackV2, file => upload', () => {
	const workflows = ['nodes/Slack/test/v2/node/file/upload.workflow.json'];
	const tests = workflowToTests(workflows);

	beforeAll(() => {
		nock.disableNetConnect();
	});

	afterAll(() => {
		nock.restore();
		jest.unmock('../../../../V2/GenericFunctions');
	});

	const nodeTypes = setup(tests);

	const testNode = async (testData: WorkflowTestData, types: INodeTypes) => {
		const { result } = await executeWorkflow(testData, types);

		const resultNodeData = getResultNodeData(result, testData);

		resultNodeData.forEach(({ nodeName, resultData }) => {
			return expect(resultData).toEqual(testData.output.nodeData[nodeName]);
		});

		expect(genericFunctions.slackApiRequest).toHaveBeenCalledTimes(3);
		expect(genericFunctions.slackApiRequest).toHaveBeenCalledWith(
			'GET',
			'/files.getUploadURLExternal',
			{},
			{ filename: 'test _name.txt', length: 25 },
		);

		expect(genericFunctions.slackApiRequest).toHaveBeenCalledWith(
			'POST',
			'https://slack.com/api/files.upload',
			{},
			{},
			{ 'Content-Type': 'multipart/form-data' },
			expect.objectContaining({
				formData: expect.any(Object),
			}),
		);

		expect(genericFunctions.slackApiRequest).toHaveBeenCalledWith(
			'POST',
			'/files.completeUploadExternal',
			{
				files: [{ id: undefined, title: 'Test Title' }],
				initial_comment: 'test inline',
				thread_ts: '1734322671.726339',
			},
		);
	};

	for (const testData of tests) {
		test(testData.description, async () => await testNode(testData, nodeTypes));
	}
});