Create Record

//native

export type DynSelect_sobject = string

// Dropdown of the org's objects (global describe), so users pick instead of typing an API name.

export async function sobject(auth: RT.Salesforce) {

  const apiVersion = auth.api_version || "v60.0"

  const response = await fetch(

    `${auth.instance_url}/services/data/${apiVersion}/sobjects/`,

    {

      headers: {

        Authorization: `Bearer ${auth.token}`,

        Accept: "application/json",

      },

    }

  )

  if (!response.ok) {

    throw new Error(`${response.status} ${await response.text()}`)

  }

  const { sobjects } = (await response.json()) as {

    sobjects: { name: string; label: string }[]

  }

  return sobjects

    .map((o) => ({ value: o.name, label: `${o.label} (${o.name})` }))

    .sort((a, b) => a.label.localeCompare(b.label))

}

/**

 * Create Record

 * Create a record of any object (Lead, Contact, Account, Opportunity, Case, Task, or a custom object). Pass the object's API name and a field map.

 */

export async function main(

  auth: RT.Salesforce,

  sobject: DynSelect_sobject,

  body: { [key: string]: any }

) {

  const apiVersion = auth.api_version || "v60.0"

  const url = new URL(

    `${auth.instance_url}/services/data/${apiVersion}/sobjects/${sobject}`

  )

  const response = await fetch(url, {

    method: "POST",

    headers: {

      Authorization: `Bearer ${auth.token}`,

      "Content-Type": "application/json",

      Accept: "application/json",

    },

    body: JSON.stringify(body),

  })

  if (!response.ok) {

    throw new Error(`${response.status} ${await response.text()}`)

  }

  return await response.json()

}