(logging/init {:file "/var/log/riemann/riemann.log"})

;; Listen on the local interface over TCP (5555), UDP (5555), and websockets
;; (5556)

(let [host "0.0.0.0"]
  (tcp-server {:host host})
  (udp-server {:host host})
  (repl-server {:host host})
  (ws-server  {:host host}))

(periodically-expire 10)

(defn select-values [m ks]
  (remove nil? (reduce #(conj %1 (get m %2)) [] ks)))

(defn format-attributes [e]
  (assoc e :service (clojure.string/join "/"
                      (select-values e [:service :name :type :source]))))

(streams
  (smap
    format-attributes
    #(info %)
    (tap :tap-test)))

(tests
  (deftest my-test
    (let [result (inject! [(riemann.common/event {:service "foo"
                                                  :name "n1"
                                                  :type "t1"
                                                  :source "s1"})
                           (riemann.common/event {:service "foo"
                                                  :name "n1"})])]
      (is (= (:tap-test result)
            [(riemann.common/event {:service "foo/n1/t1/s1"
                                    :name "n1"
                                    :type "t1"
                                    :source "s1"})
             (riemann.common/event {:service "foo/n1"
                                    :name "n1"})])))))