feat(editor): Workflow history [WIP]- Improve switching between workflow history and editor (no-changelog) (#7353)

This commit is contained in:
Csaba Tuncsik
2023-10-05 15:49:59 +02:00
committed by GitHub
parent 1a661e6d00
commit cd12a5990a
7 changed files with 48 additions and 71 deletions

View File

@@ -106,7 +106,13 @@
:to="workflowHistoryRoute" :to="workflowHistoryRoute"
:class="$style.workflowHistoryButton" :class="$style.workflowHistoryButton"
> >
<n8n-icon icon="history" size="medium" /> <n8n-icon-button
:disabled="isWorkflowHistoryButtonDisabled"
type="tertiary"
icon="history"
size="medium"
text
/>
</router-link> </router-link>
<div :class="$style.workflowMenuContainer"> <div :class="$style.workflowMenuContainer">
<input <input
@@ -355,6 +361,9 @@ export default defineComponent({
}, },
}; };
}, },
isWorkflowHistoryButtonDisabled(): boolean {
return this.workflowsStore.isNewWorkflow;
},
}, },
methods: { methods: {
async onSaveButtonClick() { async onSaveButtonClick() {
@@ -714,5 +723,11 @@ $--header-spacing: 20px;
.workflowHistoryButton { .workflowHistoryButton {
margin-left: var(--spacing-l); margin-left: var(--spacing-l);
color: var(--color-text-dark); color: var(--color-text-dark);
:disabled {
background: transparent;
border: none;
opacity: 0.5;
}
} }
</style> </style>

View File

@@ -1,17 +1,18 @@
import { faker } from '@faker-js/faker'; import { faker } from '@faker-js/faker';
import type { WorkflowHistory } from '@/types/workflowHistory'; import type { WorkflowHistory, WorkflowVersion } from '@/types/workflowHistory';
export const workflowHistoryDataFactory: () => WorkflowHistory = () => ({ export const workflowHistoryDataFactory: () => WorkflowHistory = () => ({
versionId: faker.string.nanoid(), versionId: faker.string.nanoid(),
createdAt: faker.date.past().toDateString(), createdAt: faker.date.past().toDateString(),
updatedAt: faker.date.past().toDateString(),
authors: Array.from({ length: faker.number.int({ min: 2, max: 5 }) }, faker.person.fullName).join( authors: Array.from({ length: faker.number.int({ min: 2, max: 5 }) }, faker.person.fullName).join(
', ', ', ',
), ),
}); });
export const workflowVersionDataFactory: () => WorkflowHistory = () => ({ export const workflowVersionDataFactory: () => WorkflowVersion = () => ({
...workflowHistoryDataFactory(), ...workflowHistoryDataFactory(),
workflow: { workflowId: faker.string.nanoid(),
name: faker.lorem.words(3), connections: {},
}, nodes: [],
}); });

View File

@@ -1,36 +1,13 @@
import { createPinia, setActivePinia } from 'pinia'; import { createPinia, setActivePinia } from 'pinia';
import type { IN8nUISettings } from 'n8n-workflow';
import { useWorkflowHistoryStore } from '@/stores/workflowHistory.store'; import { useWorkflowHistoryStore } from '@/stores/workflowHistory.store';
import { useSettingsStore } from '@/stores/settings.store'; import { useSettingsStore } from '@/stores/settings.store';
import {
workflowHistoryDataFactory,
workflowVersionDataFactory,
} from '@/stores/__tests__/utils/workflowHistoryTestUtils';
const historyData = Array.from({ length: 5 }, workflowHistoryDataFactory);
const versionData = {
...workflowVersionDataFactory(),
...historyData[0],
};
describe('Workflow history store', () => { describe('Workflow history store', () => {
beforeEach(() => { beforeEach(() => {
setActivePinia(createPinia()); setActivePinia(createPinia());
}); });
it('should reset data', () => {
const workflowHistoryStore = useWorkflowHistoryStore();
workflowHistoryStore.addWorkflowHistory(historyData);
workflowHistoryStore.setActiveWorkflowVersion(versionData);
expect(workflowHistoryStore.workflowHistory).toEqual(historyData);
expect(workflowHistoryStore.activeWorkflowVersion).toEqual(versionData);
workflowHistoryStore.reset();
expect(workflowHistoryStore.workflowHistory).toEqual([]);
expect(workflowHistoryStore.activeWorkflowVersion).toEqual(null);
});
test.each([ test.each([
[true, 1, 1], [true, 1, 1],
[true, 2, 2], [true, 2, 2],
@@ -49,7 +26,7 @@ describe('Workflow history store', () => {
pruneTime, pruneTime,
licensePruneTime, licensePruneTime,
}, },
}; } as IN8nUISettings;
expect(workflowHistoryStore.shouldUpgrade).toBe(shouldUpgrade); expect(workflowHistoryStore.shouldUpgrade).toBe(shouldUpgrade);
}, },

View File

@@ -1,4 +1,4 @@
import { ref, computed } from 'vue'; import { computed } from 'vue';
import { defineStore } from 'pinia'; import { defineStore } from 'pinia';
import * as whApi from '@/api/workflowHistory'; import * as whApi from '@/api/workflowHistory';
import { useRootStore } from '@/stores/n8nRoot.store'; import { useRootStore } from '@/stores/n8nRoot.store';
@@ -13,8 +13,6 @@ export const useWorkflowHistoryStore = defineStore('workflowHistory', () => {
const rootStore = useRootStore(); const rootStore = useRootStore();
const settingsStore = useSettingsStore(); const settingsStore = useSettingsStore();
const workflowHistory = ref<WorkflowHistory[]>([]);
const activeWorkflowVersion = ref<WorkflowVersion | null>(null);
const licensePruneTime = computed(() => settingsStore.settings.workflowHistory.licensePruneTime); const licensePruneTime = computed(() => settingsStore.settings.workflowHistory.licensePruneTime);
const pruneTime = computed(() => settingsStore.settings.workflowHistory.pruneTime); const pruneTime = computed(() => settingsStore.settings.workflowHistory.pruneTime);
const evaluatedPruneTime = computed(() => Math.min(pruneTime.value, licensePruneTime.value)); const evaluatedPruneTime = computed(() => Math.min(pruneTime.value, licensePruneTime.value));
@@ -22,11 +20,6 @@ export const useWorkflowHistoryStore = defineStore('workflowHistory', () => {
() => licensePruneTime.value !== -1 && licensePruneTime.value === pruneTime.value, () => licensePruneTime.value !== -1 && licensePruneTime.value === pruneTime.value,
); );
const reset = () => {
workflowHistory.value = [];
activeWorkflowVersion.value = null;
};
const getWorkflowHistory = async ( const getWorkflowHistory = async (
workflowId: string, workflowId: string,
queryParams: WorkflowHistoryRequestParams, queryParams: WorkflowHistoryRequestParams,
@@ -37,9 +30,6 @@ export const useWorkflowHistoryStore = defineStore('workflowHistory', () => {
console.error(error); console.error(error);
return [] as WorkflowHistory[]; return [] as WorkflowHistory[];
}); });
const addWorkflowHistory = (history: WorkflowHistory[]) => {
workflowHistory.value = workflowHistory.value.concat(history);
};
const getWorkflowVersion = async ( const getWorkflowVersion = async (
workflowId: string, workflowId: string,
@@ -49,18 +39,10 @@ export const useWorkflowHistoryStore = defineStore('workflowHistory', () => {
console.error(error); console.error(error);
return null; return null;
}); });
const setActiveWorkflowVersion = (version: WorkflowVersion | null) => {
activeWorkflowVersion.value = version;
};
return { return {
reset,
getWorkflowHistory, getWorkflowHistory,
addWorkflowHistory,
getWorkflowVersion, getWorkflowVersion,
setActiveWorkflowVersion,
workflowHistory,
activeWorkflowVersion,
evaluatedPruneTime, evaluatedPruneTime,
shouldUpgrade, shouldUpgrade,
}; };

View File

@@ -1,17 +1,19 @@
import type { IWorkflowDb } from '@/Interface'; import type { IConnections } from 'n8n-workflow';
import type { INodeUi } from '@/Interface';
export type WorkflowHistory = { export type WorkflowHistory = {
versionId: string; versionId: string;
authors: string; authors: string;
createdAt: string; createdAt: string;
updatedAt: string;
}; };
export type WorkflowVersionId = WorkflowHistory['versionId']; export type WorkflowVersionId = WorkflowHistory['versionId'];
export type WorkflowVersion = WorkflowHistory & { export type WorkflowVersion = WorkflowHistory & {
nodes: IWorkflowDb['nodes']; workflowId: string;
connection: IWorkflowDb['connections']; nodes: INodeUi[];
workflow: IWorkflowDb; connections: IConnections;
}; };
export type WorkflowHistoryActionTypes = ['restore', 'clone', 'open', 'download']; export type WorkflowHistoryActionTypes = ['restore', 'clone', 'open', 'download'];

View File

@@ -1,6 +1,6 @@
<script setup lang="ts"> <script setup lang="ts">
import { saveAs } from 'file-saver'; import { saveAs } from 'file-saver';
import { onBeforeMount, onUnmounted, ref, watchEffect, computed } from 'vue'; import { onBeforeMount, ref, watchEffect, computed } from 'vue';
import { useRoute, useRouter } from 'vue-router'; import { useRoute, useRouter } from 'vue-router';
import type { IWorkflowDb } from '@/Interface'; import type { IWorkflowDb } from '@/Interface';
import { VIEWS } from '@/constants'; import { VIEWS } from '@/constants';
@@ -9,6 +9,8 @@ import type {
WorkflowHistoryActionTypes, WorkflowHistoryActionTypes,
WorkflowVersionId, WorkflowVersionId,
WorkflowHistoryRequestParams, WorkflowHistoryRequestParams,
WorkflowHistory,
WorkflowVersion,
} from '@/types/workflowHistory'; } from '@/types/workflowHistory';
import WorkflowHistoryList from '@/components/WorkflowHistory/WorkflowHistoryList.vue'; import WorkflowHistoryList from '@/components/WorkflowHistory/WorkflowHistoryList.vue';
import WorkflowHistoryContent from '@/components/WorkflowHistory/WorkflowHistoryContent.vue'; import WorkflowHistoryContent from '@/components/WorkflowHistory/WorkflowHistoryContent.vue';
@@ -48,12 +50,14 @@ const editorRoute = computed(() => ({
}, },
})); }));
const activeWorkflow = ref<IWorkflowDb | null>(null); const activeWorkflow = ref<IWorkflowDb | null>(null);
const workflowHistory = ref<WorkflowHistory[]>([]);
const activeWorkflowVersion = ref<WorkflowVersion | null>(null);
const activeWorkflowVersionPreview = computed<IWorkflowDb | null>(() => { const activeWorkflowVersionPreview = computed<IWorkflowDb | null>(() => {
if (workflowHistoryStore.activeWorkflowVersion && activeWorkflow.value) { if (activeWorkflowVersion.value && activeWorkflow.value) {
return { return {
...activeWorkflow.value, ...activeWorkflow.value,
nodes: workflowHistoryStore.activeWorkflowVersion.nodes, nodes: activeWorkflowVersion.value.nodes,
connections: workflowHistoryStore.activeWorkflowVersion.connections, connections: activeWorkflowVersion.value.connections,
}; };
} }
return null; return null;
@@ -65,7 +69,7 @@ const loadMore = async (queryParams: WorkflowHistoryRequestParams) => {
queryParams, queryParams,
); );
lastReceivedItemsLength.value = history.length; lastReceivedItemsLength.value = history.length;
workflowHistoryStore.addWorkflowHistory(history); workflowHistory.value.push(...history);
}; };
onBeforeMount(async () => { onBeforeMount(async () => {
@@ -76,21 +80,17 @@ onBeforeMount(async () => {
activeWorkflow.value = workflow; activeWorkflow.value = workflow;
isListLoading.value = false; isListLoading.value = false;
if (!route.params.versionId && workflowHistoryStore.workflowHistory.length) { if (!route.params.versionId && workflowHistory.value.length) {
await router.replace({ await router.replace({
name: VIEWS.WORKFLOW_HISTORY, name: VIEWS.WORKFLOW_HISTORY,
params: { params: {
workflowId: route.params.workflowId, workflowId: route.params.workflowId,
versionId: workflowHistoryStore.workflowHistory[0].versionId, versionId: workflowHistory.value[0].versionId,
}, },
}); });
} }
}); });
onUnmounted(() => {
workflowHistoryStore.reset();
});
const openInNewTab = (id: WorkflowVersionId) => { const openInNewTab = (id: WorkflowVersionId) => {
const { href } = router.resolve({ const { href } = router.resolve({
name: VIEWS.WORKFLOW_HISTORY, name: VIEWS.WORKFLOW_HISTORY,
@@ -165,7 +165,7 @@ watchEffect(async () => {
route.params.workflowId, route.params.workflowId,
route.params.versionId, route.params.versionId,
); );
workflowHistoryStore.setActiveWorkflowVersion(workflowVersion); activeWorkflowVersion.value = workflowVersion;
} }
}); });
</script> </script>
@@ -187,9 +187,9 @@ watchEffect(async () => {
</div> </div>
<div :class="$style.listComponentWrapper"> <div :class="$style.listComponentWrapper">
<workflow-history-list <workflow-history-list
:items="workflowHistoryStore.workflowHistory" :items="workflowHistory"
:lastReceivedItemsLength="lastReceivedItemsLength" :lastReceivedItemsLength="lastReceivedItemsLength"
:activeItem="workflowHistoryStore.activeWorkflowVersion" :activeItem="activeWorkflowVersion"
:actionTypes="workflowHistoryActionTypes" :actionTypes="workflowHistoryActionTypes"
:requestNumberOfItems="requestNumberOfItems" :requestNumberOfItems="requestNumberOfItems"
:shouldUpgrade="workflowHistoryStore.shouldUpgrade" :shouldUpgrade="workflowHistoryStore.shouldUpgrade"

View File

@@ -14,6 +14,7 @@ import {
workflowHistoryDataFactory, workflowHistoryDataFactory,
workflowVersionDataFactory, workflowVersionDataFactory,
} from '@/stores/__tests__/utils/workflowHistoryTestUtils'; } from '@/stores/__tests__/utils/workflowHistoryTestUtils';
import type { WorkflowVersion } from '@/types/workflowHistory';
vi.mock('vue-router', () => { vi.mock('vue-router', () => {
const params = {}; const params = {};
@@ -34,7 +35,7 @@ vi.mock('vue-router', () => {
const workflowId = faker.string.nanoid(); const workflowId = faker.string.nanoid();
const historyData = Array.from({ length: 5 }, workflowHistoryDataFactory); const historyData = Array.from({ length: 5 }, workflowHistoryDataFactory);
const versionData = { const versionData: WorkflowVersion = {
...workflowVersionDataFactory(), ...workflowVersionDataFactory(),
...historyData[0], ...historyData[0],
}; };
@@ -76,8 +77,7 @@ describe('WorkflowHistory', () => {
router = useRouter(); router = useRouter();
vi.spyOn(workflowHistoryStore, 'getWorkflowHistory').mockResolvedValue(historyData); vi.spyOn(workflowHistoryStore, 'getWorkflowHistory').mockResolvedValue(historyData);
vi.spyOn(workflowHistoryStore, 'workflowHistory', 'get').mockReturnValue(historyData); vi.spyOn(workflowHistoryStore, 'getWorkflowVersion').mockResolvedValue(versionData);
vi.spyOn(workflowHistoryStore, 'activeWorkflowVersion', 'get').mockReturnValue(versionData);
windowOpenSpy = vi.spyOn(window, 'open').mockImplementation(() => null); windowOpenSpy = vi.spyOn(window, 'open').mockImplementation(() => null);
}); });