Concurrencia en Clojure - parte 7

Seguimos con concurrencia en Clojure

Ahora podemos modificar nuestro servicio web para usar sesiones. Primero, necesitamos una función que cree una nueva sesión:

(defn create-session []

  (let [snippets (repeatedly promise)

    translations (delay (map translate

                         (strings->sentences (map deref snippets))))]

      (new-session {:snippets snippets :translations translations})))

Seguimos usando una secuencia perezosa infinita de promesas para representar los fragmentos entrantes y un mapa sobre esa secuencia para representar las traducciones, pero ahora ambos están almacenados en una sesión.

A continuación, debemos modificar accept-snippet y get-translation para buscar :snippets o :translations dentro de una sesión:

(defn accept-snippet [session n text]

  (deliver (nth (:snippets session) n) text))

(defn get-translation [session n]

  @(nth @(:translations session) n))

Finalmente, definimos las rutas que vinculan estas funciones a las URI:

(defroutes app-routes

  (POST "/session/create" []

    (response (str (create-session))))

  (context "/session/:session-id" [session-id]

    (let [session (get-session (edn/read-string session-id))]

      (routes

        (PUT "/snippet/:n" [n :as {:keys [body]}]

          (accept-snippet session (edn/read-string n) (slurp body))

          (response "OK"))

        (GET "/translation/:n" [n]

          (response (get-translation session (edn/read-string n))))))))

Esto nos brinda un servicio web que hace un uso juicioso de los datos mutables pero aún se siente principalmente funcional.