chore: inject and fire PaymentSuccessEvent and PaymentErrorEvent in PaymentProvider

Author: otaviojava

src/main/java/com/acme/payment/provider/PaymentProvider.java

@@ -1,8 +1,12 @@
 package com.acme.payment.provider;
 
+import com.acme.payment.PaymentErrorEvent;
 import com.acme.payment.PaymentRequestedEvent;
+import com.acme.payment.PaymentSuccessEvent;
 import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.enterprise.event.Event;
 import jakarta.enterprise.event.ObservesAsync;
+import jakarta.inject.Inject;
 
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.logging.Logger;
@@ -14,7 +18,20 @@ class PaymentProvider {
 
     private final AtomicLong counter = new AtomicLong();
 
-    private
+    private final Event<PaymentSuccessEvent> successEvent;
+
+    private final Event<PaymentErrorEvent> errorEvent;
+
+    @Inject
+    PaymentProvider(Event<PaymentSuccessEvent> successEvent, Event<PaymentErrorEvent> errorEvent) {
+        this.successEvent = successEvent;
+        this.errorEvent = errorEvent;
+    }
+
+    PaymentProvider() {
+        this.successEvent = null;
+        this.errorEvent = null;
+    }
 
     void receivePayment(@ObservesAsync PaymentRequestedEvent event) {
         LOGGER.info("Processing payment: " + event.payment());
@@ -25,9 +42,11 @@ void receivePayment(@ObservesAsync PaymentRequestedEvent event) {
         }
         if(counter.getAndDecrement() % 2 == 0) {
             LOGGER.warning("Payment failed: " + event.payment());
+            successEvent.fire(new PaymentSuccessEvent(event.payment()));
 
         } else {
             LOGGER.info("Payment successful: " + event.payment());
+            errorEvent.fire(new PaymentErrorEvent(event.payment()));
         }
         LOGGER.info("Payment processed: " + event.payment() + " - Confirmation #" + counter.incrementAndGet());
     }