feat: support datasource switcher

Author: HSunboy

src/common/datasource/fileSystem/index.tsx

@@ -3,6 +3,7 @@ import { IDataSourceModeConfig } from '../interface';
 import { haveOCP } from '@/util/env';
 
 const CloudStorageConfig: IDataSourceModeConfig = {
+  isFileSystem: true,
   connection: {
     address: {
       items: ['ip'],
@@ -43,10 +44,4 @@ const HUAWEI: Record<ConnectType.OBS, IDataSourceModeConfig> = {
 const QCLOUD: Record<ConnectType.COS, IDataSourceModeConfig> = {
   [ConnectType.COS]: CloudStorageConfig,
 };
-if (haveOCP()) {
-  delete ALIYUN[ConnectType.OSS];
-  delete AWSS3[ConnectType.S3A];
-  delete HUAWEI[ConnectType.OBS];
-  delete QCLOUD[ConnectType.COS];
-}
 export default { ALIYUN, AWSS3, HUAWEI, QCLOUD };

src/common/datasource/index.tsx

@@ -43,6 +43,7 @@ import { ReactComponent as OBSSvg } from '@/svgr/OBS.svg';
 import { ReactComponent as DBOBSSvg } from '@/svgr/obs_file.svg';
 import { ReactComponent as S3Svg } from '@/svgr/S3.svg';
 import { ReactComponent as DBS3Svg } from '@/svgr/S3_file.svg';
+import odc from '@/plugins/odc';
 
 export const _types: Map<
   IDataSourceType,
@@ -158,6 +159,9 @@ function register(
 ) {
   const connectTypes: ConnectType[] = Object.entries(items)
     .map(([key, value]) => {
+      if (odc.datasourceSupport && !odc.datasourceSupport?.(key as ConnectType, value)) {
+        return null;
+      }
       if (value?.disable) {
         return null;
       }

src/common/datasource/interface.ts

@@ -114,6 +114,7 @@ interface IProcedureConfig {
 }
 
 export interface IDataSourceModeConfig {
+  isFileSystem?: boolean;
   priority?: number;
   connection: {
     address?: {

src/plugins/odc.ts

@@ -14,8 +14,10 @@
  * limitations under the License.
  */
 
+import { ConnectType } from '@/d.ts';
 import defaultConfig from './defaultConfig';
 import type { InternalAxiosRequestConfig } from 'axios';
+import { IDataSourceModeConfig } from '@/common/datasource/interface';
 interface IODCErrorHandle {
   (
     errCode: string,
@@ -35,6 +37,10 @@ interface IResponseJsonResolver {
   (response: Response, json: Record<string, any>): void;
 }
 
+interface IDataSourceSupport {
+  (type: ConnectType, config: IDataSourceModeConfig): boolean;
+}
+
 export class ODC {
   public ODCErrorHandle: Set<IODCErrorHandle> = new Set();
 
@@ -50,6 +56,8 @@ export class ODC {
 
   public responseJsonResolver: IResponseJsonResolver;
 
+  public datasourceSupport: IDataSourceSupport;
+
   public addErrorHandle(handle: IODCErrorHandle) {
     this.ODCErrorHandle.add(handle);
   }
@@ -61,6 +69,9 @@ export class ODC {
   public setResponseJsonResolve(handle: IResponseJsonResolver) {
     this.responseJsonResolver = handle;
   }
+  public setDataSourceSupport(handle: IDataSourceSupport) {
+    this.datasourceSupport = handle;
+  }
   public appConfig: Partial<typeof defaultConfig> = defaultConfig;
 }