92b5eeb2ef
comment author = ip comment author info = origin of ip ip addr is jank ( uses php public server for ip get) fuck apache reverse proxy ip change thigy thing comment command started config stuff started planning logging system
94 lines
1.9 KiB
JavaScript
94 lines
1.9 KiB
JavaScript
// A reader for when we don't yet know what kind of thing
|
|
// the thing is.
|
|
|
|
module.exports = ProxyReader
|
|
|
|
var Reader = require("./reader.js")
|
|
, getType = require("./get-type.js")
|
|
, inherits = require("inherits")
|
|
, fs = require("graceful-fs")
|
|
|
|
inherits(ProxyReader, Reader)
|
|
|
|
function ProxyReader (props) {
|
|
var me = this
|
|
if (!(me instanceof ProxyReader)) throw new Error(
|
|
"ProxyReader must be called as constructor.")
|
|
|
|
me.props = props
|
|
me._buffer = []
|
|
me.ready = false
|
|
|
|
Reader.call(me, props)
|
|
}
|
|
|
|
ProxyReader.prototype._stat = function () {
|
|
var me = this
|
|
, props = me.props
|
|
// stat the thing to see what the proxy should be.
|
|
, stat = props.follow ? "stat" : "lstat"
|
|
|
|
fs[stat](props.path, function (er, current) {
|
|
var type
|
|
if (er || !current) {
|
|
type = "File"
|
|
} else {
|
|
type = getType(current)
|
|
}
|
|
|
|
props[type] = true
|
|
props.type = me.type = type
|
|
|
|
me._old = current
|
|
me._addProxy(Reader(props, current))
|
|
})
|
|
}
|
|
|
|
ProxyReader.prototype._addProxy = function (proxy) {
|
|
var me = this
|
|
if (me._proxyTarget) {
|
|
return me.error("proxy already set")
|
|
}
|
|
|
|
me._proxyTarget = proxy
|
|
proxy._proxy = me
|
|
|
|
; [ "error"
|
|
, "data"
|
|
, "end"
|
|
, "close"
|
|
, "linkpath"
|
|
, "entry"
|
|
, "entryEnd"
|
|
, "child"
|
|
, "childEnd"
|
|
, "warn"
|
|
, "stat"
|
|
].forEach(function (ev) {
|
|
// console.error("~~ proxy event", ev, me.path)
|
|
proxy.on(ev, me.emit.bind(me, ev))
|
|
})
|
|
|
|
me.emit("proxy", proxy)
|
|
|
|
proxy.on("ready", function () {
|
|
// console.error("~~ proxy is ready!", me.path)
|
|
me.ready = true
|
|
me.emit("ready")
|
|
})
|
|
|
|
var calls = me._buffer
|
|
me._buffer.length = 0
|
|
calls.forEach(function (c) {
|
|
proxy[c[0]].apply(proxy, c[1])
|
|
})
|
|
}
|
|
|
|
ProxyReader.prototype.pause = function () {
|
|
return this._proxyTarget ? this._proxyTarget.pause() : false
|
|
}
|
|
|
|
ProxyReader.prototype.resume = function () {
|
|
return this._proxyTarget ? this._proxyTarget.resume() : false
|
|
}
|