Git-Mirrors/haveno-ts
1
0
Fork 0
mirror of https://github.com/haveno-dex/haveno-ts.git synced 2024-12-24 23:09:26 -05:00
Code Issues Packages Projects Releases Wiki Activity

manually check daemon connections

Browse Source
This commit is contained in:
woodser 2024-04-23 10:44:13 -04:00
parent 4ae2155f41
commit ca8cea8e82
10 changed files with 135 additions and 133 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dist/HavenoClient.js vendored
View File

@ -518,7 +518,7 @@ class HavenoClient {
*/
async startCheckingConnection(refreshPeriod) {
try {
await this._xmrConnectionsClient.startCheckingConnections(new grpc_pb_1.StartCheckingConnectionsRequest().setRefreshPeriod(refreshPeriod), { password: this._password });
await this._xmrConnectionsClient.startCheckingConnection(new grpc_pb_1.StartCheckingConnectionRequest().setRefreshPeriod(refreshPeriod), { password: this._password });
}
catch (e) {
throw new HavenoError_1.default(e.message, e.code);
@ -529,7 +529,7 @@ class HavenoClient {
*/
async stopCheckingConnection() {
try {
await this._xmrConnectionsClient.stopCheckingConnections(new grpc_pb_1.StopCheckingConnectionsRequest(), { password: this._password });
await this._xmrConnectionsClient.stopCheckingConnection(new grpc_pb_1.StopCheckingConnectionRequest(), { password: this._password });
}
catch (e) {
throw new HavenoError_1.default(e.message, e.code);

2
dist/HavenoClient.js.map vendored
View File

File diff suppressed because one or more lines are too long

12
dist/protobuf/GrpcServiceClientPb.d.ts vendored
View File

@ -191,12 +191,12 @@ export declare class XmrConnectionsClient {
methodDescriptorCheckConnections: grpcWeb.MethodDescriptor<grpc_pb.CheckConnectionsRequest, grpc_pb.CheckConnectionsReply>;
checkConnections(request: grpc_pb.CheckConnectionsRequest, metadata?: grpcWeb.Metadata | null): Promise<grpc_pb.CheckConnectionsReply>;
checkConnections(request: grpc_pb.CheckConnectionsRequest, metadata: grpcWeb.Metadata | null, callback: (err: grpcWeb.RpcError, response: grpc_pb.CheckConnectionsReply) => void): grpcWeb.ClientReadableStream<grpc_pb.CheckConnectionsReply>;
methodDescriptorStartCheckingConnections: grpcWeb.MethodDescriptor<grpc_pb.StartCheckingConnectionsRequest, grpc_pb.StartCheckingConnectionsReply>;
startCheckingConnections(request: grpc_pb.StartCheckingConnectionsRequest, metadata?: grpcWeb.Metadata | null): Promise<grpc_pb.StartCheckingConnectionsReply>;
startCheckingConnections(request: grpc_pb.StartCheckingConnectionsRequest, metadata: grpcWeb.Metadata | null, callback: (err: grpcWeb.RpcError, response: grpc_pb.StartCheckingConnectionsReply) => void): grpcWeb.ClientReadableStream<grpc_pb.StartCheckingConnectionsReply>;
methodDescriptorStopCheckingConnections: grpcWeb.MethodDescriptor<grpc_pb.StopCheckingConnectionsRequest, grpc_pb.StopCheckingConnectionsReply>;
stopCheckingConnections(request: grpc_pb.StopCheckingConnectionsRequest, metadata?: grpcWeb.Metadata | null): Promise<grpc_pb.StopCheckingConnectionsReply>;
stopCheckingConnections(request: grpc_pb.StopCheckingConnectionsRequest, metadata: grpcWeb.Metadata | null, callback: (err: grpcWeb.RpcError, response: grpc_pb.StopCheckingConnectionsReply) => void): grpcWeb.ClientReadableStream<grpc_pb.StopCheckingConnectionsReply>;
methodDescriptorStartCheckingConnection: grpcWeb.MethodDescriptor<grpc_pb.StartCheckingConnectionRequest, grpc_pb.StartCheckingConnectionReply>;
startCheckingConnection(request: grpc_pb.StartCheckingConnectionRequest, metadata?: grpcWeb.Metadata | null): Promise<grpc_pb.StartCheckingConnectionReply>;
startCheckingConnection(request: grpc_pb.StartCheckingConnectionRequest, metadata: grpcWeb.Metadata | null, callback: (err: grpcWeb.RpcError, response: grpc_pb.StartCheckingConnectionReply) => void): grpcWeb.ClientReadableStream<grpc_pb.StartCheckingConnectionReply>;
methodDescriptorStopCheckingConnection: grpcWeb.MethodDescriptor<grpc_pb.StopCheckingConnectionRequest, grpc_pb.StopCheckingConnectionReply>;
stopCheckingConnection(request: grpc_pb.StopCheckingConnectionRequest, metadata?: grpcWeb.Metadata | null): Promise<grpc_pb.StopCheckingConnectionReply>;
stopCheckingConnection(request: grpc_pb.StopCheckingConnectionRequest, metadata: grpcWeb.Metadata | null, callback: (err: grpcWeb.RpcError, response: grpc_pb.StopCheckingConnectionReply) => void): grpcWeb.ClientReadableStream<grpc_pb.StopCheckingConnectionReply>;
methodDescriptorGetBestAvailableConnection: grpcWeb.MethodDescriptor<grpc_pb.GetBestAvailableConnectionRequest, grpc_pb.GetBestAvailableConnectionReply>;
getBestAvailableConnection(request: grpc_pb.GetBestAvailableConnectionRequest, metadata?: grpcWeb.Metadata | null): Promise<grpc_pb.GetBestAvailableConnectionReply>;
getBestAvailableConnection(request: grpc_pb.GetBestAvailableConnectionRequest, metadata: grpcWeb.Metadata | null, callback: (err: grpcWeb.RpcError, response: grpc_pb.GetBestAvailableConnectionReply) => void): grpcWeb.ClientReadableStream<grpc_pb.GetBestAvailableConnectionReply>;

20
dist/protobuf/GrpcServiceClientPb.js vendored
View File

@ -368,12 +368,12 @@ class XmrConnectionsClient {
this.methodDescriptorCheckConnections = new grpcWeb.MethodDescriptor('/io.haveno.protobuffer.XmrConnections/CheckConnections', grpcWeb.MethodType.UNARY, grpc_pb.CheckConnectionsRequest, grpc_pb.CheckConnectionsReply, (request) => {
return request.serializeBinary();
}, grpc_pb.CheckConnectionsReply.deserializeBinary);
this.methodDescriptorStartCheckingConnections = new grpcWeb.MethodDescriptor('/io.haveno.protobuffer.XmrConnections/StartCheckingConnections', grpcWeb.MethodType.UNARY, grpc_pb.StartCheckingConnectionsRequest, grpc_pb.StartCheckingConnectionsReply, (request) => {
this.methodDescriptorStartCheckingConnection = new grpcWeb.MethodDescriptor('/io.haveno.protobuffer.XmrConnections/StartCheckingConnection', grpcWeb.MethodType.UNARY, grpc_pb.StartCheckingConnectionRequest, grpc_pb.StartCheckingConnectionReply, (request) => {
return request.serializeBinary();
}, grpc_pb.StartCheckingConnectionsReply.deserializeBinary);
this.methodDescriptorStopCheckingConnections = new grpcWeb.MethodDescriptor('/io.haveno.protobuffer.XmrConnections/StopCheckingConnections', grpcWeb.MethodType.UNARY, grpc_pb.StopCheckingConnectionsRequest, grpc_pb.StopCheckingConnectionsReply, (request) => {
}, grpc_pb.StartCheckingConnectionReply.deserializeBinary);
this.methodDescriptorStopCheckingConnection = new grpcWeb.MethodDescriptor('/io.haveno.protobuffer.XmrConnections/StopCheckingConnection', grpcWeb.MethodType.UNARY, grpc_pb.StopCheckingConnectionRequest, grpc_pb.StopCheckingConnectionReply, (request) => {
return request.serializeBinary();
}, grpc_pb.StopCheckingConnectionsReply.deserializeBinary);
}, grpc_pb.StopCheckingConnectionReply.deserializeBinary);
this.methodDescriptorGetBestAvailableConnection = new grpcWeb.MethodDescriptor('/io.haveno.protobuffer.XmrConnections/GetBestAvailableConnection', grpcWeb.MethodType.UNARY, grpc_pb.GetBestAvailableConnectionRequest, grpc_pb.GetBestAvailableConnectionReply, (request) => {
return request.serializeBinary();
}, grpc_pb.GetBestAvailableConnectionReply.deserializeBinary);
@ -446,21 +446,21 @@ class XmrConnectionsClient {
return this.client_.unaryCall(this.hostname_ +
'/io.haveno.protobuffer.XmrConnections/CheckConnections', request, metadata || {}, this.methodDescriptorCheckConnections);
}
startCheckingConnections(request, metadata, callback) {
startCheckingConnection(request, metadata, callback) {
if (callback !== undefined) {
return this.client_.rpcCall(this.hostname_ +
'/io.haveno.protobuffer.XmrConnections/StartCheckingConnections', request, metadata || {}, this.methodDescriptorStartCheckingConnections, callback);
'/io.haveno.protobuffer.XmrConnections/StartCheckingConnection', request, metadata || {}, this.methodDescriptorStartCheckingConnection, callback);
}
return this.client_.unaryCall(this.hostname_ +
'/io.haveno.protobuffer.XmrConnections/StartCheckingConnections', request, metadata || {}, this.methodDescriptorStartCheckingConnections);
'/io.haveno.protobuffer.XmrConnections/StartCheckingConnection', request, metadata || {}, this.methodDescriptorStartCheckingConnection);
}
stopCheckingConnections(request, metadata, callback) {
stopCheckingConnection(request, metadata, callback) {
if (callback !== undefined) {
return this.client_.rpcCall(this.hostname_ +
'/io.haveno.protobuffer.XmrConnections/StopCheckingConnections', request, metadata || {}, this.methodDescriptorStopCheckingConnections, callback);
'/io.haveno.protobuffer.XmrConnections/StopCheckingConnection', request, metadata || {}, this.methodDescriptorStopCheckingConnection, callback);
}
return this.client_.unaryCall(this.hostname_ +
'/io.haveno.protobuffer.XmrConnections/StopCheckingConnections', request, metadata || {}, this.methodDescriptorStopCheckingConnections);
'/io.haveno.protobuffer.XmrConnections/StopCheckingConnection', request, metadata || {}, this.methodDescriptorStopCheckingConnection);
}
getBestAvailableConnection(request, metadata, callback) {
if (callback !== undefined) {

2
dist/protobuf/GrpcServiceClientPb.js.map vendored
View File

File diff suppressed because one or more lines are too long

58
dist/protobuf/grpc_pb.d.ts vendored
View File

@ -1057,62 +1057,62 @@ export namespace CheckConnectionsReply {
}
}
export class StartCheckingConnectionsRequest extends jspb.Message {
export class StartCheckingConnectionRequest extends jspb.Message {
getRefreshPeriod(): number;
setRefreshPeriod(value: number): StartCheckingConnectionsRequest;
setRefreshPeriod(value: number): StartCheckingConnectionRequest;
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): StartCheckingConnectionsRequest.AsObject;
static toObject(includeInstance: boolean, msg: StartCheckingConnectionsRequest): StartCheckingConnectionsRequest.AsObject;
static serializeBinaryToWriter(message: StartCheckingConnectionsRequest, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): StartCheckingConnectionsRequest;
static deserializeBinaryFromReader(message: StartCheckingConnectionsRequest, reader: jspb.BinaryReader): StartCheckingConnectionsRequest;
toObject(includeInstance?: boolean): StartCheckingConnectionRequest.AsObject;
static toObject(includeInstance: boolean, msg: StartCheckingConnectionRequest): StartCheckingConnectionRequest.AsObject;
static serializeBinaryToWriter(message: StartCheckingConnectionRequest, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): StartCheckingConnectionRequest;
static deserializeBinaryFromReader(message: StartCheckingConnectionRequest, reader: jspb.BinaryReader): StartCheckingConnectionRequest;
}
export namespace StartCheckingConnectionsRequest {
export namespace StartCheckingConnectionRequest {
export type AsObject = {
refreshPeriod: number,
}
}
export class StartCheckingConnectionsReply extends jspb.Message {
export class StartCheckingConnectionReply extends jspb.Message {
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): StartCheckingConnectionsReply.AsObject;
static toObject(includeInstance: boolean, msg: StartCheckingConnectionsReply): StartCheckingConnectionsReply.AsObject;
static serializeBinaryToWriter(message: StartCheckingConnectionsReply, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): StartCheckingConnectionsReply;
static deserializeBinaryFromReader(message: StartCheckingConnectionsReply, reader: jspb.BinaryReader): StartCheckingConnectionsReply;
toObject(includeInstance?: boolean): StartCheckingConnectionReply.AsObject;
static toObject(includeInstance: boolean, msg: StartCheckingConnectionReply): StartCheckingConnectionReply.AsObject;
static serializeBinaryToWriter(message: StartCheckingConnectionReply, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): StartCheckingConnectionReply;
static deserializeBinaryFromReader(message: StartCheckingConnectionReply, reader: jspb.BinaryReader): StartCheckingConnectionReply;
}
export namespace StartCheckingConnectionsReply {
export namespace StartCheckingConnectionReply {
export type AsObject = {
}
}
export class StopCheckingConnectionsRequest extends jspb.Message {
export class StopCheckingConnectionRequest extends jspb.Message {
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): StopCheckingConnectionsRequest.AsObject;
static toObject(includeInstance: boolean, msg: StopCheckingConnectionsRequest): StopCheckingConnectionsRequest.AsObject;
static serializeBinaryToWriter(message: StopCheckingConnectionsRequest, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): StopCheckingConnectionsRequest;
static deserializeBinaryFromReader(message: StopCheckingConnectionsRequest, reader: jspb.BinaryReader): StopCheckingConnectionsRequest;
toObject(includeInstance?: boolean): StopCheckingConnectionRequest.AsObject;
static toObject(includeInstance: boolean, msg: StopCheckingConnectionRequest): StopCheckingConnectionRequest.AsObject;
static serializeBinaryToWriter(message: StopCheckingConnectionRequest, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): StopCheckingConnectionRequest;
static deserializeBinaryFromReader(message: StopCheckingConnectionRequest, reader: jspb.BinaryReader): StopCheckingConnectionRequest;
}
export namespace StopCheckingConnectionsRequest {
export namespace StopCheckingConnectionRequest {
export type AsObject = {
}
}
export class StopCheckingConnectionsReply extends jspb.Message {
export class StopCheckingConnectionReply extends jspb.Message {
serializeBinary(): Uint8Array;
toObject(includeInstance?: boolean): StopCheckingConnectionsReply.AsObject;
static toObject(includeInstance: boolean, msg: StopCheckingConnectionsReply): StopCheckingConnectionsReply.AsObject;
static serializeBinaryToWriter(message: StopCheckingConnectionsReply, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): StopCheckingConnectionsReply;
static deserializeBinaryFromReader(message: StopCheckingConnectionsReply, reader: jspb.BinaryReader): StopCheckingConnectionsReply;
toObject(includeInstance?: boolean): StopCheckingConnectionReply.AsObject;
static toObject(includeInstance: boolean, msg: StopCheckingConnectionReply): StopCheckingConnectionReply.AsObject;
static serializeBinaryToWriter(message: StopCheckingConnectionReply, writer: jspb.BinaryWriter): void;
static deserializeBinary(bytes: Uint8Array): StopCheckingConnectionReply;
static deserializeBinaryFromReader(message: StopCheckingConnectionReply, reader: jspb.BinaryReader): StopCheckingConnectionReply;
}
export namespace StopCheckingConnectionsReply {
export namespace StopCheckingConnectionReply {
export type AsObject = {
}
}

158
dist/protobuf/grpc_pb.js vendored
View File

@ -162,12 +162,12 @@ goog.exportSymbol('proto.io.haveno.protobuffer.SetConnectionReply', null, global
goog.exportSymbol('proto.io.haveno.protobuffer.SetConnectionRequest', null, global);
goog.exportSymbol('proto.io.haveno.protobuffer.SetWalletPasswordReply', null, global);
goog.exportSymbol('proto.io.haveno.protobuffer.SetWalletPasswordRequest', null, global);
goog.exportSymbol('proto.io.haveno.protobuffer.StartCheckingConnectionsReply', null, global);
goog.exportSymbol('proto.io.haveno.protobuffer.StartCheckingConnectionsRequest', null, global);
goog.exportSymbol('proto.io.haveno.protobuffer.StartCheckingConnectionReply', null, global);
goog.exportSymbol('proto.io.haveno.protobuffer.StartCheckingConnectionRequest', null, global);
goog.exportSymbol('proto.io.haveno.protobuffer.StartXmrNodeReply', null, global);
goog.exportSymbol('proto.io.haveno.protobuffer.StartXmrNodeRequest', null, global);
goog.exportSymbol('proto.io.haveno.protobuffer.StopCheckingConnectionsReply', null, global);
goog.exportSymbol('proto.io.haveno.protobuffer.StopCheckingConnectionsRequest', null, global);
goog.exportSymbol('proto.io.haveno.protobuffer.StopCheckingConnectionReply', null, global);
goog.exportSymbol('proto.io.haveno.protobuffer.StopCheckingConnectionRequest', null, global);
goog.exportSymbol('proto.io.haveno.protobuffer.StopReply', null, global);
goog.exportSymbol('proto.io.haveno.protobuffer.StopRequest', null, global);
goog.exportSymbol('proto.io.haveno.protobuffer.StopXmrNodeReply', null, global);
@ -1398,16 +1398,16 @@ if (goog.DEBUG && !COMPILED) {
* @extends {jspb.Message}
* @constructor
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsRequest = function(opt_data) {
proto.io.haveno.protobuffer.StartCheckingConnectionRequest = function(opt_data) {
jspb.Message.initialize(this, opt_data, 0, -1, null, null);
};
goog.inherits(proto.io.haveno.protobuffer.StartCheckingConnectionsRequest, jspb.Message);
goog.inherits(proto.io.haveno.protobuffer.StartCheckingConnectionRequest, jspb.Message);
if (goog.DEBUG && !COMPILED) {
/**
* @public
* @override
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.displayName = 'proto.io.haveno.protobuffer.StartCheckingConnectionsRequest';
proto.io.haveno.protobuffer.StartCheckingConnectionRequest.displayName = 'proto.io.haveno.protobuffer.StartCheckingConnectionRequest';
}
/**
* Generated by JsPbCodeGenerator.
@ -1419,16 +1419,16 @@ if (goog.DEBUG && !COMPILED) {
* @extends {jspb.Message}
* @constructor
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsReply = function(opt_data) {
proto.io.haveno.protobuffer.StartCheckingConnectionReply = function(opt_data) {
jspb.Message.initialize(this, opt_data, 0, -1, null, null);
};
goog.inherits(proto.io.haveno.protobuffer.StartCheckingConnectionsReply, jspb.Message);
goog.inherits(proto.io.haveno.protobuffer.StartCheckingConnectionReply, jspb.Message);
if (goog.DEBUG && !COMPILED) {
/**
* @public
* @override
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsReply.displayName = 'proto.io.haveno.protobuffer.StartCheckingConnectionsReply';
proto.io.haveno.protobuffer.StartCheckingConnectionReply.displayName = 'proto.io.haveno.protobuffer.StartCheckingConnectionReply';
}
/**
* Generated by JsPbCodeGenerator.
@ -1440,16 +1440,16 @@ if (goog.DEBUG && !COMPILED) {
* @extends {jspb.Message}
* @constructor
*/
proto.io.haveno.protobuffer.StopCheckingConnectionsRequest = function(opt_data) {
proto.io.haveno.protobuffer.StopCheckingConnectionRequest = function(opt_data) {
jspb.Message.initialize(this, opt_data, 0, -1, null, null);
};
goog.inherits(proto.io.haveno.protobuffer.StopCheckingConnectionsRequest, jspb.Message);
goog.inherits(proto.io.haveno.protobuffer.StopCheckingConnectionRequest, jspb.Message);
if (goog.DEBUG && !COMPILED) {
/**
* @public
* @override
*/
proto.io.haveno.protobuffer.StopCheckingConnectionsRequest.displayName = 'proto.io.haveno.protobuffer.StopCheckingConnectionsRequest';
proto.io.haveno.protobuffer.StopCheckingConnectionRequest.displayName = 'proto.io.haveno.protobuffer.StopCheckingConnectionRequest';
}
/**
* Generated by JsPbCodeGenerator.
@ -1461,16 +1461,16 @@ if (goog.DEBUG && !COMPILED) {
* @extends {jspb.Message}
* @constructor
*/
proto.io.haveno.protobuffer.StopCheckingConnectionsReply = function(opt_data) {
proto.io.haveno.protobuffer.StopCheckingConnectionReply = function(opt_data) {
jspb.Message.initialize(this, opt_data, 0, -1, null, null);
};
goog.inherits(proto.io.haveno.protobuffer.StopCheckingConnectionsReply, jspb.Message);
goog.inherits(proto.io.haveno.protobuffer.StopCheckingConnectionReply, jspb.Message);
if (goog.DEBUG && !COMPILED) {
/**
* @public
* @override
*/
proto.io.haveno.protobuffer.StopCheckingConnectionsReply.displayName = 'proto.io.haveno.protobuffer.StopCheckingConnectionsReply';
proto.io.haveno.protobuffer.StopCheckingConnectionReply.displayName = 'proto.io.haveno.protobuffer.StopCheckingConnectionReply';
}
/**
* Generated by JsPbCodeGenerator.
@ -11430,8 +11430,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) {
* http://goto/soy-param-migration
* @return {!Object}
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.prototype.toObject = function(opt_includeInstance) {
return proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.toObject(opt_includeInstance, this);
proto.io.haveno.protobuffer.StartCheckingConnectionRequest.prototype.toObject = function(opt_includeInstance) {
return proto.io.haveno.protobuffer.StartCheckingConnectionRequest.toObject(opt_includeInstance, this);
};
@ -11440,11 +11440,11 @@ proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.prototype.toObject =
* @param {boolean|undefined} includeInstance Deprecated. Whether to include
* the JSPB instance for transitional soy proto support:
* http://goto/soy-param-migration
* @param {!proto.io.haveno.protobuffer.StartCheckingConnectionsRequest} msg The msg instance to transform.
* @param {!proto.io.haveno.protobuffer.StartCheckingConnectionRequest} msg The msg instance to transform.
* @return {!Object}
* @suppress {unusedLocalVariables} f is only used for nested messages
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.toObject = function(includeInstance, msg) {
proto.io.haveno.protobuffer.StartCheckingConnectionRequest.toObject = function(includeInstance, msg) {
var f, obj = {
refreshPeriod: jspb.Message.getFieldWithDefault(msg, 1, 0)
};
@ -11460,23 +11460,23 @@ proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.toObject = function(
/**
* Deserializes binary data (in protobuf wire format).
* @param {jspb.ByteSource} bytes The bytes to deserialize.
* @return {!proto.io.haveno.protobuffer.StartCheckingConnectionsRequest}
* @return {!proto.io.haveno.protobuffer.StartCheckingConnectionRequest}
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.deserializeBinary = function(bytes) {
proto.io.haveno.protobuffer.StartCheckingConnectionRequest.deserializeBinary = function(bytes) {
var reader = new jspb.BinaryReader(bytes);
var msg = new proto.io.haveno.protobuffer.StartCheckingConnectionsRequest;
return proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.deserializeBinaryFromReader(msg, reader);
var msg = new proto.io.haveno.protobuffer.StartCheckingConnectionRequest;
return proto.io.haveno.protobuffer.StartCheckingConnectionRequest.deserializeBinaryFromReader(msg, reader);
};
/**
* Deserializes binary data (in protobuf wire format) from the
* given reader into the given message object.
* @param {!proto.io.haveno.protobuffer.StartCheckingConnectionsRequest} msg The message object to deserialize into.
* @param {!proto.io.haveno.protobuffer.StartCheckingConnectionRequest} msg The message object to deserialize into.
* @param {!jspb.BinaryReader} reader The BinaryReader to use.
* @return {!proto.io.haveno.protobuffer.StartCheckingConnectionsRequest}
* @return {!proto.io.haveno.protobuffer.StartCheckingConnectionRequest}
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.deserializeBinaryFromReader = function(msg, reader) {
proto.io.haveno.protobuffer.StartCheckingConnectionRequest.deserializeBinaryFromReader = function(msg, reader) {
while (reader.nextField()) {
if (reader.isEndGroup()) {
break;
@ -11500,9 +11500,9 @@ proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.deserializeBinaryFro
* Serializes the message to binary data (in protobuf wire format).
* @return {!Uint8Array}
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.prototype.serializeBinary = function() {
proto.io.haveno.protobuffer.StartCheckingConnectionRequest.prototype.serializeBinary = function() {
var writer = new jspb.BinaryWriter();
proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.serializeBinaryToWriter(this, writer);
proto.io.haveno.protobuffer.StartCheckingConnectionRequest.serializeBinaryToWriter(this, writer);
return writer.getResultBuffer();
};
@ -11510,11 +11510,11 @@ proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.prototype.serializeB
/**
* Serializes the given message to binary data (in protobuf wire
* format), writing to the given BinaryWriter.
* @param {!proto.io.haveno.protobuffer.StartCheckingConnectionsRequest} message
* @param {!proto.io.haveno.protobuffer.StartCheckingConnectionRequest} message
* @param {!jspb.BinaryWriter} writer
* @suppress {unusedLocalVariables} f is only used for nested messages
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.serializeBinaryToWriter = function(message, writer) {
proto.io.haveno.protobuffer.StartCheckingConnectionRequest.serializeBinaryToWriter = function(message, writer) {
var f = undefined;
f = message.getRefreshPeriod();
if (f !== 0) {
@ -11530,16 +11530,16 @@ proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.serializeBinaryToWri
* optional int32 refresh_period = 1;
* @return {number}
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.prototype.getRefreshPeriod = function() {
proto.io.haveno.protobuffer.StartCheckingConnectionRequest.prototype.getRefreshPeriod = function() {
return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 1, 0));
};
/**
* @param {number} value
* @return {!proto.io.haveno.protobuffer.StartCheckingConnectionsRequest} returns this
* @return {!proto.io.haveno.protobuffer.StartCheckingConnectionRequest} returns this
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsRequest.prototype.setRefreshPeriod = function(value) {
proto.io.haveno.protobuffer.StartCheckingConnectionRequest.prototype.setRefreshPeriod = function(value) {
return jspb.Message.setProto3IntField(this, 1, value);
};
@ -11560,8 +11560,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) {
* http://goto/soy-param-migration
* @return {!Object}
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsReply.prototype.toObject = function(opt_includeInstance) {
return proto.io.haveno.protobuffer.StartCheckingConnectionsReply.toObject(opt_includeInstance, this);
proto.io.haveno.protobuffer.StartCheckingConnectionReply.prototype.toObject = function(opt_includeInstance) {
return proto.io.haveno.protobuffer.StartCheckingConnectionReply.toObject(opt_includeInstance, this);
};
@ -11570,11 +11570,11 @@ proto.io.haveno.protobuffer.StartCheckingConnectionsReply.prototype.toObject = f
* @param {boolean|undefined} includeInstance Deprecated. Whether to include
* the JSPB instance for transitional soy proto support:
* http://goto/soy-param-migration
* @param {!proto.io.haveno.protobuffer.StartCheckingConnectionsReply} msg The msg instance to transform.
* @param {!proto.io.haveno.protobuffer.StartCheckingConnectionReply} msg The msg instance to transform.
* @return {!Object}
* @suppress {unusedLocalVariables} f is only used for nested messages
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsReply.toObject = function(includeInstance, msg) {
proto.io.haveno.protobuffer.StartCheckingConnectionReply.toObject = function(includeInstance, msg) {
var f, obj = {
};
@ -11590,23 +11590,23 @@ proto.io.haveno.protobuffer.StartCheckingConnectionsReply.toObject = function(in
/**
* Deserializes binary data (in protobuf wire format).
* @param {jspb.ByteSource} bytes The bytes to deserialize.
* @return {!proto.io.haveno.protobuffer.StartCheckingConnectionsReply}
* @return {!proto.io.haveno.protobuffer.StartCheckingConnectionReply}
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsReply.deserializeBinary = function(bytes) {
proto.io.haveno.protobuffer.StartCheckingConnectionReply.deserializeBinary = function(bytes) {
var reader = new jspb.BinaryReader(bytes);
var msg = new proto.io.haveno.protobuffer.StartCheckingConnectionsReply;
return proto.io.haveno.protobuffer.StartCheckingConnectionsReply.deserializeBinaryFromReader(msg, reader);
var msg = new proto.io.haveno.protobuffer.StartCheckingConnectionReply;
return proto.io.haveno.protobuffer.StartCheckingConnectionReply.deserializeBinaryFromReader(msg, reader);
};
/**
* Deserializes binary data (in protobuf wire format) from the
* given reader into the given message object.
* @param {!proto.io.haveno.protobuffer.StartCheckingConnectionsReply} msg The message object to deserialize into.
* @param {!proto.io.haveno.protobuffer.StartCheckingConnectionReply} msg The message object to deserialize into.
* @param {!jspb.BinaryReader} reader The BinaryReader to use.
* @return {!proto.io.haveno.protobuffer.StartCheckingConnectionsReply}
* @return {!proto.io.haveno.protobuffer.StartCheckingConnectionReply}
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsReply.deserializeBinaryFromReader = function(msg, reader) {
proto.io.haveno.protobuffer.StartCheckingConnectionReply.deserializeBinaryFromReader = function(msg, reader) {
while (reader.nextField()) {
if (reader.isEndGroup()) {
break;
@ -11626,9 +11626,9 @@ proto.io.haveno.protobuffer.StartCheckingConnectionsReply.deserializeBinaryFromR
* Serializes the message to binary data (in protobuf wire format).
* @return {!Uint8Array}
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsReply.prototype.serializeBinary = function() {
proto.io.haveno.protobuffer.StartCheckingConnectionReply.prototype.serializeBinary = function() {
var writer = new jspb.BinaryWriter();
proto.io.haveno.protobuffer.StartCheckingConnectionsReply.serializeBinaryToWriter(this, writer);
proto.io.haveno.protobuffer.StartCheckingConnectionReply.serializeBinaryToWriter(this, writer);
return writer.getResultBuffer();
};
@ -11636,11 +11636,11 @@ proto.io.haveno.protobuffer.StartCheckingConnectionsReply.prototype.serializeBin
/**
* Serializes the given message to binary data (in protobuf wire
* format), writing to the given BinaryWriter.
* @param {!proto.io.haveno.protobuffer.StartCheckingConnectionsReply} message
* @param {!proto.io.haveno.protobuffer.StartCheckingConnectionReply} message
* @param {!jspb.BinaryWriter} writer
* @suppress {unusedLocalVariables} f is only used for nested messages
*/
proto.io.haveno.protobuffer.StartCheckingConnectionsReply.serializeBinaryToWriter = function(message, writer) {
proto.io.haveno.protobuffer.StartCheckingConnectionReply.serializeBinaryToWriter = function(message, writer) {
var f = undefined;
};
@ -11661,8 +11661,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) {
* http://goto/soy-param-migration
* @return {!Object}
*/
proto.io.haveno.protobuffer.StopCheckingConnectionsRequest.prototype.toObject = function(opt_includeInstance) {
return proto.io.haveno.protobuffer.StopCheckingConnectionsRequest.toObject(opt_includeInstance, this);
proto.io.haveno.protobuffer.StopCheckingConnectionRequest.prototype.toObject = function(opt_includeInstance) {
return proto.io.haveno.protobuffer.StopCheckingConnectionRequest.toObject(opt_includeInstance, this);
};
@ -11671,11 +11671,11 @@ proto.io.haveno.protobuffer.StopCheckingConnectionsRequest.prototype.toObject =
* @param {boolean|undefined} includeInstance Deprecated. Whether to include
* the JSPB instance for transitional soy proto support:
* http://goto/soy-param-migration
* @param {!proto.io.haveno.protobuffer.StopCheckingConnectionsRequest} msg The msg instance to transform.
* @param {!proto.io.haveno.protobuffer.StopCheckingConnectionRequest} msg The msg instance to transform.
* @return {!Object}
* @suppress {unusedLocalVariables} f is only used for nested messages
*/
proto.io.haveno.protobuffer.StopCheckingConnectionsRequest.toObject = function(includeInstance, msg) {
proto.io.haveno.protobuffer.StopCheckingConnectionRequest.toObject = function(includeInstance, msg) {
var f, obj = {
};
@ -11691,23 +11691,23 @@ proto.io.haveno.protobuffer.StopCheckingConnectionsRequest.toObject = function(i
/**
* Deserializes binary data (in protobuf wire format).
* @param {jspb.ByteSource} bytes The bytes to deserialize.
* @return {!proto.io.haveno.protobuffer.StopCheckingConnectionsRequest}
* @return {!proto.io.haveno.protobuffer.StopCheckingConnectionRequest}
*/
proto.io.haveno.protobuffer.StopCheckingConnectionsRequest.deserializeBinary = function(bytes) {
proto.io.haveno.protobuffer.StopCheckingConnectionRequest.deserializeBinary = function(bytes) {
var reader = new jspb.BinaryReader(bytes);
var msg = new proto.io.haveno.protobuffer.StopCheckingConnectionsRequest;
return proto.io.haveno.protobuffer.StopCheckingConnectionsRequest.deserializeBinaryFromReader(msg, reader);
var msg = new proto.io.haveno.protobuffer.StopCheckingConnectionRequest;
return proto.io.haveno.protobuffer.StopCheckingConnectionRequest.deserializeBinaryFromReader(msg, reader);
};
/**
* Deserializes binary data (in protobuf wire format) from the
* given reader into the given message object.
* @param {!proto.io.haveno.protobuffer.StopCheckingConnectionsRequest} msg The message object to deserialize into.
* @param {!proto.io.haveno.protobuffer.StopCheckingConnectionRequest} msg The message object to deserialize into.
* @param {!jspb.BinaryReader} reader The BinaryReader to use.
* @return {!proto.io.haveno.protobuffer.StopCheckingConnectionsRequest}
* @return {!proto.io.haveno.protobuffer.StopCheckingConnectionRequest}
*/
proto.io.haveno.protobuffer.StopCheckingConnectionsRequest.deserializeBinaryFromReader = function(msg, reader) {
proto.io.haveno.protobuffer.StopCheckingConnectionRequest.deserializeBinaryFromReader = function(msg, reader) {
while (reader.nextField()) {
if (reader.isEndGroup()) {
break;
@ -11727,9 +11727,9 @@ proto.io.haveno.protobuffer.StopCheckingConnectionsRequest.deserializeBinaryFrom
* Serializes the message to binary data (in protobuf wire format).
* @return {!Uint8Array}
*/
proto.io.haveno.protobuffer.StopCheckingConnectionsRequest.prototype.serializeBinary = function() {
proto.io.haveno.protobuffer.StopCheckingConnectionRequest.prototype.serializeBinary = function() {
var writer = new jspb.BinaryWriter();
proto.io.haveno.protobuffer.StopCheckingConnectionsRequest.serializeBinaryToWriter(this, writer);
proto.io.haveno.protobuffer.StopCheckingConnectionRequest.serializeBinaryToWriter(this, writer);
return writer.getResultBuffer();
};
@ -11737,11 +11737,11 @@ proto.io.haveno.protobuffer.StopCheckingConnectionsRequest.prototype.serializeBi
/**
* Serializes the given message to binary data (in protobuf wire
* format), writing to the given BinaryWriter.
* @param {!proto.io.haveno.protobuffer.StopCheckingConnectionsRequest} message
* @param {!proto.io.haveno.protobuffer.StopCheckingConnectionRequest} message
* @param {!jspb.BinaryWriter} writer
* @suppress {unusedLocalVariables} f is only used for nested messages
*/
proto.io.haveno.protobuffer.StopCheckingConnectionsRequest.serializeBinaryToWriter = function(message, writer) {
proto.io.haveno.protobuffer.StopCheckingConnectionRequest.serializeBinaryToWriter = function(message, writer) {
var f = undefined;
};
@ -11762,8 +11762,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) {
* http://goto/soy-param-migration
* @return {!Object}
*/
proto.io.haveno.protobuffer.StopCheckingConnectionsReply.prototype.toObject = function(opt_includeInstance) {
return proto.io.haveno.protobuffer.StopCheckingConnectionsReply.toObject(opt_includeInstance, this);
proto.io.haveno.protobuffer.StopCheckingConnectionReply.prototype.toObject = function(opt_includeInstance) {
return proto.io.haveno.protobuffer.StopCheckingConnectionReply.toObject(opt_includeInstance, this);
};
@ -11772,11 +11772,11 @@ proto.io.haveno.protobuffer.StopCheckingConnectionsReply.prototype.toObject = fu
* @param {boolean|undefined} includeInstance Deprecated. Whether to include
* the JSPB instance for transitional soy proto support:
* http://goto/soy-param-migration
* @param {!proto.io.haveno.protobuffer.StopCheckingConnectionsReply} msg The msg instance to transform.
* @param {!proto.io.haveno.protobuffer.StopCheckingConnectionReply} msg The msg instance to transform.
* @return {!Object}
* @suppress {unusedLocalVariables} f is only used for nested messages
*/
proto.io.haveno.protobuffer.StopCheckingConnectionsReply.toObject = function(includeInstance, msg) {
proto.io.haveno.protobuffer.StopCheckingConnectionReply.toObject = function(includeInstance, msg) {
var f, obj = {
};
@ -11792,23 +11792,23 @@ proto.io.haveno.protobuffer.StopCheckingConnectionsReply.toObject = function(inc
/**
* Deserializes binary data (in protobuf wire format).
* @param {jspb.ByteSource} bytes The bytes to deserialize.
* @return {!proto.io.haveno.protobuffer.StopCheckingConnectionsReply}
* @return {!proto.io.haveno.protobuffer.StopCheckingConnectionReply}
*/
proto.io.haveno.protobuffer.StopCheckingConnectionsReply.deserializeBinary = function(bytes) {
proto.io.haveno.protobuffer.StopCheckingConnectionReply.deserializeBinary = function(bytes) {
var reader = new jspb.BinaryReader(bytes);
var msg = new proto.io.haveno.protobuffer.StopCheckingConnectionsReply;
return proto.io.haveno.protobuffer.StopCheckingConnectionsReply.deserializeBinaryFromReader(msg, reader);
var msg = new proto.io.haveno.protobuffer.StopCheckingConnectionReply;
return proto.io.haveno.protobuffer.StopCheckingConnectionReply.deserializeBinaryFromReader(msg, reader);
};
/**
* Deserializes binary data (in protobuf wire format) from the
* given reader into the given message object.
* @param {!proto.io.haveno.protobuffer.StopCheckingConnectionsReply} msg The message object to deserialize into.
* @param {!proto.io.haveno.protobuffer.StopCheckingConnectionReply} msg The message object to deserialize into.
* @param {!jspb.BinaryReader} reader The BinaryReader to use.
* @return {!proto.io.haveno.protobuffer.StopCheckingConnectionsReply}
* @return {!proto.io.haveno.protobuffer.StopCheckingConnectionReply}
*/
proto.io.haveno.protobuffer.StopCheckingConnectionsReply.deserializeBinaryFromReader = function(msg, reader) {
proto.io.haveno.protobuffer.StopCheckingConnectionReply.deserializeBinaryFromReader = function(msg, reader) {
while (reader.nextField()) {
if (reader.isEndGroup()) {
break;
@ -11828,9 +11828,9 @@ proto.io.haveno.protobuffer.StopCheckingConnectionsReply.deserializeBinaryFromRe
* Serializes the message to binary data (in protobuf wire format).
* @return {!Uint8Array}
*/
proto.io.haveno.protobuffer.StopCheckingConnectionsReply.prototype.serializeBinary = function() {
proto.io.haveno.protobuffer.StopCheckingConnectionReply.prototype.serializeBinary = function() {
var writer = new jspb.BinaryWriter();
proto.io.haveno.protobuffer.StopCheckingConnectionsReply.serializeBinaryToWriter(this, writer);
proto.io.haveno.protobuffer.StopCheckingConnectionReply.serializeBinaryToWriter(this, writer);
return writer.getResultBuffer();
};
@ -11838,11 +11838,11 @@ proto.io.haveno.protobuffer.StopCheckingConnectionsReply.prototype.serializeBina
/**
* Serializes the given message to binary data (in protobuf wire
* format), writing to the given BinaryWriter.
* @param {!proto.io.haveno.protobuffer.StopCheckingConnectionsReply} message
* @param {!proto.io.haveno.protobuffer.StopCheckingConnectionReply} message
* @param {!jspb.BinaryWriter} writer
* @suppress {unusedLocalVariables} f is only used for nested messages
*/
proto.io.haveno.protobuffer.StopCheckingConnectionsReply.serializeBinaryToWriter = function(message, writer) {
proto.io.haveno.protobuffer.StopCheckingConnectionReply.serializeBinaryToWriter = function(message, writer) {
var f = undefined;
};

2
dist/protobuf/grpc_pb.js.map vendored
View File

File diff suppressed because one or more lines are too long

4
src/HavenoClient.test.ts
View File

@ -798,11 +798,12 @@ test("Can manage Monero daemon connections (CI)", async () => {
user3 = await initHaveno({appName: appName, accountPassword: newPassword});
// connection is restored, online, and authenticated
await user3.checkMoneroConnection();
connection = await user3.getMoneroConnection();
testConnection(connection!, TestConfig.monerod3.url, OnlineStatus.ONLINE, AuthenticationStatus.AUTHENTICATED, 1);
// priority connections are polled
await wait(TestConfig.daemonPollPeriodMs * 2);
await user3.checkMoneroConnections();
connections = await user3.getMoneroConnections();
testConnection(getConnection(connections, monerodUrl1)!, monerodUrl1, OnlineStatus.ONLINE, AuthenticationStatus.AUTHENTICATED, 1);
@ -815,6 +816,7 @@ test("Can manage Monero daemon connections (CI)", async () => {
// test auto switch after periodic connection check
await wait(TestConfig.daemonPollPeriodMs * 2);
await user3.checkMoneroConnection();
connection = await user3.getMoneroConnection();
testConnection(connection!, monerodUrl1, OnlineStatus.ONLINE, AuthenticationStatus.AUTHENTICATED, 1);

6
src/HavenoClient.ts
View File

@ -21,7 +21,7 @@ import HavenoUtils from "./utils/HavenoUtils";
import TaskLooper from "./utils/TaskLooper";
import type * as grpcWeb from "grpc-web";
import { GetVersionClient, AccountClient, XmrConnectionsClient, DisputesClient, DisputeAgentsClient, NotificationsClient, WalletsClient, PriceClient, OffersClient, PaymentAccountsClient, TradesClient, ShutdownServerClient, XmrNodeClient } from './protobuf/GrpcServiceClientPb';
import { GetVersionRequest, GetVersionReply, IsAppInitializedRequest, IsAppInitializedReply, RegisterDisputeAgentRequest, UnregisterDisputeAgentRequest, MarketPriceRequest, MarketPriceReply, MarketPricesRequest, MarketPricesReply, MarketPriceInfo, MarketDepthRequest, MarketDepthReply, MarketDepthInfo, GetBalancesRequest, GetBalancesReply, XmrBalanceInfo, GetMyOfferRequest, GetMyOfferReply, GetOffersRequest, GetOffersReply, OfferInfo, GetPaymentMethodsRequest, GetPaymentMethodsReply, GetPaymentAccountFormRequest, CreatePaymentAccountRequest, ValidateFormFieldRequest, CreatePaymentAccountReply, GetPaymentAccountFormReply, GetPaymentAccountsRequest, GetPaymentAccountsReply, CreateCryptoCurrencyPaymentAccountRequest, CreateCryptoCurrencyPaymentAccountReply, PostOfferRequest, PostOfferReply, CancelOfferRequest, TakeOfferRequest, TakeOfferReply, TradeInfo, GetTradeRequest, GetTradeReply, GetTradesRequest, GetTradesReply, GetXmrSeedRequest, GetXmrSeedReply, GetXmrPrimaryAddressRequest, GetXmrPrimaryAddressReply, GetXmrNewSubaddressRequest, GetXmrNewSubaddressReply, ConfirmPaymentSentRequest, ConfirmPaymentReceivedRequest, CompleteTradeRequest, XmrTx, GetXmrTxsRequest, GetXmrTxsReply, XmrDestination, CreateXmrTxRequest, CreateXmrTxReply, RelayXmrTxRequest, RelayXmrTxReply, CreateAccountRequest, AccountExistsRequest, AccountExistsReply, DeleteAccountRequest, OpenAccountRequest, IsAccountOpenRequest, IsAccountOpenReply, CloseAccountRequest, ChangePasswordRequest, BackupAccountRequest, BackupAccountReply, RestoreAccountRequest, StopRequest, NotificationMessage, RegisterNotificationListenerRequest, SendNotificationRequest, UrlConnection, AddConnectionRequest, RemoveConnectionRequest, GetConnectionRequest, GetConnectionsRequest, SetConnectionRequest, CheckConnectionRequest, CheckConnectionsReply, CheckConnectionsRequest, StartCheckingConnectionsRequest, StopCheckingConnectionsRequest, GetBestAvailableConnectionRequest, SetAutoSwitchRequest, CheckConnectionReply, GetConnectionsReply, GetConnectionReply, GetBestAvailableConnectionReply, GetDisputeRequest, GetDisputeReply, GetDisputesRequest, GetDisputesReply, OpenDisputeRequest, ResolveDisputeRequest, SendDisputeChatMessageRequest, SendChatMessageRequest, GetChatMessagesRequest, GetChatMessagesReply, StartXmrNodeRequest, StopXmrNodeRequest, IsXmrNodeOnlineRequest, IsXmrNodeOnlineReply, GetXmrNodeSettingsRequest, GetXmrNodeSettingsReply } from "./protobuf/grpc_pb";
import { GetVersionRequest, GetVersionReply, IsAppInitializedRequest, IsAppInitializedReply, RegisterDisputeAgentRequest, UnregisterDisputeAgentRequest, MarketPriceRequest, MarketPriceReply, MarketPricesRequest, MarketPricesReply, MarketPriceInfo, MarketDepthRequest, MarketDepthReply, MarketDepthInfo, GetBalancesRequest, GetBalancesReply, XmrBalanceInfo, GetMyOfferRequest, GetMyOfferReply, GetOffersRequest, GetOffersReply, OfferInfo, GetPaymentMethodsRequest, GetPaymentMethodsReply, GetPaymentAccountFormRequest, CreatePaymentAccountRequest, ValidateFormFieldRequest, CreatePaymentAccountReply, GetPaymentAccountFormReply, GetPaymentAccountsRequest, GetPaymentAccountsReply, CreateCryptoCurrencyPaymentAccountRequest, CreateCryptoCurrencyPaymentAccountReply, PostOfferRequest, PostOfferReply, CancelOfferRequest, TakeOfferRequest, TakeOfferReply, TradeInfo, GetTradeRequest, GetTradeReply, GetTradesRequest, GetTradesReply, GetXmrSeedRequest, GetXmrSeedReply, GetXmrPrimaryAddressRequest, GetXmrPrimaryAddressReply, GetXmrNewSubaddressRequest, GetXmrNewSubaddressReply, ConfirmPaymentSentRequest, ConfirmPaymentReceivedRequest, CompleteTradeRequest, XmrTx, GetXmrTxsRequest, GetXmrTxsReply, XmrDestination, CreateXmrTxRequest, CreateXmrTxReply, RelayXmrTxRequest, RelayXmrTxReply, CreateAccountRequest, AccountExistsRequest, AccountExistsReply, DeleteAccountRequest, OpenAccountRequest, IsAccountOpenRequest, IsAccountOpenReply, CloseAccountRequest, ChangePasswordRequest, BackupAccountRequest, BackupAccountReply, RestoreAccountRequest, StopRequest, NotificationMessage, RegisterNotificationListenerRequest, SendNotificationRequest, UrlConnection, AddConnectionRequest, RemoveConnectionRequest, GetConnectionRequest, GetConnectionsRequest, SetConnectionRequest, CheckConnectionRequest, CheckConnectionsReply, CheckConnectionsRequest, StartCheckingConnectionRequest, StopCheckingConnectionRequest, GetBestAvailableConnectionRequest, SetAutoSwitchRequest, CheckConnectionReply, GetConnectionsReply, GetConnectionReply, GetBestAvailableConnectionReply, GetDisputeRequest, GetDisputeReply, GetDisputesRequest, GetDisputesReply, OpenDisputeRequest, ResolveDisputeRequest, SendDisputeChatMessageRequest, SendChatMessageRequest, GetChatMessagesRequest, GetChatMessagesReply, StartXmrNodeRequest, StopXmrNodeRequest, IsXmrNodeOnlineRequest, IsXmrNodeOnlineReply, GetXmrNodeSettingsRequest, GetXmrNodeSettingsReply } from "./protobuf/grpc_pb";
import { OfferDirection, PaymentMethod, PaymentAccountForm, PaymentAccountFormField, PaymentAccount, PaymentAccountPayload, AvailabilityResult, Attachment, DisputeResult, Dispute, ChatMessage, XmrNodeSettings } from "./protobuf/pb_pb";
/**
@ -544,7 +544,7 @@ export default class HavenoClient {
*/
async startCheckingConnection(refreshPeriod: number): Promise<void> {
try {
await this._xmrConnectionsClient.startCheckingConnections(new StartCheckingConnectionsRequest().setRefreshPeriod(refreshPeriod), {password: this._password});
await this._xmrConnectionsClient.startCheckingConnection(new StartCheckingConnectionRequest().setRefreshPeriod(refreshPeriod), {password: this._password});
} catch (e: any) {
throw new HavenoError(e.message, e.code);
}
@ -555,7 +555,7 @@ export default class HavenoClient {
*/
async stopCheckingConnection(): Promise<void> {
try {
await this._xmrConnectionsClient.stopCheckingConnections(new StopCheckingConnectionsRequest(), {password: this._password});
await this._xmrConnectionsClient.stopCheckingConnection(new StopCheckingConnectionRequest(), {password: this._password});
} catch (e: any) {
throw new HavenoError(e.message, e.code);
}