rsc initial pass

Author: roman01la

core/.gitignore

@@ -8,6 +8,7 @@ resources/public/benchmark.js
 target
 .rebel_readline_history
 out
+rsc-out
 index.html
 node_modules
 server_render_test

core/deps.edn

@@ -3,13 +3,15 @@
         com.adamrenklint/preo {:mvn/version "0.1.0"}}
  :paths ["src" "resources"]
  :aliases {:dev {:extra-deps {cljfmt/cljfmt {:mvn/version "0.8.0"}
-                              clj-kondo/clj-kondo {:mvn/version "2025.02.20"}}}
+                              clj-kondo/clj-kondo {:mvn/version "2025.02.20"}
+                              org.clojure/clojurescript {:mvn/version "1.11.60"}
+                              uix.dom/uix.dom {:local/root "../dom"}}}
            :benchmark {:extra-paths ["benchmark"]
                        :extra-deps {reagent/reagent {:mvn/version "1.2.0"}
                                     lilactown/helix {:mvn/version "0.1.10"}}}
 
            :test {:extra-paths ["test" "dev"]
-                  :extra-deps {org.clojure/clojure {:mvn/version "1.11.1"}
+                  :extra-deps {org.clojure/clojure {:mvn/version "1.12.0"}
                                org.clojure/clojurescript {:mvn/version "1.11.60"}
                                thheller/shadow-cljs {:mvn/version "2.28.20"}
                                uix.dom/uix.dom {:local/root "../dom"}
@@ -22,7 +24,11 @@
                      :main-opts ["-m" "release"]}
 
            :examples {:extra-paths ["dev"]
-                      :extra-deps {org.clojure/clojure {:mvn/version "1.11.1"}
+                      :extra-deps {org.clojure/clojure {:mvn/version "1.12.0"}
                                    org.clojure/clojurescript {:mvn/version "1.11.60"}
                                    thheller/shadow-cljs {:mvn/version "2.28.20"}
+                                   metosin/reitit {:mvn/version "0.8.0"}
+                                   org.apache.commons/commons-text {:mvn/version "1.13.1"}
+                                   http-kit/http-kit {:mvn/version "2.8.0"}
+                                   compojure/compojure {:mvn/version "1.7.1"}
                                    uix.dom/uix.dom {:local/root "../dom"}}}}}

core/dev/preo/core.cljs

@@ -0,0 +1,3 @@
+(ns preo.core)
+
+(defn arg! [& args])

core/dev/uix/rsc_example/actions.cljc

@@ -0,0 +1,6 @@
+(ns uix.rsc-example.actions
+  (:require [uix.rsc :refer [defaction]]))
+
+(defaction vote [id score]
+  ;; todo: quick db,sqlite example
+  (inc score))

core/dev/uix/rsc_example/client/root.cljs

@@ -0,0 +1,11 @@
+(ns uix.rsc-example.client.root
+  (:require [uix.dom.rsc :as dom.rsc]
+            [uix.rsc-example.routes :refer [routes]]
+            [uix.rsc-example.client.ui]))
+
+(defn init []
+  (dom.rsc/render-root
+    {:container (js/document.getElementById "root")
+     :routes routes
+     :rsc-endpoint "/rsc"
+     :server-actions-endpoint "/api"}))

core/dev/uix/rsc_example/client/ui.cljc

@@ -0,0 +1,14 @@
+(ns uix.rsc-example.client.ui
+  (:require [uix.core :refer [defui $] :as uix]
+            [uix.rsc-example.actions :as actions]))
+
+;; ^:client turns client component into a client ref
+;; when the component is used in server components tree
+(defui ^:client vote-btn [{:keys [id score]}]
+  (let [[score set-score] (uix/use-state score)
+        vote #(-> (actions/vote id score)
+                  (.then set-score))]
+    ($ :button {:on-click vote
+                :style {:text-decoration :underline
+                        :cursor :pointer}}
+       (str "Vote " score))))

core/dev/uix/rsc_example/routes.cljc

@@ -0,0 +1,12 @@
+(ns uix.rsc-example.routes
+  (:require [uix.rsc :refer [defroutes]]
+            #?(:clj [uix.rsc-example.server.ui :as ui])))
+
+(defroutes routes
+  [["/" {:component ui/stories :title "new"}]
+   ["/askstories" {:component ui/stories :title "ask"}]
+   ["/showstories" {:component ui/stories :title "show"}]
+   ["/jobstories" {:component ui/stories :title "job"}]
+   ["/topstories" {:component ui/stories :title "top"}]
+   ["/beststories" {:component ui/stories :title "best"}]
+   ["/item/:id" {:component ui/item}]])

core/dev/uix/rsc_example/server/core.clj

@@ -0,0 +1,67 @@
+(ns uix.rsc-example.server.core
+  (:require [clojure.edn :as edn]
+            [clojure.java.io :as io]
+            [uix.core :refer [defui $] :as uix]
+            [uix.rsc :as rsc]
+            [org.httpkit.server :as server]
+            [compojure.core :refer [defroutes GET POST]]
+            [compojure.route :as route]
+            [ring.util.response :as resp]
+            [reitit.core :as r]
+            [uix.rsc-example.server.root :refer [root]]
+            [uix.rsc-example.routes :refer [routes]])
+  (:import (java.io PushbackReader))
+  (:gen-class))
+
+(defn read-end-stream [body]
+  (with-open [reader (io/reader body)]
+    (edn/read (PushbackReader. reader))))
+
+(def router
+  (r/router routes))
+
+(defn handler [request]
+  (let [{:keys [route]} (read-end-stream (:body request))
+        route (r/match-by-path router (:path route))]
+    ;; request -> route -> react flight rows -> response stream
+    (server/as-channel request
+      {:on-open (fn [ch]
+                  (let [on-chunk (fn [chunk]
+                                   (if (= chunk :done)
+                                     (server/close ch)
+                                     (server/send! ch chunk false)))]
+                    (rsc/render-to-flight-stream ($ root {:route route})
+                                                 {:on-chunk on-chunk})))})))
+
+(defroutes server-routes*
+  ;; react flight payload endpoint
+  (POST "/rsc" req
+    (handler req))
+  ;; server actions endpoint
+  (POST "/api" {body :body}
+    (try
+      (-> (rsc/handle-action (read-end-stream body))
+          str
+          (resp/response)
+          (resp/header "Content-Type" "text/edn"))
+      (catch Exception e
+        (-> (resp/bad-request (ex-message e))
+            (resp/header "Content-Type" "text/edn")))))
+  ;; static assets
+  (route/files "/" {:root "./"})
+  ;; always serving index.html instead of 404
+  (GET "/*" req
+    ;; todo: render flight payload into html on initial load
+    (-> (resp/file-response "index.html" {:root "./"})
+        (resp/header "Content-Type" "text/html"))))
+
+(defn start-server []
+  (server/run-server #'server-routes* {:port 8080})
+  (println "Server is listening at http://localhost:8080"))
+
+(defn -main [& args]
+  (start-server))
+
+(comment
+  (def stop-server (start-server))
+  (stop-server))

core/dev/uix/rsc_example/server/root.clj

@@ -0,0 +1,21 @@
+(ns uix.rsc-example.server.root
+  (:require [uix.core :refer [defui $] :as uix]
+            [uix.rsc :as rsc]
+            [uix.rsc-example.routes :refer [routes]]))
+
+(defui root [{:keys [route]}]
+  (let [{:keys [path path-params data]} route
+        {:keys [component]} data]
+    ($ :div.flex.flex-col.items-center
+      ($ :ul.flex.gap-2.text-sm.py-1.font-medium
+        (for [[route-path {:keys [title]}] routes
+              :when title]
+          ($ :li {:key route-path}
+             ($ rsc/link
+                {:href route-path
+                 :class (if (= route-path path)
+                          "text-emerald-500"
+                          "text-stone-800")}
+                title))))
+      ($ :div.max-w-128
+         ($ component {:path path :params path-params})))))

core/dev/uix/rsc_example/server/services.clj

@@ -0,0 +1,23 @@
+(ns uix.rsc-example.server.services
+  (:require [org.httpkit.client :as http]
+            [cheshire.core :as json]))
+
+(defn fetch-json [path]
+  (-> @(http/get path)
+      :body
+      (json/parse-string keyword)))
+
+(defn fetch-story [id]
+  (fetch-json (str "https://hacker-news.firebaseio.com/v0/item/" id ".json")))
+
+(defn fetch-stories [pathname]
+  (let [pathname (if (= pathname "/")
+                   "/newstories"
+                   pathname)]
+    (->> (fetch-json (str "https://hacker-news.firebaseio.com/v0/" pathname ".json"))
+         (take 10)
+         (pmap fetch-story))))
+
+(defn fetch-item [id]
+  (-> (fetch-story id)
+      (update :kids #(pmap fetch-item %))))