Writing to mongodb

onesimus-wiafe · Aug 6, 2024 · 65ab276 · 65ab276
1 parent ef14180
commit 65ab276
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 5 deletions.
diff --git a/ReportService/src/main/java/com/trading/joe/reportservice/entities/Users.java b/ReportService/src/main/java/com/trading/joe/reportservice/entities/Users.java
@@ -16,12 +16,12 @@
 public class Users {
 
  @Id
- private Long id;
-
  private Long user_id;
+
  private String name;
  private String email;
  private String accountType;
  private Boolean pendingDelete;
  private LocalDateTime createdAt;
+ private LocalDateTime updatedAt;
 }
diff --git a/ReportService/src/main/java/com/trading/joe/reportservice/service/ReportingServiceImpl.java b/ReportService/src/main/java/com/trading/joe/reportservice/service/ReportingServiceImpl.java
@@ -3,6 +3,7 @@
 import com.joe.trading.shared.dtos.UserEventDto;
 import com.joe.trading.shared.events.Event;
 import com.joe.trading.shared.nats.NatsService;
+import com.trading.joe.reportservice.entities.Users;
 import com.trading.joe.reportservice.exceptions.ResourceNotFoundException;
 import com.trading.joe.reportservice.repository.PortfolioRepository;
 import com.trading.joe.reportservice.repository.UserRepository;
@@ -22,20 +23,35 @@ public class ReportingServiceImpl implements ReportingService{
  public void userCreatedEvent() throws ResourceNotFoundException {
  System.out.println("Testing nats subscribe");
  try {
- natsService.subscribe(Event.USER_CREATED, UserEventDto.class, System.out::println);
+ natsService.subscribe(Event.USER_CREATED, UserEventDto.class, this::saveEvent);
  } catch (Exception e) {
  throw new ResourceNotFoundException("Could not fetch from Nats Service");
  }
  }
+ public void saveEvent(UserEventDto userEventDto){
+ userRepository.save(user(userEventDto));
+ }
 
  @Override
  public void createUser() throws ResourceNotFoundException {
  try{
- natsService.subscribe(Event.USER_CREATED, UserEventDto.class, System.out::println);
- //userRepository.save()
+ natsService.subscribe(Event.USER_CREATED, UserEventDto.class,this::saveEvent);
  } catch (Exception e) {
  throw new ResourceNotFoundException("Could not fetch from Nats Service");
  }
  }
 
+ public Users user(UserEventDto userEventDto){
+ Users user = new Users();
+ user.setUser_id(userEventDto.getId());
+ user.setName(userEventDto.getName());
+ user.setEmail(userEventDto.getEmail());
+ user.setAccountType(user.getAccountType());
+ user.setPendingDelete(userEventDto.getPendingDelete());
+ user.setCreatedAt(userEventDto.getCreatedAt());
+ user.setUpdatedAt(userEventDto.getUpdatedAt());
+
+ return user;
+ }
+
 }