mirror of
https://github.com/n8n-io/n8n.git
synced 2024-11-15 09:04:07 -08:00
1b321416c0
* implement basic git service * cleanup connected prop * add skeleton of git functions * initial import/export setup * split out export service * refactor and improve export * begin import * more commands and basic import * clean up imports with transactions * work folder import functions * reintroduce versionid * add missing import to pull workfolder * add get-status endpoint * add cleanup to disconnect * add initRepo options * add more checks and cleanup * minor cleanup * refactor prefs * fix server.ts * fix sending deleted files * rename files to ee * add variable override and fix critical cred import bug * fix mkdir race condition * make initRepo default to true * fix front back integration * improve connect flow * add comment to generated ssh key * fix(editor): use useToast composable * fix buttons size * commenting out repo init for now * fix(editor): update UI logic * fix(editor): remove console.log * fix(editor): remove unused ref * adjust endpoints for improved UI * fix(editor): add push and pull buttons * keep or not ssh key * switching file name to id * fix(editor): add success messages, fix save button * fixed faulty diff preventing pull * fix build * fix(editor): adding loader to VC components * removing duplicate exports * improve conflict finding on push pull * manage pull conflict * alternate push pull * fix pull confirmation * fix rm and credential export/import * switch to alternative pull implementation * fix initial commit * fix(editor): subscribing to VC store action to refresh lists * fix(editor): wrap VC store actions with try * feat: add fine-grained file selection for push action * fix: close modal after successful push * fix(editor): VC preferences validation * fix confirm * fix: update endpoint to /get-status * feat: update pull modal override changes message * fix missing wf error * undo * removing connect endpoint * fix(editor): add button titles * fix(editor): cleaning up store action * add version-control/set-read-only protection * fix(editor): adding set branch readonly * fix(editor): remove Push button if branch set to readonly * fix(editor): fix some styles * fix(editor): remove duplicate and delete actions in WF list when branch is readonly * fix: load status before opening selective push modal * fix(editor): extend readonly logic * add cleanup after failed initRepo * fix deleted files crashing get-status * fix n8n-checkbox in staging dialog * fix(editor): fix loading * fix(editor): resize buttons * fix(editor): fix translation * fix(editor): fix copy text size * fix(editor): fix copy text size * fix(editor): add disconnection confirmation * fix(editor): add disconnection confirmation * fix(editor): set large buttons * add public api Pull endpoint * feat: add refresh ssh key * return prefs when new keys are generated * fix(editor): adding readOnly mode to main header * fix(editor): adding readOnly mode to workflow settings * improve credential owner import * add middleware to endpoints * improve public api error/doc * do not create branch if one already exists * update wordings for connect toasts * fix(editor): updating and separating readonly modes * fix(editor): fix readonly mode in WF list * fix(editor): disable elements dragging on canvas in readonly mode (WIP: not working when NodeView page is loaded first) * fix(editor): fix canvas draggables in readonly env * fix(editor): remove unused variables * fix(editor): hide actions in node connections when readonly * fix(editor): hide actions in node connections when readonly * fix(editor): disable Save button when readonly * fix(editor): disable Save settings if no branch is selected * fix(editor): lint fix * fix(editor): update snapshots * fix(editor): replace Loading... text * fix(editor): reset Loading... text * reset branchname on disconnect * fix(editor): adding some translations * fix(editor): fix unit test * fix(editor): fix loading * fix(editor): set settings saved message * fix(editor): update connection flag * fix branchName not returning after connect * temporary (but still breaking) fix for postgres * fix(editor): adding tooltip to Push/Pull buttons when they're collapsed * fix(editor): enabled activator in readonly mode * fix test * fix(editor): disabling new item addition for workflows in readonly mode * fix(editor): modify Pull/Push button tooltips * do not commit empty variables file --------- Co-authored-by: Michael Auerswald <michael.auerswald@gmail.com> Co-authored-by: Romain Minaud <romain.minaud@gmail.com> Co-authored-by: Alex Grozav <alex@grozav.com>
1134 lines
27 KiB
Vue
1134 lines
27 KiB
Vue
<template>
|
|
<div
|
|
:class="{ 'node-wrapper': true, 'node-wrapper--trigger': isTriggerNode }"
|
|
:style="nodePosition"
|
|
:id="nodeId"
|
|
data-test-id="canvas-node"
|
|
:ref="data.name"
|
|
:data-name="data.name"
|
|
>
|
|
<div class="select-background" v-show="isSelected"></div>
|
|
<div
|
|
:class="{
|
|
'node-default': true,
|
|
'touch-active': isTouchActive,
|
|
'is-touch-device': isTouchDevice,
|
|
}"
|
|
>
|
|
<div
|
|
:class="nodeClass"
|
|
:style="nodeStyle"
|
|
@click.left="onClick"
|
|
v-touch:start="touchStart"
|
|
v-touch:end="touchEnd"
|
|
>
|
|
<i class="trigger-icon" v-if="isTriggerNode">
|
|
<n8n-tooltip placement="bottom">
|
|
<template #content>
|
|
<span v-html="$locale.baseText('node.thisIsATriggerNode')" />
|
|
</template>
|
|
<font-awesome-icon icon="bolt" size="lg" />
|
|
</n8n-tooltip>
|
|
</i>
|
|
<div
|
|
v-if="!data.disabled"
|
|
:class="{ 'node-info-icon': true, 'shift-icon': shiftOutputCount }"
|
|
>
|
|
<div v-if="hasIssues" class="node-issues">
|
|
<n8n-tooltip placement="bottom">
|
|
<template #content>
|
|
<titled-list :title="`${$locale.baseText('node.issues')}:`" :items="nodeIssues" />
|
|
</template>
|
|
<font-awesome-icon icon="exclamation-triangle" />
|
|
</n8n-tooltip>
|
|
</div>
|
|
<div v-else-if="waiting || nodeExecutionStatus === 'waiting'" class="waiting">
|
|
<n8n-tooltip placement="bottom">
|
|
<template #content>
|
|
<div v-text="waiting"></div>
|
|
</template>
|
|
<font-awesome-icon icon="clock" />
|
|
</n8n-tooltip>
|
|
</div>
|
|
<span v-else-if="showPinnedDataInfo" class="node-pin-data-icon">
|
|
<font-awesome-icon icon="thumbtack" />
|
|
<span v-if="workflowDataItems > 1" class="items-count"> {{ workflowDataItems }}</span>
|
|
</span>
|
|
<span v-else-if="nodeExecutionStatus === 'unknown'">
|
|
<!-- Do nothing, unknown means the node never executed -->
|
|
</span>
|
|
<span v-else-if="workflowDataItems" class="data-count">
|
|
<font-awesome-icon icon="check" />
|
|
<span v-if="workflowDataItems > 1" class="items-count"> {{ workflowDataItems }}</span>
|
|
</span>
|
|
</div>
|
|
|
|
<div class="node-executing-info" :title="$locale.baseText('node.nodeIsExecuting')">
|
|
<font-awesome-icon icon="sync-alt" spin />
|
|
</div>
|
|
|
|
<div class="node-trigger-tooltip__wrapper">
|
|
<n8n-tooltip
|
|
placement="top"
|
|
manual
|
|
:value="showTriggerNodeTooltip"
|
|
popper-class="node-trigger-tooltip__wrapper--item"
|
|
>
|
|
<template #content>
|
|
<div v-text="getTriggerNodeTooltip"></div>
|
|
</template>
|
|
<span />
|
|
</n8n-tooltip>
|
|
<n8n-tooltip
|
|
v-if="isTriggerNode"
|
|
placement="top"
|
|
manual
|
|
:value="pinDataDiscoveryTooltipVisible"
|
|
popper-class="node-trigger-tooltip__wrapper--item"
|
|
>
|
|
<template #content>
|
|
{{ $locale.baseText('node.discovery.pinData.canvas') }}
|
|
</template>
|
|
<span />
|
|
</n8n-tooltip>
|
|
</div>
|
|
|
|
<NodeIcon
|
|
class="node-icon"
|
|
:nodeType="nodeType"
|
|
:size="40"
|
|
:shrink="false"
|
|
:disabled="this.data.disabled"
|
|
/>
|
|
</div>
|
|
|
|
<div class="node-options no-select-on-click" v-if="!isReadOnly" v-show="!hideActions">
|
|
<div
|
|
v-touch:tap="deleteNode"
|
|
class="option"
|
|
:title="$locale.baseText('node.deleteNode')"
|
|
data-test-id="delete-node-button"
|
|
>
|
|
<font-awesome-icon icon="trash" />
|
|
</div>
|
|
<div
|
|
v-touch:tap="disableNode"
|
|
class="option"
|
|
:title="$locale.baseText('node.activateDeactivateNode')"
|
|
data-test-id="disable-node-button"
|
|
>
|
|
<font-awesome-icon :icon="nodeDisabledIcon" />
|
|
</div>
|
|
<div
|
|
v-touch:tap="duplicateNode"
|
|
class="option"
|
|
:title="$locale.baseText('node.duplicateNode')"
|
|
v-if="isDuplicatable"
|
|
data-test-id="duplicate-node-button"
|
|
>
|
|
<font-awesome-icon icon="clone" />
|
|
</div>
|
|
<div
|
|
v-touch:tap="setNodeActive"
|
|
class="option touch"
|
|
:title="$locale.baseText('node.editNode')"
|
|
data-test-id="activate-node-button"
|
|
>
|
|
<font-awesome-icon class="execute-icon" icon="cog" />
|
|
</div>
|
|
<div
|
|
v-touch:tap="executeNode"
|
|
class="option"
|
|
:title="$locale.baseText('node.executeNode')"
|
|
v-if="!workflowRunning"
|
|
data-test-id="execute-node-button"
|
|
>
|
|
<font-awesome-icon class="execute-icon" icon="play-circle" />
|
|
</div>
|
|
</div>
|
|
<div
|
|
:class="{
|
|
'disabled-linethrough': true,
|
|
success: !['unknown'].includes(nodeExecutionStatus) && workflowDataItems > 0,
|
|
}"
|
|
v-if="showDisabledLinethrough"
|
|
></div>
|
|
</div>
|
|
<div class="node-description">
|
|
<div class="node-name ph-no-capture" :title="nodeTitle">
|
|
<p data-test-id="canvas-node-box-title">
|
|
{{ nodeTitle }}
|
|
</p>
|
|
<p v-if="data.disabled">({{ $locale.baseText('node.disabled') }})</p>
|
|
</div>
|
|
<div v-if="nodeSubtitle !== undefined" class="node-subtitle" :title="nodeSubtitle">
|
|
{{ nodeSubtitle }}
|
|
</div>
|
|
</div>
|
|
</div>
|
|
</template>
|
|
|
|
<script lang="ts">
|
|
import Vue, { defineComponent } from 'vue';
|
|
import { mapStores } from 'pinia';
|
|
import {
|
|
CUSTOM_API_CALL_KEY,
|
|
LOCAL_STORAGE_PIN_DATA_DISCOVERY_CANVAS_FLAG,
|
|
WAIT_TIME_UNLIMITED,
|
|
MANUAL_TRIGGER_NODE_TYPE,
|
|
} from '@/constants';
|
|
import { externalHooks } from '@/mixins/externalHooks';
|
|
import { nodeBase } from '@/mixins/nodeBase';
|
|
import { nodeHelpers } from '@/mixins/nodeHelpers';
|
|
import { workflowHelpers } from '@/mixins/workflowHelpers';
|
|
import { pinData } from '@/mixins/pinData';
|
|
|
|
import type { IExecutionsSummary, INodeTypeDescription, ITaskData } from 'n8n-workflow';
|
|
import { NodeHelpers } from 'n8n-workflow';
|
|
|
|
import NodeIcon from '@/components/NodeIcon.vue';
|
|
import TitledList from '@/components/TitledList.vue';
|
|
|
|
import { get } from 'lodash-es';
|
|
import { getStyleTokenValue, getTriggerNodeServiceName } from '@/utils';
|
|
import type { INodeUi, XYPosition } from '@/Interface';
|
|
import { debounceHelper } from '@/mixins/debounce';
|
|
import { useUIStore } from '@/stores/ui.store';
|
|
import { useWorkflowsStore } from '@/stores/workflows.store';
|
|
import { useNDVStore } from '@/stores/ndv.store';
|
|
import { useNodeTypesStore } from '@/stores/nodeTypes.store';
|
|
import { EnableNodeToggleCommand } from '@/models/history';
|
|
import { FontAwesomeIcon } from '@fortawesome/vue-fontawesome';
|
|
|
|
export default defineComponent({
|
|
name: 'Node',
|
|
mixins: [externalHooks, nodeBase, nodeHelpers, workflowHelpers, pinData, debounceHelper],
|
|
components: {
|
|
TitledList,
|
|
FontAwesomeIcon,
|
|
NodeIcon,
|
|
},
|
|
props: {
|
|
isProductionExecutionPreview: {
|
|
type: Boolean,
|
|
default: false,
|
|
},
|
|
},
|
|
computed: {
|
|
...mapStores(useNodeTypesStore, useNDVStore, useUIStore, useWorkflowsStore),
|
|
showPinnedDataInfo(): boolean {
|
|
return this.hasPinData && !this.isProductionExecutionPreview;
|
|
},
|
|
isDuplicatable(): boolean {
|
|
if (!this.nodeType) return true;
|
|
return (
|
|
this.nodeType.maxNodes === undefined || this.sameTypeNodes.length < this.nodeType.maxNodes
|
|
);
|
|
},
|
|
isScheduledGroup(): boolean {
|
|
return this.nodeType?.group.includes('schedule') === true;
|
|
},
|
|
nodeRunData(): ITaskData[] {
|
|
return this.workflowsStore.getWorkflowResultDataByNodeName(this.data?.name || '') || [];
|
|
},
|
|
hasIssues(): boolean {
|
|
if (
|
|
this.nodeExecutionStatus &&
|
|
['crashed', 'error', 'failed'].includes(this.nodeExecutionStatus)
|
|
)
|
|
return true;
|
|
if (this.hasPinData) return false;
|
|
if (this.data?.issues !== undefined && Object.keys(this.data.issues).length) {
|
|
return true;
|
|
}
|
|
return false;
|
|
},
|
|
workflowDataItems(): number {
|
|
const workflowResultDataNode = this.nodeRunData;
|
|
if (workflowResultDataNode === null) {
|
|
return 0;
|
|
}
|
|
|
|
return workflowResultDataNode.length;
|
|
},
|
|
canvasOffsetPosition() {
|
|
return this.uiStore.nodeViewOffsetPosition;
|
|
},
|
|
getTriggerNodeTooltip(): string | undefined {
|
|
if (this.nodeType !== null && this.nodeType.hasOwnProperty('eventTriggerDescription')) {
|
|
const nodeName = this.$locale.shortNodeType(this.nodeType.name);
|
|
const { eventTriggerDescription } = this.nodeType;
|
|
return this.$locale
|
|
.nodeText()
|
|
.eventTriggerDescription(nodeName, eventTriggerDescription || '');
|
|
} else {
|
|
return this.$locale.baseText('node.waitingForYouToCreateAnEventIn', {
|
|
interpolate: {
|
|
nodeType: this.nodeType ? getTriggerNodeServiceName(this.nodeType) : '',
|
|
},
|
|
});
|
|
}
|
|
},
|
|
isPollingTypeNode(): boolean {
|
|
return !!(this.nodeType && this.nodeType.polling);
|
|
},
|
|
isExecuting(): boolean {
|
|
return this.workflowsStore.executingNode === this.data.name;
|
|
},
|
|
isSingleActiveTriggerNode(): boolean {
|
|
const nodes = this.workflowsStore.workflowTriggerNodes.filter((node: INodeUi) => {
|
|
const nodeType = this.nodeTypesStore.getNodeType(node.type, node.typeVersion);
|
|
return nodeType && nodeType.eventTriggerDescription !== '' && !node.disabled;
|
|
});
|
|
|
|
return nodes.length === 1;
|
|
},
|
|
isManualTypeNode(): boolean {
|
|
return this.data.type === MANUAL_TRIGGER_NODE_TYPE;
|
|
},
|
|
isTriggerNode(): boolean {
|
|
return this.nodeTypesStore.isTriggerNode(this.data?.type || '');
|
|
},
|
|
isTriggerNodeTooltipEmpty(): boolean {
|
|
return this.nodeType !== null ? this.nodeType.eventTriggerDescription === '' : false;
|
|
},
|
|
isNodeDisabled(): boolean | undefined {
|
|
return this.node && this.node.disabled;
|
|
},
|
|
nodeType(): INodeTypeDescription | null {
|
|
return this.data && this.nodeTypesStore.getNodeType(this.data.type, this.data.typeVersion);
|
|
},
|
|
node(): INodeUi | undefined {
|
|
// same as this.data but reactive..
|
|
return this.workflowsStore.nodesByName[this.name] as INodeUi | undefined;
|
|
},
|
|
sameTypeNodes(): INodeUi[] {
|
|
return this.workflowsStore.allNodes.filter((node: INodeUi) => node.type === this.data.type);
|
|
},
|
|
nodeClass(): object {
|
|
return {
|
|
'node-box': true,
|
|
disabled: this.data.disabled,
|
|
executing: this.isExecuting,
|
|
};
|
|
},
|
|
nodeExecutionStatus(): string {
|
|
const nodeExecutionRunData = this.workflowsStore.getWorkflowRunData?.[this.name];
|
|
if (nodeExecutionRunData) {
|
|
return nodeExecutionRunData[0].executionStatus ?? '';
|
|
}
|
|
return '';
|
|
},
|
|
nodeIssues(): string[] {
|
|
const issues: string[] = [];
|
|
const nodeExecutionRunData = this.workflowsStore.getWorkflowRunData?.[this.name];
|
|
if (nodeExecutionRunData) {
|
|
nodeExecutionRunData.forEach((executionRunData) => {
|
|
if (executionRunData.error) {
|
|
issues.push(
|
|
`${executionRunData.error.message}${
|
|
executionRunData.error.description ? ` (${executionRunData.error.description})` : ''
|
|
}`,
|
|
);
|
|
}
|
|
});
|
|
}
|
|
if (this.data?.issues !== undefined) {
|
|
issues.push(...NodeHelpers.nodeIssuesToString(this.data.issues, this.data));
|
|
}
|
|
return issues;
|
|
},
|
|
nodeDisabledIcon(): string {
|
|
if (this.data.disabled === false) {
|
|
return 'pause';
|
|
} else {
|
|
return 'play';
|
|
}
|
|
},
|
|
position(): XYPosition {
|
|
return this.node ? this.node.position : [0, 0];
|
|
},
|
|
showDisabledLinethrough(): boolean {
|
|
return !!(
|
|
this.data.disabled &&
|
|
this.nodeType &&
|
|
this.nodeType.inputs.length === 1 &&
|
|
this.nodeType.outputs.length === 1
|
|
);
|
|
},
|
|
nodePosition(): object {
|
|
const returnStyles: {
|
|
[key: string]: string;
|
|
} = {
|
|
left: this.position[0] + 'px',
|
|
top: this.position[1] + 'px',
|
|
};
|
|
|
|
return returnStyles;
|
|
},
|
|
shortNodeType(): string {
|
|
return this.$locale.shortNodeType(this.data.type);
|
|
},
|
|
nodeTitle(): string {
|
|
if (this.data.name === 'Start') {
|
|
return this.$locale.headerText({
|
|
key: 'headers.start.displayName',
|
|
fallback: 'Start',
|
|
});
|
|
}
|
|
|
|
return this.data.name;
|
|
},
|
|
waiting(): string | undefined {
|
|
const workflowExecution = this.workflowsStore.getWorkflowExecution as IExecutionsSummary;
|
|
|
|
if (workflowExecution && workflowExecution.waitTill) {
|
|
const lastNodeExecuted = get(workflowExecution, 'data.resultData.lastNodeExecuted');
|
|
if (this.name === lastNodeExecuted) {
|
|
const waitDate = new Date(workflowExecution.waitTill);
|
|
if (waitDate.toISOString() === WAIT_TIME_UNLIMITED) {
|
|
return this.$locale.baseText(
|
|
'node.theNodeIsWaitingIndefinitelyForAnIncomingWebhookCall',
|
|
);
|
|
}
|
|
return this.$locale.baseText('node.nodeIsWaitingTill', {
|
|
interpolate: {
|
|
date: waitDate.toLocaleDateString(),
|
|
time: waitDate.toLocaleTimeString(),
|
|
},
|
|
});
|
|
}
|
|
}
|
|
|
|
return undefined;
|
|
},
|
|
workflowRunning(): boolean {
|
|
return this.uiStore.isActionActive('workflowRunning');
|
|
},
|
|
nodeStyle(): object {
|
|
let borderColor = getStyleTokenValue('--color-foreground-xdark');
|
|
|
|
if (this.data.disabled) {
|
|
borderColor = getStyleTokenValue('--color-foreground-base');
|
|
} else if (!this.isExecuting) {
|
|
if (this.hasIssues) {
|
|
borderColor = getStyleTokenValue('--color-danger');
|
|
} else if (this.waiting || this.showPinnedDataInfo) {
|
|
borderColor = getStyleTokenValue('--color-secondary');
|
|
} else if (this.nodeExecutionStatus === 'unknown') {
|
|
borderColor = getStyleTokenValue('--color-foreground-xdark');
|
|
} else if (this.workflowDataItems) {
|
|
borderColor = getStyleTokenValue('--color-success');
|
|
}
|
|
}
|
|
|
|
const returnStyles: {
|
|
[key: string]: string;
|
|
} = {
|
|
'border-color': borderColor,
|
|
};
|
|
|
|
return returnStyles;
|
|
},
|
|
isSelected(): boolean {
|
|
return (
|
|
this.uiStore.getSelectedNodes.find((node: INodeUi) => node.name === this.data.name) !==
|
|
undefined
|
|
);
|
|
},
|
|
shiftOutputCount(): boolean {
|
|
return !!(this.nodeType && this.nodeType.outputs.length > 2);
|
|
},
|
|
shouldShowTriggerTooltip(): boolean {
|
|
return (
|
|
!!this.node &&
|
|
this.isTriggerNode &&
|
|
!this.isPollingTypeNode &&
|
|
!this.hasPinData &&
|
|
!this.isNodeDisabled &&
|
|
this.workflowRunning &&
|
|
this.workflowDataItems === 0 &&
|
|
this.isSingleActiveTriggerNode &&
|
|
!this.isTriggerNodeTooltipEmpty &&
|
|
!this.hasIssues &&
|
|
!this.dragging
|
|
);
|
|
},
|
|
},
|
|
watch: {
|
|
isActive(newValue, oldValue) {
|
|
if (!newValue && oldValue) {
|
|
this.setSubtitle();
|
|
}
|
|
},
|
|
canvasOffsetPosition() {
|
|
if (this.showTriggerNodeTooltip) {
|
|
this.showTriggerNodeTooltip = false;
|
|
setTimeout(() => {
|
|
this.showTriggerNodeTooltip = this.shouldShowTriggerTooltip;
|
|
}, 200);
|
|
}
|
|
|
|
if (this.pinDataDiscoveryTooltipVisible) {
|
|
this.pinDataDiscoveryTooltipVisible = false;
|
|
setTimeout(() => {
|
|
this.pinDataDiscoveryTooltipVisible = true;
|
|
}, 200);
|
|
}
|
|
},
|
|
shouldShowTriggerTooltip(shouldShowTriggerTooltip) {
|
|
if (shouldShowTriggerTooltip) {
|
|
setTimeout(() => {
|
|
this.showTriggerNodeTooltip = this.shouldShowTriggerTooltip;
|
|
}, 2500);
|
|
} else {
|
|
this.showTriggerNodeTooltip = false;
|
|
}
|
|
},
|
|
nodeRunData(newValue) {
|
|
this.$emit('run', { name: this.data.name, data: newValue, waiting: !!this.waiting });
|
|
},
|
|
},
|
|
created() {
|
|
const hasSeenPinDataTooltip = localStorage.getItem(
|
|
LOCAL_STORAGE_PIN_DATA_DISCOVERY_CANVAS_FLAG,
|
|
);
|
|
if (!hasSeenPinDataTooltip) {
|
|
this.unwatchWorkflowDataItems = this.$watch('workflowDataItems', (dataItemsCount: number) => {
|
|
this.showPinDataDiscoveryTooltip(dataItemsCount);
|
|
});
|
|
}
|
|
},
|
|
mounted() {
|
|
this.setSubtitle();
|
|
if (this.nodeRunData) {
|
|
setTimeout(() => {
|
|
this.$emit('run', {
|
|
name: this.data && this.data.name,
|
|
data: this.nodeRunData,
|
|
waiting: !!this.waiting,
|
|
});
|
|
}, 0);
|
|
}
|
|
},
|
|
data() {
|
|
return {
|
|
isTouchActive: false,
|
|
nodeSubtitle: '',
|
|
showTriggerNodeTooltip: false,
|
|
pinDataDiscoveryTooltipVisible: false,
|
|
dragging: false,
|
|
unwatchWorkflowDataItems: () => {},
|
|
};
|
|
},
|
|
methods: {
|
|
showPinDataDiscoveryTooltip(dataItemsCount: number): void {
|
|
if (
|
|
!this.isTriggerNode ||
|
|
this.isManualTypeNode ||
|
|
this.isScheduledGroup ||
|
|
dataItemsCount === 0
|
|
)
|
|
return;
|
|
|
|
localStorage.setItem(LOCAL_STORAGE_PIN_DATA_DISCOVERY_CANVAS_FLAG, 'true');
|
|
|
|
this.pinDataDiscoveryTooltipVisible = true;
|
|
this.unwatchWorkflowDataItems();
|
|
},
|
|
setSubtitle() {
|
|
const nodeSubtitle =
|
|
this.getNodeSubtitle(this.data, this.nodeType, this.getCurrentWorkflow()) || '';
|
|
|
|
this.nodeSubtitle = nodeSubtitle.includes(CUSTOM_API_CALL_KEY) ? '' : nodeSubtitle;
|
|
},
|
|
disableNode() {
|
|
if (this.data !== null) {
|
|
this.disableNodes([this.data]);
|
|
this.historyStore.pushCommandToUndo(
|
|
new EnableNodeToggleCommand(
|
|
this.data.name,
|
|
!this.data.disabled,
|
|
this.data.disabled === true,
|
|
),
|
|
);
|
|
this.$telemetry.track('User clicked node hover button', {
|
|
node_type: this.data.type,
|
|
button_name: 'disable',
|
|
workflow_id: this.workflowsStore.workflowId,
|
|
});
|
|
}
|
|
},
|
|
executeNode() {
|
|
this.$emit('runWorkflow', this.data.name, 'Node.executeNode');
|
|
this.$telemetry.track('User clicked node hover button', {
|
|
node_type: this.data.type,
|
|
button_name: 'execute',
|
|
workflow_id: this.workflowsStore.workflowId,
|
|
});
|
|
},
|
|
deleteNode() {
|
|
this.$telemetry.track('User clicked node hover button', {
|
|
node_type: this.data.type,
|
|
button_name: 'delete',
|
|
workflow_id: this.workflowsStore.workflowId,
|
|
});
|
|
|
|
Vue.nextTick(() => {
|
|
// Wait a tick else vue causes problems because the data is gone
|
|
this.$emit('removeNode', this.data.name);
|
|
});
|
|
},
|
|
duplicateNode() {
|
|
this.$telemetry.track('User clicked node hover button', {
|
|
node_type: this.data.type,
|
|
button_name: 'duplicate',
|
|
workflow_id: this.workflowsStore.workflowId,
|
|
});
|
|
Vue.nextTick(() => {
|
|
// Wait a tick else vue causes problems because the data is gone
|
|
this.$emit('duplicateNode', this.data.name);
|
|
});
|
|
},
|
|
|
|
onClick(event: MouseEvent) {
|
|
void this.callDebounced('onClickDebounced', { debounceTime: 50, trailing: true }, event);
|
|
},
|
|
|
|
onClickDebounced(event: MouseEvent) {
|
|
const isDoubleClick = event.detail >= 2;
|
|
if (isDoubleClick) {
|
|
this.setNodeActive();
|
|
} else {
|
|
this.mouseLeftClick(event);
|
|
}
|
|
},
|
|
|
|
setNodeActive() {
|
|
this.ndvStore.activeNodeName = this.data ? this.data.name : '';
|
|
this.pinDataDiscoveryTooltipVisible = false;
|
|
},
|
|
touchStart() {
|
|
if (this.isTouchDevice === true && this.isMacOs === false && this.isTouchActive === false) {
|
|
this.isTouchActive = true;
|
|
setTimeout(() => {
|
|
this.isTouchActive = false;
|
|
}, 2000);
|
|
}
|
|
},
|
|
},
|
|
});
|
|
</script>
|
|
|
|
<style lang="scss" scoped>
|
|
.node-wrapper {
|
|
position: absolute;
|
|
width: 100px;
|
|
height: 100px;
|
|
|
|
.node-description {
|
|
position: absolute;
|
|
top: 100px;
|
|
left: -50px;
|
|
line-height: 1.5;
|
|
text-align: center;
|
|
cursor: default;
|
|
padding: 8px;
|
|
width: 200px;
|
|
pointer-events: none; // prevent container from being draggable
|
|
|
|
.node-name > p {
|
|
// must be paragraph tag to have two lines in safari
|
|
text-overflow: ellipsis;
|
|
display: -webkit-box;
|
|
-webkit-box-orient: vertical;
|
|
-webkit-line-clamp: 2;
|
|
overflow: hidden;
|
|
overflow-wrap: anywhere;
|
|
font-weight: var(--font-weight-bold);
|
|
line-height: var(--font-line-height-compact);
|
|
}
|
|
|
|
.node-subtitle {
|
|
white-space: nowrap;
|
|
overflow: hidden;
|
|
text-overflow: ellipsis;
|
|
font-weight: 400;
|
|
color: $custom-font-light;
|
|
font-size: 0.8em;
|
|
}
|
|
}
|
|
|
|
.node-default {
|
|
position: absolute;
|
|
width: 100%;
|
|
height: 100%;
|
|
cursor: pointer;
|
|
|
|
.node-box {
|
|
width: 100%;
|
|
height: 100%;
|
|
border: 2px solid var(--color-foreground-xdark);
|
|
border-radius: var(--border-radius-large);
|
|
background-color: var(--color-background-xlight);
|
|
&.executing {
|
|
background-color: var(--color-primary-tint-3) !important;
|
|
|
|
.node-executing-info {
|
|
display: inline-block;
|
|
}
|
|
}
|
|
}
|
|
|
|
&.touch-active,
|
|
&:hover {
|
|
.node-execute {
|
|
display: initial;
|
|
}
|
|
|
|
.node-options {
|
|
display: initial;
|
|
}
|
|
}
|
|
|
|
.node-executing-info {
|
|
display: none;
|
|
position: absolute;
|
|
left: 0px;
|
|
top: 0px;
|
|
z-index: 12;
|
|
width: 100%;
|
|
height: 100%;
|
|
font-size: 3.75em;
|
|
line-height: 1.65em;
|
|
text-align: center;
|
|
color: hsla(var(--color-primary-h), var(--color-primary-s), var(--color-primary-l), 0.7);
|
|
}
|
|
|
|
.node-icon {
|
|
position: absolute;
|
|
top: calc(50% - 20px);
|
|
left: calc(50% - 20px);
|
|
}
|
|
|
|
.node-info-icon {
|
|
position: absolute;
|
|
bottom: 6px;
|
|
right: 6px;
|
|
|
|
&.shift-icon {
|
|
right: 12px;
|
|
}
|
|
|
|
.data-count {
|
|
font-weight: 600;
|
|
color: var(--color-success);
|
|
}
|
|
|
|
.node-issues {
|
|
color: var(--color-danger);
|
|
}
|
|
|
|
.items-count {
|
|
font-size: var(--font-size-s);
|
|
padding: 0;
|
|
}
|
|
}
|
|
|
|
.node-pin-data-icon {
|
|
color: var(--color-secondary);
|
|
margin-right: 2px;
|
|
|
|
svg {
|
|
height: 0.85rem;
|
|
}
|
|
}
|
|
|
|
.waiting {
|
|
color: var(--color-secondary);
|
|
}
|
|
|
|
.node-options {
|
|
display: none;
|
|
position: absolute;
|
|
top: -25px;
|
|
left: -10px;
|
|
width: 120px;
|
|
height: 26px;
|
|
font-size: 0.9em;
|
|
text-align: left;
|
|
z-index: 10;
|
|
color: #aaa;
|
|
text-align: center;
|
|
|
|
.option {
|
|
width: 28px;
|
|
display: inline-block;
|
|
|
|
&.touch {
|
|
display: none;
|
|
}
|
|
|
|
&:hover {
|
|
color: $color-primary;
|
|
}
|
|
|
|
.execute-icon {
|
|
position: relative;
|
|
top: 2px;
|
|
font-size: 1.2em;
|
|
}
|
|
}
|
|
}
|
|
|
|
&.is-touch-device .node-options {
|
|
left: -25px;
|
|
width: 150px;
|
|
|
|
.option.touch {
|
|
display: initial;
|
|
}
|
|
}
|
|
}
|
|
&--trigger .node-default .node-box {
|
|
border-radius: 32px 8px 8px 32px;
|
|
}
|
|
.trigger-icon {
|
|
position: absolute;
|
|
right: 100%;
|
|
top: 0;
|
|
bottom: 0;
|
|
margin: auto;
|
|
color: var(--color-primary);
|
|
align-items: center;
|
|
justify-content: center;
|
|
height: fit-content;
|
|
// Increase click radius of the bolt icon
|
|
padding: var(--spacing-2xs);
|
|
}
|
|
}
|
|
|
|
.select-background {
|
|
display: block;
|
|
background-color: hsla(
|
|
var(--color-foreground-base-h),
|
|
var(--color-foreground-base-s),
|
|
var(--color-foreground-base-l),
|
|
60%
|
|
);
|
|
border-radius: var(--border-radius-xlarge);
|
|
overflow: hidden;
|
|
position: absolute;
|
|
left: -8px !important;
|
|
top: -8px !important;
|
|
height: 116px;
|
|
width: 116px !important;
|
|
|
|
.node-wrapper--trigger & {
|
|
border-radius: 36px 8px 8px 36px;
|
|
}
|
|
}
|
|
|
|
.disabled-linethrough {
|
|
border: 1px solid var(--color-foreground-dark);
|
|
position: absolute;
|
|
top: 49px;
|
|
left: -3px;
|
|
width: 111px;
|
|
pointer-events: none;
|
|
|
|
&.success {
|
|
border-color: var(--color-success-light);
|
|
}
|
|
}
|
|
</style>
|
|
|
|
<style lang="scss">
|
|
.jtk-endpoint {
|
|
z-index: 2;
|
|
}
|
|
|
|
.node-trigger-tooltip {
|
|
&__wrapper {
|
|
top: -22px;
|
|
left: 50px;
|
|
position: relative;
|
|
|
|
&--item {
|
|
max-width: 160px;
|
|
position: fixed;
|
|
z-index: 0 !important;
|
|
}
|
|
}
|
|
}
|
|
.dot-output-endpoint:hover circle {
|
|
fill: var(--color-primary);
|
|
}
|
|
/** connector */
|
|
.jtk-connector {
|
|
z-index: 3;
|
|
}
|
|
|
|
.jtk-floating-endpoint {
|
|
opacity: 0;
|
|
}
|
|
|
|
.jtk-connector path {
|
|
transition: stroke 0.1s ease-in-out;
|
|
}
|
|
|
|
.jtk-overlay {
|
|
z-index: 3;
|
|
}
|
|
.jtk-connector {
|
|
z-index: 4;
|
|
}
|
|
.node-input-endpoint-label,
|
|
.node-output-endpoint-label,
|
|
.connection-run-items-label {
|
|
z-index: 5;
|
|
}
|
|
.jtk-connector.jtk-hover {
|
|
z-index: 6;
|
|
}
|
|
|
|
.jtk-endpoint.plus-endpoint {
|
|
z-index: 6;
|
|
}
|
|
.jtk-endpoint.dot-output-endpoint {
|
|
z-index: 7;
|
|
overflow: auto;
|
|
}
|
|
|
|
.disabled-linethrough {
|
|
z-index: 8;
|
|
}
|
|
|
|
.jtk-drag-active.dot-output-endpoint,
|
|
.jtk-drag-active.rect-input-endpoint {
|
|
z-index: 9;
|
|
}
|
|
.rect-input-endpoint > * {
|
|
pointer-events: none;
|
|
}
|
|
|
|
.connection-actions {
|
|
z-index: 100;
|
|
}
|
|
|
|
.node-options {
|
|
z-index: 10;
|
|
}
|
|
|
|
.drop-add-node-label {
|
|
z-index: 10;
|
|
}
|
|
|
|
.jtk-connector.success:not(.jtk-hover) {
|
|
path:not(.jtk-connector-outline) {
|
|
stroke: var(--color-success-light);
|
|
}
|
|
path[jtk-overlay-id='endpoint-arrow'],
|
|
path[jtk-overlay-id='midpoint-arrow'] {
|
|
fill: var(--color-success-light);
|
|
}
|
|
}
|
|
</style>
|
|
|
|
<style lang="scss">
|
|
:root {
|
|
--endpoint-size-small: 14px;
|
|
--endpoint-size-medium: 18px;
|
|
--stalk-size: 40px;
|
|
--stalk-success-size: 87px;
|
|
--stalk-success-size-without-label: 40px;
|
|
--stalk-long-size: 127px;
|
|
--plus-endpoint-box-size: 24px;
|
|
--plus-endpoint-box-size-small: 17px;
|
|
}
|
|
|
|
.plus-svg-circle {
|
|
z-index: 111;
|
|
circle {
|
|
stroke: var(--color-foreground-xdark);
|
|
stroke-width: 2px;
|
|
fill: var(--color-foreground-xdark);
|
|
}
|
|
|
|
&:hover {
|
|
circle {
|
|
stroke: var(--color-primary);
|
|
fill: var(--color-primary);
|
|
}
|
|
}
|
|
}
|
|
.plus-stalk {
|
|
width: calc(var(--stalk-size) + 2px);
|
|
border: 1px solid var(--color-foreground-dark);
|
|
margin-left: calc(var(--stalk-size) / 2);
|
|
z-index: 3;
|
|
&.ep-success {
|
|
border-color: var(--color-success-light);
|
|
|
|
&:after {
|
|
content: attr(data-label);
|
|
position: absolute;
|
|
left: 0;
|
|
right: 0;
|
|
bottom: 100%;
|
|
margin: auto;
|
|
margin-bottom: 2px;
|
|
text-align: center;
|
|
|
|
line-height: 1.3em;
|
|
font-size: var(--font-size-s);
|
|
font-weight: var(--font-weight-regular);
|
|
color: var(--color-success);
|
|
}
|
|
}
|
|
}
|
|
.connection-run-items-label {
|
|
// Disable points events so that the label does not block the connection
|
|
// mouse over event.
|
|
pointer-events: none;
|
|
span {
|
|
border-radius: 7px;
|
|
background-color: hsla(
|
|
var(--color-canvas-background-h),
|
|
var(--color-canvas-background-s),
|
|
var(--color-canvas-background-l),
|
|
0.85
|
|
);
|
|
line-height: 1.3em;
|
|
padding: 0px 3px;
|
|
white-space: nowrap;
|
|
font-size: var(--font-size-s);
|
|
font-weight: var(--font-weight-regular);
|
|
color: var(--color-success);
|
|
margin-top: -15px;
|
|
|
|
&.floating {
|
|
position: absolute;
|
|
top: -6px;
|
|
transform: translateX(-50%);
|
|
}
|
|
}
|
|
}
|
|
|
|
.connection-input-name-label {
|
|
position: relative;
|
|
|
|
span {
|
|
position: absolute;
|
|
top: -10px;
|
|
left: -60px;
|
|
}
|
|
}
|
|
|
|
.plus-endpoint {
|
|
cursor: pointer;
|
|
z-index: 10;
|
|
margin-left: calc((var(--stalk-size) + var(--plus-endpoint-box-size) / 2) - 1px);
|
|
g {
|
|
fill: var(--color-background-xlight);
|
|
pointer-events: none;
|
|
}
|
|
|
|
&:hover {
|
|
path {
|
|
fill: var(--color-primary);
|
|
}
|
|
rect {
|
|
stroke: var(--color-primary);
|
|
}
|
|
}
|
|
path {
|
|
fill: var(--color-foreground-xdark);
|
|
}
|
|
rect {
|
|
stroke: var(--color-foreground-xdark);
|
|
}
|
|
|
|
&.small {
|
|
margin-left: calc((var(--stalk-size) + var(--plus-endpoint-box-size-small) / 2));
|
|
g {
|
|
transform: scale(0.75);
|
|
transform-origin: center;
|
|
}
|
|
rect {
|
|
stroke-width: 2.5;
|
|
}
|
|
}
|
|
&:hover .plus-container {
|
|
color: var(--color-primary);
|
|
border: 2px solid var(--color-primary);
|
|
}
|
|
&:hover .drop-hover-message {
|
|
display: block;
|
|
}
|
|
|
|
&.hidden {
|
|
display: none;
|
|
}
|
|
}
|
|
|
|
.node-input-endpoint-label,
|
|
.node-output-endpoint-label {
|
|
background-color: hsla(
|
|
var(--color-canvas-background-h),
|
|
var(--color-canvas-background-s),
|
|
var(--color-canvas-background-l),
|
|
0.85
|
|
);
|
|
border-radius: 7px;
|
|
font-size: 0.7em;
|
|
padding: 2px;
|
|
white-space: nowrap;
|
|
}
|
|
|
|
.node-output-endpoint-label {
|
|
margin-left: calc(var(--endpoint-size-small) + var(--spacing-2xs));
|
|
}
|
|
.node-input-endpoint-label {
|
|
text-align: right;
|
|
margin-left: -25px;
|
|
|
|
&--moved {
|
|
margin-left: -40px;
|
|
}
|
|
}
|
|
.hover-message.jtk-overlay {
|
|
--hover-message-width: 110px;
|
|
font-weight: var(--font-weight-bold);
|
|
font-size: var(--font-size-2xs);
|
|
line-height: var(--font-line-height-regular);
|
|
color: var(--color-text-light);
|
|
width: var(--hover-message-width);
|
|
margin-left: calc(
|
|
(var(--hover-message-width) / 2) + var(--stalk-size) + var(--plus-endpoint-box-size) +
|
|
var(--spacing-2xs)
|
|
);
|
|
opacity: 0;
|
|
pointer-events: none;
|
|
&.small {
|
|
margin-left: calc(
|
|
(var(--hover-message-width) / 2) + var(--stalk-size) + var(--plus-endpoint-box-size-small) +
|
|
var(--spacing-2xs)
|
|
);
|
|
}
|
|
&.visible {
|
|
pointer-events: all;
|
|
opacity: 1;
|
|
}
|
|
}
|
|
.long-stalk {
|
|
--stalk-size: var(--stalk-long-size);
|
|
}
|
|
.ep-success {
|
|
--stalk-size: var(--stalk-success-size);
|
|
}
|
|
.ep-success--without-label {
|
|
--stalk-size: var(--stalk-success-size-without-label);
|
|
}
|
|
</style>
|