zookeeper.scala

  def zookeeper: Future[Map[String, String]] = async {
    val writeback = ZooKeeper.WritebackPathPrefix.split("/").filterNot(_.isEmpty).toSeq
    def join(l: Seq[String]) = l.mkString("/")
    def nodes(parent: Seq[String], node: String): Seq[Seq[String]] = {
      (parent :+ node) match {
        case `writeback` => Seq()
        case path => path +: ZooKeeper.getChildren(join(path)).flatMap(node => nodes(path, node))
      }
    }
    nodes(Seq(), services.ZooKeeperService.BasePath.stripPrefix("/"))
      .map(join).map { node => (node, ZooKeeper.get(node)) }.filter(_._2.isDefined).toMap.mapValues(_.get)
  }