adding all logic for sending request and should work?

packages/api/services/contact.service.ts

@@ -1,3 +1,4 @@
+import { Db } from "mongodb";
 import Relationship from "@nirvana/core/models/relationship.model";
 import { collections } from "./database.service";
 
@@ -22,7 +23,7 @@ export class ContactService {
     };
 
     const query = { $or: [clauseOne, clauseTwo] };
-    const res = await collections.users?.findOne(query);
+    const res = await collections.relationships?.findOne(query);
 
     // exists
     if (res?._id) {
@@ -31,4 +32,22 @@ export class ContactService {
 
     return null;
   }
+
+  static async createRelationship(newRelationship: Relationship) {
+    // i am the sender and they are the receiver
+    const relationshipRes = await this.getRelationship(
+      newRelationship.senderUserId,
+      newRelationship.receiverUserId
+    );
+
+    if (relationshipRes) {
+      throw new Error("Already exists");
+    }
+
+    const insertResult = await collections.relationships?.insertOne(
+      newRelationship
+    );
+
+    return insertResult;
+  }
 }

packages/api/services/database.service.ts

@@ -4,7 +4,10 @@ import * as mongoDB from "mongodb";
 
 // Global Variables
 
-export const collections: { users?: mongoDB.Collection } = {};
+export const collections: {
+  users?: mongoDB.Collection;
+  relationships?: mongoDB.Collection;
+} = {};
 
 // Initialize Connection
 export async function connectToDatabase() {
@@ -17,10 +20,13 @@ export async function connectToDatabase() {
   const db: mongoDB.Db = client.db(process.env.DB_NAME);
 
   const usersCollection: mongoDB.Collection = db.collection("users");
+  const relationshipCollection: mongoDB.Collection =
+    db.collection("relationships");
 
   collections.users = usersCollection;
+  collections.relationships = relationshipCollection;
 
   console.log(
-    `Successfully connected to database: ${db.databaseName} and collection: ${usersCollection.collectionName}`
+    `Successfully connected to database: ${db.databaseName} and collections`
   );
 }