ciphermask/app/scripts/lib/ens-ipfs/setup.js

const urlUtil = require('url')
const extension = require('extensionizer')
const resolveEnsToIpfsContentId = require('./resolver.js')

const supportedTopLevelDomains = ['eth']

module.exports = setupEnsIpfsResolver

function setupEnsIpfsResolver ({ provider }) {

  // install listener
  const urlPatterns = supportedTopLevelDomains.map(tld => `*://*.${tld}/*`)
  extension.webRequest.onErrorOccurred.addListener(webRequestDidFail, { urls: urlPatterns })

  // return api object
  return {
    // uninstall listener
    remove () {
      extension.webRequest.onErrorOccurred.removeListener(webRequestDidFail)
    },
  }

  async function webRequestDidFail (details) {
    const { tabId, url } = details
    // ignore requests that are not associated with tabs
    if (tabId === -1) return
    // parse ens name
    const urlData = urlUtil.parse(url)
    const { hostname: name, path, search } = urlData
    const domainParts = name.split('.')
    const topLevelDomain = domainParts[domainParts.length - 1]
    // if unsupported TLD, abort
    if (!supportedTopLevelDomains.includes(topLevelDomain)) return
    // otherwise attempt resolve
    attemptResolve({ tabId, name, path, search })
  }

  async function attemptResolve ({ tabId, name, path, search }) {
    extension.tabs.update(tabId, { url: `loading.html` })
    try {
      let url = '400.html'
      const {type, hash} = await resolveEnsToIpfsContentId({ provider, name })
      if (type === 'ipfs-ns') {
        url = `https://gateway.ipfs.io/ipfs/${hash}${path}${search || ''}`
        try {
          // check if ipfs gateway has result
          const response = await fetch(url, { method: 'HEAD' })
          // if failure, redirect to 404 page
          if (response.status !== 200) {
            extension.tabs.update(tabId, { url: '404.html' })
            return
          }
          // otherwise redirect to the correct page
          extension.tabs.update(tabId, { url })
        } catch (err) {
          console.warn(err)
          // if HEAD fetch failed, redirect so user can see relevant error page
          extension.tabs.update(tabId, { url })
        }
      } else if (type === 'swarm-ns') {
        url = `https://swarm-gateways.net/bzz:/${hash}${path}${search || ''}`
      }
      extension.tabs.update(tabId, { url })
    } catch (err) {
      console.warn(err)
      extension.tabs.update(tabId, { url: `error.html?name=${name}` })
    }
  }
}