/* eslint-disable @typescript-eslint/no-non-null-assertion */
/* eslint-disable @typescript-eslint/no-empty-function */
// Ported from https://github.com/simov/grant/blob/master/test/util/provider.js
import http from 'http'
import _url from 'url'
import qs from 'qs'

const buffer = (req: http.IncomingMessage, done: any) => {
  let data = ''
  req.on('data', (chunk: any) => (data += chunk))
  req.on('end', () => done(/^{.*}$/.test(data) ? JSON.parse(data) : qs.parse(data)))
}
const _query = (req: http.IncomingMessage) => {
  const parsed = _url.parse(req.url as string, false)
  const query = qs.parse(parsed.query as any)
  return query
}
const _oauth = (req: http.IncomingMessage) =>
  qs.parse((req.headers.authorization || '').replace('OAuth ', '').replace(/"/g, '').replace(/,/g, '&'))

const sign = (...args: any[]) =>
  args
    .map((arg, index) =>
      index < 2
        ? Buffer.from(JSON.stringify(arg))
            .toString('base64')
            .replace(/=/g, '')
            .replace(/\+/g, '-')
            .replace(/\//g, '_')
        : arg
    )
    .join('.')

export const provider = async ({ flow, port = 5000 }: { flow: 'oauth2' | 'oauth1'; port: number }) => {
  const server = await (flow === 'oauth2' ? oauth2(port) : oauth1(port))
  return {
    oauth1,
    oauth2,
    on,
    server,
    url: (path: string) => `http://localhost:${port}${path}`,
    close: () => new Promise((resolve) => server.close(resolve))
  }
}

const oauth1 = (port: number) =>
  new Promise<http.Server>((resolve) => {
    let callback: any
    const server = http.createServer()
    server.on('request', (req, res) => {
      const method = req.method
      const url = req.url as string
      const headers = req.headers
      const oauth = _oauth(req)
      const query = _query(req)
      const provider = /^\/(.*)\/.*/.exec(url) && /^\/(.*)\/.*/.exec(url)![1]

      if (/request_url/.test(url)) {
        callback = oauth.oauth_callback
        buffer(req, (form: any) => {
          if (provider === 'getpocket') {
            callback = form.redirect_uri
          }
          on.request({ url, headers, query, form, oauth })
          provider === 'sellsy'
            ? res.writeHead(200, { 'content-type': 'application/json' })
            : res.writeHead(200, { 'content-type': 'application/x-www-form-urlencoded' })
          provider === 'getpocket'
            ? res.end(qs.stringify({ code: 'code' }))
            : provider === 'sellsy'
              ? res.end(
                  'authentification_url=https://apifeed.sellsy.com/0/login.php&oauth_token=token&oauth_token_secret=secret&oauth_callback_confirmed=true'
                )
              : res.end(qs.stringify({ oauth_token: 'token', oauth_token_secret: 'secret' }))
        })
      } else if (/authorize_url/.test(url)) {
        const location = callback + '?' + qs.stringify({ oauth_token: 'token', oauth_verifier: 'verifier' })
        on.authorize({ url, headers, query })
        res.writeHead(302, { location })
        res.end()
      } else if (/access_url/.test(url)) {
        buffer(req, (form: any) => {
          on.access({ url, headers, query, form, oauth })
          res.writeHead(200, { 'content-type': 'application/json' })
          provider === 'getpocket'
            ? res.end(JSON.stringify({ access_token: 'token' }))
            : res.end(
                JSON.stringify({
                  oauth_token: 'token',
                  oauth_token_secret: 'secret',
                  user_id: provider === 'twitter' ? 'id' : undefined
                })
              )
        })
      } else if (/request_error_message/.test(url)) {
        callback = oauth.oauth_callback
        buffer(req, (form: any) => {
          on.request({ url, headers, query, form, oauth })
          res.writeHead(200, { 'content-type': 'application/x-www-form-urlencoded' })
          res.end(qs.stringify({ error: { message: 'invalid' } }))
        })
      } else if (/request_error_token/.test(url)) {
        callback = oauth.oauth_callback
        buffer(req, (form: any) => {
          on.request({ url, headers, query, form, oauth })
          res.writeHead(200, { 'content-type': 'application/x-www-form-urlencoded' })
          res.end()
        })
      } else if (/request_error_status/.test(url)) {
        callback = oauth.oauth_callback
        buffer(req, (form: any) => {
          on.request({ url, headers, query, form, oauth })
          res.writeHead(500, { 'content-type': 'application/x-www-form-urlencoded' })
          res.end(qs.stringify({ invalid: 'request_url' }))
        })
      } else if (/authorize_error_message/.test(url)) {
        const location = callback + '?' + qs.stringify({ error: { message: 'invalid' } })
        on.authorize({ url, headers, query })
        res.writeHead(302, { location })
        res.end()
      } else if (/authorize_error_token/.test(url)) {
        const location = callback as string
        on.authorize({ url, headers, query })
        res.writeHead(302, { location })
        res.end()
      } else if (/access_error_status/.test(url)) {
        buffer(req, (form: any) => {
          on.access({ url, headers, query, form, oauth })
          res.writeHead(500, { 'content-type': 'application/json' })
          res.end(JSON.stringify({ invalid: 'access_url' }))
        })
      } else if (/profile_url/.test(url)) {
        on.profile({ method, url, query, headers })
        res.writeHead(200, { 'content-type': 'application/json' })
        provider === 'flickr'
          ? res.end('callback({"user": "simov"})')
          : res.end(JSON.stringify({ user: 'simov' }))
      }
    })
    server.listen(port, () => resolve(server))
  })

const oauth2 = (port: number) =>
  new Promise<http.Server>((resolve) => {
    const server = http.createServer()
    let openid: any
    server.on('request', (req, res) => {
      const method = req.method
      const url = req.url as string
      const headers = req.headers
      const query = _query(req) as any
      const provider = /^\/(.*)\/.*/.exec(url) && /^\/(.*)\/.*/.exec(url)![1]

      if (/authorize_url/.test(url)) {
        openid = (query.scope || []).includes('openid')
        on.authorize({ provider, method, url, headers, query })
        if (query.response_mode === 'form_post') {
          provider === 'apple'
            ? res.end(
                qs.stringify({
                  code: 'code',
                  user: { name: { firstName: 'jon', lastName: 'doe' }, email: 'jon@doe.com' }
                })
              )
            : res.end('code')
          return
        }
        const location =
          query.redirect_uri +
          '?' +
          (provider === 'intuit'
            ? qs.stringify({ code: 'code', realmId: '123' })
            : qs.stringify({ code: 'code' }))
        res.writeHead(302, { location })
        res.end()
      } else if (/access_url/.test(url)) {
        buffer(req, (form: any) => {
          on.access({ provider, method, url, headers, query, form })
          res.writeHead(200, { 'content-type': 'application/json' })
          provider === 'concur'
            ? res.end(' <Token>token</Token> <Refresh_Token>refresh</Refresh_Token> ')
            : provider === 'withings'
              ? res.end(
                  JSON.stringify({
                    body: {
                      access_token: 'token',
                      refresh_token: 'refresh',
                      expires_in: 3600
                    }
                  })
                )
              : res.end(
                  JSON.stringify({
                    access_token: 'token',
                    refresh_token: 'refresh',
                    expires_in: 3600,
                    id_token: openid ? sign({ typ: 'JWT' }, { nonce: 'whatever' }, 'signature') : undefined,
                    open_id: provider === 'tiktok' ? 'id' : undefined,
                    uid: provider === 'weibo' ? 'id' : undefined,
                    openid: provider === 'wechat' ? 'openid' : undefined
                  })
                )
        })
      } else if (/authorize_error_message/.test(url)) {
        on.authorize({ url, query, headers })
        const location = query.redirect_uri + '?' + qs.stringify({ error: { message: 'invalid' } })
        res.writeHead(302, { location })
        res.end()
      } else if (/authorize_error_code/.test(url)) {
        on.authorize({ url, query, headers })
        const location = query.redirect_uri as string
        res.writeHead(302, { location })
        res.end()
      } else if (/authorize_error_state_mismatch/.test(url)) {
        on.authorize({ url, query, headers })
        const location = query.redirect_uri + '?' + qs.stringify({ code: 'code', state: 'whatever' })
        res.writeHead(302, { location })
        res.end()
      } else if (/authorize_error_state_missing/.test(url)) {
        on.authorize({ url, query, headers })
        const location = query.redirect_uri + '?' + qs.stringify({ code: 'code' })
        res.writeHead(302, { location })
        res.end()
      } else if (/access_error_nonce_mismatch/.test(url)) {
        buffer(req, (form: any) => {
          on.access({ method, url, query, headers, form })
          res.writeHead(200, { 'content-type': 'application/json' })
          res.end(
            JSON.stringify({
              id_token: sign({ typ: 'JWT' }, { nonce: 'whatever' }, 'signature')
            })
          )
        })
      } else if (/access_error_nonce_missing/.test(url)) {
        buffer(req, (form: any) => {
          on.access({ method, url, query, headers, form })
          res.writeHead(200, { 'content-type': 'application/json' })
          res.end(
            JSON.stringify({
              id_token: sign({ typ: 'JWT' }, {}, 'signature')
            })
          )
        })
      } else if (/access_error_message/.test(url)) {
        buffer(req, (form: any) => {
          on.access({ method, url, query, headers, form })
          res.writeHead(200, { 'content-type': 'application/json' })
          res.end(JSON.stringify({ error: { message: 'invalid' } }))
        })
      } else if (/access_error_status/.test(url)) {
        buffer(req, (form: any) => {
          on.access({ method, url, query, headers, form })
          res.writeHead(500, { 'content-type': 'application/json' })
          res.end(JSON.stringify({ invalid: 'access_url' }))
        })
      } else if (/profile_url/.test(url)) {
        if (method === 'POST') {
          buffer(req, (form: any) => {
            on.profile({ method, url, query, headers, form })
            res.writeHead(200, { 'content-type': 'application/json' })
            res.end(JSON.stringify({ id: 'test', user: 'simov' }))
          })
        } else {
          on.profile({ method, url, query, headers })
          res.writeHead(200, { 'content-type': 'application/json' })
          res.end(JSON.stringify({ id: 'test', user: 'simov' }))
        }
      } else if (/profile_error/.test(url)) {
        on.profile({ method, url, query, headers })
        res.writeHead(400, { 'content-type': 'application/json' })
        res.end(JSON.stringify({ error: { message: 'Not Found' } }))
      }
    })
    server.listen(port, () => resolve(server))
  })

const on = {
  request: (_opts: any) => {},
  authorize: (_opts: any) => {},
  access: (_opts: any) => {},
  profile: (_opts: any) => {}
}