Function parseBody

src/main/http/import/opencollection.ts:240–300

(
  rawBody: unknown,
  source: string,
  warnings: HttpImportWarning[],
)

}

function parseBody(
  rawBody: unknown,
  source: string,
  warnings: HttpImportWarning[],
): Pick<HttpImportRequest, 'body' | 'bodyType' | 'formData'> {
  if (!isRecord(rawBody)) {
    return { body: null, bodyType: 'none', formData: [] }
  }

  const type = asString(rawBody.type)
  if (type === 'json') {
    return { body: asString(rawBody.data), bodyType: 'json', formData: [] }
  }

  if (type === 'text' || type === 'xml') {
    return { body: asString(rawBody.data), bodyType: 'text', formData: [] }
  }

  if (type === 'form-urlencoded') {
    const body = asArray(rawBody.data)
      .filter(isRecord)
      .filter(
        entry => entry.disabled !== true && asString(entry.name ?? entry.key),
      )
      .map(
        entry =>
          `${asString(entry.name ?? entry.key)}=${asString(entry.value)}`,
      )
      .join('&')
    return { body, bodyType: 'form-urlencoded', formData: [] }
  }

  if (type === 'multipart-form') {
    return {
      body: null,
      bodyType: 'multipart',
      formData: asArray(rawBody.data)
        .filter(isRecord)
        .filter(
          entry =>
            entry.disabled !== true && asString(entry.name ?? entry.key),
        )
        .map(entry => ({
          key: asString(entry.name ?? entry.key),
          type: asString(entry.type) === 'file' ? 'file' : 'text',
          value: asString(entry.value),
        })),
    }
  }

  if (type === 'graphql') {
    addWarning(warnings, source, 'GraphQL body imported as JSON')
    return {
      body: JSON.stringify(rawBody.data ?? {}, null, 2),
      bodyType: 'json',
      formData: [],
    }
  }