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

#!/usr/bin/env node
/* examples/plugins/exec/test_javascript_template.js */

const readline = require('readline');

// Safely read all content from Stdin
function readAllStdin() {
	return new Promise((resolve) => {
		let lines = [];
		const rl = readline.createInterface({
			input: process.stdin,
			terminal: false,
		});

		rl.on('line', (line) => {
			lines.push(line);
		});

		rl.on('close', () => {
			resolve(lines.join('\n'));
		});
	});
}

// --- Main Logic ---

(async () => {
	// Print debug info to Stderr (Vane logs this)
	console.error('⚙ Starting execution...');

	// Read ResolvedInputs from Vane
	const inputRaw = await readAllStdin();
	if (!inputRaw) {
		console.error('✗ No input received on Stdin!');
		process.exit(1);
	}

	console.error('⚙ Received Input: ' + inputRaw);

	// Parse JSON
	let inputs;
	try {
		inputs = JSON.parse(inputRaw);
	} catch (e) {
		console.error('✗ Invalid JSON: ' + e.message);
		process.exit(1);
	}

	// Business Logic
	// Assume Vane passes an argument "auth_token"
	// If token is "secret123", return success branch and write user info to KV
	let output = {};

	if (inputs.auth_token === 'secret123') {
		console.error('✓ Auth success!');
		output = {
			branch: 'success',
			store: {
				user_role: 'admin',
				verified: 'true',
			},
		};
	} else {
		console.error(`✗ Auth failed. Token was: ${inputs.auth_token}`);
		output = {
			branch: 'failure',
			store: {
				error_reason: 'invalid_token',
			},
		};
	}

	// Output result to Stdout (Must be compact JSON)
	process.stdout.write(JSON.stringify(output));
})();