Search records

//native

function wapiUrl(auth: RT.InfobloxNios, path: string) {

  const host = auth.host

    .trim()

    .replace(/^https?:\/\//, "")

    .replace(/\/+$/, "")

  const version = auth.wapi_version.trim().replace(/^v/, "")

  return new URL(`https://${host}/wapi/v${version}/${path}`)

}

function basicAuth(auth: RT.InfobloxNios) {

  const bytes = new TextEncoder().encode(`${auth.username}:${auth.password}`)

  return `Basic ${btoa(String.fromCharCode(...bytes))}`

}

/**

 * Search records

 * Search host, A or CNAME records by name (exact or regular expression), zone or IPv4 address, one page at a time. Pass the returned next_page_id as page_id to get the next page; it is null on the last page.

 */

export async function main(

  auth: RT.InfobloxNios,

  record_type: "record:host" | "record:a" | "record:cname",

  name: string | undefined,

  name_match: "exact" | "regex" | undefined,

  zone: string | undefined,

  ipv4addr: string | undefined,

  view: string | undefined,

  max_results: number | undefined,

  page_id: string | undefined,

  return_fields: string[] | undefined

) {

  if (ipv4addr && record_type === "record:cname") {

    throw new Error(

      "CNAME records have no IPv4 address; search them by name or zone"

    )

  }

  const url = wapiUrl(auth, record_type)

  if (name)

    url.searchParams.append(name_match === "regex" ? "name~" : "name", name)

  if (zone) url.searchParams.append("zone", zone)

  if (ipv4addr) url.searchParams.append("ipv4addr", ipv4addr)

  if (view) url.searchParams.append("view", view)

  const fields = [

    "comment",

    "zone",

    "ttl",

    "extattrs",

    ...(return_fields ?? []),

  ]

  url.searchParams.append("_return_fields+", fields.join(","))

  url.searchParams.append("_paging", "1")

  url.searchParams.append("_return_as_object", "1")

  url.searchParams.append("_max_results", String(max_results || 100))

  if (page_id) url.searchParams.append("_page_id", page_id)

  const response = await fetch(url, {

    headers: {

      Authorization: basicAuth(auth),

      Accept: "application/json",

    },

  })

  if (!response.ok) {

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

  }

  const data = await response.json()

  return { result: data.result, next_page_id: data.next_page_id ?? null }

}