diff --git a/CHANGELOG.md b/CHANGELOG.md index 9d8bd3e1..37a6a466 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -33,6 +33,9 @@ Ref: https://keepachangelog.com/en/1.0.0/ ## Unreleased +### Features +* Add hash price support for nav values from on chain events [#543](https://github.com/provenance-io/explorer-service/pull/543) + ### Improvements * Add limit of 1 to missing block queries [#544](https://github.com/provenance-io/explorer-service/pull/544) diff --git a/service/src/main/java/io/provlabs/flow/api/NavEvent.java b/service/src/main/java/io/provlabs/flow/api/NavEvent.java new file mode 100644 index 00000000..ac1e0e09 --- /dev/null +++ b/service/src/main/java/io/provlabs/flow/api/NavEvent.java @@ -0,0 +1,1906 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: nav_event.proto + +package io.provlabs.flow.api; + +/** + *
+ * NavEvent represents a Net Asset Value (NAV) event within a block. + *+ * + * Protobuf type {@code nav.NavEvent} + */ +public final class NavEvent extends + com.google.protobuf.GeneratedMessageV3 implements + // @@protoc_insertion_point(message_implements:nav.NavEvent) + NavEventOrBuilder { +private static final long serialVersionUID = 0L; + // Use NavEvent.newBuilder() to construct. + private NavEvent(com.google.protobuf.GeneratedMessageV3.Builder> builder) { + super(builder); + } + private NavEvent() { + txHash_ = ""; + eventType_ = ""; + scopeId_ = ""; + denom_ = ""; + priceDenom_ = ""; + source_ = ""; + } + + @java.lang.Override + @SuppressWarnings({"unused"}) + protected java.lang.Object newInstance( + UnusedPrivateParameter unused) { + return new NavEvent(); + } + + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private NavEvent( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + this(); + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + case 8: { + + blockHeight_ = input.readInt32(); + break; + } + case 16: { + + blockTime_ = input.readUInt64(); + break; + } + case 24: { + + chainId_ = input.readInt32(); + break; + } + case 34: { + java.lang.String s = input.readStringRequireUtf8(); + + txHash_ = s; + break; + } + case 40: { + + eventOrder_ = input.readInt32(); + break; + } + case 50: { + java.lang.String s = input.readStringRequireUtf8(); + + eventType_ = s; + break; + } + case 58: { + java.lang.String s = input.readStringRequireUtf8(); + + scopeId_ = s; + break; + } + case 66: { + java.lang.String s = input.readStringRequireUtf8(); + + denom_ = s; + break; + } + case 72: { + + priceAmount_ = input.readInt64(); + break; + } + case 82: { + java.lang.String s = input.readStringRequireUtf8(); + + priceDenom_ = s; + break; + } + case 88: { + + volume_ = input.readInt64(); + break; + } + case 98: { + java.lang.String s = input.readStringRequireUtf8(); + + source_ = s; + break; + } + default: { + if (!parseUnknownField( + input, unknownFields, extensionRegistry, tag)) { + done = true; + } + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return io.provlabs.flow.api.NavEventOuterClass.internal_static_nav_NavEvent_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return io.provlabs.flow.api.NavEventOuterClass.internal_static_nav_NavEvent_fieldAccessorTable + .ensureFieldAccessorsInitialized( + io.provlabs.flow.api.NavEvent.class, io.provlabs.flow.api.NavEvent.Builder.class); + } + + public static final int BLOCK_HEIGHT_FIELD_NUMBER = 1; + private int blockHeight_; + /** + *
+ * The block height where this Nav event occurred. + *+ * + *
int32 block_height = 1;
+ * @return The blockHeight.
+ */
+ @java.lang.Override
+ public int getBlockHeight() {
+ return blockHeight_;
+ }
+
+ public static final int BLOCK_TIME_FIELD_NUMBER = 2;
+ private long blockTime_;
+ /**
+ * + * The block time in UNIX epoch format when the Nav event occurred. + *+ * + *
uint64 block_time = 2;
+ * @return The blockTime.
+ */
+ @java.lang.Override
+ public long getBlockTime() {
+ return blockTime_;
+ }
+
+ public static final int CHAIN_ID_FIELD_NUMBER = 3;
+ private int chainId_;
+ /**
+ * + * The unique chain ID representing the blockchain where this NAV event occurred. + *+ * + *
int32 chain_id = 3;
+ * @return The chainId.
+ */
+ @java.lang.Override
+ public int getChainId() {
+ return chainId_;
+ }
+
+ public static final int TX_HASH_FIELD_NUMBER = 4;
+ private volatile java.lang.Object txHash_;
+ /**
+ * + * The tx hash related to this NAV event. + *+ * + *
string tx_hash = 4;
+ * @return The txHash.
+ */
+ @java.lang.Override
+ public java.lang.String getTxHash() {
+ java.lang.Object ref = txHash_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ txHash_ = s;
+ return s;
+ }
+ }
+ /**
+ * + * The tx hash related to this NAV event. + *+ * + *
string tx_hash = 4;
+ * @return The bytes for txHash.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString
+ getTxHashBytes() {
+ java.lang.Object ref = txHash_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ txHash_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int EVENT_ORDER_FIELD_NUMBER = 5;
+ private int eventOrder_;
+ /**
+ * + * The order in which this event was emitted within the block_height and tx_hash. + *+ * + *
int32 event_order = 5;
+ * @return The eventOrder.
+ */
+ @java.lang.Override
+ public int getEventOrder() {
+ return eventOrder_;
+ }
+
+ public static final int EVENT_TYPE_FIELD_NUMBER = 6;
+ private volatile java.lang.Object eventType_;
+ /**
+ * + * The type of Nav event type. + *+ * + *
string event_type = 6;
+ * @return The eventType.
+ */
+ @java.lang.Override
+ public java.lang.String getEventType() {
+ java.lang.Object ref = eventType_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ eventType_ = s;
+ return s;
+ }
+ }
+ /**
+ * + * The type of Nav event type. + *+ * + *
string event_type = 6;
+ * @return The bytes for eventType.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString
+ getEventTypeBytes() {
+ java.lang.Object ref = eventType_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ eventType_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int SCOPE_ID_FIELD_NUMBER = 7;
+ private volatile java.lang.Object scopeId_;
+ /**
+ * + * The scope ID associated with this Nav. + *+ * + *
string scope_id = 7;
+ * @return The scopeId.
+ */
+ @java.lang.Override
+ public java.lang.String getScopeId() {
+ java.lang.Object ref = scopeId_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ scopeId_ = s;
+ return s;
+ }
+ }
+ /**
+ * + * The scope ID associated with this Nav. + *+ * + *
string scope_id = 7;
+ * @return The bytes for scopeId.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString
+ getScopeIdBytes() {
+ java.lang.Object ref = scopeId_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ scopeId_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int DENOM_FIELD_NUMBER = 8;
+ private volatile java.lang.Object denom_;
+ /**
+ * + * The token denomination for the Nav. + *+ * + *
string denom = 8;
+ * @return The denom.
+ */
+ @java.lang.Override
+ public java.lang.String getDenom() {
+ java.lang.Object ref = denom_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ denom_ = s;
+ return s;
+ }
+ }
+ /**
+ * + * The token denomination for the Nav. + *+ * + *
string denom = 8;
+ * @return The bytes for denom.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString
+ getDenomBytes() {
+ java.lang.Object ref = denom_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ denom_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int PRICE_AMOUNT_FIELD_NUMBER = 9;
+ private long priceAmount_;
+ /**
+ * + * The price amount for the NAV. + *+ * + *
int64 price_amount = 9;
+ * @return The priceAmount.
+ */
+ @java.lang.Override
+ public long getPriceAmount() {
+ return priceAmount_;
+ }
+
+ public static final int PRICE_DENOM_FIELD_NUMBER = 10;
+ private volatile java.lang.Object priceDenom_;
+ /**
+ * + * The denomination of the price. + *+ * + *
string price_denom = 10;
+ * @return The priceDenom.
+ */
+ @java.lang.Override
+ public java.lang.String getPriceDenom() {
+ java.lang.Object ref = priceDenom_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ priceDenom_ = s;
+ return s;
+ }
+ }
+ /**
+ * + * The denomination of the price. + *+ * + *
string price_denom = 10;
+ * @return The bytes for priceDenom.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString
+ getPriceDenomBytes() {
+ java.lang.Object ref = priceDenom_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ priceDenom_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int VOLUME_FIELD_NUMBER = 11;
+ private long volume_;
+ /**
+ * + * The volume of tokens involved in the Nav event. + *+ * + *
int64 volume = 11;
+ * @return The volume.
+ */
+ @java.lang.Override
+ public long getVolume() {
+ return volume_;
+ }
+
+ public static final int SOURCE_FIELD_NUMBER = 12;
+ private volatile java.lang.Object source_;
+ /**
+ * + * The source of the NAV event. + *+ * + *
string source = 12;
+ * @return The source.
+ */
+ @java.lang.Override
+ public java.lang.String getSource() {
+ java.lang.Object ref = source_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ source_ = s;
+ return s;
+ }
+ }
+ /**
+ * + * The source of the NAV event. + *+ * + *
string source = 12;
+ * @return The bytes for source.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString
+ getSourceBytes() {
+ java.lang.Object ref = source_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ source_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ private byte memoizedIsInitialized = -1;
+ @java.lang.Override
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ @java.lang.Override
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ if (blockHeight_ != 0) {
+ output.writeInt32(1, blockHeight_);
+ }
+ if (blockTime_ != 0L) {
+ output.writeUInt64(2, blockTime_);
+ }
+ if (chainId_ != 0) {
+ output.writeInt32(3, chainId_);
+ }
+ if (!getTxHashBytes().isEmpty()) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 4, txHash_);
+ }
+ if (eventOrder_ != 0) {
+ output.writeInt32(5, eventOrder_);
+ }
+ if (!getEventTypeBytes().isEmpty()) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 6, eventType_);
+ }
+ if (!getScopeIdBytes().isEmpty()) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 7, scopeId_);
+ }
+ if (!getDenomBytes().isEmpty()) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 8, denom_);
+ }
+ if (priceAmount_ != 0L) {
+ output.writeInt64(9, priceAmount_);
+ }
+ if (!getPriceDenomBytes().isEmpty()) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 10, priceDenom_);
+ }
+ if (volume_ != 0L) {
+ output.writeInt64(11, volume_);
+ }
+ if (!getSourceBytes().isEmpty()) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 12, source_);
+ }
+ unknownFields.writeTo(output);
+ }
+
+ @java.lang.Override
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (blockHeight_ != 0) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(1, blockHeight_);
+ }
+ if (blockTime_ != 0L) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeUInt64Size(2, blockTime_);
+ }
+ if (chainId_ != 0) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(3, chainId_);
+ }
+ if (!getTxHashBytes().isEmpty()) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(4, txHash_);
+ }
+ if (eventOrder_ != 0) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(5, eventOrder_);
+ }
+ if (!getEventTypeBytes().isEmpty()) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(6, eventType_);
+ }
+ if (!getScopeIdBytes().isEmpty()) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(7, scopeId_);
+ }
+ if (!getDenomBytes().isEmpty()) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(8, denom_);
+ }
+ if (priceAmount_ != 0L) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt64Size(9, priceAmount_);
+ }
+ if (!getPriceDenomBytes().isEmpty()) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(10, priceDenom_);
+ }
+ if (volume_ != 0L) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt64Size(11, volume_);
+ }
+ if (!getSourceBytes().isEmpty()) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(12, source_);
+ }
+ size += unknownFields.getSerializedSize();
+ memoizedSize = size;
+ return size;
+ }
+
+ @java.lang.Override
+ public boolean equals(final java.lang.Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof io.provlabs.flow.api.NavEvent)) {
+ return super.equals(obj);
+ }
+ io.provlabs.flow.api.NavEvent other = (io.provlabs.flow.api.NavEvent) obj;
+
+ if (getBlockHeight()
+ != other.getBlockHeight()) return false;
+ if (getBlockTime()
+ != other.getBlockTime()) return false;
+ if (getChainId()
+ != other.getChainId()) return false;
+ if (!getTxHash()
+ .equals(other.getTxHash())) return false;
+ if (getEventOrder()
+ != other.getEventOrder()) return false;
+ if (!getEventType()
+ .equals(other.getEventType())) return false;
+ if (!getScopeId()
+ .equals(other.getScopeId())) return false;
+ if (!getDenom()
+ .equals(other.getDenom())) return false;
+ if (getPriceAmount()
+ != other.getPriceAmount()) return false;
+ if (!getPriceDenom()
+ .equals(other.getPriceDenom())) return false;
+ if (getVolume()
+ != other.getVolume()) return false;
+ if (!getSource()
+ .equals(other.getSource())) return false;
+ if (!unknownFields.equals(other.unknownFields)) return false;
+ return true;
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptor().hashCode();
+ hash = (37 * hash) + BLOCK_HEIGHT_FIELD_NUMBER;
+ hash = (53 * hash) + getBlockHeight();
+ hash = (37 * hash) + BLOCK_TIME_FIELD_NUMBER;
+ hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
+ getBlockTime());
+ hash = (37 * hash) + CHAIN_ID_FIELD_NUMBER;
+ hash = (53 * hash) + getChainId();
+ hash = (37 * hash) + TX_HASH_FIELD_NUMBER;
+ hash = (53 * hash) + getTxHash().hashCode();
+ hash = (37 * hash) + EVENT_ORDER_FIELD_NUMBER;
+ hash = (53 * hash) + getEventOrder();
+ hash = (37 * hash) + EVENT_TYPE_FIELD_NUMBER;
+ hash = (53 * hash) + getEventType().hashCode();
+ hash = (37 * hash) + SCOPE_ID_FIELD_NUMBER;
+ hash = (53 * hash) + getScopeId().hashCode();
+ hash = (37 * hash) + DENOM_FIELD_NUMBER;
+ hash = (53 * hash) + getDenom().hashCode();
+ hash = (37 * hash) + PRICE_AMOUNT_FIELD_NUMBER;
+ hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
+ getPriceAmount());
+ hash = (37 * hash) + PRICE_DENOM_FIELD_NUMBER;
+ hash = (53 * hash) + getPriceDenom().hashCode();
+ hash = (37 * hash) + VOLUME_FIELD_NUMBER;
+ hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
+ getVolume());
+ hash = (37 * hash) + SOURCE_FIELD_NUMBER;
+ hash = (53 * hash) + getSource().hashCode();
+ hash = (29 * hash) + unknownFields.hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static io.provlabs.flow.api.NavEvent parseFrom(
+ java.nio.ByteBuffer data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.provlabs.flow.api.NavEvent parseFrom(
+ java.nio.ByteBuffer data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.provlabs.flow.api.NavEvent parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.provlabs.flow.api.NavEvent parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.provlabs.flow.api.NavEvent parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.provlabs.flow.api.NavEvent parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.provlabs.flow.api.NavEvent parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static io.provlabs.flow.api.NavEvent parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static io.provlabs.flow.api.NavEvent parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input);
+ }
+ public static io.provlabs.flow.api.NavEvent parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static io.provlabs.flow.api.NavEvent parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static io.provlabs.flow.api.NavEvent parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ @java.lang.Override
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+ public static Builder newBuilder(io.provlabs.flow.api.NavEvent prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+ @java.lang.Override
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ * + * NavEvent represents a Net Asset Value (NAV) event within a block. + *+ * + * Protobuf type {@code nav.NavEvent} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessageV3.Builder
+ * The block height where this Nav event occurred. + *+ * + *
int32 block_height = 1;
+ * @return The blockHeight.
+ */
+ @java.lang.Override
+ public int getBlockHeight() {
+ return blockHeight_;
+ }
+ /**
+ * + * The block height where this Nav event occurred. + *+ * + *
int32 block_height = 1;
+ * @param value The blockHeight to set.
+ * @return This builder for chaining.
+ */
+ public Builder setBlockHeight(int value) {
+
+ blockHeight_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The block height where this Nav event occurred. + *+ * + *
int32 block_height = 1;
+ * @return This builder for chaining.
+ */
+ public Builder clearBlockHeight() {
+
+ blockHeight_ = 0;
+ onChanged();
+ return this;
+ }
+
+ private long blockTime_ ;
+ /**
+ * + * The block time in UNIX epoch format when the Nav event occurred. + *+ * + *
uint64 block_time = 2;
+ * @return The blockTime.
+ */
+ @java.lang.Override
+ public long getBlockTime() {
+ return blockTime_;
+ }
+ /**
+ * + * The block time in UNIX epoch format when the Nav event occurred. + *+ * + *
uint64 block_time = 2;
+ * @param value The blockTime to set.
+ * @return This builder for chaining.
+ */
+ public Builder setBlockTime(long value) {
+
+ blockTime_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The block time in UNIX epoch format when the Nav event occurred. + *+ * + *
uint64 block_time = 2;
+ * @return This builder for chaining.
+ */
+ public Builder clearBlockTime() {
+
+ blockTime_ = 0L;
+ onChanged();
+ return this;
+ }
+
+ private int chainId_ ;
+ /**
+ * + * The unique chain ID representing the blockchain where this NAV event occurred. + *+ * + *
int32 chain_id = 3;
+ * @return The chainId.
+ */
+ @java.lang.Override
+ public int getChainId() {
+ return chainId_;
+ }
+ /**
+ * + * The unique chain ID representing the blockchain where this NAV event occurred. + *+ * + *
int32 chain_id = 3;
+ * @param value The chainId to set.
+ * @return This builder for chaining.
+ */
+ public Builder setChainId(int value) {
+
+ chainId_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The unique chain ID representing the blockchain where this NAV event occurred. + *+ * + *
int32 chain_id = 3;
+ * @return This builder for chaining.
+ */
+ public Builder clearChainId() {
+
+ chainId_ = 0;
+ onChanged();
+ return this;
+ }
+
+ private java.lang.Object txHash_ = "";
+ /**
+ * + * The tx hash related to this NAV event. + *+ * + *
string tx_hash = 4;
+ * @return The txHash.
+ */
+ public java.lang.String getTxHash() {
+ java.lang.Object ref = txHash_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ txHash_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * + * The tx hash related to this NAV event. + *+ * + *
string tx_hash = 4;
+ * @return The bytes for txHash.
+ */
+ public com.google.protobuf.ByteString
+ getTxHashBytes() {
+ java.lang.Object ref = txHash_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ txHash_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * + * The tx hash related to this NAV event. + *+ * + *
string tx_hash = 4;
+ * @param value The txHash to set.
+ * @return This builder for chaining.
+ */
+ public Builder setTxHash(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ txHash_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The tx hash related to this NAV event. + *+ * + *
string tx_hash = 4;
+ * @return This builder for chaining.
+ */
+ public Builder clearTxHash() {
+
+ txHash_ = getDefaultInstance().getTxHash();
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The tx hash related to this NAV event. + *+ * + *
string tx_hash = 4;
+ * @param value The bytes for txHash to set.
+ * @return This builder for chaining.
+ */
+ public Builder setTxHashBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ txHash_ = value;
+ onChanged();
+ return this;
+ }
+
+ private int eventOrder_ ;
+ /**
+ * + * The order in which this event was emitted within the block_height and tx_hash. + *+ * + *
int32 event_order = 5;
+ * @return The eventOrder.
+ */
+ @java.lang.Override
+ public int getEventOrder() {
+ return eventOrder_;
+ }
+ /**
+ * + * The order in which this event was emitted within the block_height and tx_hash. + *+ * + *
int32 event_order = 5;
+ * @param value The eventOrder to set.
+ * @return This builder for chaining.
+ */
+ public Builder setEventOrder(int value) {
+
+ eventOrder_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The order in which this event was emitted within the block_height and tx_hash. + *+ * + *
int32 event_order = 5;
+ * @return This builder for chaining.
+ */
+ public Builder clearEventOrder() {
+
+ eventOrder_ = 0;
+ onChanged();
+ return this;
+ }
+
+ private java.lang.Object eventType_ = "";
+ /**
+ * + * The type of Nav event type. + *+ * + *
string event_type = 6;
+ * @return The eventType.
+ */
+ public java.lang.String getEventType() {
+ java.lang.Object ref = eventType_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ eventType_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * + * The type of Nav event type. + *+ * + *
string event_type = 6;
+ * @return The bytes for eventType.
+ */
+ public com.google.protobuf.ByteString
+ getEventTypeBytes() {
+ java.lang.Object ref = eventType_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ eventType_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * + * The type of Nav event type. + *+ * + *
string event_type = 6;
+ * @param value The eventType to set.
+ * @return This builder for chaining.
+ */
+ public Builder setEventType(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ eventType_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The type of Nav event type. + *+ * + *
string event_type = 6;
+ * @return This builder for chaining.
+ */
+ public Builder clearEventType() {
+
+ eventType_ = getDefaultInstance().getEventType();
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The type of Nav event type. + *+ * + *
string event_type = 6;
+ * @param value The bytes for eventType to set.
+ * @return This builder for chaining.
+ */
+ public Builder setEventTypeBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ eventType_ = value;
+ onChanged();
+ return this;
+ }
+
+ private java.lang.Object scopeId_ = "";
+ /**
+ * + * The scope ID associated with this Nav. + *+ * + *
string scope_id = 7;
+ * @return The scopeId.
+ */
+ public java.lang.String getScopeId() {
+ java.lang.Object ref = scopeId_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ scopeId_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * + * The scope ID associated with this Nav. + *+ * + *
string scope_id = 7;
+ * @return The bytes for scopeId.
+ */
+ public com.google.protobuf.ByteString
+ getScopeIdBytes() {
+ java.lang.Object ref = scopeId_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ scopeId_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * + * The scope ID associated with this Nav. + *+ * + *
string scope_id = 7;
+ * @param value The scopeId to set.
+ * @return This builder for chaining.
+ */
+ public Builder setScopeId(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ scopeId_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The scope ID associated with this Nav. + *+ * + *
string scope_id = 7;
+ * @return This builder for chaining.
+ */
+ public Builder clearScopeId() {
+
+ scopeId_ = getDefaultInstance().getScopeId();
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The scope ID associated with this Nav. + *+ * + *
string scope_id = 7;
+ * @param value The bytes for scopeId to set.
+ * @return This builder for chaining.
+ */
+ public Builder setScopeIdBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ scopeId_ = value;
+ onChanged();
+ return this;
+ }
+
+ private java.lang.Object denom_ = "";
+ /**
+ * + * The token denomination for the Nav. + *+ * + *
string denom = 8;
+ * @return The denom.
+ */
+ public java.lang.String getDenom() {
+ java.lang.Object ref = denom_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ denom_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * + * The token denomination for the Nav. + *+ * + *
string denom = 8;
+ * @return The bytes for denom.
+ */
+ public com.google.protobuf.ByteString
+ getDenomBytes() {
+ java.lang.Object ref = denom_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ denom_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * + * The token denomination for the Nav. + *+ * + *
string denom = 8;
+ * @param value The denom to set.
+ * @return This builder for chaining.
+ */
+ public Builder setDenom(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ denom_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The token denomination for the Nav. + *+ * + *
string denom = 8;
+ * @return This builder for chaining.
+ */
+ public Builder clearDenom() {
+
+ denom_ = getDefaultInstance().getDenom();
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The token denomination for the Nav. + *+ * + *
string denom = 8;
+ * @param value The bytes for denom to set.
+ * @return This builder for chaining.
+ */
+ public Builder setDenomBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ denom_ = value;
+ onChanged();
+ return this;
+ }
+
+ private long priceAmount_ ;
+ /**
+ * + * The price amount for the NAV. + *+ * + *
int64 price_amount = 9;
+ * @return The priceAmount.
+ */
+ @java.lang.Override
+ public long getPriceAmount() {
+ return priceAmount_;
+ }
+ /**
+ * + * The price amount for the NAV. + *+ * + *
int64 price_amount = 9;
+ * @param value The priceAmount to set.
+ * @return This builder for chaining.
+ */
+ public Builder setPriceAmount(long value) {
+
+ priceAmount_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The price amount for the NAV. + *+ * + *
int64 price_amount = 9;
+ * @return This builder for chaining.
+ */
+ public Builder clearPriceAmount() {
+
+ priceAmount_ = 0L;
+ onChanged();
+ return this;
+ }
+
+ private java.lang.Object priceDenom_ = "";
+ /**
+ * + * The denomination of the price. + *+ * + *
string price_denom = 10;
+ * @return The priceDenom.
+ */
+ public java.lang.String getPriceDenom() {
+ java.lang.Object ref = priceDenom_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ priceDenom_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * + * The denomination of the price. + *+ * + *
string price_denom = 10;
+ * @return The bytes for priceDenom.
+ */
+ public com.google.protobuf.ByteString
+ getPriceDenomBytes() {
+ java.lang.Object ref = priceDenom_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ priceDenom_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * + * The denomination of the price. + *+ * + *
string price_denom = 10;
+ * @param value The priceDenom to set.
+ * @return This builder for chaining.
+ */
+ public Builder setPriceDenom(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ priceDenom_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The denomination of the price. + *+ * + *
string price_denom = 10;
+ * @return This builder for chaining.
+ */
+ public Builder clearPriceDenom() {
+
+ priceDenom_ = getDefaultInstance().getPriceDenom();
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The denomination of the price. + *+ * + *
string price_denom = 10;
+ * @param value The bytes for priceDenom to set.
+ * @return This builder for chaining.
+ */
+ public Builder setPriceDenomBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ priceDenom_ = value;
+ onChanged();
+ return this;
+ }
+
+ private long volume_ ;
+ /**
+ * + * The volume of tokens involved in the Nav event. + *+ * + *
int64 volume = 11;
+ * @return The volume.
+ */
+ @java.lang.Override
+ public long getVolume() {
+ return volume_;
+ }
+ /**
+ * + * The volume of tokens involved in the Nav event. + *+ * + *
int64 volume = 11;
+ * @param value The volume to set.
+ * @return This builder for chaining.
+ */
+ public Builder setVolume(long value) {
+
+ volume_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The volume of tokens involved in the Nav event. + *+ * + *
int64 volume = 11;
+ * @return This builder for chaining.
+ */
+ public Builder clearVolume() {
+
+ volume_ = 0L;
+ onChanged();
+ return this;
+ }
+
+ private java.lang.Object source_ = "";
+ /**
+ * + * The source of the NAV event. + *+ * + *
string source = 12;
+ * @return The source.
+ */
+ public java.lang.String getSource() {
+ java.lang.Object ref = source_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ source_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * + * The source of the NAV event. + *+ * + *
string source = 12;
+ * @return The bytes for source.
+ */
+ public com.google.protobuf.ByteString
+ getSourceBytes() {
+ java.lang.Object ref = source_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ source_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * + * The source of the NAV event. + *+ * + *
string source = 12;
+ * @param value The source to set.
+ * @return This builder for chaining.
+ */
+ public Builder setSource(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ source_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The source of the NAV event. + *+ * + *
string source = 12;
+ * @return This builder for chaining.
+ */
+ public Builder clearSource() {
+
+ source_ = getDefaultInstance().getSource();
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The source of the NAV event. + *+ * + *
string source = 12;
+ * @param value The bytes for source to set.
+ * @return This builder for chaining.
+ */
+ public Builder setSourceBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ source_ = value;
+ onChanged();
+ return this;
+ }
+ @java.lang.Override
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.setUnknownFields(unknownFields);
+ }
+
+ @java.lang.Override
+ public final Builder mergeUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.mergeUnknownFields(unknownFields);
+ }
+
+
+ // @@protoc_insertion_point(builder_scope:nav.NavEvent)
+ }
+
+ // @@protoc_insertion_point(class_scope:nav.NavEvent)
+ private static final io.provlabs.flow.api.NavEvent DEFAULT_INSTANCE;
+ static {
+ DEFAULT_INSTANCE = new io.provlabs.flow.api.NavEvent();
+ }
+
+ public static io.provlabs.flow.api.NavEvent getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parser+ * The block height where this Nav event occurred. + *+ * + *
int32 block_height = 1;
+ * @return The blockHeight.
+ */
+ int getBlockHeight();
+
+ /**
+ * + * The block time in UNIX epoch format when the Nav event occurred. + *+ * + *
uint64 block_time = 2;
+ * @return The blockTime.
+ */
+ long getBlockTime();
+
+ /**
+ * + * The unique chain ID representing the blockchain where this NAV event occurred. + *+ * + *
int32 chain_id = 3;
+ * @return The chainId.
+ */
+ int getChainId();
+
+ /**
+ * + * The tx hash related to this NAV event. + *+ * + *
string tx_hash = 4;
+ * @return The txHash.
+ */
+ java.lang.String getTxHash();
+ /**
+ * + * The tx hash related to this NAV event. + *+ * + *
string tx_hash = 4;
+ * @return The bytes for txHash.
+ */
+ com.google.protobuf.ByteString
+ getTxHashBytes();
+
+ /**
+ * + * The order in which this event was emitted within the block_height and tx_hash. + *+ * + *
int32 event_order = 5;
+ * @return The eventOrder.
+ */
+ int getEventOrder();
+
+ /**
+ * + * The type of Nav event type. + *+ * + *
string event_type = 6;
+ * @return The eventType.
+ */
+ java.lang.String getEventType();
+ /**
+ * + * The type of Nav event type. + *+ * + *
string event_type = 6;
+ * @return The bytes for eventType.
+ */
+ com.google.protobuf.ByteString
+ getEventTypeBytes();
+
+ /**
+ * + * The scope ID associated with this Nav. + *+ * + *
string scope_id = 7;
+ * @return The scopeId.
+ */
+ java.lang.String getScopeId();
+ /**
+ * + * The scope ID associated with this Nav. + *+ * + *
string scope_id = 7;
+ * @return The bytes for scopeId.
+ */
+ com.google.protobuf.ByteString
+ getScopeIdBytes();
+
+ /**
+ * + * The token denomination for the Nav. + *+ * + *
string denom = 8;
+ * @return The denom.
+ */
+ java.lang.String getDenom();
+ /**
+ * + * The token denomination for the Nav. + *+ * + *
string denom = 8;
+ * @return The bytes for denom.
+ */
+ com.google.protobuf.ByteString
+ getDenomBytes();
+
+ /**
+ * + * The price amount for the NAV. + *+ * + *
int64 price_amount = 9;
+ * @return The priceAmount.
+ */
+ long getPriceAmount();
+
+ /**
+ * + * The denomination of the price. + *+ * + *
string price_denom = 10;
+ * @return The priceDenom.
+ */
+ java.lang.String getPriceDenom();
+ /**
+ * + * The denomination of the price. + *+ * + *
string price_denom = 10;
+ * @return The bytes for priceDenom.
+ */
+ com.google.protobuf.ByteString
+ getPriceDenomBytes();
+
+ /**
+ * + * The volume of tokens involved in the Nav event. + *+ * + *
int64 volume = 11;
+ * @return The volume.
+ */
+ long getVolume();
+
+ /**
+ * + * The source of the NAV event. + *+ * + *
string source = 12;
+ * @return The source.
+ */
+ java.lang.String getSource();
+ /**
+ * + * The source of the NAV event. + *+ * + *
string source = 12;
+ * @return The bytes for source.
+ */
+ com.google.protobuf.ByteString
+ getSourceBytes();
+}
diff --git a/service/src/main/java/io/provlabs/flow/api/NavEventOuterClass.java b/service/src/main/java/io/provlabs/flow/api/NavEventOuterClass.java
new file mode 100644
index 00000000..7dafd981
--- /dev/null
+++ b/service/src/main/java/io/provlabs/flow/api/NavEventOuterClass.java
@@ -0,0 +1,81 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: nav_event.proto
+
+package io.provlabs.flow.api;
+
+public final class NavEventOuterClass {
+ private NavEventOuterClass() {}
+ public static void registerAllExtensions(
+ com.google.protobuf.ExtensionRegistryLite registry) {
+ }
+
+ public static void registerAllExtensions(
+ com.google.protobuf.ExtensionRegistry registry) {
+ registerAllExtensions(
+ (com.google.protobuf.ExtensionRegistryLite) registry);
+ }
+ static final com.google.protobuf.Descriptors.Descriptor
+ internal_static_nav_NavEvent_descriptor;
+ static final
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internal_static_nav_NavEvent_fieldAccessorTable;
+ static final com.google.protobuf.Descriptors.Descriptor
+ internal_static_nav_NavEventRequest_descriptor;
+ static final
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internal_static_nav_NavEventRequest_fieldAccessorTable;
+ static final com.google.protobuf.Descriptors.Descriptor
+ internal_static_nav_NavEventResponse_descriptor;
+ static final
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internal_static_nav_NavEventResponse_fieldAccessorTable;
+
+ public static com.google.protobuf.Descriptors.FileDescriptor
+ getDescriptor() {
+ return descriptor;
+ }
+ private static com.google.protobuf.Descriptors.FileDescriptor
+ descriptor;
+ static {
+ java.lang.String[] descriptorData = {
+ "\n\017nav_event.proto\022\003nav\"\354\001\n\010NavEvent\022\024\n\014b" +
+ "lock_height\030\001 \001(\005\022\022\n\nblock_time\030\002 \001(\004\022\020\n" +
+ "\010chain_id\030\003 \001(\005\022\017\n\007tx_hash\030\004 \001(\t\022\023\n\013even" +
+ "t_order\030\005 \001(\005\022\022\n\nevent_type\030\006 \001(\t\022\020\n\010sco" +
+ "pe_id\030\007 \001(\t\022\r\n\005denom\030\010 \001(\t\022\024\n\014price_amou" +
+ "nt\030\t \001(\003\022\023\n\013price_denom\030\n \001(\t\022\016\n\006volume\030" +
+ "\013 \001(\003\022\016\n\006source\030\014 \001(\t\"{\n\017NavEventRequest" +
+ "\022\r\n\005denom\030\001 \001(\t\022\020\n\010scope_id\030\002 \001(\t\022\024\n\014pri" +
+ "ce_denoms\030\003 \003(\t\022\021\n\tfrom_date\030\004 \001(\t\022\017\n\007to" +
+ "_date\030\005 \001(\t\022\r\n\005limit\030\006 \001(\005\"5\n\020NavEventRe" +
+ "sponse\022!\n\nnav_events\030\001 \003(\0132\r.nav.NavEven" +
+ "t2I\n\nNavService\022;\n\014GetNavEvents\022\024.nav.Na" +
+ "vEventRequest\032\025.nav.NavEventResponseB \n\024" +
+ "io.provlabs.flow.apiP\001Z\006/typesb\006proto3"
+ };
+ descriptor = com.google.protobuf.Descriptors.FileDescriptor
+ .internalBuildGeneratedFileFrom(descriptorData,
+ new com.google.protobuf.Descriptors.FileDescriptor[] {
+ });
+ internal_static_nav_NavEvent_descriptor =
+ getDescriptor().getMessageTypes().get(0);
+ internal_static_nav_NavEvent_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+ internal_static_nav_NavEvent_descriptor,
+ new java.lang.String[] { "BlockHeight", "BlockTime", "ChainId", "TxHash", "EventOrder", "EventType", "ScopeId", "Denom", "PriceAmount", "PriceDenom", "Volume", "Source", });
+ internal_static_nav_NavEventRequest_descriptor =
+ getDescriptor().getMessageTypes().get(1);
+ internal_static_nav_NavEventRequest_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+ internal_static_nav_NavEventRequest_descriptor,
+ new java.lang.String[] { "Denom", "ScopeId", "PriceDenoms", "FromDate", "ToDate", "Limit", });
+ internal_static_nav_NavEventResponse_descriptor =
+ getDescriptor().getMessageTypes().get(2);
+ internal_static_nav_NavEventResponse_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+ internal_static_nav_NavEventResponse_descriptor,
+ new java.lang.String[] { "NavEvents", });
+ }
+
+ // @@protoc_insertion_point(outer_class_scope)
+}
diff --git a/service/src/main/java/io/provlabs/flow/api/NavEventRequest.java b/service/src/main/java/io/provlabs/flow/api/NavEventRequest.java
new file mode 100644
index 00000000..aefc6493
--- /dev/null
+++ b/service/src/main/java/io/provlabs/flow/api/NavEventRequest.java
@@ -0,0 +1,1420 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: nav_event.proto
+
+package io.provlabs.flow.api;
+
+/**
+ * + * NavEventRequest represents a request for NavEvents by either `denom` or `scope_id`. + * One of `denom` or `scope_id` must be provided; the other fields are optional. + *+ * + * Protobuf type {@code nav.NavEventRequest} + */ +public final class NavEventRequest extends + com.google.protobuf.GeneratedMessageV3 implements + // @@protoc_insertion_point(message_implements:nav.NavEventRequest) + NavEventRequestOrBuilder { +private static final long serialVersionUID = 0L; + // Use NavEventRequest.newBuilder() to construct. + private NavEventRequest(com.google.protobuf.GeneratedMessageV3.Builder> builder) { + super(builder); + } + private NavEventRequest() { + denom_ = ""; + scopeId_ = ""; + priceDenoms_ = com.google.protobuf.LazyStringArrayList.EMPTY; + fromDate_ = ""; + toDate_ = ""; + } + + @java.lang.Override + @SuppressWarnings({"unused"}) + protected java.lang.Object newInstance( + UnusedPrivateParameter unused) { + return new NavEventRequest(); + } + + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private NavEventRequest( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + this(); + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + case 10: { + java.lang.String s = input.readStringRequireUtf8(); + + denom_ = s; + break; + } + case 18: { + java.lang.String s = input.readStringRequireUtf8(); + + scopeId_ = s; + break; + } + case 26: { + java.lang.String s = input.readStringRequireUtf8(); + if (!((mutable_bitField0_ & 0x00000001) != 0)) { + priceDenoms_ = new com.google.protobuf.LazyStringArrayList(); + mutable_bitField0_ |= 0x00000001; + } + priceDenoms_.add(s); + break; + } + case 34: { + java.lang.String s = input.readStringRequireUtf8(); + + fromDate_ = s; + break; + } + case 42: { + java.lang.String s = input.readStringRequireUtf8(); + + toDate_ = s; + break; + } + case 48: { + + limit_ = input.readInt32(); + break; + } + default: { + if (!parseUnknownField( + input, unknownFields, extensionRegistry, tag)) { + done = true; + } + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e).setUnfinishedMessage(this); + } finally { + if (((mutable_bitField0_ & 0x00000001) != 0)) { + priceDenoms_ = priceDenoms_.getUnmodifiableView(); + } + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return io.provlabs.flow.api.NavEventOuterClass.internal_static_nav_NavEventRequest_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return io.provlabs.flow.api.NavEventOuterClass.internal_static_nav_NavEventRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + io.provlabs.flow.api.NavEventRequest.class, io.provlabs.flow.api.NavEventRequest.Builder.class); + } + + public static final int DENOM_FIELD_NUMBER = 1; + private volatile java.lang.Object denom_; + /** + *
+ * The token denomination to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string denom = 1;
+ * @return The denom.
+ */
+ @java.lang.Override
+ public java.lang.String getDenom() {
+ java.lang.Object ref = denom_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ denom_ = s;
+ return s;
+ }
+ }
+ /**
+ * + * The token denomination to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string denom = 1;
+ * @return The bytes for denom.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString
+ getDenomBytes() {
+ java.lang.Object ref = denom_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ denom_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int SCOPE_ID_FIELD_NUMBER = 2;
+ private volatile java.lang.Object scopeId_;
+ /**
+ * + * The scope ID to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string scope_id = 2;
+ * @return The scopeId.
+ */
+ @java.lang.Override
+ public java.lang.String getScopeId() {
+ java.lang.Object ref = scopeId_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ scopeId_ = s;
+ return s;
+ }
+ }
+ /**
+ * + * The scope ID to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string scope_id = 2;
+ * @return The bytes for scopeId.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString
+ getScopeIdBytes() {
+ java.lang.Object ref = scopeId_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ scopeId_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int PRICE_DENOMS_FIELD_NUMBER = 3;
+ private com.google.protobuf.LazyStringList priceDenoms_;
+ /**
+ * + * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @return A list containing the priceDenoms.
+ */
+ public com.google.protobuf.ProtocolStringList
+ getPriceDenomsList() {
+ return priceDenoms_;
+ }
+ /**
+ * + * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @return The count of priceDenoms.
+ */
+ public int getPriceDenomsCount() {
+ return priceDenoms_.size();
+ }
+ /**
+ * + * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @param index The index of the element to return.
+ * @return The priceDenoms at the given index.
+ */
+ public java.lang.String getPriceDenoms(int index) {
+ return priceDenoms_.get(index);
+ }
+ /**
+ * + * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @param index The index of the value to return.
+ * @return The bytes of the priceDenoms at the given index.
+ */
+ public com.google.protobuf.ByteString
+ getPriceDenomsBytes(int index) {
+ return priceDenoms_.getByteString(index);
+ }
+
+ public static final int FROM_DATE_FIELD_NUMBER = 4;
+ private volatile java.lang.Object fromDate_;
+ /**
+ * + * Optional. The start date (in string format) to filter events. + *+ * + *
string from_date = 4;
+ * @return The fromDate.
+ */
+ @java.lang.Override
+ public java.lang.String getFromDate() {
+ java.lang.Object ref = fromDate_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ fromDate_ = s;
+ return s;
+ }
+ }
+ /**
+ * + * Optional. The start date (in string format) to filter events. + *+ * + *
string from_date = 4;
+ * @return The bytes for fromDate.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString
+ getFromDateBytes() {
+ java.lang.Object ref = fromDate_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ fromDate_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int TO_DATE_FIELD_NUMBER = 5;
+ private volatile java.lang.Object toDate_;
+ /**
+ * + * Optional. The end date (in string format) to filter events. + *+ * + *
string to_date = 5;
+ * @return The toDate.
+ */
+ @java.lang.Override
+ public java.lang.String getToDate() {
+ java.lang.Object ref = toDate_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ toDate_ = s;
+ return s;
+ }
+ }
+ /**
+ * + * Optional. The end date (in string format) to filter events. + *+ * + *
string to_date = 5;
+ * @return The bytes for toDate.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString
+ getToDateBytes() {
+ java.lang.Object ref = toDate_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ toDate_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int LIMIT_FIELD_NUMBER = 6;
+ private int limit_;
+ /**
+ * + * Optional. The maximum number of results to return. If not provided, defaults to 100. + *+ * + *
int32 limit = 6;
+ * @return The limit.
+ */
+ @java.lang.Override
+ public int getLimit() {
+ return limit_;
+ }
+
+ private byte memoizedIsInitialized = -1;
+ @java.lang.Override
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ @java.lang.Override
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ if (!getDenomBytes().isEmpty()) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 1, denom_);
+ }
+ if (!getScopeIdBytes().isEmpty()) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 2, scopeId_);
+ }
+ for (int i = 0; i < priceDenoms_.size(); i++) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 3, priceDenoms_.getRaw(i));
+ }
+ if (!getFromDateBytes().isEmpty()) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 4, fromDate_);
+ }
+ if (!getToDateBytes().isEmpty()) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 5, toDate_);
+ }
+ if (limit_ != 0) {
+ output.writeInt32(6, limit_);
+ }
+ unknownFields.writeTo(output);
+ }
+
+ @java.lang.Override
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (!getDenomBytes().isEmpty()) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, denom_);
+ }
+ if (!getScopeIdBytes().isEmpty()) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, scopeId_);
+ }
+ {
+ int dataSize = 0;
+ for (int i = 0; i < priceDenoms_.size(); i++) {
+ dataSize += computeStringSizeNoTag(priceDenoms_.getRaw(i));
+ }
+ size += dataSize;
+ size += 1 * getPriceDenomsList().size();
+ }
+ if (!getFromDateBytes().isEmpty()) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(4, fromDate_);
+ }
+ if (!getToDateBytes().isEmpty()) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(5, toDate_);
+ }
+ if (limit_ != 0) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(6, limit_);
+ }
+ size += unknownFields.getSerializedSize();
+ memoizedSize = size;
+ return size;
+ }
+
+ @java.lang.Override
+ public boolean equals(final java.lang.Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof io.provlabs.flow.api.NavEventRequest)) {
+ return super.equals(obj);
+ }
+ io.provlabs.flow.api.NavEventRequest other = (io.provlabs.flow.api.NavEventRequest) obj;
+
+ if (!getDenom()
+ .equals(other.getDenom())) return false;
+ if (!getScopeId()
+ .equals(other.getScopeId())) return false;
+ if (!getPriceDenomsList()
+ .equals(other.getPriceDenomsList())) return false;
+ if (!getFromDate()
+ .equals(other.getFromDate())) return false;
+ if (!getToDate()
+ .equals(other.getToDate())) return false;
+ if (getLimit()
+ != other.getLimit()) return false;
+ if (!unknownFields.equals(other.unknownFields)) return false;
+ return true;
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptor().hashCode();
+ hash = (37 * hash) + DENOM_FIELD_NUMBER;
+ hash = (53 * hash) + getDenom().hashCode();
+ hash = (37 * hash) + SCOPE_ID_FIELD_NUMBER;
+ hash = (53 * hash) + getScopeId().hashCode();
+ if (getPriceDenomsCount() > 0) {
+ hash = (37 * hash) + PRICE_DENOMS_FIELD_NUMBER;
+ hash = (53 * hash) + getPriceDenomsList().hashCode();
+ }
+ hash = (37 * hash) + FROM_DATE_FIELD_NUMBER;
+ hash = (53 * hash) + getFromDate().hashCode();
+ hash = (37 * hash) + TO_DATE_FIELD_NUMBER;
+ hash = (53 * hash) + getToDate().hashCode();
+ hash = (37 * hash) + LIMIT_FIELD_NUMBER;
+ hash = (53 * hash) + getLimit();
+ hash = (29 * hash) + unknownFields.hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static io.provlabs.flow.api.NavEventRequest parseFrom(
+ java.nio.ByteBuffer data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.provlabs.flow.api.NavEventRequest parseFrom(
+ java.nio.ByteBuffer data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.provlabs.flow.api.NavEventRequest parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.provlabs.flow.api.NavEventRequest parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.provlabs.flow.api.NavEventRequest parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.provlabs.flow.api.NavEventRequest parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.provlabs.flow.api.NavEventRequest parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static io.provlabs.flow.api.NavEventRequest parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static io.provlabs.flow.api.NavEventRequest parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input);
+ }
+ public static io.provlabs.flow.api.NavEventRequest parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static io.provlabs.flow.api.NavEventRequest parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static io.provlabs.flow.api.NavEventRequest parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ @java.lang.Override
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+ public static Builder newBuilder(io.provlabs.flow.api.NavEventRequest prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+ @java.lang.Override
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ * + * NavEventRequest represents a request for NavEvents by either `denom` or `scope_id`. + * One of `denom` or `scope_id` must be provided; the other fields are optional. + *+ * + * Protobuf type {@code nav.NavEventRequest} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessageV3.Builder
+ * The token denomination to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string denom = 1;
+ * @return The denom.
+ */
+ public java.lang.String getDenom() {
+ java.lang.Object ref = denom_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ denom_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * + * The token denomination to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string denom = 1;
+ * @return The bytes for denom.
+ */
+ public com.google.protobuf.ByteString
+ getDenomBytes() {
+ java.lang.Object ref = denom_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ denom_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * + * The token denomination to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string denom = 1;
+ * @param value The denom to set.
+ * @return This builder for chaining.
+ */
+ public Builder setDenom(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ denom_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The token denomination to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string denom = 1;
+ * @return This builder for chaining.
+ */
+ public Builder clearDenom() {
+
+ denom_ = getDefaultInstance().getDenom();
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The token denomination to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string denom = 1;
+ * @param value The bytes for denom to set.
+ * @return This builder for chaining.
+ */
+ public Builder setDenomBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ denom_ = value;
+ onChanged();
+ return this;
+ }
+
+ private java.lang.Object scopeId_ = "";
+ /**
+ * + * The scope ID to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string scope_id = 2;
+ * @return The scopeId.
+ */
+ public java.lang.String getScopeId() {
+ java.lang.Object ref = scopeId_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ scopeId_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * + * The scope ID to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string scope_id = 2;
+ * @return The bytes for scopeId.
+ */
+ public com.google.protobuf.ByteString
+ getScopeIdBytes() {
+ java.lang.Object ref = scopeId_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ scopeId_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * + * The scope ID to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string scope_id = 2;
+ * @param value The scopeId to set.
+ * @return This builder for chaining.
+ */
+ public Builder setScopeId(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ scopeId_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The scope ID to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string scope_id = 2;
+ * @return This builder for chaining.
+ */
+ public Builder clearScopeId() {
+
+ scopeId_ = getDefaultInstance().getScopeId();
+ onChanged();
+ return this;
+ }
+ /**
+ * + * The scope ID to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string scope_id = 2;
+ * @param value The bytes for scopeId to set.
+ * @return This builder for chaining.
+ */
+ public Builder setScopeIdBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ scopeId_ = value;
+ onChanged();
+ return this;
+ }
+
+ private com.google.protobuf.LazyStringList priceDenoms_ = com.google.protobuf.LazyStringArrayList.EMPTY;
+ private void ensurePriceDenomsIsMutable() {
+ if (!((bitField0_ & 0x00000001) != 0)) {
+ priceDenoms_ = new com.google.protobuf.LazyStringArrayList(priceDenoms_);
+ bitField0_ |= 0x00000001;
+ }
+ }
+ /**
+ * + * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @return A list containing the priceDenoms.
+ */
+ public com.google.protobuf.ProtocolStringList
+ getPriceDenomsList() {
+ return priceDenoms_.getUnmodifiableView();
+ }
+ /**
+ * + * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @return The count of priceDenoms.
+ */
+ public int getPriceDenomsCount() {
+ return priceDenoms_.size();
+ }
+ /**
+ * + * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @param index The index of the element to return.
+ * @return The priceDenoms at the given index.
+ */
+ public java.lang.String getPriceDenoms(int index) {
+ return priceDenoms_.get(index);
+ }
+ /**
+ * + * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @param index The index of the value to return.
+ * @return The bytes of the priceDenoms at the given index.
+ */
+ public com.google.protobuf.ByteString
+ getPriceDenomsBytes(int index) {
+ return priceDenoms_.getByteString(index);
+ }
+ /**
+ * + * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @param index The index to set the value at.
+ * @param value The priceDenoms to set.
+ * @return This builder for chaining.
+ */
+ public Builder setPriceDenoms(
+ int index, java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ ensurePriceDenomsIsMutable();
+ priceDenoms_.set(index, value);
+ onChanged();
+ return this;
+ }
+ /**
+ * + * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @param value The priceDenoms to add.
+ * @return This builder for chaining.
+ */
+ public Builder addPriceDenoms(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ ensurePriceDenomsIsMutable();
+ priceDenoms_.add(value);
+ onChanged();
+ return this;
+ }
+ /**
+ * + * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @param values The priceDenoms to add.
+ * @return This builder for chaining.
+ */
+ public Builder addAllPriceDenoms(
+ java.lang.Iterable+ * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @return This builder for chaining.
+ */
+ public Builder clearPriceDenoms() {
+ priceDenoms_ = com.google.protobuf.LazyStringArrayList.EMPTY;
+ bitField0_ = (bitField0_ & ~0x00000001);
+ onChanged();
+ return this;
+ }
+ /**
+ * + * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @param value The bytes of the priceDenoms to add.
+ * @return This builder for chaining.
+ */
+ public Builder addPriceDenomsBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+ ensurePriceDenomsIsMutable();
+ priceDenoms_.add(value);
+ onChanged();
+ return this;
+ }
+
+ private java.lang.Object fromDate_ = "";
+ /**
+ * + * Optional. The start date (in string format) to filter events. + *+ * + *
string from_date = 4;
+ * @return The fromDate.
+ */
+ public java.lang.String getFromDate() {
+ java.lang.Object ref = fromDate_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ fromDate_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * + * Optional. The start date (in string format) to filter events. + *+ * + *
string from_date = 4;
+ * @return The bytes for fromDate.
+ */
+ public com.google.protobuf.ByteString
+ getFromDateBytes() {
+ java.lang.Object ref = fromDate_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ fromDate_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * + * Optional. The start date (in string format) to filter events. + *+ * + *
string from_date = 4;
+ * @param value The fromDate to set.
+ * @return This builder for chaining.
+ */
+ public Builder setFromDate(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ fromDate_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * Optional. The start date (in string format) to filter events. + *+ * + *
string from_date = 4;
+ * @return This builder for chaining.
+ */
+ public Builder clearFromDate() {
+
+ fromDate_ = getDefaultInstance().getFromDate();
+ onChanged();
+ return this;
+ }
+ /**
+ * + * Optional. The start date (in string format) to filter events. + *+ * + *
string from_date = 4;
+ * @param value The bytes for fromDate to set.
+ * @return This builder for chaining.
+ */
+ public Builder setFromDateBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ fromDate_ = value;
+ onChanged();
+ return this;
+ }
+
+ private java.lang.Object toDate_ = "";
+ /**
+ * + * Optional. The end date (in string format) to filter events. + *+ * + *
string to_date = 5;
+ * @return The toDate.
+ */
+ public java.lang.String getToDate() {
+ java.lang.Object ref = toDate_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ toDate_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * + * Optional. The end date (in string format) to filter events. + *+ * + *
string to_date = 5;
+ * @return The bytes for toDate.
+ */
+ public com.google.protobuf.ByteString
+ getToDateBytes() {
+ java.lang.Object ref = toDate_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ toDate_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * + * Optional. The end date (in string format) to filter events. + *+ * + *
string to_date = 5;
+ * @param value The toDate to set.
+ * @return This builder for chaining.
+ */
+ public Builder setToDate(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ toDate_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * Optional. The end date (in string format) to filter events. + *+ * + *
string to_date = 5;
+ * @return This builder for chaining.
+ */
+ public Builder clearToDate() {
+
+ toDate_ = getDefaultInstance().getToDate();
+ onChanged();
+ return this;
+ }
+ /**
+ * + * Optional. The end date (in string format) to filter events. + *+ * + *
string to_date = 5;
+ * @param value The bytes for toDate to set.
+ * @return This builder for chaining.
+ */
+ public Builder setToDateBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ toDate_ = value;
+ onChanged();
+ return this;
+ }
+
+ private int limit_ ;
+ /**
+ * + * Optional. The maximum number of results to return. If not provided, defaults to 100. + *+ * + *
int32 limit = 6;
+ * @return The limit.
+ */
+ @java.lang.Override
+ public int getLimit() {
+ return limit_;
+ }
+ /**
+ * + * Optional. The maximum number of results to return. If not provided, defaults to 100. + *+ * + *
int32 limit = 6;
+ * @param value The limit to set.
+ * @return This builder for chaining.
+ */
+ public Builder setLimit(int value) {
+
+ limit_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * + * Optional. The maximum number of results to return. If not provided, defaults to 100. + *+ * + *
int32 limit = 6;
+ * @return This builder for chaining.
+ */
+ public Builder clearLimit() {
+
+ limit_ = 0;
+ onChanged();
+ return this;
+ }
+ @java.lang.Override
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.setUnknownFields(unknownFields);
+ }
+
+ @java.lang.Override
+ public final Builder mergeUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.mergeUnknownFields(unknownFields);
+ }
+
+
+ // @@protoc_insertion_point(builder_scope:nav.NavEventRequest)
+ }
+
+ // @@protoc_insertion_point(class_scope:nav.NavEventRequest)
+ private static final io.provlabs.flow.api.NavEventRequest DEFAULT_INSTANCE;
+ static {
+ DEFAULT_INSTANCE = new io.provlabs.flow.api.NavEventRequest();
+ }
+
+ public static io.provlabs.flow.api.NavEventRequest getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parser+ * The token denomination to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string denom = 1;
+ * @return The denom.
+ */
+ java.lang.String getDenom();
+ /**
+ * + * The token denomination to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string denom = 1;
+ * @return The bytes for denom.
+ */
+ com.google.protobuf.ByteString
+ getDenomBytes();
+
+ /**
+ * + * The scope ID to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string scope_id = 2;
+ * @return The scopeId.
+ */
+ java.lang.String getScopeId();
+ /**
+ * + * The scope ID to filter events by. Either `denom` or `scope_id` is required. + *+ * + *
string scope_id = 2;
+ * @return The bytes for scopeId.
+ */
+ com.google.protobuf.ByteString
+ getScopeIdBytes();
+
+ /**
+ * + * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @return A list containing the priceDenoms.
+ */
+ java.util.List+ * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @return The count of priceDenoms.
+ */
+ int getPriceDenomsCount();
+ /**
+ * + * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @param index The index of the element to return.
+ * @return The priceDenoms at the given index.
+ */
+ java.lang.String getPriceDenoms(int index);
+ /**
+ * + * Optional. A list of price denominations to filter by. + *+ * + *
repeated string price_denoms = 3;
+ * @param index The index of the value to return.
+ * @return The bytes of the priceDenoms at the given index.
+ */
+ com.google.protobuf.ByteString
+ getPriceDenomsBytes(int index);
+
+ /**
+ * + * Optional. The start date (in string format) to filter events. + *+ * + *
string from_date = 4;
+ * @return The fromDate.
+ */
+ java.lang.String getFromDate();
+ /**
+ * + * Optional. The start date (in string format) to filter events. + *+ * + *
string from_date = 4;
+ * @return The bytes for fromDate.
+ */
+ com.google.protobuf.ByteString
+ getFromDateBytes();
+
+ /**
+ * + * Optional. The end date (in string format) to filter events. + *+ * + *
string to_date = 5;
+ * @return The toDate.
+ */
+ java.lang.String getToDate();
+ /**
+ * + * Optional. The end date (in string format) to filter events. + *+ * + *
string to_date = 5;
+ * @return The bytes for toDate.
+ */
+ com.google.protobuf.ByteString
+ getToDateBytes();
+
+ /**
+ * + * Optional. The maximum number of results to return. If not provided, defaults to 100. + *+ * + *
int32 limit = 6;
+ * @return The limit.
+ */
+ int getLimit();
+}
diff --git a/service/src/main/java/io/provlabs/flow/api/NavEventResponse.java b/service/src/main/java/io/provlabs/flow/api/NavEventResponse.java
new file mode 100644
index 00000000..4fbfc9c9
--- /dev/null
+++ b/service/src/main/java/io/provlabs/flow/api/NavEventResponse.java
@@ -0,0 +1,778 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: nav_event.proto
+
+package io.provlabs.flow.api;
+
+/**
+ * + * NavEventResponse represents the response containing a list of NavEvents. + *+ * + * Protobuf type {@code nav.NavEventResponse} + */ +public final class NavEventResponse extends + com.google.protobuf.GeneratedMessageV3 implements + // @@protoc_insertion_point(message_implements:nav.NavEventResponse) + NavEventResponseOrBuilder { +private static final long serialVersionUID = 0L; + // Use NavEventResponse.newBuilder() to construct. + private NavEventResponse(com.google.protobuf.GeneratedMessageV3.Builder> builder) { + super(builder); + } + private NavEventResponse() { + navEvents_ = java.util.Collections.emptyList(); + } + + @java.lang.Override + @SuppressWarnings({"unused"}) + protected java.lang.Object newInstance( + UnusedPrivateParameter unused) { + return new NavEventResponse(); + } + + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private NavEventResponse( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + this(); + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + case 10: { + if (!((mutable_bitField0_ & 0x00000001) != 0)) { + navEvents_ = new java.util.ArrayList
repeated .nav.NavEvent nav_events = 1;
+ */
+ @java.lang.Override
+ public java.util.Listrepeated .nav.NavEvent nav_events = 1;
+ */
+ @java.lang.Override
+ public java.util.List extends io.provlabs.flow.api.NavEventOrBuilder>
+ getNavEventsOrBuilderList() {
+ return navEvents_;
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ @java.lang.Override
+ public int getNavEventsCount() {
+ return navEvents_.size();
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ @java.lang.Override
+ public io.provlabs.flow.api.NavEvent getNavEvents(int index) {
+ return navEvents_.get(index);
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ @java.lang.Override
+ public io.provlabs.flow.api.NavEventOrBuilder getNavEventsOrBuilder(
+ int index) {
+ return navEvents_.get(index);
+ }
+
+ private byte memoizedIsInitialized = -1;
+ @java.lang.Override
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ @java.lang.Override
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ for (int i = 0; i < navEvents_.size(); i++) {
+ output.writeMessage(1, navEvents_.get(i));
+ }
+ unknownFields.writeTo(output);
+ }
+
+ @java.lang.Override
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ for (int i = 0; i < navEvents_.size(); i++) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(1, navEvents_.get(i));
+ }
+ size += unknownFields.getSerializedSize();
+ memoizedSize = size;
+ return size;
+ }
+
+ @java.lang.Override
+ public boolean equals(final java.lang.Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof io.provlabs.flow.api.NavEventResponse)) {
+ return super.equals(obj);
+ }
+ io.provlabs.flow.api.NavEventResponse other = (io.provlabs.flow.api.NavEventResponse) obj;
+
+ if (!getNavEventsList()
+ .equals(other.getNavEventsList())) return false;
+ if (!unknownFields.equals(other.unknownFields)) return false;
+ return true;
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptor().hashCode();
+ if (getNavEventsCount() > 0) {
+ hash = (37 * hash) + NAV_EVENTS_FIELD_NUMBER;
+ hash = (53 * hash) + getNavEventsList().hashCode();
+ }
+ hash = (29 * hash) + unknownFields.hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static io.provlabs.flow.api.NavEventResponse parseFrom(
+ java.nio.ByteBuffer data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.provlabs.flow.api.NavEventResponse parseFrom(
+ java.nio.ByteBuffer data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.provlabs.flow.api.NavEventResponse parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.provlabs.flow.api.NavEventResponse parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.provlabs.flow.api.NavEventResponse parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.provlabs.flow.api.NavEventResponse parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.provlabs.flow.api.NavEventResponse parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static io.provlabs.flow.api.NavEventResponse parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static io.provlabs.flow.api.NavEventResponse parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input);
+ }
+ public static io.provlabs.flow.api.NavEventResponse parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static io.provlabs.flow.api.NavEventResponse parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static io.provlabs.flow.api.NavEventResponse parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ @java.lang.Override
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+ public static Builder newBuilder(io.provlabs.flow.api.NavEventResponse prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+ @java.lang.Override
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ * + * NavEventResponse represents the response containing a list of NavEvents. + *+ * + * Protobuf type {@code nav.NavEventResponse} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessageV3.Builder
repeated .nav.NavEvent nav_events = 1;
+ */
+ public java.util.Listrepeated .nav.NavEvent nav_events = 1;
+ */
+ public int getNavEventsCount() {
+ if (navEventsBuilder_ == null) {
+ return navEvents_.size();
+ } else {
+ return navEventsBuilder_.getCount();
+ }
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ public io.provlabs.flow.api.NavEvent getNavEvents(int index) {
+ if (navEventsBuilder_ == null) {
+ return navEvents_.get(index);
+ } else {
+ return navEventsBuilder_.getMessage(index);
+ }
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ public Builder setNavEvents(
+ int index, io.provlabs.flow.api.NavEvent value) {
+ if (navEventsBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ ensureNavEventsIsMutable();
+ navEvents_.set(index, value);
+ onChanged();
+ } else {
+ navEventsBuilder_.setMessage(index, value);
+ }
+ return this;
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ public Builder setNavEvents(
+ int index, io.provlabs.flow.api.NavEvent.Builder builderForValue) {
+ if (navEventsBuilder_ == null) {
+ ensureNavEventsIsMutable();
+ navEvents_.set(index, builderForValue.build());
+ onChanged();
+ } else {
+ navEventsBuilder_.setMessage(index, builderForValue.build());
+ }
+ return this;
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ public Builder addNavEvents(io.provlabs.flow.api.NavEvent value) {
+ if (navEventsBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ ensureNavEventsIsMutable();
+ navEvents_.add(value);
+ onChanged();
+ } else {
+ navEventsBuilder_.addMessage(value);
+ }
+ return this;
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ public Builder addNavEvents(
+ int index, io.provlabs.flow.api.NavEvent value) {
+ if (navEventsBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ ensureNavEventsIsMutable();
+ navEvents_.add(index, value);
+ onChanged();
+ } else {
+ navEventsBuilder_.addMessage(index, value);
+ }
+ return this;
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ public Builder addNavEvents(
+ io.provlabs.flow.api.NavEvent.Builder builderForValue) {
+ if (navEventsBuilder_ == null) {
+ ensureNavEventsIsMutable();
+ navEvents_.add(builderForValue.build());
+ onChanged();
+ } else {
+ navEventsBuilder_.addMessage(builderForValue.build());
+ }
+ return this;
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ public Builder addNavEvents(
+ int index, io.provlabs.flow.api.NavEvent.Builder builderForValue) {
+ if (navEventsBuilder_ == null) {
+ ensureNavEventsIsMutable();
+ navEvents_.add(index, builderForValue.build());
+ onChanged();
+ } else {
+ navEventsBuilder_.addMessage(index, builderForValue.build());
+ }
+ return this;
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ public Builder addAllNavEvents(
+ java.lang.Iterable extends io.provlabs.flow.api.NavEvent> values) {
+ if (navEventsBuilder_ == null) {
+ ensureNavEventsIsMutable();
+ com.google.protobuf.AbstractMessageLite.Builder.addAll(
+ values, navEvents_);
+ onChanged();
+ } else {
+ navEventsBuilder_.addAllMessages(values);
+ }
+ return this;
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ public Builder clearNavEvents() {
+ if (navEventsBuilder_ == null) {
+ navEvents_ = java.util.Collections.emptyList();
+ bitField0_ = (bitField0_ & ~0x00000001);
+ onChanged();
+ } else {
+ navEventsBuilder_.clear();
+ }
+ return this;
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ public Builder removeNavEvents(int index) {
+ if (navEventsBuilder_ == null) {
+ ensureNavEventsIsMutable();
+ navEvents_.remove(index);
+ onChanged();
+ } else {
+ navEventsBuilder_.remove(index);
+ }
+ return this;
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ public io.provlabs.flow.api.NavEvent.Builder getNavEventsBuilder(
+ int index) {
+ return getNavEventsFieldBuilder().getBuilder(index);
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ public io.provlabs.flow.api.NavEventOrBuilder getNavEventsOrBuilder(
+ int index) {
+ if (navEventsBuilder_ == null) {
+ return navEvents_.get(index); } else {
+ return navEventsBuilder_.getMessageOrBuilder(index);
+ }
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ public java.util.List extends io.provlabs.flow.api.NavEventOrBuilder>
+ getNavEventsOrBuilderList() {
+ if (navEventsBuilder_ != null) {
+ return navEventsBuilder_.getMessageOrBuilderList();
+ } else {
+ return java.util.Collections.unmodifiableList(navEvents_);
+ }
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ public io.provlabs.flow.api.NavEvent.Builder addNavEventsBuilder() {
+ return getNavEventsFieldBuilder().addBuilder(
+ io.provlabs.flow.api.NavEvent.getDefaultInstance());
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ public io.provlabs.flow.api.NavEvent.Builder addNavEventsBuilder(
+ int index) {
+ return getNavEventsFieldBuilder().addBuilder(
+ index, io.provlabs.flow.api.NavEvent.getDefaultInstance());
+ }
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ public java.util.Listrepeated .nav.NavEvent nav_events = 1;
+ */
+ java.util.Listrepeated .nav.NavEvent nav_events = 1;
+ */
+ io.provlabs.flow.api.NavEvent getNavEvents(int index);
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ int getNavEventsCount();
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ java.util.List extends io.provlabs.flow.api.NavEventOrBuilder>
+ getNavEventsOrBuilderList();
+ /**
+ * repeated .nav.NavEvent nav_events = 1;
+ */
+ io.provlabs.flow.api.NavEventOrBuilder getNavEventsOrBuilder(
+ int index);
+}
diff --git a/service/src/main/java/io/provlabs/flow/api/NavServiceGrpc.java b/service/src/main/java/io/provlabs/flow/api/NavServiceGrpc.java
new file mode 100644
index 00000000..d47c18ec
--- /dev/null
+++ b/service/src/main/java/io/provlabs/flow/api/NavServiceGrpc.java
@@ -0,0 +1,303 @@
+package io.provlabs.flow.api;
+
+import static io.grpc.MethodDescriptor.generateFullMethodName;
+import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
+import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
+import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
+import static io.grpc.stub.ClientCalls.asyncUnaryCall;
+import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
+import static io.grpc.stub.ClientCalls.blockingUnaryCall;
+import static io.grpc.stub.ClientCalls.futureUnaryCall;
+import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncUnaryCall;
+import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
+
+/**
+ * + * NavService is the gRPC service for retrieving NavEvents. + *+ */ +@javax.annotation.Generated( + value = "by gRPC proto compiler", + comments = "Source: nav_event.proto") +public final class NavServiceGrpc { + + private NavServiceGrpc() {} + + public static final String SERVICE_NAME = "nav.NavService"; + + // Static method descriptors that strictly reflect the proto. + private static volatile io.grpc.MethodDescriptor
+ * NavService is the gRPC service for retrieving NavEvents. + *+ */ + public static abstract class NavServiceImplBase implements io.grpc.BindableService { + + /** + */ + public void getNavEvents(io.provlabs.flow.api.NavEventRequest request, + io.grpc.stub.StreamObserver
+ * NavService is the gRPC service for retrieving NavEvents. + *+ */ + public static final class NavServiceStub extends io.grpc.stub.AbstractAsyncStub
+ * NavService is the gRPC service for retrieving NavEvents. + *+ */ + public static final class NavServiceBlockingStub extends io.grpc.stub.AbstractBlockingStub
+ * NavService is the gRPC service for retrieving NavEvents. + *+ */ + public static final class NavServiceFutureStub extends io.grpc.stub.AbstractFutureStub