74 lines
2.3 KiB
TypeScript
74 lines
2.3 KiB
TypeScript
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'];
|
|
}
|
|
}
|