SubscribeSidecar
Source: auctioneerrpc/auctioneer.proto
gRPC
info
This is a bidirectional-streaming RPC
rpc SubscribeSidecar (stream ClientAuctionMessage) returns (stream ServerAuctionMessage);
Code Samples
- gRPC
- Shell
- Javascript
- Python
const fs = require('fs');
const grpc = require('@grpc/grpc-js');
const protoLoader = require('@grpc/proto-loader');
const GRPC_HOST = 'localhost:12010'
const MACAROON_PATH = 'POOL_DIR/regtest/pool.macaroon'
const TLS_PATH = 'POOL_DIR/tls.cert'
const loaderOptions = {
keepCase: true,
longs: String,
enums: String,
defaults: true,
oneofs: true,
};
const packageDefinition = protoLoader.loadSync('auctioneerrpc/auctioneer.proto', loaderOptions);
const poolrpc = grpc.loadPackageDefinition(packageDefinition).poolrpc;
process.env.GRPC_SSL_CIPHER_SUITES = 'HIGH+ECDSA';
const tlsCert = fs.readFileSync(TLS_PATH);
const sslCreds = grpc.credentials.createSsl(tlsCert);
const macaroon = fs.readFileSync(MACAROON_PATH).toString('hex');
const macaroonCreds = grpc.credentials.createFromMetadataGenerator(function(args, callback) {
let metadata = new grpc.Metadata();
metadata.add('macaroon', macaroon);
callback(null, metadata);
});
let creds = grpc.credentials.combineChannelCredentials(sslCreds, macaroonCreds);
let client = new poolrpc.ChannelAuctioneer(GRPC_HOST, creds);
let request = {
commit: <AccountCommitment>,
subscribe: <AccountSubscription>,
accept: <OrderMatchAccept>,
reject: <OrderMatchReject>,
sign: <OrderMatchSign>,
recover: <AccountRecovery>,
};
let call = client.subscribeSidecar({});
call.on('data', function(response) {
// A response was received from the server.
console.log(response);
});
call.on('status', function(status) {
// The current status of the stream.
});
call.on('end', function() {
// The server has closed the stream.
});
call.write(request);
// Console output:
// {
// "challenge": <ServerChallenge>,
// "success": <SubscribeSuccess>,
// "error": <SubscribeError>,
// "prepare": <OrderMatchPrepare>,
// "sign": <OrderMatchSignBegin>,
// "finalize": <OrderMatchFinalize>,
// "account": <AuctionAccount>,
// }
import codecs, grpc, os
# Generate the following 2 modules by compiling the auctioneerrpc/auctioneer.proto with the grpcio-tools.
# See https://github.com/lightningnetwork/lnd/blob/master/docs/grpc/python.md for instructions.
import auctioneer_pb2 as poolrpc, auctioneer_pb2_grpc as auctioneerstub
GRPC_HOST = 'localhost:12010'
MACAROON_PATH = 'POOL_DIR/regtest/pool.macaroon'
TLS_PATH = 'POOL_DIR/tls.cert'
# create macaroon credentials
macaroon = codecs.encode(open(MACAROON_PATH, 'rb').read(), 'hex')
def metadata_callback(context, callback):
callback([('macaroon', macaroon)], None)
auth_creds = grpc.metadata_call_credentials(metadata_callback)
# create SSL credentials
os.environ['GRPC_SSL_CIPHER_SUITES'] = 'HIGH+ECDSA'
cert = open(TLS_PATH, 'rb').read()
ssl_creds = grpc.ssl_channel_credentials(cert)
# combine macaroon and SSL credentials
combined_creds = grpc.composite_channel_credentials(ssl_creds, auth_creds)
# make the request
channel = grpc.secure_channel(GRPC_HOST, combined_creds)
stub = auctioneerstub.ChannelAuctioneerStub(channel)
# Define a generator that returns an Iterable of ClientAuctionMessage objects.
def request_generator():
# Initialization code here.
while True:
# Parameters here can be set as arguments to the generator.
request = poolrpc.ClientAuctionMessage(
commit=<AccountCommitment>,
subscribe=<AccountSubscription>,
accept=<OrderMatchAccept>,
reject=<OrderMatchReject>,
sign=<OrderMatchSign>,
recover=<AccountRecovery>,
)
yield request
# Do things between iterations here.
request_iterable = request_generator()
for response in stub.SubscribeSidecar(request_iterable):
print(response)
# {
# "challenge": <ServerChallenge>,
# "success": <SubscribeSuccess>,
# "error": <SubscribeError>,
# "prepare": <OrderMatchPrepare>,
# "sign": <OrderMatchSignBegin>,
# "finalize": <OrderMatchFinalize>,
# "account": <AuctionAccount>,
# }
# There is no CLI command for this RPC
Messages
poolrpc.ClientAuctionMessage
Source: auctioneerrpc/auctioneer.proto
Field | gRPC Type | REST Type | REST Placement |
---|---|---|---|
commit | AccountCommitment | unknown | unknown |
subscribe | AccountSubscription | unknown | unknown |
accept | OrderMatchAccept | unknown | unknown |
reject | OrderMatchReject | unknown | unknown |
sign | OrderMatchSign | unknown | unknown |
recover | AccountRecovery | unknown | unknown |
poolrpc.ServerAuctionMessage
Source: auctioneerrpc/auctioneer.proto
Field | gRPC Type | REST Type |
---|---|---|
challenge | ServerChallenge | unknown |
success | SubscribeSuccess | unknown |
error | SubscribeError | unknown |
prepare | OrderMatchPrepare | unknown |
sign | OrderMatchSignBegin | unknown |
finalize | OrderMatchFinalize | unknown |
account | AuctionAccount | unknown |
Nested Messages
poolrpc.AccountCommitment
Field | gRPC Type | REST Type |
---|---|---|
commit_hash | bytes | unknown |
batch_version | uint32 | unknown |
poolrpc.AccountDiff
Field | gRPC Type | REST Type |
---|---|---|
ending_balance | uint64 | unknown |
ending_state | AccountState | unknown |
outpoint_index | int32 | unknown |
trader_key | bytes | unknown |
new_expiry | uint32 | unknown |
new_version | uint32 | unknown |
poolrpc.AccountRecovery
Field | gRPC Type | REST Type |
---|---|---|
trader_key | bytes | unknown |
poolrpc.AccountSubscription
Field | gRPC Type | REST Type |
---|---|---|
trader_key | bytes | unknown |
commit_nonce | bytes | unknown |
auth_sig | bytes | unknown |
poolrpc.AuctionAccount
Field | gRPC Type | REST Type |
---|---|---|
value | uint64 | unknown |
expiry | uint32 | unknown |
trader_key | bytes | unknown |
auctioneer_key | bytes | unknown |
batch_key | bytes | unknown |
state | AuctionAccountState | unknown |
height_hint | uint32 | unknown |
outpoint | OutPoint | unknown |
latest_tx | bytes | unknown |
version | uint32 | unknown |
poolrpc.ChannelInfo
Field | gRPC Type | REST Type |
---|---|---|
type | ChannelType | unknown |
local_node_key | bytes | unknown |
remote_node_key | bytes | unknown |
local_payment_base_point | bytes | unknown |
remote_payment_base_point | bytes | unknown |
poolrpc.ExecutionFee
Field | gRPC Type | REST Type |
---|---|---|
base_fee | uint64 | string |
fee_rate | uint64 | string |
poolrpc.MatchedAsk
Field | gRPC Type | REST Type |
---|---|---|
ask | ServerAsk | unknown |
units_filled | uint32 | unknown |
poolrpc.MatchedBid
Field | gRPC Type | REST Type |
---|---|---|
bid | ServerBid | unknown |
units_filled | uint32 | unknown |
poolrpc.MatchedMarket
Field | gRPC Type | REST Type |
---|---|---|
matched_orders | MatchedOrdersEntry[] | unknown |
clearing_price_rate | uint32 | unknown |
poolrpc.MatchedMarket.MatchedOrdersEntry
Field | gRPC Type | REST Type |
---|---|---|
key | string | unknown |
value | MatchedOrder | unknown |
poolrpc.MatchedOrder
Field | gRPC Type | REST Type |
---|---|---|
matched_bids | MatchedBid[] | unknown |
matched_asks | MatchedAsk[] | unknown |
poolrpc.NodeAddress
Field | gRPC Type | REST Type |
---|---|---|
network | string | unknown |
addr | string | unknown |
poolrpc.OrderMatchAccept
Field | gRPC Type | REST Type |
---|---|---|
batch_id | bytes | unknown |
poolrpc.OrderMatchFinalize
Field | gRPC Type | REST Type |
---|---|---|
batch_id | bytes | unknown |
batch_txid | bytes | unknown |
poolrpc.OrderMatchPrepare
Field | gRPC Type | REST Type |
---|---|---|
matched_orders deprecated | MatchedOrdersEntry[] | unknown |
clearing_price_rate deprecated | uint32 | unknown |
charged_accounts | AccountDiff[] | unknown |
execution_fee | ExecutionFee | unknown |
batch_transaction | bytes | unknown |
fee_rate_sat_per_kw | uint64 | unknown |
fee_rebate_sat | uint64 | unknown |
batch_id | bytes | unknown |
batch_version | uint32 | unknown |
matched_markets | MatchedMarketsEntry[] | unknown |
batch_height_hint | uint32 | unknown |
poolrpc.OrderMatchPrepare.MatchedMarketsEntry
Field | gRPC Type | REST Type |
---|---|---|
key | uint32 | unknown |
value | MatchedMarket | unknown |
poolrpc.OrderMatchPrepare.MatchedOrdersEntry
Field | gRPC Type | REST Type |
---|---|---|
key | string | unknown |
value | MatchedOrder | unknown |
poolrpc.OrderMatchReject
Field | gRPC Type | REST Type |
---|---|---|
batch_id | bytes | unknown |
reason | string | unknown |
reason_code | RejectReason | unknown |
rejected_orders | RejectedOrdersEntry[] | unknown |
poolrpc.OrderMatchReject.RejectedOrdersEntry
Field | gRPC Type | REST Type |
---|---|---|
key | string | unknown |
value | OrderReject | unknown |
poolrpc.OrderMatchSign
Field | gRPC Type | REST Type |
---|---|---|
batch_id | bytes | unknown |
account_sigs | AccountSigsEntry[] | unknown |
channel_infos | ChannelInfosEntry[] | unknown |
trader_nonces | TraderNoncesEntry[] | unknown |
poolrpc.OrderMatchSign.AccountSigsEntry
Field | gRPC Type | REST Type |
---|---|---|
key | string | unknown |
value | bytes | unknown |
poolrpc.OrderMatchSign.ChannelInfosEntry
Field | gRPC Type | REST Type |
---|---|---|
key | string | unknown |
value | ChannelInfo | unknown |
poolrpc.OrderMatchSign.TraderNoncesEntry
Field | gRPC Type | REST Type |
---|---|---|
key | string | unknown |
value | bytes | unknown |
poolrpc.OrderMatchSignBegin
Field | gRPC Type | REST Type |
---|---|---|
batch_id | bytes | unknown |
server_nonces | ServerNoncesEntry[] | unknown |
prev_outputs | TxOut[] | unknown |
poolrpc.OrderMatchSignBegin.ServerNoncesEntry
Field | gRPC Type | REST Type |
---|---|---|
key | string | unknown |
value | bytes | unknown |
poolrpc.OrderReject
Field | gRPC Type | REST Type |
---|---|---|
reason | string | unknown |
reason_code | OrderRejectReason | unknown |
poolrpc.OutPoint
Field | gRPC Type | REST Type |
---|---|---|
txid | bytes | string |
output_index | uint32 | integer |
poolrpc.ServerAsk
Field | gRPC Type | REST Type |
---|---|---|
details | ServerOrder | unknown |
lease_duration_blocks | uint32 | unknown |
version | uint32 | unknown |
announcement_constraints | ChannelAnnouncementConstraints | unknown |
confirmation_constraints | ChannelConfirmationConstraints | unknown |
poolrpc.ServerBid
Field | gRPC Type | REST Type |
---|---|---|
details | ServerOrder | unknown |
lease_duration_blocks | uint32 | unknown |
version | uint32 | unknown |
min_node_tier | NodeTier | unknown |
self_chan_balance | uint64 | unknown |
is_sidecar_channel | bool | unknown |
unannounced_channel | bool | unknown |
zero_conf_channel | bool | unknown |
poolrpc.ServerChallenge
Field | gRPC Type | REST Type |
---|---|---|
challenge | bytes | unknown |
commit_hash | bytes | unknown |
poolrpc.ServerOrder
Field | gRPC Type | REST Type |
---|---|---|
trader_key | bytes | unknown |
rate_fixed | uint32 | unknown |
amt | uint64 | unknown |
min_chan_amt | uint64 | unknown |
order_nonce | bytes | unknown |
order_sig | bytes | unknown |
multi_sig_key | bytes | unknown |
node_pub | bytes | unknown |
node_addr | NodeAddress[] | unknown |
channel_type | OrderChannelType | unknown |
max_batch_fee_rate_sat_per_kw | uint64 | unknown |
allowed_node_ids | bytes[] | unknown |
not_allowed_node_ids | bytes[] | unknown |
auction_type | AuctionType | unknown |
is_public | bool | unknown |
poolrpc.SubscribeError
Field | gRPC Type | REST Type |
---|---|---|
error | string | unknown |
error_code | Error | unknown |
trader_key | bytes | unknown |
account_reservation | AuctionAccount | unknown |
poolrpc.SubscribeSuccess
Field | gRPC Type | REST Type |
---|---|---|
trader_key | bytes | unknown |
poolrpc.TxOut
Field | gRPC Type | REST Type |
---|---|---|
value | uint64 | unknown |
pk_script | bytes | unknown |
Enums
poolrpc.AccountDiff.AccountState
Name | Number |
---|---|
OUTPUT_RECREATED | 0 |
OUTPUT_DUST_EXTENDED_OFFCHAIN | 1 |
OUTPUT_DUST_ADDED_TO_FEES | 2 |
OUTPUT_FULLY_SPENT | 3 |
poolrpc.AuctionAccountState
Name | Number |
---|---|
STATE_PENDING_OPEN | 0 |
STATE_OPEN | 1 |
STATE_EXPIRED | 2 |
STATE_PENDING_UPDATE | 3 |
STATE_CLOSED | 4 |
STATE_PENDING_BATCH | 5 |
STATE_EXPIRED_PENDING_UPDATE | 6 |
poolrpc.AuctionType
Name | Number |
---|---|
AUCTION_TYPE_BTC_INBOUND_LIQUIDITY | 0 |
AUCTION_TYPE_BTC_OUTBOUND_LIQUIDITY | 1 |
poolrpc.ChannelAnnouncementConstraints
Name | Number |
---|---|
ANNOUNCEMENT_NO_PREFERENCE | 0 |
ONLY_ANNOUNCED | 1 |
ONLY_UNANNOUNCED | 2 |
poolrpc.ChannelConfirmationConstraints
Name | Number |
---|---|
CONFIRMATION_NO_PREFERENCE | 0 |
ONLY_CONFIRMED | 1 |
ONLY_ZEROCONF | 2 |
poolrpc.ChannelType
Name | Number |
---|---|
TWEAKLESS | 0 |
ANCHORS | 1 |
SCRIPT_ENFORCED_LEASE | 2 |
SIMPLE_TAPROOT | 3 |
poolrpc.NodeTier
Name | Number |
---|---|
TIER_DEFAULT | 0 |
TIER_0 | 1 |
TIER_1 | 2 |
poolrpc.OrderChannelType
Name | Number |
---|---|
ORDER_CHANNEL_TYPE_UNKNOWN | 0 |
ORDER_CHANNEL_TYPE_PEER_DEPENDENT | 1 |
ORDER_CHANNEL_TYPE_SCRIPT_ENFORCED | 2 |
ORDER_CHANNEL_TYPE_SIMPLE_TAPROOT | 3 |
poolrpc.OrderMatchReject.RejectReason
Name | Number |
---|---|
UNKNOWN | 0 |
SERVER_MISBEHAVIOR | 1 |
BATCH_VERSION_MISMATCH | 2 |
PARTIAL_REJECT | 3 |
poolrpc.OrderReject.OrderRejectReason
Name | Number |
---|---|
DUPLICATE_PEER | 0 |
CHANNEL_FUNDING_FAILED | 1 |
poolrpc.SubscribeError.Error
Name | Number |
---|---|
UNKNOWN | 0 |
SERVER_SHUTDOWN | 1 |
ACCOUNT_DOES_NOT_EXIST | 2 |
INCOMPLETE_ACCOUNT_RESERVATION | 3 |