diff options
| author | s <[email protected]> | 2025-11-07 11:50:47 -0500 |
|---|---|---|
| committer | s <[email protected]> | 2025-11-07 11:50:47 -0500 |
| commit | 7d63867f365163f149db5d768c71f518f9eaf711 (patch) | |
| tree | f3f4856cf82f57286dee5bec23fae0c5f70bd1ee /internal | |
| parent | 5821aaa32e7ff2a2b2935bee712c2684907a3451 (diff) | |
| download | dborg-7d63867f365163f149db5d768c71f518f9eaf711.tar.gz dborg-7d63867f365163f149db5d768c71f518f9eaf711.zip | |
refactor: extract json output formatting to utils.PrintJSON and add colorized json output with new dns tld command
Diffstat (limited to 'internal')
| -rw-r--r-- | internal/client/dns.go | 51 | ||||
| -rw-r--r-- | internal/models/dns.go | 12 | ||||
| -rw-r--r-- | internal/utils/output.go | 113 |
3 files changed, 175 insertions, 1 deletions
diff --git a/internal/client/dns.go b/internal/client/dns.go new file mode 100644 index 0000000..08449e0 --- /dev/null +++ b/internal/client/dns.go @@ -0,0 +1,51 @@ +package client + +import ( + "bufio" + "encoding/json" + "fmt" + "net/http" + "net/url" + + "git.db.org.ai/dborg/internal/models" +) + +func (c *Client) CheckDNSTLDStream(params *models.DNSTLDParams, callback func(result json.RawMessage) error) error { + term := url.PathEscape(params.Term) + fullURL := c.config.BaseURL + "/dns/tld/" + term + + req, err := http.NewRequest(http.MethodGet, fullURL, nil) + if err != nil { + return fmt.Errorf("failed to create request: %w", err) + } + + req.Header.Set("User-Agent", c.config.UserAgent) + + resp, err := c.httpClient.Do(req) + if err != nil { + return fmt.Errorf("request failed: %w", err) + } + defer resp.Body.Close() + + if resp.StatusCode != http.StatusOK { + return fmt.Errorf("API request failed with status %d", resp.StatusCode) + } + + scanner := bufio.NewScanner(resp.Body) + for scanner.Scan() { + line := scanner.Bytes() + if len(line) == 0 { + continue + } + + if err := callback(json.RawMessage(line)); err != nil { + return fmt.Errorf("callback failed: %w", err) + } + } + + if err := scanner.Err(); err != nil { + return fmt.Errorf("failed to read response: %w", err) + } + + return nil +} diff --git a/internal/models/dns.go b/internal/models/dns.go new file mode 100644 index 0000000..b08d8ba --- /dev/null +++ b/internal/models/dns.go @@ -0,0 +1,12 @@ +package models + +type DNSTLDParams struct { + Term string +} + +type DomainResult struct { + Domain string `json:"domain"` + Status string `json:"status"` + Title string `json:"title,omitempty"` + Tech []string `json:"tech,omitempty"` +} diff --git a/internal/utils/output.go b/internal/utils/output.go index 3f2347c..e8e97bc 100644 --- a/internal/utils/output.go +++ b/internal/utils/output.go @@ -1,18 +1,129 @@ package utils import ( + "bytes" "encoding/json" "fmt" "os" "text/tabwriter" ) +const ( + colorReset = "\033[0m" + colorKey = "\033[36m" + colorString = "\033[32m" + colorNumber = "\033[33m" + colorBool = "\033[35m" + colorNull = "\033[90m" + colorBrace = "\033[37m" +) + +func colorizeJSON(data []byte) string { + if !isTerminal() { + return string(data) + } + + var result bytes.Buffer + var inString bool + var isKey bool + var depth int + + for i := 0; i < len(data); i++ { + c := data[i] + + switch c { + case '"': + if i > 0 && data[i-1] != '\\' { + inString = !inString + if inString { + if i > 0 && (data[i-1] == '{' || data[i-1] == ',' || data[i-1] == '[' || data[i-1] == '\n' || data[i-1] == ' ') { + isKey = true + result.WriteString(colorKey) + } else { + result.WriteString(colorString) + } + } else { + result.WriteByte(c) + result.WriteString(colorReset) + if isKey && i+1 < len(data) && data[i+1] == ':' { + isKey = false + } + continue + } + } + result.WriteByte(c) + + case '{', '}', '[', ']': + if !inString { + result.WriteString(colorBrace) + result.WriteByte(c) + result.WriteString(colorReset) + if c == '{' || c == '[' { + depth++ + } else { + depth-- + } + } else { + result.WriteByte(c) + } + + case 't', 'f': + if !inString && i+3 < len(data) { + word := string(data[i:min(i+5, len(data))]) + if word[:4] == "true" || word[:5] == "false" { + result.WriteString(colorBool) + if word[:4] == "true" { + result.WriteString("true") + i += 3 + } else { + result.WriteString("false") + i += 4 + } + result.WriteString(colorReset) + } else { + result.WriteByte(c) + } + } else { + result.WriteByte(c) + } + + case 'n': + if !inString && i+3 < len(data) && string(data[i:i+4]) == "null" { + result.WriteString(colorNull) + result.WriteString("null") + result.WriteString(colorReset) + i += 3 + } else { + result.WriteByte(c) + } + + case '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', '-': + if !inString { + result.WriteString(colorNumber) + for i < len(data) && (data[i] >= '0' && data[i] <= '9' || data[i] == '.' || data[i] == '-' || data[i] == 'e' || data[i] == 'E' || data[i] == '+') { + result.WriteByte(data[i]) + i++ + } + i-- + result.WriteString(colorReset) + } else { + result.WriteByte(c) + } + + default: + result.WriteByte(c) + } + } + + return result.String() +} + func PrintJSON(data any) error { output, err := json.MarshalIndent(data, "", " ") if err != nil { return fmt.Errorf("failed to format JSON: %w", err) } - fmt.Println(string(output)) + fmt.Println(colorizeJSON(output)) return nil } |
