Added Luminus re-frame profile

src/clj/datamapper/config.clj

@@ -0,0 +1,13 @@
+(ns datamapper.config
+  (:require
+    [cprop.core :refer [load-config]]
+    [cprop.source :as source]
+    [mount.core :refer [args defstate]]))
+
+(defstate env
+  :start
+  (load-config
+    :merge
+    [(args)
+     (source/from-system-props)
+     (source/from-env)]))

src/clj/datamapper/core.clj

@@ -0,0 +1,58 @@
+(ns datamapper.core
+  (:require
+    [datamapper.handler :as handler]
+    [datamapper.nrepl :as nrepl]
+    [luminus.http-server :as http]
+    [datamapper.config :refer [env]]
+    [clojure.tools.cli :refer [parse-opts]]
+    [clojure.tools.logging :as log]
+    [mount.core :as mount])
+  (:gen-class))
+
+;; log uncaught exceptions in threads
+(Thread/setDefaultUncaughtExceptionHandler
+  (reify Thread$UncaughtExceptionHandler
+    (uncaughtException [_ thread ex]
+      (log/error {:what :uncaught-exception
+                  :exception ex
+                  :where (str "Uncaught exception on" (.getName thread))}))))
+
+(def cli-options
+  [["-p" "--port PORT" "Port number"
+    :parse-fn #(Integer/parseInt %)]])
+
+(mount/defstate ^{:on-reload :noop} http-server
+  :start
+  (http/start
+    (-> env
+        (assoc  :handler (handler/app))
+        (update :io-threads #(or % (* 2 (.availableProcessors (Runtime/getRuntime)))))
+        (update :port #(or (-> env :options :port) %))))
+  :stop
+  (http/stop http-server))
+
+(mount/defstate ^{:on-reload :noop} repl-server
+  :start
+  (when (env :nrepl-port)
+    (nrepl/start {:bind (env :nrepl-bind)
+                  :port (env :nrepl-port)}))
+  :stop
+  (when repl-server
+    (nrepl/stop repl-server)))
+
+
+(defn stop-app []
+  (doseq [component (:stopped (mount/stop))]
+    (log/info component "stopped"))
+  (shutdown-agents))
+
+(defn start-app [args]
+  (doseq [component (-> args
+                        (parse-opts cli-options)
+                        mount/start-with-args
+                        :started)]
+    (log/info component "started"))
+  (.addShutdownHook (Runtime/getRuntime) (Thread. stop-app)))
+
+(defn -main [& args]
+  (start-app args))

src/clj/datamapper/handler.clj

@@ -0,0 +1,35 @@
+(ns datamapper.handler
+  (:require
+    [datamapper.middleware :as middleware]
+    [datamapper.layout :refer [error-page]]
+    [datamapper.routes.home :refer [home-routes]]
+    [reitit.ring :as ring]
+    [ring.middleware.content-type :refer [wrap-content-type]]
+    [ring.middleware.webjars :refer [wrap-webjars]]
+    [datamapper.env :refer [defaults]]
+    [mount.core :as mount]))
+
+(mount/defstate init-app
+  :start ((or (:init defaults) (fn [])))
+  :stop  ((or (:stop defaults) (fn []))))
+
+(mount/defstate app-routes
+  :start
+  (ring/ring-handler
+    (ring/router
+      [(home-routes)])
+    (ring/routes
+      (ring/create-resource-handler
+        {:path "/"})
+      (wrap-content-type
+        (wrap-webjars (constantly nil)))
+      (ring/create-default-handler
+        {:not-found
+         (constantly (error-page {:status 404, :title "404 - Page not found"}))
+         :method-not-allowed
+         (constantly (error-page {:status 405, :title "405 - Not allowed"}))
+         :not-acceptable
+         (constantly (error-page {:status 406, :title "406 - Not acceptable"}))}))))
+
+(defn app []
+  (middleware/wrap-base #'app-routes))

src/clj/datamapper/layout.clj

@@ -0,0 +1,39 @@
+(ns datamapper.layout
+  (:require
+    [clojure.java.io]
+    [selmer.parser :as parser]
+    [selmer.filters :as filters]
+    [markdown.core :refer [md-to-html-string]]
+    [ring.util.http-response :refer [content-type ok]]
+    [ring.util.anti-forgery :refer [anti-forgery-field]]
+    [ring.middleware.anti-forgery :refer [*anti-forgery-token*]]
+    [ring.util.response]))
+
+(parser/set-resource-path!  (clojure.java.io/resource "html"))
+(parser/add-tag! :csrf-field (fn [_ _] (anti-forgery-field)))
+(filters/add-filter! :markdown (fn [content] [:safe (md-to-html-string content)]))
+
+(defn render
+  "renders the HTML template located relative to resources/html"
+  [request template & [params]]
+  (content-type
+    (ok
+      (parser/render-file
+        template
+        (assoc params
+          :page template
+          :csrf-token *anti-forgery-token*)))
+    "text/html; charset=utf-8"))
+
+(defn error-page
+  "error-details should be a map containing the following keys:
+   :status - error status
+   :title - error title (optional)
+   :message - detailed error message (optional)
+
+   returns a response map with the error page as the body
+   and the status specified by the status key"
+  [error-details]
+  {:status  (:status error-details)
+   :headers {"Content-Type" "text/html; charset=utf-8"}
+   :body    (parser/render-file "error.html" error-details)})

src/clj/datamapper/middleware.clj

@@ -0,0 +1,49 @@
+(ns datamapper.middleware
+  (:require
+    [datamapper.env :refer [defaults]]
+    [cheshire.generate :as cheshire]
+    [cognitect.transit :as transit]
+    [clojure.tools.logging :as log]
+    [datamapper.layout :refer [error-page]]
+    [ring.middleware.anti-forgery :refer [wrap-anti-forgery]]
+    [datamapper.middleware.formats :as formats]
+    [muuntaja.middleware :refer [wrap-format wrap-params]]
+    [datamapper.config :refer [env]]
+    [ring-ttl-session.core :refer [ttl-memory-store]]
+    [ring.middleware.defaults :refer [site-defaults wrap-defaults]])
+  
+           )
+
+(defn wrap-internal-error [handler]
+  (fn [req]
+    (try
+      (handler req)
+      (catch Throwable t
+        (log/error t (.getMessage t))
+        (error-page {:status 500
+                     :title "Something very bad has happened!"
+                     :message "We've dispatched a team of highly trained gnomes to take care of the problem."})))))
+
+(defn wrap-csrf [handler]
+  (wrap-anti-forgery
+    handler
+    {:error-response
+     (error-page
+       {:status 403
+        :title "Invalid anti-forgery token"})}))
+
+
+(defn wrap-formats [handler]
+  (let [wrapped (-> handler wrap-params (wrap-format formats/instance))]
+    (fn [request]
+      ;; disable wrap-formats for websockets
+      ;; since they're not compatible with this middleware
+      ((if (:websocket? request) handler wrapped) request))))
+
+(defn wrap-base [handler]
+  (-> ((:middleware defaults) handler)
+      (wrap-defaults
+        (-> site-defaults
+            (assoc-in [:security :anti-forgery] false)
+            (assoc-in  [:session :store] (ttl-memory-store (* 60 30)))))
+      wrap-internal-error))

src/clj/datamapper/middleware/formats.clj

@@ -0,0 +1,15 @@
+(ns datamapper.middleware.formats
+  (:require
+    [cognitect.transit :as transit]
+    [luminus-transit.time :as time]
+    [muuntaja.core :as m]))
+
+(def instance
+  (m/create
+    (-> m/default-options
+        (update-in
+          [:formats "application/transit+json" :decoder-opts]
+          (partial merge time/time-deserialization-handlers))
+        (update-in
+          [:formats "application/transit+json" :encoder-opts]
+          (partial merge time/time-serialization-handlers)))))

src/clj/datamapper/nrepl.clj

@@ -0,0 +1,27 @@
+(ns datamapper.nrepl
+  (:require
+    [nrepl.server :as nrepl]
+    [clojure.tools.logging :as log]))
+
+(defn start
+  "Start a network repl for debugging on specified port followed by
+  an optional parameters map. The :bind, :transport-fn, :handler,
+  :ack-port and :greeting-fn will be forwarded to
+  clojure.tools.nrepl.server/start-server as they are."
+  [{:keys [port bind transport-fn handler ack-port greeting-fn]}]
+  (try
+    (log/info "starting nREPL server on port" port)
+    (nrepl/start-server :port port
+                        :bind bind
+                        :transport-fn transport-fn
+                        :handler handler
+                        :ack-port ack-port
+                        :greeting-fn greeting-fn)
+
+    (catch Throwable t
+      (log/error t "failed to start nREPL")
+      (throw t))))
+
+(defn stop [server]
+  (nrepl/stop-server server)
+  (log/info "nREPL server stopped"))

src/clj/datamapper/routes/home.clj

@@ -0,0 +1,20 @@
+(ns datamapper.routes.home
+  (:require
+   [datamapper.layout :as layout]
+   [clojure.java.io :as io]
+   [datamapper.middleware :as middleware]
+   [ring.util.response]
+   [ring.util.http-response :as response]))
+
+(defn home-page [request]
+  (layout/render request "home.html"))
+
+(defn home-routes []
+  [""
+   {:middleware [middleware/wrap-csrf
+                 middleware/wrap-formats]}
+   ["/" {:get home-page}]
+   ["/docs" {:get (fn [_]
+                    (-> (response/ok (-> "docs/docs.md" io/resource slurp))
+                        (response/header "Content-Type" "text/plain; charset=utf-8")))}]])
+

src/cljc/datamapper/validation.cljc

@@ -0,0 +1,2 @@
+(ns datamapper.validation
+  (:require [struct.core :as st]))

src/cljs/datamapper/ajax.cljs

@@ -0,0 +1,30 @@
+(ns datamapper.ajax
+  (:require
+    [ajax.core :as ajax]
+    [luminus-transit.time :as time]
+    [cognitect.transit :as transit]
+    [re-frame.core :as rf]))
+
+(defn local-uri? [{:keys [uri]}]
+  (not (re-find #"^\w+?://" uri)))
+
+(defn default-headers [request]
+  (if (local-uri? request)
+    (-> request
+        (update :headers #(merge {"x-csrf-token" js/csrfToken} %)))
+    request))
+
+;; injects transit serialization config into request options
+(defn as-transit [opts]
+  (merge {:raw             false
+          :format          :transit
+          :response-format :transit
+          :reader          (transit/reader :json time/time-deserialization-handlers)
+          :writer          (transit/writer :json time/time-serialization-handlers)}
+         opts))
+
+(defn load-interceptors! []
+  (swap! ajax/default-interceptors
+         conj
+         (ajax/to-interceptor {:name "default headers"
+                               :request default-headers})))

src/cljs/datamapper/core.cljs

@@ -0,0 +1,83 @@
+(ns datamapper.core
+  (:require
+    [day8.re-frame.http-fx]
+    [reagent.core :as r]
+    [re-frame.core :as rf]
+    [goog.events :as events]
+    [goog.history.EventType :as HistoryEventType]
+    [markdown.core :refer [md->html]]
+    [datamapper.ajax :as ajax]
+    [datamapper.events]
+    [reitit.core :as reitit]
+    [reitit.frontend.easy :as rfe]
+    [clojure.string :as string])
+  (:import goog.History))
+
+(defn nav-link [uri title page]
+  [:a.navbar-item
+   {:href   uri
+    :class (when (= page @(rf/subscribe [:page])) :is-active)}
+   title])
+
+(defn navbar []
+  (r/with-let [expanded? (r/atom false)]
+    [:nav.navbar.is-info>div.container
+     [:div.navbar-brand
+      [:a.navbar-item {:href "/" :style {:font-weight :bold}} "datamapper"]
+      [:span.navbar-burger.burger
+       {:data-target :nav-menu
+        :on-click #(swap! expanded? not)
+        :class (when @expanded? :is-active)}
+       [:span][:span][:span]]]
+     [:div#nav-menu.navbar-menu
+      {:class (when @expanded? :is-active)}
+      [:div.navbar-start
+       [nav-link "#/" "Home" :home]
+       [nav-link "#/about" "About" :about]]]]))
+
+(defn about-page []
+  [:section.section>div.container>div.content
+   [:img {:src "/img/warning_clojure.png"}]])
+
+(defn home-page []
+  [:section.section>div.container>div.content
+   (when-let [docs @(rf/subscribe [:docs])]
+     [:div {:dangerouslySetInnerHTML {:__html (md->html docs)}}])])
+
+(def pages
+  {:home #'home-page
+   :about #'about-page})
+
+(defn page []
+  (if-let [page @(rf/subscribe [:page])]
+    [:div
+     [navbar]
+     [page]]))
+
+(defn navigate! [match _]
+  (rf/dispatch [:navigate match]))
+
+(def router
+  (reitit/router
+    [["/" {:name        :home
+           :view        #'home-page
+           :controllers [{:start (fn [_] (rf/dispatch [:page/init-home]))}]}]
+     ["/about" {:name :about
+                :view #'about-page}]]))
+
+(defn start-router! []
+  (rfe/start!
+    router
+    navigate!
+    {}))
+
+;; -------------------------
+;; Initialize app
+(defn mount-components []
+  (rf/clear-subscription-cache!)
+  (r/render [#'page] (.getElementById js/document "app")))
+
+(defn init! []
+  (start-router!)
+  (ajax/load-interceptors!)
+  (mount-components))

src/cljs/datamapper/events.cljs

@@ -0,0 +1,78 @@
+(ns datamapper.events
+  (:require
+    [re-frame.core :as rf]
+    [ajax.core :as ajax]
+    [reitit.frontend.easy :as rfe]
+    [reitit.frontend.controllers :as rfc]))
+
+;;dispatchers
+
+(rf/reg-event-db
+  :navigate
+  (fn [db [_ match]]
+    (let [old-match (:common/route db)
+          new-match (assoc match :controllers
+                                 (rfc/apply-controllers (:controllers old-match) match))]
+      (assoc db :route new-match))))
+
+(rf/reg-fx
+  :navigate-fx!
+  (fn [[k & [params query]]]
+    (rfe/push-state k params query)))
+
+(rf/reg-event-fx
+  :navigate!
+  (fn [_ [_ url-key params query]]
+    {:navigate-fx! [url-key params query]}))
+
+(rf/reg-event-db
+  :set-docs
+  (fn [db [_ docs]]
+    (assoc db :docs docs)))
+
+(rf/reg-event-fx
+  :fetch-docs
+  (fn [_ _]
+    {:http-xhrio {:method          :get
+                  :uri             "/docs"
+                  :response-format (ajax/raw-response-format)
+                  :on-success       [:set-docs]}}))
+
+(rf/reg-event-db
+  :common/set-error
+  (fn [db [_ error]]
+    (assoc db :common/error error)))
+
+(rf/reg-event-fx
+  :page/init-home
+  (fn [_ _]
+    {:dispatch [:fetch-docs]}))
+
+;;subscriptions
+
+(rf/reg-sub
+  :route
+  (fn [db _]
+    (-> db :route)))
+
+(rf/reg-sub
+  :page-id
+  :<- [:route]
+  (fn [route _]
+    (-> route :data :name)))
+
+(rf/reg-sub
+  :page
+  :<- [:route]
+  (fn [route _]
+    (-> route :data :view)))
+
+(rf/reg-sub
+  :docs
+  (fn [db _]
+    (:docs db)))
+
+(rf/reg-sub
+  :common/error
+  (fn [db _]
+    (:common/error db)))