Skip to content

Commit b1e15ec

Browse files
committed
refactor(sdk): re-use ID mismatch error
1 parent c38202f commit b1e15ec

4 files changed

Lines changed: 4 additions & 8 deletions

File tree

pkg/adaptation/plugin.go

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@ package adaptation
22

33
import (
44
"context"
5-
"errors"
65
"net"
76
"sync"
87
"time"
@@ -64,10 +63,6 @@ func newExternalPlugin(conn net.Conn, v setupValidator) (*plugin, error) {
6463
}, nil
6564
}
6665

67-
var (
68-
errIDMismatch = errors.New("id mismatch")
69-
)
70-
7166
func (p *plugin) GetSecret(ctx context.Context, request secrets.Request) (secrets.Envelope, error) {
7267
req := connect.NewRequest(v1.GetSecretRequest_builder{
7368
SecretId: proto.String(request.ID.String()),
@@ -81,7 +76,7 @@ func (p *plugin) GetSecret(ctx context.Context, request secrets.Request) (secret
8176
return envelopeErr(request, err), err
8277
}
8378
if id != request.ID {
84-
return envelopeErr(request, errIDMismatch), errIDMismatch
79+
return envelopeErr(request, secrets.ErrIDMismatch), secrets.ErrIDMismatch
8580
}
8681
return secrets.Envelope{
8782
ID: id,

pkg/secrets/secrets.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ import (
99
var (
1010
ErrNotFound = errors.New("secret not found")
1111
ErrAccessDenied = errors.New("access denied") // nuh, uh, uh!
12+
ErrIDMismatch = errors.New("id mismatch")
1213
)
1314

1415
type Request struct {

plugin/resolver.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ func (r *resolverService) GetSecret(ctx context.Context, c *connect.Request[reso
4646
return nil, connect.NewError(connect.CodeInternal, fmt.Errorf("failed to get secret %q: %w", msgID, err))
4747
}
4848
if envelope.ID != id {
49-
return nil, connect.NewError(connect.CodeInternal, fmt.Errorf("secret ID mismatch: expected %q, got %q", id, envelope.ID))
49+
return nil, connect.NewError(connect.CodeInternal, secrets.ErrIDMismatch)
5050
}
5151
return connect.NewResponse(resolverv1.GetSecretResponse_builder{
5252
SecretId: proto.String(envelope.ID.String()),

plugin/resolver_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ func TestResolverService_GetSecret(t *testing.T) {
118118
close(done)
119119
s := &resolverService{resolver: newMockResolver(t, withMockResolverID("wrongID")), setupCompleted: done, registrationTimeout: 10 * time.Second}
120120
_, err := s.GetSecret(t.Context(), newGetSecretRequest(mockSecretID))
121-
assert.ErrorContains(t, err, "secret ID mismatch")
121+
assert.ErrorIs(t, err, secrets.ErrIDMismatch)
122122
},
123123
},
124124
{

0 commit comments

Comments
 (0)