goto_meeting init

Author: luancazarine

components/goto_meeting/actions/create-meeting/create-meeting.mjs

@@ -0,0 +1,80 @@
+import goto_meeting from "../../goto_meeting.app.mjs";
+import { axios } from "@pipedream/platform";
+
+export default {
+  key: "goto_meeting-create-meeting",
+  name: "Create Meeting",
+  description: "Creates a scheduled meeting in GoTo Meeting. [See the documentation](), ",
+  version: "0.0.{{ts}}",
+  type: "action",
+  props: {
+    goto_meeting: {
+      type: "app",
+      app: "goto_meeting",
+    },
+    subject: {
+      propDefinition: [
+        goto_meeting,
+        "subject",
+      ],
+    },
+    startTime: {
+      propDefinition: [
+        goto_meeting,
+        "startTime",
+      ],
+    },
+    endTime: {
+      propDefinition: [
+        goto_meeting,
+        "endTime",
+      ],
+    },
+    passwordRequired: {
+      propDefinition: [
+        goto_meeting,
+        "passwordRequired",
+      ],
+    },
+    conferenceCallInfo: {
+      propDefinition: [
+        goto_meeting,
+        "conferenceCallInfo",
+      ],
+    },
+    meetingType: {
+      propDefinition: [
+        goto_meeting,
+        "meetingType",
+      ],
+    },
+    timezoneKey: {
+      propDefinition: [
+        goto_meeting,
+        "timezoneKey",
+      ],
+      optional: true,
+    },
+    coorganizerKeys: {
+      propDefinition: [
+        goto_meeting,
+        "coorganizerKeys",
+      ],
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    const meeting = await this.goto_meeting.createScheduledMeeting({
+      subject: this.subject,
+      startTime: this.startTime,
+      endTime: this.endTime,
+      passwordRequired: this.passwordRequired,
+      conferenceCallInfo: this.conferenceCallInfo,
+      meetingType: this.meetingType,
+      timezoneKey: this.timezoneKey,
+      coorganizerKeys: this.coorganizerKeys,
+    });
+    $.export("$summary", `Meeting Created: ${meeting.subject}`);
+    return meeting;
+  },
+};

components/goto_meeting/goto_meeting.app.mjs

@@ -1,11 +1,157 @@
+import { axios } from "@pipedream/platform";
+
 export default {
   type: "app",
   app: "goto_meeting",
-  propDefinitions: {},
+  version: "0.0.{{ts}}",
+  propDefinitions: {
+    subject: {
+      type: "string",
+      label: "Subject",
+      description: "The subject of the meeting",
+    },
+    startTime: {
+      type: "string",
+      label: "Start Time",
+      description: "The start time of the meeting in ISO 8601 format",
+    },
+    endTime: {
+      type: "string",
+      label: "End Time",
+      description: "The end time of the meeting in ISO 8601 format",
+    },
+    passwordRequired: {
+      type: "boolean",
+      label: "Password Required",
+      description: "Whether a password is required to join the meeting",
+    },
+    conferenceCallInfo: {
+      type: "string",
+      label: "Conference Call Info",
+      description: "Information for the conference call",
+    },
+    meetingType: {
+      type: "string",
+      label: "Meeting Type",
+      description: "The type of the meeting",
+      options: [
+        {
+          label: "Scheduled",
+          value: "scheduled",
+        },
+        {
+          label: "Instant",
+          value: "instant",
+        },
+        {
+          label: "Recurring",
+          value: "recurring",
+        },
+      ],
+    },
+    timezoneKey: {
+      type: "string",
+      label: "Timezone Key",
+      description: "The timezone key for the meeting time",
+      optional: true,
+    },
+    coorganizerKeys: {
+      type: "string[]",
+      label: "Co-Organizer Keys",
+      description: "Keys of the co-organizers for the meeting",
+      optional: true,
+      async options() {
+        const coorganizers = await this.listCoOrganizers();
+        return coorganizers.map((coorganizer) => ({
+          label: coorganizer.name,
+          value: coorganizer.id,
+        }));
+      },
+    },
+  },
   methods: {
-    // this.$auth contains connected account data
+    // Existing method
     authKeys() {
       console.log(Object.keys(this.$auth));
     },
+    _baseUrl() {
+      return "https://api.goto.com/meeting/v1";
+    },
+    async _makeRequest(opts = {}) {
+      const {
+        $ = this,
+        method = "GET",
+        path = "/",
+        headers = {},
+        ...otherOpts
+      } = opts;
+      return axios($, {
+        ...otherOpts,
+        method,
+        url: this._baseUrl() + path,
+        headers: {
+          ...headers,
+          "Authorization": `Bearer ${this.$auth.access_token}`,
+          "Content-Type": "application/json",
+        },
+      });
+    },
+    async createScheduledMeeting({
+      subject, startTime, endTime, passwordRequired, conferenceCallInfo, meetingType, timezoneKey, coorganizerKeys,
+    }) {
+      const data = {
+        subject: this.subject,
+        startTime: this.startTime,
+        endTime: this.endTime,
+        passwordRequired: this.passwordRequired,
+        conferenceCallInfo: this.conferenceCallInfo,
+        meetingType: this.meetingType,
+      };
+      if (this.timezoneKey) {
+        data.timezoneKey = this.timezoneKey;
+      }
+      if (this.coorganizerKeys && this.coorganizerKeys.length > 0) {
+        data.coorganizerKeys = this.coorganizerKeys;
+      }
+      const meeting = await this._makeRequest({
+        method: "POST",
+        path: "/meetings",
+        data,
+      });
+      this.emitMeetingCreated(meeting);
+      return meeting;
+    },
+    async listCoOrganizers() {
+      return this._makeRequest({
+        method: "GET",
+        path: "/users/coorganizers",
+      });
+    },
+    emitMeetingCreated(meeting) {
+      this.$emit(meeting, {
+        summary: `Meeting Created: ${meeting.subject}`,
+        id: meeting.id,
+      });
+    },
+    async paginate(fn, ...opts) {
+      const results = [];
+      let hasMore = true;
+      let page = 1;
+
+      while (hasMore) {
+        const response = await fn({
+          ...opts,
+          page,
+        });
+        if (response && response.length > 0) {
+          results.push(...response);
+          page += 1;
+        } else {
+          hasMore = false;
+        }
+      }
+
+      return results;
+    },
   },
 };

components/goto_meeting/package.json

@@ -12,4 +12,4 @@
   "publishConfig": {
     "access": "public"
   }
-}
+}

components/goto_meeting/sources/new-meeting/new-meeting.mjs

@@ -0,0 +1,139 @@
+import goto_meeting from "../../goto_meeting.app.mjs";
+import {
+  axios, DEFAULT_POLLING_SOURCE_TIMER_INTERVAL,
+} from "@pipedream/platform";
+
+export default {
+  key: "goto_meeting-new-meeting",
+  name: "New Meeting Created",
+  description: "Emit a new event when a meeting is created in your GoToMeeting account. [See the documentation]()",
+  version: "0.0.{{ts}}",
+  type: "source",
+  dedupe: "unique",
+  props: {
+    goto_meeting: {
+      type: "app",
+      app: "goto_meeting",
+    },
+    db: "$.service.db",
+    timer: {
+      type: "$.interface.timer",
+      default: {
+        intervalSeconds: DEFAULT_POLLING_SOURCE_TIMER_INTERVAL,
+      },
+    },
+  },
+  hooks: {
+    async deploy() {
+      const MAX_EVENTS = 50;
+      let page = 1;
+      const fetchedMeetings = [];
+
+      while (fetchedMeetings.length < MAX_EVENTS) {
+        const meetings = await this.goto_meeting._makeRequest({
+          method: "GET",
+          path: "/meetings",
+          params: {
+            page,
+            perPage: 50,
+            orderBy: "created",
+            order: "desc",
+          },
+        });
+
+        if (meetings.length === 0) {
+          break;
+        }
+
+        fetchedMeetings.push(...meetings);
+
+        if (meetings.length < 50) {
+          break;
+        }
+
+        page += 1;
+      }
+
+      const recentMeetings = fetchedMeetings.slice(0, MAX_EVENTS).reverse();
+
+      for (const meeting of recentMeetings) {
+        this.$emit(meeting, {
+          id: meeting.id || meeting.created,
+          summary: `Meeting Created: ${meeting.subject}`,
+          ts: meeting.created
+            ? Date.parse(meeting.created)
+            : Date.now(),
+        });
+      }
+
+      const lastMeeting = fetchedMeetings[0];
+      const lastTimestamp = lastMeeting.created
+        ? Date.parse(lastMeeting.created)
+        : Date.now();
+      await this.db.set("lastTimestamp", lastTimestamp);
+    },
+    async activate() {
+      // Add activation logic if needed
+    },
+    async deactivate() {
+      // Add deactivation logic if needed
+    },
+  },
+  async run() {
+    const lastTimestamp = (await this.db.get("lastTimestamp")) || 0;
+    let page = 1;
+    const newMeetings = [];
+
+    while (true) {
+      const meetings = await this.goto_meeting._makeRequest({
+        method: "GET",
+        path: "/meetings",
+        params: {
+          page,
+          perPage: 50,
+          orderBy: "created",
+          order: "desc",
+        },
+      });
+
+      if (meetings.length === 0) {
+        break;
+      }
+
+      for (const meeting of meetings) {
+        const meetingTimestamp = meeting.created
+          ? Date.parse(meeting.created)
+          : Date.now();
+        if (meetingTimestamp > lastTimestamp) {
+          newMeetings.push(meeting);
+        } else {
+          break;
+        }
+      }
+
+      if (meetings.length < 50) {
+        break;
+      }
+
+      page += 1;
+    }
+
+    if (newMeetings.length > 0) {
+      for (const meeting of newMeetings.reverse()) {
+        this.$emit(meeting, {
+          id: meeting.id || meeting.created,
+          summary: `Meeting Created: ${meeting.subject}`,
+          ts: meeting.created
+            ? Date.parse(meeting.created)
+            : Date.now(),
+        });
+      }
+
+      const latestMeeting = newMeetings[0];
+      const latestTimestamp = latestMeeting.created
+        ? Date.parse(latestMeeting.created)
+        : Date.now();
+      await this.db.set("lastTimestamp", latestTimestamp);
+    }
+  },
+};