<p>Retreives an agent from the <code>http</code> module
and sets the <code>maxSockets</code> property appropriately.</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="kd">function</span><spanclass="nx">_getAgent</span><spanclass="p">(</span><spanclass="nx">host</span><spanclass="p">,</span><spanclass="nx">port</span><spanclass="p">)</span><spanclass="p">{</span></pre></div></td></tr><trid="section-3"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-3">¶</a></div><p>TODO (indexzero): Make this configurable for http / https</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="kd">var</span><spanclass="nx">agent</span><spanclass="o">=</span><spanclass="nx">http</span><spanclass="p">.</span><spanclass="nx">getAgent</span><spanclass="p">(</span><spanclass="nx">host</span><spanclass="p">,</span><spanclass="nx">port</span><spanclass="p">);</span>
allowed on <strong>every</strong> outgoing request
made by <strong>all</strong> instances of <code>HttpProxy</code></p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">exports</span><spanclass="p">.</span><spanclass="nx">getMaxSockets</span><spanclass="o">=</span><spanclass="kd">function</span><spanclass="p">()</span><spanclass="p">{</span>
allowed on <strong>every</strong> outgoing request
made by <strong>all</strong> instances of <code>HttpProxy</code></p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">exports</span><spanclass="p">.</span><spanclass="nx">setMaxSockets</span><spanclass="o">=</span><spanclass="kd">function</span><spanclass="p">(</span><spanclass="nx">value</span><spanclass="p">)</span><spanclass="p">{</span>
<spanclass="k">throw</span><spanclass="k">new</span><spanclass="nb">Error</span><spanclass="p">(</span><spanclass="s1">'Cannot create server with no router and no callback'</span><spanclass="p">);</span>
<spanclass="nx">winston</span><spanclass="p">.</span><spanclass="nx">verbose</span><spanclass="p">(</span><spanclass="s1">'Incoming HTTP request to: '</span><spanclass="o">+</span><spanclass="nx">req</span><spanclass="p">.</span><spanclass="nx">headers</span><spanclass="p">.</span><spanclass="nx">host</span><spanclass="o">+</span><spanclass="nx">req</span><spanclass="p">.</span><spanclass="nx">url</span><spanclass="p">);</span></pre></div></td></tr><trid="section-7"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-7">¶</a></div><p>If we were passed a callback to process the request
or response in some way, then call it.</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="k">if</span><spanclass="p">(</span><spanclass="nx">callback</span><spanclass="p">)</span><spanclass="p">{</span>
<spanclass="nx">winston</span><spanclass="p">.</span><spanclass="nx">verbose</span><spanclass="p">(</span><spanclass="s1">'Proxying HTTP request to: '</span><spanclass="o">+</span><spanclass="nx">host</span><spanclass="o">+</span><spanclass="s1">':'</span><spanclass="o">+</span><spanclass="nx">port</span><spanclass="p">);</span>
<spanclass="nx">winston</span><spanclass="p">.</span><spanclass="nx">verbose</span><spanclass="p">(</span><spanclass="s1">'Proxying request using proxy table'</span><spanclass="p">);</span>
<spanclass="k">throw</span><spanclass="k">new</span><spanclass="nb">Error</span><spanclass="p">(</span><spanclass="s1">'Cannot proxy without port, host, or router.'</span><spanclass="p">)</span>
<spanclass="k">if</span><spanclass="p">(</span><spanclass="o">!</span><spanclass="nx">callback</span><spanclass="p">)</span><spanclass="p">{</span></pre></div></td></tr><trid="section-8"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-8">¶</a></div><p>WebSocket support: if callback is empty tunnel
<spanclass="p">};</span></pre></div></td></tr><trid="section-11"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-11">¶</a></div><p>Inherit from events.EventEmitter</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">util</span><spanclass="p">.</span><spanclass="nx">inherits</span><spanclass="p">(</span><spanclass="nx">HttpProxy</span><spanclass="p">,</span><spanclass="nx">events</span><spanclass="p">.</span><spanclass="nx">EventEmitter</span><spanclass="p">);</span></pre></div></td></tr><trid="section-12"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-12">¶</a></div><h3>function pause (obj)</h3>
<h4>@obj {Object} Object to pause events from</h4>
<p>Pause <code>data</code> and <code>end</code> events on the given <code>obj</code>.
Consumers of HttpProxy performing async tasks
<strong>must</strong> utilize this utility, to re-emit data once
the async operation has completed, otherwise these
However, this is not a big leap from the implementation in node-http-proxy < 0.4.0.
This simply chooses to manage the scope of the events on a new Object literal as opposed to
<ahref="https://github.com/nodejitsu/node-http-proxy/blob/v0.3.1/lib/node-http-proxy.js#L154">on the HttpProxy instance</a>.</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">HttpProxy</span><spanclass="p">.</span><spanclass="nx">prototype</span><spanclass="p">.</span><spanclass="nx">pause</span><spanclass="o">=</span><spanclass="kd">function</span><spanclass="p">(</span><spanclass="nx">obj</span><spanclass="p">)</span><spanclass="p">{</span>
<spanclass="p">};</span></pre></div></td></tr><trid="section-13"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-13">¶</a></div><h3>function close ()</h3>
<p>Frees the resources associated with this instance,
if they exist. </p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">HttpProxy</span><spanclass="p">.</span><spanclass="nx">prototype</span><spanclass="p">.</span><spanclass="nx">close</span><spanclass="o">=</span><spanclass="kd">function</span><spanclass="p">()</span><spanclass="p">{</span>
<h4>@req {ServerRequest} Incoming HTTP Request to proxy.</h4>
<h4>@res {ServerResponse} Outgoing HTTP Request to write proxied data to.</h4>
<h4>@port {number} <strong>Optional</strong> Port to use on the proxy target host.</h4>
<h4>@host {string} <strong>Optional</strong> Host of the proxy target.</h4>
<h4>@paused {Object} <strong>Optional</strong> Result from <code>httpProxy.pause(req)</code></h4></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">HttpProxy</span><spanclass="p">.</span><spanclass="nx">prototype</span><spanclass="p">.</span><spanclass="nx">proxyRequest</span><spanclass="o">=</span><spanclass="kd">function</span><spanclass="p">(</span><spanclass="nx">req</span><spanclass="p">,</span><spanclass="nx">res</span><spanclass="p">,</span><spanclass="nx">port</span><spanclass="p">,</span><spanclass="nx">host</span><spanclass="p">,</span><spanclass="nx">paused</span><spanclass="p">)</span><spanclass="p">{</span>
</pre></div></td></tr><trid="section-15"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-15">¶</a></div><p>Check the proxy table for this instance to see if we need
to get the proxy location for the request supplied. We will
always ignore the proxyTable if an explicit <code>port</code> and <code>host</code>
arguments are supplied to <code>proxyRequest</code>.</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="k">if</span><spanclass="p">(</span><spanclass="k">this</span><spanclass="p">.</span><spanclass="nx">proxyTable</span><spanclass="o">&&</span><spanclass="o">!</span><spanclass="nx">host</span><spanclass="p">)</span><spanclass="p">{</span>
</pre></div></td></tr><trid="section-16"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-16">¶</a></div><p>If no location is returned from the ProxyTable instance
then respond with <code>404</code> since we do not have a valid proxy target.</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="k">if</span><spanclass="p">(</span><spanclass="o">!</span><spanclass="nx">location</span><spanclass="p">)</span><spanclass="p">{</span>
</pre></div></td></tr><trid="section-17"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-17">¶</a></div><p>When using the ProxyTable in conjunction with an HttpProxy instance
only the following arguments are valid:</p>
<ul>
<li><code>proxy.proxyRequest(req, res, port, host, paused)</code>: This will be skipped</li>
<li><code>proxy.proxyRequest(req, res, paused)</code>: Paused will get updated appropriately</li>
<li><code>proxy.proxyRequest(req, res)</code>: No effect <code>undefined = undefined</code></li>
</pre></div></td></tr><trid="section-18"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-18">¶</a></div><p>If forwarding is enabled for this instance, foward proxy the
specified request to the address provided in <code>this.options.forward</code></p></td><tdclass="code"><divclass="highlight"><pre><spanclass="k">if</span><spanclass="p">(</span><spanclass="k">this</span><spanclass="p">.</span><spanclass="nx">options</span><spanclass="p">.</span><spanclass="nx">forward</span><spanclass="p">)</span><spanclass="p">{</span>
<spanclass="nx">winston</span><spanclass="p">.</span><spanclass="nx">verbose</span><spanclass="p">(</span><spanclass="s1">'Forwarding HTTP request to: '</span><spanclass="o">+</span><spanclass="k">this</span><spanclass="p">.</span><spanclass="nx">options</span><spanclass="p">.</span><spanclass="nx">forward</span><spanclass="p">.</span><spanclass="nx">host</span><spanclass="o">+</span><spanclass="s1">':'</span><spanclass="o">+</span><spanclass="k">this</span><spanclass="p">.</span><spanclass="nx">options</span><spanclass="p">.</span><spanclass="nx">forward</span><spanclass="p">.</span><spanclass="nx">port</span><spanclass="p">);</span>
<spanclass="nx">res</span><spanclass="p">.</span><spanclass="nx">write</span><spanclass="p">(</span><spanclass="s1">'An error has occurred: '</span><spanclass="o">+</span><spanclass="nx">JSON</span><spanclass="p">.</span><spanclass="nx">stringify</span><spanclass="p">(</span><spanclass="nx">err</span><spanclass="p">));</span>
</pre></div></td></tr><trid="section-19"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-19">¶</a></div><p>Open new HTTP request to internal resource with will act as a reverse proxy pass</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">reverseProxy</span><spanclass="o">=</span><spanclass="nx">http</span><spanclass="p">.</span><spanclass="nx">request</span><spanclass="p">({</span>
</pre></div></td></tr><trid="section-20"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-20">¶</a></div><p>Process the reverse_proxy response when it's received.</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="k">if</span><spanclass="p">(</span><spanclass="nx">response</span><spanclass="p">.</span><spanclass="nx">headers</span><spanclass="p">.</span><spanclass="nx">connection</span><spanclass="p">)</span><spanclass="p">{</span>
<spanclass="p">}</span></pre></div></td></tr><trid="section-21"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-21">¶</a></div><p>Set the response headers of the client response</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">res</span><spanclass="p">.</span><spanclass="nx">writeHead</span><spanclass="p">(</span><spanclass="nx">response</span><spanclass="p">.</span><spanclass="nx">statusCode</span><spanclass="p">,</span><spanclass="nx">response</span><spanclass="p">.</span><spanclass="nx">headers</span><spanclass="p">);</span></pre></div></td></tr><trid="section-22"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-22">¶</a></div><p>Status code = 304
No 'data' event and no 'end'</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="k">if</span><spanclass="p">(</span><spanclass="nx">response</span><spanclass="p">.</span><spanclass="nx">statusCode</span><spanclass="o">===</span><spanclass="mi">304</span><spanclass="p">)</span><spanclass="p">{</span>
<spanclass="p">}</span></pre></div></td></tr><trid="section-23"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-23">¶</a></div><p>Add event handler for the proxied response in chunks</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">response</span><spanclass="p">.</span><spanclass="nx">on</span><spanclass="p">(</span><spanclass="s1">'data'</span><spanclass="p">,</span><spanclass="kd">function</span><spanclass="p">(</span><spanclass="nx">chunk</span><spanclass="p">)</span><spanclass="p">{</span>
<spanclass="p">});</span></pre></div></td></tr><trid="section-24"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-24">¶</a></div><p>Add event listener for end of proxied response</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">response</span><spanclass="p">.</span><spanclass="nx">on</span><spanclass="p">(</span><spanclass="s1">'end'</span><spanclass="p">,</span><spanclass="kd">function</span><spanclass="p">()</span><spanclass="p">{</span>
</pre></div></td></tr><trid="section-25"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-25">¶</a></div><p>Add a listener for the connection timeout event</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">reverseProxy</span><spanclass="p">.</span><spanclass="nx">once</span><spanclass="p">(</span><spanclass="s1">'error'</span><spanclass="p">,</span><spanclass="nx">proxyError</span><spanclass="p">);</span>
</pre></div></td></tr><trid="section-26"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-26">¶</a></div><p>Chunk the client request body as chunks from the proxied request come in</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">req</span><spanclass="p">.</span><spanclass="nx">on</span><spanclass="p">(</span><spanclass="s1">'data'</span><spanclass="p">,</span><spanclass="kd">function</span><spanclass="p">(</span><spanclass="nx">chunk</span><spanclass="p">)</span><spanclass="p">{</span>
<spanclass="p">});</span></pre></div></td></tr><trid="section-27"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-27">¶</a></div><p>At the end of the client request, we are going to stop the proxied request</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">req</span><spanclass="p">.</span><spanclass="nx">on</span><spanclass="p">(</span><spanclass="s1">'end'</span><spanclass="p">,</span><spanclass="kd">function</span><spanclass="p">()</span><spanclass="p">{</span>
</pre></div></td></tr><trid="section-28"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-28">¶</a></div><p>Open new HTTP request to internal resource with will act as a reverse proxy pass</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">forwardProxy</span><spanclass="o">=</span><spanclass="nx">http</span><spanclass="p">.</span><spanclass="nx">request</span><spanclass="p">({</span>
<spanclass="p">},</span><spanclass="kd">function</span><spanclass="p">(</span><spanclass="nx">response</span><spanclass="p">)</span><spanclass="p">{</span></pre></div></td></tr><trid="section-29"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-29">¶</a></div><p>Ignore the response from the forward proxy since this is a 'fire-and-forget' proxy.
Remark (indexzero): We will eventually emit a 'forward' event here for performance tuning.</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="p">});</span>
</pre></div></td></tr><trid="section-30"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-30">¶</a></div><p>Add a listener for the connection timeout event.</p>
<p>Remark: Ignoring this error in the event
forward target doesn't exist.</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">forwardProxy</span><spanclass="p">.</span><spanclass="nx">on</span><spanclass="p">(</span><spanclass="s1">'error'</span><spanclass="p">,</span><spanclass="kd">function</span><spanclass="p">(</span><spanclass="nx">err</span><spanclass="p">)</span><spanclass="p">{</span><spanclass="p">});</span></pre></div></td></tr><trid="section-31"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-31">¶</a></div><p>Chunk the client request body as chunks from the proxied request come in</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">req</span><spanclass="p">.</span><spanclass="nx">on</span><spanclass="p">(</span><spanclass="s1">'data'</span><spanclass="p">,</span><spanclass="kd">function</span><spanclass="p">(</span><spanclass="nx">chunk</span><spanclass="p">)</span><spanclass="p">{</span>
<spanclass="p">})</span></pre></div></td></tr><trid="section-32"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-32">¶</a></div><p>At the end of the client request, we are going to stop the proxied request</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">req</span><spanclass="p">.</span><spanclass="nx">on</span><spanclass="p">(</span><spanclass="s1">'end'</span><spanclass="p">,</span><spanclass="kd">function</span><spanclass="p">()</span><spanclass="p">{</span>
<spanclass="nx">headers</span><spanclass="o">=</span><spanclass="k">new</span><spanclass="nx">_headers</span><spanclass="p">(</span><spanclass="nx">req</span><spanclass="p">.</span><spanclass="nx">headers</span><spanclass="p">),</span><spanclass="nx">CRLF</span><spanclass="o">=</span><spanclass="s1">'\r\n'</span><spanclass="p">;</span></pre></div></td></tr><trid="section-33"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-33">¶</a></div><p>Will generate clone of headers
To not change original</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="kd">function</span><spanclass="nx">_headers</span><spanclass="p">(</span><spanclass="nx">headers</span><spanclass="p">)</span><spanclass="p">{</span>
<spanclass="p">}</span></pre></div></td></tr><trid="section-34"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-34">¶</a></div><p>WebSocket requests has method = GET</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="k">if</span><spanclass="p">(</span><spanclass="nx">req</span><spanclass="p">.</span><spanclass="nx">method</span><spanclass="o">!==</span><spanclass="s1">'GET'</span><spanclass="o">||</span><spanclass="nx">headers</span><spanclass="p">.</span><spanclass="nx">upgrade</span><spanclass="p">.</span><spanclass="nx">toLowerCase</span><spanclass="p">()</span><spanclass="o">!==</span><spanclass="s1">'websocket'</span><spanclass="p">)</span><spanclass="p">{</span></pre></div></td></tr><trid="section-35"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-35">¶</a></div><p>This request is not WebSocket request</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="k">return</span><spanclass="p">;</span>
<spanclass="p">}</span></pre></div></td></tr><trid="section-36"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-36">¶</a></div><p>Turn of all bufferings
For server set KeepAlive
For client set encoding</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="kd">function</span><spanclass="nx">_socket</span><spanclass="p">(</span><spanclass="nx">socket</span><spanclass="p">,</span><spanclass="nx">server</span><spanclass="p">)</span><spanclass="p">{</span>
<spanclass="p">}</span></pre></div></td></tr><trid="section-37"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-37">¶</a></div><p>Client socket</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">_socket</span><spanclass="p">(</span><spanclass="nx">socket</span><spanclass="p">);</span></pre></div></td></tr><trid="section-38"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-38">¶</a></div><p>If host is undefined
Get it from headers</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="k">if</span><spanclass="p">(</span><spanclass="o">!</span><spanclass="nx">host</span><spanclass="p">)</span><spanclass="p">{</span>
<spanclass="nx">p</span><spanclass="p">.</span><spanclass="nx">getClient</span><spanclass="p">(</span><spanclass="kd">function</span><spanclass="p">(</span><spanclass="nx">client</span><spanclass="p">)</span><spanclass="p">{</span></pre></div></td></tr><trid="section-42"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-42">¶</a></div><p>Based on 'pool/main.js'</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="kd">var</span><spanclass="nx">request</span><spanclass="o">=</span><spanclass="nx">client</span><spanclass="p">.</span><spanclass="nx">request</span><spanclass="p">(</span><spanclass="s1">'GET'</span><spanclass="p">,</span><spanclass="nx">req</span><spanclass="p">.</span><spanclass="nx">url</span><spanclass="p">,</span><spanclass="nx">headers</span><spanclass="p">);</span>
</pre></div></td></tr><trid="section-43"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-43">¶</a></div><p>Remove the client from the pool's available clients since it has errored</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">p</span><spanclass="p">.</span><spanclass="nx">clients</span><spanclass="p">.</span><spanclass="nx">splice</span><spanclass="p">(</span><spanclass="nx">p</span><spanclass="p">.</span><spanclass="nx">clients</span><spanclass="p">.</span><spanclass="nx">indexOf</span><spanclass="p">(</span><spanclass="nx">client</span><spanclass="p">),</span><spanclass="mi">1</span><spanclass="p">);</span>
<spanclass="nx">request</span><spanclass="p">.</span><spanclass="nx">socket</span><spanclass="p">.</span><spanclass="nx">on</span><spanclass="p">(</span><spanclass="s1">'data'</span><spanclass="p">,</span><spanclass="nx">handshake</span><spanclass="o">=</span><spanclass="kd">function</span><spanclass="p">(</span><spanclass="nx">data</span><spanclass="p">)</span><spanclass="p">{</span></pre></div></td></tr><trid="section-47"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-47">¶</a></div><p>Handshaking</p></td><tdclass="code"><divclass="highlight"><pre></pre></div></td></tr><trid="section-48"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-48">¶</a></div><p>Ok, kind of harmfull part of code
Socket.IO is sending hash at the end of handshake
If protocol = 76
But we need to replace 'host' and 'origin' in response
So we split data to printable data and to non-printable
(Non-printable will come after double-CRLF)</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="kd">var</span><spanclass="nx">sdata</span><spanclass="o">=</span><spanclass="nx">data</span><spanclass="p">.</span><spanclass="nx">toString</span><spanclass="p">();</span></pre></div></td></tr><trid="section-49"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-49">¶</a></div><p>Get Printable</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">sdata</span><spanclass="o">=</span><spanclass="nx">sdata</span><spanclass="p">.</span><spanclass="nx">substr</span><spanclass="p">(</span><spanclass="mi">0</span><spanclass="p">,</span><spanclass="nx">sdata</span><spanclass="p">.</span><spanclass="nx">search</span><spanclass="p">(</span><spanclass="nx">CRLF</span><spanclass="o">+</span><spanclass="nx">CRLF</span><spanclass="p">));</span></pre></div></td></tr><trid="section-50"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-50">¶</a></div><p>Get Non-Printable</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">data</span><spanclass="o">=</span><spanclass="nx">data</span><spanclass="p">.</span><spanclass="nx">slice</span><spanclass="p">(</span><spanclass="nx">Buffer</span><spanclass="p">.</span><spanclass="nx">byteLength</span><spanclass="p">(</span><spanclass="nx">sdata</span><spanclass="p">),</span><spanclass="nx">data</span><spanclass="p">.</span><spanclass="nx">length</span><spanclass="p">);</span></pre></div></td></tr><trid="section-51"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-51">¶</a></div><p>Replace host and origin</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">sdata</span><spanclass="o">=</span><spanclass="nx">sdata</span><spanclass="p">.</span><spanclass="nx">replace</span><spanclass="p">(</span><spanclass="nx">remote_host</span><spanclass="p">,</span><spanclass="nx">host</span><spanclass="p">)</span>
<spanclass="p">});</span></pre></div></td></tr><trid="section-55"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-55">¶</a></div><p>Remove data listener now that the 'handshake' is complete</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">request</span><spanclass="p">.</span><spanclass="nx">socket</span><spanclass="p">.</span><spanclass="nx">removeListener</span><spanclass="p">(</span><spanclass="s1">'data'</span><spanclass="p">,</span><spanclass="nx">handshake</span><spanclass="p">);</span>
</pre></div></td></tr><trid="section-58"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-58">¶</a></div><p>We're now connected to the server, so lets change server socket</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">reverse_proxy</span><spanclass="p">.</span><spanclass="nx">on</span><spanclass="p">(</span><spanclass="s1">'data'</span><spanclass="p">,</span><spanclass="nx">listeners</span><spanclass="p">.</span><spanclass="nx">_r_data</span><spanclass="o">=</span><spanclass="kd">function</span><spanclass="p">(</span><spanclass="nx">data</span><spanclass="p">)</span><spanclass="p">{</span></pre></div></td></tr><trid="section-59"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-59">¶</a></div><p>Pass data to client</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="k">if</span><spanclass="p">(</span><spanclass="nx">socket</span><spanclass="p">.</span><spanclass="nx">writable</span><spanclass="p">)</span><spanclass="p">{</span>
<spanclass="nx">socket</span><spanclass="p">.</span><spanclass="nx">on</span><spanclass="p">(</span><spanclass="s1">'data'</span><spanclass="p">,</span><spanclass="nx">listeners</span><spanclass="p">.</span><spanclass="nx">_data</span><spanclass="o">=</span><spanclass="kd">function</span><spanclass="p">(</span><spanclass="nx">data</span><spanclass="p">)</span><spanclass="p">{</span></pre></div></td></tr><trid="section-60"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-60">¶</a></div><p>Pass data from client to server</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="k">try</span><spanclass="p">{</span>
<spanclass="p">});</span></pre></div></td></tr><trid="section-61"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-61">¶</a></div><p>Detach event listeners from reverse_proxy</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="kd">function</span><spanclass="nx">detach</span><spanclass="p">()</span><spanclass="p">{</span>
<h4>@router {Object} Object containing the host based routes</h4>
<h4>@silent {Boolean} Value indicating whether we should suppress logs</h4>
<p>Constructor function for the ProxyTable responsible for getting
locations of proxy targets based on ServerRequest headers; specifically
the HTTP host header.</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="kd">var</span><spanclass="nx">ProxyTable</span><spanclass="o">=</span><spanclass="nx">exports</span><spanclass="p">.</span><spanclass="nx">ProxyTable</span><spanclass="o">=</span><spanclass="kd">function</span><spanclass="p">(</span><spanclass="nx">router</span><spanclass="p">,</span><spanclass="nx">silent</span><spanclass="p">)</span><spanclass="p">{</span>
<spanclass="k">if</span><spanclass="p">(</span><spanclass="k">typeof</span><spanclass="nx">router</span><spanclass="o">===</span><spanclass="s1">'object'</span><spanclass="p">)</span><spanclass="p">{</span></pre></div></td></tr><trid="section-3"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-3">¶</a></div><p>If we are passed an object literal setup
the routes with RegExps from the router </p></td><tdclass="code"><divclass="highlight"><pre><spanclass="k">this</span><spanclass="p">.</span><spanclass="nx">setRoutes</span><spanclass="p">(</span><spanclass="nx">router</span><spanclass="p">);</span>
<spanclass="p">}</span>
<spanclass="k">else</span><spanclass="k">if</span><spanclass="p">(</span><spanclass="k">typeof</span><spanclass="nx">router</span><spanclass="o">===</span><spanclass="s1">'string'</span><spanclass="p">)</span><spanclass="p">{</span></pre></div></td></tr><trid="section-4"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-4">¶</a></div><p>If we are passed a string then assume it is a
file path, parse that file and watch it for changes</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="kd">var</span><spanclass="nx">self</span><spanclass="o">=</span><spanclass="k">this</span><spanclass="p">;</span>
<spanclass="k">throw</span><spanclass="k">new</span><spanclass="nb">Error</span><spanclass="p">(</span><spanclass="s1">'Cannot parse router with unknown type: '</span><spanclass="o">+</span><spanclass="k">typeof</span><spanclass="nx">router</span><spanclass="p">);</span>
<spanclass="p">}</span>
<spanclass="p">};</span></pre></div></td></tr><trid="section-5"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-5">¶</a></div><p>Inherit from events.EventEmitter</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">util</span><spanclass="p">.</span><spanclass="nx">inherits</span><spanclass="p">(</span><spanclass="nx">ProxyTable</span><spanclass="p">,</span><spanclass="nx">events</span><spanclass="p">.</span><spanclass="nx">EventEmitter</span><spanclass="p">);</span></pre></div></td></tr><trid="section-6"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-6">¶</a></div><h3>function setRoutes (router)</h3>
<h4>@router {Object} Object containing the host based routes</h4>
<p>Sets the host-based routes to be used by this instance. </p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">ProxyTable</span><spanclass="p">.</span><spanclass="nx">prototype</span><spanclass="p">.</span><spanclass="nx">setRoutes</span><spanclass="o">=</span><spanclass="kd">function</span><spanclass="p">(</span><spanclass="nx">router</span><spanclass="p">)</span><spanclass="p">{</span>
<spanclass="k">if</span><spanclass="p">(</span><spanclass="o">!</span><spanclass="nx">router</span><spanclass="p">)</span><spanclass="k">throw</span><spanclass="k">new</span><spanclass="nb">Error</span><spanclass="p">(</span><spanclass="s1">'Cannot update ProxyTable routes without router.'</span><spanclass="p">);</span>
<h4>@req {ServerRequest} The incoming server request to get proxy information about.</h4>
<p>Returns the proxy location based on the HTTP Headers in the ServerRequest <code>req</code>
available to this instance.</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">ProxyTable</span><spanclass="p">.</span><spanclass="nx">prototype</span><spanclass="p">.</span><spanclass="nx">getProxyLocation</span><spanclass="o">=</span><spanclass="kd">function</span><spanclass="p">(</span><spanclass="nx">req</span><spanclass="p">)</span><spanclass="p">{</span>
<spanclass="p">};</span></pre></div></td></tr><trid="section-8"><tdclass="docs"><divclass="pilwrap"><aclass="pilcrow"href="#section-8">¶</a></div><h3>close function ()</h3>
<p>Cleans up the event listeneners maintained
by this instance.</p></td><tdclass="code"><divclass="highlight"><pre><spanclass="nx">ProxyTable</span><spanclass="p">.</span><spanclass="nx">prototype</span><spanclass="p">.</span><spanclass="nx">close</span><spanclass="o">=</span><spanclass="kd">function</span><spanclass="p">()</span><spanclass="p">{</span>
