mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2025-02-23 15:00:30 +01:00
Code Issues Projects Releases Packages Wiki Activity

Add wasTruncated flag

Browse source 
Indicates if data response contained all data or was truncated
This commit is contained in:
chimp1984 2022-08-31 17:04:25 +02:00
parent 7d7eb13131
commit c40d4ffffa
No known key found for this signature in database
GPG key ID: 9801B4EC591F90E3
2 changed files with 11 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
p2p/src/main/java/bisq/network/p2p/peers/getdata/messages/GetDataResponse.java
View file

@ -56,14 +56,19 @@ public final class GetDataResponse extends NetworkEnvelope implements SupportedC
private final boolean isGetUpdatedDataResponse; private final boolean isGetUpdatedDataResponse;
private final Capabilities supportedCapabilities; private final Capabilities supportedCapabilities;
// Added at v1.9.6
private final boolean wasTruncated;
public GetDataResponse(@NotNull Set<ProtectedStorageEntry> dataSet, public GetDataResponse(@NotNull Set<ProtectedStorageEntry> dataSet,
@NotNull Set<PersistableNetworkPayload> persistableNetworkPayloadSet, @NotNull Set<PersistableNetworkPayload> persistableNetworkPayloadSet,
int requestNonce, int requestNonce,
boolean isGetUpdatedDataResponse) { boolean isGetUpdatedDataResponse,
boolean wasTruncated) {
this(dataSet, this(dataSet,
persistableNetworkPayloadSet, persistableNetworkPayloadSet,
requestNonce, requestNonce,
isGetUpdatedDataResponse, isGetUpdatedDataResponse,
wasTruncated,
Capabilities.app, Capabilities.app,
Version.getP2PMessageVersion()); Version.getP2PMessageVersion());
} }
@ -76,6 +81,7 @@ public final class GetDataResponse extends NetworkEnvelope implements SupportedC
@NotNull Set<PersistableNetworkPayload> persistableNetworkPayloadSet, @NotNull Set<PersistableNetworkPayload> persistableNetworkPayloadSet,
int requestNonce, int requestNonce,
boolean isGetUpdatedDataResponse, boolean isGetUpdatedDataResponse,
boolean wasTruncated,
@NotNull Capabilities supportedCapabilities, @NotNull Capabilities supportedCapabilities,
int messageVersion) { int messageVersion) {
super(messageVersion); super(messageVersion);
@ -84,6 +90,7 @@ public final class GetDataResponse extends NetworkEnvelope implements SupportedC
this.persistableNetworkPayloadSet = persistableNetworkPayloadSet; this.persistableNetworkPayloadSet = persistableNetworkPayloadSet;
this.requestNonce = requestNonce; this.requestNonce = requestNonce;
this.isGetUpdatedDataResponse = isGetUpdatedDataResponse; this.isGetUpdatedDataResponse = isGetUpdatedDataResponse;
this.wasTruncated = wasTruncated;
this.supportedCapabilities = supportedCapabilities; this.supportedCapabilities = supportedCapabilities;
} }
@ -105,6 +112,7 @@ public final class GetDataResponse extends NetworkEnvelope implements SupportedC
.collect(Collectors.toList())) .collect(Collectors.toList()))
.setRequestNonce(requestNonce) .setRequestNonce(requestNonce)
.setIsGetUpdatedDataResponse(isGetUpdatedDataResponse) .setIsGetUpdatedDataResponse(isGetUpdatedDataResponse)
.setWasTruncated(wasTruncated)
.addAllSupportedCapabilities(Capabilities.toIntList(supportedCapabilities)); .addAllSupportedCapabilities(Capabilities.toIntList(supportedCapabilities));
protobuf.NetworkEnvelope proto = getNetworkEnvelopeBuilder() protobuf.NetworkEnvelope proto = getNetworkEnvelopeBuilder()
@ -126,6 +134,7 @@ public final class GetDataResponse extends NetworkEnvelope implements SupportedC
persistableNetworkPayloadSet, persistableNetworkPayloadSet,
proto.getRequestNonce(), proto.getRequestNonce(),
proto.getIsGetUpdatedDataResponse(), proto.getIsGetUpdatedDataResponse(),
proto.getWasTruncated(),
Capabilities.fromIntList(proto.getSupportedCapabilitiesList()), Capabilities.fromIntList(proto.getSupportedCapabilitiesList()),
messageVersion); messageVersion);
} }

1
proto/src/main/proto/pb.proto
View file

@ -118,6 +118,7 @@ message GetDataResponse {
repeated StorageEntryWrapper data_set = 3; repeated StorageEntryWrapper data_set = 3;
repeated int32 supported_capabilities = 4; repeated int32 supported_capabilities = 4;
repeated PersistableNetworkPayload persistable_network_payload_items = 5; repeated PersistableNetworkPayload persistable_network_payload_items = 5;
bool was_truncated = 6;
} }
message GetUpdatedDataRequest { message GetUpdatedDataRequest {