Custom headers - Possible Implementation

packages/common/src/event-sources/json-feed-event-source.ts

@@ -34,7 +34,7 @@ let eventSourceDef: EventSourceDef<JsonFeedMeta> = {
   },
 
   fetch(arg, success, failure) {
-    let { meta } = arg.eventSource
+    let { meta, additionalHeaders } = arg.eventSource
     let requestParams = buildRequestParams(meta, arg.range, arg.context)
 
     requestJson(
@@ -45,6 +45,7 @@ let eventSourceDef: EventSourceDef<JsonFeedMeta> = {
       (errorMessage, xhr) => {
         failure({ message: errorMessage, xhr })
       },
+      additionalHeaders,
     )
   },
 

packages/common/src/structs/event-source-parse.ts

@@ -18,6 +18,7 @@ const EVENT_SOURCE_REFINERS = { // does NOT include EVENT_UI_REFINERS
   // for any network-related sources
   success: identity as Identity<EventSourceSuccessResponseHandler>,
   failure: identity as Identity<EventSourceErrorResponseHandler>,
+  additionalHeaders: identity as Identity<Headers>,
 }
 
 type BuiltInEventSourceRefiners = typeof EVENT_SOURCE_REFINERS &
@@ -76,6 +77,7 @@ export function parseEventSource(
         meta: metaRes.meta,
         ui: createEventUi(refined, context),
         extendedProps: extra,
+        additionalHeaders: refined.additionalHeaders,
       }
     }
   }

packages/common/src/structs/event-source.ts

@@ -32,6 +32,7 @@ export interface EventSource<Meta> {
   ui: EventUi
   success: EventSourceSuccessResponseHandler | null
   failure: EventSourceErrorResponseHandler | null
+  additionalHeaders: Headers | null
   extendedProps: Dictionary // undocumented
 }
 

packages/common/src/util/requestJson.ts

@@ -1,6 +1,6 @@
 import { Dictionary } from '../options'
 
-export function requestJson(method: string, url: string, params: Dictionary, successCallback, failureCallback) {
+export function requestJson(method: string, url: string, params: Dictionary, successCallback, failureCallback, additionalHeaders: Headers | null) {
   method = method.toUpperCase()
 
   let body = null
@@ -18,6 +18,12 @@ export function requestJson(method: string, url: string, params: Dictionary, suc
     xhr.setRequestHeader('Content-Type', 'application/x-www-form-urlencoded')
   }
 
+  if (!!additionalHeaders) {
+    additionalHeaders.forEach((value: string, key: string) => {
+      xhr.setRequestHeader(key, value);
+    });
+  }
+
   xhr.onload = () => {
     if (xhr.status >= 200 && xhr.status < 400) {
       let parsed = false

packages/google-calendar/src/main.ts

@@ -38,6 +38,7 @@ let eventSourceDef: EventSourceDef<GCalMeta> = {
   fetch(arg, onSuccess, onFailure) {
     let { dateEnv, options } = arg.context
     let meta: GCalMeta = arg.eventSource.meta
+    let { additionalHeaders } = arg.eventSource;
     let apiKey = meta.googleCalendarApiKey || options.googleCalendarApiKey
 
     if (!apiKey) {
@@ -76,8 +77,9 @@ let eventSourceDef: EventSourceDef<GCalMeta> = {
         }
       }, (message, xhr) => {
         onFailure({ message, xhr })
-      })
-    }
+      },
+      additionalHeaders,
+    )}
   },
 }
 

packages/icalendar/src/main.ts

@@ -32,7 +32,7 @@ let eventSourceDef: EventSourceDef<ICalFeedMeta> = {
   },
 
   fetch(arg, onSuccess, onFailure) {
-    let { meta } = arg.eventSource
+    let { meta, additionalHeaders } = arg.eventSource
     let { internalState } = meta
 
     function handleICalEvents(errorMessage, iCalExpander: IcalExpander, xhr) {
@@ -83,6 +83,7 @@ let eventSourceDef: EventSourceDef<ICalFeedMeta> = {
           internalState.errorMessage = errorMessage
           internalState.xhr = xhr
         },
+        additionalHeaders,
       )
     } else if (!internalState.completed) {
       internalState.callbacks.push(handleICalEvents)
@@ -92,9 +93,15 @@ let eventSourceDef: EventSourceDef<ICalFeedMeta> = {
   },
 }
 
-function requestICal(url: string, successCallback: Success, failureCallback: Failure) {
+function requestICal(url: string, successCallback: Success, failureCallback: Failure, additionalHeaders: Headers | null) {
   const xhr = new XMLHttpRequest()
   xhr.open('GET', url, true)
+  if (!!additionalHeaders) {
+    additionalHeaders.forEach((value: string, key: string) => {
+      xhr.setRequestHeader(key, value);
+    });
+  }
+
   xhr.onload = () => {
     if (xhr.status >= 200 && xhr.status < 400) {
       successCallback(xhr.responseText, xhr)