524 lines
15 KiB
Clojure
524 lines
15 KiB
Clojure
|
(ns worther
|
||
|
|
(:require [crux.api :as crux]))
|
||
|
|
|
||
|
|
(def crux (crux/start-node {}))
|
||
|
|
|
||
|
|
(def manifest {:crux.db/id :manifest
|
||
|
|
:pilot-name "Johanna"
|
||
|
|
:id/rocket "SB002-sol"
|
||
|
|
:id/employee "22910x2"
|
||
|
|
:badges ["SETUP"]
|
||
|
|
:cargo ["stereo" "gold fish" "slippers" "secret note"]})
|
||
|
|
|
||
|
|
(crux/submit-tx crux [[:crux.tx/put manifest]])
|
||
|
|
|
||
|
|
#_(crux/entity (crux/db crux) :manifest)
|
||
|
|
|
||
|
|
(crux/submit-tx crux
|
||
|
|
[[:crux.tx/put
|
||
|
|
{:crux.db/id :commodity/Pu
|
||
|
|
:common-name "Plutonium"
|
||
|
|
:type :element/metal
|
||
|
|
:density 19.816
|
||
|
|
:radioactive true}]
|
||
|
|
|
||
|
|
[:crux.tx/put
|
||
|
|
{:crux.db/id :commodity/N
|
||
|
|
:common-name "Nitrogen"
|
||
|
|
:type :element/gas
|
||
|
|
:density 1.2506
|
||
|
|
:radioactive false}]
|
||
|
|
|
||
|
|
[:crux.tx/put
|
||
|
|
{:crux.db/id :commodity/CH4
|
||
|
|
:common-name "Methane"
|
||
|
|
:type :molecule/gas
|
||
|
|
:density 0.717
|
||
|
|
:radioactive false}]])
|
||
|
|
|
||
|
|
(crux/submit-tx crux
|
||
|
|
[[:crux.tx/put
|
||
|
|
{:crux.db/id :stock/Pu
|
||
|
|
:commod :commodity/Pu
|
||
|
|
:weight-ton 21 }
|
||
|
|
#inst "2115-02-13T18"]
|
||
|
|
|
||
|
|
[:crux.tx/put
|
||
|
|
{:crux.db/id :stock/Pu
|
||
|
|
:commod :commodity/Pu
|
||
|
|
:weight-ton 23 }
|
||
|
|
#inst "2115-02-14T18"]
|
||
|
|
|
||
|
|
[:crux.tx/put
|
||
|
|
{:crux.db/id :stock/Pu
|
||
|
|
:commod :commodity/Pu
|
||
|
|
:weight-ton 22.2 }
|
||
|
|
#inst "2115-02-15T18"]
|
||
|
|
|
||
|
|
[:crux.tx/put
|
||
|
|
{:crux.db/id :stock/Pu
|
||
|
|
:commod :commodity/Pu
|
||
|
|
:weight-ton 24 }
|
||
|
|
#inst "2115-02-18T18"]
|
||
|
|
|
||
|
|
[:crux.tx/put
|
||
|
|
{:crux.db/id :stock/Pu
|
||
|
|
:commod :commodity/Pu
|
||
|
|
:weight-ton 24.9 }
|
||
|
|
#inst "2115-02-19T18"]])
|
||
|
|
|
||
|
|
(crux/submit-tx crux
|
||
|
|
[[:crux.tx/put
|
||
|
|
{:crux.db/id :stock/N
|
||
|
|
:commod :commodity/N
|
||
|
|
:weight-ton 3}
|
||
|
|
#inst "2115-02-13T18"
|
||
|
|
#inst "2115-02-19T18"]
|
||
|
|
[:crux.tx/put
|
||
|
|
{:crux.db/id :stock/CH4
|
||
|
|
:commod :commodity/CH4
|
||
|
|
:weight-ton 92}
|
||
|
|
#inst "2115-02-15T18"
|
||
|
|
#inst "2115-02-19T18"]])
|
||
|
|
|
||
|
|
#_(crux/entity (crux/db crux #inst "2115-02-14") :stock/Pu)
|
||
|
|
|
||
|
|
#_(crux/entity (crux/db crux #inst "2115-02-18") :stock/Pu)
|
||
|
|
|
||
|
|
(defn easy-ingest
|
||
|
|
[node docs]
|
||
|
|
(crux/submit-tx node
|
||
|
|
(vec (for [doc docs]
|
||
|
|
[:crux.tx/put doc]))))
|
||
|
|
|
||
|
|
(crux/submit-tx crux
|
||
|
|
[[:crux.tx/put
|
||
|
|
{:crux.db/id :manifest
|
||
|
|
:pilot-name "Johanna"
|
||
|
|
:id/rocket "SB002-sol"
|
||
|
|
:id/employee "22910x2"
|
||
|
|
:badges ["SETUP" "PUT"]
|
||
|
|
:cargo ["stereo" "gold fish" "slippers" "secret note"]}]])
|
||
|
|
|
||
|
|
;; Mercury
|
||
|
|
|
||
|
|
(def data
|
||
|
|
[{:crux.db/id :commodity/Pu
|
||
|
|
:common-name "Plutonium"
|
||
|
|
:type :element/metal
|
||
|
|
:density 19.816
|
||
|
|
:radioactive true}
|
||
|
|
|
||
|
|
{:crux.db/id :commodity/N
|
||
|
|
:common-name "Nitrogen"
|
||
|
|
:type :element/gas
|
||
|
|
:density 1.2506
|
||
|
|
:radioactive false}
|
||
|
|
|
||
|
|
{:crux.db/id :commodity/CH4
|
||
|
|
:common-name "Methane"
|
||
|
|
:type :molecule/gas
|
||
|
|
:density 0.717
|
||
|
|
:radioactive false}
|
||
|
|
|
||
|
|
{:crux.db/id :commodity/Au
|
||
|
|
:common-name "Gold"
|
||
|
|
:type :element/metal
|
||
|
|
:density 19.300
|
||
|
|
:radioactive false}
|
||
|
|
|
||
|
|
{:crux.db/id :commodity/C
|
||
|
|
:common-name "Carbon"
|
||
|
|
:type :element/non-metal
|
||
|
|
:density 2.267
|
||
|
|
:radioactive false}
|
||
|
|
|
||
|
|
{:crux.db/id :commodity/borax
|
||
|
|
:common-name "Borax"
|
||
|
|
:IUPAC-name "Sodium tetraborate decahydrate"
|
||
|
|
:other-names ["Borax decahydrate" "sodium borate" "sodium tetraborate" "disodium tetraborate"]
|
||
|
|
:type :mineral/solid
|
||
|
|
:appearance "white solid"
|
||
|
|
:density 1.73
|
||
|
|
:radioactive false}])
|
||
|
|
|
||
|
|
(easy-ingest crux data)
|
||
|
|
|
||
|
|
(crux/q (crux/db crux)
|
||
|
|
'{:find [element]
|
||
|
|
:where [[element :type :element/metal]]})
|
||
|
|
|
||
|
|
(= (crux/q (crux/db crux)
|
||
|
|
'{:find [element]
|
||
|
|
:where [[element :type :element/metal]]})
|
||
|
|
(crux/q (crux/db crux)
|
||
|
|
{:find '[element]
|
||
|
|
:where '[[element :type :element/metal]]})
|
||
|
|
(crux/q (crux/db crux)
|
||
|
|
(quote
|
||
|
|
{:find [element]
|
||
|
|
:where [[element :type :element/metal]]}))
|
||
|
|
(crux/q (crux/db crux)
|
||
|
|
{:find ['element]
|
||
|
|
:where [['element :type :element/metal]]}))
|
||
|
|
|
||
|
|
(crux/q (crux/db crux)
|
||
|
|
'{:find [name]
|
||
|
|
:where [[e :type :element/metal]
|
||
|
|
[e :common-name name]]})
|
||
|
|
|
||
|
|
(crux/q (crux/db crux)
|
||
|
|
'{:find [name rho]
|
||
|
|
:where [[e :density rho]
|
||
|
|
[e :common-name name]]})
|
||
|
|
|
||
|
|
(crux/q (crux/db crux)
|
||
|
|
{:find '[name]
|
||
|
|
:where '[[e :type t]
|
||
|
|
[e :common-name name]]
|
||
|
|
:args [{'t :element/metal}]})
|
||
|
|
|
||
|
|
(defn find-by-type [type]
|
||
|
|
(crux/q (crux/db crux)
|
||
|
|
{:find '[name]
|
||
|
|
:where '[[e :type t]
|
||
|
|
[e :common-name name]]
|
||
|
|
:args [{'t type}]}))
|
||
|
|
|
||
|
|
(defn filter-type [type]
|
||
|
|
(crux/q (crux/db crux)
|
||
|
|
{:find '[name]
|
||
|
|
:where '[[e :type t]
|
||
|
|
[e :common-name name]]
|
||
|
|
:args [{'t type}]}))
|
||
|
|
|
||
|
|
(filter-type :element/metal)
|
||
|
|
|
||
|
|
(filter-type :element/non-metal)
|
||
|
|
|
||
|
|
(defn filter-appearance [description]
|
||
|
|
(crux/q (crux/db crux)
|
||
|
|
{:find '[name IUPAC]
|
||
|
|
:where '[[e :common-name name]
|
||
|
|
[e :IUPAC-name IUPAC]
|
||
|
|
[e :appearance ?appearance]]
|
||
|
|
:args [{'?appearance description}]}))
|
||
|
|
|
||
|
|
(filter-appearance "white solid")
|
||
|
|
|
||
|
|
(crux/submit-tx crux
|
||
|
|
[[:crux.tx/put
|
||
|
|
{:crux.db/id :manifest
|
||
|
|
:pilot-name "Johanna"
|
||
|
|
:id/rocket "SB002-sol"
|
||
|
|
:id/employee "22910x2"
|
||
|
|
:badges ["SETUP" "PUT" "DATALOG-QUERIES"]
|
||
|
|
:cargo ["stereo" "gold fish" "slippers" "secret note"]}]])
|
||
|
|
|
||
|
|
;; Neptune
|
||
|
|
|
||
|
|
(crux/submit-tx
|
||
|
|
crux
|
||
|
|
[[:crux.tx/put
|
||
|
|
{:crux.db/id :consumer/RJ29sUU
|
||
|
|
:consumer-id :RJ29sUU
|
||
|
|
:first-name "Jay"
|
||
|
|
:last-name "Rose"
|
||
|
|
:cover? true
|
||
|
|
:cover-type :Full}
|
||
|
|
#inst "2114-12-03"]])
|
||
|
|
|
||
|
|
(crux/submit-tx
|
||
|
|
crux
|
||
|
|
[[:crux.tx/put ;; (1)
|
||
|
|
{:crux.db/id :consumer/RJ29sUU
|
||
|
|
:consumer-id :RJ29sUU
|
||
|
|
:first-name "Jay"
|
||
|
|
:last-name "Rose"
|
||
|
|
:cover? true
|
||
|
|
:cover-type :Full}
|
||
|
|
#inst "2113-12-03" ;; Valid time start
|
||
|
|
#inst "2114-12-03"] ;; Valid time end
|
||
|
|
|
||
|
|
[:crux.tx/put ;; (2)
|
||
|
|
{:crux.db/id :consumer/RJ29sUU
|
||
|
|
:consumer-id :RJ29sUU
|
||
|
|
:first-name "Jay"
|
||
|
|
:last-name "Rose"
|
||
|
|
:cover? true
|
||
|
|
:cover-type :Full}
|
||
|
|
#inst "2112-12-03"
|
||
|
|
#inst "2113-12-03"]
|
||
|
|
|
||
|
|
[:crux.tx/put ;; (3)
|
||
|
|
{:crux.db/id :consumer/RJ29sUU
|
||
|
|
:consumer-id :RJ29sUU
|
||
|
|
:first-name "Jay"
|
||
|
|
:last-name "Rose"
|
||
|
|
:cover? false}
|
||
|
|
#inst "2112-06-03"
|
||
|
|
#inst "2112-12-02"]
|
||
|
|
|
||
|
|
[:crux.tx/put ;; (4)
|
||
|
|
{:crux.db/id :consumer/RJ29sUU
|
||
|
|
:consumer-id :RJ29sUU
|
||
|
|
:first-name "Jay"
|
||
|
|
:last-name "Rose"
|
||
|
|
:cover? true
|
||
|
|
:cover-type :Promotional}
|
||
|
|
#inst "2111-06-03"
|
||
|
|
#inst "2112-06-03"]])
|
||
|
|
|
||
|
|
(crux/q (crux/db crux #inst "2114-01-01")
|
||
|
|
{:find '[cover type]
|
||
|
|
:where '[[e :consumer-id :RJ29sUU]
|
||
|
|
[e :cover? cover]
|
||
|
|
[e :cover-type type]]})
|
||
|
|
|
||
|
|
(crux/q (crux/db crux #inst "2111-07-03")
|
||
|
|
{:find '[cover type]
|
||
|
|
:where '[[e :consumer-id :RJ29sUU]
|
||
|
|
[e :cover? cover]
|
||
|
|
[e :cover-type type]]})
|
||
|
|
|
||
|
|
(crux/q (crux/db crux #inst "2112-07-03")
|
||
|
|
{:find '[cover type]
|
||
|
|
:where '[[e :consumer-id :RJ29sUU]
|
||
|
|
[e :cover? cover]
|
||
|
|
[e :cover-type type]]})
|
||
|
|
|
||
|
|
(crux/submit-tx crux
|
||
|
|
[[:crux.tx/put
|
||
|
|
{:crux.db/id :manifest
|
||
|
|
:pilot-name "Johanna"
|
||
|
|
:id/rocket "SB002-sol"
|
||
|
|
:id/employee "22910x2"
|
||
|
|
:badges ["SETUP" "PUT" "DATALOG-QUERIES" "BITEMP"]
|
||
|
|
:cargo ["stereo" "gold fish" "slippers" "secret note"]}]])
|
||
|
|
|
||
|
|
;; Saturn
|
||
|
|
|
||
|
|
(let [data [{:crux.db/id :gold-harmony
|
||
|
|
:company-name "Gold Harmony"
|
||
|
|
:seller? true
|
||
|
|
:buyer? false
|
||
|
|
:units/Au 10211
|
||
|
|
:credits 51}
|
||
|
|
|
||
|
|
{:crux.db/id :tombaugh-resources
|
||
|
|
:company-namnne "Tombaugh Resources Ltd."
|
||
|
|
:seller? true
|
||
|
|
:buyer? false
|
||
|
|
:units/Pu 50
|
||
|
|
:units/N 3
|
||
|
|
:units/CH4 92
|
||
|
|
:credits 51}
|
||
|
|
|
||
|
|
{:crux.db/id :encompass-trade
|
||
|
|
:company-name "Encompass Trade"
|
||
|
|
:seller? true
|
||
|
|
:buyer? true
|
||
|
|
:units/Au 10
|
||
|
|
:units/Pu 5
|
||
|
|
:units/CH4 211
|
||
|
|
:credits 1002}
|
||
|
|
|
||
|
|
{:crux.db/id :blue-energy
|
||
|
|
:seller? false
|
||
|
|
:buyer? true
|
||
|
|
:company-name "Blue Energy"
|
||
|
|
:credits 1000}]]
|
||
|
|
(easy-ingest crux data))
|
||
|
|
|
||
|
|
(defn stock-check [company-id item]
|
||
|
|
{:result (crux/q (crux/db crux)
|
||
|
|
{:find '[name funds stock]
|
||
|
|
:where [['e :company-name 'name]
|
||
|
|
['e :credits 'funds]
|
||
|
|
['e item 'stock]]
|
||
|
|
:args [{'e company-id}]})
|
||
|
|
:item item})
|
||
|
|
|
||
|
|
(defn format-stock-check [{:keys [result item] :as stock-check}]
|
||
|
|
(for [[name funds commod] result]
|
||
|
|
(str "Name: " name ", Funds: " funds ", " item " " commod)))
|
||
|
|
|
||
|
|
(crux/submit-tx crux
|
||
|
|
[[:crux.tx/match
|
||
|
|
:blue-energy
|
||
|
|
{:crux.db/id :blue-energy
|
||
|
|
:seller? false
|
||
|
|
:buyer? true
|
||
|
|
:company-name "Blue Energy"
|
||
|
|
:credits 1000}]
|
||
|
|
[:crux.tx/put
|
||
|
|
{:crux.db/id :blue-energy
|
||
|
|
:seller? false
|
||
|
|
:buyer? true
|
||
|
|
:company-name "Blue Energy"
|
||
|
|
:credits 900
|
||
|
|
:units/CH4 10}]
|
||
|
|
|
||
|
|
[:crux.tx/match
|
||
|
|
:tombaugh-resources
|
||
|
|
{:crux.db/id :tombaugh-resources
|
||
|
|
:company-name "Tombaugh Resources Ltd."
|
||
|
|
:seller? true
|
||
|
|
:buyer? false
|
||
|
|
:units/Pu 50
|
||
|
|
:units/N 3
|
||
|
|
:units/CH4 92
|
||
|
|
:credits 51}]
|
||
|
|
[:crux.tx/put
|
||
|
|
{:crux.db/id :tombaugh-resources
|
||
|
|
:company-name "Tombaugh Resources Ltd."
|
||
|
|
:seller? true
|
||
|
|
:buyer? false
|
||
|
|
:units/Pu 50
|
||
|
|
:units/N 3
|
||
|
|
:units/CH4 82
|
||
|
|
:credits 151}]])
|
||
|
|
|
||
|
|
(format-stock-check (stock-check :tombaugh-resources :units/CH4))
|
||
|
|
(format-stock-check (stock-check :blue-energy :units/CH4))
|
||
|
|
|
||
|
|
(crux/submit-tx crux
|
||
|
|
[[:crux.tx/match
|
||
|
|
:gold-harmony
|
||
|
|
{:crux.db/id :gold-harmony
|
||
|
|
:company-name "Gold Harmony"
|
||
|
|
:seller? true
|
||
|
|
:buyer? false
|
||
|
|
:units/Au 10211
|
||
|
|
:credits 51}]
|
||
|
|
[:crux.tx/put
|
||
|
|
{:crux.db/id :gold-harmony
|
||
|
|
:company-name "Gold Harmony"
|
||
|
|
:seller? true
|
||
|
|
:buyer? false
|
||
|
|
:units/Au 211
|
||
|
|
:credits 51}]
|
||
|
|
|
||
|
|
[:crux.tx/match
|
||
|
|
:encompass-trade
|
||
|
|
{:crux.db/id :encompass-trade
|
||
|
|
:company-name "Encompass Trade"
|
||
|
|
:seller? true
|
||
|
|
:buyer? true
|
||
|
|
:units/Au 10
|
||
|
|
:units/Pu 5
|
||
|
|
:units/CH4 211
|
||
|
|
:credits 100002}]
|
||
|
|
[:crux.tx/put
|
||
|
|
{:crux.db/id :encompass-trade
|
||
|
|
:company-name "Encompass Trade"
|
||
|
|
:seller? true
|
||
|
|
:buyer? true
|
||
|
|
:units/Au 10010
|
||
|
|
:units/Pu 5
|
||
|
|
:units/CH4 211
|
||
|
|
:credits 1002}]])
|
||
|
|
|
||
|
|
(format-stock-check (stock-check :gold-harmony :units/Au))
|
||
|
|
(format-stock-check (stock-check :encompass-trade :units/Au))
|
||
|
|
|
||
|
|
(crux/submit-tx crux
|
||
|
|
[[:crux.tx/put
|
||
|
|
{:crux.db/id :manifest
|
||
|
|
:pilot-name "Johanna"
|
||
|
|
:id/rocket "SB002-sol"
|
||
|
|
:id/employee "22910x2"
|
||
|
|
:badges ["SETUP" "PUT" "DATALOG-QUERIES" "BITEMP" "MATCH"]
|
||
|
|
:cargo ["stereo" "gold fish" "slippers" "secret note"]}]])
|
||
|
|
|
||
|
|
;; Jupiter
|
||
|
|
|
||
|
|
(crux/submit-tx crux
|
||
|
|
[[:crux.tx/put {:crux.db/id :kaarlang/clients
|
||
|
|
:clients [:encompass-trade]}
|
||
|
|
#inst "2110-01-01T09"
|
||
|
|
#inst "2111-01-01T09"]
|
||
|
|
|
||
|
|
[:crux.tx/put {:crux.db/id :kaarlang/clients
|
||
|
|
:clients [:encompass-trade :blue-energy]}
|
||
|
|
#inst "2111-01-01T09"
|
||
|
|
#inst "2113-01-01T09"]
|
||
|
|
|
||
|
|
[:crux.tx/put {:crux.db/id :kaarlang/clients
|
||
|
|
:clients [:blue-energy]}
|
||
|
|
#inst "2113-01-01T09"
|
||
|
|
#inst "2114-01-01T09"]
|
||
|
|
|
||
|
|
[:crux.tx/put {:crux.db/id :kaarlang/clients
|
||
|
|
:clients [:blue-energy :gold-harmony :tombaugh-resources]}
|
||
|
|
#inst "2114-01-01T09"
|
||
|
|
#inst "2115-01-01T09"]])
|
||
|
|
|
||
|
|
(crux/entity-history
|
||
|
|
(crux/db crux #inst "2115-01-01T08")
|
||
|
|
:kaarlang/clients
|
||
|
|
:desc
|
||
|
|
{:with-docs true})
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
(crux/submit-tx crux
|
||
|
|
[[:crux.tx/delete :kaarlang/clients
|
||
|
|
#inst "2110-01-01"
|
||
|
|
#inst "2116-01-01"]])
|
||
|
|
|
||
|
|
(crux/entity-history
|
||
|
|
(crux/db crux #inst "2118-01-01T08")
|
||
|
|
:kaarlang/clients
|
||
|
|
:desc
|
||
|
|
{:with-docs? true})
|
||
|
|
|
||
|
|
(crux/q (crux/db crux #inst "2116-01-01T08")
|
||
|
|
{:find ['clients]
|
||
|
|
:where [['e :clients 'clients]
|
||
|
|
[:crux.db/id :kaarlang/clients]]})
|
||
|
|
|
||
|
|
;; Secret
|
||
|
|
|
||
|
|
(crux/submit-tx crux
|
||
|
|
[[:crux.tx/put
|
||
|
|
{:crux.db/id :person/kaarlang
|
||
|
|
:full-name "Kaarlang"
|
||
|
|
:origin-planet "Mars"
|
||
|
|
:identity-tag :KA01299242093
|
||
|
|
:DOB #inst "2040-11-23"}]
|
||
|
|
|
||
|
|
[:crux.tx/put
|
||
|
|
{:crux.db/id :person/ilex
|
||
|
|
:full-name "Ilex Jefferson"
|
||
|
|
:origin-planet "Venus"
|
||
|
|
:identity-tag :IJ01222212454
|
||
|
|
:DOB #inst "2061-02-17"}]
|
||
|
|
|
||
|
|
[:crux.tx/put
|
||
|
|
{:crux.db/id :person/thadd
|
||
|
|
:full-name "Thad Christover"
|
||
|
|
:origin-moon "Titan"
|
||
|
|
:identity-tag :IJ01222212454
|
||
|
|
:DOB #inst "2101-01-01"}]
|
||
|
|
|
||
|
|
[:crux.tx/put
|
||
|
|
{:crux.db/id :person/johanna
|
||
|
|
:full-name "Johanna"
|
||
|
|
:origin-planet "Earth"
|
||
|
|
:identity-tag :JA012992129120
|
||
|
|
:DOB #inst "2090-12-07"}]])
|
||
|
|
|
||
|
|
(defn full-query [node]
|
||
|
|
(crux/q
|
||
|
|
(crux/db node)
|
||
|
|
'{:find [id]
|
||
|
|
:where [[e :crux.db/id id]]
|
||
|
|
:pull? true}))
|
||
|
|
|
||
|
|
(full-query crux)
|
||
|
|
|
||
|
|
(crux/submit-tx crux [[:crux.tx/evict :person/kaarlang]])
|
||
|
|
|
||
|
|
|