import { MongoClient } from "https://deno.land/x/atlas_sdk@v1.0.3/mod.ts";

/**

 * @param data_source For example: `Cluster0`

 */

type MongodbRest = {

  endpoint: string;

  api_key: string;

};

export async function main(

  auth: MongodbRest,

  data_source: string,

  database: string,

  collection: string,

  documents: Record<string, any>[],

) {

  const client = new MongoClient({

    endpoint: auth.endpoint,

    dataSource: data_source,

    auth: { apiKey: auth.api_key },

  });

  const docs = client.database(database).collection(collection);

  let items: Record<string, any>[];

  try {

    items = documents.map((doc) =>

      typeof doc === "string" ? JSON.parse(doc) : doc,

    );

  } catch (err) {

    throw Error(`\nReceived array of strings in the 'documents' argument.

Attempted to parse them into objects but the process failed with the following error:\n${err}`);

  }

  return await docs.insertMany(items);

}