Fix added flinksqlenv after show bug (#2726)

* Spotless Apply * Spotless Apply * fix-addedflinksqlenv-after-showbug * Spotless Apply --------- Co-authored-by: Zzm0809 <[email protected]>
DataLinkDC · Dec 23, 2023 · acec1e2 · acec1e2
1 parent 2d54ad7
commit acec1e2
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/dinky-web/src/pages/DataStudio/LeftContainer/Project/index.tsx b/dinky-web/src/pages/DataStudio/LeftContainer/Project/index.tsx
@@ -46,6 +46,7 @@ import {
   handlePutDataByParams,
   handleRemoveById
 } from '@/services/BusinessCrud';
+import { DIALECT } from '@/services/constants';
 import { API_CONSTANTS } from '@/services/endpoints';
 import { Catalogue } from '@/types/Studio/data.d';
 import { InitProjectState } from '@/types/Studio/init.d';
@@ -222,6 +223,9 @@ const Project: React.FC = (props: connect) => {
           ...prevState
         }));
         dispatch({ type: STUDIO_MODEL_ASYNC.queryProject });
+        if (values.type && values.type.toLowerCase() === DIALECT.FLINKSQLENV) {
+          dispatch({ type: STUDIO_MODEL_ASYNC.queryEnv });
+        }
         if (projectState.isEdit) {
           const { id } = values;
           const currentTabs = getTabByTaskId(panes, id);

diff --git a/dinky-web/src/pages/DataStudio/model.ts b/dinky-web/src/pages/DataStudio/model.ts
@@ -20,6 +20,7 @@
 import { getFooterValue, isDataStudioTabsItemType } from '@/pages/DataStudio/function';
 import { getTaskData } from '@/pages/DataStudio/LeftContainer/Project/service';
 import {
+  getEnvData,
   getFlinkConfigs,
   querySuggessionData
 } from '@/pages/DataStudio/RightContainer/JobConfig/service';
@@ -303,6 +304,7 @@ export type ModelType = {
     queryProject: Effect;
     queryFlinkConfigOptions: Effect;
     querySuggestions: Effect;
+    queryEnv: Effect;
   };
   reducers: {
     updateToolContentHeight: Reducer<StateType>;
@@ -411,6 +413,14 @@ const Model: ModelType = {
         payload: response
       });
     },
+    *queryEnv({ payload }, { call, put }) {
+      const response: EnvType[] = yield call(getEnvData, payload);
+      console.log(response);
+      yield put({
+        type: 'saveEnv',
+        payload: response
+      });
+    },
     *queryFlinkConfigOptions({ payload }, { call, put }) {
       const response: [] = yield call(getFlinkConfigs, payload);
       yield put({