Edits history of script submission #262 for ' Get recently inserted documents (mongodb)'

• deno

  Ap­pro­ved version

  Edit in Windmill

  Embed

  import {
    getState,
    setState,
  } from "https://deno.land/x/windmill@v1.85.0/mod.ts";
  import {
    MongoClient,
    ObjectId,
  } 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,
  ) {
    const client = new MongoClient({
      endpoint: auth.endpoint,
      dataSource: data_source,
      auth: { apiKey: auth.api_key },
    });
    const documents = client.database(database).collection(collection);
    const lastCheck = (await getState()) || 0;
    await setState(Date.now() / 1000);
    const id = ObjectId.createFromTime(lastCheck);
    return await documents.find({ _id: { $gt: id } });
  }
  

  Submitted by admin 460 days ago

• deno

  Edit in Windmill

  Embed

  import { getState, setState } from "https://deno.land/x/windmill@v1.85.0/mod.ts";
  import { MongoClient, ObjectId } 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
  ) {
    const client = new MongoClient({
      endpoint: auth.endpoint,
      dataSource: data_source,
      auth: { apiKey: auth.api_key },
    });
    const documents = client.database(database).collection(collection)
    const lastCheck = await getState() || 0
    await setState(Date.now() / 1000)
    const id = ObjectId.createFromTime(lastCheck)
    return await documents.find({"_id": {"$gt": id}})
  }
  

  Submitted by admin 463 days ago

• deno

  Edit in Windmill

  Embed

  import { Resource, getState, setState } from "https://deno.land/x/windmill@v1.85.0/mod.ts";
  import { MongoClient, ObjectId } from "https://deno.land/x/atlas_sdk@v1.0.3/mod.ts";
  
  /**
   * @param data_source For example: `Cluster0`
   */
  export async function main(
    auth: Resource<"mongodb_rest">,
    data_source: string,
    database: string,
    collection: string
  ) {
    const client = new MongoClient({
      endpoint: auth.endpoint,
      dataSource: data_source,
      auth: { apiKey: auth.api_key },
    });
    const documents = client.database(database).collection(collection)
    const lastCheck = await getState() || 0
    await setState(Date.now() / 1000)
    const id = ObjectId.createFromTime(lastCheck)
    return await documents.find({"_id": {"$gt": id}})
  }
  

  Submitted by adam186 591 days ago

• deno

  Edit in Windmill

  Embed

  import { Resource, getState, setState } from "https://deno.land/x/windmill@v1.70.1/mod.ts";
  import { MongoClient, ObjectId } from "https://deno.land/x/atlas_sdk@v1.0.3/mod.ts";
  
  /**
   * @param data_source For example: `Cluster0`
   */
  export async function main(
    auth: Resource<"mongodb_rest">,
    data_source: string,
    database: string,
    collection: string
  ) {
    const client = new MongoClient({
      endpoint: auth.endpoint,
      dataSource: data_source,
      auth: { apiKey: auth.api_key },
    });
    const documents = client.database(database).collection(collection)
    const lastCheck = await getState() || 0
    await setState(Date.now() / 1000)
    const id = ObjectId.createFromTime(lastCheck)
    return await documents.find({"_id": {"$gt": id}})
  }
  

  Submitted by adam186 626 days ago

• deno

  Edit in Windmill

  Embed

  import { Resource, getState, setState } from "https://deno.land/x/windmill@v1.55.0/mod.ts";
  import { MongoClient, ObjectId } from "https://deno.land/x/atlas_sdk@v1.0.3/mod.ts";
  
  /**
   * @param data_source For example: `Cluster0`
   */
  export async function main(
    auth: Resource<"mongodb_rest">,
    data_source: string,
    database: string,
    collection: string
  ) {
    const client = new MongoClient({
      endpoint: auth.endpoint,
      dataSource: data_source,
      auth: { apiKey: auth.api_key },
    });
    const documents = client.database(database).collection(collection)
    const lastCheck = await getState() || 0
    await setState(Date.now() / 1000)
    const id = ObjectId.createFromTime(lastCheck)
    return await documents.find({"_id": {"$gt": id}})
  }
  

  Submitted by adam186 695 days ago