revert-proxy

proxyc

daemon = 0
bootstrap = "test/testhttp.lua"
lualib_path = "test/?.lua;lualib/?.lua"
lualib_cpath = "test/?.so;luaclib/?.so"
ctrl="192.168.2.1@8002"
tunnel="192.168.2.1@8003"

proxyc.lua

local socket = require "socket"
local core = require "silly.core"
local env = require "silly.env"

local function direct(src, dst)
	return function()
		while true do
			local d = socket.read(src, 1)
			if not d then
				socket.close(dst)
				return
			end
			local ok = socket.write(dst, d)
			if not ok then
				socket.close(src)
				return
			end
		end
	end
end

local function bridge(ip, src)
	local fd = socket.connect(ip)
	local srcfd = socket.connect(env.get("tunnel"))
	assert(fd)
	assert(srcfd)
	socket.write(srcfd, src)
	core.fork(direct(fd, srcfd))
	core.fork(direct(srcfd, fd))
end

return function (ip)
	local fd = socket.connect(env.get("ctrl"))
	print("connect ctrl", fd)
	assert(fd)
	while true do
		local src = socket.readline(fd)
		print("new come", src)
		if not src then
			return
		end
		bridge(ip, src)
	end
end

proxyd

daemon = 0
bootstrap = "test/proxyd.lua"
lualib_path = "test/?.lua;lualib/?.lua"
lualib_cpath = "luaclib/?.so"
listen = "@8001"
ctrl = "@8002"
tunnel = "@8003"

proxyd.lua

local socket = require "socket"
local core = require "silly.core"
local env = require "silly.env"

local T = nil

socket.listen(env.get("ctrl"), function(fd, addr)
	print("ctrl", fd)
	T = fd;
end)

socket.listen(env.get("listen"), function(fd, addr)
	assert(T)
	local ok = socket.write(T, fd .. "\n")
	assert(ok)
end)

local function direct(src, dst)
	return function()
		while true do
			local d = socket.read(src, 1)
			if not d then
				socket.close(dst)
				return
			end
			local ok = socket.write(dst, d)
			if not ok then
				socket.close(src)
				return
			end
		end
	end
end

socket.listen(env.get("tunnel"), function(fd, addr)
	local to = socket.readline(fd)
	to = tonumber(to)
	core.fork(direct(fd, to))
	core.fork(direct(to, fd))
end)