mindol1004/event-sourcing-examples
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #53 from dartpopikyardo/private-event-sourcing-examples-38

Browse Source 
Resolve issues with PR
This commit is contained in:
Chris Richardson
2016-09-28 10:31:46 -07:00
committed by GitHub
parent b2d135665c 4b78658dd8
commit c2e4df440b
15 changed files with 30 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
java-spring/accounts-query-side-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/queryside/accounts/AccountInfoUpdateService.java
View File

@@ -40,7 +40,7 @@ public class AccountInfoUpdateService {
.set("description", description)
.set("balance", toIntegerRepr(initialBalance))
.push("changes", ci)
.set("date", getFromEventId(version))
.set("creationDate", getFromEventId(version))
.set("version", version),
AccountInfo.class);
logger.info("Saved in mongo");

6
java-spring/api-gateway-service/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/apigateway/controller/GatewayController.java
View File

@@ -29,7 +29,6 @@ import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.URISyntaxException;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import static org.springframework.web.bind.annotation.RequestMethod.*;
@@ -59,11 +58,12 @@ public class GatewayController {
logger.info("request: {}", proxiedRequest);
HttpResponse proxiedResponse = httpClient.execute(proxiedRequest);
logger.info("Response {}", proxiedResponse.getStatusLine().getStatusCode());
return new ResponseEntity<>(read(proxiedResponse.getEntity().getContent()), processHeaders(proxiedResponse.getFirstHeader("Content-Type")), HttpStatus.valueOf(proxiedResponse.getStatusLine().getStatusCode()));
return new ResponseEntity<>(read(proxiedResponse.getEntity().getContent()), makeResponseHeaders(proxiedResponse), HttpStatus.valueOf(proxiedResponse.getStatusLine().getStatusCode()));
}
private HttpHeaders processHeaders(Header h) {
private HttpHeaders makeResponseHeaders(HttpResponse response) {
HttpHeaders result = new HttpHeaders();
Header h = response.getFirstHeader("Content-Type");
result.set(h.getName(), h.getValue());
return result;
}

4
java-spring/common-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/common/accounts/AccountChangedEvent.java
View File

@@ -1,10 +1,8 @@
package net.chrisrichardson.eventstore.javaexamples.banking.backend.common.accounts;
import io.eventuate.Event;
import java.math.BigDecimal;
public class AccountChangedEvent implements Event {
public class AccountChangedEvent extends AccountEvent {
protected BigDecimal amount;
protected String transactionId;

4
java-spring/common-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/common/accounts/AccountDebitFailedDueToInsufficientFundsEvent.java
View File

@@ -1,8 +1,6 @@
package net.chrisrichardson.eventstore.javaexamples.banking.backend.common.accounts;
import io.eventuate.Event;
public class AccountDebitFailedDueToInsufficientFundsEvent implements Event {
public class AccountDebitFailedDueToInsufficientFundsEvent extends AccountEvent {
private String transactionId;
private AccountDebitFailedDueToInsufficientFundsEvent() {

6
java-spring/common-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/common/accounts/AccountDeletedEvent.java
View File

@@ -1,8 +1,4 @@
package net.chrisrichardson.eventstore.javaexamples.banking.backend.common.accounts;
import io.eventuate.Event;
import java.util.Date;
public class AccountDeletedEvent implements Event {
public class AccountDeletedEvent extends AccountEvent {
}

8
java-spring/common-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/common/accounts/AccountEvent.java Normal file
View File

@@ -0,0 +1,8 @@
package net.chrisrichardson.eventstore.javaexamples.banking.backend.common.accounts;
import io.eventuate.Event;
import io.eventuate.EventEntity;
@EventEntity(entity="net.chrisrichardson.eventstore.javaexamples.banking.backend.commandside.accounts.Account")
public abstract class AccountEvent implements Event{
}

5
java-spring/common-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/common/accounts/AccountOpenedEvent.java
View File

@@ -1,11 +1,8 @@
package net.chrisrichardson.eventstore.javaexamples.banking.backend.common.accounts;
import io.eventuate.Event;
import java.math.BigDecimal;
public class AccountOpenedEvent implements Event {
public class AccountOpenedEvent extends AccountEvent {
private String customerId;
private String title;

2
java-spring/common-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/common/accounts/package-info.java
View File

@@ -1,2 +0,0 @@
@io.eventuate.EventEntity(entity="net.chrisrichardson.eventstore.javaexamples.banking.backend.commandside.accounts.Account")
package net.chrisrichardson.eventstore.javaexamples.banking.backend.common.accounts;

3
java-spring/common-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/common/transactions/CreditRecordedEvent.java
View File

@@ -1,8 +1,7 @@
package net.chrisrichardson.eventstore.javaexamples.banking.backend.common.transactions;
import io.eventuate.Event;
public class CreditRecordedEvent implements Event {
public class CreditRecordedEvent extends MoneyTransferEvent {
private TransferDetails details;
private CreditRecordedEvent() {

6
java-spring/common-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/common/transactions/DebitRecordedEvent.java
View File

@@ -1,10 +1,6 @@
package net.chrisrichardson.eventstore.javaexamples.banking.backend.common.transactions;
// import io.eventuate.Event;
import io.eventuate.Event;
public class DebitRecordedEvent implements Event {
public class DebitRecordedEvent extends MoneyTransferEvent {
private TransferDetails details;
private DebitRecordedEvent() {

3
java-spring/common-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/common/transactions/FailedDebitRecordedEvent.java
View File

@@ -1,8 +1,7 @@
package net.chrisrichardson.eventstore.javaexamples.banking.backend.common.transactions;
import io.eventuate.Event;
public class FailedDebitRecordedEvent implements Event {
public class FailedDebitRecordedEvent extends MoneyTransferEvent {
private TransferDetails details;
private FailedDebitRecordedEvent() {

4
java-spring/common-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/common/transactions/MoneyTransferCreatedEvent.java
View File

@@ -1,9 +1,7 @@
package net.chrisrichardson.eventstore.javaexamples.banking.backend.common.transactions;
import io.eventuate.Event;
public class MoneyTransferCreatedEvent implements Event {
public class MoneyTransferCreatedEvent extends MoneyTransferEvent {
private TransferDetails details;
private MoneyTransferCreatedEvent() {

8
java-spring/common-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/common/transactions/MoneyTransferEvent.java Normal file
View File

@@ -0,0 +1,8 @@
package net.chrisrichardson.eventstore.javaexamples.banking.backend.common.transactions;
import io.eventuate.Event;
import io.eventuate.EventEntity;
@EventEntity(entity="net.chrisrichardson.eventstore.javaexamples.banking.backend.commandside.transactions.MoneyTransfer")
public abstract class MoneyTransferEvent implements Event {
}

2
java-spring/common-backend/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/backend/common/transactions/package-info.java
View File

@@ -1,2 +0,0 @@
@io.eventuate.EventEntity(entity="net.chrisrichardson.eventstore.javaexamples.banking.backend.commandside.transactions.MoneyTransfer")
package net.chrisrichardson.eventstore.javaexamples.banking.backend.common.transactions;

2
java-spring/customers-query-side-common/src/main/java/net/chrisrichardson/eventstore/javaexamples/banking/web/customers/queryside/common/QuerySideCustomer.java
View File

@@ -4,12 +4,14 @@ import net.chrisrichardson.eventstore.javaexamples.banking.common.customers.Addr
import net.chrisrichardson.eventstore.javaexamples.banking.common.customers.Name;
import net.chrisrichardson.eventstore.javaexamples.banking.common.customers.ToAccountInfo;
import org.springframework.data.mongodb.core.index.Indexed;
import org.springframework.data.mongodb.core.mapping.Document;
import java.util.Map;
/**
* Created by Main on 05.02.2016.
*/
@Document
public class QuerySideCustomer {
private String id;