import { test, expect, executionLogsTestConfig } from './fixtures';

test.use(executionLogsTestConfig);

// Node name constants
const NODES = {
	MANUAL_TRIGGER: 'When clicking ‘Execute workflow’',
	CODE: 'Code',
	LOOP_OVER_ITEMS: 'Loop Over Items',
	WAIT: 'Wait',
	CODE1: 'Code1',
	SCHEDULE_TRIGGER: 'Schedule Trigger',
	EDIT_FIELDS: 'Edit Fields',
	IF: 'If',
	WAIT_NODE: 'Wait node',
};

test.describe(
	'Logs',
	{
		annotation: [{ type: 'owner', description: 'Catalysts' }],
	},
	() => {
		test.beforeEach(async ({ n8n }) => {
			await n8n.goHome();
		});

		test('should populate logs as manual execution progresses', async ({
			n8n,
			setupRequirements,
		}) => {
			await setupRequirements({ workflow: 'Workflow_loop.json' });

			await n8n.canvas.clickZoomToFitButton();
			await n8n.canvas.logsPanel.open();
			await expect(n8n.canvas.logsPanel.getLogEntries()).toHaveCount(0);

			await n8n.canvas.clickExecuteWorkflowButton();

			await expect(
				n8n.canvas.logsPanel.getOverviewStatus().filter({ hasText: 'Running' }),
			).toBeVisible();

			await expect(n8n.canvas.logsPanel.getLogEntries().nth(0)).toContainText(NODES.MANUAL_TRIGGER);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(1)).toContainText(NODES.CODE);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(2)).toContainText(
				NODES.LOOP_OVER_ITEMS,
			);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(3)).toContainText(NODES.WAIT);

			await expect(n8n.canvas.logsPanel.getLogEntries().nth(4)).toContainText(
				NODES.LOOP_OVER_ITEMS,
			);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(5)).toContainText(NODES.WAIT);

			await expect(n8n.canvas.logsPanel.getLogEntries().nth(6)).toContainText(
				NODES.LOOP_OVER_ITEMS,
			);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(7)).toContainText(NODES.WAIT);

			await expect(n8n.canvas.logsPanel.getLogEntries()).toHaveCount(10);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(8)).toContainText(
				NODES.LOOP_OVER_ITEMS,
			);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(9)).toContainText(NODES.CODE1);
			await expect(
				n8n.canvas.logsPanel.getOverviewStatus().filter({ hasText: /Error in [\d.]+s/ }),
			).toBeVisible();
			await expect(n8n.canvas.logsPanel.getSelectedLogEntry()).toContainText(NODES.CODE1); // Errored node is automatically selected
			await expect(n8n.canvas.logsPanel.outputPanel.getNodeErrorMessageHeader()).toContainText(
				'test!!! [line 1]',
			);
			await expect(n8n.canvas.getNodeIssuesByName(NODES.CODE1)).toBeVisible();

			await n8n.canvas.logsPanel.getClearExecutionButton().click();
			await expect(n8n.canvas.logsPanel.getLogEntries()).toHaveCount(0);
			await expect(n8n.canvas.getNodeIssuesByName(NODES.CODE1)).toBeHidden();
		});

		test('should allow to trigger partial execution', async ({ n8n, setupRequirements }) => {
			await setupRequirements({ workflow: 'Workflow_if.json' });

			await n8n.canvas.clickZoomToFitButton();
			await n8n.canvas.logsPanel.open();

			await n8n.workflowComposer.executeWorkflowAndWaitForNotification('Successful');
			await expect(n8n.canvas.logsPanel.getLogEntries()).toHaveCount(6);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(0)).toContainText(
				NODES.SCHEDULE_TRIGGER,
			);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(1)).toContainText(NODES.CODE);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(2)).toContainText(NODES.EDIT_FIELDS);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(3)).toContainText(NODES.IF);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(4)).toContainText(NODES.EDIT_FIELDS);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(5)).toContainText(NODES.EDIT_FIELDS);

			await n8n.canvas.logsPanel.clickTriggerPartialExecutionAtRow(3);
			await expect(n8n.canvas.logsPanel.getLogEntries()).toHaveCount(3);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(0)).toContainText(
				NODES.SCHEDULE_TRIGGER,
			);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(1)).toContainText(NODES.CODE);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(2)).toContainText(NODES.IF);
		});

		test('should show input and output data in the selected display mode', async ({
			n8n,
			anthropicCredential,
			setupRequirements,
		}) => {
			await setupRequirements({ workflow: 'Workflow_ai_agent.json' });

			await n8n.canvas.clickZoomToFitButton();
			await n8n.canvas.openNode('E2E Chat Model');
			await expect(n8n.ndv.getCredentialSelect()).toHaveValue(anthropicCredential.name);
			await n8n.ndv.close();
			await n8n.canvas.logsPanel.open();
			await n8n.canvas.logsPanel.sendManualChatMessage('Hi!');
			await expect(n8n.canvas.logsPanel.getManualChatMessages().nth(0)).toContainText('Hi!');
			await expect(n8n.canvas.logsPanel.getManualChatMessages().nth(1)).toContainText('Hello');
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(2)).toHaveText('E2E Chat Model');

			await expect(n8n.canvas.logsPanel.outputPanel.get()).toContainText('Hello');
			await n8n.canvas.logsPanel.outputPanel.switchDisplayMode('table');
			await expect(n8n.canvas.logsPanel.outputPanel.getTbodyCell(0, 0)).toContainText('text:Hello');
			await expect(n8n.canvas.logsPanel.outputPanel.getTbodyCell(0, 1)).toContainText(
				/completionTokens:\d+promptTokens:\d+totalTokens:\d+/,
			);
			await n8n.canvas.logsPanel.outputPanel.switchDisplayMode('schema');
			await expect(n8n.canvas.logsPanel.outputPanel.get()).toContainText('generations[0]');
			await expect(n8n.canvas.logsPanel.outputPanel.get()).toContainText('Hello');
			await n8n.canvas.logsPanel.outputPanel.switchDisplayMode('json');
			await expect(n8n.canvas.logsPanel.outputPanel.get()).toContainText(
				/\[\s*{\s*"response":\s*{\s*"generations":\s*\[/,
			);

			await expect(n8n.canvas.logsPanel.inputPanel.get()).toContainText('Human: Hi!');
			await n8n.canvas.logsPanel.inputPanel.switchDisplayMode('table');
			await expect(n8n.canvas.logsPanel.inputPanel.getTbodyCell(0, 0)).toContainText(
				'0:Human: Hi!',
			);
			await n8n.canvas.logsPanel.inputPanel.switchDisplayMode('schema');
			await expect(n8n.canvas.logsPanel.inputPanel.get()).toContainText('messages[0]');
			await expect(n8n.canvas.logsPanel.inputPanel.get()).toContainText('Human: Hi!');
			await n8n.canvas.logsPanel.inputPanel.switchDisplayMode('json');
			await expect(n8n.canvas.logsPanel.inputPanel.get()).toContainText(
				/\[\s*{\s*"messages":\s*\[\s*"Human: Hi!"\s*\],/,
			);
		});

		test('should show input and output data of correct run index and branch', async ({
			n8n,
			setupRequirements,
		}) => {
			await setupRequirements({ workflow: 'Workflow_if.json' });

			await n8n.canvas.clickZoomToFitButton();
			await n8n.canvas.logsPanel.open();
			await n8n.canvas.clickExecuteWorkflowButton();

			await n8n.canvas.logsPanel.clickLogEntryAtRow(2); // Run #1 of 'Edit Fields' node; input is 'Code' node
			await n8n.canvas.logsPanel.toggleInputPanel();
			await n8n.canvas.logsPanel.inputPanel.get().hover();
			await n8n.canvas.logsPanel.inputPanel.switchDisplayMode('table');
			await expect(n8n.canvas.logsPanel.inputPanel.getTableRows()).toHaveCount(11);
			await expect(n8n.canvas.logsPanel.inputPanel.getTbodyCell(0, 0)).toContainText('0');
			await expect(n8n.canvas.logsPanel.inputPanel.getTbodyCell(9, 0)).toContainText('9');
			await n8n.canvas.logsPanel.clickOpenNdvAtRow(2);
			await n8n.ndv.inputPanel.switchDisplayMode('table');
			await expect(n8n.ndv.getInputSelect()).toHaveValue(`${NODES.CODE} `);
			await expect(n8n.ndv.inputPanel.getTableRows()).toHaveCount(11);
			await expect(n8n.ndv.inputPanel.getTbodyCell(0, 0)).toContainText('0');
			await expect(n8n.ndv.inputPanel.getTbodyCell(9, 0)).toContainText('9');
			await expect(n8n.ndv.outputPanel.getRunSelectorInput()).toHaveValue('1 of 3 (10 items)');

			await n8n.ndv.clickBackToCanvasButton();

			await n8n.canvas.logsPanel.clickLogEntryAtRow(4); // Run #2 of 'Edit Fields' node; input is false branch of 'If' node
			await expect(n8n.canvas.logsPanel.inputPanel.getTableRows()).toHaveCount(6);
			await expect(n8n.canvas.logsPanel.inputPanel.getTbodyCell(0, 0)).toContainText('5');
			await expect(n8n.canvas.logsPanel.inputPanel.getTbodyCell(4, 0)).toContainText('9');
			await n8n.canvas.logsPanel.clickOpenNdvAtRow(4);
			await expect(n8n.ndv.getInputSelect()).toHaveValue(`${NODES.IF} `);
			await expect(n8n.ndv.inputPanel.getTableRows()).toHaveCount(6);
			await expect(n8n.ndv.inputPanel.getTbodyCell(0, 0)).toContainText('5');
			await expect(n8n.ndv.inputPanel.getTbodyCell(4, 0)).toContainText('9');
			await expect(n8n.ndv.outputPanel.getRunSelectorInput()).toHaveValue('2 of 3 (5 items)');

			await n8n.ndv.clickBackToCanvasButton();

			await n8n.canvas.logsPanel.clickLogEntryAtRow(5); // Run #3 of 'Edit Fields' node; input is true branch of 'If' node
			await expect(n8n.canvas.logsPanel.inputPanel.getTableRows()).toHaveCount(6);
			await expect(n8n.canvas.logsPanel.inputPanel.getTbodyCell(0, 0)).toContainText('0');
			await expect(n8n.canvas.logsPanel.inputPanel.getTbodyCell(4, 0)).toContainText('4');
			await n8n.canvas.logsPanel.clickOpenNdvAtRow(5);
			await expect(n8n.ndv.getInputSelect()).toHaveValue(`${NODES.IF} `);
			await expect(n8n.ndv.inputPanel.getTableRows()).toHaveCount(6);
			await expect(n8n.ndv.inputPanel.getTbodyCell(0, 0)).toContainText('0');
			await expect(n8n.ndv.inputPanel.getTbodyCell(4, 0)).toContainText('4');
			await expect(n8n.ndv.outputPanel.getRunSelectorInput()).toHaveValue('3 of 3 (5 items)');
		});

		test('should keep populated logs unchanged when workflow get edits after the execution', async ({
			n8n,
			setupRequirements,
		}) => {
			await setupRequirements({ workflow: 'Workflow_if.json' });

			await n8n.canvas.clickZoomToFitButton();
			await n8n.canvas.logsPanel.open();

			await n8n.workflowComposer.executeWorkflowAndWaitForNotification('Successful');
			await expect(n8n.canvas.logsPanel.getLogEntries()).toHaveCount(6);
			await n8n.canvas.nodeDisableButton(NODES.EDIT_FIELDS).click();
			await expect(n8n.canvas.logsPanel.getLogEntries()).toHaveCount(6);
			await n8n.canvas.deleteNodeByName(NODES.IF);
			await expect(n8n.canvas.logsPanel.getLogEntries()).toHaveCount(6);
		});

		test('should show logs for a past execution', async ({
			n8n,
			anthropicCredential,
			setupRequirements,
		}) => {
			await setupRequirements({ workflow: 'Workflow_ai_agent.json' });

			await n8n.canvas.clickZoomToFitButton();
			await n8n.canvas.openNode('E2E Chat Model');
			await expect(n8n.ndv.getCredentialSelect()).toHaveValue(anthropicCredential.name);
			await n8n.ndv.close();
			await n8n.canvas.logsPanel.open();

			await n8n.canvas.logsPanel.sendManualChatMessage('Hi!');
			await n8n.notifications.waitForNotificationAndClose('Successful');
			await n8n.canvas.openExecutions();
			await n8n.executions.getAutoRefreshButton().click();
			await expect(n8n.executions.logsPanel.getManualChatMessages().nth(0)).toContainText('Hi!');
			await expect(n8n.executions.logsPanel.getManualChatMessages().nth(1)).toContainText('Hello');
			await expect(
				n8n.executions.logsPanel.getOverviewStatus().filter({ hasText: /Success in [\d.]+m?s/ }),
			).toBeVisible();
			await expect(n8n.executions.logsPanel.getLogEntries()).toHaveCount(3);
			await expect(n8n.executions.logsPanel.getLogEntries().nth(0)).toContainText(
				'When chat message received',
			);
			await expect(n8n.executions.logsPanel.getLogEntries().nth(1)).toContainText('AI Agent');
			await expect(n8n.executions.logsPanel.getLogEntries().nth(2)).toContainText('E2E Chat Model');
		});

		test('should show logs for a workflow with a node that waits for webhook', async ({ n8n }) => {
			await n8n.start.fromImportedWorkflow('Workflow_wait_for_webhook.json');
			await n8n.canvas.deselectAll();
			await n8n.canvas.logsPanel.open();

			await n8n.canvas.clickExecuteWorkflowButton();

			await expect(n8n.canvas.getWaitingNodes()).toContainText(NODES.WAIT_NODE);
			await expect(n8n.canvas.logsPanel.getLogEntries()).toHaveCount(2);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(1)).toContainText(NODES.WAIT_NODE);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(1)).toContainText('Waiting');

			await n8n.canvas.openNode(NODES.WAIT_NODE);
			const webhookUrl = await n8n.ndv.outputPanel.getFirstLink().getAttribute('href');
			await n8n.ndv.clickBackToCanvasButton();

			// [CAT-1454] Assert that no duplicate logs added at this point
			await expect(n8n.canvas.logsPanel.getLogEntries()).toHaveCount(2);

			// Trigger the webhook
			const response = await n8n.page.request.get(webhookUrl!);
			expect(response.status()).toBe(200);

			await expect(n8n.canvas.getWaitingNodes()).toBeHidden();
			await expect(
				n8n.canvas.logsPanel.getOverviewStatus().filter({ hasText: /Success in [\d.]+m?s/ }),
			).toBeVisible();
			await n8n.canvas.logsPanel.getLogEntries().nth(1).click(); // click selected row to deselect
			await expect(n8n.canvas.logsPanel.getLogEntries()).toHaveCount(2);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(1)).toContainText(NODES.WAIT_NODE);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(1)).toContainText('Success');
		});

		test('should allow to cancel a workflow with a node that waits for webhook', async ({
			n8n,
		}) => {
			await n8n.start.fromImportedWorkflow('Workflow_wait_for_webhook.json');
			await n8n.canvas.deselectAll();
			await n8n.canvas.logsPanel.open();

			await n8n.canvas.clickExecuteWorkflowButton();

			await expect(n8n.canvas.getWaitingNodes()).toContainText(NODES.WAIT_NODE);
			await expect(n8n.canvas.logsPanel.getLogEntries()).toHaveCount(2);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(0)).toContainText(
				'When clicking ‘Test workflow’',
			);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(1)).toContainText(NODES.WAIT_NODE);

			await n8n.canvas.stopExecutionButton().click();
			await expect(n8n.canvas.stopExecutionButton()).toBeHidden();
			await expect(n8n.canvas.logsPanel.getOverviewStatus()).toContainText('Canceled in');
			await expect(n8n.canvas.logsPanel.getLogEntries()).toHaveCount(1);
			await expect(n8n.canvas.logsPanel.getLogEntries().nth(0)).toContainText(
				'When clicking ‘Test workflow’',
			);
		});
	},
);