fix(lint): resolve all errcheck violations in ingestion module
This commit is contained in:
@@ -81,7 +81,7 @@ func (c *Client) Complete(ctx context.Context, system, user string) (string, err
|
|||||||
}
|
}
|
||||||
|
|
||||||
if resp.StatusCode == http.StatusTooManyRequests {
|
if resp.StatusCode == http.StatusTooManyRequests {
|
||||||
resp.Body.Close()
|
_ = resp.Body.Close()
|
||||||
wait := 5 * time.Second
|
wait := 5 * time.Second
|
||||||
if ra := resp.Header.Get("Retry-After"); ra != "" {
|
if ra := resp.Header.Get("Retry-After"); ra != "" {
|
||||||
if secs, err := strconv.Atoi(ra); err == nil {
|
if secs, err := strconv.Atoi(ra); err == nil {
|
||||||
@@ -98,7 +98,7 @@ func (c *Client) Complete(ctx context.Context, system, user string) (string, err
|
|||||||
return "", fmt.Errorf("retry LLM call: %w", err)
|
return "", fmt.Errorf("retry LLM call: %w", err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
defer resp.Body.Close()
|
defer resp.Body.Close() //nolint:errcheck
|
||||||
|
|
||||||
out, err := io.ReadAll(resp.Body)
|
out, err := io.ReadAll(resp.Body)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
@@ -18,7 +18,7 @@ func mockServer(t *testing.T, response string) *httptest.Server {
|
|||||||
assert.Equal(t, "/chat/completions", r.URL.Path)
|
assert.Equal(t, "/chat/completions", r.URL.Path)
|
||||||
assert.Equal(t, "application/json", r.Header.Get("Content-Type"))
|
assert.Equal(t, "application/json", r.Header.Get("Content-Type"))
|
||||||
w.Header().Set("Content-Type", "application/json")
|
w.Header().Set("Content-Type", "application/json")
|
||||||
json.NewEncoder(w).Encode(map[string]any{
|
_ = json.NewEncoder(w).Encode(map[string]any{
|
||||||
"choices": []map[string]any{
|
"choices": []map[string]any{
|
||||||
{"message": map[string]any{"role": "assistant", "content": response}},
|
{"message": map[string]any{"role": "assistant", "content": response}},
|
||||||
},
|
},
|
||||||
@@ -51,7 +51,7 @@ func TestClient_SendsAuthHeader(t *testing.T) {
|
|||||||
var gotAuth string
|
var gotAuth string
|
||||||
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
gotAuth = r.Header.Get("Authorization")
|
gotAuth = r.Header.Get("Authorization")
|
||||||
json.NewEncoder(w).Encode(map[string]any{
|
_ = json.NewEncoder(w).Encode(map[string]any{
|
||||||
"choices": []map[string]any{{"message": map[string]any{"content": "ok"}}},
|
"choices": []map[string]any{{"message": map[string]any{"content": "ok"}}},
|
||||||
})
|
})
|
||||||
}))
|
}))
|
||||||
@@ -72,7 +72,7 @@ func TestClient_Retries429(t *testing.T) {
|
|||||||
w.WriteHeader(http.StatusTooManyRequests)
|
w.WriteHeader(http.StatusTooManyRequests)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
json.NewEncoder(w).Encode(map[string]any{
|
_ = json.NewEncoder(w).Encode(map[string]any{
|
||||||
"choices": []map[string]any{{"message": map[string]any{"content": "retried"}}},
|
"choices": []map[string]any{{"message": map[string]any{"content": "retried"}}},
|
||||||
})
|
})
|
||||||
}))
|
}))
|
||||||
|
|||||||
@@ -37,7 +37,7 @@ func TestRun_WritesPages(t *testing.T) {
|
|||||||
|
|
||||||
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
w.Header().Set("Content-Type", "application/json")
|
w.Header().Set("Content-Type", "application/json")
|
||||||
json.NewEncoder(w).Encode(map[string]any{
|
_ = json.NewEncoder(w).Encode(map[string]any{
|
||||||
"choices": []map[string]any{
|
"choices": []map[string]any{
|
||||||
{"message": map[string]any{"role": "assistant", "content": llmResponse}},
|
{"message": map[string]any{"role": "assistant", "content": llmResponse}},
|
||||||
},
|
},
|
||||||
@@ -77,7 +77,7 @@ func TestRun_DryRunDoesNotWrite(t *testing.T) {
|
|||||||
}})
|
}})
|
||||||
|
|
||||||
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
json.NewEncoder(w).Encode(map[string]any{
|
_ = json.NewEncoder(w).Encode(map[string]any{
|
||||||
"choices": []map[string]any{{"message": map[string]any{"content": llmResponse}}},
|
"choices": []map[string]any{{"message": map[string]any{"content": llmResponse}}},
|
||||||
})
|
})
|
||||||
}))
|
}))
|
||||||
@@ -105,7 +105,7 @@ func TestRun_MergesDuplicatePaths(t *testing.T) {
|
|||||||
})
|
})
|
||||||
|
|
||||||
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
json.NewEncoder(w).Encode(map[string]any{
|
_ = json.NewEncoder(w).Encode(map[string]any{
|
||||||
"choices": []map[string]any{{"message": map[string]any{"content": llmResponse}}},
|
"choices": []map[string]any{{"message": map[string]any{"content": llmResponse}}},
|
||||||
})
|
})
|
||||||
}))
|
}))
|
||||||
|
|||||||
@@ -158,15 +158,15 @@ func copyFile(src, dst string) error {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("open src: %w", err)
|
return fmt.Errorf("open src: %w", err)
|
||||||
}
|
}
|
||||||
defer in.Close()
|
defer in.Close() //nolint:errcheck
|
||||||
|
|
||||||
out, err := os.Create(dst)
|
out, err := os.Create(dst)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("create dst: %w", err)
|
return fmt.Errorf("create dst: %w", err)
|
||||||
}
|
}
|
||||||
defer out.Close()
|
|
||||||
|
|
||||||
if _, err := io.Copy(out, in); err != nil {
|
if _, err := io.Copy(out, in); err != nil {
|
||||||
|
out.Close() //nolint:errcheck
|
||||||
return fmt.Errorf("copy: %w", err)
|
return fmt.Errorf("copy: %w", err)
|
||||||
}
|
}
|
||||||
return out.Close()
|
return out.Close()
|
||||||
@@ -201,10 +201,10 @@ func appendWatcherLog(brainDir, filename string, runErr error, date string) erro
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("open log: %w", err)
|
return fmt.Errorf("open log: %w", err)
|
||||||
}
|
}
|
||||||
defer f.Close()
|
|
||||||
|
|
||||||
if _, err = f.WriteString(entry); err != nil {
|
if _, err = f.WriteString(entry); err != nil {
|
||||||
|
f.Close() //nolint:errcheck
|
||||||
return fmt.Errorf("write log: %w", err)
|
return fmt.Errorf("write log: %w", err)
|
||||||
}
|
}
|
||||||
return nil
|
return f.Close()
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -47,7 +47,7 @@ func readFrontmatter(path, fallbackSlug string) (title string, aliases []string)
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
defer f.Close()
|
defer f.Close() //nolint:errcheck
|
||||||
|
|
||||||
scanner := bufio.NewScanner(f)
|
scanner := bufio.NewScanner(f)
|
||||||
inFM := false
|
inFM := false
|
||||||
|
|||||||
@@ -32,9 +32,9 @@ func AppendLog(brainDir, source string, pages, warnings []string, date string) e
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("open log: %w", err)
|
return fmt.Errorf("open log: %w", err)
|
||||||
}
|
}
|
||||||
defer f.Close()
|
|
||||||
if _, err = f.WriteString(sb.String()); err != nil {
|
if _, err = f.WriteString(sb.String()); err != nil {
|
||||||
|
f.Close() //nolint:errcheck
|
||||||
return fmt.Errorf("write log: %w", err)
|
return fmt.Errorf("write log: %w", err)
|
||||||
}
|
}
|
||||||
return nil
|
return f.Close()
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user