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

/* examples/plugins/exec/test_go_template.go */

package main

import (
	"bufio"
	"fmt"
	"os"
	"strings"
)

func main() {
	// Print debug info to Stderr
	fmt.Fprintln(os.Stderr, "⚙ Starting execution...")

	// Read all stdin safely
	reader := bufio.NewReader(os.Stdin)
	var inputRaw strings.Builder
	for {
		line, err := reader.ReadString('\n')
		if err != nil {
			if line != "" {
				inputRaw.WriteString(line)
			}
			break
		}
		inputRaw.WriteString(line)
	}

	inputStr := inputRaw.String()
	if len(inputStr) == 0 {
		fmt.Fprintln(os.Stderr, "✗ No input received on Stdin!")
		os.Exit(1)
	}

	inputStr = strings.TrimSuffix(inputStr, "\n")
	fmt.Fprintln(os.Stderr, "⚙ Received Input: "+inputStr)

	// Parse JSON manually for {"auth_token":"..."} structure
	authToken := ""
	tokenKey := "\"auth_token\":\""
	if idx := strings.Index(inputStr, tokenKey); idx != -1 {
		start := idx + len(tokenKey)
		end := strings.Index(inputStr[start:], "\"")
		if end != -1 {
			authToken = inputStr[start : start+end]
		}
	}

	// Business Logic
	var branch, store string
	if authToken == "secret123" {
		fmt.Fprintln(os.Stderr, "✓ Auth success!")
		branch = "success"
		store = `{"user_role":"admin","verified":"true"}`
	} else {
		fmt.Fprintln(os.Stderr, "✗ Auth failed. Token was: "+authToken)
		branch = "failure"
		store = `{"error_reason":"invalid_token"}`
	}

	// Output result to Stdout (compact JSON)
	fmt.Printf("{\"branch\":\"%s\",\"store\":%s}", branch, store)
}