mirror of
https://github.com/hanzoai/o11y.git
synced 2026-10-15 12:58:33 +00:00
zeekay
4679327ddc
Hanzo CI/CD / test (linux-amd64) (push) Skipped
Hanzo CI/CD / test (linux-arm64) (push) Skipped
Hanzo CI/CD / test-advisory (push) Failing after 5m15s
Hanzo CI/CD / test-amd64 (push) Failing after 17m40s
Hanzo CI/CD / cicd (push) Skipped
CI/CD / cicd (push) Failing after 17m53s
The event plane folded every occurrence into event.fact, and the Sentry module still read and wrote event.error. Its reads now select the error signal of event.fact, mapping issue, env, origin and the severity band. Errors enter through /v1/event only. The Sentry envelope and store routes, DSN keys and their rotation leave the module; the consumer of event.error files each fact through Ingest(org, product), which keeps the issue lifecycle and returns the issues a batch created.
91 lines
2.1 KiB
Go
91 lines
2.1 KiB
Go
package o11y_test
|
|
|
|
import (
|
|
"bufio"
|
|
"bytes"
|
|
"io/fs"
|
|
"os"
|
|
"path/filepath"
|
|
"regexp"
|
|
"strings"
|
|
"testing"
|
|
)
|
|
|
|
// Every o11y route is /v1/o11y/…: the host is api.hanzo.ai, so a path never
|
|
// says api again.
|
|
|
|
func TestNoRouteIsServedOutsideV1(t *testing.T) {
|
|
for route := range registered(t, mounted(t)) {
|
|
_, path, _ := strings.Cut(route, " ")
|
|
if !strings.HasPrefix(path, "/v1/") {
|
|
t.Errorf("%s is served outside /v1/", route)
|
|
}
|
|
}
|
|
}
|
|
|
|
// versioned is the spelling every first-party route had before /v1/o11y.
|
|
var versioned = regexp.MustCompile(`/api/v[0-9]`)
|
|
|
|
// Matches preceded by one of these are not o11y routes: TypeScript module
|
|
// paths (types/api/v5/…), Go modules (etcd/api/v3, alertmanager/api/v2) and
|
|
// the Sentry DSN namespace (/v1/o11y/api/…).
|
|
var notARoute = []string{"types", "etcd", "alertmanager", "/v1/o11y"}
|
|
|
|
var skipDirs = map[string]bool{".git": true, "node_modules": true, "build": true, "dist": true}
|
|
|
|
func TestNoCallerSpellsAPI(t *testing.T) {
|
|
err := filepath.WalkDir(".", func(path string, d fs.DirEntry, err error) error {
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if d.IsDir() {
|
|
if skipDirs[d.Name()] {
|
|
return filepath.SkipDir
|
|
}
|
|
return nil
|
|
}
|
|
if path == "apiprefix_test.go" || !scanned(path) {
|
|
return nil
|
|
}
|
|
b, err := os.ReadFile(path)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
s := bufio.NewScanner(bytes.NewReader(b))
|
|
s.Buffer(make([]byte, 0, 64*1024), 16*1024*1024)
|
|
for n := 1; s.Scan(); n++ {
|
|
line := s.Text()
|
|
for _, loc := range versioned.FindAllStringIndex(line, -1) {
|
|
if !excused(line[:loc[0]]) {
|
|
t.Errorf("%s:%d calls a route under /api/: %s", path, n, strings.TrimSpace(line))
|
|
}
|
|
}
|
|
}
|
|
return s.Err()
|
|
})
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
}
|
|
|
|
func scanned(path string) bool {
|
|
switch filepath.Base(path) {
|
|
case "Dockerfile", "Dockerfile.site", "Makefile":
|
|
return true
|
|
}
|
|
switch filepath.Ext(path) {
|
|
case ".go", ".ts", ".tsx", ".js", ".mjs", ".py", ".sh", ".yml", ".yaml", ".json", ".md", ".mdc", ".conf", ".env":
|
|
return true
|
|
}
|
|
return false
|
|
}
|
|
|
|
func excused(before string) bool {
|
|
for _, p := range notARoute {
|
|
if strings.HasSuffix(before, p) {
|
|
return true
|
|
}
|
|
}
|
|
return false
|
|
}
|