Function usePluginInstall

packages/extension/composables/plugin.ts:38–109

()

  const response = await fetch(REGISTRY_URL, { cache: 'no-cache', signal })
  ensureSuccessfulResponse(response)
  const text = await readBoundedText(response, MAX_PLUGIN_REGISTRY_BYTES)
  return validateRegistry(JSON.parse(text))
}

function validateRegistry(value: unknown): RegistryEntry[] {
  if (!Array.isArray(value)) throw new Error('Plugin registry is invalid.')

  return value.map((entry) => {
    if (
      !isRecord(entry) ||
      typeof entry.name !== 'string' ||
      !REGISTERED_PLUGIN_SOURCE_RE.test(`@${entry.name}`) ||
      typeof entry.url !== 'string'
    ) {
      throw new Error('Plugin registry is invalid.')
    }
    validatePluginUrl(entry.url, false)
    return { name: entry.name, url: entry.url }
  })
}

export type PluginData = {
  code: string
  integrity: string
  pluginName: string
  resolvedUrl: string
  source: string // can be a URL or a registered plugin name like `@{plugin-name}`
}

export function usePluginInstall() {
  const { show } = useToast()

  const validity = shallowRef('')
  const installing = shallowRef(false)
  let controller: AbortController | null = null

  function cancel() {
    controller?.abort()
    controller = null
    installing.value = false
  }

  async function install(src: string, isUpdate = false) {
    if (installing.value) {
      return null
    }

    const currentController = new AbortController()
    controller = currentController
    const { signal } = currentController
    const isCurrent = () => controller === currentController && !signal.aborted

    installing.value = true

    try {
      const url = REGISTERED_PLUGIN_SOURCE_RE.test(src)
        ? await getRegisteredPluginSource(src, signal)
        : src