Files
logseq/src/main/frontend/handler/common/plugin.cljs

82 lines
3.3 KiB
Clojure

(ns frontend.handler.common.plugin
"Common plugin related fns for handlers and api"
(:require [frontend.state :as state]
[frontend.util :as util]
[promesa.core :as p]
[cljs-bean.core :as bean]
[electron.ipc :as ipc]))
(defn get-web-plugin-checker-url!
([repo] (get-web-plugin-checker-url! repo ""))
([repo version]
(util/node-path.join "https://plugins.logseq.io/r2"
repo (if (not (string? version)) "" version))))
(defn fetch-web-plugin-entry-info
[repo version]
(p/let [url (get-web-plugin-checker-url! repo version)
^js res (js/window.fetch url)]
(if (and (.-ok res)
(= (.-status res) 200))
(-> (.json res)
(p/then #(bean/->clj %)))
(-> (.text res)
(p/then
(fn [error-text]
(throw (js/Error. (str "web-plugin-entry-error:" error-text)))))))))
(defn installed?
"For the given plugin id, returns boolean indicating if it is installed"
[id]
(contains? (:plugin/installed-plugins @state/state) (keyword id)))
(defn emit-lsp-updates!
[payload]
(js/console.log "debug:lsp-updates:" payload)
(js/window.apis.emit (name :lsp-updates) (bean/->js payload)))
(defn async-install-or-update-for-web!
[{:keys [version repo only-check] :as manifest}]
(js/console.log "[plugin]" (if only-check "Checking" "Installing") " #" repo)
(-> (fetch-web-plugin-entry-info repo (if only-check "" version))
(p/then (fn [web-pkg]
(let [web-pkg (merge web-pkg (dissoc manifest :stat))
latest-version (:version web-pkg)
valid-latest-version (when only-check
(let [coerced-current-version (util/sem-ver.coerce version)
coerced-latest-version (util/sem-ver.coerce latest-version)]
(if (and coerced-current-version
coerced-latest-version
(util/sem-ver.lt coerced-current-version coerced-latest-version))
latest-version
(throw (js/Error. :no-new-version)))))]
(emit-lsp-updates!
{:status :completed
:only-check only-check
:payload (if only-check
(assoc manifest :latest-version valid-latest-version :latest-notes "TODO: update notes")
(assoc manifest :dst repo :installed-version version :web-pkg web-pkg))}))))
(p/catch (fn [^js e]
(emit-lsp-updates!
{:status :error
:only-check only-check
:payload (assoc manifest :error-code (.-message e))})))))
(defn install-marketplace-plugin!
"Installs plugin given plugin map with id"
[{:keys [id] :as manifest}]
(when-not (and (:plugin/installing @state/state)
(installed? id))
(p/create
(fn [resolve]
(state/set-state! :plugin/installing manifest)
(if (util/electron?)
(ipc/ipc :installMarketPlugin manifest)
(async-install-or-update-for-web! manifest))
(resolve id)))))
(defn unregister-plugin
"Unregister and uninstall plugin given plugin id"
[id]
(js/LSPluginCore.unregister id))