feat: 增加 app 集成版本

Author: winjo

.vscode/settings.json

@@ -0,0 +1,5 @@
+{
+  "cSpell.ignoreWords": [
+    "signale"
+  ]
+}

global.d.ts

@@ -0,0 +1 @@
+declare var monaco: any

package.json

@@ -27,7 +27,6 @@
       "prettier --write"
     ],
     "*.ts?(x)": [
-      "echo eslint TODO:",
       "prettier --parser=typescript --write"
     ]
   },
@@ -50,6 +49,7 @@
     "jest": "^26.6.3",
     "lint-staged": "^10.5.1",
     "prettier": "^2.1.2",
+    "react-dom": "^17.0.1",
     "signale": "^1.4.0",
     "ts-node": "^9.0.0",
     "typescript": "^4.0.5"

packages/core/README.md

@@ -1 +1,16 @@
-# core
+# core
+
+## client
+适配在前端场景下部分服务
+
+- extension kt-ext 的静态文件及文件读取
+
+## server
+实现相对 browser 端 的 server 端，使用 Proxy 代理到 server app
+最大程度复用 browser 端的代码，只需按照需要实现对应 server path 的服务即可
+
+- DiskFileServicePath 文件系统服务
+- ExtensionNodeServiceServerPath 获取 extensions 相关数据服务
+- LogServiceForClientPath 日志服务
+- CommonServerPath 通用后端服务
+- FileSchemeDocNodeServicePath 文件文档服务

packages/core/package.json

@@ -4,7 +4,7 @@
   "description": "core",
   "main": "lib/index.js",
   "module": "esm/index.js",
-  "typing": "types/index.d.ts",
+  "typings": "types/index.d.ts",
   "files": [
     "lib",
     "esm",
@@ -21,10 +21,24 @@
   "publishConfig": {
     "registry": "https://registry.npm.alibaba-inc.com"
   },
-  "dependencies": {
-    "@alipay/spacex-core": "0.0.1"
-  },
   "tnpm": {
     "mode": "yarn"
+  },
+  "dependencies": {
+    "@ali/common-di": "^5.2.2",
+    "@ali/ide-core-browser": "^1.23.1",
+    "@ali/ide-core-common": "^1.23.1",
+    "@ali/ide-editor": "^1.23.1",
+    "@ali/ide-kaitian-extension": "^1.23.1",
+    "@ali/ide-monaco": "^1.23.1",
+    "@isomorphic-git/lightning-fs": "^4.3.0",
+    "assert": "^2.0.0",
+    "browserfs": "~1.4.3",
+    "fs-extra-factory": "^0.2.0",
+    "uuid": "^8.3.1"
+  },
+  "devDependencies": {
+    "@types/fs-extra": "^9.0.4",
+    "vscode": "^1.1.37"
   }
-}
+}

packages/core/src/client/extension/extension-fs.provider.ts

@@ -0,0 +1,49 @@
+import { Injectable } from '@ali/common-di'
+import { Uri, Event } from '@ali/ide-core-browser'
+import { FileSystemProvider, FileStat, FileType, FileChangeEvent } from '@ali/ide-file-service'
+
+/**
+ * @class 解析 kt-ext:// 文件，解决前端插件加载问题
+ */
+@Injectable()
+export class KaitianExtFsProvider implements FileSystemProvider {
+  onDidChangeFile: Event<FileChangeEvent>
+
+  watch(): number {
+    throw new Error('Method not implemented.')
+  }
+
+  stat(): Thenable<FileStat> {
+    throw new Error('Method not implemented.')
+  }
+
+  readDirectory(): [string, FileType][] | Thenable<[string, FileType][]> {
+    throw new Error('Method not implemented.')
+  }
+
+  createDirectory(): void | Thenable<void | FileStat> {
+    throw new Error('Method not implemented.')
+  }
+
+  async readFile(uri: Uri): Promise<string> {
+    const requestUrl = uri.with({ scheme: 'https' })
+
+    return await fetch(requestUrl.toString(), {
+      headers: {
+        'Accept-Encoding': 'gzip, deflate',
+      },
+    }).then((res) => res.text())
+  }
+
+  writeFile(): void | Thenable<void | FileStat> {
+    throw new Error('Method not implemented.')
+  }
+
+  delete(): void | Thenable<void> {
+    throw new Error('Method not implemented.')
+  }
+
+  rename(): void | Thenable<void | FileStat> {
+    throw new Error('Method not implemented.')
+  }
+}

packages/core/src/client/extension/extension.contribution.ts

@@ -0,0 +1,36 @@
+import { Autowired } from '@ali/common-di'
+import { Domain, URI, FsProviderContribution } from '@ali/ide-core-browser'
+import {
+  StaticResourceContribution,
+  StaticResourceService,
+} from '@ali/ide-static-resource/lib/browser/static.definition'
+import { IFileServiceClient } from '@ali/ide-file-service'
+
+import { KaitianExtFsProvider } from './extension-fs.provider'
+import { EXT_SCHEME } from '../../common/constant'
+
+/**
+ * @class 扩展静态资源转换
+ */
+@Domain(StaticResourceContribution, FsProviderContribution)
+export class KtExtFsProviderContribution
+  implements StaticResourceContribution, FsProviderContribution {
+  @Autowired()
+  private readonly ktExtFsProvider: KaitianExtFsProvider
+
+  registerStaticResolver(service: StaticResourceService): void {
+    // 直接依赖插件市场内置的插件服务，无需抽象外部依赖
+    // 处理 kt-ext 的协议内容获取
+    service.registerStaticResourceProvider({
+      scheme: EXT_SCHEME,
+      resolveStaticResource: (uri: URI) => {
+        // kt-ext 协议统一走 scheme 头转换为 https
+        return uri.withScheme('https')
+      },
+    })
+  }
+
+  registerProvider(registry: IFileServiceClient) {
+    registry.registerProvider(EXT_SCHEME, this.ktExtFsProvider)
+  }
+}

packages/core/src/client/extension/index.ts

@@ -0,0 +1,2 @@
+export * from './extension.contribution'
+export * from './extension-fs.provider'

packages/core/src/client/index.ts

@@ -0,0 +1,74 @@
+import { Injectable, Injector, ConstructorOf, Provider } from '@ali/common-di'
+import {
+  BrowserModule,
+  ClientApp as BasicClientApp,
+  IAppRenderer,
+  IClientAppOpts as IBasicClientAppOpts,
+} from '@ali/ide-core-browser'
+import { BasicModule } from '@ali/ide-core-common'
+
+import { FCServiceCenter, ClientPort, initFCService } from '../connection'
+import { KaitianExtFsProvider, KtExtFsProviderContribution } from './extension'
+import { IServerApp } from '../common'
+
+export * from './extension'
+
+export type ModuleConstructor = ConstructorOf<BrowserModule>
+
+@Injectable()
+export class ClientModule extends BrowserModule {
+  providers = [KaitianExtFsProvider, KtExtFsProviderContribution]
+}
+
+export interface IClientAppOpts extends IBasicClientAppOpts {
+  serverApp: IServerApp
+}
+
+export class ClientApp extends BasicClientApp {
+  constructor(opts: IClientAppOpts) {
+    super(opts)
+    opts.injector?.addProviders({
+      token: IServerApp,
+      useValue: opts.serverApp,
+    })
+  }
+
+  public async start(container: HTMLElement | IAppRenderer, type?: string): Promise<void> {
+    bindConnectionService(this.injector, this.modules)
+    return super.start(container, type)
+  }
+
+  public dispose() {
+    this.injector.disposeAll()
+    this.injector.get(IServerApp).dispose()
+  }
+}
+
+export async function bindConnectionService(injector: Injector, modules: ModuleConstructor[]) {
+  const clientCenter = new FCServiceCenter(ClientPort)
+
+  const { getFCService } = initFCService(clientCenter)
+
+  for (const module of modules) {
+    const moduleInstance = injector.get(module) as BasicModule
+    if (!moduleInstance.backServices) {
+      continue
+    }
+    for (const backService of moduleInstance.backServices) {
+      const { servicePath } = backService
+      const fcService = getFCService(servicePath)
+
+      const injectService = {
+        token: servicePath,
+        useValue: fcService,
+      } as Provider
+
+      injector.addProviders(injectService)
+
+      if (backService.clientToken) {
+        const clientService = injector.get(backService.clientToken)
+        fcService.onRequestService(clientService)
+      }
+    }
+  }
+}

packages/core/src/common/constant.ts

@@ -0,0 +1,14 @@
+export const EXT_SCHEME = 'kt-ext'
+
+export const HOME = '/root'
+
+export const EXTENSION_DIR = '.kaitian'
+
+export const WORKSPACE_DIR = '/root/workspace'
+
+export const IServerApp = Symbol('IServerApp')
+
+export interface IServerApp {
+  start(): Promise<void>
+  dispose(): void
+}