pogo = require("pogo")
fs = require("fs")
through = require("through")

compile = (file) ->
  compiled = ""
  try
    compiled = pogo.compile(fs.readFileSync(file, "utf8"))
  catch e
    throw new Error("PogoScript compilation failed for '" + file + "'\n" + e.toString())
  compiled

isPogo = (file) ->
  /\.pogo$/.test file

module.exports = (file) ->
  data = ""
  write = (buf) ->
    data += buf
  end = ->
    src = undefined
    try
      src = compile(file, data)
    catch error
      @emit "error", error
    @queue src
    @queue null
  return through()  unless isPogo(file)
  return through(write, end)