feat: add get user notification

Author: pengpeng

packages/api/src/notification/NatsService.ts renamed to packages/api/src/notification/UsersService.ts

@@ -1,14 +1,14 @@
 import { Injectable, OnModuleDestroy, Logger } from '@nestjs/common';
 //import { SocketService } from './pgsocket.service';
-
+import axios from 'axios';
 import { NatsConnection, StringCodec, connect } from 'nats';
 //import { get } from 'http';
 
 const NATS_HOST = process.env.NATS_HOST || '';
 const NATS_PORT = process.env.NATS_PORT || 4222;
 const NATS_USERNAME = process.env.NATS_USERNAME || '';
 const NATS_PASSWORD = process.env.NATS_PASSWORD || '';
-const NATS_SUBJECT = process.env.NATS_SUBJECT || '';
+const NATS_SUBJECT_SYSTEM_USERS = process.env.NATS_SUBJECT_SYSTEM_USERS || '';
 const nats_url = NATS_HOST + ':' + NATS_PORT;
 
 export function getNATS(): boolean {
@@ -17,28 +17,32 @@ export function getNATS(): boolean {
 }
 
 @Injectable()
-export class NatsService implements OnModuleDestroy {
-  private readonly logger = new Logger(NatsService.name);
+export class UsersService implements OnModuleDestroy {
+  private readonly logger = new Logger(UsersService.name);
   private natsClient: NatsConnection;
 
   async onModuleInit() {
     if (!getNATS()) {
       return;
     }
-    console.log('nats username:', NATS_USERNAME);
-    console.log('nats password:', NATS_PASSWORD);
-    this.natsClient = await connect({
-      servers: nats_url,
-      user: NATS_USERNAME,
-      pass: NATS_PASSWORD,
-    });
-    const sub = this.natsClient.subscribe(NATS_SUBJECT);
 
-    const sc = StringCodec();
+    await this.getUsers();
 
     (async () => {
+      console.log('nats username:', NATS_USERNAME);
+      console.log('nats password:', NATS_PASSWORD);
+      this.natsClient = await connect({
+        servers: nats_url,
+        user: NATS_USERNAME,
+        pass: NATS_PASSWORD,
+      });
+      const sub = this.natsClient.subscribe(NATS_SUBJECT_SYSTEM_USERS);
+
+      const sc = StringCodec();
+
       for await (const m of sub) {
         console.log(`[${sub.getProcessed()}]: ${sc.decode(m.data)}`);
+
         // await this.socketService.sendMsg(sc.decode(m.data));
       }
     })();
@@ -48,6 +52,21 @@ export class NatsService implements OnModuleDestroy {
     this.natsClient.drain();
   }
 
+  async getUsers() {
+    try {
+      const response: any = await axios.get(
+        'http://ks-apiserver.kubesphere-system/kapis/iam.kubesphere.io/v1alpha2/lldap/users',
+      );
+      if (response.status !== 200) {
+        throw new Error(response.statusText);
+      }
+
+      console.log('getUsers', response.data);
+    } catch (e) {
+      this.logger.error(e);
+    }
+  }
+
   async pushTemplate(
     userid: string,
     templateid: string,

packages/api/src/notification/notification.module.ts

@@ -1,6 +1,6 @@
 import { Module } from '@nestjs/common';
 import { TemplateService } from './template.service';
-import { NatsService } from './NatsService';
+import { UsersService } from './UsersService';
 import { TemplateContentService } from './template.content.service';
 import { NotificationController } from './notification.controller';
 import { PrismaModule } from '../prisma/prisma.module';
@@ -10,6 +10,6 @@ import { SystemController } from './system.controller';
 @Module({
   imports: [PrismaModule, ScheduleModule.forRoot()],
   controllers: [NotificationController, SystemController],
-  providers: [TemplateService, TemplateContentService, NatsService],
+  providers: [TemplateService, TemplateContentService, UsersService],
 })
 export class NotificationModule {}