Compare commits

...

6 Commits

14 changed files with 916 additions and 49 deletions

View File

@ -5,6 +5,8 @@
![Docker](https://img.shields.io/badge/docker-%230db7ed.svg?style=for-the-badge&logo=docker&logoColor=white)
![Rocky Linux](https://img.shields.io/badge/-Rocky%20Linux-%2310B981?style=for-the-badge&logo=rockylinux&logoColor=white)
![](https://shields.io/badge/license-business%20source%20license-orange?style=for-the-badge)
This repository contains the base chain implementation that Colinear's compute marketplace uses as a settlement layer.
## Technical Documentation

View File

@ -4,6 +4,54 @@ info:
name: ''
description: ''
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: array
items:
type: object
properties:
owner:
type: string
amount:
type: string
verifiedProviders:
type: array
items:
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}':
get:
summary: Queries a list of LockedFunds items.
@ -30926,6 +30974,22 @@ definitions:
type: string
amount:
type: string
colinear.colinearcore.QueryAuctionInfoResponse:
type: object
properties:
bids:
type: array
items:
type: object
properties:
owner:
type: string
amount:
type: string
verifiedProviders:
type: array
items:
type: string
colinear.colinearcore.QueryGetAuctionResponse:
type: object
properties:

1
go.mod
View File

@ -88,6 +88,7 @@ require (
github.com/gorilla/handlers v1.5.1 // indirect
github.com/gorilla/websocket v1.5.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/gtank/merlin v0.1.1 // 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.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/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/go.mod h1:NMPJylDgVpX0MLRlPy15sqSwOFv/U1GZ2m21JhFfek0=
github.com/gtank/merlin v0.1.1-0.20191105220539-8318aed1a79f/go.mod h1:T86dnYJhcGOh5BjZFCJWTDeTK7XW8uE+E21Cy/bIQ+s=

View File

@ -0,0 +1,19 @@
syntax = "proto3";
package colinear.colinearcore;
option go_package = "colinear/x/colinearcore/types";
enum GpuModel {
RTX_2080 = 0;
RTX_2080_TI = 1;
RTX_3070 = 2;
RTX_3070_TI = 3;
RTX_3080 = 4;
RTX_3080_TI = 5;
}
enum CpuArchitecture {
ANY = 0;
INTEL = 1;
AMD = 2;
}

View File

@ -47,6 +47,11 @@ service Query {
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
}
@ -103,4 +108,13 @@ message QueryLockedFundsResponse {
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

View File

@ -61,7 +61,15 @@ colineard tx colinearcore new-bid $(get_last_auction_index) 0 \
colineard q colinearcore auction-bids $(get_last_auction_index) \
| jq -M ".bids | length" \
| assert_eq 2 "Number of auction bids"
| assert_eq 2 "Number of auction bids in auctionBids query"
colineard q colinearcore auction-info $(get_last_auction_index) \
| jq -rM ".bids | length" \
| assert_eq 2 "Number of auction bids in auctionInfo query"
colineard q colinearcore auction-info $(get_last_auction_index) \
| jq -rM ".verifiedProviders" \
| assert_eq "[]" "Verified Provider list in auctionInfo query"
before=$(get_balance $BOB uusdc)

View File

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

View File

@ -0,0 +1,47 @@
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,44 @@
package keeper
import (
"context"
"fmt"
"colinear/x/colinearcore/memdb"
"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)
if exp, err := k.AuctionIsExpired(ctx, req.AuctionId); err != nil {
return nil, fmt.Errorf("unable to check auction expiry status: %s", err)
} else {
if exp {
return nil, fmt.Errorf("auction %s is finalized", req.AuctionId)
}
}
bids, err := memdb.AuctionDB.GetBids(req.AuctionId)
if err != nil {
return nil, fmt.Errorf("unable to get bids for auction %s: %s", req.AuctionId, err)
}
vProviders, err := memdb.AuctionDB.GetVerifiedProviders(req.AuctionId)
if err != nil {
return nil, fmt.Errorf("unable to get verified providers for auction %s: %s", req.AuctionId, err)
}
return &types.QueryAuctionInfoResponse{
Bids: bids,
VerifiedProviders: vProviders,
}, nil
}

View File

@ -226,6 +226,9 @@ func (b *auctionDB) GetVerifiedProviders(auctionId string) ([]string, error) {
return err
})
if err != nil {
if errors.Is(err, badger.ErrKeyNotFound) {
return []string{}, nil
}
return nil, err
}
if providers == nil {

View File

@ -0,0 +1,111 @@
// Code generated by protoc-gen-gogo. DO NOT EDIT.
// source: colinearcore/hardware.proto
package types
import (
fmt "fmt"
proto "github.com/gogo/protobuf/proto"
math "math"
)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package
type GpuModel int32
const (
GpuModel_RTX_2080 GpuModel = 0
GpuModel_RTX_2080_TI GpuModel = 1
GpuModel_RTX_3070 GpuModel = 2
GpuModel_RTX_3070_TI GpuModel = 3
GpuModel_RTX_3080 GpuModel = 4
GpuModel_RTX_3080_TI GpuModel = 5
)
var GpuModel_name = map[int32]string{
0: "RTX_2080",
1: "RTX_2080_TI",
2: "RTX_3070",
3: "RTX_3070_TI",
4: "RTX_3080",
5: "RTX_3080_TI",
}
var GpuModel_value = map[string]int32{
"RTX_2080": 0,
"RTX_2080_TI": 1,
"RTX_3070": 2,
"RTX_3070_TI": 3,
"RTX_3080": 4,
"RTX_3080_TI": 5,
}
func (x GpuModel) String() string {
return proto.EnumName(GpuModel_name, int32(x))
}
func (GpuModel) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_b5d8e515bcf89b12, []int{0}
}
type CpuArchitecture int32
const (
CpuArchitecture_ANY CpuArchitecture = 0
CpuArchitecture_INTEL CpuArchitecture = 1
CpuArchitecture_AMD CpuArchitecture = 2
)
var CpuArchitecture_name = map[int32]string{
0: "ANY",
1: "INTEL",
2: "AMD",
}
var CpuArchitecture_value = map[string]int32{
"ANY": 0,
"INTEL": 1,
"AMD": 2,
}
func (x CpuArchitecture) String() string {
return proto.EnumName(CpuArchitecture_name, int32(x))
}
func (CpuArchitecture) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_b5d8e515bcf89b12, []int{1}
}
func init() {
proto.RegisterEnum("colinear.colinearcore.GpuModel", GpuModel_name, GpuModel_value)
proto.RegisterEnum("colinear.colinearcore.CpuArchitecture", CpuArchitecture_name, CpuArchitecture_value)
}
func init() { proto.RegisterFile("colinearcore/hardware.proto", fileDescriptor_b5d8e515bcf89b12) }
var fileDescriptor_b5d8e515bcf89b12 = []byte{
// 214 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x92, 0x4e, 0xce, 0xcf, 0xc9,
0xcc, 0x4b, 0x4d, 0x2c, 0x4a, 0xce, 0x2f, 0x4a, 0xd5, 0xcf, 0x48, 0x2c, 0x4a, 0x29, 0x4f, 0x2c,
0x4a, 0xd5, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0x12, 0x85, 0x49, 0xea, 0x21, 0xab, 0xd2, 0x4a,
0xe7, 0xe2, 0x70, 0x2f, 0x28, 0xf5, 0xcd, 0x4f, 0x49, 0xcd, 0x11, 0xe2, 0xe1, 0xe2, 0x08, 0x0a,
0x89, 0x88, 0x37, 0x32, 0xb0, 0x30, 0x10, 0x60, 0x10, 0xe2, 0xe7, 0xe2, 0x86, 0xf1, 0xe2, 0x43,
0x3c, 0x05, 0x18, 0x61, 0xd2, 0xc6, 0x06, 0xe6, 0x06, 0x02, 0x4c, 0x30, 0x69, 0x10, 0x0f, 0x24,
0xcd, 0x8c, 0x90, 0xb6, 0x30, 0x10, 0x60, 0x41, 0x48, 0x43, 0x74, 0xb3, 0x6a, 0xe9, 0x71, 0xf1,
0x3b, 0x17, 0x94, 0x3a, 0x16, 0x25, 0x67, 0x64, 0x96, 0xa4, 0x26, 0x97, 0x94, 0x16, 0xa5, 0x0a,
0xb1, 0x73, 0x31, 0x3b, 0xfa, 0x45, 0x0a, 0x30, 0x08, 0x71, 0x72, 0xb1, 0x7a, 0xfa, 0x85, 0xb8,
0xfa, 0x08, 0x30, 0x82, 0xc5, 0x7c, 0x5d, 0x04, 0x98, 0x9c, 0xcc, 0x4f, 0x3c, 0x92, 0x63, 0xbc,
0xf0, 0x48, 0x8e, 0xf1, 0xc1, 0x23, 0x39, 0xc6, 0x09, 0x8f, 0xe5, 0x18, 0x2e, 0x3c, 0x96, 0x63,
0xb8, 0xf1, 0x58, 0x8e, 0x21, 0x4a, 0x16, 0xe6, 0x01, 0xfd, 0x0a, 0x7d, 0x14, 0x1f, 0x97, 0x54,
0x16, 0xa4, 0x16, 0x27, 0xb1, 0x81, 0xfd, 0x6b, 0x0c, 0x08, 0x00, 0x00, 0xff, 0xff, 0xbe, 0x59,
0x42, 0x58, 0x0e, 0x01, 0x00, 0x00,
}

View File

@ -633,6 +633,102 @@ func (m *QueryLockedFundsResponse) GetAmount() string {
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() {
proto.RegisterType((*QueryParamsRequest)(nil), "colinear.colinearcore.QueryParamsRequest")
proto.RegisterType((*QueryParamsResponse)(nil), "colinear.colinearcore.QueryParamsResponse")
@ -648,59 +744,66 @@ func init() {
proto.RegisterType((*QueryGetLockedUsersResponse)(nil), "colinear.colinearcore.QueryGetLockedUsersResponse")
proto.RegisterType((*QueryLockedFundsRequest)(nil), "colinear.colinearcore.QueryLockedFundsRequest")
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) }
var fileDescriptor_7b40a5389bf6a896 = []byte{
// 745 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x96, 0x41, 0x4f, 0x13, 0x41,
0x14, 0xc7, 0xbb, 0x08, 0x45, 0x87, 0xdb, 0x88, 0x88, 0x2b, 0x2c, 0x3a, 0xa8, 0x48, 0x91, 0x9d,
0xb4, 0x1c, 0x38, 0x98, 0x98, 0xc0, 0x01, 0x12, 0x62, 0x0c, 0x36, 0xf1, 0xa0, 0x17, 0x9c, 0xb6,
0x63, 0xb3, 0x71, 0xd9, 0x29, 0xbb, 0x5b, 0x2d, 0x21, 0x5c, 0x3c, 0x7a, 0x32, 0xf1, 0xe0, 0xc5,
0x8b, 0x1a, 0xe3, 0x57, 0xe1, 0x48, 0xe2, 0xc5, 0x93, 0x31, 0xe0, 0xc5, 0x6f, 0x61, 0x76, 0xf6,
0x6d, 0x99, 0x61, 0xb7, 0xbb, 0xe5, 0xd6, 0x9d, 0x79, 0xef, 0xfd, 0x7f, 0xfb, 0xfa, 0xde, 0xbf,
0x45, 0xd3, 0x4d, 0xe1, 0x3a, 0x1e, 0x67, 0x7e, 0x53, 0xf8, 0x9c, 0xee, 0x75, 0xb9, 0xbf, 0x6f,
0x77, 0x7c, 0x11, 0x0a, 0x7c, 0x2d, 0xb9, 0xb1, 0xd5, 0x10, 0x73, 0xb2, 0x2d, 0xda, 0x42, 0x46,
0xd0, 0xe8, 0x53, 0x1c, 0x6c, 0xce, 0xb4, 0x85, 0x68, 0xbb, 0x9c, 0xb2, 0x8e, 0x43, 0x99, 0xe7,
0x89, 0x90, 0x85, 0x8e, 0xf0, 0x02, 0xb8, 0xad, 0x34, 0x45, 0xb0, 0x2b, 0x02, 0xda, 0x60, 0x01,
0x68, 0xd0, 0x37, 0xd5, 0x06, 0x0f, 0x59, 0x95, 0x76, 0x58, 0xdb, 0xf1, 0x64, 0x30, 0xc4, 0xde,
0xd0, 0x80, 0x3a, 0xcc, 0x67, 0xbb, 0x49, 0x99, 0x39, 0xed, 0xca, 0xe3, 0xbd, 0x70, 0x87, 0x75,
0x9b, 0x4a, 0xae, 0xa9, 0x05, 0xe8, 0x77, 0x53, 0xda, 0x5d, 0xc3, 0x69, 0x65, 0x16, 0x75, 0x45,
0xf3, 0x35, 0x6f, 0xed, 0x74, 0x03, 0xee, 0x83, 0x2a, 0x99, 0x44, 0xf8, 0x69, 0x84, 0xbc, 0x2d,
0x51, 0xea, 0x7c, 0xaf, 0xcb, 0x83, 0x90, 0xd4, 0xd1, 0x55, 0xed, 0x34, 0xe8, 0x08, 0x2f, 0xe0,
0xf8, 0x21, 0x2a, 0xc7, 0xc8, 0xd3, 0xc6, 0x2d, 0xe3, 0xfe, 0x44, 0x6d, 0xd6, 0xce, 0xec, 0xa2,
0x1d, 0xa7, 0xad, 0x8f, 0x1e, 0xfd, 0x9e, 0x2b, 0xd5, 0x21, 0x85, 0xcc, 0x20, 0x53, 0xd6, 0xdc,
0xe4, 0xe1, 0x13, 0xde, 0x0b, 0xd7, 0x62, 0xfe, 0x44, 0xd1, 0x41, 0x37, 0x33, 0x6f, 0x41, 0x79,
0x0b, 0x4d, 0x28, 0xc7, 0x20, 0x4f, 0x06, 0xc8, 0x2b, 0x91, 0xc0, 0xa0, 0x26, 0x13, 0x1b, 0x4d,
0x25, 0x52, 0x3a, 0x04, 0x9e, 0x44, 0x63, 0x8e, 0xd7, 0xe2, 0x3d, 0x59, 0xff, 0x4a, 0x3d, 0x7e,
0x20, 0xcf, 0xd1, 0xf5, 0x54, 0x3c, 0x60, 0x3d, 0x42, 0xe3, 0x4c, 0x43, 0xb2, 0x06, 0x20, 0xe9,
0x38, 0x49, 0x12, 0x79, 0x09, 0x28, 0x6b, 0xae, 0x7b, 0x0e, 0x65, 0x03, 0xa1, 0xb3, 0xe1, 0x81,
0xe2, 0xf7, 0xec, 0x78, 0xd2, 0xec, 0x68, 0xd2, 0xec, 0x78, 0x9a, 0x61, 0xd2, 0xec, 0x6d, 0xd6,
0xe6, 0x90, 0x5b, 0x57, 0x32, 0xc9, 0x57, 0x03, 0xe8, 0x55, 0x89, 0x2c, 0xfa, 0x4b, 0x17, 0xa6,
0xc7, 0x9b, 0x1a, 0xe3, 0x88, 0x64, 0x5c, 0x28, 0x64, 0x8c, 0xc5, 0x35, 0x48, 0x9a, 0x30, 0x82,
0x8e, 0xd3, 0x0a, 0xf2, 0xbf, 0x92, 0x2d, 0x34, 0x9d, 0x4e, 0x80, 0xb7, 0xb2, 0xd1, 0x68, 0xc3,
0x69, 0x05, 0xf0, 0x4a, 0xe6, 0x80, 0x57, 0x5a, 0x77, 0x5a, 0x75, 0x19, 0xa7, 0xce, 0xe5, 0x63,
0xb9, 0x1f, 0xcf, 0xa2, 0xf5, 0xc8, 0x98, 0x4b, 0xed, 0xf6, 0x6c, 0x2e, 0x95, 0xe3, 0x82, 0xb9,
0x54, 0x22, 0x93, 0xb9, 0x54, 0x8e, 0xfa, 0x5d, 0x88, 0xcf, 0x36, 0xba, 0x9e, 0xd6, 0x05, 0xf1,
0xd6, 0xe3, 0x7e, 0xd2, 0x05, 0xf9, 0x40, 0x6a, 0xd0, 0x05, 0x2d, 0x01, 0xc0, 0xa6, 0x50, 0x99,
0xed, 0x8a, 0xae, 0x17, 0x42, 0x0a, 0x3c, 0xd5, 0xfe, 0x5d, 0x46, 0x63, 0x32, 0x09, 0xbf, 0x37,
0x50, 0x39, 0x5e, 0x54, 0xbc, 0x38, 0x00, 0x38, 0xed, 0x0c, 0x66, 0x65, 0x98, 0xd0, 0x98, 0x81,
0x2c, 0xbe, 0xfb, 0xf9, 0xf7, 0xe3, 0xc8, 0x3c, 0xbe, 0x4d, 0x35, 0x17, 0xca, 0xb0, 0x40, 0xfc,
0xdd, 0xd0, 0x16, 0x1c, 0x57, 0xf3, 0x64, 0x32, 0x1d, 0xc4, 0xac, 0x5d, 0x24, 0x05, 0x08, 0xa9,
0x24, 0x5c, 0xc4, 0x0b, 0x39, 0x84, 0xaa, 0x13, 0xe3, 0xcf, 0x06, 0x1a, 0x4f, 0x18, 0x97, 0x0b,
0x04, 0xcf, 0xf1, 0xd9, 0xc3, 0x86, 0x03, 0x5b, 0x4d, 0xb2, 0x3d, 0xc0, 0x95, 0x1c, 0x36, 0xc0,
0xa2, 0x07, 0x72, 0x2d, 0x0e, 0xf1, 0x27, 0x03, 0x21, 0xa8, 0xb3, 0xe6, 0xba, 0xf9, 0x84, 0x29,
0xcf, 0xc9, 0x27, 0x4c, 0xfb, 0x07, 0xa9, 0x48, 0xc2, 0x3b, 0x98, 0x14, 0x13, 0xe2, 0x1f, 0x06,
0x9a, 0x50, 0xb6, 0x15, 0xe7, 0x6b, 0xa5, 0x7c, 0xc0, 0xa4, 0x43, 0xc7, 0x03, 0xdc, 0xaa, 0x84,
0xab, 0x62, 0x5a, 0x0c, 0xb7, 0x13, 0xf9, 0x40, 0xbf, 0x87, 0x5f, 0x0c, 0x6d, 0xa7, 0x0b, 0x47,
0x31, 0x6d, 0x1a, 0x85, 0xa3, 0x98, 0xe1, 0x24, 0x64, 0x49, 0xf2, 0xde, 0xc5, 0xf3, 0x7d, 0x44,
0x3a, 0xf0, 0xb7, 0x1b, 0x7f, 0xeb, 0x33, 0xca, 0xad, 0xcf, 0xef, 0x66, 0xda, 0x4f, 0xf2, 0xbb,
0x99, 0x61, 0x27, 0x64, 0x45, 0xd2, 0x2d, 0xe3, 0xa5, 0x7c, 0xba, 0x57, 0x51, 0x12, 0x3d, 0x90,
0xf6, 0x74, 0xb8, 0xbe, 0x7a, 0x74, 0x62, 0x19, 0xc7, 0x27, 0x96, 0xf1, 0xe7, 0xc4, 0x32, 0x3e,
0x9c, 0x5a, 0xa5, 0xe3, 0x53, 0xab, 0xf4, 0xeb, 0xd4, 0x2a, 0xbd, 0x98, 0xed, 0x57, 0xe9, 0xe9,
0x75, 0xc2, 0xfd, 0x0e, 0x0f, 0x1a, 0x65, 0xf9, 0xdf, 0x64, 0xe5, 0x7f, 0x00, 0x00, 0x00, 0xff,
0xff, 0x28, 0x99, 0x3e, 0xce, 0xbf, 0x09, 0x00, 0x00,
// 824 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x96, 0xcf, 0x4f, 0xd4, 0x40,
0x14, 0xc7, 0xb7, 0xfc, 0x58, 0xc2, 0x70, 0x72, 0x44, 0xc4, 0x0a, 0x0b, 0x0e, 0x2a, 0xb0, 0x40,
0x27, 0xbb, 0x1c, 0x38, 0x98, 0x98, 0xc0, 0x01, 0x02, 0x31, 0x06, 0x37, 0xf1, 0xa0, 0x17, 0xec,
0x6e, 0x67, 0x37, 0x8d, 0x4b, 0x67, 0x69, 0xbb, 0xb8, 0x84, 0x70, 0xf1, 0xe8, 0xc9, 0x84, 0x83,
0x17, 0x2f, 0x6a, 0x8c, 0xff, 0x0a, 0x47, 0x12, 0x2f, 0x9e, 0x8c, 0x01, 0xff, 0x10, 0xd3, 0xe9,
0xeb, 0x32, 0x43, 0xbb, 0xed, 0xe2, 0x8d, 0xce, 0xfb, 0xf1, 0xfd, 0xf4, 0xcd, 0xeb, 0x97, 0x45,
0x93, 0x35, 0xde, 0xb4, 0x1d, 0x66, 0xba, 0x35, 0xee, 0x32, 0x7a, 0xd0, 0x66, 0xee, 0x91, 0xd1,
0x72, 0xb9, 0xcf, 0xf1, 0x9d, 0x28, 0x62, 0xc8, 0x29, 0xfa, 0x78, 0x83, 0x37, 0xb8, 0xc8, 0xa0,
0xc1, 0x5f, 0x61, 0xb2, 0x3e, 0xd5, 0xe0, 0xbc, 0xd1, 0x64, 0xd4, 0x6c, 0xd9, 0xd4, 0x74, 0x1c,
0xee, 0x9b, 0xbe, 0xcd, 0x1d, 0x0f, 0xa2, 0xc5, 0x1a, 0xf7, 0xf6, 0xb9, 0x47, 0xab, 0xa6, 0x07,
0x1a, 0xf4, 0xb0, 0x54, 0x65, 0xbe, 0x59, 0xa2, 0x2d, 0xb3, 0x61, 0x3b, 0x22, 0x19, 0x72, 0xef,
0x29, 0x40, 0x2d, 0xd3, 0x35, 0xf7, 0xa3, 0x36, 0x33, 0x4a, 0xc8, 0x61, 0x1d, 0x7f, 0xcf, 0x6c,
0xd7, 0xa4, 0x5a, 0x5d, 0x49, 0x50, 0x63, 0x13, 0x4a, 0xac, 0x6a, 0x5b, 0x89, 0x4d, 0x9b, 0xbc,
0xf6, 0x96, 0x59, 0x7b, 0x6d, 0x8f, 0xb9, 0xa0, 0x4a, 0xc6, 0x11, 0x7e, 0x11, 0x20, 0xef, 0x0a,
0x94, 0x0a, 0x3b, 0x68, 0x33, 0xcf, 0x27, 0x15, 0x74, 0x5b, 0x39, 0xf5, 0x5a, 0xdc, 0xf1, 0x18,
0x7e, 0x82, 0xf2, 0x21, 0xf2, 0xa4, 0x36, 0xab, 0x2d, 0x8c, 0x95, 0xa7, 0x8d, 0xc4, 0x29, 0x1a,
0x61, 0xd9, 0xc6, 0xd0, 0xd9, 0xef, 0x99, 0x5c, 0x05, 0x4a, 0xc8, 0x14, 0xd2, 0x45, 0xcf, 0x2d,
0xe6, 0x3f, 0x67, 0x1d, 0x7f, 0x3d, 0xe4, 0x8f, 0x14, 0x6d, 0x74, 0x3f, 0x31, 0x0a, 0xca, 0x3b,
0x68, 0x4c, 0x3a, 0x06, 0x79, 0xd2, 0x43, 0x5e, 0xca, 0x04, 0x06, 0xb9, 0x98, 0x18, 0x68, 0x22,
0x92, 0x52, 0x21, 0xf0, 0x38, 0x1a, 0xb6, 0x1d, 0x8b, 0x75, 0x44, 0xff, 0xd1, 0x4a, 0xf8, 0x40,
0x5e, 0xa1, 0xbb, 0xb1, 0x7c, 0xc0, 0x7a, 0x8a, 0x46, 0x4c, 0x05, 0xa9, 0xd0, 0x03, 0x49, 0xc5,
0x89, 0x8a, 0xc8, 0x1b, 0x40, 0x59, 0x6f, 0x36, 0xaf, 0xa1, 0x6c, 0x22, 0x74, 0xb5, 0x3c, 0xd0,
0xfc, 0xb1, 0x11, 0x6e, 0x9a, 0x11, 0x6c, 0x9a, 0x11, 0x6e, 0x33, 0x6c, 0x9a, 0xb1, 0x6b, 0x36,
0x18, 0xd4, 0x56, 0xa4, 0x4a, 0xf2, 0x55, 0x03, 0x7a, 0x59, 0x22, 0x89, 0x7e, 0xf0, 0xc6, 0xf4,
0x78, 0x4b, 0x61, 0x1c, 0x10, 0x8c, 0xf3, 0x99, 0x8c, 0xa1, 0xb8, 0x02, 0x49, 0x23, 0x46, 0xd0,
0xb1, 0x2d, 0x2f, 0xfd, 0x4a, 0x76, 0xd0, 0x64, 0xbc, 0x00, 0xde, 0xca, 0x40, 0x43, 0x55, 0xdb,
0xf2, 0xe0, 0x95, 0xf4, 0x1e, 0xaf, 0xb4, 0x61, 0x5b, 0x15, 0x91, 0x27, 0xef, 0xe5, 0x33, 0xf1,
0x7d, 0xbc, 0x0c, 0x3e, 0x8f, 0x84, 0xbd, 0x54, 0xa2, 0x57, 0x7b, 0x29, 0x1d, 0x67, 0xec, 0xa5,
0x94, 0x19, 0xed, 0xa5, 0x74, 0xd4, 0x9d, 0x42, 0x78, 0xb6, 0xd9, 0x76, 0x94, 0x29, 0xf0, 0x77,
0x0e, 0x73, 0xa3, 0x29, 0x88, 0x07, 0x52, 0x86, 0x29, 0x28, 0x05, 0x00, 0x36, 0x81, 0xf2, 0xe6,
0x3e, 0x6f, 0x3b, 0x3e, 0x94, 0xc0, 0x13, 0x59, 0x53, 0x47, 0xbd, 0xed, 0xd4, 0x79, 0x24, 0x32,
0x85, 0x46, 0xe1, 0x66, 0xb7, 0x2d, 0xa8, 0xba, 0x3a, 0x20, 0x1d, 0x75, 0xe4, 0x61, 0xe1, 0xff,
0x8d, 0x1c, 0x2f, 0xa3, 0x5b, 0x87, 0xcc, 0xb5, 0xeb, 0x36, 0xb3, 0x76, 0x5d, 0x7e, 0x68, 0x5b,
0xc1, 0xec, 0x06, 0x66, 0x07, 0x17, 0x46, 0x2b, 0xf1, 0x40, 0xf9, 0x14, 0xa1, 0x61, 0x21, 0x8d,
0x3f, 0x68, 0x28, 0x1f, 0x7a, 0x0b, 0x5e, 0xec, 0x21, 0x12, 0x37, 0x33, 0xbd, 0xd8, 0x4f, 0x6a,
0xf8, 0x26, 0x64, 0xf1, 0xfd, 0xcf, 0xbf, 0xa7, 0x03, 0x73, 0xf8, 0x01, 0x55, 0x8c, 0x33, 0xc1,
0xb5, 0xf1, 0x77, 0x4d, 0xf1, 0x24, 0x5c, 0x4a, 0x93, 0x49, 0x34, 0x3d, 0xbd, 0x7c, 0x93, 0x12,
0x20, 0xa4, 0x82, 0x70, 0x11, 0xcf, 0xa7, 0x10, 0xca, 0xff, 0x3c, 0xf0, 0x67, 0x0d, 0x8d, 0x44,
0x8c, 0x2b, 0x19, 0x82, 0xd7, 0xf8, 0x8c, 0x7e, 0xd3, 0x81, 0xad, 0x2c, 0xd8, 0x96, 0x71, 0x31,
0x85, 0x0d, 0xb0, 0xe8, 0xb1, 0xf8, 0x92, 0x4f, 0xf0, 0x27, 0x0d, 0x21, 0xe8, 0xb3, 0xde, 0x6c,
0xa6, 0x13, 0xc6, 0x6c, 0x32, 0x9d, 0x30, 0x6e, 0x79, 0xa4, 0x28, 0x08, 0x1f, 0x62, 0x92, 0x4d,
0x88, 0x7f, 0x68, 0x68, 0x4c, 0x32, 0x18, 0x9c, 0xae, 0x15, 0xb3, 0x2e, 0x9d, 0xf6, 0x9d, 0x0f,
0x70, 0x6b, 0x02, 0xae, 0x84, 0x69, 0x36, 0xdc, 0x5e, 0xf0, 0x1d, 0x75, 0x67, 0xf8, 0x45, 0x53,
0x6c, 0x28, 0x73, 0x15, 0xe3, 0x3e, 0x97, 0xb9, 0x8a, 0x09, 0xe6, 0x47, 0x96, 0x04, 0xef, 0x23,
0x3c, 0xd7, 0x45, 0xa4, 0x3d, 0x7f, 0x6e, 0xe0, 0x6f, 0x5d, 0x46, 0x61, 0x54, 0xe9, 0xd3, 0x8c,
0x5b, 0x60, 0xfa, 0x34, 0x13, 0x1c, 0x90, 0xac, 0x0a, 0xba, 0x15, 0xbc, 0x94, 0x4e, 0x57, 0x0f,
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.
@ -729,6 +832,8 @@ type QueryClient interface {
LockedUsers(ctx context.Context, in *QueryGetLockedUsersRequest, opts ...grpc.CallOption) (*QueryGetLockedUsersResponse, error)
// Queries a list of LockedFunds items.
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 {
@ -802,6 +907,15 @@ func (c *queryClient) LockedFunds(ctx context.Context, in *QueryLockedFundsReque
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.
type QueryServer interface {
// Parameters queries the parameters of the module.
@ -818,6 +932,8 @@ type QueryServer interface {
LockedUsers(context.Context, *QueryGetLockedUsersRequest) (*QueryGetLockedUsersResponse, error)
// Queries a list of LockedFunds items.
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.
@ -845,6 +961,9 @@ func (*UnimplementedQueryServer) LockedUsers(ctx context.Context, req *QueryGetL
func (*UnimplementedQueryServer) LockedFunds(ctx context.Context, req *QueryLockedFundsRequest) (*QueryLockedFundsResponse, error) {
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) {
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)
}
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{
ServiceName: "colinear.colinearcore.Query",
HandlerType: (*QueryServer)(nil),
@ -1008,6 +1145,10 @@ var _Query_serviceDesc = grpc.ServiceDesc{
MethodName: "LockedFunds",
Handler: _Query_LockedFunds_Handler,
},
{
MethodName: "AuctionInfo",
Handler: _Query_AuctionInfo_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "colinearcore/query.proto",
@ -1455,6 +1596,82 @@ func (m *QueryLockedFundsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error
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 {
offset -= sovQuery(v)
base := offset
@ -1636,6 +1853,40 @@ func (m *QueryLockedFundsResponse) Size() (n int) {
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) {
return (math_bits.Len64(x|1) + 6) / 7
}
@ -2742,6 +2993,204 @@ func (m *QueryLockedFundsResponse) Unmarshal(dAtA []byte) error {
}
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) {
l := len(dAtA)
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".
// UnaryRPC :call QueryServer directly.
// 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
}
@ -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
}
@ -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_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 (
@ -666,4 +765,6 @@ var (
forward_Query_LockedUsers_0 = runtime.ForwardResponseMessage
forward_Query_LockedFunds_0 = runtime.ForwardResponseMessage
forward_Query_AuctionInfo_0 = runtime.ForwardResponseMessage
)