diff --git a/src/ie/simm/db.clj b/src/ie/simm/db.clj
index 905b490..f401925 100644
--- a/src/ie/simm/db.clj
+++ b/src/ie/simm/db.clj
@@ -1 +1,90 @@
-(ns ie.simm.db)
\ No newline at end of file
+(ns ie.simm.db
+  (:require [clojure.java.io :as io]
+            [datahike.api :as d]
+            [clojure.string :as str]))
+
+(def default-schema (read-string (slurp "resources/default_schema.edn")))
+
+(defn ensure-conn [peer chat-id]
+  (or (get-in @peer [:conn chat-id])
+      (let [;; ensure "databases directory exists and creating it if not"
+            path (str "databases/" chat-id)
+            _ (io/make-parents path)
+            cfg {:store {:backend :file :scope "simm.ie/chats" :path path}}
+            conn
+            (try
+              (let [cfg (d/create-database cfg)
+                    conn (d/connect cfg)]
+                (d/transact conn default-schema)
+                conn)
+              (catch Exception _
+                (d/connect cfg)))]
+        #_(d/transact conn default-schema)
+        (swap! peer assoc-in [:conn chat-id] conn)
+        conn)))
+
+(defn conversation [db chat-id window-size]
+  (->>
+   (d/q '[:find ?d ?f ?l ?n ?t
+          :in $ ?chat
+          :where
+          [?c :chat/id ?chat]
+          [?e :message/chat ?c]
+          [?e :message/text ?t]
+          [?e :message/date ?d]
+          [?e :message/from ?u]
+          [(get-else $ ?u :from/username "") ?n]
+          [(get-else $ ?u :from/first_name "") ?f]
+          [(get-else $ ?u :from/last_name "") ?l]]
+        db chat-id)
+   (sort-by first)
+   (take-last window-size)
+   (map (fn [[d f l n t]] (str d " " f " " l " (" n "): " (str/replace t #"\n" " "))))
+   (str/join "\n")))
+
+(defn extract-tags [text]
+  (vec (distinct (map second (re-seq #"\[\[([^\[\]]+)\](\[.+\])?\]" text)))))
+
+(defn msg->txs [message]
+  (let [{:keys [message_id from chat date text]} message
+        tags (when text (extract-tags text))]
+    (vec
+     (concat
+      (when from
+        [(let [{:keys [id is_bot first_name last_name username language_code]} from]
+           (merge
+            {:from/id (long id)
+             :from/is_bot is_bot}
+            (when username
+              {:from/username username})
+            (when language_code
+              {:from/language_code language_code})
+            (when first_name
+              {:from/first_name first_name})
+            (when last_name
+              {:from/last_name last_name})))])
+      (when chat
+        [(let [{:keys [id first_name username type title all_members_are_administrators]} chat]
+           (merge
+            {:chat/id (long id)
+             :chat/type type}
+            (when username
+              {:chat/username username})
+            (when first_name
+              {:chat/first_name first_name})
+            (when title
+              {:chat/title title})
+            (when all_members_are_administrators
+              {:chat/all_members_are_administrators all_members_are_administrators})))])
+      [(merge
+        {:message/id (long message_id)
+         :message/from [:from/id (long (:id from))]
+         :message/chat [:chat/id (long (:id chat))]
+         :message/date (java.util.Date. (long (* 1000 date)))}
+        (when text
+          {:message/text text})
+        (when (seq tags)
+          {:message/tag tags}))]))))
+
+(def window-size 10)
+
diff --git a/src/ie/simm/runtimes/relational_assistance.clj b/src/ie/simm/runtimes/assistance.clj
similarity index 89%
rename from src/ie/simm/runtimes/relational_assistance.clj
rename to src/ie/simm/runtimes/assistance.clj
index 0ce5754..e9969e3 100644
--- a/src/ie/simm/runtimes/relational_assistance.clj
+++ b/src/ie/simm/runtimes/assistance.clj
@@ -1,4 +1,4 @@
-(ns ie.simm.runtimes.relational-assistance
+(ns ie.simm.runtimes.assistance
   "Active conversation mode that tries to extract factual and procedural knowledge from the user for later use in reasoning and recall.
    
    Properties: stateful, persistent, durable"
@@ -8,6 +8,7 @@
             [ie.simm.languages.browser :refer [extract-body]]
             [ie.simm.languages.chat :refer [send-text! send-photo! send-document!]]
             [ie.simm.prompts :as pr]
+            [ie.simm.db :refer [ensure-conn conversation extract-tags msg->txs window-size]]
             [superv.async :refer [<?? go-try S go-loop-try <? >? put? go-for] :as sasync]
             [clojure.core.async :refer [chan pub sub mult tap timeout] :as async]
             [taoensso.timbre :refer [debug info warn error]]
@@ -18,91 +19,6 @@
             [etaoin.api :as e])
   (:import [java.util.zip ZipEntry ZipOutputStream]))
 
-(def default-schema (read-string (slurp "resources/default_schema.edn")))
-
-(defn ensure-conn [peer chat-id]
-  (or (get-in @peer [:conn chat-id])
-      (let [;; ensure "databases directory exists and creating it if not"
-            path (str "databases/" chat-id)
-            _ (io/make-parents path)
-            cfg {:store {:backend :file :scope "simm.ie/chats" :path path}}
-            conn
-            (try
-              (let [cfg (d/create-database cfg)
-                    conn (d/connect cfg)]
-                (d/transact conn default-schema)
-                conn)
-              (catch Exception _
-                (d/connect cfg)))]
-        #_(d/transact conn default-schema)
-        (swap! peer assoc-in [:conn chat-id] conn)
-        conn)))
-
-(defn conversation [db chat-id window-size]
-  (->>
-   (d/q '[:find ?d ?f ?l ?n ?t
-          :in $ ?chat
-          :where
-          [?c :chat/id ?chat]
-          [?e :message/chat ?c]
-          [?e :message/text ?t]
-          [?e :message/date ?d]
-          [?e :message/from ?u]
-          [(get-else $ ?u :from/username "") ?n]
-          [(get-else $ ?u :from/first_name "") ?f]
-          [(get-else $ ?u :from/last_name "") ?l]]
-        db chat-id)
-   (sort-by first)
-   (take-last window-size)
-   (map (fn [[d f l n t]] (str d " " f " " l " (" n "): " (str/replace t #"\n" " "))))
-   (str/join "\n")))
-
-(defn extract-tags [text]
-  (vec (distinct (map second (re-seq #"\[\[([^\[\]]+)\](\[.+\])?\]" text)))))
-
-(defn msg->txs [message]
-  (let [{:keys [message_id from chat date text]} message
-        tags (when text (extract-tags text))]
-    (vec
-     (concat
-      (when from
-        [(let [{:keys [id is_bot first_name last_name username language_code]} from]
-           (merge
-            {:from/id (long id)
-             :from/is_bot is_bot}
-            (when username
-              {:from/username username})
-            (when language_code
-              {:from/language_code language_code})
-            (when first_name
-              {:from/first_name first_name})
-            (when last_name
-              {:from/last_name last_name})))])
-      (when chat
-        [(let [{:keys [id first_name username type title all_members_are_administrators]} chat]
-           (merge
-            {:chat/id (long id)
-             :chat/type type}
-            (when username
-              {:chat/username username})
-            (when first_name
-              {:chat/first_name first_name})
-            (when title
-              {:chat/title title})
-            (when all_members_are_administrators
-              {:chat/all_members_are_administrators all_members_are_administrators})))])
-      [(merge
-        {:message/id (long message_id)
-         :message/from [:from/id (long (:id from))]
-         :message/chat [:chat/id (long (:id chat))]
-         :message/date (java.util.Date. (long (* 1000 date)))}
-        (when text
-          {:message/text text})
-        (when (seq tags)
-          {:message/tag tags}))]))))
-
-(def window-size 10)
-
 (defn summarize [S conn conv chat]
   (go-try S
           (debug "=========================== SUMMARIZING ===============================")
@@ -175,7 +91,7 @@
     (.close zip-out)
     zip-file))
 
-(defn relational-assistance
+(defn assistance
   "This interpreter can derive facts and effects through a relational database."
   [[S peer [in out]]]
   ;; pass everything from in to next-in for the next middleware
diff --git a/src/ie/simm/runtimes/notes.clj b/src/ie/simm/runtimes/notes.clj
index 8e1ceba..3474a4f 100644
--- a/src/ie/simm/runtimes/notes.clj
+++ b/src/ie/simm/runtimes/notes.clj
@@ -1,22 +1,241 @@
 (ns ie.simm.runtimes.notes
-  "Note taking runtime.
+  "Active conversation mode that tries to extract factual and procedural knowledge from the user for later use in reasoning and recall.
    
    Properties: stateful, persistent, durable"
   (:require [ie.simm.languages.bindings :as lb]
             [ie.simm.languages.gen-ai :refer [cheap-llm reasoner-llm stt-basic image-gen]]
+            [ie.simm.languages.web-search :refer [search]]
+            [ie.simm.languages.browser :refer [extract-body]]
+            [ie.simm.languages.chat :refer [send-text! send-photo! send-document!]]
             [ie.simm.prompts :as pr]
-            [superv.async :refer [<?? go-try S go-loop-try <? >? put?]]
-            [clojure.core.async :refer [chan pub sub mult tap timeout]]
+            [ie.simm.db :refer [ensure-conn conversation extract-tags msg->txs window-size]]
+            [superv.async :refer [<?? go-try S go-loop-try <? >? put? go-for] :as sasync]
+            [clojure.core.async :refer [chan pub sub mult tap timeout] :as async]
             [taoensso.timbre :refer [debug info warn error]]
             [datahike.api :as d]
             [hasch.core :refer [uuid]]
             [clojure.string :as str]
-            [clojure.java.io :as io]))
+            [clojure.java.io :as io]
+            [etaoin.api :as e])
+  (:import [java.util.zip ZipEntry ZipOutputStream]))
 
-(defn summarize [conv]
+(defn summarize [S conn conv chat]
   (go-try S
-          (let [summarization  (<? S (reasoner-llm (format pr/summarization conv))) ]
-            #_(<? S (send-text! (:id chat) (str "Note on recent conversation:\n" summarization)))
-            #_(debug "with tags" (extract-tags summarization))
-            summarization
-            )))
\ No newline at end of file
+          (debug "=========================== SUMMARIZING ===============================")
+          (let [db @conn
+                summarization  (<? S (reasoner-llm (format pr/summarization conv)))
+                messages (->> (d/q '[:find ?d ?e
+                                     :in $ ?chat
+                                     :where
+                                     [?c :chat/id ?chat]
+                                     [?e :message/chat ?c]
+                                     [?e :message/date ?d]]
+                                   db (:id chat))
+                              (sort-by first)
+                              (take-last window-size)
+                              (map second))
+                note-titles (extract-tags summarization)
+                _ (debug "=========================== CREATING NOTES ===============================")
+                new-notes
+                (<? S (async/into []
+                                  (go-for S [[i note] (partition 2 (interleave (iterate inc 2) note-titles))
+                                             :let [[nid body] (first (d/q '[:find ?n ?b :in $ ?t :where [?n :note/title ?t] [(get-else $ ?n :note/body "EMPTY") ?b]] db note))
+                                                   prompt (format pr/note note body summarization #_conv)
+                                                   new-body (<? S (reasoner-llm prompt))]
+                                             :when (not (.contains new-body "SKIP"))
+                                             :let [new-refs (extract-tags new-body)
+                                                   ref-ids (mapv first (d/q '[:find ?n
+                                                                              :in $ [?t ...]
+                                                                              :where
+                                                                              [?n :note/title ?t]]
+                                                                            db new-refs))]]
+                                          {:db/id (or nid (- i))
+                                           :note/title note
+                                           :note/body new-body
+                                           :note/link ref-ids
+                                           :note/summary -1})))]
+            (debug "=========================== STORING NOTES ===============================")
+            (debug "Summarization:" summarization)
+            (debug "summarization tags" (extract-tags summarization))
+            (d/transact conn (concat
+                              [{:db/id -1
+                                :conversation/summary summarization
+                                :conversation/tag (extract-tags summarization)
+                                :conversation/message messages}]
+                              new-notes))
+                              ;; keep exports up to date
+            (doseq [[t b] (map (fn [{:keys [note/title note/body]}] [title body]) new-notes)]
+              (debug "writing note" t)
+              ;; write to org file in notes/chat-id/title.org
+              (let [f (io/file (str "notes/" (:id chat) "/" t ".org"))]
+                (io/make-parents f)
+                (with-open [w (io/writer f)]
+                  (binding [*out* w]
+                    (println b)))))
+            (extract-tags summarization))))
+
+(defn zip-notes [chat-id]
+  (let [zip-file (io/file (str "notes/" chat-id ".zip"))
+        zip-out (io/output-stream zip-file)
+        zip (ZipOutputStream. zip-out)
+        notes-dir (io/file (str "notes/" chat-id))
+        _ (io/make-parents notes-dir)
+        _ (io/make-parents zip-file)
+        _ (doseq [f (rest (file-seq notes-dir))]
+            (let [entry (ZipEntry. (str chat-id "/" (.getName f)))]
+              (.putNextEntry zip entry)
+              (with-open [in (io/input-stream f)]
+                (io/copy in zip))
+              (.closeEntry zip)))]
+    (.close zip)
+    (.close zip-out)
+    zip-file))
+
+(defn notes
+  [[S peer [in out]]]
+  ;; pass everything from in to next-in for the next middleware
+  ;; and create publication channel for runtime context
+  (let [mi (mult in)
+        next-in (chan)
+        _ (tap mi next-in)
+        pub-in (chan)
+        _ (tap mi pub-in)
+        pi (pub pub-in :type)
+
+       ;; subscriptions for this runtime context
+        msg-ch (chan 1000)
+        _ (sub pi :ie.simm.runtimes.telegram/message msg-ch)
+
+       ;; do the same in reverse for outputs from below
+        prev-out (chan)
+        mo (mult prev-out)
+        _ (tap mo out)
+        pub-out (chan)
+        _ (tap mo pub-out)
+        po (pub pub-out :type)]
+    ;; we will continuously interpret the messages
+    (go-loop-try S [m (<? S msg-ch)]
+                 (when m
+                   (binding [lb/*chans* [next-in pi out po]]
+                     (let [{:keys [msg]
+                            {:keys [chat from]} :msg} m]
+                       (try
+                         (let [conn (ensure-conn peer (:id chat))
+
+                           ;; 1. add new facts from messages
+                               _ (d/transact conn (msg->txs msg))
+                               _ (debug "transacted")
+                           ;; 2. recent conversation
+                               conv (conversation @conn (:id chat) window-size)
+                               _ (debug "conversation" conv)
+                               _ (debug "message count" (d/q '[:find (count ?m) .
+                                                               :in $ ?cid
+                                                               :where
+                                                               [?m :message/chat ?c]
+                                                               [?c :chat/id ?cid]]
+                                                             @conn (:id chat)))
+                               _ (when (<= (mod (d/q '[:find (count ?m) .
+                                                       :in $ ?cid
+                                                       :where
+                                                       [?m :message/chat ?c]
+                                                       [?c :chat/id ?cid]]
+                                                     @conn (:id chat))
+                                                window-size) 1)
+                                   (summarize S conn conv chat))
+
+
+                           ;; 3. retrieve summaries for active tags
+                               all-tags (d/q '[:find [?t ...] :where [_ :conversation/tag ?t]] @conn)
+                               relevant (<? S (cheap-llm (format "You are given the following tags in brackets [[some tag]]:\n\n%s\n\nList the most relevant tags for the following conversation with descending priority.\n\n%s"
+                                                                 (str/join ", " (map #(str "[[" % "]]") all-tags))
+                                                                 conv)))
+                               active-tags (concat (take 3 (extract-tags relevant)) [firstname])
+
+                               summaries (d/q '[:find ?t ?s
+                                                :in $ [?t ...]
+                                                :where
+                                                [?c :note/title ?t]
+                                                [?c :note/body ?s]]
+                                              @conn (concat active-tags (extract-tags conv)))
+                               _ (debug "active tags" #_summaries active-tags)
+
+                          ;; 4. derive reply
+                               assist-prompt (format pr/assistance 
+                                                     (str/join "\n\n" (map (fn [[t s]] (format "Title: %s\nBody: %s" t s))
+                                                                           summaries)) 
+                                                     conv
+                                                     (str (java.util.Date.)))
+                               _ (debug "prompt" assist-prompt)
+                               reply (<? S (reasoner-llm assist-prompt))
+                               _ (debug "reply" reply)
+
+                               ;; 5. dispatch
+                               _ (when-let [prompt (second (re-find #"IMAGEGEN\(['\"](.*)['\"]\)" reply))]
+                                   (let [url (<? S (image-gen prompt))]
+                                     (debug "generated image" url)
+                                     (d/transact conn (msg->txs (:result (<? S (send-photo! (:id chat) url)))))))
+
+                               _ (when-let [title (second (re-find #"ADD_ISSUE\(['\"](.*)['\"]\)" reply))]
+                                   (debug "adding issue" title)
+                                   (d/transact conn [{:db/id -1 :issue/title title}])
+                                   (d/transact conn (msg->txs (:result (<? S (send-text! (:id chat) (str "Added issue: " title)))))))
+
+                               _ (when-let [title (second (re-find #"REMOVE_ISSUE\(['\"](.*)['\"]\)" reply))]
+                                   (if-let [eid (d/q '[:find ?i . :in $ ?t :where [?i :issue/title ?t]] @conn title)]
+                                     (do
+                                       (debug "removing issue" title eid)
+                                       (d/transact conn [[:db/retractEntity eid]])
+                                       (d/transact conn (msg->txs (:result (<? S (send-text! (:id chat) (str "Removed issue: " title)))))))
+                                     (d/transact conn (msg->txs (:result (<? S (send-text! (:id chat) (str "Could not find issue: " title))))))))
+
+                               _ (when (or (.contains reply "LIST_ISSUES") (.contains reply "DAILY"))
+                                   (debug "listing issues")
+                                   (let [issues (d/q '[:find [?t ...] :where [_ :issue/title ?t]] @conn)]
+                                     (d/transact conn (msg->txs (:result (<? S (send-text! (:id chat) (str "Issues:\n" (str/join "\n" (map #(format "* %s" %) issues))))))))))
+
+                               _ (when (.contains reply "SEND_NOTES")
+                               ;; TODO transact document info
+                                   (<? S (send-document! (:id chat) (zip-notes (:id chat))))
+                                   (d/transact conn (msg->txs (:result (<? S (send-text! (:id chat) "Done."))))))
+
+                               _ (when-let [title (second (re-find #"RETRIEVE_NOTE\(['\"](.*)['\"]\)" reply))]
+                                   (if-let [body (d/q '[:find ?b . :in $ ?t :where [?n :note/title ?t] [?n :note/body ?b]] @conn title)]
+                                     (do
+                                       (debug "retrieved note" title body)
+                                       (d/transact conn (msg->txs (:result (<? S (send-text! (:id chat) (str "Retrieved " title "\n" body)))))))
+                                     (d/transact conn (msg->txs (:result (<? S (send-text! (:id chat) (str "Could not find note: " title))))))))
+
+                               _ (when (.contains reply "LIST_NOTES")
+                                   (debug "listing notes")
+                                   (let [issues (d/q '[:find [?t ...] :where [_ :note/title ?t]] @conn)]
+                                     (d/transact conn (msg->txs (:result (<? S (send-text! (:id chat) (str "Notes:\n" (str/join "\n" (map #(format "* %s" %) issues))))))))))
+
+
+                               _ (if (or (.contains reply "QUIET") (.contains reply "IMAGEGEN") (.contains reply "LIST_ISSUES") (.contains reply "ADD_ISSUE") 
+                                         (.contains reply "REMOVE_ISSUE") (.contains reply "SEND_NOTES") (.contains reply "RETRIEVE_NOTE") (.contains reply "LIST_NOTES"))
+                                   (debug "No reply necessary")
+                                   (let [reply (if-let [terms (second (re-find #"WEBSEARCH\(['\"](.*)['\"]\)" reply))]
+                                                 (let [url (<? S (search terms))
+                                                       body (<? S (extract-body url))
+                                                       prompt (format pr/search (conversation @conn (:id chat) 5) body)
+                                                       reply (<? S (cheap-llm prompt))]
+                                                   (debug "conducting web search" terms)
+                                                   (str reply "\n" url))
+                                                 (.replace reply "DAILY" ""))
+                                         send-time-ms (System/currentTimeMillis)
+                                         min-response-time 3000
+                                         too-fast-by (max 0 (- min-response-time (- send-time-ms start-time-ms)))
+                                         _ (debug "too fast by" too-fast-by)
+                                         _ (<? S (timeout too-fast-by))
+                                         reply-msg (<? S (send-text! (:id chat) reply))
+                                         _ (debug "reply-msg" reply-msg)
+                                         _ (d/transact conn (msg->txs (:result reply-msg)))]))]
+                           )
+                         (catch Exception e
+                           (let [error-id (uuid)]
+                             (error "Could not process message(" error-id "): " m e)
+                             (<? S (send-text! (:id chat) (str "Sorry, I could not process your message. Error: " error-id))))))))
+                   (recur (<? S msg-ch))))
+    ;; Note that we pass through the supervisor, peer and new channels for composition
+    [S peer [next-in prev-out]]))
+
diff --git a/src/ie/simm/runtimes/text_extractor.clj b/src/ie/simm/runtimes/text_extractor.clj
index 43018a8..94c7049 100644
--- a/src/ie/simm/runtimes/text_extractor.clj
+++ b/src/ie/simm/runtimes/text_extractor.clj
@@ -58,14 +58,20 @@
   [[S peer [in out]]]
   ;; pass everything from in to next-in for the next middleware
   ;; and create publication channel for runtime context
-  (let [pi (pub in :type)
-        next-in (chan 1000)
+  (let [mi (mult in)
+        pub-in (chan)
+        _ (tap mi pub-in)
+        ;; pub for internal function dispatch
+        pi (pub pub-in :type)
 
-        ;; subscriptions for this runtime context
-        p (pub in (fn [{:keys [type]}]
-                    (or ({:ie.simm.runtimes.telegram/message ::message} type)
-                        :unrelated)))
+        ;; internal subscriptions for this runtime context
+        pub-subs (chan)
+        _ (tap mi pub-subs)
+        p (pub pub-subs (fn [{:keys [type]}]
+                          (or ({:ie.simm.runtimes.telegram/message ::message} type)
+                              :unrelated)))
         msg-ch (chan 1000)
+        next-in (chan 1000)
         _ (sub p ::message msg-ch)
         _ (sub p :unrelated next-in)
 
diff --git a/src/ie/simm/simmie.clj b/src/ie/simm/simmie.clj
index 9acd729..3551705 100644
--- a/src/ie/simm/simmie.clj
+++ b/src/ie/simm/simmie.clj
@@ -48,7 +48,7 @@
 
   (require '[datahike.api :as d])
 
-  (require '[ie.simm.runtimes.relational-assistance :refer [conversation extract-tags]])
+  (require '[ie.simm.runtimes.assistance :refer [conversation extract-tags]])
 
   (def conv (conversation conn 79524334 20))
 
diff --git a/src/ie/simm/towers.clj b/src/ie/simm/towers.clj
index 6c22850..d9e942d 100644
--- a/src/ie/simm/towers.clj
+++ b/src/ie/simm/towers.clj
@@ -5,7 +5,7 @@
             [ie.simm.runtimes.etaoin :refer [etaoin]]
             [ie.simm.runtimes.telegram :refer [telegram long-polling]]
             [ie.simm.runtimes.text-extractor :refer [text-extractor]]
-            [ie.simm.runtimes.relational-assistance :refer [relational-assistance]]
+            [ie.simm.runtimes.assistance :refer [assistance]]
             [kabel.peer :refer [drain]]
             [clojure.core.async :refer [close!]]
             [superv.async :refer [go-loop-super <? S]]))
@@ -18,7 +18,7 @@
   [S peer [in out]])
 
 (defn default []
-  (comp drain brave etaoin openai relational-assistance text-extractor telegram codrain))
+  (comp drain brave etaoin openai assistance text-extractor telegram codrain))
 
 (defn debug [] 
   (comp drain 
@@ -29,8 +29,8 @@
         (partial report #(println "etaoin: " (:type %) (:request-id %)))
         openai
         (partial report #(println "openai: " (:type %) (:request-id %)))
-        relational-assistance
-        (partial report #(println "relational-assistance: " (:type %) (:request-id %)))
+        assistance
+        (partial report #(println "assistance: " (:type %) (:request-id %)))
         text-extractor
         (partial report #(println "text-extractor: " (:type %) (:request-id %)))
         telegram
@@ -46,8 +46,8 @@
          (partial report #(println "etaoin: " (:type %) (:request-id %)))
          openai
          (partial report #(println "openai: " (:type %) (:request-id %)))
-         relational-assistance
-         (partial report #(println "relational-assistance: " (:type %) (:request-id %)))
+         assistance
+         (partial report #(println "assistance: " (:type %) (:request-id %)))
          text-extractor
          (partial report #(println "text-extractor: " (:type %) (:request-id %)))
          (partial telegram long-polling)