feat(runtime): add __init__ hook in runtime (#1081)

.vscode/settings.json

@@ -35,8 +35,6 @@
     "buildah",
     "buildx",
     "Builtins",
-    "casbin",
-    "casdoor",
     "chakra",
     "Chakra",
     "chatgpt",

runtimes/nodejs/README.md

@@ -52,7 +52,3 @@ npm start
 ```bash
 telepresence leave $APPID-$APPID
 ```
-
-## Troubleshooting
-
-- `telepresence helm install` failed for `arm64 / Apple Chip` cluster, please upgrade your telepresence to `v2.11.1` or later.

runtimes/nodejs/src/index.ts

@@ -22,12 +22,14 @@ import './support/function-log'
 import './support/cloud-sdk'
 import { FunctionCache } from './support/function-engine/cache'
 import { DatabaseChangeStream } from './support/db-change-stream'
+import { InitHook } from './support/init-hook'
 
 const app = express()
 
 DatabaseAgent.accessor.ready.then(() => {
   FunctionCache.initialize()
   DatabaseChangeStream.initialize()
+  InitHook.invoke()
 })
 
 if (process.env.NODE_ENV === 'development') {

runtimes/nodejs/src/support/init-hook.ts

@@ -0,0 +1,41 @@
+import { CLOUD_FUNCTION_COLLECTION, INIT_FUNCTION_NAME } from '../constants'
+import { DatabaseAgent } from '../db'
+import { CloudFunction, ICloudFunctionData } from './function-engine'
+import { logger } from './logger'
+import { generateUUID } from './utils'
+
+/**
+ * Init hook for `__init__` cloud function
+ */
+export class InitHook {
+  static async invoke() {
+    const func = await this.getInitCloudFunction()
+    if (!func) {
+      return
+    }
+
+    const cf = new CloudFunction(func)
+    await cf.invoke({
+      method: 'INIT',
+      requestId: generateUUID(),
+      __function_name: func.name,
+    })
+
+    logger.info('Init hook invoked')
+  }
+
+  /**
+   * Get init hook cloud function
+   * @returns
+   */
+  private static async getInitCloudFunction() {
+    const db = DatabaseAgent.db
+    const doc = await db
+      .collection<ICloudFunctionData>(CLOUD_FUNCTION_COLLECTION)
+      .findOne({
+        name: INIT_FUNCTION_NAME,
+      })
+
+    return doc
+  }
+}

server/README.md

@@ -23,7 +23,6 @@
 - [Prisma](https://www.prisma.io)
 - [MinIO](https://min.io) object storage
 - [APISIX](https://apisix.apache.org) gateway
-- [Casdoor](https://casdoor.org/)
 
 ## Prerequisites