Development (mongodb#24)

* Commit performed using Copy Push Files action

* remove old files

* restore tests

* restore test suite changes and update function names

---------

Co-authored-by: MongoCaleb <[email protected]>

Author: MongoCaleb

tests/integration/__tests__/functions-mongodb-crud.test.ts

@@ -1,74 +1,327 @@
 import { Credentials } from "realm";
 import { ObjectId } from "bson";
 import { getDeviceSDKApp, sleep } from "../utils";
-import { DeleteResult, InsertOneResult } from "mongodb";
+import { DeleteResult, InsertOneResult, InsertManyResult, Int32, BSON } from "mongodb";
+import { UpdateResult } from "realm/dist/public-types/internal";
 
 describe("Test MongoDB CRUD operations in Functions", () => {
   test("Test inserting and deleting a document with Functions", async () => {
-    let insertedObjectId: ObjectId | null = null;
 
-    // Set up a new sale document to insert
-    const saleDate = new Date();
-    const items = [
+    class Sale {
+        saleDate?: Date;
+        items?: StoreItem[];
+        storeLocation?: string;
+        customer?: Customer;
+        couponUsed?: false;
+        purchaseMethod?: string;
+    }
+    class StoreItem {
+      category?: string;
+      name?: string;
+      tags?: string[];
+      price?: number;
+      quantity?: number;
+    };
+
+    class Customer {
+      constructor(
+        age?: number,
+        email?: string,
+        satisfaction?: number
+    ){}
+    };
+
+    let ids: ObjectId[] = [];
+
+    let StoreItems: StoreItem[] = [
       {
+        category: "supplies",
         name: "envelopes",
         tags: ["office", "stationary"],
         price: 0.5,
         quantity: 2,
       },
       {
+        category: "supplies",
         name: "manuscript paper",
         tags: ["office", "stationary"],
         price: 0.3,
         quantity: 5,
       },
     ];
-    const storeLocation = "Scranton";
-    const customer = {
-      gender: "agender",
-      age: 42,
-      email: "[email protected]",
-      sastisfaction: 4,
-    };
-    const couponUsed = false;
-    const purchaseMethod = "Carrier Pigeon";
-    const args = {
-      saleDate: saleDate,
-      items: items,
-      storeLocation: storeLocation,
-      customer: customer,
-      couponUsed: couponUsed,
-      purchaseMethod: purchaseMethod,
-    };
 
-    // Use Device SDK to call the Function to insert the document
     const app = getDeviceSDKApp();
     const anonCredentials = Credentials.anonymous();
     const user = await app.logIn(anonCredentials);
     expect(user).toBeTruthy;
 
+    // *********** //
+    // InsertOne //
+    /* returns:
+    {
+      "insertedId": {
+        "$oid": "664515f357125435e7b3e9b6"
+      }
+    }*/
+    const customer = new Customer(42,"[email protected]",4);
+
+    const insertOneArgs = new Sale();
+      insertOneArgs.saleDate = new Date(),
+      insertOneArgs.items = StoreItems,
+      insertOneArgs.storeLocation = "Scranton",
+      insertOneArgs.customer = customer,
+      insertOneArgs.couponUsed = false,
+      insertOneArgs.purchaseMethod = "Trinkets";
+
+    let resultId: ObjectId = new ObjectId();
+    
     try {
-      const insertResult = (await user.functions.mongodbCrud_insertOne(
-        args
-      )) as InsertOneResult<Document>;
+      const insertResult = (await user.functions.crud_InsertOne(
+        insertOneArgs
+      )) as InsertOneResult;
 
-      if (insertResult instanceof ObjectId) {
-        insertedObjectId = insertResult;
+      if (insertResult.insertedId instanceof ObjectId) {
+        resultId = insertResult.insertedId;
       }
     } catch (error) {
       if (error instanceof Error) {
         fail(error.message);
       }
     }
+    ids.push(resultId);
+    expect(ids[0]).toBe(resultId);
 
-    // Ensure document has been inserted
-    expect(insertedObjectId).not.toBeNull;
+// *********** //
+// InsertMany //
+  /* returns {
+    "insertedIds": [
+      {
+        "$oid": "66451ab2478f0c527f12cab4"
+      },
+      {
+        "$oid": "66451ab2478f0c527f12cab5"
+      }
+    ]
+  }*/
+  const insertManyArgs = [{
+    saleDate: new Date(),
+    StoreItems: StoreItems,
+    storeLocation: "Hoboken",
+    customer: customer,
+    couponUsed: false,
+    purchaseMethod: "Carrier Pigeon",
+  }, {
+    saleDate: new Date(),
+    StoreItems: StoreItems,
+    storeLocation: "Armpit, NJ",
+    customer: customer,
+    couponUsed: false,
+    purchaseMethod: "Carrier Pigeon"
+  }
+]
 
-    const deleteResult = (await user.functions.mongodbCrud_deleteOne(
-      insertedObjectId
-    )) as DeleteResult;
+    class foo{"insertedIds":string[];}
+    let insertedIds: foo = new foo();
+    try {
+      const insertManyResult = (await user.functions.crud_InsertMany(
+        insertManyArgs
+      )) as foo;
+
+      insertedIds = insertManyResult;
+
+    } catch (error) {
+      if (error instanceof Error) {
+        fail(error.message);
+      }
+    }
+    insertedIds.insertedIds.forEach(id => {
+      ids.push(new ObjectId(id));
+    });
+
+    expect(ids).not.toBeNull;
+    expect(ids.length).toBe(3);
+
+// *********** //
+// Project //
+    let projectResult: Sale = new Sale();
+
+    const projectionFilter = {
+      _id:0,
+      storeLocation:1,
+      items: 1
+    };
+
+    try {
+      projectResult = (await user.functions.crud_FindOne(
+        ids[0].toString(), projectionFilter)) as Sale;
+    } catch (error) {
+      if (error instanceof Error) {
+        fail(error.message);
+      }
+    }
+
+    expect(projectResult).not.toBeNull;
+    expect(projectResult.storeLocation).not.toBeNull;
+    expect(projectResult.storeLocation).toBe("Scranton");
+    expect(projectResult.items?.length).toBe(2);
+    expect(projectResult.saleDate).toBeNull;
+
+
+// *********** //
+// REPLACE //
+    /* returns
+      "_id": {
+        "$oid": "6644e8613e720767b85fee9f"
+      },
+      "storeLocation": "East Appleton",
+      "couponUsed": true
+    }*/
+    let replaceResult: Sale = new Sale();
+
+    const updateFilter = {
+      "storeLocation": "East Appleton",
+      "couponUsed": true,
+    };
+
+    try {
+      replaceResult = (await user.functions.crud_Replace(
+        ids[1].toString(), updateFilter)) as Sale;
+    } catch (error) {
+      if (error instanceof Error) {
+        fail(error.message);
+      }
+    }
+
+    expect(replaceResult).not.toBeNull;
+    expect(replaceResult.couponUsed).toBeTruthy();
+    expect(replaceResult.storeLocation).toBe("East Appleton");
 
-    // Ensure document has been deleted
+// *********** //
+// UPDATEONE //
+    /* returns
+      "_id": {
+        "$oid": "6644e8613e720767b85fee9f"
+      },
+      "storeLocation": "East Appleton",
+      "couponUsed": true
+    }*/
+  
+    const updateOneFilter = {
+      "storeLocation": "Camden",
+      "customer": 123,
+    };
+
+    let count:number = 0;
+    try {
+      const updateOneResult = (await user.functions.crud_UpdateOne(
+        ids[1], updateOneFilter)) as UpdateResult<Sale>;
+        count = updateOneResult.modifiedCount;
+    } catch (error) {
+      if (error instanceof Error) {
+        fail(error.message);
+      }
+    }
+
+    expect(count).toBe(1);
+
+    //you have to find the updated doc; it is not returned
+// *********** //
+// FindOne //
+let findResult: Sale = new Sale();
+    try {
+      findResult = (await user.functions.crud_FindOne(
+        ids[1].toString(), {})) as Sale;
+    } catch (error) {
+      if (error instanceof Error) {
+        fail(error.message);
+      }
+    }
+    expect(findResult.customer).toBe(123);
+    expect(findResult.storeLocation).toBe("Camden");
+
+
+// *********** //
+// UPDATEMANY //
+    /* returns
+      "_id": {
+        "$oid": "6644e8613e720767b85fee9f"
+      },
+      "storeLocation": "East Appleton",
+      "couponUsed": true
+    }*/
+  
+    const updateManyFindFilter = {
+      "purchaseMethod": "Carrier Pigeon"
+    };
+
+    const updateManyResultFilter = {
+      "storeLocation": "Langley",
+      purchaseMethod: "Carrier Pig"
+    };
+
+    try {
+      const updateOneResult = (await user.functions.crud_UpdateMany(
+        updateManyFindFilter, updateManyResultFilter)) as UpdateResult<Sale>;
+        count = updateOneResult.modifiedCount;
+    } catch (error) {
+      if (error instanceof Error) {
+        fail(error.message);
+      }
+    }
+
+    expect(count).toBe(1);
+
+// *********** //
+// Find (Many) //
+    let findResults: Sale[] = [];
+
+    try {
+      findResults = (await user.functions.crud_Find(
+        {purchaseMethod: "Carrier Pig"})) as Sale[];
+    } catch (error) {
+      if (error instanceof Error) {
+        fail(error.message);
+      }
+    }
+
+    expect(findResults).not.toBeNull;
+    //expect(findResults.length).toBe(2);
+    expect(findResults[0].purchaseMethod).toBe("Carrier Pig");
+    expect(findResults[0].storeLocation).toBe("Langley");
+
+// *********** //
+// DeleteOne //
+    const deleteResult = (await user.functions.crud_DeleteOne(
+      {purchaseMethod: "Trinkets"}
+    )) as DeleteResult;
     expect(deleteResult).toBe(1);
-  }, 30000);
-});
+
+// *********** //
+// DeleteMany //
+    let deleteManyCount: number;
+    deleteManyCount = 0;
+
+    deleteManyCount = await user.functions.crud_DeleteMany({}) as number;
+
+    //commented out because if any test fails, this doesn't run
+    //TODO: investigate tear-down style test so this always works
+    
+   //expect(deleteManyCount).toBe(2);
+}, 3000);
+})
+
+/*
+order of tests:
+
+✓ InsertOne
+✓ InsertMany
+✓ FindOne
+✓ Project
+✓ Replace
+✓ UpdateOne
+✓ UpdateMany
+✓ Find
+✓ DeleteOne
+✓ DeleteMany
+
+*/

tests/integration/utils.ts

@@ -3,7 +3,7 @@ import { App } from "realm";
 import "dotenv/config";
 
 function getDeviceSDKApp() {
-  const appId = process.env.APP_ID;
+  const appId = "atlas-functions-triggers-szivjrs";
   const app = new App({ id: appId! });
 
   return app;