loopd: add RPC method to list tokens

pull/101/head
Oliver Gugger 4 years ago
parent a23dfe36ab
commit 47bf510bd8
No known key found for this signature in database
GPG Key ID: 8E4256593F177720

@ -95,6 +95,7 @@ func NewClient(dbDir string, serverAddress string, insecure bool,
LndServices: lnd, LndServices: lnd,
Server: swapServerClient, Server: swapServerClient,
Store: store, Store: store,
LsatStore: lsatStore,
CreateExpiryTimer: func(d time.Duration) <-chan time.Time { CreateExpiryTimer: func(d time.Duration) <-chan time.Time {
return time.NewTimer(d).C return time.NewTimer(d).C
}, },

@ -346,6 +346,40 @@ func (s *swapClientServer) LoopIn(ctx context.Context,
}, nil }, nil
} }
// GetLsatTokens returns all tokens that are contained in the LSAT token store.
func (s *swapClientServer) GetLsatTokens(ctx context.Context,
_ *looprpc.TokensRequest) (*looprpc.TokensResponse, error) {
log.Infof("Get LSAT tokens request received")
tokens, err := s.impl.LsatStore.AllTokens()
if err != nil {
return nil, err
}
rpcTokens := make([]*looprpc.LsatToken, len(tokens))
idx := 0
for key, token := range tokens {
macBytes, err := token.BaseMacaroon().MarshalBinary()
if err != nil {
return nil, err
}
rpcTokens[idx] = &looprpc.LsatToken{
BaseMacaroon: macBytes,
PaymentHash: token.PaymentHash[:],
PaymentPreimage: token.Preimage[:],
AmountPaidMsat: int64(token.AmountPaid),
RoutingFeePaidMsat: int64(token.RoutingFeePaid),
TimeCreated: token.TimeCreated.Unix(),
Expired: !token.IsValid(),
StorageName: key,
}
idx++
}
return &looprpc.TokensResponse{Tokens: rpcTokens}, nil
}
// validateConfTarget ensures the given confirmation target is valid. If one // validateConfTarget ensures the given confirmation target is valid. If one
// isn't specified (0 value), then the default target is used. // isn't specified (0 value), then the default target is used.
func validateConfTarget(target, defaultTarget int32) (int32, error) { func validateConfTarget(target, defaultTarget int32) (int32, error) {

@ -5,6 +5,7 @@ import (
"github.com/lightninglabs/loop/lndclient" "github.com/lightninglabs/loop/lndclient"
"github.com/lightninglabs/loop/loopdb" "github.com/lightninglabs/loop/loopdb"
"github.com/lightninglabs/loop/lsat"
) )
// clientConfig contains config items for the swap client. // clientConfig contains config items for the swap client.
@ -12,5 +13,6 @@ type clientConfig struct {
LndServices *lndclient.LndServices LndServices *lndclient.LndServices
Server swapServerClient Server swapServerClient
Store loopdb.SwapStore Store loopdb.SwapStore
LsatStore lsat.Store
CreateExpiryTimer func(expiry time.Duration) <-chan time.Time CreateExpiryTimer func(expiry time.Duration) <-chan time.Time
} }

@ -801,6 +801,192 @@ func (m *QuoteResponse) GetCltvDelta() int32 {
return 0 return 0
} }
type TokensRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *TokensRequest) Reset() { *m = TokensRequest{} }
func (m *TokensRequest) String() string { return proto.CompactTextString(m) }
func (*TokensRequest) ProtoMessage() {}
func (*TokensRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_014de31d7ac8c57c, []int{9}
}
func (m *TokensRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_TokensRequest.Unmarshal(m, b)
}
func (m *TokensRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_TokensRequest.Marshal(b, m, deterministic)
}
func (m *TokensRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_TokensRequest.Merge(m, src)
}
func (m *TokensRequest) XXX_Size() int {
return xxx_messageInfo_TokensRequest.Size(m)
}
func (m *TokensRequest) XXX_DiscardUnknown() {
xxx_messageInfo_TokensRequest.DiscardUnknown(m)
}
var xxx_messageInfo_TokensRequest proto.InternalMessageInfo
type TokensResponse struct {
//*
//List of all tokens the daemon knows of, including old/expired tokens.
Tokens []*LsatToken `protobuf:"bytes,1,rep,name=tokens,proto3" json:"tokens,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *TokensResponse) Reset() { *m = TokensResponse{} }
func (m *TokensResponse) String() string { return proto.CompactTextString(m) }
func (*TokensResponse) ProtoMessage() {}
func (*TokensResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_014de31d7ac8c57c, []int{10}
}
func (m *TokensResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_TokensResponse.Unmarshal(m, b)
}
func (m *TokensResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_TokensResponse.Marshal(b, m, deterministic)
}
func (m *TokensResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_TokensResponse.Merge(m, src)
}
func (m *TokensResponse) XXX_Size() int {
return xxx_messageInfo_TokensResponse.Size(m)
}
func (m *TokensResponse) XXX_DiscardUnknown() {
xxx_messageInfo_TokensResponse.DiscardUnknown(m)
}
var xxx_messageInfo_TokensResponse proto.InternalMessageInfo
func (m *TokensResponse) GetTokens() []*LsatToken {
if m != nil {
return m.Tokens
}
return nil
}
type LsatToken struct {
//*
//The base macaroon that was baked by the auth server.
BaseMacaroon []byte `protobuf:"bytes,1,opt,name=base_macaroon,json=baseMacaroon,proto3" json:"base_macaroon,omitempty"`
//*
//The payment hash of the payment that was paid to obtain the token.
PaymentHash []byte `protobuf:"bytes,2,opt,name=payment_hash,json=paymentHash,proto3" json:"payment_hash,omitempty"`
//*
//The preimage of the payment hash, knowledge of this is proof that the
//payment has been paid. If the preimage is set to all zeros, this means the
//payment is still pending and the token is not yet fully valid.
PaymentPreimage []byte `protobuf:"bytes,3,opt,name=payment_preimage,json=paymentPreimage,proto3" json:"payment_preimage,omitempty"`
//*
//The amount of millisatoshis that was paid to get the token.
AmountPaidMsat int64 `protobuf:"varint,4,opt,name=amount_paid_msat,json=amountPaidMsat,proto3" json:"amount_paid_msat,omitempty"`
//*
//The amount of millisatoshis paid in routing fee to pay for the token.
RoutingFeePaidMsat int64 `protobuf:"varint,5,opt,name=routing_fee_paid_msat,json=routingFeePaidMsat,proto3" json:"routing_fee_paid_msat,omitempty"`
//*
//The creation time of the token as UNIX timestamp in seconds.
TimeCreated int64 `protobuf:"varint,6,opt,name=time_created,json=timeCreated,proto3" json:"time_created,omitempty"`
//*
//Indicates whether the token is expired or still valid.
Expired bool `protobuf:"varint,7,opt,name=expired,proto3" json:"expired,omitempty"`
//*
//Identifying attribute of this token in the store. Currently represents the
//file name of the token where it's stored on the file system.
StorageName string `protobuf:"bytes,8,opt,name=storage_name,json=storageName,proto3" json:"storage_name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *LsatToken) Reset() { *m = LsatToken{} }
func (m *LsatToken) String() string { return proto.CompactTextString(m) }
func (*LsatToken) ProtoMessage() {}
func (*LsatToken) Descriptor() ([]byte, []int) {
return fileDescriptor_014de31d7ac8c57c, []int{11}
}
func (m *LsatToken) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_LsatToken.Unmarshal(m, b)
}
func (m *LsatToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_LsatToken.Marshal(b, m, deterministic)
}
func (m *LsatToken) XXX_Merge(src proto.Message) {
xxx_messageInfo_LsatToken.Merge(m, src)
}
func (m *LsatToken) XXX_Size() int {
return xxx_messageInfo_LsatToken.Size(m)
}
func (m *LsatToken) XXX_DiscardUnknown() {
xxx_messageInfo_LsatToken.DiscardUnknown(m)
}
var xxx_messageInfo_LsatToken proto.InternalMessageInfo
func (m *LsatToken) GetBaseMacaroon() []byte {
if m != nil {
return m.BaseMacaroon
}
return nil
}
func (m *LsatToken) GetPaymentHash() []byte {
if m != nil {
return m.PaymentHash
}
return nil
}
func (m *LsatToken) GetPaymentPreimage() []byte {
if m != nil {
return m.PaymentPreimage
}
return nil
}
func (m *LsatToken) GetAmountPaidMsat() int64 {
if m != nil {
return m.AmountPaidMsat
}
return 0
}
func (m *LsatToken) GetRoutingFeePaidMsat() int64 {
if m != nil {
return m.RoutingFeePaidMsat
}
return 0
}
func (m *LsatToken) GetTimeCreated() int64 {
if m != nil {
return m.TimeCreated
}
return 0
}
func (m *LsatToken) GetExpired() bool {
if m != nil {
return m.Expired
}
return false
}
func (m *LsatToken) GetStorageName() string {
if m != nil {
return m.StorageName
}
return ""
}
func init() { func init() {
proto.RegisterEnum("looprpc.SwapType", SwapType_name, SwapType_value) proto.RegisterEnum("looprpc.SwapType", SwapType_name, SwapType_value)
proto.RegisterEnum("looprpc.SwapState", SwapState_name, SwapState_value) proto.RegisterEnum("looprpc.SwapState", SwapState_name, SwapState_value)
@ -813,81 +999,97 @@ func init() {
proto.RegisterType((*TermsResponse)(nil), "looprpc.TermsResponse") proto.RegisterType((*TermsResponse)(nil), "looprpc.TermsResponse")
proto.RegisterType((*QuoteRequest)(nil), "looprpc.QuoteRequest") proto.RegisterType((*QuoteRequest)(nil), "looprpc.QuoteRequest")
proto.RegisterType((*QuoteResponse)(nil), "looprpc.QuoteResponse") proto.RegisterType((*QuoteResponse)(nil), "looprpc.QuoteResponse")
proto.RegisterType((*TokensRequest)(nil), "looprpc.TokensRequest")
proto.RegisterType((*TokensResponse)(nil), "looprpc.TokensResponse")
proto.RegisterType((*LsatToken)(nil), "looprpc.LsatToken")
} }
func init() { proto.RegisterFile("client.proto", fileDescriptor_014de31d7ac8c57c) } func init() { proto.RegisterFile("client.proto", fileDescriptor_014de31d7ac8c57c) }
var fileDescriptor_014de31d7ac8c57c = []byte{ var fileDescriptor_014de31d7ac8c57c = []byte{
// 1096 bytes of a gzipped FileDescriptorProto // 1310 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x56, 0x4f, 0x73, 0xda, 0xc6, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x56, 0xcd, 0x72, 0x1a, 0x47,
0x1b, 0x8e, 0x40, 0x18, 0xf1, 0x5a, 0xc8, 0x62, 0x9d, 0xd8, 0x98, 0xdf, 0x2f, 0x13, 0xaa, 0x36, 0x10, 0x36, 0x3f, 0x12, 0xd0, 0x2c, 0xcb, 0x6a, 0x64, 0x4b, 0x48, 0x89, 0xcb, 0x78, 0x13, 0x3b,
0x29, 0xe3, 0x43, 0x68, 0x93, 0x53, 0x73, 0xa3, 0x40, 0x12, 0x3c, 0xb6, 0xa1, 0x02, 0x67, 0xa6, 0x44, 0x07, 0x13, 0xdb, 0xa7, 0xb8, 0x72, 0x21, 0x08, 0x5b, 0xa8, 0x24, 0x41, 0x16, 0xe4, 0x2a,
0xbd, 0xa8, 0x1b, 0x58, 0x6c, 0xcd, 0x48, 0x2b, 0x45, 0x5a, 0xfc, 0x67, 0x3a, 0xb9, 0xf4, 0x2b, 0xe7, 0xb2, 0x19, 0xc3, 0x48, 0xda, 0x0a, 0x3b, 0xbb, 0xde, 0x19, 0x6c, 0xa9, 0x52, 0xbe, 0xe4,
0xf4, 0xd6, 0x6f, 0xd1, 0x99, 0x7e, 0x93, 0xde, 0x7b, 0xea, 0xf4, 0x73, 0x74, 0xf6, 0x5d, 0x81, 0x15, 0x72, 0xcb, 0x5b, 0xa4, 0x2a, 0xb7, 0x9c, 0xf2, 0x0c, 0xb9, 0xe7, 0x94, 0x07, 0x49, 0x4d,
0x85, 0x89, 0x2f, 0xb9, 0x99, 0x67, 0x9f, 0x7d, 0xde, 0x3f, 0xfb, 0xbc, 0xaf, 0x0c, 0xe6, 0x34, 0xcf, 0xb0, 0x5a, 0x84, 0x7d, 0xf1, 0x8d, 0xfd, 0xe6, 0x9b, 0x6f, 0xba, 0x7b, 0xbe, 0xee, 0x01,
0xf0, 0x19, 0x17, 0xcf, 0xe3, 0x24, 0x12, 0x11, 0x29, 0x07, 0x51, 0x14, 0x27, 0xf1, 0xb4, 0xf1, 0xac, 0xc9, 0x2c, 0x60, 0x5c, 0x3e, 0x8a, 0x93, 0x48, 0x46, 0xa4, 0x34, 0x8b, 0xa2, 0x38, 0x89,
0xff, 0xf3, 0x28, 0x3a, 0x0f, 0x58, 0x9b, 0xc6, 0x7e, 0x9b, 0x72, 0x1e, 0x09, 0x2a, 0xfc, 0x88, 0x27, 0xbb, 0x9f, 0x9f, 0x47, 0xd1, 0xf9, 0x8c, 0xb5, 0x69, 0x1c, 0xb4, 0x29, 0xe7, 0x91, 0xa4,
0xa7, 0x8a, 0xe6, 0xfc, 0x5e, 0x04, 0xeb, 0x38, 0x8a, 0xe2, 0xe1, 0x42, 0xb8, 0xec, 0xc3, 0x82, 0x32, 0x88, 0xb8, 0xd0, 0x34, 0xf7, 0xf7, 0x02, 0xd8, 0x47, 0x51, 0x14, 0x0f, 0xe6, 0xd2, 0x63,
0xa5, 0x82, 0xd8, 0x50, 0xa4, 0xa1, 0xa8, 0x6b, 0x4d, 0xad, 0x55, 0x74, 0xe5, 0x9f, 0x84, 0x80, 0x6f, 0xe6, 0x4c, 0x48, 0xe2, 0x40, 0x81, 0x86, 0xb2, 0x91, 0x6b, 0xe6, 0x5a, 0x05, 0x4f, 0xfd,
0x3e, 0x63, 0xa9, 0xa8, 0x17, 0x9a, 0x5a, 0xab, 0xe2, 0xe2, 0xdf, 0xa4, 0x0d, 0x0f, 0x43, 0x7a, 0x24, 0x04, 0x8a, 0x53, 0x26, 0x64, 0x23, 0xdf, 0xcc, 0xb5, 0x2a, 0x1e, 0xfe, 0x26, 0x6d, 0xb8,
0xed, 0xa5, 0x57, 0x34, 0xf6, 0x92, 0x68, 0x21, 0x7c, 0x7e, 0xee, 0xcd, 0x19, 0xab, 0x17, 0xf1, 0x1d, 0xd2, 0x4b, 0x5f, 0xbc, 0xa3, 0xb1, 0x9f, 0x44, 0x73, 0x19, 0xf0, 0x73, 0xff, 0x8c, 0xb1,
0x5a, 0x2d, 0xa4, 0xd7, 0xe3, 0x2b, 0x1a, 0xbb, 0xea, 0xe4, 0x35, 0x63, 0xe4, 0x25, 0xec, 0xc9, 0x46, 0x01, 0xb7, 0x6d, 0x84, 0xf4, 0x72, 0xf4, 0x8e, 0xc6, 0x9e, 0x5e, 0x79, 0xce, 0x18, 0x79,
0x0b, 0x71, 0xc2, 0x62, 0x7a, 0xb3, 0x76, 0x45, 0xc7, 0x2b, 0xbb, 0x21, 0xbd, 0x1e, 0xe1, 0x61, 0x0a, 0x5b, 0x6a, 0x43, 0x9c, 0xb0, 0x98, 0x5e, 0x2d, 0x6d, 0x29, 0xe2, 0x96, 0xcd, 0x90, 0x5e,
0xee, 0x52, 0x13, 0xcc, 0x55, 0x14, 0x49, 0x2d, 0x21, 0x15, 0x32, 0x75, 0xc9, 0xf8, 0x0a, 0xac, 0x0e, 0x71, 0x31, 0xb3, 0xa9, 0x09, 0x56, 0x7a, 0x8a, 0xa2, 0xae, 0x21, 0x15, 0x8c, 0xba, 0x62,
0x9c, 0xac, 0x4c, 0x7c, 0x0b, 0x39, 0xe6, 0x4a, 0xae, 0x13, 0x0a, 0xe2, 0x40, 0x55, 0xb2, 0x42, 0x7c, 0x09, 0x76, 0x46, 0x56, 0x05, 0xbe, 0x8e, 0x1c, 0x2b, 0x95, 0xeb, 0x84, 0x92, 0xb8, 0x50,
0x9f, 0xb3, 0x04, 0x85, 0xca, 0x48, 0xda, 0x0e, 0xe9, 0xf5, 0x89, 0xc4, 0xa4, 0x52, 0x0b, 0x6c, 0x53, 0xac, 0x30, 0xe0, 0x2c, 0x41, 0xa1, 0x12, 0x92, 0xaa, 0x21, 0xbd, 0x3c, 0x56, 0x98, 0x52,
0xd9, 0x33, 0x2f, 0x5a, 0x08, 0x6f, 0x7a, 0x41, 0x39, 0x67, 0x41, 0xdd, 0x68, 0x6a, 0x2d, 0xdd, 0x6a, 0x81, 0xa3, 0x6a, 0xe6, 0x47, 0x73, 0xe9, 0x4f, 0x2e, 0x28, 0xe7, 0x6c, 0xd6, 0x28, 0x37,
0xb5, 0x02, 0xd5, 0xa1, 0xae, 0x42, 0xc9, 0x21, 0xd4, 0xd2, 0x2b, 0xc6, 0x62, 0x6f, 0x1a, 0xf1, 0x73, 0xad, 0xa2, 0x67, 0xcf, 0x74, 0x85, 0xba, 0x1a, 0x25, 0x7b, 0xb0, 0x21, 0xde, 0x31, 0x16,
0xb9, 0x27, 0x68, 0x72, 0xce, 0x44, 0xbd, 0xd2, 0xd4, 0x5a, 0x25, 0x77, 0x07, 0x0f, 0xba, 0x11, 0xfb, 0x93, 0x88, 0x9f, 0xf9, 0x92, 0x26, 0xe7, 0x4c, 0x36, 0x2a, 0xcd, 0x5c, 0x6b, 0xcd, 0xab,
0x9f, 0x4f, 0x10, 0x26, 0xaf, 0xe0, 0x00, 0xb3, 0x8f, 0x17, 0xef, 0x03, 0x7f, 0x8a, 0xbd, 0xf7, 0xe3, 0x42, 0x37, 0xe2, 0x67, 0x63, 0x84, 0xc9, 0x33, 0xd8, 0xc1, 0xe8, 0xe3, 0xf9, 0xeb, 0x59,
0x66, 0x8c, 0xce, 0x02, 0x9f, 0xb3, 0x3a, 0xa0, 0xfc, 0xbe, 0x24, 0x8c, 0x6e, 0xcf, 0x7b, 0xd9, 0x30, 0xc1, 0xda, 0xfb, 0x53, 0x46, 0xa7, 0xb3, 0x80, 0xb3, 0x06, 0xa0, 0xfc, 0xb6, 0x22, 0x0c,
0xb1, 0xf3, 0xa7, 0x06, 0x55, 0xf9, 0x38, 0x03, 0x7e, 0xff, 0xdb, 0xdc, 0xed, 0x50, 0x61, 0xa3, 0xaf, 0xd7, 0xf7, 0xcd, 0xb2, 0xfb, 0x67, 0x0e, 0x6a, 0xea, 0x72, 0xfa, 0xfc, 0xe3, 0x77, 0x73,
0x43, 0x1b, 0xb5, 0x17, 0x37, 0x6b, 0x7f, 0x06, 0x3b, 0x58, 0xbb, 0xcf, 0x57, 0xa5, 0xeb, 0x98, 0xb3, 0x42, 0xf9, 0x95, 0x0a, 0xad, 0xe4, 0x5e, 0x58, 0xcd, 0xfd, 0x21, 0xd4, 0x31, 0xf7, 0x80,
0x5b, 0x35, 0xc0, 0xf8, 0xcb, 0xca, 0xbf, 0x84, 0x2a, 0xbb, 0x16, 0x2c, 0xe1, 0x34, 0xf0, 0x2e, 0xa7, 0xa9, 0x17, 0x31, 0xb6, 0xda, 0x0c, 0xcf, 0x5f, 0x64, 0xfe, 0x05, 0xd4, 0xd8, 0xa5, 0x64,
0x44, 0x30, 0xc5, 0x07, 0x31, 0x5c, 0x73, 0x09, 0xbe, 0x15, 0xc1, 0xd4, 0xe9, 0x80, 0x89, 0x6f, 0x09, 0xa7, 0x33, 0xff, 0x42, 0xce, 0x26, 0x78, 0x21, 0x65, 0xcf, 0x5a, 0x80, 0x07, 0x72, 0x36,
0xcf, 0xd2, 0x38, 0xe2, 0x29, 0x23, 0x16, 0x14, 0xfc, 0x19, 0xe6, 0x5c, 0x71, 0x0b, 0xfe, 0x8c, 0x71, 0x3b, 0x60, 0xe1, 0xdd, 0x33, 0x11, 0x47, 0x5c, 0x30, 0x62, 0x43, 0x3e, 0x98, 0x62, 0xcc,
0x7c, 0x01, 0xa6, 0xbc, 0xeb, 0xd1, 0xd9, 0x2c, 0x61, 0x69, 0x9a, 0xd9, 0x6a, 0x5b, 0x62, 0x1d, 0x15, 0x2f, 0x1f, 0x4c, 0xc9, 0x7d, 0xb0, 0xd4, 0x5e, 0x9f, 0x4e, 0xa7, 0x09, 0x13, 0xc2, 0xd8,
0x05, 0x39, 0x36, 0x58, 0x27, 0x11, 0xf7, 0x45, 0x94, 0x64, 0x95, 0x3b, 0x7f, 0x17, 0x00, 0xa4, 0xaa, 0xaa, 0xb0, 0x8e, 0x86, 0x5c, 0x07, 0xec, 0xe3, 0x88, 0x07, 0x32, 0x4a, 0x4c, 0xe6, 0xee,
0xea, 0x58, 0x50, 0xb1, 0x48, 0x3f, 0xd1, 0x08, 0x15, 0xa5, 0xb0, 0x8a, 0xf2, 0x14, 0x74, 0x71, 0xbf, 0x79, 0x00, 0xa5, 0x3a, 0x92, 0x54, 0xce, 0xc5, 0x07, 0x0a, 0xa1, 0x4f, 0xc9, 0xa7, 0xa7,
0x13, 0xab, 0x6a, 0xad, 0x17, 0xb5, 0xe7, 0xd9, 0x3c, 0x3c, 0x97, 0x22, 0x93, 0x9b, 0x98, 0xb9, 0x3c, 0x80, 0xa2, 0xbc, 0x8a, 0x75, 0xb6, 0xf6, 0x93, 0x8d, 0x47, 0xa6, 0x1f, 0x1e, 0x29, 0x91,
0x78, 0x4c, 0x5a, 0x50, 0x4a, 0x05, 0x15, 0xca, 0x85, 0xd6, 0x0b, 0xb2, 0xc6, 0x93, 0xc1, 0x98, 0xf1, 0x55, 0xcc, 0x3c, 0x5c, 0x26, 0x2d, 0x58, 0x13, 0x92, 0x4a, 0xed, 0x42, 0xfb, 0x09, 0x59,
0xab, 0x08, 0xe4, 0x6b, 0xd8, 0xf1, 0xb9, 0x2f, 0x7c, 0xf5, 0x86, 0xc2, 0x0f, 0x97, 0x76, 0xb4, 0xe2, 0xa9, 0xc3, 0x98, 0xa7, 0x09, 0xe4, 0x2b, 0xa8, 0x07, 0x3c, 0x90, 0x81, 0xbe, 0x43, 0x19,
0x6e, 0xe1, 0x89, 0x1f, 0x2a, 0x23, 0xd1, 0x54, 0x78, 0x8b, 0x78, 0x46, 0x05, 0x53, 0x4c, 0x65, 0x84, 0x0b, 0x3b, 0xda, 0xd7, 0xf0, 0x38, 0x08, 0xb5, 0x91, 0xa8, 0x90, 0xfe, 0x3c, 0x9e, 0x52,
0x4a, 0x4b, 0xe2, 0x67, 0x08, 0x23, 0xf3, 0x6e, 0x27, 0xca, 0x1b, 0x9d, 0x20, 0x4f, 0x60, 0x7b, 0xc9, 0x34, 0x53, 0x9b, 0xd2, 0x56, 0xf8, 0x29, 0xc2, 0xc8, 0xbc, 0x59, 0x89, 0xd2, 0x4a, 0x25,
0x1a, 0xa5, 0xc2, 0x4b, 0x59, 0x72, 0xc9, 0x12, 0x34, 0x64, 0xd1, 0x05, 0x09, 0x8d, 0x11, 0x91, 0xc8, 0x3d, 0xa8, 0x4e, 0x22, 0x21, 0x7d, 0xc1, 0x92, 0xb7, 0x2c, 0x41, 0x43, 0x16, 0x3c, 0x50,
0x1a, 0x48, 0x88, 0xf8, 0xf4, 0x82, 0xfa, 0x1c, 0x7d, 0x58, 0x74, 0xf1, 0xd2, 0x50, 0x41, 0xf2, 0xd0, 0x08, 0x11, 0xa5, 0x81, 0x84, 0x88, 0x4f, 0x2e, 0x68, 0xc0, 0xd1, 0x87, 0x05, 0x0f, 0x37,
0xd5, 0x14, 0x65, 0x3e, 0x57, 0x1c, 0x50, 0x23, 0x82, 0x9c, 0x0c, 0x73, 0x2c, 0x30, 0x27, 0x2c, 0x0d, 0x34, 0xa4, 0x6e, 0x4d, 0x53, 0xce, 0xce, 0x34, 0x07, 0x74, 0x8b, 0x20, 0xc7, 0x60, 0xae,
0x09, 0xd3, 0x65, 0xc3, 0x3f, 0x42, 0x35, 0xfb, 0x9d, 0x3d, 0xe3, 0x33, 0xd8, 0x09, 0x7d, 0xae, 0x0d, 0xd6, 0x98, 0x25, 0xa1, 0x58, 0x14, 0xfc, 0x3d, 0xd4, 0xcc, 0xb7, 0xb9, 0xc6, 0x87, 0x50,
0x9c, 0x46, 0xc3, 0x68, 0xc1, 0x45, 0x56, 0x7f, 0x35, 0xf4, 0xb9, 0xec, 0x56, 0x07, 0x41, 0xe4, 0x0f, 0x03, 0xae, 0x9d, 0x46, 0xc3, 0x68, 0xce, 0xa5, 0xc9, 0xbf, 0x16, 0x06, 0x5c, 0x55, 0xab,
0x2d, 0x1d, 0x99, 0xf1, 0xb6, 0x32, 0x9e, 0x32, 0xa5, 0xe2, 0x1d, 0xe9, 0x86, 0x66, 0x17, 0x8e, 0x83, 0x20, 0xf2, 0x16, 0x8e, 0x34, 0xbc, 0x75, 0xc3, 0xd3, 0xa6, 0xd4, 0xbc, 0xc3, 0x62, 0x39,
0x74, 0xa3, 0x60, 0x17, 0x8f, 0x74, 0xa3, 0x68, 0xeb, 0x47, 0xba, 0xa1, 0xdb, 0xa5, 0x23, 0xdd, 0xe7, 0xe4, 0x0f, 0x8b, 0xe5, 0xbc, 0x53, 0x38, 0x2c, 0x96, 0x0b, 0x4e, 0xf1, 0xb0, 0x58, 0x2e,
0x28, 0xdb, 0x86, 0x33, 0x07, 0xf3, 0x87, 0x45, 0x24, 0xd8, 0xfd, 0xce, 0xc7, 0xce, 0xdc, 0xce, 0x3a, 0x6b, 0x87, 0xc5, 0x72, 0xc9, 0x29, 0xbb, 0x67, 0x60, 0xfd, 0x30, 0x8f, 0x24, 0xfb, 0xb8,
0x5f, 0x01, 0xe7, 0x0f, 0xa6, 0xb7, 0xa3, 0xb7, 0x61, 0xd6, 0xe2, 0x27, 0xcc, 0xfa, 0x87, 0x06, 0xf3, 0xb1, 0x32, 0xd7, 0xfd, 0x97, 0xc7, 0xfe, 0x83, 0xc9, 0x75, 0xeb, 0xad, 0x98, 0xb5, 0xf0,
0xd5, 0x2c, 0x50, 0x56, 0xe7, 0x01, 0x18, 0xab, 0x69, 0x52, 0xe1, 0xca, 0x69, 0x36, 0x4a, 0x8f, 0x01, 0xb3, 0xfe, 0x91, 0x83, 0x9a, 0x39, 0xc8, 0xe4, 0xb9, 0x03, 0xe5, 0xb4, 0x9b, 0xf4, 0x71,
0x01, 0x72, 0x8b, 0x46, 0x8d, 0x5a, 0x25, 0x5e, 0x6d, 0x99, 0xff, 0x41, 0xe5, 0xee, 0x94, 0x19, 0x25, 0x61, 0x5a, 0xe9, 0x2e, 0x40, 0x66, 0xd0, 0xe8, 0x56, 0xab, 0xc4, 0xe9, 0x94, 0xf9, 0x0c,
0xe1, 0x72, 0xc4, 0x70, 0x69, 0xc8, 0x45, 0x40, 0x6f, 0x42, 0xc6, 0x85, 0x87, 0x1b, 0x55, 0x9a, 0x2a, 0x37, 0xbb, 0xac, 0x1c, 0x2e, 0x5a, 0x0c, 0x87, 0x86, 0x1a, 0x04, 0xf4, 0x2a, 0x64, 0x5c,
0xce, 0x94, 0x4b, 0x83, 0xc6, 0x23, 0x85, 0xf7, 0x64, 0xb1, 0x8f, 0x01, 0xa6, 0x81, 0xb8, 0xf4, 0xfa, 0x38, 0x51, 0x95, 0xe9, 0x2c, 0x35, 0x34, 0x68, 0x3c, 0xd4, 0xf8, 0xbe, 0x4a, 0xf6, 0x2e,
0x66, 0x2c, 0x10, 0x14, 0xbb, 0x5c, 0x72, 0x2b, 0x12, 0xe9, 0x49, 0xe0, 0xf0, 0x29, 0x18, 0x4b, 0xc0, 0x64, 0x26, 0xdf, 0xfa, 0x53, 0x36, 0x93, 0x14, 0xab, 0xbc, 0xe6, 0x55, 0x14, 0xb2, 0xaf,
0x17, 0x13, 0x13, 0x8c, 0xe3, 0xe1, 0x70, 0xe4, 0x0d, 0xcf, 0x26, 0xf6, 0x03, 0xb2, 0x0d, 0x65, 0x00, 0xb7, 0x0e, 0xb5, 0x71, 0xf4, 0x33, 0xe3, 0xe9, 0x5d, 0x7d, 0x07, 0xf6, 0x02, 0x30, 0x49,
0xfc, 0x35, 0x38, 0xb5, 0xb5, 0xc3, 0x14, 0x2a, 0x2b, 0x13, 0x93, 0x2a, 0x54, 0x06, 0xa7, 0x83, 0xec, 0xc1, 0xba, 0x44, 0xa4, 0x91, 0x6b, 0x16, 0x5a, 0xd5, 0x8c, 0xaf, 0x8f, 0x04, 0x95, 0x48,
0xc9, 0xa0, 0x33, 0xe9, 0xf7, 0xec, 0x07, 0xe4, 0x11, 0xd4, 0x46, 0x6e, 0x7f, 0x70, 0xd2, 0x79, 0xf6, 0x0c, 0xc3, 0xfd, 0x2b, 0x0f, 0x95, 0x14, 0x55, 0x55, 0x7b, 0x4d, 0x05, 0xf3, 0x43, 0x3a,
0xd3, 0xf7, 0xdc, 0xfe, 0xbb, 0x7e, 0xe7, 0xb8, 0xdf, 0xb3, 0x35, 0x42, 0xc0, 0x7a, 0x3b, 0x39, 0xa1, 0x49, 0x14, 0x71, 0xac, 0x81, 0xe5, 0x59, 0x0a, 0x3c, 0x36, 0x98, 0x32, 0xdd, 0x22, 0x8f,
0xee, 0x7a, 0xa3, 0xb3, 0xef, 0x8f, 0x07, 0xe3, 0xb7, 0xfd, 0x9e, 0x5d, 0x90, 0x9a, 0xe3, 0xb3, 0x0b, 0x2a, 0x2e, 0xb0, 0x14, 0x96, 0x57, 0x35, 0xd8, 0x01, 0x15, 0x17, 0xe4, 0x6b, 0x70, 0x16,
0x6e, 0xb7, 0x3f, 0x1e, 0xdb, 0x45, 0x02, 0xb0, 0xf5, 0xba, 0x33, 0x90, 0x64, 0x9d, 0xec, 0xc2, 0x94, 0x38, 0x61, 0x41, 0x48, 0xcf, 0x75, 0x4d, 0x2c, 0xaf, 0x6e, 0xf0, 0xa1, 0x81, 0x55, 0xc3,
0xce, 0xe0, 0xf4, 0xdd, 0x70, 0xd0, 0xed, 0x7b, 0xe3, 0xfe, 0x64, 0x22, 0xc1, 0xd2, 0x8b, 0x7f, 0x68, 0xa3, 0xf8, 0x31, 0x0d, 0xa6, 0x7e, 0x28, 0xa8, 0x34, 0x8f, 0x82, 0xad, 0xf1, 0x21, 0x0d,
0x75, 0x35, 0xa7, 0x5d, 0xfc, 0x18, 0x11, 0x17, 0xca, 0xd9, 0xe7, 0x85, 0xec, 0xaf, 0x46, 0x6b, 0xa6, 0xc7, 0x82, 0x4a, 0xf2, 0x18, 0xee, 0x64, 0x5e, 0x8e, 0x0c, 0x5d, 0x3b, 0x91, 0x24, 0xe9,
0xfd, 0x83, 0xd3, 0x78, 0xb4, 0x36, 0x73, 0xcb, 0x77, 0x70, 0xf6, 0x7f, 0xfd, 0xeb, 0x9f, 0xdf, 0xd3, 0x91, 0x6e, 0xb9, 0x0f, 0x96, 0xea, 0x40, 0x7f, 0x92, 0x30, 0x2a, 0xd9, 0xd4, 0x78, 0xb1,
0x0a, 0x35, 0xc7, 0x6c, 0x5f, 0x7e, 0xdb, 0x96, 0x8c, 0x76, 0xb4, 0x10, 0xaf, 0xb4, 0x43, 0x32, 0xaa, 0xb0, 0xae, 0x86, 0x48, 0x03, 0x4a, 0xec, 0x32, 0x0e, 0x12, 0x36, 0xc5, 0x0e, 0x2c, 0x7b,
0x84, 0x2d, 0xb5, 0x15, 0xc9, 0xde, 0x9a, 0xe4, 0x6a, 0x4d, 0xde, 0xa7, 0xb8, 0x87, 0x8a, 0xb6, 0x8b, 0x4f, 0xb5, 0x59, 0xc8, 0x28, 0xa1, 0xe7, 0xcc, 0xe7, 0x34, 0x64, 0xd8, 0x7e, 0x15, 0xaf,
0xb3, 0xbd, 0x52, 0xf4, 0xb9, 0x14, 0xfc, 0x0e, 0xca, 0xd9, 0xb6, 0xc9, 0x25, 0xb9, 0xbe, 0x7f, 0x6a, 0xb0, 0x13, 0x1a, 0xb2, 0xbd, 0x07, 0x50, 0x5e, 0x8c, 0x14, 0x62, 0x41, 0xf9, 0x68, 0x30,
0x1a, 0xbb, 0x1b, 0x8b, 0x61, 0x91, 0x7e, 0xa3, 0x91, 0x1f, 0xc1, 0xcc, 0xaa, 0xc1, 0x61, 0x21, 0x18, 0xfa, 0x83, 0xd3, 0xb1, 0x73, 0x8b, 0x54, 0xa1, 0x84, 0x5f, 0xfd, 0x13, 0x27, 0xb7, 0x27,
0xb7, 0x91, 0xf3, 0xc3, 0xd4, 0xd8, 0xbb, 0x0b, 0x67, 0x19, 0x35, 0x30, 0xa3, 0x87, 0x84, 0xe4, 0xa0, 0x92, 0x4e, 0x14, 0x52, 0x83, 0x4a, 0xff, 0xa4, 0x3f, 0xee, 0x77, 0xc6, 0xbd, 0x7d, 0xe7,
0x6b, 0x6c, 0x0b, 0x94, 0xf2, 0x56, 0xd2, 0xe8, 0xcf, 0x9c, 0x74, 0x7e, 0x30, 0x72, 0xd2, 0x6b, 0x16, 0xb9, 0x03, 0x1b, 0x43, 0xaf, 0xd7, 0x3f, 0xee, 0xbc, 0xe8, 0xf9, 0x5e, 0xef, 0x65, 0xaf,
0x36, 0x76, 0x9a, 0x28, 0xdd, 0x20, 0xf5, 0x35, 0xe9, 0x0f, 0x92, 0xd3, 0xfe, 0x85, 0x86, 0xe2, 0x73, 0xd4, 0xdb, 0x77, 0x72, 0x84, 0x80, 0x7d, 0x30, 0x3e, 0xea, 0xfa, 0xc3, 0xd3, 0xef, 0x8f,
0x23, 0xf9, 0x09, 0xac, 0x37, 0x4c, 0xa8, 0xce, 0x7d, 0x56, 0xf6, 0x07, 0x18, 0x62, 0x97, 0xd4, 0xfa, 0xa3, 0x83, 0xde, 0xbe, 0x93, 0x57, 0x9a, 0xa3, 0xd3, 0x6e, 0xb7, 0x37, 0x1a, 0x39, 0x05,
0x72, 0xfd, 0xcc, 0x92, 0xff, 0x39, 0xa7, 0xfd, 0x59, 0xe9, 0x3f, 0x41, 0xed, 0x03, 0xb2, 0x9f, 0x02, 0xb0, 0xfe, 0xbc, 0xd3, 0x57, 0xe4, 0x22, 0xd9, 0x84, 0x7a, 0xff, 0xe4, 0xe5, 0xa0, 0xdf,
0xd7, 0xce, 0x65, 0xff, 0x7e, 0x0b, 0xff, 0x81, 0x79, 0xf9, 0x5f, 0x00, 0x00, 0x00, 0xff, 0xff, 0xed, 0xf9, 0xa3, 0xde, 0x78, 0xac, 0xc0, 0xb5, 0x27, 0x7f, 0xaf, 0xe9, 0xa1, 0xd9, 0xc5, 0x7f,
0xc2, 0x6b, 0xe2, 0x2f, 0xf7, 0x08, 0x00, 0x00, 0x06, 0xc4, 0x83, 0x92, 0x79, 0xeb, 0xc9, 0xf6, 0xb5, 0x1f, 0x96, 0x5e, 0xff, 0xdd, 0x3b, 0x4b,
0x03, 0x70, 0xe1, 0x27, 0x77, 0xfb, 0xd7, 0x7f, 0xfe, 0xfb, 0x2d, 0xbf, 0xe1, 0x5a, 0xed, 0xb7,
0x8f, 0xdb, 0x8a, 0xd1, 0x8e, 0xe6, 0xf2, 0x59, 0x6e, 0x8f, 0x0c, 0x60, 0x5d, 0x3f, 0x51, 0x64,
0x6b, 0x49, 0x32, 0x7d, 0xb3, 0x3e, 0xa6, 0xb8, 0x85, 0x8a, 0x8e, 0x5b, 0x4d, 0x15, 0x03, 0xae,
0x04, 0xbf, 0x85, 0x92, 0x19, 0xfd, 0x99, 0x20, 0x97, 0x1f, 0x83, 0xdd, 0xcd, 0x95, 0x29, 0x3d,
0x17, 0xdf, 0xe4, 0xc8, 0x2b, 0xb0, 0x4c, 0x36, 0x38, 0xb9, 0xc8, 0xf5, 0xc9, 0xd9, 0xc9, 0xb6,
0xbb, 0x75, 0x13, 0x36, 0x11, 0xed, 0x62, 0x44, 0xb7, 0x09, 0xc9, 0xe6, 0xd8, 0x96, 0x28, 0xe5,
0xa7, 0xd2, 0x38, 0x2c, 0x32, 0xd2, 0xd9, 0x29, 0x95, 0x91, 0x5e, 0x9a, 0x29, 0x6e, 0x13, 0xa5,
0x77, 0x49, 0x63, 0x49, 0xfa, 0x8d, 0xe2, 0xb4, 0x7f, 0xa1, 0xa1, 0x7c, 0x4f, 0x7e, 0x04, 0xfb,
0x05, 0x93, 0xba, 0x72, 0x9f, 0x14, 0xfd, 0x0e, 0x1e, 0xb1, 0x49, 0x36, 0x32, 0xf5, 0x34, 0xc1,
0xff, 0x94, 0xd1, 0xfe, 0xa4, 0xf0, 0xef, 0xa1, 0xf6, 0x0e, 0xd9, 0xce, 0x6a, 0x67, 0xa3, 0x7f,
0x05, 0x35, 0x75, 0xc2, 0x62, 0x88, 0x88, 0x8c, 0x19, 0x96, 0x26, 0xd5, 0xee, 0xf6, 0x0a, 0xbe,
0x6c, 0x30, 0x52, 0xc7, 0x23, 0x04, 0x95, 0x6d, 0x3d, 0x9d, 0x5e, 0xaf, 0xe3, 0x1f, 0xd5, 0xa7,
0xff, 0x07, 0x00, 0x00, 0xff, 0xff, 0xbc, 0xc2, 0x52, 0x9d, 0xdf, 0x0a, 0x00, 0x00,
} }
// Reference imports to suppress errors if they are not otherwise used. // Reference imports to suppress errors if they are not otherwise used.
@ -931,6 +1133,9 @@ type SwapClientClient interface {
//* //*
//GetQuote returns a quote for a swap with the provided parameters. //GetQuote returns a quote for a swap with the provided parameters.
GetLoopInQuote(ctx context.Context, in *QuoteRequest, opts ...grpc.CallOption) (*QuoteResponse, error) GetLoopInQuote(ctx context.Context, in *QuoteRequest, opts ...grpc.CallOption) (*QuoteResponse, error)
//*
//GetLsatTokens returns all LSAT tokens the daemon ever paid for.
GetLsatTokens(ctx context.Context, in *TokensRequest, opts ...grpc.CallOption) (*TokensResponse, error)
} }
type swapClientClient struct { type swapClientClient struct {
@ -1027,6 +1232,15 @@ func (c *swapClientClient) GetLoopInQuote(ctx context.Context, in *QuoteRequest,
return out, nil return out, nil
} }
func (c *swapClientClient) GetLsatTokens(ctx context.Context, in *TokensRequest, opts ...grpc.CallOption) (*TokensResponse, error) {
out := new(TokensResponse)
err := c.cc.Invoke(ctx, "/looprpc.SwapClient/GetLsatTokens", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// SwapClientServer is the server API for SwapClient service. // SwapClientServer is the server API for SwapClient service.
type SwapClientServer interface { type SwapClientServer interface {
//* loop: `out` //* loop: `out`
@ -1058,6 +1272,9 @@ type SwapClientServer interface {
//* //*
//GetQuote returns a quote for a swap with the provided parameters. //GetQuote returns a quote for a swap with the provided parameters.
GetLoopInQuote(context.Context, *QuoteRequest) (*QuoteResponse, error) GetLoopInQuote(context.Context, *QuoteRequest) (*QuoteResponse, error)
//*
//GetLsatTokens returns all LSAT tokens the daemon ever paid for.
GetLsatTokens(context.Context, *TokensRequest) (*TokensResponse, error)
} }
func RegisterSwapClientServer(s *grpc.Server, srv SwapClientServer) { func RegisterSwapClientServer(s *grpc.Server, srv SwapClientServer) {
@ -1193,6 +1410,24 @@ func _SwapClient_GetLoopInQuote_Handler(srv interface{}, ctx context.Context, de
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
func _SwapClient_GetLsatTokens_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(TokensRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(SwapClientServer).GetLsatTokens(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/looprpc.SwapClient/GetLsatTokens",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(SwapClientServer).GetLsatTokens(ctx, req.(*TokensRequest))
}
return interceptor(ctx, in, info, handler)
}
var _SwapClient_serviceDesc = grpc.ServiceDesc{ var _SwapClient_serviceDesc = grpc.ServiceDesc{
ServiceName: "looprpc.SwapClient", ServiceName: "looprpc.SwapClient",
HandlerType: (*SwapClientServer)(nil), HandlerType: (*SwapClientServer)(nil),
@ -1221,6 +1456,10 @@ var _SwapClient_serviceDesc = grpc.ServiceDesc{
MethodName: "GetLoopInQuote", MethodName: "GetLoopInQuote",
Handler: _SwapClient_GetLoopInQuote_Handler, Handler: _SwapClient_GetLoopInQuote_Handler,
}, },
{
MethodName: "GetLsatTokens",
Handler: _SwapClient_GetLsatTokens_Handler,
},
}, },
Streams: []grpc.StreamDesc{ Streams: []grpc.StreamDesc{
{ {

@ -9,13 +9,13 @@ It translates gRPC into RESTful JSON APIs.
package looprpc package looprpc
import ( import (
"context"
"io" "io"
"net/http" "net/http"
"github.com/golang/protobuf/proto" "github.com/golang/protobuf/proto"
"github.com/grpc-ecosystem/grpc-gateway/runtime" "github.com/grpc-ecosystem/grpc-gateway/runtime"
"github.com/grpc-ecosystem/grpc-gateway/utilities" "github.com/grpc-ecosystem/grpc-gateway/utilities"
"golang.org/x/net/context"
"google.golang.org/grpc" "google.golang.org/grpc"
"google.golang.org/grpc/codes" "google.golang.org/grpc/codes"
"google.golang.org/grpc/grpclog" "google.golang.org/grpc/grpclog"
@ -32,7 +32,11 @@ func request_SwapClient_LoopOut_0(ctx context.Context, marshaler runtime.Marshal
var protoReq LoopOutRequest var protoReq LoopOutRequest
var metadata runtime.ServerMetadata var metadata runtime.ServerMetadata
if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil { newReader, berr := utilities.IOReaderFactory(req.Body)
if berr != nil {
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
}
if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err) return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
} }
@ -45,7 +49,11 @@ func request_SwapClient_LoopIn_0(ctx context.Context, marshaler runtime.Marshale
var protoReq LoopInRequest var protoReq LoopInRequest
var metadata runtime.ServerMetadata var metadata runtime.ServerMetadata
if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil { newReader, berr := utilities.IOReaderFactory(req.Body)
if berr != nil {
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
}
if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err) return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
} }
@ -142,6 +150,15 @@ func request_SwapClient_GetLoopInQuote_0(ctx context.Context, marshaler runtime.
} }
func request_SwapClient_GetLsatTokens_0(ctx context.Context, marshaler runtime.Marshaler, client SwapClientClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
var protoReq TokensRequest
var metadata runtime.ServerMetadata
msg, err := client.GetLsatTokens(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
return msg, metadata, err
}
// RegisterSwapClientHandlerFromEndpoint is same as RegisterSwapClientHandler but // RegisterSwapClientHandlerFromEndpoint is same as RegisterSwapClientHandler but
// automatically dials to "endpoint" and closes the connection when "ctx" gets done. // automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterSwapClientHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) { func RegisterSwapClientHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {
@ -152,14 +169,14 @@ func RegisterSwapClientHandlerFromEndpoint(ctx context.Context, mux *runtime.Ser
defer func() { defer func() {
if err != nil { if err != nil {
if cerr := conn.Close(); cerr != nil { if cerr := conn.Close(); cerr != nil {
grpclog.Printf("Failed to close conn to %s: %v", endpoint, cerr) grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
} }
return return
} }
go func() { go func() {
<-ctx.Done() <-ctx.Done()
if cerr := conn.Close(); cerr != nil { if cerr := conn.Close(); cerr != nil {
grpclog.Printf("Failed to close conn to %s: %v", endpoint, cerr) grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
} }
}() }()
}() }()
@ -170,20 +187,19 @@ func RegisterSwapClientHandlerFromEndpoint(ctx context.Context, mux *runtime.Ser
// RegisterSwapClientHandler registers the http handlers for service SwapClient to "mux". // RegisterSwapClientHandler registers the http handlers for service SwapClient to "mux".
// The handlers forward requests to the grpc endpoint over "conn". // The handlers forward requests to the grpc endpoint over "conn".
func RegisterSwapClientHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error { func RegisterSwapClientHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error {
client := NewSwapClientClient(conn) return RegisterSwapClientHandlerClient(ctx, mux, NewSwapClientClient(conn))
}
// RegisterSwapClientHandlerClient registers the http handlers for service SwapClient
// to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "SwapClientClient".
// Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "SwapClientClient"
// doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in
// "SwapClientClient" to call the correct interceptors.
func RegisterSwapClientHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SwapClientClient) error {
mux.Handle("POST", pattern_SwapClient_LoopOut_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { mux.Handle("POST", pattern_SwapClient_LoopOut_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
ctx, cancel := context.WithCancel(ctx) ctx, cancel := context.WithCancel(req.Context())
defer cancel() defer cancel()
if cn, ok := w.(http.CloseNotifier); ok {
go func(done <-chan struct{}, closed <-chan bool) {
select {
case <-done:
case <-closed:
cancel()
}
}(ctx.Done(), cn.CloseNotify())
}
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
rctx, err := runtime.AnnotateContext(ctx, mux, req) rctx, err := runtime.AnnotateContext(ctx, mux, req)
if err != nil { if err != nil {
@ -202,17 +218,8 @@ func RegisterSwapClientHandler(ctx context.Context, mux *runtime.ServeMux, conn
}) })
mux.Handle("POST", pattern_SwapClient_LoopIn_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { mux.Handle("POST", pattern_SwapClient_LoopIn_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
ctx, cancel := context.WithCancel(ctx) ctx, cancel := context.WithCancel(req.Context())
defer cancel() defer cancel()
if cn, ok := w.(http.CloseNotifier); ok {
go func(done <-chan struct{}, closed <-chan bool) {
select {
case <-done:
case <-closed:
cancel()
}
}(ctx.Done(), cn.CloseNotify())
}
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
rctx, err := runtime.AnnotateContext(ctx, mux, req) rctx, err := runtime.AnnotateContext(ctx, mux, req)
if err != nil { if err != nil {
@ -231,17 +238,8 @@ func RegisterSwapClientHandler(ctx context.Context, mux *runtime.ServeMux, conn
}) })
mux.Handle("GET", pattern_SwapClient_LoopOutTerms_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { mux.Handle("GET", pattern_SwapClient_LoopOutTerms_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
ctx, cancel := context.WithCancel(ctx) ctx, cancel := context.WithCancel(req.Context())
defer cancel() defer cancel()
if cn, ok := w.(http.CloseNotifier); ok {
go func(done <-chan struct{}, closed <-chan bool) {
select {
case <-done:
case <-closed:
cancel()
}
}(ctx.Done(), cn.CloseNotify())
}
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
rctx, err := runtime.AnnotateContext(ctx, mux, req) rctx, err := runtime.AnnotateContext(ctx, mux, req)
if err != nil { if err != nil {
@ -260,17 +258,8 @@ func RegisterSwapClientHandler(ctx context.Context, mux *runtime.ServeMux, conn
}) })
mux.Handle("GET", pattern_SwapClient_LoopOutQuote_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { mux.Handle("GET", pattern_SwapClient_LoopOutQuote_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
ctx, cancel := context.WithCancel(ctx) ctx, cancel := context.WithCancel(req.Context())
defer cancel() defer cancel()
if cn, ok := w.(http.CloseNotifier); ok {
go func(done <-chan struct{}, closed <-chan bool) {
select {
case <-done:
case <-closed:
cancel()
}
}(ctx.Done(), cn.CloseNotify())
}
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
rctx, err := runtime.AnnotateContext(ctx, mux, req) rctx, err := runtime.AnnotateContext(ctx, mux, req)
if err != nil { if err != nil {
@ -289,17 +278,8 @@ func RegisterSwapClientHandler(ctx context.Context, mux *runtime.ServeMux, conn
}) })
mux.Handle("GET", pattern_SwapClient_GetLoopInTerms_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { mux.Handle("GET", pattern_SwapClient_GetLoopInTerms_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
ctx, cancel := context.WithCancel(ctx) ctx, cancel := context.WithCancel(req.Context())
defer cancel() defer cancel()
if cn, ok := w.(http.CloseNotifier); ok {
go func(done <-chan struct{}, closed <-chan bool) {
select {
case <-done:
case <-closed:
cancel()
}
}(ctx.Done(), cn.CloseNotify())
}
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
rctx, err := runtime.AnnotateContext(ctx, mux, req) rctx, err := runtime.AnnotateContext(ctx, mux, req)
if err != nil { if err != nil {
@ -318,17 +298,8 @@ func RegisterSwapClientHandler(ctx context.Context, mux *runtime.ServeMux, conn
}) })
mux.Handle("GET", pattern_SwapClient_GetLoopInQuote_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { mux.Handle("GET", pattern_SwapClient_GetLoopInQuote_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
ctx, cancel := context.WithCancel(ctx) ctx, cancel := context.WithCancel(req.Context())
defer cancel() defer cancel()
if cn, ok := w.(http.CloseNotifier); ok {
go func(done <-chan struct{}, closed <-chan bool) {
select {
case <-done:
case <-closed:
cancel()
}
}(ctx.Done(), cn.CloseNotify())
}
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
rctx, err := runtime.AnnotateContext(ctx, mux, req) rctx, err := runtime.AnnotateContext(ctx, mux, req)
if err != nil { if err != nil {
@ -346,6 +317,26 @@ func RegisterSwapClientHandler(ctx context.Context, mux *runtime.ServeMux, conn
}) })
mux.Handle("GET", pattern_SwapClient_GetLsatTokens_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_SwapClient_GetLsatTokens_0(rctx, inboundMarshaler, client, req, pathParams)
ctx = runtime.NewServerMetadataContext(ctx, md)
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
forward_SwapClient_GetLsatTokens_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
})
return nil return nil
} }
@ -361,6 +352,8 @@ var (
pattern_SwapClient_GetLoopInTerms_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 2, 3}, []string{"v1", "loop", "in", "terms"}, "")) pattern_SwapClient_GetLoopInTerms_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 2, 3}, []string{"v1", "loop", "in", "terms"}, ""))
pattern_SwapClient_GetLoopInQuote_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 2, 3, 1, 0, 4, 1, 5, 4}, []string{"v1", "loop", "in", "quote", "amt"}, "")) pattern_SwapClient_GetLoopInQuote_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 2, 3, 1, 0, 4, 1, 5, 4}, []string{"v1", "loop", "in", "quote", "amt"}, ""))
pattern_SwapClient_GetLsatTokens_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v1", "lsat", "tokens"}, ""))
) )
var ( var (
@ -375,4 +368,6 @@ var (
forward_SwapClient_GetLoopInTerms_0 = runtime.ForwardResponseMessage forward_SwapClient_GetLoopInTerms_0 = runtime.ForwardResponseMessage
forward_SwapClient_GetLoopInQuote_0 = runtime.ForwardResponseMessage forward_SwapClient_GetLoopInQuote_0 = runtime.ForwardResponseMessage
forward_SwapClient_GetLsatTokens_0 = runtime.ForwardResponseMessage
) )

@ -15,7 +15,7 @@ service SwapClient {
point onwards, progress can be tracked via the SwapStatus stream that is point onwards, progress can be tracked via the SwapStatus stream that is
returned from Monitor(). returned from Monitor().
*/ */
rpc LoopOut(LoopOutRequest) returns (SwapResponse) { rpc LoopOut (LoopOutRequest) returns (SwapResponse) {
option (google.api.http) = { option (google.api.http) = {
post: "/v1/loop/out" post: "/v1/loop/out"
body: "*" body: "*"
@ -28,7 +28,7 @@ service SwapClient {
point onwards, progress can be tracked via the SwapStatus stream point onwards, progress can be tracked via the SwapStatus stream
that is returned from Monitor(). that is returned from Monitor().
*/ */
rpc LoopIn(LoopInRequest) returns (SwapResponse) { rpc LoopIn (LoopInRequest) returns (SwapResponse) {
option (google.api.http) = { option (google.api.http) = {
post: "/v1/loop/in" post: "/v1/loop/in"
body: "*" body: "*"
@ -39,12 +39,12 @@ service SwapClient {
Monitor will return a stream of swap updates for currently active swaps. Monitor will return a stream of swap updates for currently active swaps.
TODO: add MonitorSync version for REST clients. TODO: add MonitorSync version for REST clients.
*/ */
rpc Monitor(MonitorRequest) returns(stream SwapStatus); rpc Monitor (MonitorRequest) returns (stream SwapStatus);
/** loop: `terms` /** loop: `terms`
LoopOutTerms returns the terms that the server enforces for a loop out swap. LoopOutTerms returns the terms that the server enforces for a loop out swap.
*/ */
rpc LoopOutTerms(TermsRequest) returns(TermsResponse) { rpc LoopOutTerms (TermsRequest) returns (TermsResponse) {
option (google.api.http) = { option (google.api.http) = {
get: "/v1/loop/out/terms" get: "/v1/loop/out/terms"
}; };
@ -54,7 +54,7 @@ service SwapClient {
LoopOutQuote returns a quote for a loop out swap with the provided LoopOutQuote returns a quote for a loop out swap with the provided
parameters. parameters.
*/ */
rpc LoopOutQuote(QuoteRequest) returns(QuoteResponse) { rpc LoopOutQuote (QuoteRequest) returns (QuoteResponse) {
option (google.api.http) = { option (google.api.http) = {
get: "/v1/loop/out/quote/{amt}" get: "/v1/loop/out/quote/{amt}"
}; };
@ -63,7 +63,7 @@ service SwapClient {
/** /**
GetTerms returns the terms that the server enforces for swaps. GetTerms returns the terms that the server enforces for swaps.
*/ */
rpc GetLoopInTerms(TermsRequest) returns(TermsResponse) { rpc GetLoopInTerms (TermsRequest) returns (TermsResponse) {
option (google.api.http) = { option (google.api.http) = {
get: "/v1/loop/in/terms" get: "/v1/loop/in/terms"
}; };
@ -72,11 +72,20 @@ service SwapClient {
/** /**
GetQuote returns a quote for a swap with the provided parameters. GetQuote returns a quote for a swap with the provided parameters.
*/ */
rpc GetLoopInQuote(QuoteRequest) returns(QuoteResponse) { rpc GetLoopInQuote (QuoteRequest) returns (QuoteResponse) {
option (google.api.http) = { option (google.api.http) = {
get: "/v1/loop/in/quote/{amt}" get: "/v1/loop/in/quote/{amt}"
}; };
} }
/**
GetLsatTokens returns all LSAT tokens the daemon ever paid for.
*/
rpc GetLsatTokens (TokensRequest) returns (TokensResponse) {
option (google.api.http) = {
get: "/v1/lsat/tokens"
};
}
} }
message LoopOutRequest { message LoopOutRequest {
@ -180,7 +189,7 @@ message LoopInRequest {
max_miner_fee is typically taken from the response of the GetQuote call. max_miner_fee is typically taken from the response of the GetQuote call.
*/ */
int64 max_miner_fee = 3; int64 max_miner_fee = 3;
/** /**
The channel to loop in. If zero, the channel to loop in is selected based The channel to loop in. If zero, the channel to loop in is selected based
on the lowest routing fee for the swap payment from the server. on the lowest routing fee for the swap payment from the server.
@ -209,7 +218,7 @@ message SwapResponse {
string htlc_address = 2; string htlc_address = 2;
} }
message MonitorRequest{ message MonitorRequest {
} }
message SwapStatus { message SwapStatus {
@ -303,10 +312,10 @@ enum SwapState {
*/ */
FAILED = 4; FAILED = 4;
/** /**
INVOICE_SETTLED is reached when the swap invoice in a loop in swap has been INVOICE_SETTLED is reached when the swap invoice in a loop in swap has been
paid, but we are still waiting for the htlc spend to confirm. paid, but we are still waiting for the htlc spend to confirm.
*/ */
INVOICE_SETTLED = 5; INVOICE_SETTLED = 5;
} }
@ -315,7 +324,7 @@ message TermsRequest {
message TermsResponse { message TermsResponse {
reserved 1,2,3,4,7; reserved 1, 2, 3, 4, 7;
/** /**
Minimum swap amount (sat) Minimum swap amount (sat)
@ -376,3 +385,58 @@ message QuoteResponse {
*/ */
int32 cltv_delta = 5; int32 cltv_delta = 5;
} }
message TokensRequest {
}
message TokensResponse {
/**
List of all tokens the daemon knows of, including old/expired tokens.
*/
repeated LsatToken tokens = 1;
}
message LsatToken {
/**
The base macaroon that was baked by the auth server.
*/
bytes base_macaroon = 1;
/**
The payment hash of the payment that was paid to obtain the token.
*/
bytes payment_hash = 2;
/**
The preimage of the payment hash, knowledge of this is proof that the
payment has been paid. If the preimage is set to all zeros, this means the
payment is still pending and the token is not yet fully valid.
*/
bytes payment_preimage = 3;
/**
The amount of millisatoshis that was paid to get the token.
*/
int64 amount_paid_msat = 4;
/**
The amount of millisatoshis paid in routing fee to pay for the token.
*/
int64 routing_fee_paid_msat = 5;
/**
The creation time of the token as UNIX timestamp in seconds.
*/
int64 time_created = 6;
/**
Indicates whether the token is expired or still valid.
*/
bool expired = 7;
/**
Identifying attribute of this token in the store. Currently represents the
file name of the token where it's stored on the file system.
*/
string storage_name = 8;
}

@ -21,7 +21,7 @@
"operationId": "LoopIn", "operationId": "LoopIn",
"responses": { "responses": {
"200": { "200": {
"description": "", "description": "A successful response.",
"schema": { "schema": {
"$ref": "#/definitions/looprpcSwapResponse" "$ref": "#/definitions/looprpcSwapResponse"
} }
@ -48,7 +48,7 @@
"operationId": "GetLoopInQuote", "operationId": "GetLoopInQuote",
"responses": { "responses": {
"200": { "200": {
"description": "", "description": "A successful response.",
"schema": { "schema": {
"$ref": "#/definitions/looprpcQuoteResponse" "$ref": "#/definitions/looprpcQuoteResponse"
} }
@ -57,6 +57,7 @@
"parameters": [ "parameters": [
{ {
"name": "amt", "name": "amt",
"description": "*\nThe amount to swap in satoshis.",
"in": "path", "in": "path",
"required": true, "required": true,
"type": "string", "type": "string",
@ -90,7 +91,7 @@
"operationId": "GetLoopInTerms", "operationId": "GetLoopInTerms",
"responses": { "responses": {
"200": { "200": {
"description": "", "description": "A successful response.",
"schema": { "schema": {
"$ref": "#/definitions/looprpcTermsResponse" "$ref": "#/definitions/looprpcTermsResponse"
} }
@ -107,7 +108,7 @@
"operationId": "LoopOut", "operationId": "LoopOut",
"responses": { "responses": {
"200": { "200": {
"description": "", "description": "A successful response.",
"schema": { "schema": {
"$ref": "#/definitions/looprpcSwapResponse" "$ref": "#/definitions/looprpcSwapResponse"
} }
@ -134,7 +135,7 @@
"operationId": "LoopOutQuote", "operationId": "LoopOutQuote",
"responses": { "responses": {
"200": { "200": {
"description": "", "description": "A successful response.",
"schema": { "schema": {
"$ref": "#/definitions/looprpcQuoteResponse" "$ref": "#/definitions/looprpcQuoteResponse"
} }
@ -143,6 +144,7 @@
"parameters": [ "parameters": [
{ {
"name": "amt", "name": "amt",
"description": "*\nThe amount to swap in satoshis.",
"in": "path", "in": "path",
"required": true, "required": true,
"type": "string", "type": "string",
@ -176,7 +178,7 @@
"operationId": "LoopOutTerms", "operationId": "LoopOutTerms",
"responses": { "responses": {
"200": { "200": {
"description": "", "description": "A successful response.",
"schema": { "schema": {
"$ref": "#/definitions/looprpcTermsResponse" "$ref": "#/definitions/looprpcTermsResponse"
} }
@ -186,6 +188,23 @@
"SwapClient" "SwapClient"
] ]
} }
},
"/v1/lsat/tokens": {
"get": {
"summary": "*\nGetLsatTokens returns all LSAT tokens the daemon ever paid for.",
"operationId": "GetLsatTokens",
"responses": {
"200": {
"description": "A successful response.",
"schema": {
"$ref": "#/definitions/looprpcTokensResponse"
}
}
},
"tags": [
"SwapClient"
]
}
} }
}, },
"definitions": { "definitions": {
@ -273,6 +292,50 @@
} }
} }
}, },
"looprpcLsatToken": {
"type": "object",
"properties": {
"base_macaroon": {
"type": "string",
"format": "byte",
"description": "*\nThe base macaroon that was baked by the auth server."
},
"payment_hash": {
"type": "string",
"format": "byte",
"description": "*\nThe payment hash of the payment that was paid to obtain the token."
},
"payment_preimage": {
"type": "string",
"format": "byte",
"description": "*\nThe preimage of the payment hash, knowledge of this is proof that the\npayment has been paid. If the preimage is set to all zeros, this means the\npayment is still pending and the token is not yet fully valid."
},
"amount_paid_msat": {
"type": "string",
"format": "int64",
"description": "*\nThe amount of millisatoshis that was paid to get the token."
},
"routing_fee_paid_msat": {
"type": "string",
"format": "int64",
"description": "*\nThe amount of millisatoshis paid in routing fee to pay for the token."
},
"time_created": {
"type": "string",
"format": "int64",
"description": "*\nThe creation time of the token as UNIX timestamp in seconds."
},
"expired": {
"type": "boolean",
"format": "boolean",
"description": "*\nIndicates whether the token is expired or still valid."
},
"storage_name": {
"type": "string",
"description": "*\nIdentifying attribute of this token in the store. Currently represents the\nfile name of the token where it's stored on the file system."
}
}
},
"looprpcQuoteResponse": { "looprpcQuoteResponse": {
"type": "object", "type": "object",
"properties": { "properties": {
@ -403,6 +466,69 @@
"title": "*\nMaximum swap amount (sat)" "title": "*\nMaximum swap amount (sat)"
} }
} }
},
"looprpcTokensResponse": {
"type": "object",
"properties": {
"tokens": {
"type": "array",
"items": {
"$ref": "#/definitions/looprpcLsatToken"
},
"description": "*\nList of all tokens the daemon knows of, including old/expired tokens."
}
}
},
"protobufAny": {
"type": "object",
"properties": {
"type_url": {
"type": "string"
},
"value": {
"type": "string",
"format": "byte"
}
}
},
"runtimeStreamError": {
"type": "object",
"properties": {
"grpc_code": {
"type": "integer",
"format": "int32"
},
"http_code": {
"type": "integer",
"format": "int32"
},
"message": {
"type": "string"
},
"http_status": {
"type": "string"
},
"details": {
"type": "array",
"items": {
"$ref": "#/definitions/protobufAny"
}
}
}
}
},
"x-stream-definitions": {
"looprpcSwapStatus": {
"type": "object",
"properties": {
"result": {
"$ref": "#/definitions/looprpcSwapStatus"
},
"error": {
"$ref": "#/definitions/runtimeStreamError"
}
},
"title": "Stream result of looprpcSwapStatus"
} }
} }
} }

Loading…
Cancel
Save