vane 0.9.0

A flow-based reverse proxy with multi-layer routing and programmable pipelines.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91

#!/usr/bin/env lua

-- A simple HTTP server over Unix Domain Socket to mock a Vane middleware plugin.
-- Requires: luasocket (and specifically socket.unix)

local socket = require "socket"
local unix = require "socket.unix"

-- Simple JSON fallback (same as the HTTP example)
local json = {
	decode = function(str)
		local token = str:match '"auth_token"%s*:%s*"(.-)"'
		return { auth_token = token }
	end,
	encode = function(tbl)
		if tbl.status == "success" then
			return string.format('{"status":"success","data":{"branch":"%s","store":{"user":"admin"}}}', tbl.data.branch)
		else
			return string.format('{"status":"error","message":"%s"}', tbl.message)
		end
	end,
}

local path = arg[1]
if not path then
	print "Usage: lua mock_unix_server.lua <socket_path>"
	os.exit(1)
end

-- Ensure clean state
os.remove(path)

local server = assert(unix())
assert(server:bind(path))
assert(server:listen())

print("Listening on " .. path)
io.stdout:flush()

while true do
	local client = server:accept()
	if client then
		client:settimeout(5)

		-- Vane sends raw HTTP over UDS
		local line, err = client:receive()
		if not err then
			-- Read headers to find Content-Length
			local content_length = 0
			while line and line ~= "" do
				local len_str = line:match "Content%-Length:%s*(%d+)"
				if len_str then
					content_length = tonumber(len_str) or 0
				end
				line, err = client:receive()
			end

			-- Read Body
			local body, err_body = client:receive(content_length)

			if body then
				local input = json.decode(body)

				-- Logic: Check auth_token
				local response_data
				if input and input.auth_token == "secret123" then
					response_data = {
						status = "success",
						data = { branch = "success" },
					}
				else
					response_data = {
						status = "success",
						data = { branch = "failure" },
					}
				end

				local response_body = json.encode(response_data)

				-- Send HTTP Response
				client:send "HTTP/1.1 200 OK\r\n"
				client:send "Content-Type: application/json\r\n"
				client:send("Content-Length: " .. #response_body .. "\r\n")
				client:send "Connection: close\r\n" -- Vane expects close or reads len
				client:send "\r\n"
				client:send(response_body)
			end
		end
		client:close()
	end
end