Triggers

By default, adding a trigger will set the schedule to 15 minutes.

Flows can be scheduled through the Flow UI using a CRON expression and then activating the schedule as seen in the image below.

Example of a trigger script watching new Slack posts with a given word in a given channel and the flow sending each of them by email in a for loop:

This flow can be found on getOperate Hub.

Examples of trigger scripts include:

• Trigger every time a new item text on HackerNews match at least one mention
• Notify of new Github repo stars
• Check new uploaded files on Google Drive

The following TypeScript code is an example of the first module of a Flow that checks for new documents in a MongoDB collection on a regular schedule. In this case we query documents that were created after a specific time, expressed with a timestamp. The timestamp is stored with the help of getOperate’s built-in state functions and is updated in each run.

import { getState, type Resource, setState } from 'https://deno.land/x/getOperate/mod.ts';
import { MongoClient, ObjectId } from 'https://deno.land/x/atlas_sdk/mod.ts';

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 } });
}