seancarroll/fdb-java-es

package com.eventfully.foundationdb.eventstore;

import com.apple.foundationdb.tuple.Versionstamp;
import com.google.common.base.MoreObjects;

/**
 * Represents the result returned after appending to a stream
 *
 */
public class AppendResult {

    private Integer maxCount;

    // TODO: EventStore instead has NextExpectedVersion - The next expected version for the stream -  For example if you write to a stream at version 1, then you expect it to be at version 1 next time you write
    /**
     * The current version of the stream after the append operation was performed
     *
     */
    private final long currentVersion;

    /**
     * The current position of the stream after the append operation was performed
     */
    private final Versionstamp currentPosition;

    /**
     * Constructs new {@link AppendResult}
     * @param currentVersion The current version of the stream after the append operation was performed.
     * @param currentPosition The current position of the stream after the append operation was performed.
     */
    public AppendResult(long currentVersion, Versionstamp currentPosition) {
        this(null, currentVersion, currentPosition);
    }

    /**
     * Constructs new {@link AppendResult}
     * @param currentVersion The current version of the stream after the append operation was performed.
     * @param currentPosition The current position of the stream after the append operation was performed.
     */
    public AppendResult(Integer maxCount, long currentVersion, Versionstamp currentPosition) {
        this.maxCount = maxCount;
        this.currentVersion = currentVersion;
        this.currentPosition = currentPosition;
    }

    public Integer getMaxCount() {
        return maxCount;
    }

    public long getCurrentVersion() {
        return currentVersion;
    }

    public Versionstamp getCurrentPosition() {
        return currentPosition;
    }

    @Override
    public String toString() {
        return MoreObjects.toStringHelper(this)
            .add("maxCount", getMaxCount())
            .add("currentVersion", getCurrentVersion())
            .add("currentPosition", getCurrentPosition())
            .toString();
    }
}