import taskScheduler from "../../../pipedream/sources/new-scheduled-tasks/new-scheduled-tasks.mjs";
import googleCalendar from "../../google_calendar.app.mjs";
import sampleEmit from "./test-event.mjs";
export default {
key: "google_calendar-upcoming-event-alert",
name: "New Upcoming Event Alert",
description: `Emit new event based on a time interval before an upcoming event in the calendar. This source uses Pipedream's Task Scheduler.
[See the documentation](https://pipedream.com/docs/examples/waiting-to-execute-next-step-of-workflow/#step-1-create-a-task-scheduler-event-source)
for more information and instructions for connecting your Pipedream account.`,
version: "0.0.9",
type: "source",
props: {
pipedream: taskScheduler.props.pipedream,
googleCalendar,
db: "$.service.db",
http: "$.interface.http",
calendarId: {
propDefinition: [
googleCalendar,
"calendarId",
],
},
eventTypes: {
propDefinition: [
googleCalendar,
"eventTypes",
],
},
time: {
type: "integer",
label: "Minutes Before",
description: "Number of minutes to trigger before the start of the calendar event.",
min: 0,
reloadProps: true,
},
},
async additionalProps() {
const props = {};
if (this.time > 0) {
props.timer = {
type: "$.interface.timer",
description: "Poll the API to schedule alerts for any newly created events",
default: {
intervalSeconds: 60 * this.time,
},
};
}
return props;
},
hooks: {
async deactivate() {
const ids = this._getScheduledEventIds();
if (!ids?.length) {
return;
}
for (const id of ids) {
if (await this.deleteEvent({
body: {
id,
},
})) {
console.log("Cancelled scheduled event");
}
}
this._setScheduledEventIds();
},
},
methods: {
...taskScheduler.methods,
_getScheduledEventIds() {
return this.db.get("scheduledEventIds");
},
_setScheduledEventIds(ids) {
this.db.set("scheduledEventIds", ids);
},
_getScheduledCalendarEventIds() {
return this.db.get("scheduledCalendarEventIds");
},
_setScheduledCalendarEventIds(ids) {
this.db.set("scheduledCalendarEventIds", ids);
},
_hasDeployed() {
const result = this.db.get("hasDeployed");
this.db.set("hasDeployed", true);
return result;
},
subtractMinutes(date, minutes) {
return date.getTime() - minutes * 60000;
},
async getCalendarEvents() {
const calendarEvents = [];
const params = {
returnOnlyData: false,
calendarId: this.calendarId,
eventTypes: this.eventTypes,
};
do {
const {
data: {
items, nextPageToken,
},
} = await this.googleCalendar.listEvents(params);
if (items?.length) {
calendarEvents.push(...items);
}
params.pageToken = nextPageToken;
} while (params.pageToken);
return calendarEvents;
},
},
async run(event) {
if (!this._hasDeployed()) {
await this.selfSubscribe();
}
const scheduledEventIds = this._getScheduledEventIds() || [];
if (event.$channel === this.selfChannel()) {
const remainingScheduledEventIds = scheduledEventIds.filter((id) => id !== event["$id"]);
this._setScheduledEventIds(remainingScheduledEventIds);
this.emitEvent(event, `Upcoming ${event.summary} event`);
return;
}
const scheduledCalendarEventIds = this._getScheduledCalendarEventIds() || {};
const calendarEvents = await this.getCalendarEvents();
for (const calendarEvent of calendarEvents) {
const startTime = calendarEvent.start
? (new Date(calendarEvent.start.dateTime || calendarEvent.start.date))
: null;
if (!startTime
|| startTime.getTime() < Date.now()
|| scheduledCalendarEventIds[calendarEvent.id])
{
continue;
}
const later = new Date(this.subtractMinutes(startTime, this.time));
const scheduledEventId = this.emitScheduleEvent(calendarEvent, later);
scheduledEventIds.push(scheduledEventId);
scheduledCalendarEventIds[calendarEvent.id] = true;
}
this._setScheduledEventIds(scheduledEventIds);
this._setScheduledCalendarEventIds(scheduledCalendarEventIds);
},
sampleEmit,
};
Chase Roberts@chsrbrts@benedictevans If you haven’t used @pipedream yet, then you haven’t lived.
✨Ellie Day✨@heyelliedayEvaluation update: @pipedream has quite literally been a dream to work with! I’m excited to leverage this tool for all the various workflows I need to write. I’m currently at 11k invocations a day from the initial workflows I’ve written in the past couple weeks.
Michael Braedley@MBraedleyUpdate: I got it working properly, and it's working so well that I'm dropping IFTTT. @pipedream can do everything that IFTTT basic can, and most (if not all things) IFTTT pro can for free or at a reasonable price if you need it. I am recommending it for basically any power user.
Thomas Cutting@mrthomascuttingWant quick+dirty integrations for a serverless workflow - @pipedream is my new go-to 😃
Matthew Roberts@mattdotrobertsday 013 - finally hit node js. This is the secret sauce of taking #nocode projects that one step further. Pumped about getting deeper into @pipedream now
Kenneth Auchenberg 💭@auchenbergYahoo Pipes is back! Kinda 😍 @pipedream
Raymond Camden 🥑@raymondcamdenAwesome video by the @pipedream folks showing real time twitter sentiment analysis integrated with Google Sheets. This is where Pipedream *really* shines, connecting systems together in easy workflows.
Nacho Caballero@nachocaballeroI couldn't recommend @pipedream more. It's an amazing service to integrate different APIs. Much more powerful than Zapier and more user-friendly than AWS Lambda. I'm very proud to wear this t-shirt #NoCode
Jason Snow@jyksnwDeveloped a working prototype environmental sensor IoT solution with @particle Photon, @pipedream, and @MongoDB with full graphing and alerting in less than a day! All amazing technology, will def. be exploring these more.
Steven Terrana@steven_terrana@burgwyn you've inspired me to finally set up my own blog. I'll make sure my first blog post explains the tech behind the setup. think @obsdmd + @GatsbyJS + @pipedream.
🚄 James Augeri, PhD@DotDotJamesWant to low-code your back end, need more horsepower than @Bubble / @KnackHQ, or just miss Yahoo! Pipes? Check out @PipeDream
Sébastien Chopin@AtinuxGitHub issues should be like @linear_app for maintainers. Looking forward more integrations with GH actions or tools like @pipedream 👀
Raul@raul_predescuIf you're a dev and not using @pipedream, you're missing out. Been using it for months, daily. FREE for devs. Plenty of integrations and good limits. Absolutely love it.
Bruno Skvorc@bitfallsSo @pipedream is pretty amazing. In 3 minutes I just made a flow which adds @rickastley's Never Gonna Give You Up to my @spotify playlist whenever a new pull request arrives in an old repo of mine.
Zach Lanich@ZachLanichUm, wow 🤯 @pipedream
Steven Bell@bellontechI just used @pipedream to build a Shopify App. Wow, they make small backed tasks easy.
Jay Hack 🎩🇺🇸@_jayhack_Very impressed with this bad boi - it reminds me of a @PalantirTech internal tool, but geared towards integrations instead of data analysis and far more customizable. Great expectations here 🚀🤩
Tree Sturgeon 🔥🚴♂️🌳@philsturgeonFor context this is day 2 of a really challenging and stupid migration from Notion to @airtable with disparate/missing data. It's going better than expected and thanks to @pipedream I don't have to bother the iOS dev to add W3W.