package io.vertx.ext.mongo;

import java.util.Objects;

import io.vertx.codegen.annotations.DataObject;
import io.vertx.core.json.JsonObject;

Options used to configure aggregate operations.
Author:
Nick Scavelli/**
 * Options used to configure aggregate operations.
 *
 * @author <a href="mailto:nscavell@redhat.com">Nick Scavelli</a>
 */
@DataObject(generateConverter = true)
public class AggregateOptions {
  
The default value of batchSize = 10.
/**
   * The default value of batchSize = 10.
   */
  public static final int  DEFAULT_BATCH_SIZE     = 20;
  
The default value of maxTime = 0.
/**
   * The default value of maxTime = 0.
   */
  public static final long DEFAULT_MAX_TIME       = 0L;
  
The default value of maxAwaiTime = 0.
/**
   * The default value of maxAwaiTime = 0.
   */
  public static final long DEFAULT_MAX_AWAIT_TIME = 1000L;

  private int     batchSize;
  private long    maxTime;
  private long    maxAwaitTime;
  private Boolean allowDiskUse;

  
Default constructor
/**
   * Default constructor
   */
  public AggregateOptions() {
    this.batchSize = DEFAULT_BATCH_SIZE;
    this.maxTime = DEFAULT_MAX_TIME;
    this.maxAwaitTime = DEFAULT_MAX_AWAIT_TIME;
  }

  
Copy constructor
Params:
options – the one to copy/**
   * Copy constructor
   *
   * @param options the one to copy
   */
  public AggregateOptions(AggregateOptions options) {
    this.batchSize = options.batchSize;
    this.maxTime = options.maxTime;
    this.maxAwaitTime = options.maxAwaitTime;
    this.allowDiskUse = options.allowDiskUse;
  }

  
Constructor from JSON
Params:
options – the JSON/**
   * Constructor from JSON
   *
   * @param options the JSON
   */
  public AggregateOptions(JsonObject options) {
    this();
    AggregateOptionsConverter.fromJson(options, this);
  }

  
Convert to JSON
Returns:
the JSON/**
   * Convert to JSON
   *
   * @return the JSON
   */
  public JsonObject toJson() {
    JsonObject json = new JsonObject();
    AggregateOptionsConverter.toJson(this, json);
    return json;
  }

  
Get the specified time limit in milliseconds for processing operations on a cursor.
If you do not specify a value for maxTime, operations will not time out.
A value of 0 explicitly specifies the default unbounded behavior.
Returns:
the specified time limit in milliseconds for processing operations on a cursor/**
   * Get the specified time limit in milliseconds for processing operations on a cursor.
   * If you do not specify a value for maxTime, operations will not time out.
   * A value of 0 explicitly specifies the default unbounded behavior.
   *
   * @return the specified time limit in milliseconds for processing operations on a cursor
   */
  public long getMaxTime() {
    return maxTime;
  }

  
Set the time limit in milliseconds for processing operations on a cursor.
Params:
maxTime – the time limit in milliseconds for processing operations on a cursor
Returns:
reference to this, for fluency/**
   * Set the time limit in milliseconds for processing operations on a cursor.
   *
   * @param maxTime the time limit in milliseconds for processing operations on a cursor
   * @return reference to this, for fluency
   */
  public AggregateOptions setMaxTime(long maxTime) {
    this.maxTime = maxTime;
    return this;
  }

  
Returns:
the batch size for methods loading found data in batches/**
   * @return the batch size for methods loading found data in batches
   */
  public int getBatchSize() {
    return batchSize;
  }

  
Get the flag if writing to temporary files is enabled.
When set to true, aggregation operations can write data to the _tmp subdirectory in the dbPath directory.
Returns:
true if writing to temporary files is enabled./**
   * Get the flag if writing to temporary files is enabled.
   * When set to true, aggregation operations can write data to the _tmp subdirectory in the dbPath directory.
   *
   * @return true if writing to temporary files is enabled.
   */
  public Boolean getAllowDiskUse(){
    return allowDiskUse;
  }
  
Set the flag if writing to temporary files is enabled.
Params:
allowDiskUse – the flag indicating disk usage on aggregate or not.
Returns:
reference to this, for fluency/**
   * Set the flag if writing to temporary files is enabled.
   *
   * @param allowDiskUse the flag indicating disk usage on aggregate or not.
   * @return reference to this, for fluency
   */
  public AggregateOptions setAllowDiskUse(final Boolean allowDiskUse) {
    this.allowDiskUse = allowDiskUse;
    return this;
  }

  
Set the batch size for methods loading found data in batches.
Params:
batchSize – the number of documents in a batch
Returns:
reference to this, for fluency/**
   * Set the batch size for methods loading found data in batches.
   *
   * @param batchSize the number of documents in a batch
   * @return reference to this, for fluency
   */
  public AggregateOptions setBatchSize(int batchSize) {
    this.batchSize = batchSize;
    return this;
  }

  
Returns:
the max await time in ms/**
   *
   * @return the max await time in ms
   */
  public long getMaxAwaitTime() {
    return maxAwaitTime;
  }

  
The maximum amount of time for the server to wait on new documents to satisfy a $changeStream aggregation.
Params:
maxAwaitTime – the max await time in ms
Returns:
reference to this, for fluency/**
   * The maximum amount of time for the server to wait on new documents to satisfy a $changeStream aggregation.
   *
   * @param maxAwaitTime the max await time in ms
   * @return reference to this, for fluency
   */
  public AggregateOptions setMaxAwaitTime(final long maxAwaitTime) {
    this.maxAwaitTime = maxAwaitTime;
    return this;
  }

  @Override
  public boolean equals(final Object o) {
    if (this == o) {
      return true;
    }
    if (o == null || getClass() != o.getClass()) {
      return false;
    }
    final AggregateOptions that = (AggregateOptions) o;
    return batchSize == that.batchSize && maxTime == that.maxTime && maxAwaitTime == that.maxAwaitTime && allowDiskUse == that.allowDiskUse;
  }

  @Override
  public int hashCode() {
    return Objects.hash(batchSize, maxTime, maxAwaitTime, allowDiskUse);
  }
}