Custom providers

import type {
  CreateAuthorizationInput,
  ExchangeCodeInput,
  OAuthProvider,
  ProviderTokenResponse,
} from '@hookfish/provider'
import { ProviderRequestError } from '@hookfish/provider'

export class ExampleProvider implements OAuthProvider {
  readonly label = 'Example'
  readonly defaultScopes = ['profile.read']
  readonly availableScopes = ['profile.read', 'projects.read']

  constructor(
    private readonly clientId: string,
    private readonly clientSecret: string,
  ) {}

  createAuthorization(input: CreateAuthorizationInput) {
    const url = new URL('https://accounts.example.com/oauth/authorize')
    url.searchParams.set('response_type', 'code')
    url.searchParams.set('client_id', this.clientId)
    url.searchParams.set('redirect_uri', input.redirectUri)
    url.searchParams.set('state', input.state)
    url.searchParams.set('scope', input.scopes.join(' '))
    return { url: url.toString() }
  }

  async exchangeCode(
    input: ExchangeCodeInput,
  ): Promise<ProviderTokenResponse> {
    const response = await fetch('https://accounts.example.com/oauth/token', {
      method: 'POST',
      headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
      body: new URLSearchParams({
        grant_type: 'authorization_code',
        code: input.code,
        redirect_uri: input.redirectUri,
        client_id: this.clientId,
        client_secret: this.clientSecret,
      }),
    })
    const payload: unknown = await response.json()
    if (
      !response.ok ||
      typeof payload !== 'object' ||
      payload === null ||
      Array.isArray(payload) ||
      typeof Reflect.get(payload, 'access_token') !== 'string'
    ) {
      throw new ProviderRequestError('Example token exchange failed.')
    }

    return { payload: Object.fromEntries(Object.entries(payload)) }
  }
}