mirror of
https://github.com/hanzoai/gateway.git
synced 2026-11-02 08:45:10 +00:00
Every import in this module now resolves to github.com/hanzoai/gateway/v2.
The 34 github.com/krakend/* + github.com/luraproject/lura modules that
supplied the engine and its components are vendored under internal/ and
their 91 packages rewritten onto our own path.
Why fold rather than mirror into 34 hanzoai/* repos:
- It removes the exposure outright. 34 rows leave 34 rows of go.sum to
reason about; zero modules leave nothing. `go list -m all` and go.sum
now contain no krakend/lura entry at all.
- Cross-references cannot go wrong. 28 of the 34 import lura (97 files
inside lura self-reference it). Mirroring means rewriting every one of
those to our lura, and a single miss silently links a SECOND copy of
lura into the binary. With one module that is structurally impossible.
- It creates no duplicates. These are lura-coupled gateway glue with no
consumer outside this binary; publishing 34 repos would be 34 new
things to maintain for zero second caller. internal/ makes that
guarantee mechanical — Go forbids importing it from outside this
module, so none of it can become a competing public package. Verified
no repo outside gateway imports any hanzoai/gateway/v2 subpackage.
Layout mirrors provenance so an upstream re-sync stays a diff:
luraproject/lura/v2 -> internal/lura (the engine, 20 pkgs)
krakend/krakend-<x> -> internal/plugin/<x> (28 components)
krakend/<x> -> internal/pkg/<x> (6 standalone libs)
This commit is PURELY MECHANICAL: 196 of the 197 vendored files are
byte-identical to their upstream original once the import rewrite is
applied. The single exception is bloomfilter's subpackage, which upstream
names `krakend` — the one package name that could not survive as-is; it
becomes internal/pkg/bloomfilter/register. Hand edits land separately in
the next commit so they are readable on their own.
Per `go mod vendor` semantics, dependencies' _test.go files are not
vendored. They test upstream code at a pinned version that we do not
modify, several cannot run at all from a module distribution (they need
TLS certs and compiled .so plugins upstream generates but never ships),
and one is a 100k-request stress test that exhausts the ephemeral port
range and fails every package running beside it. Fold integrity is proven
by the byte-diff above instead, which is the stronger check.
Preserved deliberately — each of these is behaviour, not branding:
- the `github.com/devopsfaith/krakend*` extra_config namespace strings
(35 of them). These are config-surface keys, not import paths;
renaming one silently stops that component finding its config. The
jose validator namespace backs `auth/validator` on 212 endpoints.
- core.KrakendVersion / KrakendUserAgent / the X-KRAKEND consts, whose
VALUES rebrand.go overwrites — that seam is unchanged.
- the KRAKEND_ koanf env prefix (a hardcoded upstream const).
- every vendored module's LICENSE (34 files, Apache-2.0/MIT).
The Makefile/CI -X paths move with the engine. An -X naming a symbol that
does not exist is silently ignored by the linker, so a stale path here
would have shipped an "undefined" version in the backend User-Agent and
X-Api-Version with a perfectly green build. Verified live:
`gateway version` reports 2.13.0, not undefined.
Verification (GOWORK=off CGO_ENABLED=0, both tag modes):
go build ./... OK go build -tags legacy ./... OK
go vet ./... clean go vet -tags legacy ./... clean
go test ./... 6/6 ok go test -tags legacy 5/5 ok
tests/ integration harness 47 fixtures pass
gateway check -c configs/{hanzo,lux}/gateway.json -> Syntax OK!
go list -m all | grep -iE 'krakend|lura' -> empty
go mod verify -> all modules verified
Co-authored-by: Hanzo Dev <[email protected]>
252 lines
4.3 KiB
Go
252 lines
4.3 KiB
Go
package binder
|
|
|
|
import (
|
|
"bytes"
|
|
"fmt"
|
|
"io/ioutil"
|
|
"strconv"
|
|
"strings"
|
|
|
|
"github.com/alecthomas/chroma/quick"
|
|
"github.com/fatih/color"
|
|
lua "github.com/yuin/gopher-lua"
|
|
)
|
|
|
|
const (
|
|
// errorLinesBefore lines before problem line
|
|
errorLinesBefore = 5
|
|
|
|
// errorLinesBefore lines after problem line
|
|
errorLinesAfter = 5
|
|
)
|
|
|
|
type errSourceHandler func(problem int) *source
|
|
|
|
type line struct {
|
|
number int
|
|
problem bool
|
|
code string
|
|
}
|
|
|
|
const (
|
|
errBgColor = color.BgRed
|
|
errFgColor = color.FgWhite
|
|
|
|
numberFgColor = color.FgHiBlack
|
|
numberBgColor = color.BgBlack
|
|
)
|
|
|
|
func (l *line) str(numbers, len int) string {
|
|
numberBg := numberBgColor
|
|
|
|
line := l.codeString(len)
|
|
if l.problem {
|
|
numberBg = errBgColor
|
|
line = color.New(errBgColor, errFgColor).Sprintf("%s", line)
|
|
} else {
|
|
line = highlight(line)
|
|
}
|
|
|
|
number := color.New(numberBg, numberFgColor).Sprintf("%s ", l.numberString(numbers))
|
|
|
|
return number + line
|
|
}
|
|
|
|
func (l *line) numberString(pad int) string {
|
|
output := fmt.Sprintf("%d", l.number)
|
|
pad -= len(output)
|
|
|
|
if pad <= 0 {
|
|
return output
|
|
}
|
|
|
|
return fmt.Sprintf("%s%s", strings.Repeat(" ", pad), output)
|
|
}
|
|
|
|
func (l *line) codeString(pad int) string {
|
|
output := l.code
|
|
pad -= len(output)
|
|
|
|
if pad <= 0 {
|
|
return output
|
|
}
|
|
|
|
return fmt.Sprintf("%s%s", output, strings.Repeat(" ", pad))
|
|
}
|
|
|
|
type source struct {
|
|
lines []*line
|
|
}
|
|
|
|
func (s *source) problem() string {
|
|
output := make([]string, len(s.lines))
|
|
numbers, len := s.maxLengths()
|
|
|
|
for i, l := range s.lines {
|
|
output[i] = l.str(numbers, len)
|
|
}
|
|
|
|
return strings.Join(output, "\n")
|
|
}
|
|
|
|
func (s *source) maxLengths() (int, int) {
|
|
n := 0
|
|
l := 0
|
|
|
|
for _, line := range s.lines {
|
|
nl := len(fmt.Sprintf("%d", line.number))
|
|
if nl > n {
|
|
n = nl
|
|
}
|
|
|
|
ll := len(line.code)
|
|
if ll > l {
|
|
l = ll
|
|
}
|
|
}
|
|
|
|
return n, l
|
|
}
|
|
|
|
func newSource(code string, problem int) *source {
|
|
l := strings.Split(code, "\n")
|
|
count := len(l)
|
|
lines := make([]*line, count)
|
|
|
|
for i, v := range l {
|
|
lines[i] = &line{
|
|
number: i + 1,
|
|
problem: i+1 == problem,
|
|
code: strings.TrimSpace(v),
|
|
}
|
|
}
|
|
|
|
length := errorLinesBefore + errorLinesAfter + 1
|
|
|
|
if length <= count {
|
|
before := problem - errorLinesBefore
|
|
after := problem + errorLinesAfter
|
|
|
|
if before < 0 {
|
|
before = 0
|
|
after = before + length
|
|
}
|
|
|
|
if after > count-1 {
|
|
after = count - 1
|
|
before = after - length
|
|
}
|
|
|
|
if before > 0 {
|
|
lines = lines[before-1 : after]
|
|
}
|
|
}
|
|
|
|
return &source{
|
|
lines: lines,
|
|
}
|
|
}
|
|
|
|
// Error error object
|
|
type Error struct {
|
|
error string
|
|
problem int
|
|
source *source
|
|
}
|
|
|
|
// Error returns error string
|
|
func (e *Error) Error() string {
|
|
if e.problem >= 0 {
|
|
return fmt.Sprintf("Line %d: %s", e.problem, e.error)
|
|
}
|
|
|
|
return e.error
|
|
}
|
|
|
|
// Source returns problem source code as string
|
|
func (e *Error) Source() string {
|
|
return e.source.problem()
|
|
}
|
|
|
|
// Print prints problem source code
|
|
func (e *Error) Print() {
|
|
color.New(color.FgHiRed).Println(e.Error())
|
|
fmt.Println()
|
|
fmt.Println(e.Source())
|
|
}
|
|
|
|
func newError(err error, h errSourceHandler) error {
|
|
switch err.(type) {
|
|
case *lua.ApiError:
|
|
e := err.(*lua.ApiError)
|
|
var (
|
|
problem = -1
|
|
text = e.Error()
|
|
)
|
|
|
|
if e.Type == lua.ApiErrorSyntax {
|
|
text, problem = parseSyntaxError(e.Object.String())
|
|
} else {
|
|
p := strings.Split(e.Object.String(), ":")
|
|
c := len(p)
|
|
|
|
if c > 1 {
|
|
if v, err := strconv.Atoi(p[1]); err == nil {
|
|
problem = v
|
|
}
|
|
}
|
|
|
|
if c > 2 {
|
|
text = strings.Trim(strings.Join(p[2:], ":"), " ")
|
|
}
|
|
}
|
|
|
|
return &Error{
|
|
error: text,
|
|
problem: problem,
|
|
source: h(problem),
|
|
}
|
|
}
|
|
|
|
return err
|
|
}
|
|
|
|
func parseSyntaxError(errorText string) (string, int) {
|
|
var (
|
|
problem = -1
|
|
text = errorText
|
|
)
|
|
|
|
if strings.Contains(errorText, " at EOF:") {
|
|
problem = 0
|
|
text = strings.TrimSpace(strings.Split(errorText, ":")[1]) + " at EOF"
|
|
|
|
return text, problem
|
|
}
|
|
|
|
parts := strings.Split(errorText, " near ")
|
|
if len(parts) == 2 {
|
|
text = strings.Join(strings.Fields(strings.TrimSuffix(parts[1], "\n")), " ")
|
|
where := strings.Split(strings.TrimSuffix(strings.ReplaceAll(parts[0], "<string> line:", ""), ")"), "(column:")
|
|
if v, err := strconv.Atoi(where[0]); err == nil {
|
|
problem = v
|
|
}
|
|
|
|
}
|
|
return text, problem
|
|
}
|
|
|
|
func highlight(s string) string {
|
|
var buf bytes.Buffer
|
|
if err := quick.Highlight(&buf, s, "lua", "terminal", "solarized-dark"); err != nil {
|
|
return s
|
|
}
|
|
|
|
b, err := ioutil.ReadAll(&buf)
|
|
if err != nil {
|
|
return s
|
|
}
|
|
|
|
return string(b)
|
|
}
|