package se.citerus.cqrs.bookstore.domain.publisher;

import se.citerus.cqrs.bookstore.book.BookId;
import se.citerus.cqrs.bookstore.domain.AggregateRoot;
import se.citerus.cqrs.bookstore.publisher.PublisherContractId;
import se.citerus.cqrs.bookstore.publisher.event.PublisherRegisteredEvent;
import se.citerus.cqrs.bookstore.publisher.event.PurchaseRegisteredEvent;

import static com.google.common.base.Preconditions.checkState;

public class PublisherContract extends AggregateRoot<PublisherContractId> {

  private String publisherName;
  private double fee;
  private long limit;
  private long accumulatedAmount;

  public void register(PublisherContractId publisherContractId, String name, double fee, long limit) {
    assertHasNotBeenRegistered();
    applyChange(new PublisherRegisteredEvent(publisherContractId, nextVersion(), now(), name, fee, limit));
  }

  public void registerPurchase(BookId bookId, long amount) {
    long newAmount = ExcapAmount(amount);
    applyChange(new PurchaseRegisteredEvent(id(), nextVersion(), now(), bookId, newAmount));
  }

  private long capAmount(long amount) {
    long newAmount = amount;
    if (exceedsLimit(amount)) {
      newAmount = limit - accumulatedAmount;
    }
    return newAmount;
  }

  private boolean exceedsLimit(long amount) {
    return accumulatedAmount + amount >= limit;
  }

  private void assertHasNotBeenRegistered() {
    checkState(id == null, "Contract has already been registered");
  }

  @SuppressWarnings("UnusedDeclaration")
  void handleEvent(PublisherRegisteredEvent event) {
    this.id = event.aggregateId;
    this.version = event.version;
    this.timestamp = event.timestamp;
    this.publisherName = event.publisherName;
    this.fee = event.fee;
    this.limit = event.limit;
  }

  @SuppressWarnings("UnusedDeclaration")
  void handleEvent(PurchaseRegisteredEvent event) {
    this.version = event.version;
    this.timestamp = event.timestamp;
    this.accumulatedAmount += event.amount;
  }

  public String publisherName() {
    return publisherName;
  }

  public double fee() {
    return fee;
  }

}

package se.citerus.cqrs.bookstore.domain.publisher;

import se.citerus.cqrs.bookstore.book.BookId;
import se.citerus.cqrs.bookstore.domain.AggregateRoot;
import se.citerus.cqrs.bookstore.publisher.PublisherContractId;
import se.citerus.cqrs.bookstore.publisher.event.PublisherRegisteredEvent;
import se.citerus.cqrs.bookstore.publisher.event.PurchaseRegisteredEvent;

import static com.google.common.base.Preconditions.checkState;

public class PublisherContract extends AggregateRoot<PublisherContractId> {

  private String publisherName;
  private double fee;
  private long limit;
  private long accumulatedAmount;

  public void register(PublisherContractId publisherContractId, String name, double fee, long limit) {
    assertHasNotBeenRegistered();
    applyChange(new PublisherRegisteredEvent(publisherContractId, nextVersion(), now(), name, fee, limit));
  }

  public void registerPurchase(BookId bookId, long amount) {
    long newAmount = capAmount(amount);
    applyChange(new PurchaseRegisteredEvent(id(), nextVersion(), now(), bookId, newAmount));
  }

  private long capAmount(long amount) {
    long newAmount = amount;
    if (exceedsLimit(amount)) {
      newAmount = limit - accumulatedAmount;
    }
    return newAmount;
  }

  private boolean exceedsLimit(long amount) {
    return accumulatedAmount + amount >= limit;
  }

  private void assertHasNotBeenRegistered() {
    checkState(id == null, "Contract has already been registered");
  }

  @SuppressWarnings("UnusedDeclaration")
  void handleEvent(PublisherRegisteredEvent event) {
    this.id = event.aggregateId;
    this.version = event.version;
    this.timestamp = event.timestamp;
    this.publisherName = event.publisherName;
    this.fee = event.fee;
    this.limit = event.limit;
  }

  @SuppressWarnings("UnusedDeclaration")
  void handleEvent(PurchaseRegisteredEvent event) {
    this.version = event.version;
    this.timestamp = event.timestamp;
    this.accumulatedAmount += event.amount;
  }

  public String publisherName() {
    return publisherName;
  }

  public double fee() {
    return fee;
  }

}

Fix bad commit