diff --git a/packages/dag/src/composables/useFormScope.ts b/packages/dag/src/composables/useFormScope.ts index 60e5af39d..73d4afe50 100644 --- a/packages/dag/src/composables/useFormScope.ts +++ b/packages/dag/src/composables/useFormScope.ts @@ -865,7 +865,7 @@ export function useFormScope({ canvasRef }) { findParentNodeByType, - useSyncConnection: async (field) => { + useSyncConnection: async (field: any) => { const id = field.value const form = field.form const connection = await getConnectionNoSchema(id) @@ -875,39 +875,18 @@ export function useFormScope({ canvasRef }) { return } - const connectionType = form.getValuesIn('attrs.connectionType') || '' - const accessNodeProcessId = - form.getValuesIn('attrs.accessNodeProcessId') || '' - const accessNodeType = form.getValuesIn('attrs.accessNodeType') || '' - const priorityProcessId = - form.getValuesIn('attrs.priorityProcessId') || '' - const connectionName = form.getValuesIn('attrs.connectionName') - const pdkType = form.getValuesIn('attrs.pdkType') - const pdkHash = form.getValuesIn('attrs.pdkHash') - const db_version = form.getValuesIn('attrs.db_version') - - pdkType !== connection.pdkType && - form.setValuesIn('attrs.pdkType', connection.pdkType) - pdkHash !== connection.pdkHash && - form.setValuesIn('attrs.pdkHash', connection.pdkHash) - connectionType !== connection.connection_type && - form.setValuesIn('attrs.connectionType', connection.connection_type) - accessNodeProcessId !== connection.accessNodeProcessId && - form.setValuesIn( - 'attrs.accessNodeProcessId', - connection.accessNodeProcessId, - ) - accessNodeType !== connection.accessNodeType && - form.setValuesIn('attrs.accessNodeType', connection.accessNodeType) - priorityProcessId !== connection.priorityProcessId && - form.setValuesIn( - 'attrs.priorityProcessId', - connection.priorityProcessId, - ) - connectionName !== connection.name && - form.setValuesIn('attrs.connectionName', connection.name) - db_version !== connection.db_version && - form.setValuesIn('attrs.db_version', connection.db_version) + form.setFieldState('connectionConfig', { data: connection.config }) + form.setValuesIn('attrs.pdkType', connection.pdkType) + form.setValuesIn('attrs.pdkHash', connection.pdkHash) + form.setValuesIn('attrs.connectionType', connection.connection_type) + form.setValuesIn( + 'attrs.accessNodeProcessId', + connection.accessNodeProcessId, + ) + form.setValuesIn('attrs.accessNodeType', connection.accessNodeType) + form.setValuesIn('attrs.priorityProcessId', connection.priorityProcessId) + form.setValuesIn('attrs.connectionName', connection.name) + form.setValuesIn('attrs.db_version', connection.db_version) }, getPdkProperties: (node) => { diff --git a/packages/dag/src/nodes/Database.js b/packages/dag/src/nodes/Database.js index 44dd57935..71b147b91 100644 --- a/packages/dag/src/nodes/Database.js +++ b/packages/dag/src/nodes/Database.js @@ -33,7 +33,9 @@ export class Database extends NodeType { 'x-display': 'hidden', 'x-reactions': '{{useSyncConnection}}', }, - + connectionConfig: { + type: 'void', + }, type: { type: 'string', 'x-display': 'hidden', diff --git a/packages/dag/src/nodes/Table.js b/packages/dag/src/nodes/Table.js index afb2c539a..685c62ebd 100644 --- a/packages/dag/src/nodes/Table.js +++ b/packages/dag/src/nodes/Table.js @@ -40,6 +40,9 @@ export class Table extends NodeType { 'x-reactions': '{{useAsyncDataSourceByConfig({service: useSyncConnection})}}', }, + connectionConfig: { + type: 'void', + }, tabs: { type: 'void', 'x-decorator': 'FormItem',