From 142dac0b82bfa2903ee32f2e34eb2ef91be6269d Mon Sep 17 00:00:00 2001
From: Jim Heising <jheising@redfoundry.com>
Date: Thu, 21 Aug 2014 15:20:01 -0700
Subject: [PATCH] changed name of default script

---
 package.json  |   5 +-
 thingproxy.js | 137 --------------------------------------------------
 2 files changed, 1 insertion(+), 141 deletions(-)
 delete mode 100644 thingproxy.js

diff --git a/package.json b/package.json
index 705583b..555f75a 100644
--- a/package.json
+++ b/package.json
@@ -2,10 +2,7 @@
 	"name": "thingproxy.freeboard.io",
 	"version": "0.0.1",
 	"description": "A simple forward proxy server for processing API calls to servers that don't send CORS headers or support HTTPS.",
-	"main": "thingproxy.js",
-	"scripts": {
-		"start": "thingproxy.js"
-	},
+	"main": "server.js",
 	"author": "Jim Heising <jim@buglabs.net>",
 	"license": "MIT",
 	"dependencies": {
diff --git a/thingproxy.js b/thingproxy.js
deleted file mode 100644
index 3d74fd1..0000000
--- a/thingproxy.js
+++ /dev/null
@@ -1,137 +0,0 @@
-var http = require('http');
-var config = require("./config");
-var url = require("url");
-var request = require("request");
-var throttle = require("tokenthrottle")({rate: config.max_requests_per_second});
-
-function addCORSHeaders(res) {
-	res.setHeader("Access-Control-Allow-Origin", "*");
-	res.setHeader("Access-Control-Allow-Methods", "GET, POST, OPTIONS, PUT, DELETE");
-	res.setHeader("Access-Control-Allow-Credentials", "true");
-	res.setHeader("Access-Control-Allow-Headers", "Origin,Content-Type,Accept");
-	res.setHeader("Content-Type", "text/plain");
-}
-
-function writeResponse(res, httpCode, body) {
-	res.statusCode = httpCode;
-	res.end(body);
-}
-
-function sendInvalidURLResponse(res) {
-	return writeResponse(res, 400, "url must be in the form of /fetch/{some_url_here}");
-}
-
-function sendTooBigResponse(res) {
-	return writeResponse(res, 413, "the content in the request or response cannot exceed " + config.max_request_length + " characters.");
-}
-
-function getClientAddress(req) {
-	return (req.headers['x-forwarded-for'] || '').split(',')[0]
-		|| req.connection.remoteAddress;
-}
-
-function processRequest(req, res)
-{
-	addCORSHeaders(res);
-
-	// Return options pre-flight requests right away
-	if (req.method.toUpperCase() === "OPTIONS") {
-		return writeResponse(res, 204);
-	}
-
-	var result = config.fetch_regex.exec(req.url);
-
-	if (result && result.length == 2 && result[1]) {
-		var remoteURL;
-
-		try {
-			remoteURL = url.parse(decodeURI(result[1]));
-		}
-		catch (e) {
-			return sendInvalidURLResponse(res);
-		}
-
-		// We only support http and https
-		if (remoteURL.protocol != "http:" && remoteURL.protocol !== "https:") {
-			return writeResponse(res, 400, "only http and https are supported");
-		}
-
-		var proxyRequest = request({
-			url: remoteURL,
-			headers: req.headers,
-			method: req.method,
-			timeout: config.proxy_request_timeout_ms,
-			strictSSL : false
-		});
-
-		proxyRequest.on('error', function(err){
-
-			console.log(err);
-
-			if(err.code === "ENOTFOUND")
-			{
-				return writeResponse(res, 502, "host cannot be found.")
-			}
-			else
-			{
-				return writeResponse(res, 500);
-			}
-
-		});
-
-		var requestSize = 0;
-		var proxyResponseSize = 0;
-
-		req.pipe(proxyRequest).on('data', function(data){
-
-			requestSize += data.length;
-
-			if(requestSize >= config.max_request_length)
-			{
-				proxyRequest.end();
-				return sendTooBigResponse(res);
-			}
-		});
-
-		proxyRequest.pipe(res).on('data', function (data) {
-
-			proxyResponseSize += data.length;
-
-			if(proxyResponseSize >= config.max_request_length)
-			{
-				proxyRequest.end();
-				return sendTooBigResponse(res);
-			}
-		});
-	}
-	else {
-		return sendInvalidURLResponse(res);
-	}
-}
-
-http.createServer(function (req, res) {
-
-	var remoteIP = getClientAddress(req);
-
-	// Log our request
-	console.log("%s %s %s", (new Date()).toJSON(), remoteIP, req.method, req.url);
-
-	if(config.enable_rate_limiting)
-	{
-		throttle.rateLimit(remoteIP, function(err, limited) {
-			if (limited)
-			{
-				return writeResponse(res, 429, "enhance your calm");
-			}
-
-			processRequest(req, res);
-		})
-	}
-	else
-	{
-		processRequest(req, res);
-	}
-
-}).listen(config.port);
-
-console.log("thingproxy.freeboard.io started");