Segment OCI Streaming Function

index.js

async function track(e, settings) {
  return await send(e, settings)
}

async function identify(e, settings) {
  return await send(e, settings)
}

async function group(e, settings) {
  return await send(e, settings)
}

async function alias(e, settings) {
  return await send(e, settings)
}

async function screen(e, settings) {
  return await send(e, settings)
}

async function page(e, settings) {
  return await send(e, settings)
}

async function send(e, { eventMapping, authToken, region }) {
  const mappedStreamId = eventMapping[(e.type === 'track' ? e.event : e.type)]
  if (!mappedStreamId) return
  
  // is this the correct host ??
  const endpoint = `https://streaming-api.${region}.oraclecloud.com/20180418/streams/${mappedStreamId}/messages`
  
  // do we have to sign this request or does this endpoint support authToken
  // if so, how do we encode that in the request?
  return await fetch(endpoint, {
    method: 'POST',
    headers: new Headers({
      'Content-Type': 'application/json',
      'Authorization': btoa(`:${authToken}`) // how is this formatted???
    }),
    body: JSON.stringify({
      messages: [{ key: e.messageId, value: new Buffer(JSON.stringify(e)) }]
    })
  })
}