test.clj

(ns riemann.test.nagios
  (:use riemann.nagios
        clj-nsca.core
        clojure.test)
  (:require [riemann.logging :as logging]))

(logging/init)

(def test-event
  {:host "host01" :service "test_service" :state "ok" :description "Quick brown fox"})

(def expected
  (let [e test-event]
    (nagios-message (:host e) (:state e) (:service e) (:description e))))

(deftest test-event-to-nagios
  (is (= (event->nagios test-event)
                        expected)))

(deftest test-stream
  (let [calls (atom [])] (with-redefs [clj-nsca.core/send-message (fn [& args] (swap! calls conj args))]
                           ((nagios {}) test-event))
    (is (= expected (last (last @calls))))))