types: add generated code from proto compilation to git

To remove the need for installing protoc for building the source from
scratch, we check in the generated JavaScript and TypeScript code that
is compiled from the *.proto files.
We will make sure the protos and generated files are in sync with the
help of a GitHub Action.
By adding a .gitattributes file we also make sure the committed
generated JS code does not count towards GitHub's language statistics of
the repo.
This commit is contained in:
Oliver Gugger 2020-12-09 17:47:11 +01:00
parent f0be051181
commit 47a435944d
No known key found for this signature in database
GPG key ID: 8E4256593F177720
26 changed files with 84017 additions and 3 deletions

5
.gitattributes vendored Normal file
View file

@ -0,0 +1,5 @@
# Instruct the GitHub linguist tool to interpret the generated JS code as just
# that, generated. This will make sure the JS (and TS types for that matter)
# will not show up in the repository's language statistics.
app/src/types/generated* linguist-generated

3
.gitignore vendored
View file

@ -1,6 +1,3 @@
# generated proto scripts
/app/src/types/generated
# local environment vars to ignore
.env*.local

1892
app/src/types/generated/auctioneer_pb.d.ts vendored Normal file

File diff suppressed because it is too large Load diff

File diff suppressed because it is too large Load diff

View file

@ -0,0 +1,245 @@
// package: poolrpc
// file: auctioneer.proto
import * as auctioneer_pb from "./auctioneer_pb";
import {grpc} from "@improbable-eng/grpc-web";
type ChannelAuctioneerReserveAccount = {
readonly methodName: string;
readonly service: typeof ChannelAuctioneer;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof auctioneer_pb.ReserveAccountRequest;
readonly responseType: typeof auctioneer_pb.ReserveAccountResponse;
};
type ChannelAuctioneerInitAccount = {
readonly methodName: string;
readonly service: typeof ChannelAuctioneer;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof auctioneer_pb.ServerInitAccountRequest;
readonly responseType: typeof auctioneer_pb.ServerInitAccountResponse;
};
type ChannelAuctioneerModifyAccount = {
readonly methodName: string;
readonly service: typeof ChannelAuctioneer;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof auctioneer_pb.ServerModifyAccountRequest;
readonly responseType: typeof auctioneer_pb.ServerModifyAccountResponse;
};
type ChannelAuctioneerSubmitOrder = {
readonly methodName: string;
readonly service: typeof ChannelAuctioneer;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof auctioneer_pb.ServerSubmitOrderRequest;
readonly responseType: typeof auctioneer_pb.ServerSubmitOrderResponse;
};
type ChannelAuctioneerCancelOrder = {
readonly methodName: string;
readonly service: typeof ChannelAuctioneer;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof auctioneer_pb.ServerCancelOrderRequest;
readonly responseType: typeof auctioneer_pb.ServerCancelOrderResponse;
};
type ChannelAuctioneerOrderState = {
readonly methodName: string;
readonly service: typeof ChannelAuctioneer;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof auctioneer_pb.ServerOrderStateRequest;
readonly responseType: typeof auctioneer_pb.ServerOrderStateResponse;
};
type ChannelAuctioneerSubscribeBatchAuction = {
readonly methodName: string;
readonly service: typeof ChannelAuctioneer;
readonly requestStream: true;
readonly responseStream: true;
readonly requestType: typeof auctioneer_pb.ClientAuctionMessage;
readonly responseType: typeof auctioneer_pb.ServerAuctionMessage;
};
type ChannelAuctioneerTerms = {
readonly methodName: string;
readonly service: typeof ChannelAuctioneer;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof auctioneer_pb.TermsRequest;
readonly responseType: typeof auctioneer_pb.TermsResponse;
};
type ChannelAuctioneerRelevantBatchSnapshot = {
readonly methodName: string;
readonly service: typeof ChannelAuctioneer;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof auctioneer_pb.RelevantBatchRequest;
readonly responseType: typeof auctioneer_pb.RelevantBatch;
};
type ChannelAuctioneerBatchSnapshot = {
readonly methodName: string;
readonly service: typeof ChannelAuctioneer;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof auctioneer_pb.BatchSnapshotRequest;
readonly responseType: typeof auctioneer_pb.BatchSnapshotResponse;
};
type ChannelAuctioneerNodeRating = {
readonly methodName: string;
readonly service: typeof ChannelAuctioneer;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof auctioneer_pb.ServerNodeRatingRequest;
readonly responseType: typeof auctioneer_pb.ServerNodeRatingResponse;
};
export class ChannelAuctioneer {
static readonly serviceName: string;
static readonly ReserveAccount: ChannelAuctioneerReserveAccount;
static readonly InitAccount: ChannelAuctioneerInitAccount;
static readonly ModifyAccount: ChannelAuctioneerModifyAccount;
static readonly SubmitOrder: ChannelAuctioneerSubmitOrder;
static readonly CancelOrder: ChannelAuctioneerCancelOrder;
static readonly OrderState: ChannelAuctioneerOrderState;
static readonly SubscribeBatchAuction: ChannelAuctioneerSubscribeBatchAuction;
static readonly Terms: ChannelAuctioneerTerms;
static readonly RelevantBatchSnapshot: ChannelAuctioneerRelevantBatchSnapshot;
static readonly BatchSnapshot: ChannelAuctioneerBatchSnapshot;
static readonly NodeRating: ChannelAuctioneerNodeRating;
}
export type ServiceError = { message: string, code: number; metadata: grpc.Metadata }
export type Status = { details: string, code: number; metadata: grpc.Metadata }
interface UnaryResponse {
cancel(): void;
}
interface ResponseStream<T> {
cancel(): void;
on(type: 'data', handler: (message: T) => void): ResponseStream<T>;
on(type: 'end', handler: (status?: Status) => void): ResponseStream<T>;
on(type: 'status', handler: (status: Status) => void): ResponseStream<T>;
}
interface RequestStream<T> {
write(message: T): RequestStream<T>;
end(): void;
cancel(): void;
on(type: 'end', handler: (status?: Status) => void): RequestStream<T>;
on(type: 'status', handler: (status: Status) => void): RequestStream<T>;
}
interface BidirectionalStream<ReqT, ResT> {
write(message: ReqT): BidirectionalStream<ReqT, ResT>;
end(): void;
cancel(): void;
on(type: 'data', handler: (message: ResT) => void): BidirectionalStream<ReqT, ResT>;
on(type: 'end', handler: (status?: Status) => void): BidirectionalStream<ReqT, ResT>;
on(type: 'status', handler: (status: Status) => void): BidirectionalStream<ReqT, ResT>;
}
export class ChannelAuctioneerClient {
readonly serviceHost: string;
constructor(serviceHost: string, options?: grpc.RpcOptions);
reserveAccount(
requestMessage: auctioneer_pb.ReserveAccountRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.ReserveAccountResponse|null) => void
): UnaryResponse;
reserveAccount(
requestMessage: auctioneer_pb.ReserveAccountRequest,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.ReserveAccountResponse|null) => void
): UnaryResponse;
initAccount(
requestMessage: auctioneer_pb.ServerInitAccountRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.ServerInitAccountResponse|null) => void
): UnaryResponse;
initAccount(
requestMessage: auctioneer_pb.ServerInitAccountRequest,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.ServerInitAccountResponse|null) => void
): UnaryResponse;
modifyAccount(
requestMessage: auctioneer_pb.ServerModifyAccountRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.ServerModifyAccountResponse|null) => void
): UnaryResponse;
modifyAccount(
requestMessage: auctioneer_pb.ServerModifyAccountRequest,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.ServerModifyAccountResponse|null) => void
): UnaryResponse;
submitOrder(
requestMessage: auctioneer_pb.ServerSubmitOrderRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.ServerSubmitOrderResponse|null) => void
): UnaryResponse;
submitOrder(
requestMessage: auctioneer_pb.ServerSubmitOrderRequest,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.ServerSubmitOrderResponse|null) => void
): UnaryResponse;
cancelOrder(
requestMessage: auctioneer_pb.ServerCancelOrderRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.ServerCancelOrderResponse|null) => void
): UnaryResponse;
cancelOrder(
requestMessage: auctioneer_pb.ServerCancelOrderRequest,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.ServerCancelOrderResponse|null) => void
): UnaryResponse;
orderState(
requestMessage: auctioneer_pb.ServerOrderStateRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.ServerOrderStateResponse|null) => void
): UnaryResponse;
orderState(
requestMessage: auctioneer_pb.ServerOrderStateRequest,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.ServerOrderStateResponse|null) => void
): UnaryResponse;
subscribeBatchAuction(metadata?: grpc.Metadata): BidirectionalStream<auctioneer_pb.ClientAuctionMessage, auctioneer_pb.ServerAuctionMessage>;
terms(
requestMessage: auctioneer_pb.TermsRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.TermsResponse|null) => void
): UnaryResponse;
terms(
requestMessage: auctioneer_pb.TermsRequest,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.TermsResponse|null) => void
): UnaryResponse;
relevantBatchSnapshot(
requestMessage: auctioneer_pb.RelevantBatchRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.RelevantBatch|null) => void
): UnaryResponse;
relevantBatchSnapshot(
requestMessage: auctioneer_pb.RelevantBatchRequest,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.RelevantBatch|null) => void
): UnaryResponse;
batchSnapshot(
requestMessage: auctioneer_pb.BatchSnapshotRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.BatchSnapshotResponse|null) => void
): UnaryResponse;
batchSnapshot(
requestMessage: auctioneer_pb.BatchSnapshotRequest,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.BatchSnapshotResponse|null) => void
): UnaryResponse;
nodeRating(
requestMessage: auctioneer_pb.ServerNodeRatingRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.ServerNodeRatingResponse|null) => void
): UnaryResponse;
nodeRating(
requestMessage: auctioneer_pb.ServerNodeRatingRequest,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.ServerNodeRatingResponse|null) => void
): UnaryResponse;
}

View file

@ -0,0 +1,475 @@
// package: poolrpc
// file: auctioneer.proto
var auctioneer_pb = require("./auctioneer_pb");
var grpc = require("@improbable-eng/grpc-web").grpc;
var ChannelAuctioneer = (function () {
function ChannelAuctioneer() {}
ChannelAuctioneer.serviceName = "poolrpc.ChannelAuctioneer";
return ChannelAuctioneer;
}());
ChannelAuctioneer.ReserveAccount = {
methodName: "ReserveAccount",
service: ChannelAuctioneer,
requestStream: false,
responseStream: false,
requestType: auctioneer_pb.ReserveAccountRequest,
responseType: auctioneer_pb.ReserveAccountResponse
};
ChannelAuctioneer.InitAccount = {
methodName: "InitAccount",
service: ChannelAuctioneer,
requestStream: false,
responseStream: false,
requestType: auctioneer_pb.ServerInitAccountRequest,
responseType: auctioneer_pb.ServerInitAccountResponse
};
ChannelAuctioneer.ModifyAccount = {
methodName: "ModifyAccount",
service: ChannelAuctioneer,
requestStream: false,
responseStream: false,
requestType: auctioneer_pb.ServerModifyAccountRequest,
responseType: auctioneer_pb.ServerModifyAccountResponse
};
ChannelAuctioneer.SubmitOrder = {
methodName: "SubmitOrder",
service: ChannelAuctioneer,
requestStream: false,
responseStream: false,
requestType: auctioneer_pb.ServerSubmitOrderRequest,
responseType: auctioneer_pb.ServerSubmitOrderResponse
};
ChannelAuctioneer.CancelOrder = {
methodName: "CancelOrder",
service: ChannelAuctioneer,
requestStream: false,
responseStream: false,
requestType: auctioneer_pb.ServerCancelOrderRequest,
responseType: auctioneer_pb.ServerCancelOrderResponse
};
ChannelAuctioneer.OrderState = {
methodName: "OrderState",
service: ChannelAuctioneer,
requestStream: false,
responseStream: false,
requestType: auctioneer_pb.ServerOrderStateRequest,
responseType: auctioneer_pb.ServerOrderStateResponse
};
ChannelAuctioneer.SubscribeBatchAuction = {
methodName: "SubscribeBatchAuction",
service: ChannelAuctioneer,
requestStream: true,
responseStream: true,
requestType: auctioneer_pb.ClientAuctionMessage,
responseType: auctioneer_pb.ServerAuctionMessage
};
ChannelAuctioneer.Terms = {
methodName: "Terms",
service: ChannelAuctioneer,
requestStream: false,
responseStream: false,
requestType: auctioneer_pb.TermsRequest,
responseType: auctioneer_pb.TermsResponse
};
ChannelAuctioneer.RelevantBatchSnapshot = {
methodName: "RelevantBatchSnapshot",
service: ChannelAuctioneer,
requestStream: false,
responseStream: false,
requestType: auctioneer_pb.RelevantBatchRequest,
responseType: auctioneer_pb.RelevantBatch
};
ChannelAuctioneer.BatchSnapshot = {
methodName: "BatchSnapshot",
service: ChannelAuctioneer,
requestStream: false,
responseStream: false,
requestType: auctioneer_pb.BatchSnapshotRequest,
responseType: auctioneer_pb.BatchSnapshotResponse
};
ChannelAuctioneer.NodeRating = {
methodName: "NodeRating",
service: ChannelAuctioneer,
requestStream: false,
responseStream: false,
requestType: auctioneer_pb.ServerNodeRatingRequest,
responseType: auctioneer_pb.ServerNodeRatingResponse
};
exports.ChannelAuctioneer = ChannelAuctioneer;
function ChannelAuctioneerClient(serviceHost, options) {
this.serviceHost = serviceHost;
this.options = options || {};
}
ChannelAuctioneerClient.prototype.reserveAccount = function reserveAccount(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(ChannelAuctioneer.ReserveAccount, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
ChannelAuctioneerClient.prototype.initAccount = function initAccount(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(ChannelAuctioneer.InitAccount, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
ChannelAuctioneerClient.prototype.modifyAccount = function modifyAccount(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(ChannelAuctioneer.ModifyAccount, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
ChannelAuctioneerClient.prototype.submitOrder = function submitOrder(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(ChannelAuctioneer.SubmitOrder, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
ChannelAuctioneerClient.prototype.cancelOrder = function cancelOrder(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(ChannelAuctioneer.CancelOrder, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
ChannelAuctioneerClient.prototype.orderState = function orderState(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(ChannelAuctioneer.OrderState, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
ChannelAuctioneerClient.prototype.subscribeBatchAuction = function subscribeBatchAuction(metadata) {
var listeners = {
data: [],
end: [],
status: []
};
var client = grpc.client(ChannelAuctioneer.SubscribeBatchAuction, {
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport
});
client.onEnd(function (status, statusMessage, trailers) {
listeners.status.forEach(function (handler) {
handler({ code: status, details: statusMessage, metadata: trailers });
});
listeners.end.forEach(function (handler) {
handler({ code: status, details: statusMessage, metadata: trailers });
});
listeners = null;
});
client.onMessage(function (message) {
listeners.data.forEach(function (handler) {
handler(message);
})
});
client.start(metadata);
return {
on: function (type, handler) {
listeners[type].push(handler);
return this;
},
write: function (requestMessage) {
client.send(requestMessage);
return this;
},
end: function () {
client.finishSend();
},
cancel: function () {
listeners = null;
client.close();
}
};
};
ChannelAuctioneerClient.prototype.terms = function terms(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(ChannelAuctioneer.Terms, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
ChannelAuctioneerClient.prototype.relevantBatchSnapshot = function relevantBatchSnapshot(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(ChannelAuctioneer.RelevantBatchSnapshot, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
ChannelAuctioneerClient.prototype.batchSnapshot = function batchSnapshot(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(ChannelAuctioneer.BatchSnapshot, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
ChannelAuctioneerClient.prototype.nodeRating = function nodeRating(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(ChannelAuctioneer.NodeRating, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
exports.ChannelAuctioneerClient = ChannelAuctioneerClient;

View file

@ -0,0 +1,9 @@
// package: google.api
// file: google/api/annotations.proto
import * as jspb from "google-protobuf";
import * as google_api_http_pb from "../../google/api/http_pb";
import * as google_protobuf_descriptor_pb from "google-protobuf/google/protobuf/descriptor_pb";
export const http: jspb.ExtensionFieldInfo<google_api_http_pb.HttpRule>;

View file

@ -0,0 +1,45 @@
/* eslint-disable */
var proto = { google: { api: {} } };
/**
* @fileoverview
* @enhanceable
* @suppress {messageConventions} JS Compiler reports an error if a variable or
* field starts with 'MSG_' and isn't a translatable message.
* @public
*/
// GENERATED CODE -- DO NOT EDIT!
var jspb = require('google-protobuf');
var goog = jspb;
var global = Function('return this')();
var google_api_http_pb = require('../../google/api/http_pb.js');
var google_protobuf_descriptor_pb = require('google-protobuf/google/protobuf/descriptor_pb.js');
goog.exportSymbol('proto.google.api.http', null, global);
/**
* A tuple of {field number, class constructor} for the extension
* field named `http`.
* @type {!jspb.ExtensionFieldInfo.<!proto.google.api.HttpRule>}
*/
proto.google.api.http = new jspb.ExtensionFieldInfo(
72295728,
{http: 0},
google_api_http_pb.HttpRule,
/** @type {?function((boolean|undefined),!jspb.Message=): !Object} */ (
google_api_http_pb.HttpRule.toObject),
0);
google_protobuf_descriptor_pb.MethodOptions.extensionsBinary[72295728] = new jspb.ExtensionFieldBinaryInfo(
proto.google.api.http,
jspb.BinaryReader.prototype.readMessage,
jspb.BinaryWriter.prototype.writeMessage,
google_api_http_pb.HttpRule.serializeBinaryToWriter,
google_api_http_pb.HttpRule.deserializeBinaryFromReader,
false);
// This registers the extension field with the extended class, so that
// toObject() will function correctly.
google_protobuf_descriptor_pb.MethodOptions.extensions[72295728] = proto.google.api.http;
goog.object.extend(exports, proto.google.api);

View file

@ -0,0 +1,3 @@
// package: google.api
// file: google/api/annotations.proto

View file

@ -0,0 +1,3 @@
// package: google.api
// file: google/api/annotations.proto

View file

@ -0,0 +1,136 @@
// package: google.api
// file: google/api/http.proto
import * as jspb from "google-protobuf";
export class Http extends jspb.Message {
clearRulesList(): void;
getRulesList(): Array<HttpRule>;
setRulesList(value: Array<HttpRule>): void;
addRules(value?: HttpRule, index?: number): HttpRule;
getFullyDecodeReservedExpansion(): boolean;
setFullyDecodeReservedExpansion(value: boolean): void;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): Http.AsObject;
static toObject(includeInstance: boolean, msg: Http): Http.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: Http, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): Http;
static deserializeBinaryFromReader(message: Http, reader: jspb.BinaryReader): Http;
}
export namespace Http {
export type AsObject = {
rulesList: Array<HttpRule.AsObject>,
fullyDecodeReservedExpansion: boolean,
}
}
export class HttpRule extends jspb.Message {
getSelector(): string;
setSelector(value: string): void;
hasGet(): boolean;
clearGet(): void;
getGet(): string;
setGet(value: string): void;
hasPut(): boolean;
clearPut(): void;
getPut(): string;
setPut(value: string): void;
hasPost(): boolean;
clearPost(): void;
getPost(): string;
setPost(value: string): void;
hasDelete(): boolean;
clearDelete(): void;
getDelete(): string;
setDelete(value: string): void;
hasPatch(): boolean;
clearPatch(): void;
getPatch(): string;
setPatch(value: string): void;
hasCustom(): boolean;
clearCustom(): void;
getCustom(): CustomHttpPattern | undefined;
setCustom(value?: CustomHttpPattern): void;
getBody(): string;
setBody(value: string): void;
getResponseBody(): string;
setResponseBody(value: string): void;
clearAdditionalBindingsList(): void;
getAdditionalBindingsList(): Array<HttpRule>;
setAdditionalBindingsList(value: Array<HttpRule>): void;
addAdditionalBindings(value?: HttpRule, index?: number): HttpRule;
getPatternCase(): HttpRule.PatternCase;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): HttpRule.AsObject;
static toObject(includeInstance: boolean, msg: HttpRule): HttpRule.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: HttpRule, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): HttpRule;
static deserializeBinaryFromReader(message: HttpRule, reader: jspb.BinaryReader): HttpRule;
}
export namespace HttpRule {
export type AsObject = {
selector: string,
get: string,
put: string,
post: string,
pb_delete: string,
patch: string,
custom?: CustomHttpPattern.AsObject,
body: string,
responseBody: string,
additionalBindingsList: Array<HttpRule.AsObject>,
}
export enum PatternCase {
PATTERN_NOT_SET = 0,
GET = 2,
PUT = 3,
POST = 4,
DELETE = 5,
PATCH = 6,
CUSTOM = 8,
}
}
export class CustomHttpPattern extends jspb.Message {
getKind(): string;
setKind(value: string): void;
getPath(): string;
setPath(value: string): void;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): CustomHttpPattern.AsObject;
static toObject(includeInstance: boolean, msg: CustomHttpPattern): CustomHttpPattern.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: CustomHttpPattern, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): CustomHttpPattern;
static deserializeBinaryFromReader(message: CustomHttpPattern, reader: jspb.BinaryReader): CustomHttpPattern;
}
export namespace CustomHttpPattern {
export type AsObject = {
kind: string,
path: string,
}
}

View file

@ -0,0 +1,914 @@
/* eslint-disable */
var proto = { google: { api: {} } };
/**
* @fileoverview
* @enhanceable
* @suppress {messageConventions} JS Compiler reports an error if a variable or
* field starts with 'MSG_' and isn't a translatable message.
* @public
*/
// GENERATED CODE -- DO NOT EDIT!
var jspb = require('google-protobuf');
var goog = jspb;
var global = Function('return this')();
goog.exportSymbol('proto.google.api.CustomHttpPattern', null, global);
goog.exportSymbol('proto.google.api.Http', null, global);
goog.exportSymbol('proto.google.api.HttpRule', null, global);
/**
* Generated by JsPbCodeGenerator.
* @param {Array=} opt_data Optional initial data array, typically from a
* server response, or constructed directly in Javascript. The array is used
* in place and becomes part of the constructed object. It is not cloned.
* If no data is provided, the constructed object will be empty, but still
* valid.
* @extends {jspb.Message}
* @constructor
*/
proto.google.api.Http = function(opt_data) {
jspb.Message.initialize(this, opt_data, 0, -1, proto.google.api.Http.repeatedFields_, null);
};
goog.inherits(proto.google.api.Http, jspb.Message);
if (goog.DEBUG && !COMPILED) {
proto.google.api.Http.displayName = 'proto.google.api.Http';
}
/**
* List of repeated fields within this message type.
* @private {!Array<number>}
* @const
*/
proto.google.api.Http.repeatedFields_ = [1];
if (jspb.Message.GENERATE_TO_OBJECT) {
/**
* Creates an object representation of this proto suitable for use in Soy templates.
* Field names that are reserved in JavaScript and will be renamed to pb_name.
* To access a reserved field use, foo.pb_<name>, eg, foo.pb_default.
* For the list of reserved names please see:
* com.google.apps.jspb.JsClassTemplate.JS_RESERVED_WORDS.
* @param {boolean=} opt_includeInstance Whether to include the JSPB instance
* for transitional soy proto support: http://goto/soy-param-migration
* @return {!Object}
*/
proto.google.api.Http.prototype.toObject = function(opt_includeInstance) {
return proto.google.api.Http.toObject(opt_includeInstance, this);
};
/**
* Static version of the {@see toObject} method.
* @param {boolean|undefined} includeInstance Whether to include the JSPB
* instance for transitional soy proto support:
* http://goto/soy-param-migration
* @param {!proto.google.api.Http} msg The msg instance to transform.
* @return {!Object}
* @suppress {unusedLocalVariables} f is only used for nested messages
*/
proto.google.api.Http.toObject = function(includeInstance, msg) {
var f, obj = {
rulesList: jspb.Message.toObjectList(msg.getRulesList(),
proto.google.api.HttpRule.toObject, includeInstance),
fullyDecodeReservedExpansion: jspb.Message.getFieldWithDefault(msg, 2, false)
};
if (includeInstance) {
obj.$jspbMessageInstance = msg;
}
return obj;
};
}
/**
* Deserializes binary data (in protobuf wire format).
* @param {jspb.ByteSource} bytes The bytes to deserialize.
* @return {!proto.google.api.Http}
*/
proto.google.api.Http.deserializeBinary = function(bytes) {
var reader = new jspb.BinaryReader(bytes);
var msg = new proto.google.api.Http;
return proto.google.api.Http.deserializeBinaryFromReader(msg, reader);
};
/**
* Deserializes binary data (in protobuf wire format) from the
* given reader into the given message object.
* @param {!proto.google.api.Http} msg The message object to deserialize into.
* @param {!jspb.BinaryReader} reader The BinaryReader to use.
* @return {!proto.google.api.Http}
*/
proto.google.api.Http.deserializeBinaryFromReader = function(msg, reader) {
while (reader.nextField()) {
if (reader.isEndGroup()) {
break;
}
var field = reader.getFieldNumber();
switch (field) {
case 1:
var value = new proto.google.api.HttpRule;
reader.readMessage(value,proto.google.api.HttpRule.deserializeBinaryFromReader);
msg.addRules(value);
break;
case 2:
var value = /** @type {boolean} */ (reader.readBool());
msg.setFullyDecodeReservedExpansion(value);
break;
default:
reader.skipField();
break;
}
}
return msg;
};
/**
* Serializes the message to binary data (in protobuf wire format).
* @return {!Uint8Array}
*/
proto.google.api.Http.prototype.serializeBinary = function() {
var writer = new jspb.BinaryWriter();
proto.google.api.Http.serializeBinaryToWriter(this, writer);
return writer.getResultBuffer();
};
/**
* Serializes the given message to binary data (in protobuf wire
* format), writing to the given BinaryWriter.
* @param {!proto.google.api.Http} message
* @param {!jspb.BinaryWriter} writer
* @suppress {unusedLocalVariables} f is only used for nested messages
*/
proto.google.api.Http.serializeBinaryToWriter = function(message, writer) {
var f = undefined;
f = message.getRulesList();
if (f.length > 0) {
writer.writeRepeatedMessage(
1,
f,
proto.google.api.HttpRule.serializeBinaryToWriter
);
}
f = message.getFullyDecodeReservedExpansion();
if (f) {
writer.writeBool(
2,
f
);
}
};
/**
* repeated HttpRule rules = 1;
* @return {!Array.<!proto.google.api.HttpRule>}
*/
proto.google.api.Http.prototype.getRulesList = function() {
return /** @type{!Array.<!proto.google.api.HttpRule>} */ (
jspb.Message.getRepeatedWrapperField(this, proto.google.api.HttpRule, 1));
};
/** @param {!Array.<!proto.google.api.HttpRule>} value */
proto.google.api.Http.prototype.setRulesList = function(value) {
jspb.Message.setRepeatedWrapperField(this, 1, value);
};
/**
* @param {!proto.google.api.HttpRule=} opt_value
* @param {number=} opt_index
* @return {!proto.google.api.HttpRule}
*/
proto.google.api.Http.prototype.addRules = function(opt_value, opt_index) {
return jspb.Message.addToRepeatedWrapperField(this, 1, opt_value, proto.google.api.HttpRule, opt_index);
};
proto.google.api.Http.prototype.clearRulesList = function() {
this.setRulesList([]);
};
/**
* optional bool fully_decode_reserved_expansion = 2;
* Note that Boolean fields may be set to 0/1 when serialized from a Java server.
* You should avoid comparisons like {@code val === true/false} in those cases.
* @return {boolean}
*/
proto.google.api.Http.prototype.getFullyDecodeReservedExpansion = function() {
return /** @type {boolean} */ (jspb.Message.getFieldWithDefault(this, 2, false));
};
/** @param {boolean} value */
proto.google.api.Http.prototype.setFullyDecodeReservedExpansion = function(value) {
jspb.Message.setField(this, 2, value);
};
/**
* Generated by JsPbCodeGenerator.
* @param {Array=} opt_data Optional initial data array, typically from a
* server response, or constructed directly in Javascript. The array is used
* in place and becomes part of the constructed object. It is not cloned.
* If no data is provided, the constructed object will be empty, but still
* valid.
* @extends {jspb.Message}
* @constructor
*/
proto.google.api.HttpRule = function(opt_data) {
jspb.Message.initialize(this, opt_data, 0, -1, proto.google.api.HttpRule.repeatedFields_, proto.google.api.HttpRule.oneofGroups_);
};
goog.inherits(proto.google.api.HttpRule, jspb.Message);
if (goog.DEBUG && !COMPILED) {
proto.google.api.HttpRule.displayName = 'proto.google.api.HttpRule';
}
/**
* List of repeated fields within this message type.
* @private {!Array<number>}
* @const
*/
proto.google.api.HttpRule.repeatedFields_ = [11];
/**
* Oneof group definitions for this message. Each group defines the field
* numbers belonging to that group. When of these fields' value is set, all
* other fields in the group are cleared. During deserialization, if multiple
* fields are encountered for a group, only the last value seen will be kept.
* @private {!Array<!Array<number>>}
* @const
*/
proto.google.api.HttpRule.oneofGroups_ = [[2,3,4,5,6,8]];
/**
* @enum {number}
*/
proto.google.api.HttpRule.PatternCase = {
PATTERN_NOT_SET: 0,
GET: 2,
PUT: 3,
POST: 4,
DELETE: 5,
PATCH: 6,
CUSTOM: 8
};
/**
* @return {proto.google.api.HttpRule.PatternCase}
*/
proto.google.api.HttpRule.prototype.getPatternCase = function() {
return /** @type {proto.google.api.HttpRule.PatternCase} */(jspb.Message.computeOneofCase(this, proto.google.api.HttpRule.oneofGroups_[0]));
};
if (jspb.Message.GENERATE_TO_OBJECT) {
/**
* Creates an object representation of this proto suitable for use in Soy templates.
* Field names that are reserved in JavaScript and will be renamed to pb_name.
* To access a reserved field use, foo.pb_<name>, eg, foo.pb_default.
* For the list of reserved names please see:
* com.google.apps.jspb.JsClassTemplate.JS_RESERVED_WORDS.
* @param {boolean=} opt_includeInstance Whether to include the JSPB instance
* for transitional soy proto support: http://goto/soy-param-migration
* @return {!Object}
*/
proto.google.api.HttpRule.prototype.toObject = function(opt_includeInstance) {
return proto.google.api.HttpRule.toObject(opt_includeInstance, this);
};
/**
* Static version of the {@see toObject} method.
* @param {boolean|undefined} includeInstance Whether to include the JSPB
* instance for transitional soy proto support:
* http://goto/soy-param-migration
* @param {!proto.google.api.HttpRule} msg The msg instance to transform.
* @return {!Object}
* @suppress {unusedLocalVariables} f is only used for nested messages
*/
proto.google.api.HttpRule.toObject = function(includeInstance, msg) {
var f, obj = {
selector: jspb.Message.getFieldWithDefault(msg, 1, ""),
get: jspb.Message.getFieldWithDefault(msg, 2, ""),
put: jspb.Message.getFieldWithDefault(msg, 3, ""),
post: jspb.Message.getFieldWithDefault(msg, 4, ""),
pb_delete: jspb.Message.getFieldWithDefault(msg, 5, ""),
patch: jspb.Message.getFieldWithDefault(msg, 6, ""),
custom: (f = msg.getCustom()) && proto.google.api.CustomHttpPattern.toObject(includeInstance, f),
body: jspb.Message.getFieldWithDefault(msg, 7, ""),
responseBody: jspb.Message.getFieldWithDefault(msg, 12, ""),
additionalBindingsList: jspb.Message.toObjectList(msg.getAdditionalBindingsList(),
proto.google.api.HttpRule.toObject, includeInstance)
};
if (includeInstance) {
obj.$jspbMessageInstance = msg;
}
return obj;
};
}
/**
* Deserializes binary data (in protobuf wire format).
* @param {jspb.ByteSource} bytes The bytes to deserialize.
* @return {!proto.google.api.HttpRule}
*/
proto.google.api.HttpRule.deserializeBinary = function(bytes) {
var reader = new jspb.BinaryReader(bytes);
var msg = new proto.google.api.HttpRule;
return proto.google.api.HttpRule.deserializeBinaryFromReader(msg, reader);
};
/**
* Deserializes binary data (in protobuf wire format) from the
* given reader into the given message object.
* @param {!proto.google.api.HttpRule} msg The message object to deserialize into.
* @param {!jspb.BinaryReader} reader The BinaryReader to use.
* @return {!proto.google.api.HttpRule}
*/
proto.google.api.HttpRule.deserializeBinaryFromReader = function(msg, reader) {
while (reader.nextField()) {
if (reader.isEndGroup()) {
break;
}
var field = reader.getFieldNumber();
switch (field) {
case 1:
var value = /** @type {string} */ (reader.readString());
msg.setSelector(value);
break;
case 2:
var value = /** @type {string} */ (reader.readString());
msg.setGet(value);
break;
case 3:
var value = /** @type {string} */ (reader.readString());
msg.setPut(value);
break;
case 4:
var value = /** @type {string} */ (reader.readString());
msg.setPost(value);
break;
case 5:
var value = /** @type {string} */ (reader.readString());
msg.setDelete(value);
break;
case 6:
var value = /** @type {string} */ (reader.readString());
msg.setPatch(value);
break;
case 8:
var value = new proto.google.api.CustomHttpPattern;
reader.readMessage(value,proto.google.api.CustomHttpPattern.deserializeBinaryFromReader);
msg.setCustom(value);
break;
case 7:
var value = /** @type {string} */ (reader.readString());
msg.setBody(value);
break;
case 12:
var value = /** @type {string} */ (reader.readString());
msg.setResponseBody(value);
break;
case 11:
var value = new proto.google.api.HttpRule;
reader.readMessage(value,proto.google.api.HttpRule.deserializeBinaryFromReader);
msg.addAdditionalBindings(value);
break;
default:
reader.skipField();
break;
}
}
return msg;
};
/**
* Serializes the message to binary data (in protobuf wire format).
* @return {!Uint8Array}
*/
proto.google.api.HttpRule.prototype.serializeBinary = function() {
var writer = new jspb.BinaryWriter();
proto.google.api.HttpRule.serializeBinaryToWriter(this, writer);
return writer.getResultBuffer();
};
/**
* Serializes the given message to binary data (in protobuf wire
* format), writing to the given BinaryWriter.
* @param {!proto.google.api.HttpRule} message
* @param {!jspb.BinaryWriter} writer
* @suppress {unusedLocalVariables} f is only used for nested messages
*/
proto.google.api.HttpRule.serializeBinaryToWriter = function(message, writer) {
var f = undefined;
f = message.getSelector();
if (f.length > 0) {
writer.writeString(
1,
f
);
}
f = /** @type {string} */ (jspb.Message.getField(message, 2));
if (f != null) {
writer.writeString(
2,
f
);
}
f = /** @type {string} */ (jspb.Message.getField(message, 3));
if (f != null) {
writer.writeString(
3,
f
);
}
f = /** @type {string} */ (jspb.Message.getField(message, 4));
if (f != null) {
writer.writeString(
4,
f
);
}
f = /** @type {string} */ (jspb.Message.getField(message, 5));
if (f != null) {
writer.writeString(
5,
f
);
}
f = /** @type {string} */ (jspb.Message.getField(message, 6));
if (f != null) {
writer.writeString(
6,
f
);
}
f = message.getCustom();
if (f != null) {
writer.writeMessage(
8,
f,
proto.google.api.CustomHttpPattern.serializeBinaryToWriter
);
}
f = message.getBody();
if (f.length > 0) {
writer.writeString(
7,
f
);
}
f = message.getResponseBody();
if (f.length > 0) {
writer.writeString(
12,
f
);
}
f = message.getAdditionalBindingsList();
if (f.length > 0) {
writer.writeRepeatedMessage(
11,
f,
proto.google.api.HttpRule.serializeBinaryToWriter
);
}
};
/**
* optional string selector = 1;
* @return {string}
*/
proto.google.api.HttpRule.prototype.getSelector = function() {
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, ""));
};
/** @param {string} value */
proto.google.api.HttpRule.prototype.setSelector = function(value) {
jspb.Message.setField(this, 1, value);
};
/**
* optional string get = 2;
* @return {string}
*/
proto.google.api.HttpRule.prototype.getGet = function() {
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 2, ""));
};
/** @param {string} value */
proto.google.api.HttpRule.prototype.setGet = function(value) {
jspb.Message.setOneofField(this, 2, proto.google.api.HttpRule.oneofGroups_[0], value);
};
proto.google.api.HttpRule.prototype.clearGet = function() {
jspb.Message.setOneofField(this, 2, proto.google.api.HttpRule.oneofGroups_[0], undefined);
};
/**
* Returns whether this field is set.
* @return {!boolean}
*/
proto.google.api.HttpRule.prototype.hasGet = function() {
return jspb.Message.getField(this, 2) != null;
};
/**
* optional string put = 3;
* @return {string}
*/
proto.google.api.HttpRule.prototype.getPut = function() {
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 3, ""));
};
/** @param {string} value */
proto.google.api.HttpRule.prototype.setPut = function(value) {
jspb.Message.setOneofField(this, 3, proto.google.api.HttpRule.oneofGroups_[0], value);
};
proto.google.api.HttpRule.prototype.clearPut = function() {
jspb.Message.setOneofField(this, 3, proto.google.api.HttpRule.oneofGroups_[0], undefined);
};
/**
* Returns whether this field is set.
* @return {!boolean}
*/
proto.google.api.HttpRule.prototype.hasPut = function() {
return jspb.Message.getField(this, 3) != null;
};
/**
* optional string post = 4;
* @return {string}
*/
proto.google.api.HttpRule.prototype.getPost = function() {
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 4, ""));
};
/** @param {string} value */
proto.google.api.HttpRule.prototype.setPost = function(value) {
jspb.Message.setOneofField(this, 4, proto.google.api.HttpRule.oneofGroups_[0], value);
};
proto.google.api.HttpRule.prototype.clearPost = function() {
jspb.Message.setOneofField(this, 4, proto.google.api.HttpRule.oneofGroups_[0], undefined);
};
/**
* Returns whether this field is set.
* @return {!boolean}
*/
proto.google.api.HttpRule.prototype.hasPost = function() {
return jspb.Message.getField(this, 4) != null;
};
/**
* optional string delete = 5;
* @return {string}
*/
proto.google.api.HttpRule.prototype.getDelete = function() {
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 5, ""));
};
/** @param {string} value */
proto.google.api.HttpRule.prototype.setDelete = function(value) {
jspb.Message.setOneofField(this, 5, proto.google.api.HttpRule.oneofGroups_[0], value);
};
proto.google.api.HttpRule.prototype.clearDelete = function() {
jspb.Message.setOneofField(this, 5, proto.google.api.HttpRule.oneofGroups_[0], undefined);
};
/**
* Returns whether this field is set.
* @return {!boolean}
*/
proto.google.api.HttpRule.prototype.hasDelete = function() {
return jspb.Message.getField(this, 5) != null;
};
/**
* optional string patch = 6;
* @return {string}
*/
proto.google.api.HttpRule.prototype.getPatch = function() {
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 6, ""));
};
/** @param {string} value */
proto.google.api.HttpRule.prototype.setPatch = function(value) {
jspb.Message.setOneofField(this, 6, proto.google.api.HttpRule.oneofGroups_[0], value);
};
proto.google.api.HttpRule.prototype.clearPatch = function() {
jspb.Message.setOneofField(this, 6, proto.google.api.HttpRule.oneofGroups_[0], undefined);
};
/**
* Returns whether this field is set.
* @return {!boolean}
*/
proto.google.api.HttpRule.prototype.hasPatch = function() {
return jspb.Message.getField(this, 6) != null;
};
/**
* optional CustomHttpPattern custom = 8;
* @return {?proto.google.api.CustomHttpPattern}
*/
proto.google.api.HttpRule.prototype.getCustom = function() {
return /** @type{?proto.google.api.CustomHttpPattern} */ (
jspb.Message.getWrapperField(this, proto.google.api.CustomHttpPattern, 8));
};
/** @param {?proto.google.api.CustomHttpPattern|undefined} value */
proto.google.api.HttpRule.prototype.setCustom = function(value) {
jspb.Message.setOneofWrapperField(this, 8, proto.google.api.HttpRule.oneofGroups_[0], value);
};
proto.google.api.HttpRule.prototype.clearCustom = function() {
this.setCustom(undefined);
};
/**
* Returns whether this field is set.
* @return {!boolean}
*/
proto.google.api.HttpRule.prototype.hasCustom = function() {
return jspb.Message.getField(this, 8) != null;
};
/**
* optional string body = 7;
* @return {string}
*/
proto.google.api.HttpRule.prototype.getBody = function() {
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 7, ""));
};
/** @param {string} value */
proto.google.api.HttpRule.prototype.setBody = function(value) {
jspb.Message.setField(this, 7, value);
};
/**
* optional string response_body = 12;
* @return {string}
*/
proto.google.api.HttpRule.prototype.getResponseBody = function() {
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 12, ""));
};
/** @param {string} value */
proto.google.api.HttpRule.prototype.setResponseBody = function(value) {
jspb.Message.setField(this, 12, value);
};
/**
* repeated HttpRule additional_bindings = 11;
* @return {!Array.<!proto.google.api.HttpRule>}
*/
proto.google.api.HttpRule.prototype.getAdditionalBindingsList = function() {
return /** @type{!Array.<!proto.google.api.HttpRule>} */ (
jspb.Message.getRepeatedWrapperField(this, proto.google.api.HttpRule, 11));
};
/** @param {!Array.<!proto.google.api.HttpRule>} value */
proto.google.api.HttpRule.prototype.setAdditionalBindingsList = function(value) {
jspb.Message.setRepeatedWrapperField(this, 11, value);
};
/**
* @param {!proto.google.api.HttpRule=} opt_value
* @param {number=} opt_index
* @return {!proto.google.api.HttpRule}
*/
proto.google.api.HttpRule.prototype.addAdditionalBindings = function(opt_value, opt_index) {
return jspb.Message.addToRepeatedWrapperField(this, 11, opt_value, proto.google.api.HttpRule, opt_index);
};
proto.google.api.HttpRule.prototype.clearAdditionalBindingsList = function() {
this.setAdditionalBindingsList([]);
};
/**
* Generated by JsPbCodeGenerator.
* @param {Array=} opt_data Optional initial data array, typically from a
* server response, or constructed directly in Javascript. The array is used
* in place and becomes part of the constructed object. It is not cloned.
* If no data is provided, the constructed object will be empty, but still
* valid.
* @extends {jspb.Message}
* @constructor
*/
proto.google.api.CustomHttpPattern = function(opt_data) {
jspb.Message.initialize(this, opt_data, 0, -1, null, null);
};
goog.inherits(proto.google.api.CustomHttpPattern, jspb.Message);
if (goog.DEBUG && !COMPILED) {
proto.google.api.CustomHttpPattern.displayName = 'proto.google.api.CustomHttpPattern';
}
if (jspb.Message.GENERATE_TO_OBJECT) {
/**
* Creates an object representation of this proto suitable for use in Soy templates.
* Field names that are reserved in JavaScript and will be renamed to pb_name.
* To access a reserved field use, foo.pb_<name>, eg, foo.pb_default.
* For the list of reserved names please see:
* com.google.apps.jspb.JsClassTemplate.JS_RESERVED_WORDS.
* @param {boolean=} opt_includeInstance Whether to include the JSPB instance
* for transitional soy proto support: http://goto/soy-param-migration
* @return {!Object}
*/
proto.google.api.CustomHttpPattern.prototype.toObject = function(opt_includeInstance) {
return proto.google.api.CustomHttpPattern.toObject(opt_includeInstance, this);
};
/**
* Static version of the {@see toObject} method.
* @param {boolean|undefined} includeInstance Whether to include the JSPB
* instance for transitional soy proto support:
* http://goto/soy-param-migration
* @param {!proto.google.api.CustomHttpPattern} msg The msg instance to transform.
* @return {!Object}
* @suppress {unusedLocalVariables} f is only used for nested messages
*/
proto.google.api.CustomHttpPattern.toObject = function(includeInstance, msg) {
var f, obj = {
kind: jspb.Message.getFieldWithDefault(msg, 1, ""),
path: jspb.Message.getFieldWithDefault(msg, 2, "")
};
if (includeInstance) {
obj.$jspbMessageInstance = msg;
}
return obj;
};
}
/**
* Deserializes binary data (in protobuf wire format).
* @param {jspb.ByteSource} bytes The bytes to deserialize.
* @return {!proto.google.api.CustomHttpPattern}
*/
proto.google.api.CustomHttpPattern.deserializeBinary = function(bytes) {
var reader = new jspb.BinaryReader(bytes);
var msg = new proto.google.api.CustomHttpPattern;
return proto.google.api.CustomHttpPattern.deserializeBinaryFromReader(msg, reader);
};
/**
* Deserializes binary data (in protobuf wire format) from the
* given reader into the given message object.
* @param {!proto.google.api.CustomHttpPattern} msg The message object to deserialize into.
* @param {!jspb.BinaryReader} reader The BinaryReader to use.
* @return {!proto.google.api.CustomHttpPattern}
*/
proto.google.api.CustomHttpPattern.deserializeBinaryFromReader = function(msg, reader) {
while (reader.nextField()) {
if (reader.isEndGroup()) {
break;
}
var field = reader.getFieldNumber();
switch (field) {
case 1:
var value = /** @type {string} */ (reader.readString());
msg.setKind(value);
break;
case 2:
var value = /** @type {string} */ (reader.readString());
msg.setPath(value);
break;
default:
reader.skipField();
break;
}
}
return msg;
};
/**
* Serializes the message to binary data (in protobuf wire format).
* @return {!Uint8Array}
*/
proto.google.api.CustomHttpPattern.prototype.serializeBinary = function() {
var writer = new jspb.BinaryWriter();
proto.google.api.CustomHttpPattern.serializeBinaryToWriter(this, writer);
return writer.getResultBuffer();
};
/**
* Serializes the given message to binary data (in protobuf wire
* format), writing to the given BinaryWriter.
* @param {!proto.google.api.CustomHttpPattern} message
* @param {!jspb.BinaryWriter} writer
* @suppress {unusedLocalVariables} f is only used for nested messages
*/
proto.google.api.CustomHttpPattern.serializeBinaryToWriter = function(message, writer) {
var f = undefined;
f = message.getKind();
if (f.length > 0) {
writer.writeString(
1,
f
);
}
f = message.getPath();
if (f.length > 0) {
writer.writeString(
2,
f
);
}
};
/**
* optional string kind = 1;
* @return {string}
*/
proto.google.api.CustomHttpPattern.prototype.getKind = function() {
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, ""));
};
/** @param {string} value */
proto.google.api.CustomHttpPattern.prototype.setKind = function(value) {
jspb.Message.setField(this, 1, value);
};
/**
* optional string path = 2;
* @return {string}
*/
proto.google.api.CustomHttpPattern.prototype.getPath = function() {
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 2, ""));
};
/** @param {string} value */
proto.google.api.CustomHttpPattern.prototype.setPath = function(value) {
jspb.Message.setField(this, 2, value);
};
goog.object.extend(exports, proto.google.api);

View file

@ -0,0 +1,3 @@
// package: google.api
// file: google/api/http.proto

View file

@ -0,0 +1,3 @@
// package: google.api
// file: google/api/http.proto

5499
app/src/types/generated/lnd_pb.d.ts vendored Normal file

File diff suppressed because it is too large Load diff

File diff suppressed because it is too large Load diff

File diff suppressed because it is too large Load diff

File diff suppressed because it is too large Load diff

819
app/src/types/generated/loop_pb.d.ts vendored Normal file
View file

@ -0,0 +1,819 @@
// package: looprpc
// file: loop.proto
import * as jspb from "google-protobuf";
import * as google_api_annotations_pb from "./google/api/annotations_pb";
export class LoopOutRequest extends jspb.Message {
getAmt(): number;
setAmt(value: number): void;
getDest(): string;
setDest(value: string): void;
getMaxSwapRoutingFee(): number;
setMaxSwapRoutingFee(value: number): void;
getMaxPrepayRoutingFee(): number;
setMaxPrepayRoutingFee(value: number): void;
getMaxSwapFee(): number;
setMaxSwapFee(value: number): void;
getMaxPrepayAmt(): number;
setMaxPrepayAmt(value: number): void;
getMaxMinerFee(): number;
setMaxMinerFee(value: number): void;
getLoopOutChannel(): number;
setLoopOutChannel(value: number): void;
clearOutgoingChanSetList(): void;
getOutgoingChanSetList(): Array<number>;
setOutgoingChanSetList(value: Array<number>): void;
addOutgoingChanSet(value: number, index?: number): number;
getSweepConfTarget(): number;
setSweepConfTarget(value: number): void;
getHtlcConfirmations(): number;
setHtlcConfirmations(value: number): void;
getSwapPublicationDeadline(): number;
setSwapPublicationDeadline(value: number): void;
getLabel(): string;
setLabel(value: string): void;
getInitiator(): string;
setInitiator(value: string): void;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): LoopOutRequest.AsObject;
static toObject(includeInstance: boolean, msg: LoopOutRequest): LoopOutRequest.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: LoopOutRequest, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): LoopOutRequest;
static deserializeBinaryFromReader(message: LoopOutRequest, reader: jspb.BinaryReader): LoopOutRequest;
}
export namespace LoopOutRequest {
export type AsObject = {
amt: number,
dest: string,
maxSwapRoutingFee: number,
maxPrepayRoutingFee: number,
maxSwapFee: number,
maxPrepayAmt: number,
maxMinerFee: number,
loopOutChannel: number,
outgoingChanSetList: Array<number>,
sweepConfTarget: number,
htlcConfirmations: number,
swapPublicationDeadline: number,
label: string,
initiator: string,
}
}
export class LoopInRequest extends jspb.Message {
getAmt(): number;
setAmt(value: number): void;
getMaxSwapFee(): number;
setMaxSwapFee(value: number): void;
getMaxMinerFee(): number;
setMaxMinerFee(value: number): void;
getLastHop(): Uint8Array | string;
getLastHop_asU8(): Uint8Array;
getLastHop_asB64(): string;
setLastHop(value: Uint8Array | string): void;
getExternalHtlc(): boolean;
setExternalHtlc(value: boolean): void;
getHtlcConfTarget(): number;
setHtlcConfTarget(value: number): void;
getLabel(): string;
setLabel(value: string): void;
getInitiator(): string;
setInitiator(value: string): void;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): LoopInRequest.AsObject;
static toObject(includeInstance: boolean, msg: LoopInRequest): LoopInRequest.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: LoopInRequest, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): LoopInRequest;
static deserializeBinaryFromReader(message: LoopInRequest, reader: jspb.BinaryReader): LoopInRequest;
}
export namespace LoopInRequest {
export type AsObject = {
amt: number,
maxSwapFee: number,
maxMinerFee: number,
lastHop: Uint8Array | string,
externalHtlc: boolean,
htlcConfTarget: number,
label: string,
initiator: string,
}
}
export class SwapResponse extends jspb.Message {
getId(): string;
setId(value: string): void;
getIdBytes(): Uint8Array | string;
getIdBytes_asU8(): Uint8Array;
getIdBytes_asB64(): string;
setIdBytes(value: Uint8Array | string): void;
getHtlcAddress(): string;
setHtlcAddress(value: string): void;
getHtlcAddressNp2wsh(): string;
setHtlcAddressNp2wsh(value: string): void;
getHtlcAddressP2wsh(): string;
setHtlcAddressP2wsh(value: string): void;
getServerMessage(): string;
setServerMessage(value: string): void;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): SwapResponse.AsObject;
static toObject(includeInstance: boolean, msg: SwapResponse): SwapResponse.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: SwapResponse, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): SwapResponse;
static deserializeBinaryFromReader(message: SwapResponse, reader: jspb.BinaryReader): SwapResponse;
}
export namespace SwapResponse {
export type AsObject = {
id: string,
idBytes: Uint8Array | string,
htlcAddress: string,
htlcAddressNp2wsh: string,
htlcAddressP2wsh: string,
serverMessage: string,
}
}
export class MonitorRequest extends jspb.Message {
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): MonitorRequest.AsObject;
static toObject(includeInstance: boolean, msg: MonitorRequest): MonitorRequest.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: MonitorRequest, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): MonitorRequest;
static deserializeBinaryFromReader(message: MonitorRequest, reader: jspb.BinaryReader): MonitorRequest;
}
export namespace MonitorRequest {
export type AsObject = {
}
}
export class SwapStatus extends jspb.Message {
getAmt(): number;
setAmt(value: number): void;
getId(): string;
setId(value: string): void;
getIdBytes(): Uint8Array | string;
getIdBytes_asU8(): Uint8Array;
getIdBytes_asB64(): string;
setIdBytes(value: Uint8Array | string): void;
getType(): SwapTypeMap[keyof SwapTypeMap];
setType(value: SwapTypeMap[keyof SwapTypeMap]): void;
getState(): SwapStateMap[keyof SwapStateMap];
setState(value: SwapStateMap[keyof SwapStateMap]): void;
getFailureReason(): FailureReasonMap[keyof FailureReasonMap];
setFailureReason(value: FailureReasonMap[keyof FailureReasonMap]): void;
getInitiationTime(): number;
setInitiationTime(value: number): void;
getLastUpdateTime(): number;
setLastUpdateTime(value: number): void;
getHtlcAddress(): string;
setHtlcAddress(value: string): void;
getHtlcAddressP2wsh(): string;
setHtlcAddressP2wsh(value: string): void;
getHtlcAddressNp2wsh(): string;
setHtlcAddressNp2wsh(value: string): void;
getCostServer(): number;
setCostServer(value: number): void;
getCostOnchain(): number;
setCostOnchain(value: number): void;
getCostOffchain(): number;
setCostOffchain(value: number): void;
getLabel(): string;
setLabel(value: string): void;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): SwapStatus.AsObject;
static toObject(includeInstance: boolean, msg: SwapStatus): SwapStatus.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: SwapStatus, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): SwapStatus;
static deserializeBinaryFromReader(message: SwapStatus, reader: jspb.BinaryReader): SwapStatus;
}
export namespace SwapStatus {
export type AsObject = {
amt: number,
id: string,
idBytes: Uint8Array | string,
type: SwapTypeMap[keyof SwapTypeMap],
state: SwapStateMap[keyof SwapStateMap],
failureReason: FailureReasonMap[keyof FailureReasonMap],
initiationTime: number,
lastUpdateTime: number,
htlcAddress: string,
htlcAddressP2wsh: string,
htlcAddressNp2wsh: string,
costServer: number,
costOnchain: number,
costOffchain: number,
label: string,
}
}
export class ListSwapsRequest extends jspb.Message {
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): ListSwapsRequest.AsObject;
static toObject(includeInstance: boolean, msg: ListSwapsRequest): ListSwapsRequest.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: ListSwapsRequest, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): ListSwapsRequest;
static deserializeBinaryFromReader(message: ListSwapsRequest, reader: jspb.BinaryReader): ListSwapsRequest;
}
export namespace ListSwapsRequest {
export type AsObject = {
}
}
export class ListSwapsResponse extends jspb.Message {
clearSwapsList(): void;
getSwapsList(): Array<SwapStatus>;
setSwapsList(value: Array<SwapStatus>): void;
addSwaps(value?: SwapStatus, index?: number): SwapStatus;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): ListSwapsResponse.AsObject;
static toObject(includeInstance: boolean, msg: ListSwapsResponse): ListSwapsResponse.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: ListSwapsResponse, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): ListSwapsResponse;
static deserializeBinaryFromReader(message: ListSwapsResponse, reader: jspb.BinaryReader): ListSwapsResponse;
}
export namespace ListSwapsResponse {
export type AsObject = {
swapsList: Array<SwapStatus.AsObject>,
}
}
export class SwapInfoRequest extends jspb.Message {
getId(): Uint8Array | string;
getId_asU8(): Uint8Array;
getId_asB64(): string;
setId(value: Uint8Array | string): void;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): SwapInfoRequest.AsObject;
static toObject(includeInstance: boolean, msg: SwapInfoRequest): SwapInfoRequest.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: SwapInfoRequest, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): SwapInfoRequest;
static deserializeBinaryFromReader(message: SwapInfoRequest, reader: jspb.BinaryReader): SwapInfoRequest;
}
export namespace SwapInfoRequest {
export type AsObject = {
id: Uint8Array | string,
}
}
export class TermsRequest extends jspb.Message {
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): TermsRequest.AsObject;
static toObject(includeInstance: boolean, msg: TermsRequest): TermsRequest.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: TermsRequest, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): TermsRequest;
static deserializeBinaryFromReader(message: TermsRequest, reader: jspb.BinaryReader): TermsRequest;
}
export namespace TermsRequest {
export type AsObject = {
}
}
export class InTermsResponse extends jspb.Message {
getMinSwapAmount(): number;
setMinSwapAmount(value: number): void;
getMaxSwapAmount(): number;
setMaxSwapAmount(value: number): void;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): InTermsResponse.AsObject;
static toObject(includeInstance: boolean, msg: InTermsResponse): InTermsResponse.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: InTermsResponse, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): InTermsResponse;
static deserializeBinaryFromReader(message: InTermsResponse, reader: jspb.BinaryReader): InTermsResponse;
}
export namespace InTermsResponse {
export type AsObject = {
minSwapAmount: number,
maxSwapAmount: number,
}
}
export class OutTermsResponse extends jspb.Message {
getMinSwapAmount(): number;
setMinSwapAmount(value: number): void;
getMaxSwapAmount(): number;
setMaxSwapAmount(value: number): void;
getMinCltvDelta(): number;
setMinCltvDelta(value: number): void;
getMaxCltvDelta(): number;
setMaxCltvDelta(value: number): void;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): OutTermsResponse.AsObject;
static toObject(includeInstance: boolean, msg: OutTermsResponse): OutTermsResponse.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: OutTermsResponse, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): OutTermsResponse;
static deserializeBinaryFromReader(message: OutTermsResponse, reader: jspb.BinaryReader): OutTermsResponse;
}
export namespace OutTermsResponse {
export type AsObject = {
minSwapAmount: number,
maxSwapAmount: number,
minCltvDelta: number,
maxCltvDelta: number,
}
}
export class QuoteRequest extends jspb.Message {
getAmt(): number;
setAmt(value: number): void;
getConfTarget(): number;
setConfTarget(value: number): void;
getExternalHtlc(): boolean;
setExternalHtlc(value: boolean): void;
getSwapPublicationDeadline(): number;
setSwapPublicationDeadline(value: number): void;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): QuoteRequest.AsObject;
static toObject(includeInstance: boolean, msg: QuoteRequest): QuoteRequest.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: QuoteRequest, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): QuoteRequest;
static deserializeBinaryFromReader(message: QuoteRequest, reader: jspb.BinaryReader): QuoteRequest;
}
export namespace QuoteRequest {
export type AsObject = {
amt: number,
confTarget: number,
externalHtlc: boolean,
swapPublicationDeadline: number,
}
}
export class InQuoteResponse extends jspb.Message {
getSwapFeeSat(): number;
setSwapFeeSat(value: number): void;
getHtlcPublishFeeSat(): number;
setHtlcPublishFeeSat(value: number): void;
getCltvDelta(): number;
setCltvDelta(value: number): void;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): InQuoteResponse.AsObject;
static toObject(includeInstance: boolean, msg: InQuoteResponse): InQuoteResponse.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: InQuoteResponse, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): InQuoteResponse;
static deserializeBinaryFromReader(message: InQuoteResponse, reader: jspb.BinaryReader): InQuoteResponse;
}
export namespace InQuoteResponse {
export type AsObject = {
swapFeeSat: number,
htlcPublishFeeSat: number,
cltvDelta: number,
}
}
export class OutQuoteResponse extends jspb.Message {
getSwapFeeSat(): number;
setSwapFeeSat(value: number): void;
getPrepayAmtSat(): number;
setPrepayAmtSat(value: number): void;
getHtlcSweepFeeSat(): number;
setHtlcSweepFeeSat(value: number): void;
getSwapPaymentDest(): Uint8Array | string;
getSwapPaymentDest_asU8(): Uint8Array;
getSwapPaymentDest_asB64(): string;
setSwapPaymentDest(value: Uint8Array | string): void;
getCltvDelta(): number;
setCltvDelta(value: number): void;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): OutQuoteResponse.AsObject;
static toObject(includeInstance: boolean, msg: OutQuoteResponse): OutQuoteResponse.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: OutQuoteResponse, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): OutQuoteResponse;
static deserializeBinaryFromReader(message: OutQuoteResponse, reader: jspb.BinaryReader): OutQuoteResponse;
}
export namespace OutQuoteResponse {
export type AsObject = {
swapFeeSat: number,
prepayAmtSat: number,
htlcSweepFeeSat: number,
swapPaymentDest: Uint8Array | string,
cltvDelta: number,
}
}
export class TokensRequest extends jspb.Message {
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): TokensRequest.AsObject;
static toObject(includeInstance: boolean, msg: TokensRequest): TokensRequest.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: TokensRequest, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): TokensRequest;
static deserializeBinaryFromReader(message: TokensRequest, reader: jspb.BinaryReader): TokensRequest;
}
export namespace TokensRequest {
export type AsObject = {
}
}
export class TokensResponse extends jspb.Message {
clearTokensList(): void;
getTokensList(): Array<LsatToken>;
setTokensList(value: Array<LsatToken>): void;
addTokens(value?: LsatToken, index?: number): LsatToken;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): TokensResponse.AsObject;
static toObject(includeInstance: boolean, msg: TokensResponse): TokensResponse.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: TokensResponse, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): TokensResponse;
static deserializeBinaryFromReader(message: TokensResponse, reader: jspb.BinaryReader): TokensResponse;
}
export namespace TokensResponse {
export type AsObject = {
tokensList: Array<LsatToken.AsObject>,
}
}
export class LsatToken extends jspb.Message {
getBaseMacaroon(): Uint8Array | string;
getBaseMacaroon_asU8(): Uint8Array;
getBaseMacaroon_asB64(): string;
setBaseMacaroon(value: Uint8Array | string): void;
getPaymentHash(): Uint8Array | string;
getPaymentHash_asU8(): Uint8Array;
getPaymentHash_asB64(): string;
setPaymentHash(value: Uint8Array | string): void;
getPaymentPreimage(): Uint8Array | string;
getPaymentPreimage_asU8(): Uint8Array;
getPaymentPreimage_asB64(): string;
setPaymentPreimage(value: Uint8Array | string): void;
getAmountPaidMsat(): number;
setAmountPaidMsat(value: number): void;
getRoutingFeePaidMsat(): number;
setRoutingFeePaidMsat(value: number): void;
getTimeCreated(): number;
setTimeCreated(value: number): void;
getExpired(): boolean;
setExpired(value: boolean): void;
getStorageName(): string;
setStorageName(value: string): void;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): LsatToken.AsObject;
static toObject(includeInstance: boolean, msg: LsatToken): LsatToken.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: LsatToken, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): LsatToken;
static deserializeBinaryFromReader(message: LsatToken, reader: jspb.BinaryReader): LsatToken;
}
export namespace LsatToken {
export type AsObject = {
baseMacaroon: Uint8Array | string,
paymentHash: Uint8Array | string,
paymentPreimage: Uint8Array | string,
amountPaidMsat: number,
routingFeePaidMsat: number,
timeCreated: number,
expired: boolean,
storageName: string,
}
}
export class GetLiquidityParamsRequest extends jspb.Message {
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): GetLiquidityParamsRequest.AsObject;
static toObject(includeInstance: boolean, msg: GetLiquidityParamsRequest): GetLiquidityParamsRequest.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: GetLiquidityParamsRequest, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): GetLiquidityParamsRequest;
static deserializeBinaryFromReader(message: GetLiquidityParamsRequest, reader: jspb.BinaryReader): GetLiquidityParamsRequest;
}
export namespace GetLiquidityParamsRequest {
export type AsObject = {
}
}
export class LiquidityParameters extends jspb.Message {
clearRulesList(): void;
getRulesList(): Array<LiquidityRule>;
setRulesList(value: Array<LiquidityRule>): void;
addRules(value?: LiquidityRule, index?: number): LiquidityRule;
getSweepFeeRateSatPerVbyte(): number;
setSweepFeeRateSatPerVbyte(value: number): void;
getMaxSwapFeePpm(): number;
setMaxSwapFeePpm(value: number): void;
getMaxRoutingFeePpm(): number;
setMaxRoutingFeePpm(value: number): void;
getMaxPrepayRoutingFeePpm(): number;
setMaxPrepayRoutingFeePpm(value: number): void;
getMaxPrepaySat(): number;
setMaxPrepaySat(value: number): void;
getMaxMinerFeeSat(): number;
setMaxMinerFeeSat(value: number): void;
getSweepConfTarget(): number;
setSweepConfTarget(value: number): void;
getFailureBackoffSec(): number;
setFailureBackoffSec(value: number): void;
getAutoLoopOut(): boolean;
setAutoLoopOut(value: boolean): void;
getAutoOutBudgetSat(): number;
setAutoOutBudgetSat(value: number): void;
getAutoOutBudgetStartSec(): number;
setAutoOutBudgetStartSec(value: number): void;
getAutoMaxInFlight(): number;
setAutoMaxInFlight(value: number): void;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): LiquidityParameters.AsObject;
static toObject(includeInstance: boolean, msg: LiquidityParameters): LiquidityParameters.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: LiquidityParameters, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): LiquidityParameters;
static deserializeBinaryFromReader(message: LiquidityParameters, reader: jspb.BinaryReader): LiquidityParameters;
}
export namespace LiquidityParameters {
export type AsObject = {
rulesList: Array<LiquidityRule.AsObject>,
sweepFeeRateSatPerVbyte: number,
maxSwapFeePpm: number,
maxRoutingFeePpm: number,
maxPrepayRoutingFeePpm: number,
maxPrepaySat: number,
maxMinerFeeSat: number,
sweepConfTarget: number,
failureBackoffSec: number,
autoLoopOut: boolean,
autoOutBudgetSat: number,
autoOutBudgetStartSec: number,
autoMaxInFlight: number,
}
}
export class LiquidityRule extends jspb.Message {
getChannelId(): number;
setChannelId(value: number): void;
getType(): LiquidityRuleTypeMap[keyof LiquidityRuleTypeMap];
setType(value: LiquidityRuleTypeMap[keyof LiquidityRuleTypeMap]): void;
getIncomingThreshold(): number;
setIncomingThreshold(value: number): void;
getOutgoingThreshold(): number;
setOutgoingThreshold(value: number): void;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): LiquidityRule.AsObject;
static toObject(includeInstance: boolean, msg: LiquidityRule): LiquidityRule.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: LiquidityRule, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): LiquidityRule;
static deserializeBinaryFromReader(message: LiquidityRule, reader: jspb.BinaryReader): LiquidityRule;
}
export namespace LiquidityRule {
export type AsObject = {
channelId: number,
type: LiquidityRuleTypeMap[keyof LiquidityRuleTypeMap],
incomingThreshold: number,
outgoingThreshold: number,
}
}
export class SetLiquidityParamsRequest extends jspb.Message {
hasParameters(): boolean;
clearParameters(): void;
getParameters(): LiquidityParameters | undefined;
setParameters(value?: LiquidityParameters): void;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): SetLiquidityParamsRequest.AsObject;
static toObject(includeInstance: boolean, msg: SetLiquidityParamsRequest): SetLiquidityParamsRequest.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: SetLiquidityParamsRequest, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): SetLiquidityParamsRequest;
static deserializeBinaryFromReader(message: SetLiquidityParamsRequest, reader: jspb.BinaryReader): SetLiquidityParamsRequest;
}
export namespace SetLiquidityParamsRequest {
export type AsObject = {
parameters?: LiquidityParameters.AsObject,
}
}
export class SetLiquidityParamsResponse extends jspb.Message {
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): SetLiquidityParamsResponse.AsObject;
static toObject(includeInstance: boolean, msg: SetLiquidityParamsResponse): SetLiquidityParamsResponse.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: SetLiquidityParamsResponse, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): SetLiquidityParamsResponse;
static deserializeBinaryFromReader(message: SetLiquidityParamsResponse, reader: jspb.BinaryReader): SetLiquidityParamsResponse;
}
export namespace SetLiquidityParamsResponse {
export type AsObject = {
}
}
export class SuggestSwapsRequest extends jspb.Message {
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): SuggestSwapsRequest.AsObject;
static toObject(includeInstance: boolean, msg: SuggestSwapsRequest): SuggestSwapsRequest.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: SuggestSwapsRequest, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): SuggestSwapsRequest;
static deserializeBinaryFromReader(message: SuggestSwapsRequest, reader: jspb.BinaryReader): SuggestSwapsRequest;
}
export namespace SuggestSwapsRequest {
export type AsObject = {
}
}
export class SuggestSwapsResponse extends jspb.Message {
clearLoopOutList(): void;
getLoopOutList(): Array<LoopOutRequest>;
setLoopOutList(value: Array<LoopOutRequest>): void;
addLoopOut(value?: LoopOutRequest, index?: number): LoopOutRequest;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): SuggestSwapsResponse.AsObject;
static toObject(includeInstance: boolean, msg: SuggestSwapsResponse): SuggestSwapsResponse.AsObject;
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
static serializeBinaryToWriter(message: SuggestSwapsResponse, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): SuggestSwapsResponse;
static deserializeBinaryFromReader(message: SuggestSwapsResponse, reader: jspb.BinaryReader): SuggestSwapsResponse;
}
export namespace SuggestSwapsResponse {
export type AsObject = {
loopOutList: Array<LoopOutRequest.AsObject>,
}
}
export interface SwapTypeMap {
LOOP_OUT: 0;
LOOP_IN: 1;
}
export const SwapType: SwapTypeMap;
export interface SwapStateMap {
INITIATED: 0;
PREIMAGE_REVEALED: 1;
HTLC_PUBLISHED: 2;
SUCCESS: 3;
FAILED: 4;
INVOICE_SETTLED: 5;
}
export const SwapState: SwapStateMap;
export interface FailureReasonMap {
FAILURE_REASON_NONE: 0;
FAILURE_REASON_OFFCHAIN: 1;
FAILURE_REASON_TIMEOUT: 2;
FAILURE_REASON_SWEEP_TIMEOUT: 3;
FAILURE_REASON_INSUFFICIENT_VALUE: 4;
FAILURE_REASON_TEMPORARY: 5;
FAILURE_REASON_INCORRECT_AMOUNT: 6;
}
export const FailureReason: FailureReasonMap;
export interface LiquidityRuleTypeMap {
UNKNOWN: 0;
THRESHOLD: 1;
}
export const LiquidityRuleType: LiquidityRuleTypeMap;

File diff suppressed because it is too large Load diff

View file

@ -0,0 +1,283 @@
// package: looprpc
// file: loop.proto
import * as loop_pb from "./loop_pb";
import {grpc} from "@improbable-eng/grpc-web";
type SwapClientLoopOut = {
readonly methodName: string;
readonly service: typeof SwapClient;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof loop_pb.LoopOutRequest;
readonly responseType: typeof loop_pb.SwapResponse;
};
type SwapClientLoopIn = {
readonly methodName: string;
readonly service: typeof SwapClient;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof loop_pb.LoopInRequest;
readonly responseType: typeof loop_pb.SwapResponse;
};
type SwapClientMonitor = {
readonly methodName: string;
readonly service: typeof SwapClient;
readonly requestStream: false;
readonly responseStream: true;
readonly requestType: typeof loop_pb.MonitorRequest;
readonly responseType: typeof loop_pb.SwapStatus;
};
type SwapClientListSwaps = {
readonly methodName: string;
readonly service: typeof SwapClient;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof loop_pb.ListSwapsRequest;
readonly responseType: typeof loop_pb.ListSwapsResponse;
};
type SwapClientSwapInfo = {
readonly methodName: string;
readonly service: typeof SwapClient;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof loop_pb.SwapInfoRequest;
readonly responseType: typeof loop_pb.SwapStatus;
};
type SwapClientLoopOutTerms = {
readonly methodName: string;
readonly service: typeof SwapClient;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof loop_pb.TermsRequest;
readonly responseType: typeof loop_pb.OutTermsResponse;
};
type SwapClientLoopOutQuote = {
readonly methodName: string;
readonly service: typeof SwapClient;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof loop_pb.QuoteRequest;
readonly responseType: typeof loop_pb.OutQuoteResponse;
};
type SwapClientGetLoopInTerms = {
readonly methodName: string;
readonly service: typeof SwapClient;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof loop_pb.TermsRequest;
readonly responseType: typeof loop_pb.InTermsResponse;
};
type SwapClientGetLoopInQuote = {
readonly methodName: string;
readonly service: typeof SwapClient;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof loop_pb.QuoteRequest;
readonly responseType: typeof loop_pb.InQuoteResponse;
};
type SwapClientGetLsatTokens = {
readonly methodName: string;
readonly service: typeof SwapClient;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof loop_pb.TokensRequest;
readonly responseType: typeof loop_pb.TokensResponse;
};
type SwapClientGetLiquidityParams = {
readonly methodName: string;
readonly service: typeof SwapClient;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof loop_pb.GetLiquidityParamsRequest;
readonly responseType: typeof loop_pb.LiquidityParameters;
};
type SwapClientSetLiquidityParams = {
readonly methodName: string;
readonly service: typeof SwapClient;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof loop_pb.SetLiquidityParamsRequest;
readonly responseType: typeof loop_pb.SetLiquidityParamsResponse;
};
type SwapClientSuggestSwaps = {
readonly methodName: string;
readonly service: typeof SwapClient;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof loop_pb.SuggestSwapsRequest;
readonly responseType: typeof loop_pb.SuggestSwapsResponse;
};
export class SwapClient {
static readonly serviceName: string;
static readonly LoopOut: SwapClientLoopOut;
static readonly LoopIn: SwapClientLoopIn;
static readonly Monitor: SwapClientMonitor;
static readonly ListSwaps: SwapClientListSwaps;
static readonly SwapInfo: SwapClientSwapInfo;
static readonly LoopOutTerms: SwapClientLoopOutTerms;
static readonly LoopOutQuote: SwapClientLoopOutQuote;
static readonly GetLoopInTerms: SwapClientGetLoopInTerms;
static readonly GetLoopInQuote: SwapClientGetLoopInQuote;
static readonly GetLsatTokens: SwapClientGetLsatTokens;
static readonly GetLiquidityParams: SwapClientGetLiquidityParams;
static readonly SetLiquidityParams: SwapClientSetLiquidityParams;
static readonly SuggestSwaps: SwapClientSuggestSwaps;
}
export type ServiceError = { message: string, code: number; metadata: grpc.Metadata }
export type Status = { details: string, code: number; metadata: grpc.Metadata }
interface UnaryResponse {
cancel(): void;
}
interface ResponseStream<T> {
cancel(): void;
on(type: 'data', handler: (message: T) => void): ResponseStream<T>;
on(type: 'end', handler: (status?: Status) => void): ResponseStream<T>;
on(type: 'status', handler: (status: Status) => void): ResponseStream<T>;
}
interface RequestStream<T> {
write(message: T): RequestStream<T>;
end(): void;
cancel(): void;
on(type: 'end', handler: (status?: Status) => void): RequestStream<T>;
on(type: 'status', handler: (status: Status) => void): RequestStream<T>;
}
interface BidirectionalStream<ReqT, ResT> {
write(message: ReqT): BidirectionalStream<ReqT, ResT>;
end(): void;
cancel(): void;
on(type: 'data', handler: (message: ResT) => void): BidirectionalStream<ReqT, ResT>;
on(type: 'end', handler: (status?: Status) => void): BidirectionalStream<ReqT, ResT>;
on(type: 'status', handler: (status: Status) => void): BidirectionalStream<ReqT, ResT>;
}
export class SwapClientClient {
readonly serviceHost: string;
constructor(serviceHost: string, options?: grpc.RpcOptions);
loopOut(
requestMessage: loop_pb.LoopOutRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: loop_pb.SwapResponse|null) => void
): UnaryResponse;
loopOut(
requestMessage: loop_pb.LoopOutRequest,
callback: (error: ServiceError|null, responseMessage: loop_pb.SwapResponse|null) => void
): UnaryResponse;
loopIn(
requestMessage: loop_pb.LoopInRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: loop_pb.SwapResponse|null) => void
): UnaryResponse;
loopIn(
requestMessage: loop_pb.LoopInRequest,
callback: (error: ServiceError|null, responseMessage: loop_pb.SwapResponse|null) => void
): UnaryResponse;
monitor(requestMessage: loop_pb.MonitorRequest, metadata?: grpc.Metadata): ResponseStream<loop_pb.SwapStatus>;
listSwaps(
requestMessage: loop_pb.ListSwapsRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: loop_pb.ListSwapsResponse|null) => void
): UnaryResponse;
listSwaps(
requestMessage: loop_pb.ListSwapsRequest,
callback: (error: ServiceError|null, responseMessage: loop_pb.ListSwapsResponse|null) => void
): UnaryResponse;
swapInfo(
requestMessage: loop_pb.SwapInfoRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: loop_pb.SwapStatus|null) => void
): UnaryResponse;
swapInfo(
requestMessage: loop_pb.SwapInfoRequest,
callback: (error: ServiceError|null, responseMessage: loop_pb.SwapStatus|null) => void
): UnaryResponse;
loopOutTerms(
requestMessage: loop_pb.TermsRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: loop_pb.OutTermsResponse|null) => void
): UnaryResponse;
loopOutTerms(
requestMessage: loop_pb.TermsRequest,
callback: (error: ServiceError|null, responseMessage: loop_pb.OutTermsResponse|null) => void
): UnaryResponse;
loopOutQuote(
requestMessage: loop_pb.QuoteRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: loop_pb.OutQuoteResponse|null) => void
): UnaryResponse;
loopOutQuote(
requestMessage: loop_pb.QuoteRequest,
callback: (error: ServiceError|null, responseMessage: loop_pb.OutQuoteResponse|null) => void
): UnaryResponse;
getLoopInTerms(
requestMessage: loop_pb.TermsRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: loop_pb.InTermsResponse|null) => void
): UnaryResponse;
getLoopInTerms(
requestMessage: loop_pb.TermsRequest,
callback: (error: ServiceError|null, responseMessage: loop_pb.InTermsResponse|null) => void
): UnaryResponse;
getLoopInQuote(
requestMessage: loop_pb.QuoteRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: loop_pb.InQuoteResponse|null) => void
): UnaryResponse;
getLoopInQuote(
requestMessage: loop_pb.QuoteRequest,
callback: (error: ServiceError|null, responseMessage: loop_pb.InQuoteResponse|null) => void
): UnaryResponse;
getLsatTokens(
requestMessage: loop_pb.TokensRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: loop_pb.TokensResponse|null) => void
): UnaryResponse;
getLsatTokens(
requestMessage: loop_pb.TokensRequest,
callback: (error: ServiceError|null, responseMessage: loop_pb.TokensResponse|null) => void
): UnaryResponse;
getLiquidityParams(
requestMessage: loop_pb.GetLiquidityParamsRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: loop_pb.LiquidityParameters|null) => void
): UnaryResponse;
getLiquidityParams(
requestMessage: loop_pb.GetLiquidityParamsRequest,
callback: (error: ServiceError|null, responseMessage: loop_pb.LiquidityParameters|null) => void
): UnaryResponse;
setLiquidityParams(
requestMessage: loop_pb.SetLiquidityParamsRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: loop_pb.SetLiquidityParamsResponse|null) => void
): UnaryResponse;
setLiquidityParams(
requestMessage: loop_pb.SetLiquidityParamsRequest,
callback: (error: ServiceError|null, responseMessage: loop_pb.SetLiquidityParamsResponse|null) => void
): UnaryResponse;
suggestSwaps(
requestMessage: loop_pb.SuggestSwapsRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: loop_pb.SuggestSwapsResponse|null) => void
): UnaryResponse;
suggestSwaps(
requestMessage: loop_pb.SuggestSwapsRequest,
callback: (error: ServiceError|null, responseMessage: loop_pb.SuggestSwapsResponse|null) => void
): UnaryResponse;
}

View file

@ -0,0 +1,549 @@
// package: looprpc
// file: loop.proto
var loop_pb = require("./loop_pb");
var grpc = require("@improbable-eng/grpc-web").grpc;
var SwapClient = (function () {
function SwapClient() {}
SwapClient.serviceName = "looprpc.SwapClient";
return SwapClient;
}());
SwapClient.LoopOut = {
methodName: "LoopOut",
service: SwapClient,
requestStream: false,
responseStream: false,
requestType: loop_pb.LoopOutRequest,
responseType: loop_pb.SwapResponse
};
SwapClient.LoopIn = {
methodName: "LoopIn",
service: SwapClient,
requestStream: false,
responseStream: false,
requestType: loop_pb.LoopInRequest,
responseType: loop_pb.SwapResponse
};
SwapClient.Monitor = {
methodName: "Monitor",
service: SwapClient,
requestStream: false,
responseStream: true,
requestType: loop_pb.MonitorRequest,
responseType: loop_pb.SwapStatus
};
SwapClient.ListSwaps = {
methodName: "ListSwaps",
service: SwapClient,
requestStream: false,
responseStream: false,
requestType: loop_pb.ListSwapsRequest,
responseType: loop_pb.ListSwapsResponse
};
SwapClient.SwapInfo = {
methodName: "SwapInfo",
service: SwapClient,
requestStream: false,
responseStream: false,
requestType: loop_pb.SwapInfoRequest,
responseType: loop_pb.SwapStatus
};
SwapClient.LoopOutTerms = {
methodName: "LoopOutTerms",
service: SwapClient,
requestStream: false,
responseStream: false,
requestType: loop_pb.TermsRequest,
responseType: loop_pb.OutTermsResponse
};
SwapClient.LoopOutQuote = {
methodName: "LoopOutQuote",
service: SwapClient,
requestStream: false,
responseStream: false,
requestType: loop_pb.QuoteRequest,
responseType: loop_pb.OutQuoteResponse
};
SwapClient.GetLoopInTerms = {
methodName: "GetLoopInTerms",
service: SwapClient,
requestStream: false,
responseStream: false,
requestType: loop_pb.TermsRequest,
responseType: loop_pb.InTermsResponse
};
SwapClient.GetLoopInQuote = {
methodName: "GetLoopInQuote",
service: SwapClient,
requestStream: false,
responseStream: false,
requestType: loop_pb.QuoteRequest,
responseType: loop_pb.InQuoteResponse
};
SwapClient.GetLsatTokens = {
methodName: "GetLsatTokens",
service: SwapClient,
requestStream: false,
responseStream: false,
requestType: loop_pb.TokensRequest,
responseType: loop_pb.TokensResponse
};
SwapClient.GetLiquidityParams = {
methodName: "GetLiquidityParams",
service: SwapClient,
requestStream: false,
responseStream: false,
requestType: loop_pb.GetLiquidityParamsRequest,
responseType: loop_pb.LiquidityParameters
};
SwapClient.SetLiquidityParams = {
methodName: "SetLiquidityParams",
service: SwapClient,
requestStream: false,
responseStream: false,
requestType: loop_pb.SetLiquidityParamsRequest,
responseType: loop_pb.SetLiquidityParamsResponse
};
SwapClient.SuggestSwaps = {
methodName: "SuggestSwaps",
service: SwapClient,
requestStream: false,
responseStream: false,
requestType: loop_pb.SuggestSwapsRequest,
responseType: loop_pb.SuggestSwapsResponse
};
exports.SwapClient = SwapClient;
function SwapClientClient(serviceHost, options) {
this.serviceHost = serviceHost;
this.options = options || {};
}
SwapClientClient.prototype.loopOut = function loopOut(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(SwapClient.LoopOut, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
SwapClientClient.prototype.loopIn = function loopIn(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(SwapClient.LoopIn, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
SwapClientClient.prototype.monitor = function monitor(requestMessage, metadata) {
var listeners = {
data: [],
end: [],
status: []
};
var client = grpc.invoke(SwapClient.Monitor, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onMessage: function (responseMessage) {
listeners.data.forEach(function (handler) {
handler(responseMessage);
});
},
onEnd: function (status, statusMessage, trailers) {
listeners.status.forEach(function (handler) {
handler({ code: status, details: statusMessage, metadata: trailers });
});
listeners.end.forEach(function (handler) {
handler({ code: status, details: statusMessage, metadata: trailers });
});
listeners = null;
}
});
return {
on: function (type, handler) {
listeners[type].push(handler);
return this;
},
cancel: function () {
listeners = null;
client.close();
}
};
};
SwapClientClient.prototype.listSwaps = function listSwaps(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(SwapClient.ListSwaps, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
SwapClientClient.prototype.swapInfo = function swapInfo(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(SwapClient.SwapInfo, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
SwapClientClient.prototype.loopOutTerms = function loopOutTerms(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(SwapClient.LoopOutTerms, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
SwapClientClient.prototype.loopOutQuote = function loopOutQuote(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(SwapClient.LoopOutQuote, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
SwapClientClient.prototype.getLoopInTerms = function getLoopInTerms(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(SwapClient.GetLoopInTerms, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
SwapClientClient.prototype.getLoopInQuote = function getLoopInQuote(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(SwapClient.GetLoopInQuote, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
SwapClientClient.prototype.getLsatTokens = function getLsatTokens(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(SwapClient.GetLsatTokens, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
SwapClientClient.prototype.getLiquidityParams = function getLiquidityParams(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(SwapClient.GetLiquidityParams, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
SwapClientClient.prototype.setLiquidityParams = function setLiquidityParams(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(SwapClient.SetLiquidityParams, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
SwapClientClient.prototype.suggestSwaps = function suggestSwaps(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(SwapClient.SuggestSwaps, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
exports.SwapClientClient = SwapClientClient;

1372
app/src/types/generated/trader_pb.d.ts vendored Normal file

File diff suppressed because it is too large Load diff

File diff suppressed because it is too large Load diff

View file

@ -0,0 +1,387 @@
// package: poolrpc
// file: trader.proto
import * as trader_pb from "./trader_pb";
import * as auctioneer_pb from "./auctioneer_pb";
import {grpc} from "@improbable-eng/grpc-web";
type TraderQuoteAccount = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.QuoteAccountRequest;
readonly responseType: typeof trader_pb.QuoteAccountResponse;
};
type TraderInitAccount = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.InitAccountRequest;
readonly responseType: typeof trader_pb.Account;
};
type TraderListAccounts = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.ListAccountsRequest;
readonly responseType: typeof trader_pb.ListAccountsResponse;
};
type TraderCloseAccount = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.CloseAccountRequest;
readonly responseType: typeof trader_pb.CloseAccountResponse;
};
type TraderWithdrawAccount = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.WithdrawAccountRequest;
readonly responseType: typeof trader_pb.WithdrawAccountResponse;
};
type TraderDepositAccount = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.DepositAccountRequest;
readonly responseType: typeof trader_pb.DepositAccountResponse;
};
type TraderBumpAccountFee = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.BumpAccountFeeRequest;
readonly responseType: typeof trader_pb.BumpAccountFeeResponse;
};
type TraderRecoverAccounts = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.RecoverAccountsRequest;
readonly responseType: typeof trader_pb.RecoverAccountsResponse;
};
type TraderSubmitOrder = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.SubmitOrderRequest;
readonly responseType: typeof trader_pb.SubmitOrderResponse;
};
type TraderListOrders = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.ListOrdersRequest;
readonly responseType: typeof trader_pb.ListOrdersResponse;
};
type TraderCancelOrder = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.CancelOrderRequest;
readonly responseType: typeof trader_pb.CancelOrderResponse;
};
type TraderAuctionFee = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.AuctionFeeRequest;
readonly responseType: typeof trader_pb.AuctionFeeResponse;
};
type TraderLeaseDurations = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.LeaseDurationRequest;
readonly responseType: typeof trader_pb.LeaseDurationResponse;
};
type TraderNextBatchInfo = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.NextBatchInfoRequest;
readonly responseType: typeof trader_pb.NextBatchInfoResponse;
};
type TraderBatchSnapshot = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof auctioneer_pb.BatchSnapshotRequest;
readonly responseType: typeof auctioneer_pb.BatchSnapshotResponse;
};
type TraderGetLsatTokens = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.TokensRequest;
readonly responseType: typeof trader_pb.TokensResponse;
};
type TraderLeases = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.LeasesRequest;
readonly responseType: typeof trader_pb.LeasesResponse;
};
type TraderNodeRatings = {
readonly methodName: string;
readonly service: typeof Trader;
readonly requestStream: false;
readonly responseStream: false;
readonly requestType: typeof trader_pb.NodeRatingRequest;
readonly responseType: typeof trader_pb.NodeRatingResponse;
};
export class Trader {
static readonly serviceName: string;
static readonly QuoteAccount: TraderQuoteAccount;
static readonly InitAccount: TraderInitAccount;
static readonly ListAccounts: TraderListAccounts;
static readonly CloseAccount: TraderCloseAccount;
static readonly WithdrawAccount: TraderWithdrawAccount;
static readonly DepositAccount: TraderDepositAccount;
static readonly BumpAccountFee: TraderBumpAccountFee;
static readonly RecoverAccounts: TraderRecoverAccounts;
static readonly SubmitOrder: TraderSubmitOrder;
static readonly ListOrders: TraderListOrders;
static readonly CancelOrder: TraderCancelOrder;
static readonly AuctionFee: TraderAuctionFee;
static readonly LeaseDurations: TraderLeaseDurations;
static readonly NextBatchInfo: TraderNextBatchInfo;
static readonly BatchSnapshot: TraderBatchSnapshot;
static readonly GetLsatTokens: TraderGetLsatTokens;
static readonly Leases: TraderLeases;
static readonly NodeRatings: TraderNodeRatings;
}
export type ServiceError = { message: string, code: number; metadata: grpc.Metadata }
export type Status = { details: string, code: number; metadata: grpc.Metadata }
interface UnaryResponse {
cancel(): void;
}
interface ResponseStream<T> {
cancel(): void;
on(type: 'data', handler: (message: T) => void): ResponseStream<T>;
on(type: 'end', handler: (status?: Status) => void): ResponseStream<T>;
on(type: 'status', handler: (status: Status) => void): ResponseStream<T>;
}
interface RequestStream<T> {
write(message: T): RequestStream<T>;
end(): void;
cancel(): void;
on(type: 'end', handler: (status?: Status) => void): RequestStream<T>;
on(type: 'status', handler: (status: Status) => void): RequestStream<T>;
}
interface BidirectionalStream<ReqT, ResT> {
write(message: ReqT): BidirectionalStream<ReqT, ResT>;
end(): void;
cancel(): void;
on(type: 'data', handler: (message: ResT) => void): BidirectionalStream<ReqT, ResT>;
on(type: 'end', handler: (status?: Status) => void): BidirectionalStream<ReqT, ResT>;
on(type: 'status', handler: (status: Status) => void): BidirectionalStream<ReqT, ResT>;
}
export class TraderClient {
readonly serviceHost: string;
constructor(serviceHost: string, options?: grpc.RpcOptions);
quoteAccount(
requestMessage: trader_pb.QuoteAccountRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.QuoteAccountResponse|null) => void
): UnaryResponse;
quoteAccount(
requestMessage: trader_pb.QuoteAccountRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.QuoteAccountResponse|null) => void
): UnaryResponse;
initAccount(
requestMessage: trader_pb.InitAccountRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.Account|null) => void
): UnaryResponse;
initAccount(
requestMessage: trader_pb.InitAccountRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.Account|null) => void
): UnaryResponse;
listAccounts(
requestMessage: trader_pb.ListAccountsRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.ListAccountsResponse|null) => void
): UnaryResponse;
listAccounts(
requestMessage: trader_pb.ListAccountsRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.ListAccountsResponse|null) => void
): UnaryResponse;
closeAccount(
requestMessage: trader_pb.CloseAccountRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.CloseAccountResponse|null) => void
): UnaryResponse;
closeAccount(
requestMessage: trader_pb.CloseAccountRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.CloseAccountResponse|null) => void
): UnaryResponse;
withdrawAccount(
requestMessage: trader_pb.WithdrawAccountRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.WithdrawAccountResponse|null) => void
): UnaryResponse;
withdrawAccount(
requestMessage: trader_pb.WithdrawAccountRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.WithdrawAccountResponse|null) => void
): UnaryResponse;
depositAccount(
requestMessage: trader_pb.DepositAccountRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.DepositAccountResponse|null) => void
): UnaryResponse;
depositAccount(
requestMessage: trader_pb.DepositAccountRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.DepositAccountResponse|null) => void
): UnaryResponse;
bumpAccountFee(
requestMessage: trader_pb.BumpAccountFeeRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.BumpAccountFeeResponse|null) => void
): UnaryResponse;
bumpAccountFee(
requestMessage: trader_pb.BumpAccountFeeRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.BumpAccountFeeResponse|null) => void
): UnaryResponse;
recoverAccounts(
requestMessage: trader_pb.RecoverAccountsRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.RecoverAccountsResponse|null) => void
): UnaryResponse;
recoverAccounts(
requestMessage: trader_pb.RecoverAccountsRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.RecoverAccountsResponse|null) => void
): UnaryResponse;
submitOrder(
requestMessage: trader_pb.SubmitOrderRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.SubmitOrderResponse|null) => void
): UnaryResponse;
submitOrder(
requestMessage: trader_pb.SubmitOrderRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.SubmitOrderResponse|null) => void
): UnaryResponse;
listOrders(
requestMessage: trader_pb.ListOrdersRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.ListOrdersResponse|null) => void
): UnaryResponse;
listOrders(
requestMessage: trader_pb.ListOrdersRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.ListOrdersResponse|null) => void
): UnaryResponse;
cancelOrder(
requestMessage: trader_pb.CancelOrderRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.CancelOrderResponse|null) => void
): UnaryResponse;
cancelOrder(
requestMessage: trader_pb.CancelOrderRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.CancelOrderResponse|null) => void
): UnaryResponse;
auctionFee(
requestMessage: trader_pb.AuctionFeeRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.AuctionFeeResponse|null) => void
): UnaryResponse;
auctionFee(
requestMessage: trader_pb.AuctionFeeRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.AuctionFeeResponse|null) => void
): UnaryResponse;
leaseDurations(
requestMessage: trader_pb.LeaseDurationRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.LeaseDurationResponse|null) => void
): UnaryResponse;
leaseDurations(
requestMessage: trader_pb.LeaseDurationRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.LeaseDurationResponse|null) => void
): UnaryResponse;
nextBatchInfo(
requestMessage: trader_pb.NextBatchInfoRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.NextBatchInfoResponse|null) => void
): UnaryResponse;
nextBatchInfo(
requestMessage: trader_pb.NextBatchInfoRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.NextBatchInfoResponse|null) => void
): UnaryResponse;
batchSnapshot(
requestMessage: auctioneer_pb.BatchSnapshotRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.BatchSnapshotResponse|null) => void
): UnaryResponse;
batchSnapshot(
requestMessage: auctioneer_pb.BatchSnapshotRequest,
callback: (error: ServiceError|null, responseMessage: auctioneer_pb.BatchSnapshotResponse|null) => void
): UnaryResponse;
getLsatTokens(
requestMessage: trader_pb.TokensRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.TokensResponse|null) => void
): UnaryResponse;
getLsatTokens(
requestMessage: trader_pb.TokensRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.TokensResponse|null) => void
): UnaryResponse;
leases(
requestMessage: trader_pb.LeasesRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.LeasesResponse|null) => void
): UnaryResponse;
leases(
requestMessage: trader_pb.LeasesRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.LeasesResponse|null) => void
): UnaryResponse;
nodeRatings(
requestMessage: trader_pb.NodeRatingRequest,
metadata: grpc.Metadata,
callback: (error: ServiceError|null, responseMessage: trader_pb.NodeRatingResponse|null) => void
): UnaryResponse;
nodeRatings(
requestMessage: trader_pb.NodeRatingRequest,
callback: (error: ServiceError|null, responseMessage: trader_pb.NodeRatingResponse|null) => void
): UnaryResponse;
}

View file

@ -0,0 +1,742 @@
// package: poolrpc
// file: trader.proto
var trader_pb = require("./trader_pb");
var auctioneer_pb = require("./auctioneer_pb");
var grpc = require("@improbable-eng/grpc-web").grpc;
var Trader = (function () {
function Trader() {}
Trader.serviceName = "poolrpc.Trader";
return Trader;
}());
Trader.QuoteAccount = {
methodName: "QuoteAccount",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.QuoteAccountRequest,
responseType: trader_pb.QuoteAccountResponse
};
Trader.InitAccount = {
methodName: "InitAccount",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.InitAccountRequest,
responseType: trader_pb.Account
};
Trader.ListAccounts = {
methodName: "ListAccounts",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.ListAccountsRequest,
responseType: trader_pb.ListAccountsResponse
};
Trader.CloseAccount = {
methodName: "CloseAccount",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.CloseAccountRequest,
responseType: trader_pb.CloseAccountResponse
};
Trader.WithdrawAccount = {
methodName: "WithdrawAccount",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.WithdrawAccountRequest,
responseType: trader_pb.WithdrawAccountResponse
};
Trader.DepositAccount = {
methodName: "DepositAccount",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.DepositAccountRequest,
responseType: trader_pb.DepositAccountResponse
};
Trader.BumpAccountFee = {
methodName: "BumpAccountFee",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.BumpAccountFeeRequest,
responseType: trader_pb.BumpAccountFeeResponse
};
Trader.RecoverAccounts = {
methodName: "RecoverAccounts",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.RecoverAccountsRequest,
responseType: trader_pb.RecoverAccountsResponse
};
Trader.SubmitOrder = {
methodName: "SubmitOrder",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.SubmitOrderRequest,
responseType: trader_pb.SubmitOrderResponse
};
Trader.ListOrders = {
methodName: "ListOrders",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.ListOrdersRequest,
responseType: trader_pb.ListOrdersResponse
};
Trader.CancelOrder = {
methodName: "CancelOrder",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.CancelOrderRequest,
responseType: trader_pb.CancelOrderResponse
};
Trader.AuctionFee = {
methodName: "AuctionFee",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.AuctionFeeRequest,
responseType: trader_pb.AuctionFeeResponse
};
Trader.LeaseDurations = {
methodName: "LeaseDurations",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.LeaseDurationRequest,
responseType: trader_pb.LeaseDurationResponse
};
Trader.NextBatchInfo = {
methodName: "NextBatchInfo",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.NextBatchInfoRequest,
responseType: trader_pb.NextBatchInfoResponse
};
Trader.BatchSnapshot = {
methodName: "BatchSnapshot",
service: Trader,
requestStream: false,
responseStream: false,
requestType: auctioneer_pb.BatchSnapshotRequest,
responseType: auctioneer_pb.BatchSnapshotResponse
};
Trader.GetLsatTokens = {
methodName: "GetLsatTokens",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.TokensRequest,
responseType: trader_pb.TokensResponse
};
Trader.Leases = {
methodName: "Leases",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.LeasesRequest,
responseType: trader_pb.LeasesResponse
};
Trader.NodeRatings = {
methodName: "NodeRatings",
service: Trader,
requestStream: false,
responseStream: false,
requestType: trader_pb.NodeRatingRequest,
responseType: trader_pb.NodeRatingResponse
};
exports.Trader = Trader;
function TraderClient(serviceHost, options) {
this.serviceHost = serviceHost;
this.options = options || {};
}
TraderClient.prototype.quoteAccount = function quoteAccount(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.QuoteAccount, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.initAccount = function initAccount(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.InitAccount, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.listAccounts = function listAccounts(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.ListAccounts, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.closeAccount = function closeAccount(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.CloseAccount, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.withdrawAccount = function withdrawAccount(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.WithdrawAccount, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.depositAccount = function depositAccount(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.DepositAccount, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.bumpAccountFee = function bumpAccountFee(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.BumpAccountFee, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.recoverAccounts = function recoverAccounts(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.RecoverAccounts, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.submitOrder = function submitOrder(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.SubmitOrder, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.listOrders = function listOrders(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.ListOrders, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.cancelOrder = function cancelOrder(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.CancelOrder, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.auctionFee = function auctionFee(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.AuctionFee, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.leaseDurations = function leaseDurations(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.LeaseDurations, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.nextBatchInfo = function nextBatchInfo(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.NextBatchInfo, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.batchSnapshot = function batchSnapshot(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.BatchSnapshot, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.getLsatTokens = function getLsatTokens(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.GetLsatTokens, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.leases = function leases(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.Leases, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
TraderClient.prototype.nodeRatings = function nodeRatings(requestMessage, metadata, callback) {
if (arguments.length === 2) {
callback = arguments[1];
}
var client = grpc.unary(Trader.NodeRatings, {
request: requestMessage,
host: this.serviceHost,
metadata: metadata,
transport: this.options.transport,
debug: this.options.debug,
onEnd: function (response) {
if (callback) {
if (response.status !== grpc.Code.OK) {
var err = new Error(response.statusMessage);
err.code = response.status;
err.metadata = response.trailers;
callback(err, null);
} else {
callback(null, response.message);
}
}
}
});
return {
cancel: function () {
callback = null;
client.close();
}
};
};
exports.TraderClient = TraderClient;