chrome-background-rpc.cljs

(ns ygq.background.main
  (:require-macros [cljs.core.async.macros :refer [go]])
  (:require [cljs.core.async :as async :refer [<!]]
            [chrome.rpc :as rpc]
            [ygq.background.parser :as p]
            [google.api :as g]))

(defonce comm-listener
  (go
    (let [rpc (rpc/listen (async/chan 10))
          token (<! (g/request-token))]
      (loop []
        (when-let [{::rpc/keys [payload send-response]} (<! rpc)]
          (let [[k x] payload]
            (case k
              :app/graph (let [response (<! (p/parse {::g/access-token token} x))]
                           (try
                             (send-response response)
                             (catch :default _)))
              (do
                (js/console.info "Can't handle message" k)
                nil)))
          (recur))))))