fix(runtime): fix db stream initialize (#1592)

* fix(runtime): fix db stream initialize

* chore: add type hint for web ide

* lint

runtimes/nodejs/src/handler/debug-func.ts

@@ -15,7 +15,9 @@ export async function handleDebugFunction(ctx: FunctionContext) {
   }
   const auth = parseToken(token) || null
   if (auth?.type !== 'develop') {
-    return ctx.response.status(403).send('permission denied: invalid develop token')
+    return ctx.response
+      .status(403)
+      .send('permission denied: invalid develop token')
   }
 
   // get func_data from header
@@ -37,7 +39,11 @@ export async function handleDebugFunction(ctx: FunctionContext) {
   const func_name = ctx.request.params?.name
 
   if (!func_data) {
-    return ctx.response.send({ code: 1, error: 'function data not found', requestId })
+    return ctx.response.send({
+      code: 1,
+      error: 'function data not found',
+      requestId,
+    })
   }
 
   const func = new CloudFunction(func_data)

runtimes/nodejs/src/handler/invoke-func.ts

@@ -11,7 +11,6 @@ import { DEFAULT_FUNCTION_NAME, INTERCEPTOR_FUNCTION_NAME } from '../constants'
  * Handler of invoking cloud function
  */
 export async function handleInvokeFunction(req: IRequest, res: Response) {
-
   const ctx: FunctionContext = {
     requestId: req.requestId,
     query: req.query,
@@ -23,7 +22,6 @@ export async function handleInvokeFunction(req: IRequest, res: Response) {
     user: req.user,
     request: req,
     response: res,
-    varMap: new Map(),
   }
 
   // intercept the request, skip websocket request
@@ -102,7 +100,6 @@ export async function handleInvokeFunction(req: IRequest, res: Response) {
 }
 
 async function invokeInterceptor(ctx: FunctionContext) {
-
   const func_name = INTERCEPTOR_FUNCTION_NAME
   const requestId = ctx.requestId
 

runtimes/nodejs/src/index.ts

@@ -21,13 +21,11 @@ import xmlparser from 'express-xml-bodyparser'
 import './support/cloud-sdk'
 import storageServer from './storage-server'
 import { DatabaseChangeStream } from './support/database-change-stream'
-import { FunctionCache } from './support/function-engine/cache'
 
 const app = express()
 
 DatabaseAgent.accessor.ready.then(() => {
   DatabaseChangeStream.initialize()
-  FunctionCache.initialize()
 })
 
 if (process.env.NODE_ENV === 'development') {

runtimes/nodejs/src/storage-server.ts

@@ -1,18 +1,13 @@
 import express from 'express'
 import Config from './config'
 import { logger } from './support/logger'
-import { DatabaseAgent } from './db'
 import './support/cloud-sdk'
 import { WebsiteHostingChangeStream } from './support/database-change-stream/website-hosting-change-stream'
 import proxy from 'express-http-proxy'
 import axios from 'axios'
 
 const app = express()
 
-DatabaseAgent.accessor.ready.then(() => {
-  WebsiteHostingChangeStream.initialize()
-})
-
 const tryPath = (bucket: string, path: string) => {
   const testPaths = path.endsWith('/')
     ? [path + 'index.html', '/index.html']

runtimes/nodejs/src/support/database-change-stream/conf-change-stream.ts

@@ -4,6 +4,8 @@ import { DatabaseChangeStream } from '.'
 
 export class ConfChangeStream {
   static initialize() {
+    this.updateEnvironments()
+
     DatabaseChangeStream.onStreamChange(
       CONFIG_COLLECTION,
       this.updateEnvironments,

runtimes/nodejs/src/support/database-change-stream/index.ts

@@ -7,12 +7,25 @@ import {
   CONFIG_COLLECTION,
   WEBSITE_HOSTING_COLLECTION,
 } from '../../constants'
+import { ConfChangeStream } from './conf-change-stream'
+import { WebsiteHostingChangeStream } from './website-hosting-change-stream'
+import { FunctionCache } from '../function-engine/cache'
 
 const collectionsToWatch = [
-  CONFIG_COLLECTION,
-  CLOUD_FUNCTION_COLLECTION,
-  WEBSITE_HOSTING_COLLECTION,
+  {
+    name: CONFIG_COLLECTION,
+    handler: () => ConfChangeStream,
+  },
+  {
+    name: WEBSITE_HOSTING_COLLECTION,
+    handler: () => WebsiteHostingChangeStream,
+  },
+  {
+    name: CLOUD_FUNCTION_COLLECTION,
+    handler: () => FunctionCache,
+  },
 ] as const
+
 export class DatabaseChangeStream extends EventEmitter {
   private static instance: DatabaseChangeStream
 
@@ -50,13 +63,14 @@ export class DatabaseChangeStream extends EventEmitter {
   static initialize() {
     const instance = DatabaseChangeStream.getInstance()
 
-    collectionsToWatch.forEach((collectionName) => {
-      instance.initializeForCollection(collectionName)
+    collectionsToWatch.forEach((v) => {
+      instance.initializeForCollection(v.name)
+      v.handler().initialize()
     })
   }
 
   static onStreamChange(
-    collectionName: (typeof collectionsToWatch)[number],
+    collectionName: (typeof collectionsToWatch)[number]['name'],
     listener: (...args: any[]) => void,
   ) {
     const instance = DatabaseChangeStream.getInstance()

runtimes/nodejs/src/support/database-change-stream/website-hosting-change-stream.ts

@@ -6,6 +6,8 @@ export class WebsiteHostingChangeStream {
   static websiteHosting = []
 
   static initialize() {
+    this.onStreamChange()
+
     DatabaseChangeStream.onStreamChange(
       WEBSITE_HOSTING_COLLECTION,
       this.onStreamChange.bind(this),

runtimes/nodejs/src/support/function-engine/types.ts

@@ -52,7 +52,7 @@ export interface FunctionContext {
   method?: string
   socket?: WebSocket
   request?: Request
-  response?: Response  
+  response?: Response
   __function_name?: string
   __is_required?: boolean
   [key: string]: any

web/src/components/Editor/typesResolve/globals.ts

@@ -97,6 +97,8 @@ interface FunctionContext {
    * WebSocket object
    */
   socket?: WebSocket
+
+  [key: string]: any
 }
 
 interface IModule {
@@ -110,10 +112,18 @@ interface IExports {
   main: (ctx: FunctionContext) => any
 }
 
+interface IProcess {
+  /**
+   * Environment
+   */
+  env: any
+}
+
 declare const module: IModule
 declare const exports: IExports
 declare const console: FunctionConsole
 declare const global: typeof globalThis
+declare const process: IProcess
 
 /**
  *  The main function, entry of the cloud function