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

import { Controller } from '@nestjs/common';
import { MessagePattern, Payload } from '@nestjs/microservices';
import { User, UserDocument } from '../schemas/user.schema';
import { UsersService } from './users.service';

@Controller()
export class UsersController {
  constructor(private readonly userService: UsersService) { }

  @MessagePattern({ cmd: 'createUser' })
  create(@Payload() user: UserDocument) {
    return this.userService.create(user);
  }

  @MessagePattern({ cmd: 'createAdminSystem' })
  createUserAdmin(@Payload() user: UserDocument) {
    return this.userService.create(user);
  }

  @MessagePattern({ cmd: 'createGuard' })
  createGuard(@Payload() user: UserDocument) {
    return this.userService.create(user);
  }


  @MessagePattern({ cmd: 'findAllUsers' })
  findAll() {
    return this.userService.findAll();
  }

  @MessagePattern({ cmd: 'findUserDNI' })
  findOne(@Payload() id: string) {
    let dni = id['dni'];
    return this.userService.findOneByDNI(dni);
  }

  @MessagePattern({ cmd: 'findGuardsCommunity' })
  findGuardsCommunity(@Payload() community_id: string) {
    let pcommunity_id = community_id['community_id'];
    return this.userService.findGuardsCommunity(pcommunity_id);
  }
  

  @MessagePattern({ cmd: 'updateUser' })
  update(@Payload() user: UserDocument) {
    return this.userService.update(user.id, user);
  }

  @MessagePattern({ cmd: 'removeUser' })
  remove(@Payload() id: string) {
    let dni = id['dni'];
    return this.userService.remove(dni);
  }

  //inicio de sesion
  @MessagePattern({ cmd: 'loginUser' })
  findLogin(@Payload() body: string) {
    let pemail = body['email'];
    let ppassword = body['password'];
    return this.userService.findLogin(pemail, ppassword);
  }

  //buscar solo admins del sistema
  @MessagePattern({ cmd: 'findAdminSistema' })
  allUsersAdminSistema() {
    return this.userService.allUsersAdminSistema();
  }

  //buscar solo admins de comunidad
  @MessagePattern({ cmd: 'findAdminComunidad' })
  allUsersAdminComunidad() {
    return this.userService.allUsersAdminComunidad();
  }

  //Prueba de envio de correo despues de registro, llamando a microservicio notificaciones
  @MessagePattern({ cmd: 'testSendMail' })
  testSendMail(@Payload() user: UserDocument) {
    return this.userService.testSendMail(user);
  }

  //buscar usuario de una comunidad
  @MessagePattern({ cmd: 'findOneCommunityUser' })
  findCommunityUser(@Payload() user: any) {
    return this.userService.findCommunityUser(user["community_id"], user["user_type"]);
  }

  @MessagePattern({ cmd: 'deleteAdminSystem' })
  deleteAdminSystem(@Payload() user: any) {
    console.log("entró")

    return this.userService.deleteAdminSystem(user["id"]);
  }

}