diff options
| author | Fuwn <[email protected]> | 2026-02-26 16:26:38 -0800 |
|---|---|---|
| committer | Fuwn <[email protected]> | 2026-02-26 16:26:38 -0800 |
| commit | 8b7f7b938aead6ec285c5c9290f9a4305b96521f (patch) | |
| tree | 3a52bd80d3a0468b3fc96c5b240d02d7b16e8f49 /internal/ingest/client.go | |
| parent | feat: Apply Iku formatting (diff) | |
| download | plutia-test-8b7f7b938aead6ec285c5c9290f9a4305b96521f.tar.xz plutia-test-8b7f7b938aead6ec285c5c9290f9a4305b96521f.zip | |
style: align codebase with official Go idioms
Diffstat (limited to 'internal/ingest/client.go')
| -rw-r--r-- | internal/ingest/client.go | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/internal/ingest/client.go b/internal/ingest/client.go index 12d8bd6..29457cf 100644 --- a/internal/ingest/client.go +++ b/internal/ingest/client.go @@ -7,6 +7,7 @@ import ( "encoding/json" "errors" "fmt" + "github.com/Fuwn/plutia/internal/types" "io" "log" "net" @@ -17,7 +18,6 @@ import ( "strconv" "strings" "time" - "github.com/Fuwn/plutia/internal/types" ) type Client struct { @@ -369,11 +369,7 @@ func isSpace(b byte) bool { } func (c *Client) fetchFromFile(after uint64, limit uint64) ([]types.ExportRecord, error) { - path := c.source - - if strings.HasPrefix(path, "file://") { - path = strings.TrimPrefix(path, "file://") - } + path := strings.TrimPrefix(c.source, "file://") path = filepath.Clean(path) b, err := os.ReadFile(path) |