Clara Ruleによるexpert system(外部とのデータのやり取り)

ns test01.rules
  (:require [clara.rules :refer :all]))

(defrecord Stage [status txt])

(defrule rule1
  [Stage (= status "start" )]
  =>
  (insert! (->Stage  "　step1" "this is start"))
  (println "this is start"))

(defrule rule2
  [Stage (= status "step1")]
  =>
  (insert! (->Stage  "next step" "this is next"))
  (println "this is next"))

(defrule rule3
  [Stage (= status "next step")]
  =>
  (insert! (->Stage  "last step" "this is last"))
  (println "this is last"))


(defquery get-ans []
  [?a <- Stage]) (defn show-ans [session] (query session get-ans)) (defn ask-ans [q] (println "pre:" q) (-> (mk-session 'test01.rules)
      (insert (->Stage q nil))
      (fire-rules)
      (show-ans)))

(defn get-ans-from-rules [res]
  (-> (:params res)
      (ask-ans)
      (first)
      (:?a)
      :txt
      )) 

(ns test01.server
  (:require [test01.rules :as rule]
            [ring.util.response :as r]
            [ring.adapter.jetty :as server]
            [compojure.core :refer :all]
            [compojure.route :as route]
            [ring.middleware.defaults :refer [wrap-defaults site-defaults]]
            [ring.middleware.json :refer [wrap-json-response wrap-json-body]]
            [ring.middleware.cors :refer [wrap-cors]]
            [ring.middleware.x-headers :refer [wrap-frame-options]]))
(defonce server (atom nil))

(defn ans-response [req]
  (r/response (response-data (rule/get-ans-from-rules req ))))

;;route
(defroutes app-routes
  (GET "/ans-response" [] ans-response)
  (route/not-found "Not Found"))

(def app
  (-> app-routes
      wrap-json-body
      wrap-json-response
      (wrap-defaults site-defaults)
      (wrap-cors :access-control-allow-origin [#".*"] :access-control-allow-methods [:get])))

;;servef
(defn start-server []
  (when-not @server
    (reset! server (server/run-jetty app {:port 3000 :join? false}))))

(defn stop-server []
  (when @server
    (.stop @server)
    (reset! server nil)))

(defn restart-server []
  (when @server
    (stop-server)
    (start-server)))

(defn -main []
  (start-server))

(start-server)
(stop-server)
(restart-server)