katoikia-app/servicio-comunidad-viviendas/src/communities/communities.service.ts

import { Injectable, Inject } from '@nestjs/common';
import { Model } from 'mongoose';
import { Community, CommunityDocument } from 'src/schemas/community.schema';
import { InjectModel } from '@nestjs/mongoose';
import { RpcException, ClientProxy } from '@nestjs/microservices';
import { from, lastValueFrom, map, scan, mergeMap } from 'rxjs';
import { Admin } from 'src/schemas/admin.entity';
import { appendFileSync } from 'fs';


@Injectable()
export class CommunitiesService {

  constructor(
    @InjectModel(Community.name) private readonly communityModel: Model<CommunityDocument>,
    @Inject('SERVICIO_USUARIOS') private readonly clientUserApp: ClientProxy,

  ) { }

  async create(community: CommunityDocument): Promise<Community> {
    return this.communityModel.create(community);
  }

  async findAll(): Promise<Community[]> {

    return await this.communityModel
      .find()
      .setOptions({ sanitizeFilter: true })
      .exec()
      .then(async community => {
        if (community) {
          await Promise.all(community.map(async c => {
            //buscar al usuario con el id de la comunidad anexado
            let admin = await this.findCommunityAdmin(c["_id"], "2")
            if (admin) {
              c["id_admin"] = admin["_id"]
              c["name_admin"] = admin["name"]
            }
            return c
          }))
        }
        return community;
      })
  }

  findOne(id: string): Promise<Community> {
    return this.communityModel.findOne({ _id: id }).exec();
  }
  findOneName(id: string): Promise<Community> {
    return this.communityModel.findOne({ _id: id }).exec();
  }

  update(id: string, community: CommunityDocument) {
    return this.communityModel.findOneAndUpdate({ _id: id }, community, {
      new: true,
    });
  }

  async remove(id: string) {
    return this.communityModel.findByIdAndRemove({ _id: id }).exec();
  }

  async findCommunityAdmin(community: string, user_type: string) {
    const pattern = { cmd: 'findOneCommunityUser' }
    const payload = { community_id: community, user_type: user_type }

    let callback = await this.clientUserApp
      .send<string>(pattern, payload)
      .pipe(
        map((response: string) => ({ response }))
      )

    const finalValue = await lastValueFrom(callback);
    return finalValue['response'];

  }
}