fix: duplicate error

api/client_test.go

@@ -482,7 +482,7 @@ func TestClient_CreateSubscription(t *testing.T) {
 		"busy": {
 			svcSubs: subscriptions.NewServiceMock(),
 			descr:   "busy",
-			err:     subscriptions.ErrBusy,
+			err:     subscriptions.ErrUnavailable,
 		},
 	}
 	for k, c := range cases {

api/grpc/subscriptions/service.go

@@ -39,9 +39,6 @@ type service struct {
 // ErrNotFound indicates the subscription is missing in the storage and can not be read/updated/deleted.
 var ErrNotFound = errors.New("subscription was not found")
 
-// ErrBusy indicates a storage entity is locked and the operation should be retried.
-var ErrBusy = errors.New("subscription is busy, retry the operation")
-
 // ErrInternal indicates some unexpected internal failure.
 var ErrInternal = errors.New("internal failure")
 
@@ -262,8 +259,6 @@ func decodeError(src error) (dst error) {
 			dst = fmt.Errorf("%w: %s", ErrInvalid, src)
 		case s.Code() == codes.ResourceExhausted:
 			dst = fmt.Errorf("%w: %s", limits.ErrReached, src)
-		case s.Code() == codes.Unavailable:
-			dst = fmt.Errorf("%w: %s", ErrBusy, src)
 		case s.Code() == codes.Unauthenticated:
 			dst = fmt.Errorf("%w: %s", auth.ErrAuth, src)
 		case s.Code() == codes.Unavailable:

api/grpc/subscriptions/service_mock.go

@@ -27,7 +27,7 @@ func (sm serviceMock) Create(ctx context.Context, userId string, subData subscri
 	case "limit_reached":
 		err = limits.ErrReached
 	case "busy":
-		err = ErrBusy
+		err = ErrUnavailable
 	default:
 		id = "sub0"
 	}

api/grpc/subscriptions/service_test.go

@@ -37,7 +37,7 @@ func TestService_Create(t *testing.T) {
 					"locked", false,
 				),
 			},
-			err: ErrBusy,
+			err: ErrUnavailable,
 		},
 		"fail": {
 			req: subscription.Data{