Transaction API fix

yugabyte-integration/src/main/java/com/ondc/yugabyte_integration/Controller/PayloadController.java

@@ -46,9 +46,8 @@ public void deletePayload(@PathVariable Long id) {
         service.deletePayload(id);
     }
 
-    @GetMapping("/{transactionId}")
-    public Payload getPayloadFromTransactionId(@PathVariable String transactionId) {
-        Optional<Payload> payload = service.getPayloadByTransactionId(transactionId);
-        return payload.orElse(null);
+    @GetMapping("/transaction/{transactionId}")
+    public List<Payload> getPayloadFromTransactionId(@PathVariable String transactionId) {
+        return service.getPayloadByTransactionId(transactionId);
     }
 }

yugabyte-integration/src/main/java/com/ondc/yugabyte_integration/Entity/Payload.java

@@ -36,7 +36,7 @@ public class Payload {
     private Timestamp createdAt;
     private Timestamp updatedAt;
 
-    @ManyToOne(fetch = FetchType.LAZY)
+    @ManyToOne(fetch = FetchType.EAGER)
     @JoinColumn(name = "session_id", referencedColumnName = "sessionId")
     @JsonIgnoreProperties({"payloads", "npType", "npId", "domain", "version", "sessionType", "sessionActive"})
     private SessionDetails sessionDetails;

yugabyte-integration/src/main/java/com/ondc/yugabyte_integration/Repository/PayloadRepository.java

@@ -10,7 +10,7 @@
 @Repository
 public interface PayloadRepository extends JpaRepository<Payload, Long> {
 
-    Optional<Payload> findByTransactionId(String transactionId);
+    List<Payload> findByTransactionId(String transactionId);
     List<Payload> findBySessionDetailsSessionId(String sessionId);
 
 }

yugabyte-integration/src/main/java/com/ondc/yugabyte_integration/Service/PayloadService.java

@@ -27,7 +27,9 @@ public Payload getPayloadById(Long id) {
         return repository.findById(id).orElse(null);
     }
 
-    public Optional<Payload> getPayloadByTransactionId(String transactionId) {
+    @Transactional
+    public List<Payload> getPayloadByTransactionId(String transactionId) {
+        Log.info("transactionId - {}", transactionId);
         return repository.findByTransactionId(transactionId);
     }
 

yugabyte-integration/src/main/resources/application.properties

@@ -1,9 +1,9 @@
 spring.application.name=yugabyte-integration
-spring.datasource.url=${DB_URL}
-#spring.datasource.url=jdbc:postgresql://127.0.0.1:5433/my_app
+#spring.datasource.url=${DB_URL}
+spring.datasource.url=jdbc:postgresql://127.0.0.1:5433/my_app
 spring.datasource.username=yugabyte
 #spring.datasource.password=
-spring.datasource.password=${DB_PASSWORD}
+#spring.datasource.password=${DB_PASSWORD}
 spring.jpa.database-platform=org.hibernate.dialect.PostgreSQLDialect
 spring.jpa.hibernate.ddl-auto=update
 spring.jpa.show-sql=true

yugabyte-integration/target/classes/application.properties

@@ -1,9 +1,9 @@
 spring.application.name=yugabyte-integration
-spring.datasource.url=${DB_URL}
-#spring.datasource.url=jdbc:postgresql://127.0.0.1:5433/my_app
+#spring.datasource.url=${DB_URL}
+spring.datasource.url=jdbc:postgresql://127.0.0.1:5433/my_app
 spring.datasource.username=yugabyte
 #spring.datasource.password=
-spring.datasource.password=${DB_PASSWORD}
+#spring.datasource.password=${DB_PASSWORD}
 spring.jpa.database-platform=org.hibernate.dialect.PostgreSQLDialect
 spring.jpa.hibernate.ddl-auto=update
 spring.jpa.show-sql=true