Skip to content

Commit

Permalink
use services.CloseAll
Browse files Browse the repository at this point in the history
  • Loading branch information
dimkouv committed Oct 4, 2024
1 parent ed5508c commit 42439a6
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 9 deletions.
8 changes: 3 additions & 5 deletions core/capabilities/ccip/oraclecreator/wrapped_oracle.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,8 @@ import (
"fmt"
"io"

"github.com/smartcontractkit/chainlink-common/pkg/services"

cctypes "github.com/smartcontractkit/chainlink/v2/core/capabilities/ccip/types"
)

Expand Down Expand Up @@ -34,11 +36,7 @@ func (o *wrappedOracle) Close() error {
errs = append(errs, fmt.Errorf("close base oracle: %w", err))
}

for _, closer := range o.closableResources {
if err := closer.Close(); err != nil {
errs = append(errs, fmt.Errorf("close resource: %w", err))
}
}
errs = append(errs, services.CloseAll(o.closableResources...))

return errors.Join(errs...)
}
8 changes: 4 additions & 4 deletions core/capabilities/ccip/oraclecreator/wrapped_oracle_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -27,14 +27,14 @@ func Test_wrappedOracle_Close(t *testing.T) {
{
name: "oracle and closers errors",
oracleErr: err1,
closerErrors: []error{err2, nil, err3},
expectedErr: errors.New("close base oracle: err1\nclose resource: err2\nclose resource: err3"),
closerErrors: []error{nil, nil, err3},
expectedErr: errors.New("close base oracle: err1\nerr3"),
},
{
name: "closers only errors",
oracleErr: nil,
closerErrors: []error{err2, nil, err3},
expectedErr: errors.New("close resource: err2\nclose resource: err3"),
closerErrors: []error{nil, err2, nil},
expectedErr: err2,
},
{
name: "no errors with closers",
Expand Down

0 comments on commit 42439a6

Please sign in to comment.