feat(server): add func db design, turn pg to mongo (#454)

Signed-off-by: maslow <wangfugen@126.com>

deploy/scripts/README.md

@@ -49,7 +49,7 @@ multipass exec laf-dev -- sudo -u root kubectl apply -f /laf/deploy/scripts/init
 
 ```bash
 # Forward service in cluster to localhost, run this command in another terminal separately
-kubectl port-forward deployment/postgresql 5432 -n laf
+kubectl port-forward deployment/mongodb 27017:27017 -n laf
 kubectl port-forward deployments/casdoor 30070:8000 -n laf
 
 # Run these in first time or when someone change the schema.

server/.env

@@ -1,6 +1,8 @@
 
 # database
-DATABASE_URL=postgresql://adm1n:passw0rd@localhost:5432/sys_db?schema=public
+# DATABASE_URL=postgresql://adm1n:passw0rd@localhost:5432/sys_db?schema=public
+DATABASE_URL=mongodb://admin:passw0rd@mongo.laf.svc.cluster.local:27017/sys_db?authSource=admin&replicaSet=rs0 #&writeConcern=majority
+
 
 # jwt settings
 JWT_SECRET=abc123

server/package.json

@@ -35,6 +35,7 @@
     "@nestjs/terminus": "^9.1.2",
     "@nestjs/throttler": "^3.1.0",
     "@prisma/client": "^4.6.1",
+    "bson": "^4.7.0",
     "casdoor-nodejs-sdk": "^1.3.0",
     "class-transformer": "^0.5.1",
     "class-validator": "^0.13.2",

server/prisma/schema.prisma

@@ -6,23 +6,63 @@ generator client {
 }
 
 datasource db {
-  provider = "postgresql"
+  provider = "mongodb"
   url      = env("DATABASE_URL")
 }
 
 model User {
-  id          String       @unique
-  username    String       @unique
-  email       String       @unique
-  phone       String       @unique
+  id         String   @id @default(auto()) @map("_id") @db.ObjectId
+  username   String   @unique
+  email      String   @unique
+  phone      String   @unique
+  created_at DateTime @default(now())
+  updated_at DateTime @updatedAt
+
   profile UserProfile?
 }
 
 model UserProfile {
-  uid    String @unique
-  openid String?
-  from   String?
-  avatar String?
-  name   String?
-  user   User   @relation(fields: [uid], references: [id])
+  id         String   @id @default(auto()) @map("_id") @db.ObjectId
+  uid        String   @unique @db.ObjectId
+  openid     String?
+  from       String?
+  avatar     String?
+  name       String?
+  created_at DateTime @default(now())
+  updated_at DateTime @updatedAt
+
+  user User @relation(fields: [uid], references: [id])
+}
+
+enum HttpMethod {
+  GET
+  POST
+  PUT
+  DELETE
+  PATCH
+  HEAD
+}
+
+type CloudFunctionSource {
+  code    String
+  uri     String?
+  version Int     @default(0)
+  hash    String?
+  lang    String?
+}
+
+model CloudFunction {
+  id         String              @id @default(auto()) @map("_id") @db.ObjectId
+  appid      String
+  name       String
+  source     CloudFunctionSource
+  desc       String
+  tags       String[]
+  websocket  Boolean
+  methods    HttpMethod[]
+  created_at DateTime            @default(now())
+  updated_at DateTime            @updatedAt
+  created_by String              @db.ObjectId
+
+  @@unique([appid, name])
 }

server/src/auth/auth.service.ts

@@ -30,7 +30,6 @@ export class AuthService {
       let user = profile?.user
       if (!user) {
         user = await this.userService.create({
-          id: this.userService.generateUserId(),
           username: casdoorUser.name,
           email: casdoorUser.email,
           phone: casdoorUser.phone,

server/src/collections/database.service.ts

@@ -62,8 +62,9 @@ export class DatabaseService {
     assert(db.status.connectionUri, 'Database connection uri is required')
 
     const uri = db.status?.connectionUri
-    const client = new MongoClient(uri)
+    const client = new MongoClient(uri, { maxPoolSize: 1, minPoolSize: 0 })
     try {
+      this.logger.verbose(`Connecting to database ${db.metadata.name}`)
       await client.connect()
       this.logger.log(`Connected to database ${db.metadata.namespace}`)
       return client

server/src/users/dto/user.response.ts

@@ -2,6 +2,8 @@ import { ApiProperty } from '@nestjs/swagger'
 import { User, UserProfile } from '@prisma/client'
 
 export class UserProfileDto implements UserProfile {
+  id: string
+
   @ApiProperty()
   uid: string
 
@@ -15,6 +17,12 @@ export class UserProfileDto implements UserProfile {
   name: string
 
   from: string
+
+  @ApiProperty()
+  created_at: Date
+
+  @ApiProperty()
+  updated_at: Date
 }
 
 export class UserDto implements User {
@@ -32,4 +40,10 @@ export class UserDto implements User {
 
   @ApiProperty()
   profile: UserProfileDto
+
+  @ApiProperty()
+  created_at: Date
+
+  @ApiProperty()
+  updated_at: Date
 }

server/src/users/users.service.ts

@@ -2,11 +2,15 @@ import { Injectable } from '@nestjs/common'
 import { Prisma, User } from '@prisma/client'
 import { PrismaService } from '../prisma.service'
 import * as nanoid from 'nanoid'
-
+import { ObjectID } from 'bson'
 @Injectable()
 export class UsersService {
   constructor(private prisma: PrismaService) {}
 
+  /**
+   * @deprecated
+   * @returns
+   */
   generateUserId() {
     const nano = nanoid.customAlphabet(
       '1234567890abcdefghijklmnopqrstuvwxyz',
@@ -16,10 +20,6 @@ export class UsersService {
   }
 
   async create(data: Prisma.UserCreateInput): Promise<User> {
-    if (!data.id) {
-      data.id = this.generateUserId()
-    }
-
     return this.prisma.user.create({
       data,
     })