Remove Kafka publishing events

Author: lakhina

user-api/src/main/java/com/example/auction/user/api/UserService.java

@@ -20,7 +20,6 @@ public interface UserService extends Service {
 
     ServiceCall<NotUsed, User> getUser(UUID userId);
 
-    Topic<UserEvent> userEvents();
 
     ServiceCall<NotUsed, PaginatedSequence<User>> getUsers(
             Optional<Integer> pageNo, Optional<Integer> pageSize);

user-impl/src/main/java/com/example/auction/user/impl/UserServiceImpl.java

@@ -40,7 +40,7 @@ public UserServiceImpl(PersistentEntityRegistry registry, UserRepository userRep
     public ServiceCall<UserRegistration, User> createUser() {
         return user -> {
             UUID uuid = UUID.randomUUID();
-            Instant createdAt = Instant.now();
+
             String password = PUserCommand.hashPassword(user.getPassword());
             PUser createdUser = new PUser(uuid,  user.getName(), user.getEmail(), password);
             return entityRef(uuid)
@@ -63,27 +63,6 @@ public ServiceCall<NotUsed, User> getUser(UUID userId) {
                         });
 
     }
-    @Override
-    public Topic<UserEvent> userEvents() {
-        return TopicProducer.taggedStreamWithOffset(PUserEvent.TAG.allTags(), this::streamForTag);
-    }
-
-    private Source<Pair<UserEvent, Offset>, ?> streamForTag(AggregateEventTag<PUserEvent> tag, Offset offset) {
-        return registry.eventStream(tag, offset).filter(eventOffset ->
-                eventOffset.first() instanceof PUserEvent.PUserCreated
-        ).mapAsync(1, eventOffset -> {
-
-                PUserEvent.PUserCreated userCreated = (PUserEvent.PUserCreated) eventOffset.first();
-                return CompletableFuture.completedFuture(Pair.create(
-                        new UserEvent.PUserCreated(convertUser(userCreated.getUser())),
-                        eventOffset.second()
-                ));
-
-        });
-    }
-    private User convertUser(com.example.auction.user.impl.PUser user) {
-        return new User(user.getId(),user.getCreatedAt(),user.getName(),user.getEmail());
-    }
 
     @Override
     public ServiceCall<NotUsed, PaginatedSequence<User>> getUsers(Optional<Integer> pageNo, Optional<Integer> pageSize) {

web-gateway/src/main/java/controllers/ItemController.java

@@ -17,8 +17,6 @@
 import play.mvc.Result;
 import views.html.editItem;
 
-import play.Configuration;
-import views.html.item;
 
 import javax.inject.Inject;
 import java.time.Duration;
@@ -27,7 +25,7 @@
 import java.util.*;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CompletionStage;
-import java.util.concurrent.ExecutionException;
+
 
 import static com.example.auction.security.ClientSecurity.*;
 
@@ -185,9 +183,10 @@ private CompletionStage<Result> doGetItem(Http.Context ctx, String itemId, Form<
                     .handleRequestHeader(authenticate(user)).invoke();
             CompletionStage<PaginatedSequence<User>> users =userService.getUsers(Optional.of(0),Optional.of(10))
                     .handleRequestHeader(authenticate(user)).invoke();
+            users.thenCombineAsync(u, (userPaginatedSequence, user1) -> {
+
+                return itemFuture.thenCombineAsync(bidHistoryFuture, (item, bidHistory) -> {
 
-            itemFuture.thenCombineAsync(bidHistoryFuture, (item, bidHistory) -> {
-                return users.thenCombineAsync(u, (userPaginatedSequence, user1) -> {
                     if (item.getStatus() == ItemStatus.CREATED && !item.getCreator().equals(user1.getId())) {
                         return forbidden();
                     }
@@ -236,9 +235,9 @@ private CompletionStage<Result> doGetItem(Http.Context ctx, String itemId, Form<
 
                     return ok(views.html.item.render(showInlineInstruction, item, bidForm, anonymizeBids(user, currency, bidHistory), user, currency, seller, winner, currentBidMaximum, bidResult, nav));
                 });
-                return null;
+
             }, ec.current());
-            return null;
+return null;
         }, ec.current()));
     }
 

web-gateway/src/main/java/controllers/TransactionController.java

@@ -110,7 +110,7 @@ public CompletionStage<Result> getTransaction(String id) {
                                     return ok(views.html.transaction.render(showInlineInstruction, Optional.empty(),user, Optional.empty(), Optional.empty(), Optional.empty(), Optional.of(msg), nav));
                                 }
                             });
-                            return null;
+                          return null;
                         }
                 , ec.current())
                 );