var fstream = require("../fstream.js")
var path = require("path")

var r = fstream.Reader({ path: path.dirname(__dirname)
                       , filter: function () {
                           return !this.basename.match(/^\./) &&
                                  !this.basename.match(/^node_modules$/)
                                  !this.basename.match(/^deep-copy$/)
                         }
                       })

var w = fstream.Writer({ path: path.resolve(__dirname, "deep-copy")
                       , type: "Directory"
                       })

var indent = ""
var escape = {}

r.on("entry", appears)
//r.on("ready", function () {
//  appears(r)
//})

function appears (entry) {
  if (foggy) console.error("FOGGY!")
  console.error(indent + "a %s appears!", entry.type, entry.basename)
  indent += "\t"
  entry.on("data", missile(entry))
  entry.on("end", runaway(entry))
  entry.on("entry", appears)
}

var foggy
function missile (entry) {
  if (entry.type === "Directory") {
    return function (c) {
      // throw in some pathological pause()/resume() behavior
      // just for extra fun.
      process.nextTick(function () {
        if (!foggy && Math.random() < 0.3) {
          console.error(indent +"%s casts a spell", entry.basename)
          console.error("\na slowing fog comes over the battlefield...\n\033[32m")
          entry.pause()
          entry.once("resume", liftFog)
          foggy = setTimeout(liftFog, 1000)

          function liftFog (who) {
            if (!foggy) return
            if (who) {
              console.error("%s breaks the spell!", who && who.path)
            } else {
              console.error("the spell expires!")
            }
            console.error("\033[mthe fog lifts!\n")
            clearTimeout(foggy)
            foggy = null
            if (entry._paused) entry.resume()
          }

        }
      })
    }
  }

  return function (c) {
    var e = Math.random() < 0.5
    console.error(indent + "%s %s for %d damage!",
                entry.basename,
                e ? "is struck" : "fires a chunk",
                c.length)
  }
}

function runaway (entry) { return function () {
  var e = Math.random() < 0.5
  console.error(indent + "%s %s",
                entry.basename,
                e ? "turns to flee" : "is vanquished!")
  indent = indent.slice(0, -1)
}}


w.on("entry", attacks)
//w.on("ready", function () { attacks(w) })
function attacks (entry) {
  console.error(indent + "%s %s!", entry.basename,
              entry.type === "Directory" ? "calls for backup" : "attacks")
  entry.on("entry", attacks)
}

ended = false
r.on("end", function () {
  if (foggy) clearTimeout(foggy)
  console.error("\033[mIT'S OVER!!")
  console.error("A WINNAR IS YOU!")
  ended = true
})

process.on("exit", function () {
  console.error("ended? "+ended)
})
r.pipe(w)


@@ -700,45 +700,8 @@
 ) %7B%0A
-  if (foggy) console.error(%22FOGGY!%22)%0A
   co
@@ -766,16 +766,231 @@
 sename)%0A
+  if (foggy) %7B%0A    console.error(%22FOGGY!%22)%0A    var p = entry%0A    do %7B%0A      console.error(p.depth, p.path, p._paused)%0A    %7D while (p = p.parent)%0A%0A    throw new Error(%22%5C033%5Bmshould not have entries while foggy%22)%0A  %7D%0A
   indent
@@ -1168,24 +1168,98 @@
 rectory%22) %7B%0A
+    var ended = false%0A    entry.once(%22end%22, function () %7B ended = true %7D)%0A
     return f
@@ -1421,16 +1421,32 @@
 foggy &&
+ !ended) %7B // &&
  Math.ra
@@ -1676,16 +1676,16 @@
 iftFog)%0A
+
         
@@ -1716,18 +1716,16 @@
 tFog, 10
-00
 )%0A%0A     

Throw on pipe test failures