refactor(api): remove unused Allocate RPC from Query service

api/dwn/v1/query_grpc.pb.go

@@ -19,8 +19,7 @@ import (
 const _ = grpc.SupportPackageIsVersion9
 
 const (
-	Query_Params_FullMethodName   = "/dwn.v1.Query/Params"
+	Query_Params_FullMethodName = "/dwn.v1.Query/Params"
-	Query_Allocate_FullMethodName = "/dwn.v1.Query/Allocate"
 )
 
 // QueryClient is the client API for Query service.
@@ -31,9 +30,6 @@ const (
 type QueryClient interface {
 	// Params queries all parameters of the module.
 	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
-	// Allocate initializes a Target Vault available for claims with a compatible
-	// Authentication mechanism. The default authentication mechanism is WebAuthn.
-	Allocate(ctx context.Context, in *QueryAllocateRequest, opts ...grpc.CallOption) (*QueryAllocateResponse, error)
 }
 
 type queryClient struct {
@@ -54,16 +50,6 @@ func (c *queryClient) Params(ctx context.Context, in *QueryParamsRequest, opts .
 	return out, nil
 }
 
-func (c *queryClient) Allocate(ctx context.Context, in *QueryAllocateRequest, opts ...grpc.CallOption) (*QueryAllocateResponse, error) {
-	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
-	out := new(QueryAllocateResponse)
-	err := c.cc.Invoke(ctx, Query_Allocate_FullMethodName, in, out, cOpts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
 // QueryServer is the server API for Query service.
 // All implementations must embed UnimplementedQueryServer
 // for forward compatibility.
@@ -72,9 +58,6 @@ func (c *queryClient) Allocate(ctx context.Context, in *QueryAllocateRequest, op
 type QueryServer interface {
 	// Params queries all parameters of the module.
 	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
-	// Allocate initializes a Target Vault available for claims with a compatible
-	// Authentication mechanism. The default authentication mechanism is WebAuthn.
-	Allocate(context.Context, *QueryAllocateRequest) (*QueryAllocateResponse, error)
 	mustEmbedUnimplementedQueryServer()
 }
 
@@ -88,9 +71,6 @@ type UnimplementedQueryServer struct{}
 func (UnimplementedQueryServer) Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method Params not implemented")
 }
-func (UnimplementedQueryServer) Allocate(context.Context, *QueryAllocateRequest) (*QueryAllocateResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method Allocate not implemented")
-}
 func (UnimplementedQueryServer) mustEmbedUnimplementedQueryServer() {}
 func (UnimplementedQueryServer) testEmbeddedByValue()               {}
 
@@ -130,24 +110,6 @@ func _Query_Params_Handler(srv interface{}, ctx context.Context, dec func(interf
 	return interceptor(ctx, in, info, handler)
 }
 
-func _Query_Allocate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(QueryAllocateRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(QueryServer).Allocate(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: Query_Allocate_FullMethodName,
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(QueryServer).Allocate(ctx, req.(*QueryAllocateRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
 // Query_ServiceDesc is the grpc.ServiceDesc for Query service.
 // It's only intended for direct use with grpc.RegisterService,
 // and not to be introspected or modified (even as a copy)
@@ -159,10 +121,6 @@ var Query_ServiceDesc = grpc.ServiceDesc{
 			MethodName: "Params",
 			Handler:    _Query_Params_Handler,
 		},
-		{
-			MethodName: "Allocate",
-			Handler:    _Query_Allocate_Handler,
-		},
 	},
 	Streams:  []grpc.StreamDesc{},
 	Metadata: "dwn/v1/query.proto",

proto/dwn/v1/query.proto

@@ -16,13 +16,6 @@ service Query {
   rpc Params(QueryParamsRequest) returns (QueryParamsResponse) {
     option (google.api.http).get = "/vault/v1/params";
   }
-
-
-  // Allocate initializes a Target Vault available for claims with a compatible
-  // Authentication mechanism. The default authentication mechanism is WebAuthn.
-  rpc Allocate(QueryAllocateRequest) returns (QueryAllocateResponse) {
-    option (google.api.http).get = "/vault/v1/allocate";
-  }
 }
 
 // ╭──────────────────────────────────────────────────────────╮
@@ -38,15 +31,3 @@ message QueryParamsResponse {
   Params params = 1;
 }
 
-// QueryAllocateRequest is the request type for the Allocate RPC method.
-message QueryAllocateRequest {}
-
-// AllocateResponse is the response type for the Allocate RPC method.
-message QueryAllocateResponse {
-  bool success = 1;
-  string cid = 2;
-  string macaroon = 3;
-  string public_uri = 4;
-  int64 expiry_block = 5;
-}
-

x/dwn/keeper/query_server.go

@@ -28,10 +28,3 @@ func (k Querier) Params(c context.Context, req *types.QueryParamsRequest) (*type
 
 	return &types.QueryParamsResponse{Params: &p}, nil
 }
-
-// Allocate implements types.QueryServer.
-func (k Querier) Allocate(goCtx context.Context, req *types.QueryAllocateRequest) (*types.QueryAllocateResponse, error) {
-	// ctx := sdk.UnwrapSDKContext(goCtx)
-	panic("Allocate is unimplemented")
-	return &types.QueryAllocateResponse{}, nil
-}

x/dwn/types/query.pb.go

@@ -111,156 +111,31 @@ func (m *QueryParamsResponse) GetParams() *Params {
 	return nil
 }
 
-// QueryAllocateRequest is the request type for the Allocate RPC method.
-type QueryAllocateRequest struct {
-}
-
-func (m *QueryAllocateRequest) Reset()         { *m = QueryAllocateRequest{} }
-func (m *QueryAllocateRequest) String() string { return proto.CompactTextString(m) }
-func (*QueryAllocateRequest) ProtoMessage()    {}
-func (*QueryAllocateRequest) Descriptor() ([]byte, []int) {
-	return fileDescriptor_9a31dfed63924cb3, []int{2}
-}
-func (m *QueryAllocateRequest) XXX_Unmarshal(b []byte) error {
-	return m.Unmarshal(b)
-}
-func (m *QueryAllocateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
-	if deterministic {
-		return xxx_messageInfo_QueryAllocateRequest.Marshal(b, m, deterministic)
-	} else {
-		b = b[:cap(b)]
-		n, err := m.MarshalToSizedBuffer(b)
-		if err != nil {
-			return nil, err
-		}
-		return b[:n], nil
-	}
-}
-func (m *QueryAllocateRequest) XXX_Merge(src proto.Message) {
-	xxx_messageInfo_QueryAllocateRequest.Merge(m, src)
-}
-func (m *QueryAllocateRequest) XXX_Size() int {
-	return m.Size()
-}
-func (m *QueryAllocateRequest) XXX_DiscardUnknown() {
-	xxx_messageInfo_QueryAllocateRequest.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_QueryAllocateRequest proto.InternalMessageInfo
-
-// AllocateResponse is the response type for the Allocate RPC method.
-type QueryAllocateResponse struct {
-	Success     bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
-	Cid         string `protobuf:"bytes,2,opt,name=cid,proto3" json:"cid,omitempty"`
-	Macaroon    string `protobuf:"bytes,3,opt,name=macaroon,proto3" json:"macaroon,omitempty"`
-	PublicUri   string `protobuf:"bytes,4,opt,name=public_uri,json=publicUri,proto3" json:"public_uri,omitempty"`
-	ExpiryBlock int64  `protobuf:"varint,5,opt,name=expiry_block,json=expiryBlock,proto3" json:"expiry_block,omitempty"`
-}
-
-func (m *QueryAllocateResponse) Reset()         { *m = QueryAllocateResponse{} }
-func (m *QueryAllocateResponse) String() string { return proto.CompactTextString(m) }
-func (*QueryAllocateResponse) ProtoMessage()    {}
-func (*QueryAllocateResponse) Descriptor() ([]byte, []int) {
-	return fileDescriptor_9a31dfed63924cb3, []int{3}
-}
-func (m *QueryAllocateResponse) XXX_Unmarshal(b []byte) error {
-	return m.Unmarshal(b)
-}
-func (m *QueryAllocateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
-	if deterministic {
-		return xxx_messageInfo_QueryAllocateResponse.Marshal(b, m, deterministic)
-	} else {
-		b = b[:cap(b)]
-		n, err := m.MarshalToSizedBuffer(b)
-		if err != nil {
-			return nil, err
-		}
-		return b[:n], nil
-	}
-}
-func (m *QueryAllocateResponse) XXX_Merge(src proto.Message) {
-	xxx_messageInfo_QueryAllocateResponse.Merge(m, src)
-}
-func (m *QueryAllocateResponse) XXX_Size() int {
-	return m.Size()
-}
-func (m *QueryAllocateResponse) XXX_DiscardUnknown() {
-	xxx_messageInfo_QueryAllocateResponse.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_QueryAllocateResponse proto.InternalMessageInfo
-
-func (m *QueryAllocateResponse) GetSuccess() bool {
-	if m != nil {
-		return m.Success
-	}
-	return false
-}
-
-func (m *QueryAllocateResponse) GetCid() string {
-	if m != nil {
-		return m.Cid
-	}
-	return ""
-}
-
-func (m *QueryAllocateResponse) GetMacaroon() string {
-	if m != nil {
-		return m.Macaroon
-	}
-	return ""
-}
-
-func (m *QueryAllocateResponse) GetPublicUri() string {
-	if m != nil {
-		return m.PublicUri
-	}
-	return ""
-}
-
-func (m *QueryAllocateResponse) GetExpiryBlock() int64 {
-	if m != nil {
-		return m.ExpiryBlock
-	}
-	return 0
-}
-
 func init() {
 	proto.RegisterType((*QueryParamsRequest)(nil), "dwn.v1.QueryParamsRequest")
 	proto.RegisterType((*QueryParamsResponse)(nil), "dwn.v1.QueryParamsResponse")
-	proto.RegisterType((*QueryAllocateRequest)(nil), "dwn.v1.QueryAllocateRequest")
-	proto.RegisterType((*QueryAllocateResponse)(nil), "dwn.v1.QueryAllocateResponse")
 }
 
 func init() { proto.RegisterFile("dwn/v1/query.proto", fileDescriptor_9a31dfed63924cb3) }
 
 var fileDescriptor_9a31dfed63924cb3 = []byte{
-	// 399 bytes of a gzipped FileDescriptorProto
+	// 254 bytes of a gzipped FileDescriptorProto
-	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x52, 0xcd, 0x8e, 0xd3, 0x30,
+	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x12, 0x4a, 0x29, 0xcf, 0xd3,
-	0x10, 0xae, 0xb7, 0x6c, 0xe8, 0x7a, 0x11, 0x5a, 0x0d, 0x01, 0x45, 0x61, 0x37, 0x2a, 0x39, 0xa0,
+	0x2f, 0x33, 0xd4, 0x2f, 0x2c, 0x4d, 0x2d, 0xaa, 0xd4, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0x62,
-	0x9e, 0x62, 0xed, 0x72, 0x85, 0x03, 0xfb, 0x04, 0x10, 0x89, 0x0b, 0x1c, 0x56, 0x8e, 0x6b, 0x05,
+	0x4b, 0x29, 0xcf, 0xd3, 0x2b, 0x33, 0x94, 0x92, 0x49, 0xcf, 0xcf, 0x4f, 0xcf, 0x49, 0xd5, 0x4f,
-	0x8b, 0xd4, 0x4e, 0x6d, 0xa7, 0x3f, 0x57, 0x9e, 0x00, 0x89, 0x27, 0xe0, 0x6d, 0xe0, 0x56, 0x89,
+	0x2c, 0xc8, 0xd4, 0x4f, 0xcc, 0xcb, 0xcb, 0x2f, 0x49, 0x2c, 0xc9, 0xcc, 0xcf, 0x2b, 0x86, 0xa8,
-	0x0b, 0x47, 0xd4, 0xf2, 0x20, 0x28, 0x76, 0x02, 0x6a, 0x61, 0x2f, 0x51, 0xe6, 0xfb, 0x66, 0xbe,
+	0x92, 0x12, 0x81, 0xea, 0x4c, 0x4f, 0xcd, 0x4b, 0x2d, 0xce, 0x84, 0x8a, 0x2a, 0x89, 0x70, 0x09,
-	0xcf, 0xf3, 0x69, 0x30, 0x4c, 0x97, 0x92, 0x2c, 0x2e, 0xc9, 0xbc, 0xe1, 0x7a, 0x9d, 0xd5, 0x5a,
+	0x05, 0x82, 0x8c, 0x0a, 0x48, 0x2c, 0x4a, 0xcc, 0x2d, 0x0e, 0x4a, 0x2d, 0x2c, 0x4d, 0x2d, 0x2e,
-	0x59, 0x05, 0xc1, 0x74, 0x29, 0xb3, 0xc5, 0x65, 0x7c, 0x5e, 0x2a, 0x55, 0x56, 0x9c, 0xd0, 0x5a,
+	0x51, 0xb2, 0xe5, 0x12, 0x46, 0x11, 0x2d, 0x2e, 0xc8, 0xcf, 0x2b, 0x4e, 0x15, 0x52, 0xe3, 0x62,
-	0x10, 0x2a, 0xa5, 0xb2, 0xd4, 0x0a, 0x25, 0x8d, 0xef, 0x8a, 0xc3, 0x6e, 0xb2, 0xe4, 0x92, 0x1b,
+	0x2b, 0x00, 0x8b, 0x48, 0x30, 0x2a, 0x30, 0x6a, 0x70, 0x1b, 0xf1, 0xe9, 0x41, 0x6c, 0xd6, 0x83,
-	0xd1, 0xa1, 0x69, 0x88, 0xe1, 0x75, 0x2b, 0xf5, 0x8a, 0x6a, 0x3a, 0x33, 0x39, 0x9f, 0x37, 0xdc,
+	0xaa, 0x83, 0xca, 0x1a, 0xa5, 0x70, 0xb1, 0x82, 0xb5, 0x0b, 0x45, 0x73, 0xb1, 0x41, 0xa4, 0x84,
-	0xd8, 0xf4, 0x05, 0x7e, 0xb0, 0x87, 0x9a, 0x5a, 0x49, 0xc3, 0xe1, 0x29, 0x0e, 0x6a, 0x87, 0x44,
+	0xa4, 0x60, 0x4a, 0x31, 0x6d, 0x93, 0x92, 0xc6, 0x2a, 0x07, 0xb1, 0x53, 0x49, 0xa2, 0xe9, 0xf2,
-	0x68, 0x8c, 0x26, 0xa7, 0x57, 0xf7, 0x33, 0xef, 0x9c, 0x75, 0x7d, 0x1d, 0x9b, 0x3e, 0xc2, 0xa1,
+	0x93, 0xc9, 0x4c, 0x42, 0x42, 0x02, 0xfa, 0x65, 0x89, 0xa5, 0x39, 0x25, 0x20, 0x1f, 0x40, 0x6c,
-	0x1b, 0x7f, 0x59, 0x55, 0x8a, 0x51, 0xcb, 0x7b, 0xd9, 0x2f, 0x08, 0x3f, 0x3c, 0x20, 0x3a, 0xe5,
+	0x71, 0xb2, 0x39, 0xf1, 0x48, 0x8e, 0xf1, 0xc2, 0x23, 0x39, 0xc6, 0x07, 0x8f, 0xe4, 0x18, 0x27,
-	0x08, 0xdf, 0x35, 0x0d, 0x63, 0xdc, 0x78, 0xe9, 0x51, 0xde, 0x97, 0x70, 0x86, 0x87, 0x4c, 0x4c,
+	0x3c, 0x96, 0x63, 0xb8, 0xf0, 0x58, 0x8e, 0xe1, 0xc6, 0x63, 0x39, 0x86, 0x28, 0xa5, 0xf4, 0xcc,
-	0xa3, 0xa3, 0x31, 0x9a, 0x9c, 0xe4, 0xed, 0x2f, 0xc4, 0x78, 0x34, 0xa3, 0x8c, 0x6a, 0xa5, 0x64,
+	0x92, 0x8c, 0xd2, 0x24, 0xbd, 0xe4, 0xfc, 0x5c, 0xfd, 0xfc, 0xbc, 0xe2, 0xfc, 0xbc, 0x22, 0x7d,
-	0x34, 0x74, 0xf0, 0x9f, 0x1a, 0x2e, 0x30, 0xae, 0x9b, 0xa2, 0x12, 0xec, 0xa6, 0xd1, 0x22, 0xba,
+	0x30, 0x51, 0xa1, 0x0f, 0x0a, 0x83, 0x92, 0xca, 0x82, 0xd4, 0xe2, 0x24, 0x36, 0xb0, 0xff, 0x8d,
-	0xe3, 0xd8, 0x13, 0x8f, 0xbc, 0xd1, 0x02, 0x9e, 0xe0, 0x7b, 0x7c, 0x55, 0x0b, 0xbd, 0xbe, 0x29,
+	0x01, 0x01, 0x00, 0x00, 0xff, 0xff, 0x9d, 0xd6, 0xd8, 0xe6, 0x51, 0x01, 0x00, 0x00,
-	0x2a, 0xc5, 0x3e, 0x44, 0xc7, 0x63, 0x34, 0x19, 0xe6, 0xa7, 0x1e, 0xbb, 0x6e, 0xa1, 0xab, 0x6f,
-	0x08, 0x1f, 0xbb, 0x37, 0xc2, 0x3b, 0x1c, 0xf8, 0xbd, 0x20, 0xee, 0xf7, 0xfc, 0x37, 0xaa, 0xf8,
-	0xf1, 0x7f, 0x39, 0xbf, 0x56, 0x1a, 0x7d, 0xfc, 0xfe, 0xeb, 0xf3, 0x11, 0xc0, 0x19, 0x59, 0xd0,
-	0xa6, 0xb2, 0x6d, 0xfc, 0x3e, 0x22, 0x60, 0x78, 0xd4, 0x87, 0x00, 0xe7, 0x7b, 0x12, 0x07, 0xa1,
-	0xc5, 0x17, 0xb7, 0xb0, 0x9d, 0x45, 0xec, 0x2c, 0x42, 0x80, 0xbf, 0x16, 0xb4, 0xeb, 0xb9, 0x7e,
-	0xfe, 0x75, 0x9b, 0xa0, 0xcd, 0x36, 0x41, 0x3f, 0xb7, 0x09, 0xfa, 0xb4, 0x4b, 0x06, 0x9b, 0x5d,
-	0x32, 0xf8, 0xb1, 0x4b, 0x06, 0x6f, 0xd3, 0x52, 0xd8, 0xf7, 0x4d, 0x91, 0x31, 0x35, 0x23, 0x4a,
-	0x1a, 0x25, 0x35, 0x71, 0x9f, 0x15, 0x69, 0xaf, 0xc4, 0xae, 0x6b, 0x6e, 0x8a, 0xc0, 0x5d, 0xc8,
-	0xb3, 0xdf, 0x01, 0x00, 0x00, 0xff, 0xff, 0x14, 0x99, 0xd4, 0xa2, 0x73, 0x02, 0x00, 0x00,
 }
 
 // Reference imports to suppress errors if they are not otherwise used.
@@ -277,9 +152,6 @@ const _ = grpc.SupportPackageIsVersion4
 type QueryClient interface {
 	// Params queries all parameters of the module.
 	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
-	// Allocate initializes a Target Vault available for claims with a compatible
-	// Authentication mechanism. The default authentication mechanism is WebAuthn.
-	Allocate(ctx context.Context, in *QueryAllocateRequest, opts ...grpc.CallOption) (*QueryAllocateResponse, error)
 }
 
 type queryClient struct {
@@ -299,22 +171,10 @@ func (c *queryClient) Params(ctx context.Context, in *QueryParamsRequest, opts .
 	return out, nil
 }
 
-func (c *queryClient) Allocate(ctx context.Context, in *QueryAllocateRequest, opts ...grpc.CallOption) (*QueryAllocateResponse, error) {
-	out := new(QueryAllocateResponse)
-	err := c.cc.Invoke(ctx, "/dwn.v1.Query/Allocate", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
 // QueryServer is the server API for Query service.
 type QueryServer interface {
 	// Params queries all parameters of the module.
 	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
-	// Allocate initializes a Target Vault available for claims with a compatible
-	// Authentication mechanism. The default authentication mechanism is WebAuthn.
-	Allocate(context.Context, *QueryAllocateRequest) (*QueryAllocateResponse, error)
 }
 
 // UnimplementedQueryServer can be embedded to have forward compatible implementations.
@@ -324,9 +184,6 @@ type UnimplementedQueryServer struct {
 func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method Params not implemented")
 }
-func (*UnimplementedQueryServer) Allocate(ctx context.Context, req *QueryAllocateRequest) (*QueryAllocateResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method Allocate not implemented")
-}
 
 func RegisterQueryServer(s grpc1.Server, srv QueryServer) {
 	s.RegisterService(&_Query_serviceDesc, srv)
@@ -350,24 +207,6 @@ func _Query_Params_Handler(srv interface{}, ctx context.Context, dec func(interf
 	return interceptor(ctx, in, info, handler)
 }
 
-func _Query_Allocate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(QueryAllocateRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(QueryServer).Allocate(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/dwn.v1.Query/Allocate",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(QueryServer).Allocate(ctx, req.(*QueryAllocateRequest))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
 var Query_serviceDesc = _Query_serviceDesc
 var _Query_serviceDesc = grpc.ServiceDesc{
 	ServiceName: "dwn.v1.Query",
@@ -377,10 +216,6 @@ var _Query_serviceDesc = grpc.ServiceDesc{
 			MethodName: "Params",
 			Handler:    _Query_Params_Handler,
 		},
-		{
-			MethodName: "Allocate",
-			Handler:    _Query_Allocate_Handler,
-		},
 	},
 	Streams:  []grpc.StreamDesc{},
 	Metadata: "dwn/v1/query.proto",
@@ -444,88 +279,6 @@ func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
 	return len(dAtA) - i, nil
 }
 
-func (m *QueryAllocateRequest) Marshal() (dAtA []byte, err error) {
-	size := m.Size()
-	dAtA = make([]byte, size)
-	n, err := m.MarshalToSizedBuffer(dAtA[:size])
-	if err != nil {
-		return nil, err
-	}
-	return dAtA[:n], nil
-}
-
-func (m *QueryAllocateRequest) MarshalTo(dAtA []byte) (int, error) {
-	size := m.Size()
-	return m.MarshalToSizedBuffer(dAtA[:size])
-}
-
-func (m *QueryAllocateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
-	i := len(dAtA)
-	_ = i
-	var l int
-	_ = l
-	return len(dAtA) - i, nil
-}
-
-func (m *QueryAllocateResponse) Marshal() (dAtA []byte, err error) {
-	size := m.Size()
-	dAtA = make([]byte, size)
-	n, err := m.MarshalToSizedBuffer(dAtA[:size])
-	if err != nil {
-		return nil, err
-	}
-	return dAtA[:n], nil
-}
-
-func (m *QueryAllocateResponse) MarshalTo(dAtA []byte) (int, error) {
-	size := m.Size()
-	return m.MarshalToSizedBuffer(dAtA[:size])
-}
-
-func (m *QueryAllocateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
-	i := len(dAtA)
-	_ = i
-	var l int
-	_ = l
-	if m.ExpiryBlock != 0 {
-		i = encodeVarintQuery(dAtA, i, uint64(m.ExpiryBlock))
-		i--
-		dAtA[i] = 0x28
-	}
-	if len(m.PublicUri) > 0 {
-		i -= len(m.PublicUri)
-		copy(dAtA[i:], m.PublicUri)
-		i = encodeVarintQuery(dAtA, i, uint64(len(m.PublicUri)))
-		i--
-		dAtA[i] = 0x22
-	}
-	if len(m.Macaroon) > 0 {
-		i -= len(m.Macaroon)
-		copy(dAtA[i:], m.Macaroon)
-		i = encodeVarintQuery(dAtA, i, uint64(len(m.Macaroon)))
-		i--
-		dAtA[i] = 0x1a
-	}
-	if len(m.Cid) > 0 {
-		i -= len(m.Cid)
-		copy(dAtA[i:], m.Cid)
-		i = encodeVarintQuery(dAtA, i, uint64(len(m.Cid)))
-		i--
-		dAtA[i] = 0x12
-	}
-	if m.Success {
-		i--
-		if m.Success {
-			dAtA[i] = 1
-		} else {
-			dAtA[i] = 0
-		}
-		i--
-		dAtA[i] = 0x8
-	}
-	return len(dAtA) - i, nil
-}
-
 func encodeVarintQuery(dAtA []byte, offset int, v uint64) int {
 	offset -= sovQuery(v)
 	base := offset
@@ -559,42 +312,6 @@ func (m *QueryParamsResponse) Size() (n int) {
 	return n
 }
 
-func (m *QueryAllocateRequest) Size() (n int) {
-	if m == nil {
-		return 0
-	}
-	var l int
-	_ = l
-	return n
-}
-
-func (m *QueryAllocateResponse) Size() (n int) {
-	if m == nil {
-		return 0
-	}
-	var l int
-	_ = l
-	if m.Success {
-		n += 2
-	}
-	l = len(m.Cid)
-	if l > 0 {
-		n += 1 + l + sovQuery(uint64(l))
-	}
-	l = len(m.Macaroon)
-	if l > 0 {
-		n += 1 + l + sovQuery(uint64(l))
-	}
-	l = len(m.PublicUri)
-	if l > 0 {
-		n += 1 + l + sovQuery(uint64(l))
-	}
-	if m.ExpiryBlock != 0 {
-		n += 1 + sovQuery(uint64(m.ExpiryBlock))
-	}
-	return n
-}
-
 func sovQuery(x uint64) (n int) {
 	return (math_bits.Len64(x|1) + 6) / 7
 }
@@ -737,241 +454,6 @@ func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error {
 	}
 	return nil
 }
-func (m *QueryAllocateRequest) Unmarshal(dAtA []byte) error {
-	l := len(dAtA)
-	iNdEx := 0
-	for iNdEx < l {
-		preIndex := iNdEx
-		var wire uint64
-		for shift := uint(0); ; shift += 7 {
-			if shift >= 64 {
-				return ErrIntOverflowQuery
-			}
-			if iNdEx >= l {
-				return io.ErrUnexpectedEOF
-			}
-			b := dAtA[iNdEx]
-			iNdEx++
-			wire |= uint64(b&0x7F) << shift
-			if b < 0x80 {
-				break
-			}
-		}
-		fieldNum := int32(wire >> 3)
-		wireType := int(wire & 0x7)
-		if wireType == 4 {
-			return fmt.Errorf("proto: QueryAllocateRequest: wiretype end group for non-group")
-		}
-		if fieldNum <= 0 {
-			return fmt.Errorf("proto: QueryAllocateRequest: illegal tag %d (wire type %d)", fieldNum, wire)
-		}
-		switch fieldNum {
-		default:
-			iNdEx = preIndex
-			skippy, err := skipQuery(dAtA[iNdEx:])
-			if err != nil {
-				return err
-			}
-			if (skippy < 0) || (iNdEx+skippy) < 0 {
-				return ErrInvalidLengthQuery
-			}
-			if (iNdEx + skippy) > l {
-				return io.ErrUnexpectedEOF
-			}
-			iNdEx += skippy
-		}
-	}
-
-	if iNdEx > l {
-		return io.ErrUnexpectedEOF
-	}
-	return nil
-}
-func (m *QueryAllocateResponse) Unmarshal(dAtA []byte) error {
-	l := len(dAtA)
-	iNdEx := 0
-	for iNdEx < l {
-		preIndex := iNdEx
-		var wire uint64
-		for shift := uint(0); ; shift += 7 {
-			if shift >= 64 {
-				return ErrIntOverflowQuery
-			}
-			if iNdEx >= l {
-				return io.ErrUnexpectedEOF
-			}
-			b := dAtA[iNdEx]
-			iNdEx++
-			wire |= uint64(b&0x7F) << shift
-			if b < 0x80 {
-				break
-			}
-		}
-		fieldNum := int32(wire >> 3)
-		wireType := int(wire & 0x7)
-		if wireType == 4 {
-			return fmt.Errorf("proto: QueryAllocateResponse: wiretype end group for non-group")
-		}
-		if fieldNum <= 0 {
-			return fmt.Errorf("proto: QueryAllocateResponse: illegal tag %d (wire type %d)", fieldNum, wire)
-		}
-		switch fieldNum {
-		case 1:
-			if wireType != 0 {
-				return fmt.Errorf("proto: wrong wireType = %d for field Success", wireType)
-			}
-			var v int
-			for shift := uint(0); ; shift += 7 {
-				if shift >= 64 {
-					return ErrIntOverflowQuery
-				}
-				if iNdEx >= l {
-					return io.ErrUnexpectedEOF
-				}
-				b := dAtA[iNdEx]
-				iNdEx++
-				v |= int(b&0x7F) << shift
-				if b < 0x80 {
-					break
-				}
-			}
-			m.Success = bool(v != 0)
-		case 2:
-			if wireType != 2 {
-				return fmt.Errorf("proto: wrong wireType = %d for field Cid", wireType)
-			}
-			var stringLen uint64
-			for shift := uint(0); ; shift += 7 {
-				if shift >= 64 {
-					return ErrIntOverflowQuery
-				}
-				if iNdEx >= l {
-					return io.ErrUnexpectedEOF
-				}
-				b := dAtA[iNdEx]
-				iNdEx++
-				stringLen |= uint64(b&0x7F) << shift
-				if b < 0x80 {
-					break
-				}
-			}
-			intStringLen := int(stringLen)
-			if intStringLen < 0 {
-				return ErrInvalidLengthQuery
-			}
-			postIndex := iNdEx + intStringLen
-			if postIndex < 0 {
-				return ErrInvalidLengthQuery
-			}
-			if postIndex > l {
-				return io.ErrUnexpectedEOF
-			}
-			m.Cid = string(dAtA[iNdEx:postIndex])
-			iNdEx = postIndex
-		case 3:
-			if wireType != 2 {
-				return fmt.Errorf("proto: wrong wireType = %d for field Macaroon", wireType)
-			}
-			var stringLen uint64
-			for shift := uint(0); ; shift += 7 {
-				if shift >= 64 {
-					return ErrIntOverflowQuery
-				}
-				if iNdEx >= l {
-					return io.ErrUnexpectedEOF
-				}
-				b := dAtA[iNdEx]
-				iNdEx++
-				stringLen |= uint64(b&0x7F) << shift
-				if b < 0x80 {
-					break
-				}
-			}
-			intStringLen := int(stringLen)
-			if intStringLen < 0 {
-				return ErrInvalidLengthQuery
-			}
-			postIndex := iNdEx + intStringLen
-			if postIndex < 0 {
-				return ErrInvalidLengthQuery
-			}
-			if postIndex > l {
-				return io.ErrUnexpectedEOF
-			}
-			m.Macaroon = string(dAtA[iNdEx:postIndex])
-			iNdEx = postIndex
-		case 4:
-			if wireType != 2 {
-				return fmt.Errorf("proto: wrong wireType = %d for field PublicUri", wireType)
-			}
-			var stringLen uint64
-			for shift := uint(0); ; shift += 7 {
-				if shift >= 64 {
-					return ErrIntOverflowQuery
-				}
-				if iNdEx >= l {
-					return io.ErrUnexpectedEOF
-				}
-				b := dAtA[iNdEx]
-				iNdEx++
-				stringLen |= uint64(b&0x7F) << shift
-				if b < 0x80 {
-					break
-				}
-			}
-			intStringLen := int(stringLen)
-			if intStringLen < 0 {
-				return ErrInvalidLengthQuery
-			}
-			postIndex := iNdEx + intStringLen
-			if postIndex < 0 {
-				return ErrInvalidLengthQuery
-			}
-			if postIndex > l {
-				return io.ErrUnexpectedEOF
-			}
-			m.PublicUri = string(dAtA[iNdEx:postIndex])
-			iNdEx = postIndex
-		case 5:
-			if wireType != 0 {
-				return fmt.Errorf("proto: wrong wireType = %d for field ExpiryBlock", wireType)
-			}
-			m.ExpiryBlock = 0
-			for shift := uint(0); ; shift += 7 {
-				if shift >= 64 {
-					return ErrIntOverflowQuery
-				}
-				if iNdEx >= l {
-					return io.ErrUnexpectedEOF
-				}
-				b := dAtA[iNdEx]
-				iNdEx++
-				m.ExpiryBlock |= int64(b&0x7F) << shift
-				if b < 0x80 {
-					break
-				}
-			}
-		default:
-			iNdEx = preIndex
-			skippy, err := skipQuery(dAtA[iNdEx:])
-			if err != nil {
-				return err
-			}
-			if (skippy < 0) || (iNdEx+skippy) < 0 {
-				return ErrInvalidLengthQuery
-			}
-			if (iNdEx + skippy) > l {
-				return io.ErrUnexpectedEOF
-			}
-			iNdEx += skippy
-		}
-	}
-
-	if iNdEx > l {
-		return io.ErrUnexpectedEOF
-	}
-	return nil
-}
 func skipQuery(dAtA []byte) (n int, err error) {
 	l := len(dAtA)
 	iNdEx := 0

x/dwn/types/query.pb.gw.go

@@ -51,24 +51,6 @@ func local_request_Query_Params_0(ctx context.Context, marshaler runtime.Marshal
 
 }
 
-func request_Query_Allocate_0(ctx context.Context, marshaler runtime.Marshaler, client QueryClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
-	var protoReq QueryAllocateRequest
-	var metadata runtime.ServerMetadata
-
-	msg, err := client.Allocate(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
-	return msg, metadata, err
-
-}
-
-func local_request_Query_Allocate_0(ctx context.Context, marshaler runtime.Marshaler, server QueryServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
-	var protoReq QueryAllocateRequest
-	var metadata runtime.ServerMetadata
-
-	msg, err := server.Allocate(ctx, &protoReq)
-	return msg, metadata, err
-
-}
-
 // RegisterQueryHandlerServer registers the http handlers for service Query to "mux".
 // UnaryRPC     :call QueryServer directly.
 // StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
@@ -98,29 +80,6 @@ func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, serv
 
 	})
 
-	mux.Handle("GET", pattern_Query_Allocate_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
-		ctx, cancel := context.WithCancel(req.Context())
-		defer cancel()
-		var stream runtime.ServerTransportStream
-		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
-		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
-		rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
-		if err != nil {
-			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
-			return
-		}
-		resp, md, err := local_request_Query_Allocate_0(rctx, inboundMarshaler, server, req, pathParams)
-		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
-		ctx = runtime.NewServerMetadataContext(ctx, md)
-		if err != nil {
-			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
-			return
-		}
-
-		forward_Query_Allocate_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
-
-	})
-
 	return nil
 }
 
@@ -182,37 +141,13 @@ func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, clie
 
 	})
 
-	mux.Handle("GET", pattern_Query_Allocate_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
-		ctx, cancel := context.WithCancel(req.Context())
-		defer cancel()
-		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
-		rctx, err := runtime.AnnotateContext(ctx, mux, req)
-		if err != nil {
-			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
-			return
-		}
-		resp, md, err := request_Query_Allocate_0(rctx, inboundMarshaler, client, req, pathParams)
-		ctx = runtime.NewServerMetadataContext(ctx, md)
-		if err != nil {
-			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
-			return
-		}
-
-		forward_Query_Allocate_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
-
-	})
-
 	return nil
 }
 
 var (
 	pattern_Query_Params_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"vault", "v1", "params"}, "", runtime.AssumeColonVerbOpt(false)))
-
-	pattern_Query_Allocate_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"vault", "v1", "allocate"}, "", runtime.AssumeColonVerbOpt(false)))
 )
 
 var (
 	forward_Query_Params_0 = runtime.ForwardResponseMessage
-
-	forward_Query_Allocate_0 = runtime.ForwardResponseMessage
 )