feat(cli): add buy command

README.md

@@ -342,9 +342,10 @@ try {
 
 ## CLI
 
-Every product is a `microlink` subcommand — `npx microlink.io` works without a global install. Run `microlink login` to save an API key from your account.
+Every product is a `microlink` subcommand — `npx microlink.io` works without a global install. Run `microlink buy` to purchase an API key, then `microlink login` to save it.
 
 ```bash
+npx microlink.io buy
 npx microlink.io login
 npx microlink.io markdown https://example.com
 npx microlink.io screenshot https://example.com --fullPage

packages/core/bin/argv.js

@@ -7,5 +7,5 @@ module.exports = argvInput =>
   mri(argvInput, {
     alias: { H: 'header' },
     boolean: ['trace', 'trace-full', 'help', 'html', 'markdown'],
-    string: ['header', 'api-key', 'data', 'file', 'endpoint']
+    string: ['header', 'api-key', 'data', 'file', 'endpoint', 'email', 'plan']
   })

packages/core/bin/buy.js

@@ -0,0 +1,103 @@
+'use strict'
+
+const { randomUUID } = require('crypto')
+const { writeConfig, configPathDisplay } = require('./config')
+const { authorize, fetchJson } = require('./dashboard')
+const select = require('./select')
+const openUrl = require('./open')
+const { gray } = require('./style')
+
+const TIMEOUT_MS = 15 * 60 * 1000
+const POLL_MS = 2000
+
+const request = async (path, options) => {
+  const { res, body } = await fetchJson(path, options)
+  if (!res.ok) {
+    throw new Error(body.error || `Dashboard request failed (${res.status})`)
+  }
+  return body
+}
+
+const money = (amount, currency) =>
+  new Intl.NumberFormat(undefined, {
+    style: 'currency',
+    currency,
+    maximumFractionDigits: amount % 100 === 0 ? 0 : 2
+  }).format(amount / 100)
+
+const asChoice = plan => ({
+  name: `${plan.limit.toLocaleString()} req`,
+  hint: `${money(plan.price, plan.currency)}/mo`,
+  value: plan.id
+})
+
+const sleep = ms => new Promise(resolve => setTimeout(resolve, ms))
+
+const pickPlan = async (plans, planId) => {
+  if (planId) {
+    if (!plans.some(plan => plan.id === planId)) {
+      throw new Error(`Unknown plan \`${planId}\``)
+    }
+    return planId
+  }
+  const { value } = await select({
+    message: 'Which plan?',
+    choices: plans.map(asChoice)
+  })
+  return value
+}
+
+const waitForPayment = async sessionId => {
+  const started = Date.now()
+  const path = `/api/v1/checkout/sessions/${encodeURIComponent(sessionId)}`
+  for (;;) {
+    const body = await request(path)
+    if (body.state === 'ready') return body
+    if (body.state === 'expired') throw new Error('Checkout expired')
+    if (Date.now() - started > TIMEOUT_MS) {
+      throw new Error('Timed out waiting for payment')
+    }
+    await sleep(POLL_MS)
+  }
+}
+
+const buy = async ({ plan: planId } = {}) => {
+  const { plans } = await request('/api/v1/plans')
+  if (!plans?.length) throw new Error('No plans available')
+
+  planId = await pickPlan(plans, planId)
+  const { token, sessionId, checkoutUrl } = await authorize({ plan: planId })
+
+  let session
+  if (sessionId != null && checkoutUrl != null) {
+    session = { sessionId, checkoutUrl }
+  } else {
+    session = await request('/api/v1/checkout/sessions', {
+      method: 'POST',
+      headers: {
+        'content-type': 'application/json',
+        'idempotency-key': randomUUID(),
+        authorization: `Bearer ${token}`
+      },
+      body: JSON.stringify({ planId, label: 'default' })
+    })
+    process.stderr.write(`Opening ${session.checkoutUrl}\n\n`)
+    if (process.stderr.isTTY) openUrl(session.checkoutUrl)
+  }
+
+  process.stderr.write('Waiting for payment…\n')
+  const { apiKey } = await waitForPayment(session.sessionId)
+  if (typeof apiKey !== 'string' || apiKey === '') {
+    process.stderr.write(
+      `\n${gray('Paid.')} Run \`microlink login\` to save your API key.\n`
+    )
+    return
+  }
+  writeConfig({ apiKey })
+  process.stdout.write(`${apiKey}\n`)
+  process.stderr.write(
+    `\n${gray('Saved')} ${gray(`to ${configPathDisplay()}`)}\n`
+  )
+}
+
+module.exports = buy

packages/core/bin/dashboard.js

@@ -0,0 +1,109 @@
+'use strict'
+
+const debug = require('debug-logfmt')('microlink')
+const { randomBytes } = require('crypto')
+const http = require('http')
+const openUrl = require('./open')
+
+const TIMEOUT_MS = 5 * 60 * 1000
+const CLOSE_MS = 2000
+
+const dashboardUrl = () =>
+  process.env.MICROLINK_DASHBOARD_URL || 'https://dashboard.microlink.io'
+
+const debugResponse = (method, path, status, body) => {
+  const fields = { method, path, status }
+  for (const [key, value] of Object.entries(body || {})) {
+    fields[key] =
+      value != null && typeof value === 'object' ? JSON.stringify(value) : value
+  }
+  debug(fields)
+}
+
+const fetchJson = async (path, options = {}) => {
+  const method = options.method || 'GET'
+  const res = await fetch(new URL(path, dashboardUrl()), options)
+  const body = await res.json().catch(() => ({}))
+  debugResponse(method, path, res.status, body)
+  return { res, body }
+}
+
+const end = (res, status) => {
+  res.writeHead(status)
+  res.end()
+}
+
+const listen = state =>
+  new Promise((resolve, reject) => {
+    let settle
+    const handshake = new Promise((resolve, reject) => {
+      settle = { resolve, reject }
+    })
+
+    const cors = res => {
+      res.setHeader('Access-Control-Allow-Origin', '*')
+      res.setHeader('Access-Control-Allow-Methods', 'POST, OPTIONS')
+      res.setHeader('Access-Control-Allow-Headers', 'content-type')
+      res.setHeader('Access-Control-Allow-Private-Network', 'true')
+    }
+
+    const server = http.createServer((req, res) => {
+      cors(res)
+      if (req.method === 'OPTIONS') return end(res, 204)
+      if (req.method !== 'POST') return end(res, 405)
+      const chunks = []
+      req.on('data', chunk => chunks.push(chunk))
+      req.on('end', () => {
+        try {
+          const body = JSON.parse(Buffer.concat(chunks).toString())
+          if (body.state !== state || typeof body.token !== 'string') {
+            return end(res, 400)
+          }
+          end(res, 204)
+          clearTimeout(timer)
+          settle.resolve(body)
+        } catch {
+          end(res, 400)
+        }
+      })
+    })
+
+    const close = () => {
+      clearTimeout(timer)
+      server.close()
+    }
+
+    const timer = setTimeout(() => {
+      close()
+      settle.reject(new Error('Timed out waiting for dashboard authorization'))
+    }, TIMEOUT_MS)
+
+    server.listen(0, '127.0.0.1', () => {
+      resolve({ port: server.address().port, handshake, close })
+    })
+    server.on('error', reject)
+  })
+
+const authorize = async (query = {}) => {
+  if (process.env.MICROLINK_CONNECT_TOKEN) {
+    return { token: process.env.MICROLINK_CONNECT_TOKEN }
+  }
+
+  const state = randomBytes(16).toString('hex')
+  const { port, handshake, close } = await listen(state)
+  const url = new URL('/connect', dashboardUrl())
+  url.searchParams.set('port', String(port))
+  url.searchParams.set('state', state)
+  for (const [key, value] of Object.entries(query)) {
+    if (value != null && value !== '') url.searchParams.set(key, String(value))
+  }
+  process.stderr.write(`Opening ${url}\n\n`)
+  openUrl(url.toString())
+  try {
+    return await handshake
+  } finally {
+    setTimeout(close, CLOSE_MS).unref()
+  }
+}
+
+module.exports = { dashboardUrl, authorize, fetchJson }

packages/core/bin/help.js

@@ -83,6 +83,16 @@ const COMMANDS = {
       ['help screenshot', 'show screenshot help']
     ]
   },
+  buy: {
+    usage: 'buy',
+    desc: 'Buy a Microlink API key',
+    flags: [['--plan', 'Plan id from the catalog']],
+    cli: [],
+    examples: [
+      ['buy', 'sign in on the dashboard, pick a plan, pay'],
+      ['buy --plan pro', 'buy a specific plan']
+    ]
+  },
   login: {
     usage: 'login',
     desc: 'Save an API key from your Microlink account',
@@ -303,6 +313,7 @@ ${cmd('<url> [options]')}
 ${cmd('<product> <url|query> [options]')}
 ${cmd('<product> docs')}
 ${cmd('help')}
+${cmd('buy')}
 ${cmd('login')}
 ${cmd('logout')}
 
@@ -316,6 +327,7 @@ Options
 ${rows(CLI)}
 
 Examples
+${cmd('buy', 'buy an API key')}
 ${cmd('login', 'save an API key from your account')}
 ${cmd('markdown docs', 'print the markdown docs page')}
 ${cmd('https://example.com', 'unified metadata (default)')}

packages/core/bin/host.js

@@ -4,6 +4,7 @@ const { readFileSync } = require('fs')
 const path = require('path')
 const { readApiKey, clearConfig } = require('./config')
 const login = require('./login')
+const buy = require('./buy')
 
 module.exports = {
   stdout: process.stdout,
@@ -21,6 +22,7 @@ module.exports = {
   readApiKey,
   clearConfig,
   login,
+  buy,
   exit (code) {
     process.exit(code)
   },