cloudflare.js

import * as core from '@actions/core'

const API_VERSION = 'v4'

async function set(kvUrl, headers, value, expiration, expirationTtl) {
  let url = kvUrl

  headers['Content-Type'] = 'text/plain'

  if (expiration) {
    url = `${url}?expiration=${expiration}`
  } else if (expirationTtl) {
    url = `${url}?expiration_ttl=${expirationTtl}`
  }

  if (typeof value !== 'string') {
    if (Object.keys(value).length > 0) {
      value = JSON.stringify(value)
    } else {
      value = value.toString()
    }
  }

  const response = await fetch(url, {
    method: 'PUT',
    body: value,
    headers
  })

  if (!response.ok) {
    const body = await response.text().catch(() => '')
    throw new Error(
      `PUT failed: ${response.status} ${response.statusText}${body ? ` — ${body}` : ''}`
    )
  }

  return null
}

async function get(kvUrl, headers) {
  const response = await fetch(kvUrl, { headers })

  if (!response.ok) {
    const body = await response.text().catch(() => '')
    throw new Error(
      `GET failed: ${response.status} ${response.statusText}${body ? ` — ${body}` : ''}`
    )
  }

  const text = await response.text()
  try {
    return JSON.parse(text)
  } catch {
    return text
  }
}

export default async function kv(
  accountId,
  accountEmail,
  apiKey,
  namespaceId,
  key,
  value,
  expiration,
  expirationTtl
) {
  const kvUrl = `https://api.cloudflare.com/client/${API_VERSION}/accounts/${accountId}/storage/kv/namespaces/${namespaceId}/values/${key}`

  const headers = accountEmail
    ? {
        'X-Auth-Key': apiKey,
        'X-Auth-Email': accountEmail
      }
    : {
        Authorization: `Bearer ${apiKey}`
      }

  if (value && (value.length > 0 || Object.keys(value).length > 0)) {
    core.info(`Setting value for ${key}`)
    return set(kvUrl, headers, value, expiration, expirationTtl)
  } else {
    core.info(`Getting value for ${key}`)
    return get(kvUrl, headers)
  }
}