import * as wmill from "https://deno.land/x/windmill@v1.19.2/mod.ts";
import { Bson, MongoClient } from "https://deno.land/x/mongo@v0.30.1/mod.ts";
/*
@param: {wmill.Resource} mongodb - Resource containing mongodb connection object
example:
await client.connect({
  db: "<db_name>",
  tls: true,
  servers: [
    {
      host: "<db_cluster_url>",
      port: 27017,
    },
  ],
  credential: {
    username: "<username>",
    password: "<password>",
    db: "<db_name>",
    mechanism: "SCRAM-SHA-1",
  },
});
*/
export async function main(
    mongodb_con: wmill.Resource<"mongodb">,
    new_document: object,
    db_name: string,
    collection_name: string,
) {
    const client = new MongoClient();
    // Connecting to a Mongo Atlas Database
    const resp = await client.connect(mongodb_con);
    const db = client.database(db_name);
    const coll = db.collection(collection_name);
    const insertId = await coll.insertOne(new_document);
    return `Document inserted in MongoDB`;
}
 Submitted by rossmccrann 1205 days ago