user list api done

apps/auth/src/auth.module.ts

@@ -1,10 +1,18 @@
 import { Module } from '@nestjs/common';
 import { AuthController } from './auth.controller';
 import { AuthService } from './auth.service';
-
+import { ConfigModule } from '@nestjs/config';
+import config from './config';
+import { AuthenticationModule } from './modules/authentication/authentication.module';
+import { AuthenticationController } from './modules/authentication/controllers/authentication.controller';
 @Module({
-  imports: [],
-  controllers: [AuthController],
+  imports: [
+    ConfigModule.forRoot({
+      load: config,
+    }),
+    AuthenticationModule,
+  ],
+  controllers: [AuthController,AuthenticationController],
   providers: [AuthService],
 })
 export class AuthModule {}

apps/auth/src/config/auth.config.ts

@@ -0,0 +1,10 @@
+import { registerAs } from '@nestjs/config';
+
+export default registerAs(
+  'auth-config',
+  (): Record<string, any> => ({
+    DEVICE_ID: process.env.DEVICE_ID,
+    ACCESS_KEY: process.env.ACCESS_KEY,
+    SECRET_KEY: process.env.SECRET_KEY,
+  }),
+);

apps/auth/src/config/index.ts

@@ -0,0 +1,3 @@
+import AuthConfig from './auth.config';
+
+export default [AuthConfig];

apps/auth/src/modules/authentication/authentication.module.ts

@@ -0,0 +1,12 @@
+import { Module } from '@nestjs/common';
+import { AuthenticationController } from './controllers/authentication.controller';
+import { AuthenticationService } from './services/authentication.service';
+import { ConfigModule } from '@nestjs/config';
+
+@Module({
+  imports: [ConfigModule],
+  controllers: [AuthenticationController],
+  providers: [AuthenticationService],
+  exports: [AuthenticationService],
+})
+export class AuthenticationModule {}

apps/auth/src/modules/authentication/controllers/authentication.controller.ts

@@ -0,0 +1,14 @@
+import { Controller, Post } from '@nestjs/common';
+import { AuthenticationService } from '../services/authentication.service';
+
+@Controller({
+  version: '1',
+  path: 'authentication',
+})
+export class AuthenticationController {
+  constructor(private readonly authenticationService: AuthenticationService) {}
+  @Post('auth')
+  async Authentication() {
+    return await this.authenticationService.main();
+  }
+}

apps/auth/src/modules/authentication/services/authentication.service.ts

@@ -0,0 +1,121 @@
+import { Injectable } from '@nestjs/common';
+import * as qs from 'qs';
+import * as crypto from 'crypto';
+import { ConfigService } from '@nestjs/config';
+import axios from 'axios';
+@Injectable()
+export class AuthenticationService {
+  private token: string;
+  private deviceId: string;
+  private accessKey: string;
+  private secretKey: string;
+
+  constructor(private readonly configService: ConfigService) {
+    (this.deviceId = this.configService.get<string>('auth-config.DEVICE_ID')),
+      (this.accessKey = this.configService.get<string>(
+        'auth-config.ACCESS_KEY',
+      )),
+      (this.secretKey = this.configService.get<string>(
+        'auth-config.SECRET_KEY',
+      ));
+  }
+
+  async main() {
+    await this.getToken();
+    const data = await this.getDeviceInfo(this.deviceId);
+    console.log('fetch success: ', JSON.stringify(data));
+    return JSON.stringify(data);
+  }
+
+  async getToken() {
+    const method = 'GET';
+    const timestamp = Date.now().toString();
+    const signUrl = 'https://openapi.tuyaeu.com/v1.0/token?grant_type=1';
+    const contentHash = crypto.createHash('sha256').update('').digest('hex');
+    const stringToSign = [method, contentHash, '', signUrl].join('\n');
+    const signStr = this.accessKey + timestamp + stringToSign;
+
+    const headers = {
+      t: timestamp,
+      sign_method: 'HMAC-SHA256',
+      client_id: this.accessKey,
+      sign: await this.encryptStr(signStr, this.secretKey),
+    };
+
+    const { data: login } = await axios.get(
+      'https://openapi.tuyaeu.com/v1.0/token',
+      {
+        params: {
+          grant_type: 1,
+        },
+        headers,
+      },
+    );
+
+    if (!login || !login.success) {
+      throw new Error(`fetch failed: ${login.msg}`);
+    }
+    this.token = login.result.access_token;
+  }
+
+  async getDeviceInfo(deviceId: string) {
+    const query = {};
+    const method = 'POST';
+    const url = `https://openapi.tuyaeu.com/v1.0/devices/${deviceId}/commands`;
+    const reqHeaders: { [k: string]: string } = await this.getRequestSign(
+      url,
+      method,
+      {},
+      query,
+    );
+
+    const { data } = await axios.post(url, {}, reqHeaders);
+
+    if (!data || !data.success) {
+      throw new Error(`request api failed: ${data.msg}`);
+    }
+
+    return data;
+  }
+
+  async encryptStr(str: string, secret: string): Promise<string> {
+    return crypto
+      .createHmac('sha256', secret)
+      .update(str, 'utf8')
+      .digest('hex')
+      .toUpperCase();
+  }
+
+  async getRequestSign(
+    path: string,
+    method: string,
+    headers: { [k: string]: string } = {},
+    query: { [k: string]: any } = {},
+    body: { [k: string]: any } = {},
+  ) {
+    const t = Date.now().toString();
+    const [uri, pathQuery] = path.split('?');
+    const queryMerged = Object.assign(query, qs.parse(pathQuery));
+    const sortedQuery: { [k: string]: string } = {};
+    Object.keys(queryMerged)
+      .sort()
+      .forEach((i) => (sortedQuery[i] = query[i]));
+
+    const querystring = decodeURIComponent(qs.stringify(sortedQuery));
+    const url = querystring ? `${uri}?${querystring}` : uri;
+    const contentHash = crypto
+      .createHash('sha256')
+      .update(JSON.stringify(body))
+      .digest('hex');
+    const stringToSign = [method, contentHash, '', url].join('\n');
+    const signStr = this.accessKey + this.token + t + stringToSign;
+    return {
+      t,
+      path: url,
+      client_id: this.accessKey,
+      sign: await this.encryptStr(signStr, this.secretKey),
+      sign_method: 'HMAC-SHA256',
+      access_token: this.token,
+    };
+  }
+}