Connect Google Calendar
to Your Pipeline

# calendar-read.yaml
# Reads upcoming calendar events
input:
  http_server:
    path: /calendar-read
    allowed_verbs: [ "POST" ]
pipeline:
  processors:
    - http:
        url: "https://www.googleapis.com/calendar/v3/calendars/primary/events"
        verb: GET
        headers:
          Authorization: "Bearer ${GOOGLE_ACCESS_TOKEN}"
    - mapping: |
        root.events = this.items.map_each(event -> {
          "title": event.summary,
          "start": event.start.dateTime.or(event.start.date),
          "end": event.end.dateTime.or(event.end.date),
          "location": event.location.or(""),
          "attendees": event.attendees.or([]).map_each(a -> a.email)
        })
output:
  sync_response: {}

# calendar-create.yaml
# Creates new calendar events
input:
  http_server:
    path: /calendar-create
    allowed_verbs: [ "POST" ]
pipeline:
  processors:
    - mapping: |
        root.summary = this.title
        root.start.dateTime = this.start_time
        root.start.timeZone = this.timezone.or("America/Los_Angeles")
        root.end.dateTime = this.end_time
        root.end.timeZone = this.timezone.or("America/Los_Angeles")
        root.attendees = this.attendees.or([]).map_each(email -> {"email": email})
    - http:
        url: "https://www.googleapis.com/calendar/v3/calendars/primary/events"
        verb: POST
        headers:
          Authorization: "Bearer ${GOOGLE_ACCESS_TOKEN}"
          Content-Type: "application/json"
output:
  sync_response: {}

# calendar-ics.yaml
# Reads events from ICS feed (read-only, no OAuth needed)
input:
  http_server:
    path: /calendar-ics
    allowed_verbs: [ "POST" ]
pipeline:
  processors:
    - http:
        url: "${GOOGLE_CALENDAR_ICS_URL}"
        verb: GET
    - mapping: |
        root.events = this.split("BEGIN:VEVENT").slice(1).map_each(block -> {
          "title": block.re_find("SUMMARY:(.+)").index(1).or(""),
          "start": block.re_find("DTSTART[^:]*:(.+)").index(1).or("")
        })
output:
  sync_response: {}