Venn v0.0.3-alpha (#64)

Author: bryanmikaelian

.gitignore

@@ -14,4 +14,5 @@ pom.xml.asc
 log
 1
 projects/**/target
-development/resources/system.edn
+
+data/*.db

bases/agent/resources/agent/migrations/20250321011104-create-events.edn

@@ -0,0 +1,4 @@
+{:ns com.vennbilling.agent.migrations.create-events
+ :up-fn migrate-up
+ :down-fn migrate-down
+ :transaction? true}

bases/agent/resources/agent/system.edn

@@ -1,42 +1,8 @@
-{:system/env #profile {:dev :dev
-                       :test :test
+{:system/env #profile {:development :development
                        :prod :prod}
 
- :http/server
- {:host #profile {:dev "0.0.0.0"
-                  :test "0.0.0.0"
+ :system/server
+ {:host #profile {:development "0.0.0.0"
                   :prod #env VENN_AGENT_HTTP_HOST}
-  :port #profile {:dev 8080
-                  :test 8080
-                  :prod #env VENN_AGENT_HTTP_PORT}}
-
- :db/server
- {:db {:dbtype "postgresql"
-       :dbname #profile   {:dev "venn_development"
-                           :test "venn_test"
-                           :prod #env VENN_AGENT_DB_NAME}
-       :host #profile     {:dev "0.0.0.0"
-                           :test "0.0.0.0"
-                           :prod #env VENN_AGENT_DB_HOST}
-       :port #profile     {:dev 5432
-                           :test 5433
-                           :prod #env VENN_AGENT_DB_PORT}
-       :user #profile     {:dev "venn"
-                           :test "venn"
-                           :prod #env VENN_AGENT_DB_USER}
-       :password #profile {:dev "password"
-                           :test "password"
-                           :prod #env VENN_AGENT_DB_PASSWORD}
-
-       ;; Migration-related configs
-       :store :database
-       :migration-dir "../components/database/resources/database/migrations"
-       :migration-table-name "schema_migrations"
-       ;; Script to initialize the DB
-       :init-script #profile {:dev "schema.sql"
-                              :test "schema.sql"
-                              :prod nil}
-       ;; Managed connections allow migration commands to re-use the same connection
-       :managed-connection? #profile {:dev true
-                                      :test true
-                                      :prod false}}}}
+  :port #profile {:development 8080
+                  :prod #env VENN_AGENT_HTTP_PORT}}}

bases/agent/src/com/vennbilling/agent/core.clj

@@ -2,15 +2,14 @@
   (:gen-class)
   (:require
    [clojure.java.io :as io]
-   [com.vennbilling.healthcheck.interface :as healthcheck]
+   [com.vennbilling.http.interface :as http]
    [com.vennbilling.logging.interface :as log]
-   [com.vennbilling.spec.interface :as venn-spec]
    [com.vennbilling.system.interface :as system]))
 
 (def api-routes
   ["/v1"
-   [venn-spec/identify-route
-    healthcheck/simple-route]])
+   http/agent-routes
+   http/healthcheck-routes])
 
 (def ^:const banner (slurp (io/resource "agent/banner.txt")))
 (def config-file (io/resource "agent/system.edn"))

bases/agent/src/com/vennbilling/agent/migrations/.gitkeep

@@ -0,0 +1,22 @@
+(ns com.vennbilling.agent.migrations.create-events
+
+  (:require [com.vennbilling.database.interface :as database]))
+
+(def up-query {:create-table [:events :if-not-exists]
+               :with-columns
+               [[:uuid :text {:primary-key true}
+                 :payload :text {:not-null true}
+                 :timestamp :integer {:not-null true}
+                 :flushed_at :integer {:not-null true}]]})
+
+(def down-query {:drop-table :events})
+
+(defn migrate-up
+  [{:keys [db]}]
+  (let [{:keys [datasource]} db]
+    (database/exec! datasource up-query)))
+
+(defn migrate-down
+  [{:keys [db]}]
+  (let [{:keys [datasource]} db]
+    (database/exec! datasource down-query)))

bases/agent/src/com/vennbilling/agent/migrations/create_events.clj

@@ -1,7 +1,7 @@
 {:system/env #profile {:dev :dev
                        :prod :prod}
 
- :http/server
+ :system/server
  {:host #profile {:dev "0.0.0.0"
                   :prod #env VENN_SERVER_HTTP_HOST}
   :port #profile {:dev 8080

bases/server/resources/server/system.edn

@@ -2,17 +2,14 @@
   (:gen-class)
   (:require
    [clojure.java.io :as io]
-   [com.vennbilling.customer.interface :as customer]
-   [com.vennbilling.healthcheck.interface :as healthcheck]
+   [com.vennbilling.http.interface :as http]
    [com.vennbilling.logging.interface :as log]
    [com.vennbilling.system.interface :as system]))
 
 (def api-routes
   ["/v1"
-   [customer/list-route
-    customer/show-route
-
-    healthcheck/simple-route]])
+   [http/server-routes
+    http/healthcheck-routes]])
 
 (def ^:const banner (slurp (io/resource "server/banner.txt")))
 (def config-file (io/resource "server/system.edn"))

bases/server/src/com/vennbilling/server/core.clj

@@ -0,0 +1,9 @@
+(ns com.vennbilling.customer.handlers)
+
+(defn list-handler
+  [_]
+  [:ok []])
+
+(defn show-handler
+  [_]
+  [:not-found {}])