core/agent
8
0
Fork 0
Code Issues 5 Pull requests Projects Releases Packages Wiki Activity Actions

fix(agentic): close transport response bodies

Browse source 
Co-Authored-By: Virgil <virgil@lethean.io>
This commit is contained in:
Virgil 2026-04-02 07:01:51 +00:00
parent e5472f6aa5
commit f5fdbb8cac
1 changed files with 8 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
pkg/agentic/transport.go
View file

@ -20,6 +20,8 @@ type httpStream struct {
response []byte
}
// stream := &httpStream{client: defaultClient, url: "https://api.lthn.sh/v1/health", method: "POST"}
// _ = stream.Send([]byte(`{"ping":1}`))
func (s *httpStream) Send(data []byte) error {
request, err := http.NewRequestWithContext(context.Background(), s.method, s.url, core.NewReader(string(data)))
if err != nil {
@ -35,6 +37,7 @@ func (s *httpStream) Send(data []byte) error {
if err != nil {
return err
}
defer response.Body.Close()
readResult := core.ReadAll(response.Body)
if !readResult.OK {
@ -45,10 +48,14 @@ func (s *httpStream) Send(data []byte) error {
return nil
}
// stream := &httpStream{}
// response, err := stream.Receive()
func (s *httpStream) Receive() ([]byte, error) {
return s.response, nil
}
// stream := &httpStream{}
// _ = stream.Close()
func (s *httpStream) Close() error {
return nil
}
@ -155,6 +162,7 @@ func httpDo(ctx context.Context, method, url, body, token, authScheme string) co
if requestErr != nil {
return core.Result{Value: core.E("httpDo", "request failed", requestErr), OK: false}
}
defer response.Body.Close()
readResult := core.ReadAll(response.Body)
if !readResult.OK {