Conveying Information with Simulant’s Process State Service

acquirer.clj

(ns my-suite.actions.acquirer
  (:require ;; …
		    [io.homegrown.sim-ephemeral :as eph])

(defn create-payment
  “Create a payment, returning a vector of [<response> <payment id> <nsecs taken>]”
  [action]
  …)

(defn approve-paymenet
  “Approve a payment, returning a vector of [<response> <nsecs taken>]”
  [id action]
  …)

(defmethod sim/perform-action :action.type/createPayment [action process]
  (try
    (let [agent           (-> action :agent/_actions solo)
          [resp id nsecs] (create-payment action)]
      ;; Store the current payment-id for later use.
      (store agent :payment-id :db.cardinality/one :db.type/string id)
      (log action process resp nsecs))
    (catch Throwable t
      (log-error action process t 0))))

(defmethod sim/perform-action :action.type/approvePayment [action process]
  (try
    (let [agent        (-> action :agent/_actions solo)
          ;; Retrieve the current payment-id.
          payment-id  (retrieve agent :payment-id)
          [resp nsecs] (approve-payment payment-id action)]
      ;; At this point, it may be prudent to clear the agent’s state.
      (clear agent)
      (log action process resp nsecs))
    (catch Throwable t
      (log-error action process t 0))))

sim.clj

(ns my-suite.sim
  (:require ;; …
            [simulant.sim :as sim]))

;; …

(defn- setup-sim [context]
  ;; <Extract information from context to create sim>
  (sim/create-process-state conn sim)
  (assoc context :sim sim))