feat(server): implement cron trigger schema & crud apis (#578)

.vscode/settings.json

@@ -49,6 +49,7 @@
     "ghaction",
     "gonanoid",
     "healthz",
+    "hokify",
     "hostpath",
     "Kube",
     "kubebuilder",

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

@@ -11,6 +11,7 @@ import { logger } from '../support/logger'
 import { CloudFunction } from '../support/function-engine'
 import { IRequest } from '../support/types'
 import { handleDebugFunction } from './debug-func'
+import { parseToken } from '../support/token'
 
 const DEFAULT_FUNCTION_NAME = '__default__'
 
@@ -21,7 +22,12 @@ export async function handleInvokeFunction(req: IRequest, res: Response) {
   if (req.get('x-laf-debug-token')) {
     return await handleDebugFunction(req, res)
   }
-
+
+  let isTrigger = false
+  if (parseToken(req.get('x-laf-trigger-token'))) {
+    isTrigger = true
+  }
+
   const requestId = req.requestId
   const func_name = req.params?.name
 
@@ -38,7 +44,7 @@ export async function handleInvokeFunction(req: IRequest, res: Response) {
   const func = new CloudFunction(funcData)
 
   // reject while no HTTP enabled
-  if (!func.methods.includes(req.method.toUpperCase())) {
+  if (!func.methods.includes(req.method.toUpperCase()) && !isTrigger) {
     return res.status(405).send('Method Not Allowed')
   }
 
@@ -49,7 +55,7 @@ export async function handleInvokeFunction(req: IRequest, res: Response) {
       files: req.files as any,
       body: req.body,
       headers: req.headers,
-      method: req.method,
+      method: isTrigger ? 'trigger' : req.method,
       auth: req['auth'],
       user: req.user,
       requestId,

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

@@ -37,7 +37,9 @@ export interface FunctionContext {
   query?: any
   body?: any
   params?: any
-  // @Deprecated use user instead
+  /**
+   * @deprecated use user instead
+   */
   auth?: any
   user?: any
   requestId: string

server/package.json

@@ -25,6 +25,7 @@
   },
   "dependencies": {
     "@aws-sdk/client-sts": "^3.226.0",
+    "@hokify/agenda": "^6.3.0",
     "@kubernetes/client-node": "^0.17.1",
     "@nestjs/axios": "^1.0.0",
     "@nestjs/common": "^9.0.0",

server/prisma/schema.prisma

@@ -173,5 +173,19 @@ model CloudFunction {
   updatedAt DateTime            @updatedAt
   createdBy String              @db.ObjectId
 
+  cronTriggers CronTrigger[]
+
   @@unique([appid, name])
 }
+
+model CronTrigger {
+  id        String   @id @default(auto()) @map("_id") @db.ObjectId
+  appid     String
+  desc      String
+  cron      String
+  target    String
+  createdAt DateTime @default(now())
+  updatedAt DateTime @updatedAt
+
+  cloudFunction CloudFunction @relation(fields: [appid, target], references: [appid, name])
+}

server/src/app.module.ts

@@ -16,6 +16,7 @@ import { PrismaService } from './prisma.service'
 import { StorageModule } from './storage/storage.module'
 import { LogModule } from './log/log.module'
 import { DependencyModule } from './dependency/dependency.module'
+import { TriggerModule } from './trigger/trigger.module';
 
 @Module({
   imports: [
@@ -36,6 +37,7 @@ import { DependencyModule } from './dependency/dependency.module'
     StorageModule,
     LogModule,
     DependencyModule,
+    TriggerModule,
   ],
   controllers: [AppController],
   providers: [AppService, PrismaService],

server/src/constants.ts

@@ -3,6 +3,13 @@ dotenv.config({ path: '.env.local' })
 dotenv.config()
 
 export class ServerConfig {
+  static get DATABASE_URL() {
+    if (!process.env.DATABASE_URL) {
+      throw new Error('DATABASE_URL is not defined')
+    }
+    return process.env.DATABASE_URL
+  }
+
   static get JWT_SECRET() {
     if (!process.env.JWT_SECRET) {
       throw new Error('JWT_SECRET is not defined')