Development (mongodb#23)

* Commit performed using Copy Push Files action

* remove old files

---------

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

Author: MongoCaleb

snippets/functions/mongodb-crud/InsertMany.js

@@ -1,19 +1,15 @@
-exports = async function(productIdToDelete){
-  // Find the name of the MongoDB service you want to use (see "Linked Data Sources" tab)
+exports = async function(args){
+  console.log(JSON.stringify(args));
+  
   var serviceName = "mongodb-atlas";
-
-  // Update these to reflect your db/collection
   var dbName = "sample_supplies";
   var collName = "sales";
 
-  // Get a collection from the context
   var collection = context.services.get(serviceName).db(dbName).collection(collName);
 
   try {
-    const query = { "product": productIdToDelete }
-    deleteResult = await collection.deleteMany(query);
+    deleteResult = await collection.deleteMany(args);
     return deleteResult["deletedCount"];
-
   } catch(err) {
     console.log("Failed to delete item: ", err.message);
     return { error: err.message };

snippets/functions/mongodb-crud/InsertOne.js

@@ -1,17 +1,15 @@
-exports = async function(objectIdToDelete){
-  // Find the name of the MongoDB service you want to use (see "Linked Data Sources" tab)
+exports = async function(deleteFilter){
   var serviceName = "mongodb-atlas";
-
-  // Update these to reflect your db/collection
   var dbName = "sample_supplies";
   var collName = "sales";
 
-  // Get a collection from the context
+  // example deleteFilter:
+  // { _id: ObjectId("123")}
+  
   var collection = context.services.get(serviceName).db(dbName).collection(collName);
 
   try {
-    const query = { "_id": objectIdToDelete }
-    deleteResult = await collection.deleteOne(query);
+    deleteResult = await collection.deleteOne(deleteFilter);
     return deleteResult["deletedCount"];
 
   } catch(err) {

snippets/functions/mongodb-crud/DeleteMany.js renamed to snippets/functions/mongodb-crud/crud_DeleteMany.js

@@ -9,15 +9,10 @@ exports = async function(args){
   // Get a collection from the context
   var collection = context.services.get(serviceName).db(dbName).collection(collName);
 
-  const query = { "price": { "$gt": 29.99 } };
-  const projection = {
-   "title": 1,
-   "quantity": 1,
-  }
-  
   try {
-    doc = await collection.find(query, projection);
-    return doc;
+    docs = await collection.find(args);
+    console.log(JSON.stringify(docs));
+    return docs;
 
   } catch(err) {
     console.log("Failed to find item: ", err.message);

snippets/functions/mongodb-crud/deleteOne.js renamed to snippets/functions/mongodb-crud/crud_DeleteOne.js

@@ -0,0 +1,17 @@
+exports = async function(saleId){
+  var serviceName = "mongodb-atlas";
+  var dbName = "sample_supplies";
+  var collName = "sales";
+
+  var collection = context.services.get(serviceName).db(dbName).collection(collName);
+  const query = { "_id": new BSON.ObjectId(saleId) };
+  try {
+    doc = await collection.findOne(query);
+    console.log('found:', JSON.stringify(doc));
+    return doc;
+
+  } catch(err) {
+    console.log("Failed to find item: ", err.message);
+    return { error: err.message };
+  }
+};

snippets/functions/mongodb-crud/Find.js renamed to snippets/functions/mongodb-crud/crud_Find.js

@@ -0,0 +1,23 @@
+exports = async function(args){
+  // Find the name of the MongoDB service you want to use (see "Linked Data Sources" tab)
+  var serviceName = "mongodb-atlas";
+
+  // Update these to reflect your db/collection
+  var dbName = "sample_supplies";
+  var collName = "sales";
+
+  // Get a collection from the context
+  var collection = context.services.get(serviceName).db(dbName).collection(collName);
+
+  try {
+    insertResult = await collection.insertMany(args);
+    console.log('insertResult ids:', insertResult.insertedIds);
+    console.log('insertResult length:', insertResult.insertedIds.length);
+    console.log('returning', JSON.stringify(insertResult));
+    return insertResult;
+
+  } catch(err) {
+    console.log("Failed to insert item(s): ", err.message);
+    return { error: err.message };
+  }
+};

snippets/functions/mongodb-crud/crud_FindOne.js

@@ -1,4 +1,4 @@
-exports = async function(objectIdToDelete){
+exports = async function(args){
   // Find the name of the MongoDB service you want to use (see "Linked Data Sources" tab)
   var serviceName = "mongodb-atlas";
 
@@ -10,12 +10,12 @@ exports = async function(objectIdToDelete){
   var collection = context.services.get(serviceName).db(dbName).collection(collName);
 
   try {
-    const query = { "_id": objectIdToDelete }
-    deleteResult = await collection.deleteOne(query);
-    return deleteResult["deletedCount"];
+    // Execute an InsertOne in MongoDB 
+    insertResult = await collection.insertOne(args);
+    return insertResult;
 
   } catch(err) {
-    console.log("Failed to delete item: ", err.message);
+    console.log("Failed to insert item: ", err.message);
     return { error: err.message };
   }
 };

snippets/functions/mongodb-crud/crud_InsertMany.js

@@ -1,22 +1,19 @@
-exports = async function(productId){
-  // Find the name of the MongoDB service you want to use (see "Linked Data Sources" tab)
+exports = async function(saleId, projection={}){
   var serviceName = "mongodb-atlas";
-
-  // Update these to reflect your db/collection
   var dbName = "sample_supplies";
   var collName = "sales";
 
-  // Get a collection from the context
   var collection = context.services.get(serviceName).db(dbName).collection(collName);
-  
-  const query = { "productId": productId };
-  const projection = {
-   "title": 1,
-   "quantity": 1,
-  }
-
+  const query = { "_id": new BSON.ObjectId(saleId) };
+  // An example of the projection object that might be passed in:
+  /*const projection = {
+    _id:0,
+    storeLocation:1,
+    items: 1
+  }*/
   try {
     doc = await collection.findOne(query, projection);
+    console.log('found:', JSON.stringify(doc));
     return doc;
 
   } catch(err) {

snippets/functions/mongodb-crud/DeleteOne.js renamed to snippets/functions/mongodb-crud/crud_InsertOne.js

@@ -1,4 +1,6 @@
-exports = async function(productId){
+exports = async function(productId, replacement){
+  console.log(productId);
+  console.log(replacement);
   // Find the name of the MongoDB service you want to use (see "Linked Data Sources" tab)
   var serviceName = "mongodb-atlas";
 
@@ -9,15 +11,14 @@ exports = async function(productId){
   // Get a collection from the context
   var collection = context.services.get(serviceName).db(dbName).collection(collName);
 
-  const query = { "productId": productId };
-  
-  const replacement = {
-      "name": "blocks",
-      "price": 20.99,
-      "category": "toys"
-  };
+  const query = { "_id": BSON.ObjectId(productId) };
+  // an example replacement ojbect:
+  /*const replacement = {
+      "storeLocation": "East Appleton",
+      "couponUsed": true,
+  };*/
 
-const options = { "returnNewDocument": false };
+const options = { "returnNewDocument": true };
 
   try {
     return await collection.findOneAndReplace(query, replacement, options);