import { writable } from "svelte/store"
import { API } from "api"

export function createPluginsStore() {
  const { subscribe, set, update } = writable([])

  async function load() {
    const plugins = await API.getPlugins()
    set(plugins)
  }

  async function deletePlugin(pluginId, pluginRev) {
    await API.deletePlugin(pluginId, pluginRev)
    update(state => {
      state = state.filter(existing => existing._id !== pluginId)
      return state
    })
  }

  async function createPlugin(type, source, url, auth = null) {
    let pluginData = {
      type,
      source,
      url,
    }

    switch (source) {
      case "url":
        pluginData.headers = auth
        break
      case "npm":
        pluginData.npmToken = auth
        break
      case "github":
        pluginData.githubToken = auth
        break
    }

    let res = await API.createPlugin(pluginData)

    let newPlugin = res.plugins[0]
    update(state => {
      const currentIdx = state.findIndex(plugin => plugin._id === newPlugin._id)
      if (currentIdx >= 0) {
        state.splice(currentIdx, 1, newPlugin)
      } else {
        state.push(newPlugin)
      }
      return state
    })
  }

  async function uploadPlugin(file, source, updatePlugin) {
    let data = new FormData()
    data.append("file", file)
    data.append("source", source)
    data.append("update", updatePlugin)
    let resp = await API.uploadPlugin(data)
    let newPlugin = resp.plugins[0]
    update(state => {
      const currentIdx = state.findIndex(plugin => plugin._id === newPlugin._id)
      if (currentIdx >= 0) {
        state.splice(currentIdx, 1, newPlugin)
      } else {
        state.push(newPlugin)
      }
      return state
    })
  }
  return {
    subscribe,
    load,
    createPlugin,
    deletePlugin,
    uploadPlugin,
  }
}

export const plugins = createPluginsStore()