mirror of
https://github.com/n8n-io/n8n.git
synced 2026-05-24 21:35:24 +02:00
f96cdb17db
Some checks are pending
CI: Master (Build, Test, Lint) / Build for Github Cache (push) Waiting to run
CI: Master (Build, Test, Lint) / Unit tests (22.x) (push) Waiting to run
CI: Master (Build, Test, Lint) / Unit tests (24.14.1) (push) Waiting to run
CI: Master (Build, Test, Lint) / Unit tests (25.x) (push) Waiting to run
CI: Master (Build, Test, Lint) / Lint (push) Waiting to run
CI: Master (Build, Test, Lint) / Performance (push) Waiting to run
CI: Master (Build, Test, Lint) / Notify Slack on failure (push) Blocked by required conditions
Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>
268 lines
9.7 KiB
TypeScript
268 lines
9.7 KiB
TypeScript
import { MANUAL_TRIGGER_NODE_NAME } from '../../../config/constants';
|
|
import { expect, test } from '../../../fixtures/base';
|
|
import type { n8nPage } from '../../../pages/n8nPage';
|
|
import { type GitRepoHelper, setupGitRepo } from '../../../utils/source-control-helper';
|
|
|
|
test.use({ capability: 'source-control' });
|
|
|
|
async function expectPushSuccess(n8n: n8nPage) {
|
|
expect(
|
|
await n8n.notifications.waitForNotificationAndClose('Pushed successfully', { timeout: 30000 }),
|
|
).toBe(true);
|
|
}
|
|
|
|
async function expectNoChangesToCommit(n8n: n8nPage) {
|
|
expect(
|
|
await n8n.notifications.waitForNotificationAndClose('No changes to commit', { timeout: 10000 }),
|
|
).toBe(true);
|
|
}
|
|
|
|
// Skipped: These tests are flaky. Re-enable when PAY-4365 is resolved.
|
|
// https://linear.app/n8n/issue/PAY-4365/bug-source-control-operations-fail-in-multi-main-deployment
|
|
test.describe(
|
|
'Push resources to Git @capability:source-control',
|
|
{
|
|
annotation: [{ type: 'owner', description: 'Lifecycle & Governance' }],
|
|
},
|
|
() => {
|
|
test.fixme();
|
|
|
|
let gitRepo: GitRepoHelper;
|
|
|
|
test.beforeEach(async ({ n8n, services }) => {
|
|
await n8n.api.enableFeature('sourceControl');
|
|
await n8n.api.enableFeature('variables');
|
|
|
|
gitRepo = await setupGitRepo(n8n, services.gitea);
|
|
});
|
|
|
|
test('should push a new workflow', async ({ n8n }) => {
|
|
// create workflow
|
|
const workflow = await n8n.api.workflows.createWorkflow({
|
|
name: 'Test Workflow',
|
|
nodes: [],
|
|
connections: {},
|
|
active: false,
|
|
});
|
|
await n8n.navigate.toWorkflow(workflow.id);
|
|
|
|
// check modal
|
|
await n8n.sideBar.getSourceControlPushButton().click();
|
|
await expect(n8n.sourceControlPushModal.container).toBeVisible();
|
|
const isWorkflowsTabSelected = await n8n.sourceControlPushModal.isWorkflowsTabSelected();
|
|
expect(isWorkflowsTabSelected).toBe(true);
|
|
|
|
// check selected workflow
|
|
await expect(n8n.sourceControlPushModal.getFileInModal('Test Workflow')).toBeVisible();
|
|
const workflowCheckbox = n8n.sourceControlPushModal.getFileCheckboxByName('Test Workflow');
|
|
await expect(workflowCheckbox).toBeChecked();
|
|
|
|
// push and wait for commit to be indexed
|
|
await gitRepo.pushAndWait(n8n, 'Add test workflow with manual trigger');
|
|
await expectPushSuccess(n8n);
|
|
|
|
// check no changes to commit
|
|
await n8n.sideBar.getSourceControlPushButton().click();
|
|
await expectNoChangesToCommit(n8n);
|
|
});
|
|
|
|
test('should push all resource types together', async ({ n8n }) => {
|
|
// variables and tags
|
|
await n8n.api.variables.createTestVariable();
|
|
await n8n.api.tags.create('test-tag');
|
|
|
|
// projects and folders
|
|
const project = await n8n.api.projects.createProject('Test Project');
|
|
const folderA = await n8n.api.projects.createFolder(project.id, 'Folder A');
|
|
const folderB = await n8n.api.projects.createFolder(project.id, 'Folder B', folderA.id);
|
|
|
|
// workflows
|
|
await n8n.api.workflows.createInProject(project.id, {
|
|
name: 'Workflow in Folder A',
|
|
folder: folderA.id,
|
|
});
|
|
await n8n.api.workflows.createInProject(project.id, {
|
|
name: 'Workflow in Folder B',
|
|
folder: folderB.id,
|
|
});
|
|
await n8n.api.workflows.createInProject(project.id, {
|
|
name: 'Root Workflow',
|
|
});
|
|
|
|
// credentials
|
|
await n8n.api.credentials.createCredential({
|
|
name: 'Credential in Project 1',
|
|
type: 'notionApi',
|
|
data: { apiKey: '1234567890' },
|
|
projectId: project.id,
|
|
});
|
|
|
|
// Open push modal
|
|
await n8n.navigate.toHome();
|
|
await expect(n8n.workflows.cards.getWorkflow('Workflow in Folder A')).toBeVisible();
|
|
await expect(n8n.workflows.cards.getWorkflow('Workflow in Folder B')).toBeVisible();
|
|
await expect(n8n.workflows.cards.getWorkflow('Root Workflow')).toBeVisible();
|
|
|
|
await n8n.sideBar.getSourceControlPushButton().click();
|
|
await expect(n8n.sourceControlPushModal.container).toBeVisible();
|
|
|
|
// check notice
|
|
const notice = n8n.sourceControlPushModal.getNotice();
|
|
await expect(notice).toBeVisible();
|
|
expect(await notice.textContent()).toContain('Variables');
|
|
expect(await notice.textContent()).toContain('Projects');
|
|
expect(await notice.textContent()).toContain('Folders');
|
|
expect(await notice.textContent()).toContain('Tags');
|
|
|
|
// check workflows
|
|
await n8n.sourceControlPushModal.selectWorkflowsTab();
|
|
await expect(n8n.sourceControlPushModal.getFileInModal('Workflow in Folder A')).toBeVisible();
|
|
await expect(n8n.sourceControlPushModal.getFileInModal('Workflow in Folder B')).toBeVisible();
|
|
await expect(n8n.sourceControlPushModal.getFileInModal('Root Workflow')).toBeVisible();
|
|
await n8n.sourceControlPushModal.selectAllFilesInModal();
|
|
|
|
// check credentials
|
|
await n8n.sourceControlPushModal.selectCredentialsTab();
|
|
await expect(
|
|
n8n.sourceControlPushModal.getFileInModal('Credential in Project 1'),
|
|
).toBeVisible();
|
|
await n8n.sourceControlPushModal.selectAllFilesInModal();
|
|
|
|
// Push all resources
|
|
await n8n.sourceControlPushModal.push('Add all resource types');
|
|
await expectPushSuccess(n8n);
|
|
});
|
|
|
|
test('should push modifications and deletions', async ({ n8n }) => {
|
|
// create resources
|
|
const project = await n8n.api.projects.createProject('Test Project');
|
|
const workflow = await n8n.api.workflows.createInProject(project.id, {
|
|
name: 'Workflow to Modify',
|
|
});
|
|
const credential = await n8n.api.credentials.createCredential({
|
|
name: 'Credential to Delete',
|
|
type: 'notionApi',
|
|
data: { apiKey: '1234567890' },
|
|
projectId: project.id,
|
|
});
|
|
|
|
// Push it to Git first
|
|
await n8n.navigate.toHome();
|
|
await expect(n8n.workflows.cards.getWorkflow('Workflow to Modify')).toBeVisible();
|
|
await n8n.sideBar.getSourceControlPushButton().click();
|
|
await expect(n8n.sourceControlPushModal.container).toBeVisible();
|
|
|
|
await n8n.sourceControlPushModal.selectWorkflowsTab();
|
|
await n8n.sourceControlPushModal.selectAllFilesInModal();
|
|
|
|
await gitRepo.pushAndWait(n8n, 'new resources');
|
|
await expectPushSuccess(n8n);
|
|
|
|
// modify and delete resources
|
|
await n8n.navigate.toWorkflow(workflow.id);
|
|
await n8n.canvas.addNode(MANUAL_TRIGGER_NODE_NAME);
|
|
await n8n.canvas.waitForSaveWorkflowCompleted();
|
|
|
|
await n8n.api.credentials.deleteCredential(credential.id);
|
|
|
|
await n8n.sideBar.getSourceControlPushButton().click();
|
|
await expect(n8n.sourceControlPushModal.container).toBeVisible();
|
|
|
|
await n8n.sourceControlPushModal.selectWorkflowsTab();
|
|
await expect(n8n.sourceControlPushModal.getFileInModal('Workflow to Modify')).toBeVisible();
|
|
await expect(
|
|
n8n.sourceControlPushModal.getStatusBadge('Workflow to Modify', 'Modified'),
|
|
).toBeVisible();
|
|
|
|
await n8n.sourceControlPushModal.selectCredentialsTab();
|
|
await expect(n8n.sourceControlPushModal.getFileInModal('Credential to Delete')).toBeVisible();
|
|
await expect(
|
|
n8n.sourceControlPushModal.getStatusBadge('Credential to Delete', 'Deleted'),
|
|
).toBeVisible();
|
|
|
|
// push and wait for commit
|
|
await gitRepo.pushAndWait(n8n, 'Modify workflow and delete credential');
|
|
await expectPushSuccess(n8n);
|
|
|
|
// check no changes to commit
|
|
await n8n.sideBar.getSourceControlPushButton().click();
|
|
await expectNoChangesToCommit(n8n);
|
|
});
|
|
|
|
test('should push selected resources', async ({ n8n }) => {
|
|
// Create multiple workflows
|
|
const workflowA = await n8n.api.workflows.createWorkflow({
|
|
name: 'Workflow A',
|
|
nodes: [],
|
|
connections: {},
|
|
active: false,
|
|
});
|
|
|
|
await n8n.api.workflows.createWorkflow({
|
|
name: 'Workflow B',
|
|
nodes: [],
|
|
connections: {},
|
|
active: false,
|
|
});
|
|
|
|
await n8n.api.workflows.createWorkflow({
|
|
name: 'Workflow C',
|
|
nodes: [],
|
|
connections: {},
|
|
active: false,
|
|
});
|
|
|
|
// check resources
|
|
await n8n.navigate.toHome();
|
|
await expect(n8n.workflows.cards.getWorkflow('Workflow A')).toBeVisible();
|
|
await expect(n8n.workflows.cards.getWorkflow('Workflow B')).toBeVisible();
|
|
await expect(n8n.workflows.cards.getWorkflow('Workflow C')).toBeVisible();
|
|
|
|
await n8n.sideBar.getSourceControlPushButton().click();
|
|
await expect(n8n.sourceControlPushModal.container).toBeVisible();
|
|
await expect(n8n.sourceControlPushModal.getFileCheckboxByName('Workflow A')).toBeVisible();
|
|
await expect(n8n.sourceControlPushModal.getFileCheckboxByName('Workflow B')).toBeVisible();
|
|
await expect(n8n.sourceControlPushModal.getFileCheckboxByName('Workflow C')).toBeVisible();
|
|
|
|
// select
|
|
await n8n.sourceControlPushModal.selectFile('Workflow A');
|
|
await n8n.sourceControlPushModal.selectFile('Workflow C');
|
|
|
|
await expect(n8n.sourceControlPushModal.getFileCheckboxByName('Workflow A')).toBeChecked();
|
|
await expect(
|
|
n8n.sourceControlPushModal.getFileCheckboxByName('Workflow B'),
|
|
).not.toBeChecked();
|
|
await expect(n8n.sourceControlPushModal.getFileCheckboxByName('Workflow C')).toBeChecked();
|
|
|
|
// push and wait for commit
|
|
await gitRepo.pushAndWait(n8n, 'Push workflows A and C');
|
|
await expectPushSuccess(n8n);
|
|
|
|
// modify workflow A
|
|
await n8n.navigate.toWorkflow(workflowA.id);
|
|
await n8n.canvas.addNode(MANUAL_TRIGGER_NODE_NAME);
|
|
await n8n.canvas.waitForSaveWorkflowCompleted();
|
|
|
|
// check resources
|
|
await n8n.navigate.toHome();
|
|
await n8n.sideBar.getSourceControlPushButton().click();
|
|
await expect(n8n.sourceControlPushModal.container).toBeVisible();
|
|
|
|
await expect(n8n.sourceControlPushModal.getFileCheckboxByName('Workflow A')).toBeVisible();
|
|
await expect(n8n.sourceControlPushModal.getFileCheckboxByName('Workflow B')).toBeVisible();
|
|
await expect(n8n.sourceControlPushModal.getFileCheckboxByName('Workflow C')).toBeHidden();
|
|
|
|
await n8n.sourceControlPushModal.selectFile('Workflow A');
|
|
await n8n.sourceControlPushModal.selectFile('Workflow B');
|
|
|
|
// push and wait for commit
|
|
await gitRepo.pushAndWait(n8n, 'Push workflow A and B');
|
|
await expectPushSuccess(n8n);
|
|
|
|
// Verify no more changes
|
|
await n8n.sideBar.getSourceControlPushButton().click();
|
|
await expectNoChangesToCommit(n8n);
|
|
});
|
|
},
|
|
);
|