feat: 支持自定义worker插件地址

Author: guqiankun.gqk

packages/alex/src/api/types.ts

@@ -18,6 +18,11 @@ export type IAppConfig = Partial<IAppOpts> & {
    * 插件配置
    */
   plugins?: IPluginConfig;
+  /** 
+   * 插件OSS地址
+   * extensionOSSPath/publisher.name-version
+   */
+  extensionOSSPath?: string;
 };
 
 export interface IConfig {

packages/core/src/common/util.ts

@@ -33,7 +33,15 @@ export const getFunctionProps = (obj: Record<string, any>): string[] => {
   }
 };
 
-export const getExtensionPath = (ext: IExtensionIdentity, mode?: IExtensionMode) => {
+export const getExtensionPath = (
+  ext: IExtensionIdentity,
+  mode?: IExtensionMode,
+  OSSPath?: string
+) => {
+  if (!!OSSPath) {
+    return [OSSPath, '/', `${ext.publisher}.${ext.name}-${ext.version}`].join('');
+  }
+
   return [
     EXT_SCHEME,
     '://',

packages/core/src/server/kaitian-extension/extension.service.client.ts

@@ -5,6 +5,7 @@ import { IExtensionNodeClientService, IExtensionMetadata, ExtraMetadata } from '
 import { ServerConfig } from '../core/app';
 import { getExtensionPath } from '../../common/util';
 import { EXT_SCHEME } from '../../common/constant';
+import { AppConfig } from '../../common';
 
 const { posix } = path;
 
@@ -16,6 +17,9 @@ export class ExtensionServiceClientImpl implements IExtensionNodeClientService {
   @Autowired(ServerConfig)
   serverConfig: ServerConfig;
 
+  @Autowired(AppConfig)
+  appConfig: AppConfig & { extensionOSSPath?: string };
+
   getElectronMainThreadListenPath(): Promise<string> {
     throw new Error('Method not implemented.');
   }
@@ -30,9 +34,12 @@ export class ExtensionServiceClientImpl implements IExtensionNodeClientService {
       return [];
     }
     const extensions: IExtensionMetadata[] = await Promise.all(
-      extensionMetadata.map((ext) => getExtension(ext, localization))
+      extensionMetadata.map((ext) =>
+        getExtension(ext, localization, undefined, this.appConfig.extensionOSSPath)
+      )
     );
 
+    console.log('==> extensions', extensions);
     return extensions;
   }
   getExtension(
@@ -130,10 +137,11 @@ async function getExtraMetaData(
 async function getExtension(
   ext: IExtensionBasicMetadata,
   localization: string,
-  extraMetaData?: ExtraMetadata
+  extraMetaData?: ExtraMetadata,
+  OSSPath?: string
 ) {
   const extensionPath =
-    ext.mode === 'local' && ext.uri ? ext.uri : getExtensionPath(ext.extension, ext.mode);
+    ext.mode === 'local' && ext.uri ? ext.uri : getExtensionPath(ext.extension, ext.mode, OSSPath);
   const extensionUri = Uri.parse(extensionPath);
 
   let pkgNlsJSON: { [key: string]: string } | undefined;