scaffold generalized ongoing auction info query

master
michael 2022-09-17 21:13:49 +00:00
parent 0d11ad94c9
commit 669837845d
9 changed files with 728 additions and 48 deletions

View File

@ -4,6 +4,43 @@ info:
name: '' name: ''
description: '' description: ''
paths: paths:
'/colinear/colinearcore/auction_info/{auctionId}':
get:
summary: Queries a list of AuctionInfo items.
operationId: ColinearColinearcoreAuctionInfo
responses:
'200':
description: A successful response.
schema:
type: object
properties:
bids:
type: string
default:
description: An unexpected error response.
schema:
type: object
properties:
code:
type: integer
format: int32
message:
type: string
details:
type: array
items:
type: object
properties:
'@type':
type: string
additionalProperties: {}
parameters:
- name: auctionId
in: path
required: true
type: string
tags:
- Query
'/colinear/colinearcore/locked_funds/{owner}': '/colinear/colinearcore/locked_funds/{owner}':
get: get:
summary: Queries a list of LockedFunds items. summary: Queries a list of LockedFunds items.
@ -30926,6 +30963,11 @@ definitions:
type: string type: string
amount: amount:
type: string type: string
colinear.colinearcore.QueryAuctionInfoResponse:
type: object
properties:
bids:
type: string
colinear.colinearcore.QueryGetAuctionResponse: colinear.colinearcore.QueryGetAuctionResponse:
type: object type: object
properties: properties:

1
go.mod
View File

@ -88,6 +88,7 @@ require (
github.com/gorilla/handlers v1.5.1 // indirect github.com/gorilla/handlers v1.5.1 // indirect
github.com/gorilla/websocket v1.5.0 // indirect github.com/gorilla/websocket v1.5.0 // indirect
github.com/grpc-ecosystem/go-grpc-middleware v1.3.0 // indirect github.com/grpc-ecosystem/go-grpc-middleware v1.3.0 // indirect
github.com/grpc-ecosystem/grpc-gateway/v2 v2.11.3 // indirect
github.com/gsterjov/go-libsecret v0.0.0-20161001094733-a6f4afe4910c // indirect github.com/gsterjov/go-libsecret v0.0.0-20161001094733-a6f4afe4910c // indirect
github.com/gtank/merlin v0.1.1 // indirect github.com/gtank/merlin v0.1.1 // indirect
github.com/gtank/ristretto255 v0.1.2 // indirect github.com/gtank/ristretto255 v0.1.2 // indirect

2
go.sum
View File

@ -734,6 +734,8 @@ github.com/grpc-ecosystem/grpc-gateway v1.9.0/go.mod h1:vNeuVxBJEsws4ogUvrchl83t
github.com/grpc-ecosystem/grpc-gateway v1.9.5/go.mod h1:vNeuVxBJEsws4ogUvrchl83t/GYV9WGTSLVdBhOQFDY= github.com/grpc-ecosystem/grpc-gateway v1.9.5/go.mod h1:vNeuVxBJEsws4ogUvrchl83t/GYV9WGTSLVdBhOQFDY=
github.com/grpc-ecosystem/grpc-gateway v1.16.0 h1:gmcG1KaJ57LophUzW0Hy8NmPhnMZb4M0+kPpLofRdBo= github.com/grpc-ecosystem/grpc-gateway v1.16.0 h1:gmcG1KaJ57LophUzW0Hy8NmPhnMZb4M0+kPpLofRdBo=
github.com/grpc-ecosystem/grpc-gateway v1.16.0/go.mod h1:BDjrQk3hbvj6Nolgz8mAMFbcEtjT1g+wF4CSlocrBnw= github.com/grpc-ecosystem/grpc-gateway v1.16.0/go.mod h1:BDjrQk3hbvj6Nolgz8mAMFbcEtjT1g+wF4CSlocrBnw=
github.com/grpc-ecosystem/grpc-gateway/v2 v2.11.3 h1:lLT7ZLSzGLI08vc9cpd+tYmNWjdKDqyr/2L+f6U12Fk=
github.com/grpc-ecosystem/grpc-gateway/v2 v2.11.3/go.mod h1:o//XUCC/F+yRGJoPO/VU0GSB0f8Nhgmxx0VIRUvaC0w=
github.com/gsterjov/go-libsecret v0.0.0-20161001094733-a6f4afe4910c h1:6rhixN/i8ZofjG1Y75iExal34USq5p+wiN1tpie8IrU= github.com/gsterjov/go-libsecret v0.0.0-20161001094733-a6f4afe4910c h1:6rhixN/i8ZofjG1Y75iExal34USq5p+wiN1tpie8IrU=
github.com/gsterjov/go-libsecret v0.0.0-20161001094733-a6f4afe4910c/go.mod h1:NMPJylDgVpX0MLRlPy15sqSwOFv/U1GZ2m21JhFfek0= github.com/gsterjov/go-libsecret v0.0.0-20161001094733-a6f4afe4910c/go.mod h1:NMPJylDgVpX0MLRlPy15sqSwOFv/U1GZ2m21JhFfek0=
github.com/gtank/merlin v0.1.1-0.20191105220539-8318aed1a79f/go.mod h1:T86dnYJhcGOh5BjZFCJWTDeTK7XW8uE+E21Cy/bIQ+s= github.com/gtank/merlin v0.1.1-0.20191105220539-8318aed1a79f/go.mod h1:T86dnYJhcGOh5BjZFCJWTDeTK7XW8uE+E21Cy/bIQ+s=

View File

@ -47,6 +47,11 @@ service Query {
option (google.api.http).get = "/colinear/colinearcore/locked_funds/{owner}"; option (google.api.http).get = "/colinear/colinearcore/locked_funds/{owner}";
} }
// Queries a list of AuctionInfo items.
rpc AuctionInfo(QueryAuctionInfoRequest) returns (QueryAuctionInfoResponse) {
option (google.api.http).get = "/colinear/colinearcore/auction_info/{auctionId}";
}
// this line is used by starport scaffolding # 2 // this line is used by starport scaffolding # 2
} }
@ -103,4 +108,13 @@ message QueryLockedFundsResponse {
string amount = 1; string amount = 1;
} }
message QueryAuctionInfoRequest {
string auctionId = 1;
}
message QueryAuctionInfoResponse {
repeated Bid bids = 1;
repeated string verifiedProviders = 2;
}
// this line is used by starport scaffolding # 3 // this line is used by starport scaffolding # 3

View File

@ -33,6 +33,8 @@ func GetQueryCmd(queryRoute string) *cobra.Command {
cmd.AddCommand(CmdShowLockedUsers()) cmd.AddCommand(CmdShowLockedUsers())
cmd.AddCommand(CmdLockedFunds()) cmd.AddCommand(CmdLockedFunds())
cmd.AddCommand(CmdAuctionInfo())
// this line is used by starport scaffolding # 1 // this line is used by starport scaffolding # 1
return cmd return cmd

View File

@ -0,0 +1,46 @@
package cli
import (
"strconv"
"colinear/x/colinearcore/types"
"github.com/cosmos/cosmos-sdk/client"
"github.com/cosmos/cosmos-sdk/client/flags"
"github.com/spf13/cobra"
)
var _ = strconv.Itoa(0)
func CmdAuctionInfo() *cobra.Command {
cmd := &cobra.Command{
Use: "auction-info [auction-id]",
Short: "Query auctionInfo",
Args: cobra.ExactArgs(1),
RunE: func(cmd *cobra.Command, args []string) (err error) {
reqAuctionId := args[0]
clientCtx, err := client.GetClientTxContext(cmd)
if err != nil {
return err
}
queryClient := types.NewQueryClient(clientCtx)
params := &types.QueryAuctionInfoRequest{
AuctionId: reqAuctionId,
}
res, err := queryClient.AuctionInfo(cmd.Context(), params)
if err != nil {
return err
}
return clientCtx.PrintProto(res)
},
}
flags.AddQueryFlagsToCmd(cmd)
return cmd
}

View File

@ -0,0 +1,23 @@
package keeper
import (
"context"
"colinear/x/colinearcore/types"
sdk "github.com/cosmos/cosmos-sdk/types"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
)
func (k Keeper) AuctionInfo(goCtx context.Context, req *types.QueryAuctionInfoRequest) (*types.QueryAuctionInfoResponse, error) {
if req == nil {
return nil, status.Error(codes.InvalidArgument, "invalid request")
}
ctx := sdk.UnwrapSDKContext(goCtx)
// TODO: Process the query
_ = ctx
return &types.QueryAuctionInfoResponse{}, nil
}

View File

@ -633,6 +633,102 @@ func (m *QueryLockedFundsResponse) GetAmount() string {
return "" return ""
} }
type QueryAuctionInfoRequest struct {
AuctionId string `protobuf:"bytes,1,opt,name=auctionId,proto3" json:"auctionId,omitempty"`
}
func (m *QueryAuctionInfoRequest) Reset() { *m = QueryAuctionInfoRequest{} }
func (m *QueryAuctionInfoRequest) String() string { return proto.CompactTextString(m) }
func (*QueryAuctionInfoRequest) ProtoMessage() {}
func (*QueryAuctionInfoRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_7b40a5389bf6a896, []int{14}
}
func (m *QueryAuctionInfoRequest) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryAuctionInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryAuctionInfoRequest.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 *QueryAuctionInfoRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryAuctionInfoRequest.Merge(m, src)
}
func (m *QueryAuctionInfoRequest) XXX_Size() int {
return m.Size()
}
func (m *QueryAuctionInfoRequest) XXX_DiscardUnknown() {
xxx_messageInfo_QueryAuctionInfoRequest.DiscardUnknown(m)
}
var xxx_messageInfo_QueryAuctionInfoRequest proto.InternalMessageInfo
func (m *QueryAuctionInfoRequest) GetAuctionId() string {
if m != nil {
return m.AuctionId
}
return ""
}
type QueryAuctionInfoResponse struct {
Bids []*Bid `protobuf:"bytes,1,rep,name=bids,proto3" json:"bids,omitempty"`
VerifiedProviders []string `protobuf:"bytes,2,rep,name=verifiedProviders,proto3" json:"verifiedProviders,omitempty"`
}
func (m *QueryAuctionInfoResponse) Reset() { *m = QueryAuctionInfoResponse{} }
func (m *QueryAuctionInfoResponse) String() string { return proto.CompactTextString(m) }
func (*QueryAuctionInfoResponse) ProtoMessage() {}
func (*QueryAuctionInfoResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_7b40a5389bf6a896, []int{15}
}
func (m *QueryAuctionInfoResponse) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryAuctionInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryAuctionInfoResponse.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 *QueryAuctionInfoResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryAuctionInfoResponse.Merge(m, src)
}
func (m *QueryAuctionInfoResponse) XXX_Size() int {
return m.Size()
}
func (m *QueryAuctionInfoResponse) XXX_DiscardUnknown() {
xxx_messageInfo_QueryAuctionInfoResponse.DiscardUnknown(m)
}
var xxx_messageInfo_QueryAuctionInfoResponse proto.InternalMessageInfo
func (m *QueryAuctionInfoResponse) GetBids() []*Bid {
if m != nil {
return m.Bids
}
return nil
}
func (m *QueryAuctionInfoResponse) GetVerifiedProviders() []string {
if m != nil {
return m.VerifiedProviders
}
return nil
}
func init() { func init() {
proto.RegisterType((*QueryParamsRequest)(nil), "colinear.colinearcore.QueryParamsRequest") proto.RegisterType((*QueryParamsRequest)(nil), "colinear.colinearcore.QueryParamsRequest")
proto.RegisterType((*QueryParamsResponse)(nil), "colinear.colinearcore.QueryParamsResponse") proto.RegisterType((*QueryParamsResponse)(nil), "colinear.colinearcore.QueryParamsResponse")
@ -648,59 +744,66 @@ func init() {
proto.RegisterType((*QueryGetLockedUsersResponse)(nil), "colinear.colinearcore.QueryGetLockedUsersResponse") proto.RegisterType((*QueryGetLockedUsersResponse)(nil), "colinear.colinearcore.QueryGetLockedUsersResponse")
proto.RegisterType((*QueryLockedFundsRequest)(nil), "colinear.colinearcore.QueryLockedFundsRequest") proto.RegisterType((*QueryLockedFundsRequest)(nil), "colinear.colinearcore.QueryLockedFundsRequest")
proto.RegisterType((*QueryLockedFundsResponse)(nil), "colinear.colinearcore.QueryLockedFundsResponse") proto.RegisterType((*QueryLockedFundsResponse)(nil), "colinear.colinearcore.QueryLockedFundsResponse")
proto.RegisterType((*QueryAuctionInfoRequest)(nil), "colinear.colinearcore.QueryAuctionInfoRequest")
proto.RegisterType((*QueryAuctionInfoResponse)(nil), "colinear.colinearcore.QueryAuctionInfoResponse")
} }
func init() { proto.RegisterFile("colinearcore/query.proto", fileDescriptor_7b40a5389bf6a896) } func init() { proto.RegisterFile("colinearcore/query.proto", fileDescriptor_7b40a5389bf6a896) }
var fileDescriptor_7b40a5389bf6a896 = []byte{ var fileDescriptor_7b40a5389bf6a896 = []byte{
// 745 bytes of a gzipped FileDescriptorProto // 824 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x96, 0x41, 0x4f, 0x13, 0x41, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x96, 0xcf, 0x4f, 0xd4, 0x40,
0x14, 0xc7, 0xbb, 0x08, 0x45, 0x87, 0xdb, 0x88, 0x88, 0x2b, 0x2c, 0x3a, 0xa8, 0x48, 0x91, 0x9d, 0x14, 0xc7, 0xb7, 0xfc, 0x58, 0xc2, 0x70, 0x72, 0x44, 0xc4, 0x0a, 0x0b, 0x0e, 0x2a, 0xb0, 0x40,
0xb4, 0x1c, 0x38, 0x98, 0x98, 0xc0, 0x01, 0x12, 0x62, 0x0c, 0x36, 0xf1, 0xa0, 0x17, 0x9c, 0xb6, 0x27, 0xbb, 0x1c, 0x38, 0x98, 0x98, 0xc0, 0x01, 0x02, 0x31, 0x06, 0x37, 0xf1, 0xa0, 0x17, 0xec,
0x63, 0xb3, 0x71, 0xd9, 0x29, 0xbb, 0x5b, 0x2d, 0x21, 0x5c, 0x3c, 0x7a, 0x32, 0xf1, 0xe0, 0xc5, 0x6e, 0x67, 0x37, 0x8d, 0x4b, 0x67, 0x69, 0xbb, 0xb8, 0x84, 0x70, 0xf1, 0xe8, 0xc9, 0x84, 0x83,
0x8b, 0x1a, 0xe3, 0x57, 0xe1, 0x48, 0xe2, 0xc5, 0x93, 0x31, 0xe0, 0xc5, 0x6f, 0x61, 0x76, 0xf6, 0x17, 0x2f, 0x6a, 0x8c, 0xff, 0x0a, 0x47, 0x12, 0x2f, 0x9e, 0x8c, 0x01, 0xff, 0x10, 0xd3, 0xe9,
0x6d, 0x99, 0x61, 0xb7, 0xbb, 0xe5, 0xd6, 0x9d, 0x79, 0xef, 0xfd, 0x7f, 0xfb, 0xfa, 0xde, 0xbf, 0xeb, 0x32, 0x43, 0xbb, 0xed, 0xe2, 0x8d, 0xce, 0xfb, 0xf1, 0xfd, 0xf4, 0xcd, 0xeb, 0x97, 0x45,
0x45, 0xd3, 0x4d, 0xe1, 0x3a, 0x1e, 0x67, 0x7e, 0x53, 0xf8, 0x9c, 0xee, 0x75, 0xb9, 0xbf, 0x6f, 0x93, 0x35, 0xde, 0xb4, 0x1d, 0x66, 0xba, 0x35, 0xee, 0x32, 0x7a, 0xd0, 0x66, 0xee, 0x91, 0xd1,
0x77, 0x7c, 0x11, 0x0a, 0x7c, 0x2d, 0xb9, 0xb1, 0xd5, 0x10, 0x73, 0xb2, 0x2d, 0xda, 0x42, 0x46, 0x72, 0xb9, 0xcf, 0xf1, 0x9d, 0x28, 0x62, 0xc8, 0x29, 0xfa, 0x78, 0x83, 0x37, 0xb8, 0xc8, 0xa0,
0xd0, 0xe8, 0x53, 0x1c, 0x6c, 0xce, 0xb4, 0x85, 0x68, 0xbb, 0x9c, 0xb2, 0x8e, 0x43, 0x99, 0xe7, 0xc1, 0x5f, 0x61, 0xb2, 0x3e, 0xd5, 0xe0, 0xbc, 0xd1, 0x64, 0xd4, 0x6c, 0xd9, 0xd4, 0x74, 0x1c,
0x89, 0x90, 0x85, 0x8e, 0xf0, 0x02, 0xb8, 0xad, 0x34, 0x45, 0xb0, 0x2b, 0x02, 0xda, 0x60, 0x01, 0xee, 0x9b, 0xbe, 0xcd, 0x1d, 0x0f, 0xa2, 0xc5, 0x1a, 0xf7, 0xf6, 0xb9, 0x47, 0xab, 0xa6, 0x07,
0x68, 0xd0, 0x37, 0xd5, 0x06, 0x0f, 0x59, 0x95, 0x76, 0x58, 0xdb, 0xf1, 0x64, 0x30, 0xc4, 0xde, 0x1a, 0xf4, 0xb0, 0x54, 0x65, 0xbe, 0x59, 0xa2, 0x2d, 0xb3, 0x61, 0x3b, 0x22, 0x19, 0x72, 0xef,
0xd0, 0x80, 0x3a, 0xcc, 0x67, 0xbb, 0x49, 0x99, 0x39, 0xed, 0xca, 0xe3, 0xbd, 0x70, 0x87, 0x75, 0x29, 0x40, 0x2d, 0xd3, 0x35, 0xf7, 0xa3, 0x36, 0x33, 0x4a, 0xc8, 0x61, 0x1d, 0x7f, 0xcf, 0x6c,
0x9b, 0x4a, 0xae, 0xa9, 0x05, 0xe8, 0x77, 0x53, 0xda, 0x5d, 0xc3, 0x69, 0x65, 0x16, 0x75, 0x45, 0xd7, 0xa4, 0x5a, 0x5d, 0x49, 0x50, 0x63, 0x13, 0x4a, 0xac, 0x6a, 0x5b, 0x89, 0x4d, 0x9b, 0xbc,
0xf3, 0x35, 0x6f, 0xed, 0x74, 0x03, 0xee, 0x83, 0x2a, 0x99, 0x44, 0xf8, 0x69, 0x84, 0xbc, 0x2d, 0xf6, 0x96, 0x59, 0x7b, 0x6d, 0x8f, 0xb9, 0xa0, 0x4a, 0xc6, 0x11, 0x7e, 0x11, 0x20, 0xef, 0x0a,
0x51, 0xea, 0x7c, 0xaf, 0xcb, 0x83, 0x90, 0xd4, 0xd1, 0x55, 0xed, 0x34, 0xe8, 0x08, 0x2f, 0xe0, 0x94, 0x0a, 0x3b, 0x68, 0x33, 0xcf, 0x27, 0x15, 0x74, 0x5b, 0x39, 0xf5, 0x5a, 0xdc, 0xf1, 0x18,
0xf8, 0x21, 0x2a, 0xc7, 0xc8, 0xd3, 0xc6, 0x2d, 0xe3, 0xfe, 0x44, 0x6d, 0xd6, 0xce, 0xec, 0xa2, 0x7e, 0x82, 0xf2, 0x21, 0xf2, 0xa4, 0x36, 0xab, 0x2d, 0x8c, 0x95, 0xa7, 0x8d, 0xc4, 0x29, 0x1a,
0x1d, 0xa7, 0xad, 0x8f, 0x1e, 0xfd, 0x9e, 0x2b, 0xd5, 0x21, 0x85, 0xcc, 0x20, 0x53, 0xd6, 0xdc, 0x61, 0xd9, 0xc6, 0xd0, 0xd9, 0xef, 0x99, 0x5c, 0x05, 0x4a, 0xc8, 0x14, 0xd2, 0x45, 0xcf, 0x2d,
0xe4, 0xe1, 0x13, 0xde, 0x0b, 0xd7, 0x62, 0xfe, 0x44, 0xd1, 0x41, 0x37, 0x33, 0x6f, 0x41, 0x79, 0xe6, 0x3f, 0x67, 0x1d, 0x7f, 0x3d, 0xe4, 0x8f, 0x14, 0x6d, 0x74, 0x3f, 0x31, 0x0a, 0xca, 0x3b,
0x0b, 0x4d, 0x28, 0xc7, 0x20, 0x4f, 0x06, 0xc8, 0x2b, 0x91, 0xc0, 0xa0, 0x26, 0x13, 0x1b, 0x4d, 0x68, 0x4c, 0x3a, 0x06, 0x79, 0xd2, 0x43, 0x5e, 0xca, 0x04, 0x06, 0xb9, 0x98, 0x18, 0x68, 0x22,
0x25, 0x52, 0x3a, 0x04, 0x9e, 0x44, 0x63, 0x8e, 0xd7, 0xe2, 0x3d, 0x59, 0xff, 0x4a, 0x3d, 0x7e, 0x92, 0x52, 0x21, 0xf0, 0x38, 0x1a, 0xb6, 0x1d, 0x8b, 0x75, 0x44, 0xff, 0xd1, 0x4a, 0xf8, 0x40,
0x20, 0xcf, 0xd1, 0xf5, 0x54, 0x3c, 0x60, 0x3d, 0x42, 0xe3, 0x4c, 0x43, 0xb2, 0x06, 0x20, 0xe9, 0x5e, 0xa1, 0xbb, 0xb1, 0x7c, 0xc0, 0x7a, 0x8a, 0x46, 0x4c, 0x05, 0xa9, 0xd0, 0x03, 0x49, 0xc5,
0x38, 0x49, 0x12, 0x79, 0x09, 0x28, 0x6b, 0xae, 0x7b, 0x0e, 0x65, 0x03, 0xa1, 0xb3, 0xe1, 0x81, 0x89, 0x8a, 0xc8, 0x1b, 0x40, 0x59, 0x6f, 0x36, 0xaf, 0xa1, 0x6c, 0x22, 0x74, 0xb5, 0x3c, 0xd0,
0xe2, 0xf7, 0xec, 0x78, 0xd2, 0xec, 0x68, 0xd2, 0xec, 0x78, 0x9a, 0x61, 0xd2, 0xec, 0x6d, 0xd6, 0xfc, 0xb1, 0x11, 0x6e, 0x9a, 0x11, 0x6c, 0x9a, 0x11, 0x6e, 0x33, 0x6c, 0x9a, 0xb1, 0x6b, 0x36,
0xe6, 0x90, 0x5b, 0x57, 0x32, 0xc9, 0x57, 0x03, 0xe8, 0x55, 0x89, 0x2c, 0xfa, 0x4b, 0x17, 0xa6, 0x18, 0xd4, 0x56, 0xa4, 0x4a, 0xf2, 0x55, 0x03, 0x7a, 0x59, 0x22, 0x89, 0x7e, 0xf0, 0xc6, 0xf4,
0xc7, 0x9b, 0x1a, 0xe3, 0x88, 0x64, 0x5c, 0x28, 0x64, 0x8c, 0xc5, 0x35, 0x48, 0x9a, 0x30, 0x82, 0x78, 0x4b, 0x61, 0x1c, 0x10, 0x8c, 0xf3, 0x99, 0x8c, 0xa1, 0xb8, 0x02, 0x49, 0x23, 0x46, 0xd0,
0x8e, 0xd3, 0x0a, 0xf2, 0xbf, 0x92, 0x2d, 0x34, 0x9d, 0x4e, 0x80, 0xb7, 0xb2, 0xd1, 0x68, 0xc3, 0xb1, 0x2d, 0x2f, 0xfd, 0x4a, 0x76, 0xd0, 0x64, 0xbc, 0x00, 0xde, 0xca, 0x40, 0x43, 0x55, 0xdb,
0x69, 0x05, 0xf0, 0x4a, 0xe6, 0x80, 0x57, 0x5a, 0x77, 0x5a, 0x75, 0x19, 0xa7, 0xce, 0xe5, 0x63, 0xf2, 0xe0, 0x95, 0xf4, 0x1e, 0xaf, 0xb4, 0x61, 0x5b, 0x15, 0x91, 0x27, 0xef, 0xe5, 0x33, 0xf1,
0xb9, 0x1f, 0xcf, 0xa2, 0xf5, 0xc8, 0x98, 0x4b, 0xed, 0xf6, 0x6c, 0x2e, 0x95, 0xe3, 0x82, 0xb9, 0x7d, 0xbc, 0x0c, 0x3e, 0x8f, 0x84, 0xbd, 0x54, 0xa2, 0x57, 0x7b, 0x29, 0x1d, 0x67, 0xec, 0xa5,
0x54, 0x22, 0x93, 0xb9, 0x54, 0x8e, 0xfa, 0x5d, 0x88, 0xcf, 0x36, 0xba, 0x9e, 0xd6, 0x05, 0xf1, 0x94, 0x19, 0xed, 0xa5, 0x74, 0xd4, 0x9d, 0x42, 0x78, 0xb6, 0xd9, 0x76, 0x94, 0x29, 0xf0, 0x77,
0xd6, 0xe3, 0x7e, 0xd2, 0x05, 0xf9, 0x40, 0x6a, 0xd0, 0x05, 0x2d, 0x01, 0xc0, 0xa6, 0x50, 0x99, 0x0e, 0x73, 0xa3, 0x29, 0x88, 0x07, 0x52, 0x86, 0x29, 0x28, 0x05, 0x00, 0x36, 0x81, 0xf2, 0xe6,
0xed, 0x8a, 0xae, 0x17, 0x42, 0x0a, 0x3c, 0xd5, 0xfe, 0x5d, 0x46, 0x63, 0x32, 0x09, 0xbf, 0x37, 0x3e, 0x6f, 0x3b, 0x3e, 0x94, 0xc0, 0x13, 0x59, 0x53, 0x47, 0xbd, 0xed, 0xd4, 0x79, 0x24, 0x32,
0x50, 0x39, 0x5e, 0x54, 0xbc, 0x38, 0x00, 0x38, 0xed, 0x0c, 0x66, 0x65, 0x98, 0xd0, 0x98, 0x81, 0x85, 0x46, 0xe1, 0x66, 0xb7, 0x2d, 0xa8, 0xba, 0x3a, 0x20, 0x1d, 0x75, 0xe4, 0x61, 0xe1, 0xff,
0x2c, 0xbe, 0xfb, 0xf9, 0xf7, 0xe3, 0xc8, 0x3c, 0xbe, 0x4d, 0x35, 0x17, 0xca, 0xb0, 0x40, 0xfc, 0x8d, 0x1c, 0x2f, 0xa3, 0x5b, 0x87, 0xcc, 0xb5, 0xeb, 0x36, 0xb3, 0x76, 0x5d, 0x7e, 0x68, 0x5b,
0xdd, 0xd0, 0x16, 0x1c, 0x57, 0xf3, 0x64, 0x32, 0x1d, 0xc4, 0xac, 0x5d, 0x24, 0x05, 0x08, 0xa9, 0xc1, 0xec, 0x06, 0x66, 0x07, 0x17, 0x46, 0x2b, 0xf1, 0x40, 0xf9, 0x14, 0xa1, 0x61, 0x21, 0x8d,
0x24, 0x5c, 0xc4, 0x0b, 0x39, 0x84, 0xaa, 0x13, 0xe3, 0xcf, 0x06, 0x1a, 0x4f, 0x18, 0x97, 0x0b, 0x3f, 0x68, 0x28, 0x1f, 0x7a, 0x0b, 0x5e, 0xec, 0x21, 0x12, 0x37, 0x33, 0xbd, 0xd8, 0x4f, 0x6a,
0x04, 0xcf, 0xf1, 0xd9, 0xc3, 0x86, 0x03, 0x5b, 0x4d, 0xb2, 0x3d, 0xc0, 0x95, 0x1c, 0x36, 0xc0, 0xf8, 0x26, 0x64, 0xf1, 0xfd, 0xcf, 0xbf, 0xa7, 0x03, 0x73, 0xf8, 0x01, 0x55, 0x8c, 0x33, 0xc1,
0xa2, 0x07, 0x72, 0x2d, 0x0e, 0xf1, 0x27, 0x03, 0x21, 0xa8, 0xb3, 0xe6, 0xba, 0xf9, 0x84, 0x29, 0xb5, 0xf1, 0x77, 0x4d, 0xf1, 0x24, 0x5c, 0x4a, 0x93, 0x49, 0x34, 0x3d, 0xbd, 0x7c, 0x93, 0x12,
0xcf, 0xc9, 0x27, 0x4c, 0xfb, 0x07, 0xa9, 0x48, 0xc2, 0x3b, 0x98, 0x14, 0x13, 0xe2, 0x1f, 0x06, 0x20, 0xa4, 0x82, 0x70, 0x11, 0xcf, 0xa7, 0x10, 0xca, 0xff, 0x3c, 0xf0, 0x67, 0x0d, 0x8d, 0x44,
0x9a, 0x50, 0xb6, 0x15, 0xe7, 0x6b, 0xa5, 0x7c, 0xc0, 0xa4, 0x43, 0xc7, 0x03, 0xdc, 0xaa, 0x84, 0x8c, 0x2b, 0x19, 0x82, 0xd7, 0xf8, 0x8c, 0x7e, 0xd3, 0x81, 0xad, 0x2c, 0xd8, 0x96, 0x71, 0x31,
0xab, 0x62, 0x5a, 0x0c, 0xb7, 0x13, 0xf9, 0x40, 0xbf, 0x87, 0x5f, 0x0c, 0x6d, 0xa7, 0x0b, 0x47, 0x85, 0x0d, 0xb0, 0xe8, 0xb1, 0xf8, 0x92, 0x4f, 0xf0, 0x27, 0x0d, 0x21, 0xe8, 0xb3, 0xde, 0x6c,
0x31, 0x6d, 0x1a, 0x85, 0xa3, 0x98, 0xe1, 0x24, 0x64, 0x49, 0xf2, 0xde, 0xc5, 0xf3, 0x7d, 0x44, 0xa6, 0x13, 0xc6, 0x6c, 0x32, 0x9d, 0x30, 0x6e, 0x79, 0xa4, 0x28, 0x08, 0x1f, 0x62, 0x92, 0x4d,
0x3a, 0xf0, 0xb7, 0x1b, 0x7f, 0xeb, 0x33, 0xca, 0xad, 0xcf, 0xef, 0x66, 0xda, 0x4f, 0xf2, 0xbb, 0x88, 0x7f, 0x68, 0x68, 0x4c, 0x32, 0x18, 0x9c, 0xae, 0x15, 0xb3, 0x2e, 0x9d, 0xf6, 0x9d, 0x0f,
0x99, 0x61, 0x27, 0x64, 0x45, 0xd2, 0x2d, 0xe3, 0xa5, 0x7c, 0xba, 0x57, 0x51, 0x12, 0x3d, 0x90, 0x70, 0x6b, 0x02, 0xae, 0x84, 0x69, 0x36, 0xdc, 0x5e, 0xf0, 0x1d, 0x75, 0x67, 0xf8, 0x45, 0x53,
0xf6, 0x74, 0xb8, 0xbe, 0x7a, 0x74, 0x62, 0x19, 0xc7, 0x27, 0x96, 0xf1, 0xe7, 0xc4, 0x32, 0x3e, 0x6c, 0x28, 0x73, 0x15, 0xe3, 0x3e, 0x97, 0xb9, 0x8a, 0x09, 0xe6, 0x47, 0x96, 0x04, 0xef, 0x23,
0x9c, 0x5a, 0xa5, 0xe3, 0x53, 0xab, 0xf4, 0xeb, 0xd4, 0x2a, 0xbd, 0x98, 0xed, 0x57, 0xe9, 0xe9, 0x3c, 0xd7, 0x45, 0xa4, 0x3d, 0x7f, 0x6e, 0xe0, 0x6f, 0x5d, 0x46, 0x61, 0x54, 0xe9, 0xd3, 0x8c,
0x75, 0xc2, 0xfd, 0x0e, 0x0f, 0x1a, 0x65, 0xf9, 0xdf, 0x64, 0xe5, 0x7f, 0x00, 0x00, 0x00, 0xff, 0x5b, 0x60, 0xfa, 0x34, 0x13, 0x1c, 0x90, 0xac, 0x0a, 0xba, 0x15, 0xbc, 0x94, 0x4e, 0x57, 0x0f,
0xff, 0x28, 0x99, 0x3e, 0xce, 0xbf, 0x09, 0x00, 0x00, 0x8a, 0xe8, 0xb1, 0x70, 0xd4, 0x13, 0xf9, 0xce, 0x03, 0x87, 0xeb, 0xeb, 0xce, 0x25, 0x0f, 0xed,
0xeb, 0xce, 0x65, 0xeb, 0x4c, 0xb8, 0xf3, 0xe4, 0xfb, 0xb6, 0x9d, 0x3a, 0xa7, 0xc7, 0x5d, 0x3b,
0x3e, 0xd9, 0x58, 0x3b, 0xbb, 0x28, 0x68, 0xe7, 0x17, 0x05, 0xed, 0xcf, 0x45, 0x41, 0xfb, 0x78,
0x59, 0xc8, 0x9d, 0x5f, 0x16, 0x72, 0xbf, 0x2e, 0x0b, 0xb9, 0xd7, 0xd3, 0xdd, 0x4e, 0x1d, 0xb5,
0x97, 0x7f, 0xd4, 0x62, 0x5e, 0x35, 0x2f, 0x7e, 0xf8, 0xad, 0xfe, 0x0b, 0x00, 0x00, 0xff, 0xff,
0x91, 0xdb, 0x1e, 0xec, 0x1c, 0x0b, 0x00, 0x00,
} }
// Reference imports to suppress errors if they are not otherwise used. // Reference imports to suppress errors if they are not otherwise used.
@ -729,6 +832,8 @@ type QueryClient interface {
LockedUsers(ctx context.Context, in *QueryGetLockedUsersRequest, opts ...grpc.CallOption) (*QueryGetLockedUsersResponse, error) LockedUsers(ctx context.Context, in *QueryGetLockedUsersRequest, opts ...grpc.CallOption) (*QueryGetLockedUsersResponse, error)
// Queries a list of LockedFunds items. // Queries a list of LockedFunds items.
LockedFunds(ctx context.Context, in *QueryLockedFundsRequest, opts ...grpc.CallOption) (*QueryLockedFundsResponse, error) LockedFunds(ctx context.Context, in *QueryLockedFundsRequest, opts ...grpc.CallOption) (*QueryLockedFundsResponse, error)
// Queries a list of AuctionInfo items.
AuctionInfo(ctx context.Context, in *QueryAuctionInfoRequest, opts ...grpc.CallOption) (*QueryAuctionInfoResponse, error)
} }
type queryClient struct { type queryClient struct {
@ -802,6 +907,15 @@ func (c *queryClient) LockedFunds(ctx context.Context, in *QueryLockedFundsReque
return out, nil return out, nil
} }
func (c *queryClient) AuctionInfo(ctx context.Context, in *QueryAuctionInfoRequest, opts ...grpc.CallOption) (*QueryAuctionInfoResponse, error) {
out := new(QueryAuctionInfoResponse)
err := c.cc.Invoke(ctx, "/colinear.colinearcore.Query/AuctionInfo", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// QueryServer is the server API for Query service. // QueryServer is the server API for Query service.
type QueryServer interface { type QueryServer interface {
// Parameters queries the parameters of the module. // Parameters queries the parameters of the module.
@ -818,6 +932,8 @@ type QueryServer interface {
LockedUsers(context.Context, *QueryGetLockedUsersRequest) (*QueryGetLockedUsersResponse, error) LockedUsers(context.Context, *QueryGetLockedUsersRequest) (*QueryGetLockedUsersResponse, error)
// Queries a list of LockedFunds items. // Queries a list of LockedFunds items.
LockedFunds(context.Context, *QueryLockedFundsRequest) (*QueryLockedFundsResponse, error) LockedFunds(context.Context, *QueryLockedFundsRequest) (*QueryLockedFundsResponse, error)
// Queries a list of AuctionInfo items.
AuctionInfo(context.Context, *QueryAuctionInfoRequest) (*QueryAuctionInfoResponse, error)
} }
// UnimplementedQueryServer can be embedded to have forward compatible implementations. // UnimplementedQueryServer can be embedded to have forward compatible implementations.
@ -845,6 +961,9 @@ func (*UnimplementedQueryServer) LockedUsers(ctx context.Context, req *QueryGetL
func (*UnimplementedQueryServer) LockedFunds(ctx context.Context, req *QueryLockedFundsRequest) (*QueryLockedFundsResponse, error) { func (*UnimplementedQueryServer) LockedFunds(ctx context.Context, req *QueryLockedFundsRequest) (*QueryLockedFundsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method LockedFunds not implemented") return nil, status.Errorf(codes.Unimplemented, "method LockedFunds not implemented")
} }
func (*UnimplementedQueryServer) AuctionInfo(ctx context.Context, req *QueryAuctionInfoRequest) (*QueryAuctionInfoResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method AuctionInfo not implemented")
}
func RegisterQueryServer(s grpc1.Server, srv QueryServer) { func RegisterQueryServer(s grpc1.Server, srv QueryServer) {
s.RegisterService(&_Query_serviceDesc, srv) s.RegisterService(&_Query_serviceDesc, srv)
@ -976,6 +1095,24 @@ func _Query_LockedFunds_Handler(srv interface{}, ctx context.Context, dec func(i
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
func _Query_AuctionInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(QueryAuctionInfoRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(QueryServer).AuctionInfo(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/colinear.colinearcore.Query/AuctionInfo",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(QueryServer).AuctionInfo(ctx, req.(*QueryAuctionInfoRequest))
}
return interceptor(ctx, in, info, handler)
}
var _Query_serviceDesc = grpc.ServiceDesc{ var _Query_serviceDesc = grpc.ServiceDesc{
ServiceName: "colinear.colinearcore.Query", ServiceName: "colinear.colinearcore.Query",
HandlerType: (*QueryServer)(nil), HandlerType: (*QueryServer)(nil),
@ -1008,6 +1145,10 @@ var _Query_serviceDesc = grpc.ServiceDesc{
MethodName: "LockedFunds", MethodName: "LockedFunds",
Handler: _Query_LockedFunds_Handler, Handler: _Query_LockedFunds_Handler,
}, },
{
MethodName: "AuctionInfo",
Handler: _Query_AuctionInfo_Handler,
},
}, },
Streams: []grpc.StreamDesc{}, Streams: []grpc.StreamDesc{},
Metadata: "colinearcore/query.proto", Metadata: "colinearcore/query.proto",
@ -1455,6 +1596,82 @@ func (m *QueryLockedFundsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error
return len(dAtA) - i, nil return len(dAtA) - i, nil
} }
func (m *QueryAuctionInfoRequest) 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 *QueryAuctionInfoRequest) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryAuctionInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if len(m.AuctionId) > 0 {
i -= len(m.AuctionId)
copy(dAtA[i:], m.AuctionId)
i = encodeVarintQuery(dAtA, i, uint64(len(m.AuctionId)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *QueryAuctionInfoResponse) 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 *QueryAuctionInfoResponse) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryAuctionInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if len(m.VerifiedProviders) > 0 {
for iNdEx := len(m.VerifiedProviders) - 1; iNdEx >= 0; iNdEx-- {
i -= len(m.VerifiedProviders[iNdEx])
copy(dAtA[i:], m.VerifiedProviders[iNdEx])
i = encodeVarintQuery(dAtA, i, uint64(len(m.VerifiedProviders[iNdEx])))
i--
dAtA[i] = 0x12
}
}
if len(m.Bids) > 0 {
for iNdEx := len(m.Bids) - 1; iNdEx >= 0; iNdEx-- {
{
size, err := m.Bids[iNdEx].MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintQuery(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0xa
}
}
return len(dAtA) - i, nil
}
func encodeVarintQuery(dAtA []byte, offset int, v uint64) int { func encodeVarintQuery(dAtA []byte, offset int, v uint64) int {
offset -= sovQuery(v) offset -= sovQuery(v)
base := offset base := offset
@ -1636,6 +1853,40 @@ func (m *QueryLockedFundsResponse) Size() (n int) {
return n return n
} }
func (m *QueryAuctionInfoRequest) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.AuctionId)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
return n
}
func (m *QueryAuctionInfoResponse) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if len(m.Bids) > 0 {
for _, e := range m.Bids {
l = e.Size()
n += 1 + l + sovQuery(uint64(l))
}
}
if len(m.VerifiedProviders) > 0 {
for _, s := range m.VerifiedProviders {
l = len(s)
n += 1 + l + sovQuery(uint64(l))
}
}
return n
}
func sovQuery(x uint64) (n int) { func sovQuery(x uint64) (n int) {
return (math_bits.Len64(x|1) + 6) / 7 return (math_bits.Len64(x|1) + 6) / 7
} }
@ -2742,6 +2993,204 @@ func (m *QueryLockedFundsResponse) Unmarshal(dAtA []byte) error {
} }
return nil return nil
} }
func (m *QueryAuctionInfoRequest) 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: QueryAuctionInfoRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryAuctionInfoRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field AuctionId", 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.AuctionId = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
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 *QueryAuctionInfoResponse) 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: QueryAuctionInfoResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryAuctionInfoResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Bids", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Bids = append(m.Bids, &Bid{})
if err := m.Bids[len(m.Bids)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field VerifiedProviders", 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.VerifiedProviders = append(m.VerifiedProviders, string(dAtA[iNdEx:postIndex]))
iNdEx = postIndex
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) { func skipQuery(dAtA []byte) (n int, err error) {
l := len(dAtA) l := len(dAtA)
iNdEx := 0 iNdEx := 0

View File

@ -285,6 +285,60 @@ func local_request_Query_LockedFunds_0(ctx context.Context, marshaler runtime.Ma
} }
func request_Query_AuctionInfo_0(ctx context.Context, marshaler runtime.Marshaler, client QueryClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
var protoReq QueryAuctionInfoRequest
var metadata runtime.ServerMetadata
var (
val string
ok bool
err error
_ = err
)
val, ok = pathParams["auctionId"]
if !ok {
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "auctionId")
}
protoReq.AuctionId, err = runtime.String(val)
if err != nil {
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "auctionId", err)
}
msg, err := client.AuctionInfo(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
return msg, metadata, err
}
func local_request_Query_AuctionInfo_0(ctx context.Context, marshaler runtime.Marshaler, server QueryServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
var protoReq QueryAuctionInfoRequest
var metadata runtime.ServerMetadata
var (
val string
ok bool
err error
_ = err
)
val, ok = pathParams["auctionId"]
if !ok {
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "auctionId")
}
protoReq.AuctionId, err = runtime.String(val)
if err != nil {
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "auctionId", err)
}
msg, err := server.AuctionInfo(ctx, &protoReq)
return msg, metadata, err
}
// RegisterQueryHandlerServer registers the http handlers for service Query to "mux". // RegisterQueryHandlerServer registers the http handlers for service Query to "mux".
// UnaryRPC :call QueryServer directly. // UnaryRPC :call QueryServer directly.
// StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. // StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
@ -452,6 +506,29 @@ func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, serv
}) })
mux.Handle("GET", pattern_Query_AuctionInfo_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_AuctionInfo_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_AuctionInfo_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
})
return nil return nil
} }
@ -633,6 +710,26 @@ func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, clie
}) })
mux.Handle("GET", pattern_Query_AuctionInfo_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_AuctionInfo_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_AuctionInfo_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
})
return nil return nil
} }
@ -650,6 +747,8 @@ var (
pattern_Query_LockedUsers_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"colinear", "colinearcore", "locked_users"}, "", runtime.AssumeColonVerbOpt(true))) pattern_Query_LockedUsers_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"colinear", "colinearcore", "locked_users"}, "", runtime.AssumeColonVerbOpt(true)))
pattern_Query_LockedFunds_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"colinear", "colinearcore", "locked_funds", "owner"}, "", runtime.AssumeColonVerbOpt(true))) pattern_Query_LockedFunds_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"colinear", "colinearcore", "locked_funds", "owner"}, "", runtime.AssumeColonVerbOpt(true)))
pattern_Query_AuctionInfo_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"colinear", "colinearcore", "auction_info", "auctionId"}, "", runtime.AssumeColonVerbOpt(true)))
) )
var ( var (
@ -666,4 +765,6 @@ var (
forward_Query_LockedUsers_0 = runtime.ForwardResponseMessage forward_Query_LockedUsers_0 = runtime.ForwardResponseMessage
forward_Query_LockedFunds_0 = runtime.ForwardResponseMessage forward_Query_LockedFunds_0 = runtime.ForwardResponseMessage
forward_Query_AuctionInfo_0 = runtime.ForwardResponseMessage
) )