nirvana-v3/packages/api/services/conversation.service.ts

import Conversation, { MemberState } from '@nirvana/core/models/conversation.model';

import { ObjectId } from 'mongodb';
import { collections } from './database.service';

export default class ConversationService {
  static async getConversationById(conversationId: string) {
    const query = { _id: new ObjectId(conversationId) };

    const res = await collections.conversations?.findOne(query);

    // exists
    if (res?._id) {
      return res as Conversation;
    }

    return undefined;
  }

  static async createConversation(newConversation: Conversation) {
    return await collections.conversations?.insertOne(newConversation);
  }

  /**
   *
   * @param userId
   * @returns all conversations for user
   * sorted by lastActivityDate descending
   */
  static async getAllConversationsForUser(userId: string) {
    const query = { 'members._id': new ObjectId(userId) };

    const res = await collections.conversations
      ?.find(query)
      .sort({ lastActivityDate: -1 })
      .toArray();

    // exists
    if (res?.length) {
      return res as Conversation[];
    }

    return undefined;
  }

  /**
   * gets one on one conversation between two people if it exists
   */
  static async getConversationBetweenTwoPeople(userAId: ObjectId, userBId: ObjectId) {
    const query = {
      $and: [
        { members: { $size: 2 } },
        {
          'members._id': userAId,
        },
        { 'members._id': userBId },
      ],
    };

    const res = await collections.conversations?.findOne(query);

    // exists
    if (res?._id) {
      return res as Conversation;
    }

    return null;
  }

  static async updateUserConversationPriority(
    conversationId: ObjectId,
    memberId: ObjectId,
    newState: MemberState,
  ) {
    const query = { _id: conversationId, 'members._id': memberId };

    return await collections.conversations?.findOneAndUpdate(query, {
      $set: { 'members.$.memberState': newState },
    });
  }
}