segment events -> rockset

segment-function.js

// https://segment.com/docs/connections/functions/destination-functions/
export const track = insertEvent
export const identify = insertEvent
export const page = insertEvent
export const screen = insertEvent
export const group = insertEvent

// https://docs.rockset.com/rest-api/#patchdocuments
const insertEvent = async (msg, { collection, workspace, apiKey }) => {
  const endpoint = `https://api.rs2.usw2.rockset.com/v1/orgs/self/ws/${workspace}/collections/${collection}/docs`
  return await fetch(endpoint, {
    method: 'post',
    headers: {
      Authorization: `ApiKey ${apiKey}`, 
      'content-type': 'application/json'
    },
    body: JSON.stringify(msg)
  })
}

❤️

Body attribute should be:

JSON.stringify({ data: [msg] })