circular-:(.js

var shoe = require("shoe")
    , MuxDemux = require("mux-demux")
    , curry = require("ap").curry
    , PauseStream = require("pause-stream")
    , reemit = curry(function (stream, message) {
        stream.emit(message)
    })

module.exports = createOuterStream

function createOuterStream(uri, reconnect) {
    var mdm = MuxDemux()
        , innerPause = PauseStream()

    innerPause.on("connect", reemit(mdm, "connect"))

    innerPause.pipe(mdm).pipe(innerPause, {
        end: false
    })

    createShoeStream(uri, reconnect, innerPause)

    return mdm
}

function createShoeStream(uri, reconnect, outer) {
    var stream = shoe(uri)
    outer.pause()
    stream.on("connect", outer.resume.bind(outer))
    stream.on("connect", reemit(outer, "connect"))

    outer.pipe(stream).pipe(outer, {
        end: false
    })

    if (reconnect) {
        stream.on("end", onend)
    }

    return outer

    function onend() {
        console.log("STREAM ENDED")
        stream.destroy()
        createShoeStream(uri, reconnect, outer)
        outer.emit("disconnect")
    }
}