refactoring mount sample app

drinking more "pure tea"
This commit is contained in:
anatoly 2016-01-14 00:24:09 -05:00
parent d834c6a2b0
commit e3066fe024
5 changed files with 25 additions and 26 deletions

View file

@ -20,7 +20,7 @@
(defstate conn :start (new-connection config) (defstate conn :start (new-connection config)
:stop (disconnect config conn)) :stop (disconnect config conn))
;; datomic schema (staging as an example) ;; datomic schema (staging for an example)
(defn create-schema [conn] (defn create-schema [conn]
(let [schema [{:db/id #db/id [:db.part/db] (let [schema [{:db/id #db/id [:db.part/db]
:db/ident :order/symbol :db/ident :order/symbol

View file

@ -2,7 +2,7 @@
(:require [clojure.tools.nrepl.server :refer [start-server stop-server]] (:require [clojure.tools.nrepl.server :refer [start-server stop-server]]
[mount.core :as mount :refer [defstate]] [mount.core :as mount :refer [defstate]]
[app.conf :refer [config]] [app.conf :refer [config]]
[app.www :refer [nyse-app]]) [app.www])
(:gen-class)) ;; for -main / uberjar (no need in dev) (:gen-class)) ;; for -main / uberjar (no need in dev)
;; example on creating a network REPL ;; example on creating a network REPL

View file

@ -1,20 +1,16 @@
(ns app.nyse (ns app.nyse
(:require [datomic.api :as d] (:require [datomic.api :as d]
[app.db :refer [create-schema] :as db]
[app.utils.datomic :refer [touch]])) [app.utils.datomic :refer [touch]]))
(defn add-order [ticker bid offer qty] ;; can take connection as param (defn add-order [conn {:keys [ticker bid offer qty]}]
@(d/transact db/conn [{:db/id (d/tempid :db.part/user) @(d/transact conn [{:db/id (d/tempid :db.part/user)
:order/symbol ticker :order/symbol ticker
:order/bid bid :order/bid bid
:order/offer offer :order/offer offer
:order/qty qty}])) :order/qty qty}]))
(defn find-orders [ticker] ;; can take connection as param (defn find-orders [conn ticker]
(let [orders (d/q '[:find ?e :in $ ?ticker (let [orders (d/q '[:find ?e :in $ ?ticker
:where [?e :order/symbol ?ticker]] :where [?e :order/symbol ?ticker]]
(d/db db/conn) ticker)] (d/db conn) ticker)]
(touch db/conn orders))) (touch conn orders)))
(defn create-nyse-schema []
(create-schema db/conn))

View file

@ -1,5 +1,6 @@
(ns app.www (ns app.www
(:require [app.nyse :refer [add-order find-orders create-nyse-schema]] (:require [app.nyse :refer [add-order find-orders]]
[app.db :refer [conn create-schema]]
[app.conf :refer [config]] [app.conf :refer [config]]
[mount.core :refer [defstate]] [mount.core :refer [defstate]]
[cheshire.core :refer [generate-string]] [cheshire.core :refer [generate-string]]
@ -11,21 +12,22 @@
(GET "/" [] "welcome to mount sample app!") (GET "/" [] "welcome to mount sample app!")
(GET "/nyse/orders/:ticker" [ticker] (GET "/nyse/orders/:ticker" [ticker]
(generate-string (find-orders ticker))) (generate-string (find-orders conn ticker)))
(POST "/nyse/orders" [ticker qty bid offer] (POST "/nyse/orders" [ticker qty bid offer]
(add-order ticker (bigdec bid) (bigdec offer) (Integer/parseInt qty)) (let [order {:ticker ticker
(generate-string {:added {:ticker ticker :bid (bigdec bid)
:qty qty :offer (bigdec offer)
:bid bid :qty (Integer/parseInt qty)}]
:offer offer}}))) (add-order conn order)
(generate-string {:added order}))))
(defn start-nyse [{:keys [www]}] (defn start-nyse [conn {:keys [www]}] ;; app entry point
(create-nyse-schema) ;; creating schema (usually done long before the app is started..) (create-schema conn) ;; just an example, usually schema would already be there
(-> (routes mount-example-routes) (-> (routes mount-example-routes)
(handler/site) (handler/site)
(run-jetty {:join? false (run-jetty {:join? false
:port (:port www)}))) :port (:port www)})))
(defstate nyse-app :start (start-nyse config) (defstate nyse-app :start (start-nyse conn config)
:stop (.stop nyse-app)) ;; it's a "org.eclipse.jetty.server.Server" at this point :stop (.stop nyse-app)) ;; it's a "org.eclipse.jetty.server.Server" at this point

View file

@ -6,8 +6,9 @@
[mount.tools.graph :refer [states-with-deps]] [mount.tools.graph :refer [states-with-deps]]
[app.utils.logging :refer [with-logging-status]] [app.utils.logging :refer [with-logging-status]]
[app.www] [app.www]
[app.db :refer [conn]]
[app.example] [app.example]
[app.nyse :refer [create-nyse-schema find-orders add-order]])) ;; <<<< replace this your "app" namespace(s) you want to be available at REPL time [app.nyse :refer [find-orders add-order]])) ;; <<<< replace this your "app" namespace(s) you want to be available at REPL time
(defn start [] (defn start []
(with-logging-status) (with-logging-status)