taskrunner.clj

(task update-version
  "Updates version of the software"
  (start [:shell (str *src-dir* "update-version.sh")])
  (stop :kill))

(task run-zookeeper
  "Runs zookeeper"
  (depends-on update-version)
  (start [:shell (str *base-dir* "bin/zookeeper.sh")]
         [:finish-when :stdout :regexp "\\.started\\."])
  (stop :kill))

(task run-kafka
  "Runs kafka"
  (depends-on run-zookeeper)
  (start [:shell (str *base-dir* "bin/kafka.sh")]
         [:finish-when :stdout :regexp "\\.started\\."])
  (stop :kill))

(task run-broker
  "Runs broker"
  (depends-on run-kafka)
  (start [:shell (str *src-dir* "broker/start.sh")]
         [:finish-when (file *src-dir* "broker/logs.log") :regexp "\\.started\\."])
  (stop [:http-request "http://localhost:5000/stop"]))


(task run-consumer-db
  "Runs consumer-db"
  (depends-on run-kafka)
  (start [:shell (str *src-dir* "consumer-db/start.sh")]
         [:finish-when :stderr :regexp "\\.started\\."])
  (stop [:http-request "http://localhost:5001/stop"]))

(task run-tests
  (depends-on run-broker run-consumer-db)
  (start [:shell (str *src-dir* "tests/start.sh")]))