Primera prueba inicio

api-gateway/package-lock.json

@@ -5,7 +5,6 @@
   "requires": true,
   "packages": {
     "": {
-      "name": "api-gateway",
       "version": "0.0.1",
       "license": "UNLICENSED",
       "dependencies": {

api-gateway/src/app.controller.ts

@@ -44,6 +44,14 @@ export class AppController {
     return this.appService.allUsers();
   }
 
+  @Post('user/loginUser')
+  inicioSesion(
+    @Body('email') pEmail: string,
+    @Body('password') pPassword: string,
+  ) {
+    return this.appService.inicioSesion(pEmail,pPassword);
+  }
+
   @Get('user/find/:dni')
   findUser(
     @Param('dni') paramUserDNI: string

api-gateway/src/app.service.ts

@@ -71,6 +71,16 @@ export class AppService {
       );
   }
 
+  inicioSesion(pEmail: string, pPassword: string) {
+    const pattern = { cmd: 'loginUser' };
+    const payload = { email: pEmail, password: pPassword};
+    return this.clientUserApp
+      .send<string>(pattern, payload)
+      .pipe(
+        map((message: string) => ({ message })),
+      );
+  }
+
   // ====================== COMMUNITIES =============================== 
 
   //POST parameter from API

package-lock.json

@@ -0,0 +1,6 @@
+{
+  "name": "katoikia-app",
+  "lockfileVersion": 2,
+  "requires": true,
+  "packages": {}
+}

servicio-usuarios/package-lock.json

@@ -5,7 +5,6 @@
   "requires": true,
   "packages": {
     "": {
-      "name": "servicio-usuarios",
       "version": "0.0.1",
       "license": "UNLICENSED",
       "dependencies": {

servicio-usuarios/src/users/users.controller.ts

@@ -38,4 +38,11 @@ export class UsersController {
     let dni = id['dni'];
     return this.userService.remove(dni);
   }
+
+  //inicio de sesion
+  @MessagePattern({ cmd: 'loginUser' })
+  findLogin(@Payload() body:string) {
+    let pemail= body['email'];
+    return this.userService.findLogin(pemail);
+  }
 }

servicio-usuarios/src/users/users.service.ts

@@ -37,4 +37,9 @@ export class UsersService {
   async remove(id: string) {
     return this.userModel.findByIdAndRemove({ _id: id }).exec();
   }
+
+  //inicio de sesion
+  async findLogin(email: string): Promise<User> {
+    return this.userModel.findOne({ email:email}).exec();
+  }
 }