             [ceres.collector :refer [store set-db] :as collector]
             [ceres.curator :refer [get-articles-count get-news-diffusion get-news-frequencies] :as curator]
             [ceres.executor :refer [start-executor]]
-            [gezwitscher.core :refer [gezwitscher]]
+            [gezwitscher.core :refer [start-filter-stream]]
             [clojure.java.io :as io]
             [clojure.core.async :refer [close! put! timeout sub chan <!! >!! <! >! go go-loop] :as async]
             [taoensso.timbre :as timbre]))

                    (send! channel (str (dispatch (read-string data)))))))))


(defn processed-tweets
  "React to incoming tweets"
  [state tweet]
  (let [articles (->> (store tweet)

  (info @server-state)
  (when (:http-server? @server-state)
    (run-server (site #'all-routes) {:port (:port @server-state) :join? false}))
  (let [{:keys [follow track handler credentials]} (:app @server-state)]
    (start-filter-stream follow track handler credentials))
  (when (:backup? @server-state)
    (start-executor (:backup-folder @server-state))))

