wip
This commit is contained in:
hatim boufnichel
parent
4f550a937f
commit
f39025df53
39 changed files with 7571 additions and 1892 deletions
|
|
@ -1,9 +1,10 @@
|
|||
// @generated by protobuf-ts 2.5.0 with parameter long_type_string
|
||||
// @generated by protobuf-ts 2.5.0
|
||||
// @generated from protobuf file "invoices.proto" (package "invoicesrpc", syntax proto3)
|
||||
// tslint:disable
|
||||
import type { RpcTransport } from "@protobuf-ts/runtime-rpc";
|
||||
import type { ServiceInfo } from "@protobuf-ts/runtime-rpc";
|
||||
import { Invoices } from "./invoices";
|
||||
import type { LookupInvoiceMsg } from "./invoices";
|
||||
import type { SettleInvoiceResp } from "./invoices";
|
||||
import type { SettleInvoiceMsg } from "./invoices";
|
||||
import type { AddHoldInvoiceResp } from "./invoices";
|
||||
|
|
@ -12,7 +13,7 @@ import type { CancelInvoiceResp } from "./invoices";
|
|||
import type { CancelInvoiceMsg } from "./invoices";
|
||||
import type { UnaryCall } from "@protobuf-ts/runtime-rpc";
|
||||
import { stackIntercept } from "@protobuf-ts/runtime-rpc";
|
||||
import type { Invoice } from "./rpc";
|
||||
import type { Invoice } from "./lightning";
|
||||
import type { SubscribeSingleInvoiceRequest } from "./invoices";
|
||||
import type { ServerStreamingCall } from "@protobuf-ts/runtime-rpc";
|
||||
import type { RpcOptions } from "@protobuf-ts/runtime-rpc";
|
||||
|
|
@ -57,6 +58,14 @@ export interface IInvoicesClient {
|
|||
* @generated from protobuf rpc: SettleInvoice(invoicesrpc.SettleInvoiceMsg) returns (invoicesrpc.SettleInvoiceResp);
|
||||
*/
|
||||
settleInvoice(input: SettleInvoiceMsg, options?: RpcOptions): UnaryCall<SettleInvoiceMsg, SettleInvoiceResp>;
|
||||
/**
|
||||
*
|
||||
* LookupInvoiceV2 attempts to look up at invoice. An invoice can be refrenced
|
||||
* using either its payment hash, payment address, or set ID.
|
||||
*
|
||||
* @generated from protobuf rpc: LookupInvoiceV2(invoicesrpc.LookupInvoiceMsg) returns (lnrpc.Invoice);
|
||||
*/
|
||||
lookupInvoiceV2(input: LookupInvoiceMsg, options?: RpcOptions): UnaryCall<LookupInvoiceMsg, Invoice>;
|
||||
}
|
||||
/**
|
||||
* Invoices is a service that can be used to create, accept, settle and cancel
|
||||
|
|
@ -116,4 +125,15 @@ export class InvoicesClient implements IInvoicesClient, ServiceInfo {
|
|||
const method = this.methods[3], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<SettleInvoiceMsg, SettleInvoiceResp>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
*
|
||||
* LookupInvoiceV2 attempts to look up at invoice. An invoice can be refrenced
|
||||
* using either its payment hash, payment address, or set ID.
|
||||
*
|
||||
* @generated from protobuf rpc: LookupInvoiceV2(invoicesrpc.LookupInvoiceMsg) returns (lnrpc.Invoice);
|
||||
*/
|
||||
lookupInvoiceV2(input: LookupInvoiceMsg, options?: RpcOptions): UnaryCall<LookupInvoiceMsg, Invoice> {
|
||||
const method = this.methods[4], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<LookupInvoiceMsg, Invoice>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,7 +1,7 @@
|
|||
// @generated by protobuf-ts 2.5.0 with parameter long_type_string
|
||||
// @generated by protobuf-ts 2.5.0
|
||||
// @generated from protobuf file "invoices.proto" (package "invoicesrpc", syntax proto3)
|
||||
// tslint:disable
|
||||
import { Invoice } from "./rpc";
|
||||
import { Invoice } from "./lightning";
|
||||
import { ServiceType } from "@protobuf-ts/runtime-rpc";
|
||||
import type { BinaryWriteOptions } from "@protobuf-ts/runtime";
|
||||
import type { IBinaryWriter } from "@protobuf-ts/runtime";
|
||||
|
|
@ -13,13 +13,14 @@ import type { PartialMessage } from "@protobuf-ts/runtime";
|
|||
import { reflectionMergePartial } from "@protobuf-ts/runtime";
|
||||
import { MESSAGE_TYPE } from "@protobuf-ts/runtime";
|
||||
import { MessageType } from "@protobuf-ts/runtime";
|
||||
import { RouteHint } from "./rpc";
|
||||
import { RouteHint } from "./lightning";
|
||||
/**
|
||||
* @generated from protobuf message invoicesrpc.CancelInvoiceMsg
|
||||
*/
|
||||
export interface CancelInvoiceMsg {
|
||||
/**
|
||||
* Hash corresponding to the (hold) invoice to cancel.
|
||||
* Hash corresponding to the (hold) invoice to cancel. When using
|
||||
* REST, this field must be encoded as base64.
|
||||
*
|
||||
* @generated from protobuf field: bytes payment_hash = 1;
|
||||
*/
|
||||
|
|
@ -58,7 +59,7 @@ export interface AddHoldInvoiceRequest {
|
|||
*
|
||||
* @generated from protobuf field: int64 value = 3;
|
||||
*/
|
||||
value: string;
|
||||
value: bigint;
|
||||
/**
|
||||
*
|
||||
* The value of this invoice in millisatoshis
|
||||
|
|
@ -67,7 +68,7 @@ export interface AddHoldInvoiceRequest {
|
|||
*
|
||||
* @generated from protobuf field: int64 value_msat = 10;
|
||||
*/
|
||||
valueMsat: string;
|
||||
valueMsat: bigint;
|
||||
/**
|
||||
*
|
||||
* Hash (SHA-256) of a description of the payment. Used if the description of
|
||||
|
|
@ -82,7 +83,7 @@ export interface AddHoldInvoiceRequest {
|
|||
*
|
||||
* @generated from protobuf field: int64 expiry = 5;
|
||||
*/
|
||||
expiry: string;
|
||||
expiry: bigint;
|
||||
/**
|
||||
* Fallback on-chain address.
|
||||
*
|
||||
|
|
@ -94,7 +95,7 @@ export interface AddHoldInvoiceRequest {
|
|||
*
|
||||
* @generated from protobuf field: uint64 cltv_expiry = 7;
|
||||
*/
|
||||
cltvExpiry: string;
|
||||
cltvExpiry: bigint;
|
||||
/**
|
||||
*
|
||||
* Route hints that can each be individually used to assist in reaching the
|
||||
|
|
@ -116,13 +117,32 @@ export interface AddHoldInvoiceRequest {
|
|||
export interface AddHoldInvoiceResp {
|
||||
/**
|
||||
*
|
||||
* A bare-bones invoice for a payment within the Lightning Network. With the
|
||||
* A bare-bones invoice for a payment within the Lightning Network. With the
|
||||
* details of the invoice, the sender has all the data necessary to send a
|
||||
* payment to the recipient.
|
||||
*
|
||||
* @generated from protobuf field: string payment_request = 1;
|
||||
*/
|
||||
paymentRequest: string;
|
||||
/**
|
||||
*
|
||||
* The "add" index of this invoice. Each newly created invoice will increment
|
||||
* this index making it monotonically increasing. Callers to the
|
||||
* SubscribeInvoices call can use this to instantly get notified of all added
|
||||
* invoices with an add_index greater than this one.
|
||||
*
|
||||
* @generated from protobuf field: uint64 add_index = 2;
|
||||
*/
|
||||
addIndex: bigint;
|
||||
/**
|
||||
*
|
||||
* The payment address of the generated invoice. This value should be used
|
||||
* in all payments for this invoice as we require it for end to end
|
||||
* security.
|
||||
*
|
||||
* @generated from protobuf field: bytes payment_addr = 3;
|
||||
*/
|
||||
paymentAddr: Uint8Array;
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf message invoicesrpc.SettleInvoiceMsg
|
||||
|
|
@ -146,12 +166,77 @@ export interface SettleInvoiceResp {
|
|||
*/
|
||||
export interface SubscribeSingleInvoiceRequest {
|
||||
/**
|
||||
* Hash corresponding to the (hold) invoice to subscribe to.
|
||||
* Hash corresponding to the (hold) invoice to subscribe to. When using
|
||||
* REST, this field must be encoded as base64url.
|
||||
*
|
||||
* @generated from protobuf field: bytes r_hash = 2;
|
||||
*/
|
||||
rHash: Uint8Array;
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf message invoicesrpc.LookupInvoiceMsg
|
||||
*/
|
||||
export interface LookupInvoiceMsg {
|
||||
/**
|
||||
* @generated from protobuf oneof: invoice_ref
|
||||
*/
|
||||
invoiceRef: {
|
||||
oneofKind: "paymentHash";
|
||||
/**
|
||||
* When using REST, this field must be encoded as base64.
|
||||
*
|
||||
* @generated from protobuf field: bytes payment_hash = 1;
|
||||
*/
|
||||
paymentHash: Uint8Array;
|
||||
} | {
|
||||
oneofKind: "paymentAddr";
|
||||
/**
|
||||
* @generated from protobuf field: bytes payment_addr = 2;
|
||||
*/
|
||||
paymentAddr: Uint8Array;
|
||||
} | {
|
||||
oneofKind: "setId";
|
||||
/**
|
||||
* @generated from protobuf field: bytes set_id = 3;
|
||||
*/
|
||||
setId: Uint8Array;
|
||||
} | {
|
||||
oneofKind: undefined;
|
||||
};
|
||||
/**
|
||||
* @generated from protobuf field: invoicesrpc.LookupModifier lookup_modifier = 4;
|
||||
*/
|
||||
lookupModifier: LookupModifier;
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf enum invoicesrpc.LookupModifier
|
||||
*/
|
||||
export enum LookupModifier {
|
||||
/**
|
||||
* The default look up modifier, no look up behavior is changed.
|
||||
*
|
||||
* @generated from protobuf enum value: DEFAULT = 0;
|
||||
*/
|
||||
DEFAULT = 0,
|
||||
/**
|
||||
*
|
||||
* Indicates that when a look up is done based on a set_id, then only that set
|
||||
* of HTLCs related to that set ID should be returned.
|
||||
*
|
||||
* @generated from protobuf enum value: HTLC_SET_ONLY = 1;
|
||||
*/
|
||||
HTLC_SET_ONLY = 1,
|
||||
/**
|
||||
*
|
||||
* Indicates that when a look up is done using a payment_addr, then no HTLCs
|
||||
* related to the payment_addr should be returned. This is useful when one
|
||||
* wants to be able to obtain the set of associated setIDs with a given
|
||||
* invoice, then look up the sub-invoices "projected" by that set ID.
|
||||
*
|
||||
* @generated from protobuf enum value: HTLC_SET_BLANK = 2;
|
||||
*/
|
||||
HTLC_SET_BLANK = 2
|
||||
}
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class CancelInvoiceMsg$Type extends MessageType<CancelInvoiceMsg> {
|
||||
constructor() {
|
||||
|
|
@ -231,18 +316,18 @@ class AddHoldInvoiceRequest$Type extends MessageType<AddHoldInvoiceRequest> {
|
|||
super("invoicesrpc.AddHoldInvoiceRequest", [
|
||||
{ no: 1, name: "memo", kind: "scalar", T: 9 /*ScalarType.STRING*/ },
|
||||
{ no: 2, name: "hash", kind: "scalar", T: 12 /*ScalarType.BYTES*/ },
|
||||
{ no: 3, name: "value", kind: "scalar", T: 3 /*ScalarType.INT64*/ },
|
||||
{ no: 10, name: "value_msat", kind: "scalar", T: 3 /*ScalarType.INT64*/ },
|
||||
{ no: 3, name: "value", kind: "scalar", T: 3 /*ScalarType.INT64*/, L: 0 /*LongType.BIGINT*/ },
|
||||
{ no: 10, name: "value_msat", kind: "scalar", T: 3 /*ScalarType.INT64*/, L: 0 /*LongType.BIGINT*/ },
|
||||
{ no: 4, name: "description_hash", kind: "scalar", T: 12 /*ScalarType.BYTES*/ },
|
||||
{ no: 5, name: "expiry", kind: "scalar", T: 3 /*ScalarType.INT64*/ },
|
||||
{ no: 5, name: "expiry", kind: "scalar", T: 3 /*ScalarType.INT64*/, L: 0 /*LongType.BIGINT*/ },
|
||||
{ no: 6, name: "fallback_addr", kind: "scalar", T: 9 /*ScalarType.STRING*/ },
|
||||
{ no: 7, name: "cltv_expiry", kind: "scalar", T: 4 /*ScalarType.UINT64*/ },
|
||||
{ no: 7, name: "cltv_expiry", kind: "scalar", T: 4 /*ScalarType.UINT64*/, L: 0 /*LongType.BIGINT*/ },
|
||||
{ no: 8, name: "route_hints", kind: "message", repeat: 1 /*RepeatType.PACKED*/, T: () => RouteHint },
|
||||
{ no: 9, name: "private", kind: "scalar", T: 8 /*ScalarType.BOOL*/ }
|
||||
]);
|
||||
}
|
||||
create(value?: PartialMessage<AddHoldInvoiceRequest>): AddHoldInvoiceRequest {
|
||||
const message = { memo: "", hash: new Uint8Array(0), value: "0", valueMsat: "0", descriptionHash: new Uint8Array(0), expiry: "0", fallbackAddr: "", cltvExpiry: "0", routeHints: [], private: false };
|
||||
const message = { memo: "", hash: new Uint8Array(0), value: 0n, valueMsat: 0n, descriptionHash: new Uint8Array(0), expiry: 0n, fallbackAddr: "", cltvExpiry: 0n, routeHints: [], private: false };
|
||||
globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this });
|
||||
if (value !== undefined)
|
||||
reflectionMergePartial<AddHoldInvoiceRequest>(this, message, value);
|
||||
|
|
@ -260,22 +345,22 @@ class AddHoldInvoiceRequest$Type extends MessageType<AddHoldInvoiceRequest> {
|
|||
message.hash = reader.bytes();
|
||||
break;
|
||||
case /* int64 value */ 3:
|
||||
message.value = reader.int64().toString();
|
||||
message.value = reader.int64().toBigInt();
|
||||
break;
|
||||
case /* int64 value_msat */ 10:
|
||||
message.valueMsat = reader.int64().toString();
|
||||
message.valueMsat = reader.int64().toBigInt();
|
||||
break;
|
||||
case /* bytes description_hash */ 4:
|
||||
message.descriptionHash = reader.bytes();
|
||||
break;
|
||||
case /* int64 expiry */ 5:
|
||||
message.expiry = reader.int64().toString();
|
||||
message.expiry = reader.int64().toBigInt();
|
||||
break;
|
||||
case /* string fallback_addr */ 6:
|
||||
message.fallbackAddr = reader.string();
|
||||
break;
|
||||
case /* uint64 cltv_expiry */ 7:
|
||||
message.cltvExpiry = reader.uint64().toString();
|
||||
message.cltvExpiry = reader.uint64().toBigInt();
|
||||
break;
|
||||
case /* repeated lnrpc.RouteHint route_hints */ 8:
|
||||
message.routeHints.push(RouteHint.internalBinaryRead(reader, reader.uint32(), options));
|
||||
|
|
@ -302,22 +387,22 @@ class AddHoldInvoiceRequest$Type extends MessageType<AddHoldInvoiceRequest> {
|
|||
if (message.hash.length)
|
||||
writer.tag(2, WireType.LengthDelimited).bytes(message.hash);
|
||||
/* int64 value = 3; */
|
||||
if (message.value !== "0")
|
||||
if (message.value !== 0n)
|
||||
writer.tag(3, WireType.Varint).int64(message.value);
|
||||
/* int64 value_msat = 10; */
|
||||
if (message.valueMsat !== "0")
|
||||
if (message.valueMsat !== 0n)
|
||||
writer.tag(10, WireType.Varint).int64(message.valueMsat);
|
||||
/* bytes description_hash = 4; */
|
||||
if (message.descriptionHash.length)
|
||||
writer.tag(4, WireType.LengthDelimited).bytes(message.descriptionHash);
|
||||
/* int64 expiry = 5; */
|
||||
if (message.expiry !== "0")
|
||||
if (message.expiry !== 0n)
|
||||
writer.tag(5, WireType.Varint).int64(message.expiry);
|
||||
/* string fallback_addr = 6; */
|
||||
if (message.fallbackAddr !== "")
|
||||
writer.tag(6, WireType.LengthDelimited).string(message.fallbackAddr);
|
||||
/* uint64 cltv_expiry = 7; */
|
||||
if (message.cltvExpiry !== "0")
|
||||
if (message.cltvExpiry !== 0n)
|
||||
writer.tag(7, WireType.Varint).uint64(message.cltvExpiry);
|
||||
/* repeated lnrpc.RouteHint route_hints = 8; */
|
||||
for (let i = 0; i < message.routeHints.length; i++)
|
||||
|
|
@ -339,11 +424,13 @@ export const AddHoldInvoiceRequest = new AddHoldInvoiceRequest$Type();
|
|||
class AddHoldInvoiceResp$Type extends MessageType<AddHoldInvoiceResp> {
|
||||
constructor() {
|
||||
super("invoicesrpc.AddHoldInvoiceResp", [
|
||||
{ no: 1, name: "payment_request", kind: "scalar", T: 9 /*ScalarType.STRING*/ }
|
||||
{ no: 1, name: "payment_request", kind: "scalar", T: 9 /*ScalarType.STRING*/ },
|
||||
{ no: 2, name: "add_index", kind: "scalar", T: 4 /*ScalarType.UINT64*/, L: 0 /*LongType.BIGINT*/ },
|
||||
{ no: 3, name: "payment_addr", kind: "scalar", T: 12 /*ScalarType.BYTES*/ }
|
||||
]);
|
||||
}
|
||||
create(value?: PartialMessage<AddHoldInvoiceResp>): AddHoldInvoiceResp {
|
||||
const message = { paymentRequest: "" };
|
||||
const message = { paymentRequest: "", addIndex: 0n, paymentAddr: new Uint8Array(0) };
|
||||
globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this });
|
||||
if (value !== undefined)
|
||||
reflectionMergePartial<AddHoldInvoiceResp>(this, message, value);
|
||||
|
|
@ -357,6 +444,12 @@ class AddHoldInvoiceResp$Type extends MessageType<AddHoldInvoiceResp> {
|
|||
case /* string payment_request */ 1:
|
||||
message.paymentRequest = reader.string();
|
||||
break;
|
||||
case /* uint64 add_index */ 2:
|
||||
message.addIndex = reader.uint64().toBigInt();
|
||||
break;
|
||||
case /* bytes payment_addr */ 3:
|
||||
message.paymentAddr = reader.bytes();
|
||||
break;
|
||||
default:
|
||||
let u = options.readUnknownField;
|
||||
if (u === "throw")
|
||||
|
|
@ -372,6 +465,12 @@ class AddHoldInvoiceResp$Type extends MessageType<AddHoldInvoiceResp> {
|
|||
/* string payment_request = 1; */
|
||||
if (message.paymentRequest !== "")
|
||||
writer.tag(1, WireType.LengthDelimited).string(message.paymentRequest);
|
||||
/* uint64 add_index = 2; */
|
||||
if (message.addIndex !== 0n)
|
||||
writer.tag(2, WireType.Varint).uint64(message.addIndex);
|
||||
/* bytes payment_addr = 3; */
|
||||
if (message.paymentAddr.length)
|
||||
writer.tag(3, WireType.LengthDelimited).bytes(message.paymentAddr);
|
||||
let u = options.writeUnknownFields;
|
||||
if (u !== false)
|
||||
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
|
||||
|
|
@ -502,6 +601,83 @@ class SubscribeSingleInvoiceRequest$Type extends MessageType<SubscribeSingleInvo
|
|||
* @generated MessageType for protobuf message invoicesrpc.SubscribeSingleInvoiceRequest
|
||||
*/
|
||||
export const SubscribeSingleInvoiceRequest = new SubscribeSingleInvoiceRequest$Type();
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class LookupInvoiceMsg$Type extends MessageType<LookupInvoiceMsg> {
|
||||
constructor() {
|
||||
super("invoicesrpc.LookupInvoiceMsg", [
|
||||
{ no: 1, name: "payment_hash", kind: "scalar", oneof: "invoiceRef", T: 12 /*ScalarType.BYTES*/ },
|
||||
{ no: 2, name: "payment_addr", kind: "scalar", oneof: "invoiceRef", T: 12 /*ScalarType.BYTES*/ },
|
||||
{ no: 3, name: "set_id", kind: "scalar", oneof: "invoiceRef", T: 12 /*ScalarType.BYTES*/ },
|
||||
{ no: 4, name: "lookup_modifier", kind: "enum", T: () => ["invoicesrpc.LookupModifier", LookupModifier] }
|
||||
]);
|
||||
}
|
||||
create(value?: PartialMessage<LookupInvoiceMsg>): LookupInvoiceMsg {
|
||||
const message = { invoiceRef: { oneofKind: undefined }, lookupModifier: 0 };
|
||||
globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this });
|
||||
if (value !== undefined)
|
||||
reflectionMergePartial<LookupInvoiceMsg>(this, message, value);
|
||||
return message;
|
||||
}
|
||||
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: LookupInvoiceMsg): LookupInvoiceMsg {
|
||||
let message = target ?? this.create(), end = reader.pos + length;
|
||||
while (reader.pos < end) {
|
||||
let [fieldNo, wireType] = reader.tag();
|
||||
switch (fieldNo) {
|
||||
case /* bytes payment_hash */ 1:
|
||||
message.invoiceRef = {
|
||||
oneofKind: "paymentHash",
|
||||
paymentHash: reader.bytes()
|
||||
};
|
||||
break;
|
||||
case /* bytes payment_addr */ 2:
|
||||
message.invoiceRef = {
|
||||
oneofKind: "paymentAddr",
|
||||
paymentAddr: reader.bytes()
|
||||
};
|
||||
break;
|
||||
case /* bytes set_id */ 3:
|
||||
message.invoiceRef = {
|
||||
oneofKind: "setId",
|
||||
setId: reader.bytes()
|
||||
};
|
||||
break;
|
||||
case /* invoicesrpc.LookupModifier lookup_modifier */ 4:
|
||||
message.lookupModifier = reader.int32();
|
||||
break;
|
||||
default:
|
||||
let u = options.readUnknownField;
|
||||
if (u === "throw")
|
||||
throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
|
||||
let d = reader.skip(wireType);
|
||||
if (u !== false)
|
||||
(u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
|
||||
}
|
||||
}
|
||||
return message;
|
||||
}
|
||||
internalBinaryWrite(message: LookupInvoiceMsg, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
||||
/* bytes payment_hash = 1; */
|
||||
if (message.invoiceRef.oneofKind === "paymentHash")
|
||||
writer.tag(1, WireType.LengthDelimited).bytes(message.invoiceRef.paymentHash);
|
||||
/* bytes payment_addr = 2; */
|
||||
if (message.invoiceRef.oneofKind === "paymentAddr")
|
||||
writer.tag(2, WireType.LengthDelimited).bytes(message.invoiceRef.paymentAddr);
|
||||
/* bytes set_id = 3; */
|
||||
if (message.invoiceRef.oneofKind === "setId")
|
||||
writer.tag(3, WireType.LengthDelimited).bytes(message.invoiceRef.setId);
|
||||
/* invoicesrpc.LookupModifier lookup_modifier = 4; */
|
||||
if (message.lookupModifier !== 0)
|
||||
writer.tag(4, WireType.Varint).int32(message.lookupModifier);
|
||||
let u = options.writeUnknownFields;
|
||||
if (u !== false)
|
||||
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
|
||||
return writer;
|
||||
}
|
||||
}
|
||||
/**
|
||||
* @generated MessageType for protobuf message invoicesrpc.LookupInvoiceMsg
|
||||
*/
|
||||
export const LookupInvoiceMsg = new LookupInvoiceMsg$Type();
|
||||
/**
|
||||
* @generated ServiceType for protobuf service invoicesrpc.Invoices
|
||||
*/
|
||||
|
|
@ -509,5 +685,6 @@ export const Invoices = new ServiceType("invoicesrpc.Invoices", [
|
|||
{ name: "SubscribeSingleInvoice", serverStreaming: true, options: {}, I: SubscribeSingleInvoiceRequest, O: Invoice },
|
||||
{ name: "CancelInvoice", options: {}, I: CancelInvoiceMsg, O: CancelInvoiceResp },
|
||||
{ name: "AddHoldInvoice", options: {}, I: AddHoldInvoiceRequest, O: AddHoldInvoiceResp },
|
||||
{ name: "SettleInvoice", options: {}, I: SettleInvoiceMsg, O: SettleInvoiceResp }
|
||||
{ name: "SettleInvoice", options: {}, I: SettleInvoiceMsg, O: SettleInvoiceResp },
|
||||
{ name: "LookupInvoiceV2", options: {}, I: LookupInvoiceMsg, O: Invoice }
|
||||
]);
|
||||
|
|
|
|||
|
|
@ -1,119 +1,135 @@
|
|||
// @generated by protobuf-ts 2.5.0 with parameter long_type_string
|
||||
// @generated from protobuf file "rpc.proto" (package "lnrpc", syntax proto3)
|
||||
// @generated by protobuf-ts 2.5.0
|
||||
// @generated from protobuf file "lightning.proto" (package "lnrpc", syntax proto3)
|
||||
// tslint:disable
|
||||
import type { RpcTransport } from "@protobuf-ts/runtime-rpc";
|
||||
import type { ServiceInfo } from "@protobuf-ts/runtime-rpc";
|
||||
import { Lightning } from "./rpc";
|
||||
import type { ListPermissionsResponse } from "./rpc";
|
||||
import type { ListPermissionsRequest } from "./rpc";
|
||||
import type { DeleteMacaroonIDResponse } from "./rpc";
|
||||
import type { DeleteMacaroonIDRequest } from "./rpc";
|
||||
import type { ListMacaroonIDsResponse } from "./rpc";
|
||||
import type { ListMacaroonIDsRequest } from "./rpc";
|
||||
import type { BakeMacaroonResponse } from "./rpc";
|
||||
import type { BakeMacaroonRequest } from "./rpc";
|
||||
import type { ChannelBackupSubscription } from "./rpc";
|
||||
import type { RestoreBackupResponse } from "./rpc";
|
||||
import type { RestoreChanBackupRequest } from "./rpc";
|
||||
import type { VerifyChanBackupResponse } from "./rpc";
|
||||
import type { ChanBackupSnapshot } from "./rpc";
|
||||
import type { ChanBackupExportRequest } from "./rpc";
|
||||
import type { ChannelBackup } from "./rpc";
|
||||
import type { ExportChannelBackupRequest } from "./rpc";
|
||||
import type { ForwardingHistoryResponse } from "./rpc";
|
||||
import type { ForwardingHistoryRequest } from "./rpc";
|
||||
import type { PolicyUpdateResponse } from "./rpc";
|
||||
import type { PolicyUpdateRequest } from "./rpc";
|
||||
import type { FeeReportResponse } from "./rpc";
|
||||
import type { FeeReportRequest } from "./rpc";
|
||||
import type { DebugLevelResponse } from "./rpc";
|
||||
import type { DebugLevelRequest } from "./rpc";
|
||||
import type { GraphTopologyUpdate } from "./rpc";
|
||||
import type { GraphTopologySubscription } from "./rpc";
|
||||
import type { StopResponse } from "./rpc";
|
||||
import type { StopRequest } from "./rpc";
|
||||
import type { NetworkInfo } from "./rpc";
|
||||
import type { NetworkInfoRequest } from "./rpc";
|
||||
import type { QueryRoutesResponse } from "./rpc";
|
||||
import type { QueryRoutesRequest } from "./rpc";
|
||||
import type { NodeInfo } from "./rpc";
|
||||
import type { NodeInfoRequest } from "./rpc";
|
||||
import type { ChannelEdge } from "./rpc";
|
||||
import type { ChanInfoRequest } from "./rpc";
|
||||
import type { NodeMetricsResponse } from "./rpc";
|
||||
import type { NodeMetricsRequest } from "./rpc";
|
||||
import type { ChannelGraph } from "./rpc";
|
||||
import type { ChannelGraphRequest } from "./rpc";
|
||||
import type { DeleteAllPaymentsResponse } from "./rpc";
|
||||
import type { DeleteAllPaymentsRequest } from "./rpc";
|
||||
import type { ListPaymentsResponse } from "./rpc";
|
||||
import type { ListPaymentsRequest } from "./rpc";
|
||||
import type { PayReq } from "./rpc";
|
||||
import type { PayReqString } from "./rpc";
|
||||
import type { InvoiceSubscription } from "./rpc";
|
||||
import type { PaymentHash } from "./rpc";
|
||||
import type { ListInvoiceResponse } from "./rpc";
|
||||
import type { ListInvoiceRequest } from "./rpc";
|
||||
import type { AddInvoiceResponse } from "./rpc";
|
||||
import type { Invoice } from "./rpc";
|
||||
import type { SendToRouteRequest } from "./rpc";
|
||||
import type { SendResponse } from "./rpc";
|
||||
import type { SendRequest } from "./rpc";
|
||||
import type { AbandonChannelResponse } from "./rpc";
|
||||
import type { AbandonChannelRequest } from "./rpc";
|
||||
import type { CloseStatusUpdate } from "./rpc";
|
||||
import type { CloseChannelRequest } from "./rpc";
|
||||
import type { ChannelAcceptRequest } from "./rpc";
|
||||
import type { ChannelAcceptResponse } from "./rpc";
|
||||
import { Lightning } from "./lightning";
|
||||
import type { LookupHtlcResponse } from "./lightning";
|
||||
import type { LookupHtlcRequest } from "./lightning";
|
||||
import type { ListAliasesResponse } from "./lightning";
|
||||
import type { ListAliasesRequest } from "./lightning";
|
||||
import type { CustomMessage } from "./lightning";
|
||||
import type { SubscribeCustomMessagesRequest } from "./lightning";
|
||||
import type { SendCustomMessageResponse } from "./lightning";
|
||||
import type { SendCustomMessageRequest } from "./lightning";
|
||||
import type { RPCMiddlewareRequest } from "./lightning";
|
||||
import type { RPCMiddlewareResponse } from "./lightning";
|
||||
import type { CheckMacPermResponse } from "./lightning";
|
||||
import type { CheckMacPermRequest } from "./lightning";
|
||||
import type { ListPermissionsResponse } from "./lightning";
|
||||
import type { ListPermissionsRequest } from "./lightning";
|
||||
import type { DeleteMacaroonIDResponse } from "./lightning";
|
||||
import type { DeleteMacaroonIDRequest } from "./lightning";
|
||||
import type { ListMacaroonIDsResponse } from "./lightning";
|
||||
import type { ListMacaroonIDsRequest } from "./lightning";
|
||||
import type { BakeMacaroonResponse } from "./lightning";
|
||||
import type { BakeMacaroonRequest } from "./lightning";
|
||||
import type { ChannelBackupSubscription } from "./lightning";
|
||||
import type { RestoreBackupResponse } from "./lightning";
|
||||
import type { RestoreChanBackupRequest } from "./lightning";
|
||||
import type { VerifyChanBackupResponse } from "./lightning";
|
||||
import type { ChanBackupSnapshot } from "./lightning";
|
||||
import type { ChanBackupExportRequest } from "./lightning";
|
||||
import type { ChannelBackup } from "./lightning";
|
||||
import type { ExportChannelBackupRequest } from "./lightning";
|
||||
import type { ForwardingHistoryResponse } from "./lightning";
|
||||
import type { ForwardingHistoryRequest } from "./lightning";
|
||||
import type { PolicyUpdateResponse } from "./lightning";
|
||||
import type { PolicyUpdateRequest } from "./lightning";
|
||||
import type { FeeReportResponse } from "./lightning";
|
||||
import type { FeeReportRequest } from "./lightning";
|
||||
import type { DebugLevelResponse } from "./lightning";
|
||||
import type { DebugLevelRequest } from "./lightning";
|
||||
import type { GraphTopologyUpdate } from "./lightning";
|
||||
import type { GraphTopologySubscription } from "./lightning";
|
||||
import type { StopResponse } from "./lightning";
|
||||
import type { StopRequest } from "./lightning";
|
||||
import type { NetworkInfo } from "./lightning";
|
||||
import type { NetworkInfoRequest } from "./lightning";
|
||||
import type { QueryRoutesResponse } from "./lightning";
|
||||
import type { QueryRoutesRequest } from "./lightning";
|
||||
import type { NodeInfo } from "./lightning";
|
||||
import type { NodeInfoRequest } from "./lightning";
|
||||
import type { ChannelEdge } from "./lightning";
|
||||
import type { ChanInfoRequest } from "./lightning";
|
||||
import type { NodeMetricsResponse } from "./lightning";
|
||||
import type { NodeMetricsRequest } from "./lightning";
|
||||
import type { ChannelGraph } from "./lightning";
|
||||
import type { ChannelGraphRequest } from "./lightning";
|
||||
import type { DeleteAllPaymentsResponse } from "./lightning";
|
||||
import type { DeleteAllPaymentsRequest } from "./lightning";
|
||||
import type { DeletePaymentResponse } from "./lightning";
|
||||
import type { DeletePaymentRequest } from "./lightning";
|
||||
import type { ListPaymentsResponse } from "./lightning";
|
||||
import type { ListPaymentsRequest } from "./lightning";
|
||||
import type { PayReq } from "./lightning";
|
||||
import type { PayReqString } from "./lightning";
|
||||
import type { InvoiceSubscription } from "./lightning";
|
||||
import type { PaymentHash } from "./lightning";
|
||||
import type { ListInvoiceResponse } from "./lightning";
|
||||
import type { ListInvoiceRequest } from "./lightning";
|
||||
import type { AddInvoiceResponse } from "./lightning";
|
||||
import type { Invoice } from "./lightning";
|
||||
import type { SendToRouteRequest } from "./lightning";
|
||||
import type { SendResponse } from "./lightning";
|
||||
import type { SendRequest } from "./lightning";
|
||||
import type { AbandonChannelResponse } from "./lightning";
|
||||
import type { AbandonChannelRequest } from "./lightning";
|
||||
import type { CloseStatusUpdate } from "./lightning";
|
||||
import type { CloseChannelRequest } from "./lightning";
|
||||
import type { ChannelAcceptRequest } from "./lightning";
|
||||
import type { ChannelAcceptResponse } from "./lightning";
|
||||
import type { DuplexStreamingCall } from "@protobuf-ts/runtime-rpc";
|
||||
import type { FundingStateStepResp } from "./rpc";
|
||||
import type { FundingTransitionMsg } from "./rpc";
|
||||
import type { OpenStatusUpdate } from "./rpc";
|
||||
import type { ChannelPoint } from "./rpc";
|
||||
import type { OpenChannelRequest } from "./rpc";
|
||||
import type { ClosedChannelsResponse } from "./rpc";
|
||||
import type { ClosedChannelsRequest } from "./rpc";
|
||||
import type { ChannelEventUpdate } from "./rpc";
|
||||
import type { ChannelEventSubscription } from "./rpc";
|
||||
import type { ListChannelsResponse } from "./rpc";
|
||||
import type { ListChannelsRequest } from "./rpc";
|
||||
import type { PendingChannelsResponse } from "./rpc";
|
||||
import type { PendingChannelsRequest } from "./rpc";
|
||||
import type { GetRecoveryInfoResponse } from "./rpc";
|
||||
import type { GetRecoveryInfoRequest } from "./rpc";
|
||||
import type { GetInfoResponse } from "./rpc";
|
||||
import type { GetInfoRequest } from "./rpc";
|
||||
import type { PeerEvent } from "./rpc";
|
||||
import type { PeerEventSubscription } from "./rpc";
|
||||
import type { ListPeersResponse } from "./rpc";
|
||||
import type { ListPeersRequest } from "./rpc";
|
||||
import type { DisconnectPeerResponse } from "./rpc";
|
||||
import type { DisconnectPeerRequest } from "./rpc";
|
||||
import type { ConnectPeerResponse } from "./rpc";
|
||||
import type { ConnectPeerRequest } from "./rpc";
|
||||
import type { VerifyMessageResponse } from "./rpc";
|
||||
import type { VerifyMessageRequest } from "./rpc";
|
||||
import type { SignMessageResponse } from "./rpc";
|
||||
import type { SignMessageRequest } from "./rpc";
|
||||
import type { NewAddressResponse } from "./rpc";
|
||||
import type { NewAddressRequest } from "./rpc";
|
||||
import type { SendManyResponse } from "./rpc";
|
||||
import type { SendManyRequest } from "./rpc";
|
||||
import type { Transaction } from "./rpc";
|
||||
import type { FundingStateStepResp } from "./lightning";
|
||||
import type { FundingTransitionMsg } from "./lightning";
|
||||
import type { BatchOpenChannelResponse } from "./lightning";
|
||||
import type { BatchOpenChannelRequest } from "./lightning";
|
||||
import type { OpenStatusUpdate } from "./lightning";
|
||||
import type { ChannelPoint } from "./lightning";
|
||||
import type { OpenChannelRequest } from "./lightning";
|
||||
import type { ClosedChannelsResponse } from "./lightning";
|
||||
import type { ClosedChannelsRequest } from "./lightning";
|
||||
import type { ChannelEventUpdate } from "./lightning";
|
||||
import type { ChannelEventSubscription } from "./lightning";
|
||||
import type { ListChannelsResponse } from "./lightning";
|
||||
import type { ListChannelsRequest } from "./lightning";
|
||||
import type { PendingChannelsResponse } from "./lightning";
|
||||
import type { PendingChannelsRequest } from "./lightning";
|
||||
import type { GetRecoveryInfoResponse } from "./lightning";
|
||||
import type { GetRecoveryInfoRequest } from "./lightning";
|
||||
import type { GetInfoResponse } from "./lightning";
|
||||
import type { GetInfoRequest } from "./lightning";
|
||||
import type { PeerEvent } from "./lightning";
|
||||
import type { PeerEventSubscription } from "./lightning";
|
||||
import type { ListPeersResponse } from "./lightning";
|
||||
import type { ListPeersRequest } from "./lightning";
|
||||
import type { DisconnectPeerResponse } from "./lightning";
|
||||
import type { DisconnectPeerRequest } from "./lightning";
|
||||
import type { ConnectPeerResponse } from "./lightning";
|
||||
import type { ConnectPeerRequest } from "./lightning";
|
||||
import type { VerifyMessageResponse } from "./lightning";
|
||||
import type { VerifyMessageRequest } from "./lightning";
|
||||
import type { SignMessageResponse } from "./lightning";
|
||||
import type { SignMessageRequest } from "./lightning";
|
||||
import type { NewAddressResponse } from "./lightning";
|
||||
import type { NewAddressRequest } from "./lightning";
|
||||
import type { SendManyResponse } from "./lightning";
|
||||
import type { SendManyRequest } from "./lightning";
|
||||
import type { Transaction } from "./lightning";
|
||||
import type { ServerStreamingCall } from "@protobuf-ts/runtime-rpc";
|
||||
import type { ListUnspentResponse } from "./rpc";
|
||||
import type { ListUnspentRequest } from "./rpc";
|
||||
import type { SendCoinsResponse } from "./rpc";
|
||||
import type { SendCoinsRequest } from "./rpc";
|
||||
import type { EstimateFeeResponse } from "./rpc";
|
||||
import type { EstimateFeeRequest } from "./rpc";
|
||||
import type { TransactionDetails } from "./rpc";
|
||||
import type { GetTransactionsRequest } from "./rpc";
|
||||
import type { ChannelBalanceResponse } from "./rpc";
|
||||
import type { ChannelBalanceRequest } from "./rpc";
|
||||
import type { ListUnspentResponse } from "./lightning";
|
||||
import type { ListUnspentRequest } from "./lightning";
|
||||
import type { SendCoinsResponse } from "./lightning";
|
||||
import type { SendCoinsRequest } from "./lightning";
|
||||
import type { EstimateFeeResponse } from "./lightning";
|
||||
import type { EstimateFeeRequest } from "./lightning";
|
||||
import type { TransactionDetails } from "./lightning";
|
||||
import type { GetTransactionsRequest } from "./lightning";
|
||||
import type { ChannelBalanceResponse } from "./lightning";
|
||||
import type { ChannelBalanceRequest } from "./lightning";
|
||||
import { stackIntercept } from "@protobuf-ts/runtime-rpc";
|
||||
import type { WalletBalanceResponse } from "./rpc";
|
||||
import type { WalletBalanceRequest } from "./rpc";
|
||||
import type { WalletBalanceResponse } from "./lightning";
|
||||
import type { WalletBalanceRequest } from "./lightning";
|
||||
import type { UnaryCall } from "@protobuf-ts/runtime-rpc";
|
||||
import type { RpcOptions } from "@protobuf-ts/runtime-rpc";
|
||||
//
|
||||
|
|
@ -358,6 +374,17 @@ export interface ILightningClient {
|
|||
* @generated from protobuf rpc: OpenChannel(lnrpc.OpenChannelRequest) returns (stream lnrpc.OpenStatusUpdate);
|
||||
*/
|
||||
openChannel(input: OpenChannelRequest, options?: RpcOptions): ServerStreamingCall<OpenChannelRequest, OpenStatusUpdate>;
|
||||
/**
|
||||
* lncli: `batchopenchannel`
|
||||
* BatchOpenChannel attempts to open multiple single-funded channels in a
|
||||
* single transaction in an atomic way. This means either all channel open
|
||||
* requests succeed at once or all attempts are aborted if any of them fail.
|
||||
* This is the safer variant of using PSBTs to manually fund a batch of
|
||||
* channels through the OpenChannel RPC.
|
||||
*
|
||||
* @generated from protobuf rpc: BatchOpenChannel(lnrpc.BatchOpenChannelRequest) returns (lnrpc.BatchOpenChannelResponse);
|
||||
*/
|
||||
batchOpenChannel(input: BatchOpenChannelRequest, options?: RpcOptions): UnaryCall<BatchOpenChannelRequest, BatchOpenChannelResponse>;
|
||||
/**
|
||||
*
|
||||
* FundingStateStep is an advanced funding related call that allows the caller
|
||||
|
|
@ -514,7 +541,16 @@ export interface ILightningClient {
|
|||
listPayments(input: ListPaymentsRequest, options?: RpcOptions): UnaryCall<ListPaymentsRequest, ListPaymentsResponse>;
|
||||
/**
|
||||
*
|
||||
* DeleteAllPayments deletes all outgoing payments from DB.
|
||||
* DeletePayment deletes an outgoing payment from DB. Note that it will not
|
||||
* attempt to delete an In-Flight payment, since that would be unsafe.
|
||||
*
|
||||
* @generated from protobuf rpc: DeletePayment(lnrpc.DeletePaymentRequest) returns (lnrpc.DeletePaymentResponse);
|
||||
*/
|
||||
deletePayment(input: DeletePaymentRequest, options?: RpcOptions): UnaryCall<DeletePaymentRequest, DeletePaymentResponse>;
|
||||
/**
|
||||
*
|
||||
* DeleteAllPayments deletes all outgoing payments from DB. Note that it will
|
||||
* not attempt to delete In-Flight payments, since that would be unsafe.
|
||||
*
|
||||
* @generated from protobuf rpc: DeleteAllPayments(lnrpc.DeleteAllPaymentsRequest) returns (lnrpc.DeleteAllPaymentsResponse);
|
||||
*/
|
||||
|
|
@ -631,8 +667,9 @@ export interface ILightningClient {
|
|||
* lncli: `fwdinghistory`
|
||||
* ForwardingHistory allows the caller to query the htlcswitch for a record of
|
||||
* all HTLCs forwarded within the target time range, and integer offset
|
||||
* within that time range. If no time-range is specified, then the first chunk
|
||||
* of the past 24 hrs of forwarding history are returned.
|
||||
* within that time range, for a maximum number of events. If no maximum number
|
||||
* of events is specified, up to 100 events will be returned. If no time-range
|
||||
* is specified, then events will be returned in the order that they occured.
|
||||
*
|
||||
* A list of forwarding events are returned. The size of each forwarding event
|
||||
* is 40 bytes, and the max message size able to be returned in gRPC is 4 MiB.
|
||||
|
|
@ -730,6 +767,61 @@ export interface ILightningClient {
|
|||
* @generated from protobuf rpc: ListPermissions(lnrpc.ListPermissionsRequest) returns (lnrpc.ListPermissionsResponse);
|
||||
*/
|
||||
listPermissions(input: ListPermissionsRequest, options?: RpcOptions): UnaryCall<ListPermissionsRequest, ListPermissionsResponse>;
|
||||
/**
|
||||
*
|
||||
* CheckMacaroonPermissions checks whether a request follows the constraints
|
||||
* imposed on the macaroon and that the macaroon is authorized to follow the
|
||||
* provided permissions.
|
||||
*
|
||||
* @generated from protobuf rpc: CheckMacaroonPermissions(lnrpc.CheckMacPermRequest) returns (lnrpc.CheckMacPermResponse);
|
||||
*/
|
||||
checkMacaroonPermissions(input: CheckMacPermRequest, options?: RpcOptions): UnaryCall<CheckMacPermRequest, CheckMacPermResponse>;
|
||||
/**
|
||||
*
|
||||
* RegisterRPCMiddleware adds a new gRPC middleware to the interceptor chain. A
|
||||
* gRPC middleware is software component external to lnd that aims to add
|
||||
* additional business logic to lnd by observing/intercepting/validating
|
||||
* incoming gRPC client requests and (if needed) replacing/overwriting outgoing
|
||||
* messages before they're sent to the client. When registering the middleware
|
||||
* must identify itself and indicate what custom macaroon caveats it wants to
|
||||
* be responsible for. Only requests that contain a macaroon with that specific
|
||||
* custom caveat are then sent to the middleware for inspection. The other
|
||||
* option is to register for the read-only mode in which all requests/responses
|
||||
* are forwarded for interception to the middleware but the middleware is not
|
||||
* allowed to modify any responses. As a security measure, _no_ middleware can
|
||||
* modify responses for requests made with _unencumbered_ macaroons!
|
||||
*
|
||||
* @generated from protobuf rpc: RegisterRPCMiddleware(stream lnrpc.RPCMiddlewareResponse) returns (stream lnrpc.RPCMiddlewareRequest);
|
||||
*/
|
||||
registerRPCMiddleware(options?: RpcOptions): DuplexStreamingCall<RPCMiddlewareResponse, RPCMiddlewareRequest>;
|
||||
/**
|
||||
* lncli: `sendcustom`
|
||||
* SendCustomMessage sends a custom peer message.
|
||||
*
|
||||
* @generated from protobuf rpc: SendCustomMessage(lnrpc.SendCustomMessageRequest) returns (lnrpc.SendCustomMessageResponse);
|
||||
*/
|
||||
sendCustomMessage(input: SendCustomMessageRequest, options?: RpcOptions): UnaryCall<SendCustomMessageRequest, SendCustomMessageResponse>;
|
||||
/**
|
||||
* lncli: `subscribecustom`
|
||||
* SubscribeCustomMessages subscribes to a stream of incoming custom peer
|
||||
* messages.
|
||||
*
|
||||
* @generated from protobuf rpc: SubscribeCustomMessages(lnrpc.SubscribeCustomMessagesRequest) returns (stream lnrpc.CustomMessage);
|
||||
*/
|
||||
subscribeCustomMessages(input: SubscribeCustomMessagesRequest, options?: RpcOptions): ServerStreamingCall<SubscribeCustomMessagesRequest, CustomMessage>;
|
||||
/**
|
||||
* lncli: `listaliases`
|
||||
* ListAliases returns the set of all aliases that have ever existed with
|
||||
* their confirmed SCID (if it exists) and/or the base SCID (in the case of
|
||||
* zero conf).
|
||||
*
|
||||
* @generated from protobuf rpc: ListAliases(lnrpc.ListAliasesRequest) returns (lnrpc.ListAliasesResponse);
|
||||
*/
|
||||
listAliases(input: ListAliasesRequest, options?: RpcOptions): UnaryCall<ListAliasesRequest, ListAliasesResponse>;
|
||||
/**
|
||||
* @generated from protobuf rpc: LookupHtlc(lnrpc.LookupHtlcRequest) returns (lnrpc.LookupHtlcResponse);
|
||||
*/
|
||||
lookupHtlc(input: LookupHtlcRequest, options?: RpcOptions): UnaryCall<LookupHtlcRequest, LookupHtlcResponse>;
|
||||
}
|
||||
//
|
||||
// Comments in this file will be directly parsed into the API
|
||||
|
|
@ -1047,6 +1139,20 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
const method = this.methods[22], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<OpenChannelRequest, OpenStatusUpdate>("serverStreaming", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* lncli: `batchopenchannel`
|
||||
* BatchOpenChannel attempts to open multiple single-funded channels in a
|
||||
* single transaction in an atomic way. This means either all channel open
|
||||
* requests succeed at once or all attempts are aborted if any of them fail.
|
||||
* This is the safer variant of using PSBTs to manually fund a batch of
|
||||
* channels through the OpenChannel RPC.
|
||||
*
|
||||
* @generated from protobuf rpc: BatchOpenChannel(lnrpc.BatchOpenChannelRequest) returns (lnrpc.BatchOpenChannelResponse);
|
||||
*/
|
||||
batchOpenChannel(input: BatchOpenChannelRequest, options?: RpcOptions): UnaryCall<BatchOpenChannelRequest, BatchOpenChannelResponse> {
|
||||
const method = this.methods[23], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<BatchOpenChannelRequest, BatchOpenChannelResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
*
|
||||
* FundingStateStep is an advanced funding related call that allows the caller
|
||||
|
|
@ -1061,7 +1167,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: FundingStateStep(lnrpc.FundingTransitionMsg) returns (lnrpc.FundingStateStepResp);
|
||||
*/
|
||||
fundingStateStep(input: FundingTransitionMsg, options?: RpcOptions): UnaryCall<FundingTransitionMsg, FundingStateStepResp> {
|
||||
const method = this.methods[23], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[24], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<FundingTransitionMsg, FundingStateStepResp>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1075,7 +1181,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: ChannelAcceptor(stream lnrpc.ChannelAcceptResponse) returns (stream lnrpc.ChannelAcceptRequest);
|
||||
*/
|
||||
channelAcceptor(options?: RpcOptions): DuplexStreamingCall<ChannelAcceptResponse, ChannelAcceptRequest> {
|
||||
const method = this.methods[24], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[25], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ChannelAcceptResponse, ChannelAcceptRequest>("duplex", this._transport, method, opt);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1091,7 +1197,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: CloseChannel(lnrpc.CloseChannelRequest) returns (stream lnrpc.CloseStatusUpdate);
|
||||
*/
|
||||
closeChannel(input: CloseChannelRequest, options?: RpcOptions): ServerStreamingCall<CloseChannelRequest, CloseStatusUpdate> {
|
||||
const method = this.methods[25], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[26], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<CloseChannelRequest, CloseStatusUpdate>("serverStreaming", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1106,7 +1212,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: AbandonChannel(lnrpc.AbandonChannelRequest) returns (lnrpc.AbandonChannelResponse);
|
||||
*/
|
||||
abandonChannel(input: AbandonChannelRequest, options?: RpcOptions): UnaryCall<AbandonChannelRequest, AbandonChannelResponse> {
|
||||
const method = this.methods[26], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[27], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<AbandonChannelRequest, AbandonChannelResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1121,7 +1227,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: SendPayment(stream lnrpc.SendRequest) returns (stream lnrpc.SendResponse);
|
||||
*/
|
||||
sendPayment(options?: RpcOptions): DuplexStreamingCall<SendRequest, SendResponse> {
|
||||
const method = this.methods[27], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[28], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<SendRequest, SendResponse>("duplex", this._transport, method, opt);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1134,7 +1240,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: SendPaymentSync(lnrpc.SendRequest) returns (lnrpc.SendResponse);
|
||||
*/
|
||||
sendPaymentSync(input: SendRequest, options?: RpcOptions): UnaryCall<SendRequest, SendResponse> {
|
||||
const method = this.methods[28], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[29], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<SendRequest, SendResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1149,7 +1255,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: SendToRoute(stream lnrpc.SendToRouteRequest) returns (stream lnrpc.SendResponse);
|
||||
*/
|
||||
sendToRoute(options?: RpcOptions): DuplexStreamingCall<SendToRouteRequest, SendResponse> {
|
||||
const method = this.methods[29], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[30], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<SendToRouteRequest, SendResponse>("duplex", this._transport, method, opt);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1160,7 +1266,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: SendToRouteSync(lnrpc.SendToRouteRequest) returns (lnrpc.SendResponse);
|
||||
*/
|
||||
sendToRouteSync(input: SendToRouteRequest, options?: RpcOptions): UnaryCall<SendToRouteRequest, SendResponse> {
|
||||
const method = this.methods[30], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[31], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<SendToRouteRequest, SendResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1172,7 +1278,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: AddInvoice(lnrpc.Invoice) returns (lnrpc.AddInvoiceResponse);
|
||||
*/
|
||||
addInvoice(input: Invoice, options?: RpcOptions): UnaryCall<Invoice, AddInvoiceResponse> {
|
||||
const method = this.methods[31], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[32], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<Invoice, AddInvoiceResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1188,7 +1294,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: ListInvoices(lnrpc.ListInvoiceRequest) returns (lnrpc.ListInvoiceResponse);
|
||||
*/
|
||||
listInvoices(input: ListInvoiceRequest, options?: RpcOptions): UnaryCall<ListInvoiceRequest, ListInvoiceResponse> {
|
||||
const method = this.methods[32], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[33], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ListInvoiceRequest, ListInvoiceResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1200,7 +1306,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: LookupInvoice(lnrpc.PaymentHash) returns (lnrpc.Invoice);
|
||||
*/
|
||||
lookupInvoice(input: PaymentHash, options?: RpcOptions): UnaryCall<PaymentHash, Invoice> {
|
||||
const method = this.methods[33], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[34], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<PaymentHash, Invoice>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1218,7 +1324,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: SubscribeInvoices(lnrpc.InvoiceSubscription) returns (stream lnrpc.Invoice);
|
||||
*/
|
||||
subscribeInvoices(input: InvoiceSubscription, options?: RpcOptions): ServerStreamingCall<InvoiceSubscription, Invoice> {
|
||||
const method = this.methods[34], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[35], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<InvoiceSubscription, Invoice>("serverStreaming", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1230,7 +1336,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: DecodePayReq(lnrpc.PayReqString) returns (lnrpc.PayReq);
|
||||
*/
|
||||
decodePayReq(input: PayReqString, options?: RpcOptions): UnaryCall<PayReqString, PayReq> {
|
||||
const method = this.methods[35], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[36], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<PayReqString, PayReq>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1240,17 +1346,29 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: ListPayments(lnrpc.ListPaymentsRequest) returns (lnrpc.ListPaymentsResponse);
|
||||
*/
|
||||
listPayments(input: ListPaymentsRequest, options?: RpcOptions): UnaryCall<ListPaymentsRequest, ListPaymentsResponse> {
|
||||
const method = this.methods[36], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[37], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ListPaymentsRequest, ListPaymentsResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
*
|
||||
* DeleteAllPayments deletes all outgoing payments from DB.
|
||||
* DeletePayment deletes an outgoing payment from DB. Note that it will not
|
||||
* attempt to delete an In-Flight payment, since that would be unsafe.
|
||||
*
|
||||
* @generated from protobuf rpc: DeletePayment(lnrpc.DeletePaymentRequest) returns (lnrpc.DeletePaymentResponse);
|
||||
*/
|
||||
deletePayment(input: DeletePaymentRequest, options?: RpcOptions): UnaryCall<DeletePaymentRequest, DeletePaymentResponse> {
|
||||
const method = this.methods[38], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<DeletePaymentRequest, DeletePaymentResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
*
|
||||
* DeleteAllPayments deletes all outgoing payments from DB. Note that it will
|
||||
* not attempt to delete In-Flight payments, since that would be unsafe.
|
||||
*
|
||||
* @generated from protobuf rpc: DeleteAllPayments(lnrpc.DeleteAllPaymentsRequest) returns (lnrpc.DeleteAllPaymentsResponse);
|
||||
*/
|
||||
deleteAllPayments(input: DeleteAllPaymentsRequest, options?: RpcOptions): UnaryCall<DeleteAllPaymentsRequest, DeleteAllPaymentsResponse> {
|
||||
const method = this.methods[37], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[39], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<DeleteAllPaymentsRequest, DeleteAllPaymentsResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1265,7 +1383,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: DescribeGraph(lnrpc.ChannelGraphRequest) returns (lnrpc.ChannelGraph);
|
||||
*/
|
||||
describeGraph(input: ChannelGraphRequest, options?: RpcOptions): UnaryCall<ChannelGraphRequest, ChannelGraph> {
|
||||
const method = this.methods[38], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[40], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ChannelGraphRequest, ChannelGraph>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1276,7 +1394,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: GetNodeMetrics(lnrpc.NodeMetricsRequest) returns (lnrpc.NodeMetricsResponse);
|
||||
*/
|
||||
getNodeMetrics(input: NodeMetricsRequest, options?: RpcOptions): UnaryCall<NodeMetricsRequest, NodeMetricsResponse> {
|
||||
const method = this.methods[39], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[41], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<NodeMetricsRequest, NodeMetricsResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1289,7 +1407,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: GetChanInfo(lnrpc.ChanInfoRequest) returns (lnrpc.ChannelEdge);
|
||||
*/
|
||||
getChanInfo(input: ChanInfoRequest, options?: RpcOptions): UnaryCall<ChanInfoRequest, ChannelEdge> {
|
||||
const method = this.methods[40], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[42], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ChanInfoRequest, ChannelEdge>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1300,7 +1418,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: GetNodeInfo(lnrpc.NodeInfoRequest) returns (lnrpc.NodeInfo);
|
||||
*/
|
||||
getNodeInfo(input: NodeInfoRequest, options?: RpcOptions): UnaryCall<NodeInfoRequest, NodeInfo> {
|
||||
const method = this.methods[41], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[43], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<NodeInfoRequest, NodeInfo>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1319,7 +1437,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: QueryRoutes(lnrpc.QueryRoutesRequest) returns (lnrpc.QueryRoutesResponse);
|
||||
*/
|
||||
queryRoutes(input: QueryRoutesRequest, options?: RpcOptions): UnaryCall<QueryRoutesRequest, QueryRoutesResponse> {
|
||||
const method = this.methods[42], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[44], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<QueryRoutesRequest, QueryRoutesResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1330,7 +1448,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: GetNetworkInfo(lnrpc.NetworkInfoRequest) returns (lnrpc.NetworkInfo);
|
||||
*/
|
||||
getNetworkInfo(input: NetworkInfoRequest, options?: RpcOptions): UnaryCall<NetworkInfoRequest, NetworkInfo> {
|
||||
const method = this.methods[43], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[45], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<NetworkInfoRequest, NetworkInfo>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1341,7 +1459,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: StopDaemon(lnrpc.StopRequest) returns (lnrpc.StopResponse);
|
||||
*/
|
||||
stopDaemon(input: StopRequest, options?: RpcOptions): UnaryCall<StopRequest, StopResponse> {
|
||||
const method = this.methods[44], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[46], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StopRequest, StopResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1356,7 +1474,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: SubscribeChannelGraph(lnrpc.GraphTopologySubscription) returns (stream lnrpc.GraphTopologyUpdate);
|
||||
*/
|
||||
subscribeChannelGraph(input: GraphTopologySubscription, options?: RpcOptions): ServerStreamingCall<GraphTopologySubscription, GraphTopologyUpdate> {
|
||||
const method = this.methods[45], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[47], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<GraphTopologySubscription, GraphTopologyUpdate>("serverStreaming", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1369,7 +1487,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: DebugLevel(lnrpc.DebugLevelRequest) returns (lnrpc.DebugLevelResponse);
|
||||
*/
|
||||
debugLevel(input: DebugLevelRequest, options?: RpcOptions): UnaryCall<DebugLevelRequest, DebugLevelResponse> {
|
||||
const method = this.methods[46], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[48], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<DebugLevelRequest, DebugLevelResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1380,7 +1498,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: FeeReport(lnrpc.FeeReportRequest) returns (lnrpc.FeeReportResponse);
|
||||
*/
|
||||
feeReport(input: FeeReportRequest, options?: RpcOptions): UnaryCall<FeeReportRequest, FeeReportResponse> {
|
||||
const method = this.methods[47], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[49], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<FeeReportRequest, FeeReportResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1391,15 +1509,16 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: UpdateChannelPolicy(lnrpc.PolicyUpdateRequest) returns (lnrpc.PolicyUpdateResponse);
|
||||
*/
|
||||
updateChannelPolicy(input: PolicyUpdateRequest, options?: RpcOptions): UnaryCall<PolicyUpdateRequest, PolicyUpdateResponse> {
|
||||
const method = this.methods[48], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[50], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<PolicyUpdateRequest, PolicyUpdateResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* lncli: `fwdinghistory`
|
||||
* ForwardingHistory allows the caller to query the htlcswitch for a record of
|
||||
* all HTLCs forwarded within the target time range, and integer offset
|
||||
* within that time range. If no time-range is specified, then the first chunk
|
||||
* of the past 24 hrs of forwarding history are returned.
|
||||
* within that time range, for a maximum number of events. If no maximum number
|
||||
* of events is specified, up to 100 events will be returned. If no time-range
|
||||
* is specified, then events will be returned in the order that they occured.
|
||||
*
|
||||
* A list of forwarding events are returned. The size of each forwarding event
|
||||
* is 40 bytes, and the max message size able to be returned in gRPC is 4 MiB.
|
||||
|
|
@ -1410,7 +1529,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: ForwardingHistory(lnrpc.ForwardingHistoryRequest) returns (lnrpc.ForwardingHistoryResponse);
|
||||
*/
|
||||
forwardingHistory(input: ForwardingHistoryRequest, options?: RpcOptions): UnaryCall<ForwardingHistoryRequest, ForwardingHistoryResponse> {
|
||||
const method = this.methods[49], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[51], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ForwardingHistoryRequest, ForwardingHistoryResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1425,7 +1544,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: ExportChannelBackup(lnrpc.ExportChannelBackupRequest) returns (lnrpc.ChannelBackup);
|
||||
*/
|
||||
exportChannelBackup(input: ExportChannelBackupRequest, options?: RpcOptions): UnaryCall<ExportChannelBackupRequest, ChannelBackup> {
|
||||
const method = this.methods[50], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[52], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ExportChannelBackupRequest, ChannelBackup>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1439,7 +1558,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: ExportAllChannelBackups(lnrpc.ChanBackupExportRequest) returns (lnrpc.ChanBackupSnapshot);
|
||||
*/
|
||||
exportAllChannelBackups(input: ChanBackupExportRequest, options?: RpcOptions): UnaryCall<ChanBackupExportRequest, ChanBackupSnapshot> {
|
||||
const method = this.methods[51], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[53], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ChanBackupExportRequest, ChanBackupSnapshot>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1451,7 +1570,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: VerifyChanBackup(lnrpc.ChanBackupSnapshot) returns (lnrpc.VerifyChanBackupResponse);
|
||||
*/
|
||||
verifyChanBackup(input: ChanBackupSnapshot, options?: RpcOptions): UnaryCall<ChanBackupSnapshot, VerifyChanBackupResponse> {
|
||||
const method = this.methods[52], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[54], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ChanBackupSnapshot, VerifyChanBackupResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1464,7 +1583,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: RestoreChannelBackups(lnrpc.RestoreChanBackupRequest) returns (lnrpc.RestoreBackupResponse);
|
||||
*/
|
||||
restoreChannelBackups(input: RestoreChanBackupRequest, options?: RpcOptions): UnaryCall<RestoreChanBackupRequest, RestoreBackupResponse> {
|
||||
const method = this.methods[53], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[55], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<RestoreChanBackupRequest, RestoreBackupResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1480,7 +1599,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: SubscribeChannelBackups(lnrpc.ChannelBackupSubscription) returns (stream lnrpc.ChanBackupSnapshot);
|
||||
*/
|
||||
subscribeChannelBackups(input: ChannelBackupSubscription, options?: RpcOptions): ServerStreamingCall<ChannelBackupSubscription, ChanBackupSnapshot> {
|
||||
const method = this.methods[54], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[56], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ChannelBackupSubscription, ChanBackupSnapshot>("serverStreaming", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1492,7 +1611,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: BakeMacaroon(lnrpc.BakeMacaroonRequest) returns (lnrpc.BakeMacaroonResponse);
|
||||
*/
|
||||
bakeMacaroon(input: BakeMacaroonRequest, options?: RpcOptions): UnaryCall<BakeMacaroonRequest, BakeMacaroonResponse> {
|
||||
const method = this.methods[55], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[57], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<BakeMacaroonRequest, BakeMacaroonResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1502,7 +1621,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: ListMacaroonIDs(lnrpc.ListMacaroonIDsRequest) returns (lnrpc.ListMacaroonIDsResponse);
|
||||
*/
|
||||
listMacaroonIDs(input: ListMacaroonIDsRequest, options?: RpcOptions): UnaryCall<ListMacaroonIDsRequest, ListMacaroonIDsResponse> {
|
||||
const method = this.methods[56], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[58], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ListMacaroonIDsRequest, ListMacaroonIDsResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1513,7 +1632,7 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: DeleteMacaroonID(lnrpc.DeleteMacaroonIDRequest) returns (lnrpc.DeleteMacaroonIDResponse);
|
||||
*/
|
||||
deleteMacaroonID(input: DeleteMacaroonIDRequest, options?: RpcOptions): UnaryCall<DeleteMacaroonIDRequest, DeleteMacaroonIDResponse> {
|
||||
const method = this.methods[57], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[59], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<DeleteMacaroonIDRequest, DeleteMacaroonIDResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -1524,7 +1643,80 @@ export class LightningClient implements ILightningClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: ListPermissions(lnrpc.ListPermissionsRequest) returns (lnrpc.ListPermissionsResponse);
|
||||
*/
|
||||
listPermissions(input: ListPermissionsRequest, options?: RpcOptions): UnaryCall<ListPermissionsRequest, ListPermissionsResponse> {
|
||||
const method = this.methods[58], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[60], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ListPermissionsRequest, ListPermissionsResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
*
|
||||
* CheckMacaroonPermissions checks whether a request follows the constraints
|
||||
* imposed on the macaroon and that the macaroon is authorized to follow the
|
||||
* provided permissions.
|
||||
*
|
||||
* @generated from protobuf rpc: CheckMacaroonPermissions(lnrpc.CheckMacPermRequest) returns (lnrpc.CheckMacPermResponse);
|
||||
*/
|
||||
checkMacaroonPermissions(input: CheckMacPermRequest, options?: RpcOptions): UnaryCall<CheckMacPermRequest, CheckMacPermResponse> {
|
||||
const method = this.methods[61], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<CheckMacPermRequest, CheckMacPermResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
*
|
||||
* RegisterRPCMiddleware adds a new gRPC middleware to the interceptor chain. A
|
||||
* gRPC middleware is software component external to lnd that aims to add
|
||||
* additional business logic to lnd by observing/intercepting/validating
|
||||
* incoming gRPC client requests and (if needed) replacing/overwriting outgoing
|
||||
* messages before they're sent to the client. When registering the middleware
|
||||
* must identify itself and indicate what custom macaroon caveats it wants to
|
||||
* be responsible for. Only requests that contain a macaroon with that specific
|
||||
* custom caveat are then sent to the middleware for inspection. The other
|
||||
* option is to register for the read-only mode in which all requests/responses
|
||||
* are forwarded for interception to the middleware but the middleware is not
|
||||
* allowed to modify any responses. As a security measure, _no_ middleware can
|
||||
* modify responses for requests made with _unencumbered_ macaroons!
|
||||
*
|
||||
* @generated from protobuf rpc: RegisterRPCMiddleware(stream lnrpc.RPCMiddlewareResponse) returns (stream lnrpc.RPCMiddlewareRequest);
|
||||
*/
|
||||
registerRPCMiddleware(options?: RpcOptions): DuplexStreamingCall<RPCMiddlewareResponse, RPCMiddlewareRequest> {
|
||||
const method = this.methods[62], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<RPCMiddlewareResponse, RPCMiddlewareRequest>("duplex", this._transport, method, opt);
|
||||
}
|
||||
/**
|
||||
* lncli: `sendcustom`
|
||||
* SendCustomMessage sends a custom peer message.
|
||||
*
|
||||
* @generated from protobuf rpc: SendCustomMessage(lnrpc.SendCustomMessageRequest) returns (lnrpc.SendCustomMessageResponse);
|
||||
*/
|
||||
sendCustomMessage(input: SendCustomMessageRequest, options?: RpcOptions): UnaryCall<SendCustomMessageRequest, SendCustomMessageResponse> {
|
||||
const method = this.methods[63], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<SendCustomMessageRequest, SendCustomMessageResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* lncli: `subscribecustom`
|
||||
* SubscribeCustomMessages subscribes to a stream of incoming custom peer
|
||||
* messages.
|
||||
*
|
||||
* @generated from protobuf rpc: SubscribeCustomMessages(lnrpc.SubscribeCustomMessagesRequest) returns (stream lnrpc.CustomMessage);
|
||||
*/
|
||||
subscribeCustomMessages(input: SubscribeCustomMessagesRequest, options?: RpcOptions): ServerStreamingCall<SubscribeCustomMessagesRequest, CustomMessage> {
|
||||
const method = this.methods[64], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<SubscribeCustomMessagesRequest, CustomMessage>("serverStreaming", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* lncli: `listaliases`
|
||||
* ListAliases returns the set of all aliases that have ever existed with
|
||||
* their confirmed SCID (if it exists) and/or the base SCID (in the case of
|
||||
* zero conf).
|
||||
*
|
||||
* @generated from protobuf rpc: ListAliases(lnrpc.ListAliasesRequest) returns (lnrpc.ListAliasesResponse);
|
||||
*/
|
||||
listAliases(input: ListAliasesRequest, options?: RpcOptions): UnaryCall<ListAliasesRequest, ListAliasesResponse> {
|
||||
const method = this.methods[65], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ListAliasesRequest, ListAliasesResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: LookupHtlc(lnrpc.LookupHtlcRequest) returns (lnrpc.LookupHtlcResponse);
|
||||
*/
|
||||
lookupHtlc(input: LookupHtlcRequest, options?: RpcOptions): UnaryCall<LookupHtlcRequest, LookupHtlcResponse> {
|
||||
const method = this.methods[66], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<LookupHtlcRequest, LookupHtlcResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
}
|
||||
File diff suppressed because it is too large
Load diff
|
|
@ -1,4 +1,4 @@
|
|||
// @generated by protobuf-ts 2.5.0 with parameter long_type_string
|
||||
// @generated by protobuf-ts 2.5.0
|
||||
// @generated from protobuf file "router.proto" (package "routerrpc", syntax proto3)
|
||||
// tslint:disable
|
||||
import type { RpcTransport } from "@protobuf-ts/runtime-rpc";
|
||||
|
|
@ -26,15 +26,16 @@ import type { QueryMissionControlResponse } from "./router";
|
|||
import type { QueryMissionControlRequest } from "./router";
|
||||
import type { ResetMissionControlResponse } from "./router";
|
||||
import type { ResetMissionControlRequest } from "./router";
|
||||
import type { HTLCAttempt } from "./rpc";
|
||||
import type { HTLCAttempt } from "./lightning";
|
||||
import type { SendToRouteResponse } from "./router";
|
||||
import type { SendToRouteRequest } from "./router";
|
||||
import type { RouteFeeResponse } from "./router";
|
||||
import type { RouteFeeRequest } from "./router";
|
||||
import type { UnaryCall } from "@protobuf-ts/runtime-rpc";
|
||||
import type { TrackPaymentsRequest } from "./router";
|
||||
import type { TrackPaymentRequest } from "./router";
|
||||
import { stackIntercept } from "@protobuf-ts/runtime-rpc";
|
||||
import type { Payment } from "./rpc";
|
||||
import type { Payment } from "./lightning";
|
||||
import type { SendPaymentRequest } from "./router";
|
||||
import type { ServerStreamingCall } from "@protobuf-ts/runtime-rpc";
|
||||
import type { RpcOptions } from "@protobuf-ts/runtime-rpc";
|
||||
|
|
@ -62,6 +63,18 @@ export interface IRouterClient {
|
|||
* @generated from protobuf rpc: TrackPaymentV2(routerrpc.TrackPaymentRequest) returns (stream lnrpc.Payment);
|
||||
*/
|
||||
trackPaymentV2(input: TrackPaymentRequest, options?: RpcOptions): ServerStreamingCall<TrackPaymentRequest, Payment>;
|
||||
/**
|
||||
*
|
||||
* TrackPayments returns an update stream for every payment that is not in a
|
||||
* terminal state. Note that if payments are in-flight while starting a new
|
||||
* subscription, the start of the payment stream could produce out-of-order
|
||||
* and/or duplicate events. In order to get updates for every in-flight
|
||||
* payment attempt make sure to subscribe to this method before initiating any
|
||||
* payments.
|
||||
*
|
||||
* @generated from protobuf rpc: TrackPayments(routerrpc.TrackPaymentsRequest) returns (stream lnrpc.Payment);
|
||||
*/
|
||||
trackPayments(input: TrackPaymentsRequest, options?: RpcOptions): ServerStreamingCall<TrackPaymentsRequest, Payment>;
|
||||
/**
|
||||
*
|
||||
* EstimateRouteFee allows callers to obtain a lower bound w.r.t how much it
|
||||
|
|
@ -234,6 +247,21 @@ export class RouterClient implements IRouterClient, ServiceInfo {
|
|||
const method = this.methods[1], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<TrackPaymentRequest, Payment>("serverStreaming", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
*
|
||||
* TrackPayments returns an update stream for every payment that is not in a
|
||||
* terminal state. Note that if payments are in-flight while starting a new
|
||||
* subscription, the start of the payment stream could produce out-of-order
|
||||
* and/or duplicate events. In order to get updates for every in-flight
|
||||
* payment attempt make sure to subscribe to this method before initiating any
|
||||
* payments.
|
||||
*
|
||||
* @generated from protobuf rpc: TrackPayments(routerrpc.TrackPaymentsRequest) returns (stream lnrpc.Payment);
|
||||
*/
|
||||
trackPayments(input: TrackPaymentsRequest, options?: RpcOptions): ServerStreamingCall<TrackPaymentsRequest, Payment> {
|
||||
const method = this.methods[2], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<TrackPaymentsRequest, Payment>("serverStreaming", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
*
|
||||
* EstimateRouteFee allows callers to obtain a lower bound w.r.t how much it
|
||||
|
|
@ -242,7 +270,7 @@ export class RouterClient implements IRouterClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: EstimateRouteFee(routerrpc.RouteFeeRequest) returns (routerrpc.RouteFeeResponse);
|
||||
*/
|
||||
estimateRouteFee(input: RouteFeeRequest, options?: RpcOptions): UnaryCall<RouteFeeRequest, RouteFeeResponse> {
|
||||
const method = this.methods[2], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[3], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<RouteFeeRequest, RouteFeeResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -257,7 +285,7 @@ export class RouterClient implements IRouterClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: SendToRoute(routerrpc.SendToRouteRequest) returns (routerrpc.SendToRouteResponse);
|
||||
*/
|
||||
sendToRoute(input: SendToRouteRequest, options?: RpcOptions): UnaryCall<SendToRouteRequest, SendToRouteResponse> {
|
||||
const method = this.methods[3], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[4], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<SendToRouteRequest, SendToRouteResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -270,7 +298,7 @@ export class RouterClient implements IRouterClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: SendToRouteV2(routerrpc.SendToRouteRequest) returns (lnrpc.HTLCAttempt);
|
||||
*/
|
||||
sendToRouteV2(input: SendToRouteRequest, options?: RpcOptions): UnaryCall<SendToRouteRequest, HTLCAttempt> {
|
||||
const method = this.methods[4], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[5], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<SendToRouteRequest, HTLCAttempt>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -281,7 +309,7 @@ export class RouterClient implements IRouterClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: ResetMissionControl(routerrpc.ResetMissionControlRequest) returns (routerrpc.ResetMissionControlResponse);
|
||||
*/
|
||||
resetMissionControl(input: ResetMissionControlRequest, options?: RpcOptions): UnaryCall<ResetMissionControlRequest, ResetMissionControlResponse> {
|
||||
const method = this.methods[5], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[6], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ResetMissionControlRequest, ResetMissionControlResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -292,7 +320,7 @@ export class RouterClient implements IRouterClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: QueryMissionControl(routerrpc.QueryMissionControlRequest) returns (routerrpc.QueryMissionControlResponse);
|
||||
*/
|
||||
queryMissionControl(input: QueryMissionControlRequest, options?: RpcOptions): UnaryCall<QueryMissionControlRequest, QueryMissionControlResponse> {
|
||||
const method = this.methods[6], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[7], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<QueryMissionControlRequest, QueryMissionControlResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -305,7 +333,7 @@ export class RouterClient implements IRouterClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: XImportMissionControl(routerrpc.XImportMissionControlRequest) returns (routerrpc.XImportMissionControlResponse);
|
||||
*/
|
||||
xImportMissionControl(input: XImportMissionControlRequest, options?: RpcOptions): UnaryCall<XImportMissionControlRequest, XImportMissionControlResponse> {
|
||||
const method = this.methods[7], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[8], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<XImportMissionControlRequest, XImportMissionControlResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -315,7 +343,7 @@ export class RouterClient implements IRouterClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: GetMissionControlConfig(routerrpc.GetMissionControlConfigRequest) returns (routerrpc.GetMissionControlConfigResponse);
|
||||
*/
|
||||
getMissionControlConfig(input: GetMissionControlConfigRequest, options?: RpcOptions): UnaryCall<GetMissionControlConfigRequest, GetMissionControlConfigResponse> {
|
||||
const method = this.methods[8], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[9], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<GetMissionControlConfigRequest, GetMissionControlConfigResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -326,7 +354,7 @@ export class RouterClient implements IRouterClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: SetMissionControlConfig(routerrpc.SetMissionControlConfigRequest) returns (routerrpc.SetMissionControlConfigResponse);
|
||||
*/
|
||||
setMissionControlConfig(input: SetMissionControlConfigRequest, options?: RpcOptions): UnaryCall<SetMissionControlConfigRequest, SetMissionControlConfigResponse> {
|
||||
const method = this.methods[9], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[10], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<SetMissionControlConfigRequest, SetMissionControlConfigResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -337,7 +365,7 @@ export class RouterClient implements IRouterClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: QueryProbability(routerrpc.QueryProbabilityRequest) returns (routerrpc.QueryProbabilityResponse);
|
||||
*/
|
||||
queryProbability(input: QueryProbabilityRequest, options?: RpcOptions): UnaryCall<QueryProbabilityRequest, QueryProbabilityResponse> {
|
||||
const method = this.methods[10], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[11], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<QueryProbabilityRequest, QueryProbabilityResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -349,7 +377,7 @@ export class RouterClient implements IRouterClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: BuildRoute(routerrpc.BuildRouteRequest) returns (routerrpc.BuildRouteResponse);
|
||||
*/
|
||||
buildRoute(input: BuildRouteRequest, options?: RpcOptions): UnaryCall<BuildRouteRequest, BuildRouteResponse> {
|
||||
const method = this.methods[11], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[12], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<BuildRouteRequest, BuildRouteResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -360,7 +388,7 @@ export class RouterClient implements IRouterClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: SubscribeHtlcEvents(routerrpc.SubscribeHtlcEventsRequest) returns (stream routerrpc.HtlcEvent);
|
||||
*/
|
||||
subscribeHtlcEvents(input: SubscribeHtlcEventsRequest, options?: RpcOptions): ServerStreamingCall<SubscribeHtlcEventsRequest, HtlcEvent> {
|
||||
const method = this.methods[12], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[13], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<SubscribeHtlcEventsRequest, HtlcEvent>("serverStreaming", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -373,7 +401,7 @@ export class RouterClient implements IRouterClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: SendPayment(routerrpc.SendPaymentRequest) returns (stream routerrpc.PaymentStatus);
|
||||
*/
|
||||
sendPayment(input: SendPaymentRequest, options?: RpcOptions): ServerStreamingCall<SendPaymentRequest, PaymentStatus> {
|
||||
const method = this.methods[13], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[14], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<SendPaymentRequest, PaymentStatus>("serverStreaming", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -385,7 +413,7 @@ export class RouterClient implements IRouterClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: TrackPayment(routerrpc.TrackPaymentRequest) returns (stream routerrpc.PaymentStatus);
|
||||
*/
|
||||
trackPayment(input: TrackPaymentRequest, options?: RpcOptions): ServerStreamingCall<TrackPaymentRequest, PaymentStatus> {
|
||||
const method = this.methods[14], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[15], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<TrackPaymentRequest, PaymentStatus>("serverStreaming", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
|
|
@ -399,7 +427,7 @@ export class RouterClient implements IRouterClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: HtlcInterceptor(stream routerrpc.ForwardHtlcInterceptResponse) returns (stream routerrpc.ForwardHtlcInterceptRequest);
|
||||
*/
|
||||
htlcInterceptor(options?: RpcOptions): DuplexStreamingCall<ForwardHtlcInterceptResponse, ForwardHtlcInterceptRequest> {
|
||||
const method = this.methods[15], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[16], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ForwardHtlcInterceptResponse, ForwardHtlcInterceptRequest>("duplex", this._transport, method, opt);
|
||||
}
|
||||
/**
|
||||
|
|
@ -412,7 +440,7 @@ export class RouterClient implements IRouterClient, ServiceInfo {
|
|||
* @generated from protobuf rpc: UpdateChanStatus(routerrpc.UpdateChanStatusRequest) returns (routerrpc.UpdateChanStatusResponse);
|
||||
*/
|
||||
updateChanStatus(input: UpdateChanStatusRequest, options?: RpcOptions): UnaryCall<UpdateChanStatusRequest, UpdateChanStatusResponse> {
|
||||
const method = this.methods[16], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[17], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<UpdateChanStatusRequest, UpdateChanStatusResponse>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
}
|
||||
|
|
|
|||
File diff suppressed because it is too large
Load diff
Loading…
Add table
Add a link
Reference in a new issue