BAH 2962 | SMS functionality of appointment booking and reminder moved to backend

api/pom.xml

@@ -113,6 +113,10 @@
 			<artifactId>web-clients</artifactId>
 			<version>0.94.3</version>
 		</dependency>
+		<dependency>
+			<groupId>org.bahmni.module</groupId>
+			<artifactId>communication-api</artifactId>
+		</dependency>
 		<dependency>
 			<groupId>org.apache.httpcomponents</groupId>
 			<artifactId>httpclient</artifactId>

api/src/main/java/org/openmrs/module/appointments/constants/PrivilegeConstants.java

@@ -7,4 +7,5 @@ public class PrivilegeConstants {
     public static final String RESET_APPOINTMENT_STATUS = "Reset Appointment Status";
     public static final String MANAGE_APPOINTMENTS_SERVICE = "Manage Appointment Services";
     public static final String VIEW_APPOINTMENTS_SERVICE = "View Appointment Services";
+
 }

api/src/main/java/org/openmrs/module/appointments/events/AppointmentBookingEvent.java

@@ -0,0 +1,28 @@
+package org.openmrs.module.appointments.events;
+
+import org.openmrs.api.context.Context;
+import org.openmrs.module.appointments.model.Appointment;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+import java.util.UUID;
+
+@Component
+public class AppointmentBookingEvent extends AppointmentEvent {
+
+    private Appointment appointment;
+
+    public void createAppointmentEvent(AppointmentEventType eventType, Appointment appointment) {
+        this.eventType = eventType;
+        this.appointment = appointment;
+        this.eventId = UUID.randomUUID().toString();
+        this.payloadId = appointment.getUuid();
+        this.publishedDateTime = LocalDateTime.now();
+        this.userContext= Context.getUserContext();
+    }
+
+    public Appointment getAppointment() {
+        return appointment;
+    }
+}
+

api/src/main/java/org/openmrs/module/appointments/events/AppointmentEvent.java

@@ -0,0 +1,35 @@
+package org.openmrs.module.appointments.events;
+
+import org.openmrs.api.context.UserContext;
+import org.openmrs.module.appointments.events.AppointmentEventType;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+
+@Component
+public class AppointmentEvent {
+    private static final long version = 1L;
+    public UserContext userContext;
+    public String eventId;
+    public AppointmentEventType eventType;
+    public String payloadId;
+    public LocalDateTime publishedDateTime;
+
+    public UserContext getUserContext() {
+        return userContext;
+    }
+    public String getEventId() {
+        return eventId;
+    }
+    public AppointmentEventType getEventType() {
+        return eventType;
+    }
+    public String getPayloadId() {
+        return payloadId;
+    }
+    public LocalDateTime getPublishedDateTime() {
+        return publishedDateTime;
+    }
+}
+
+

api/src/main/java/org/openmrs/module/appointments/events/AppointmentEventType.java

@@ -0,0 +1,17 @@
+package org.openmrs.module.appointments.events;
+
+public enum AppointmentEventType {
+    BAHMNI_APPOINTMENT_CREATED("bahmni-appointment"),
+    BAHMNI_APPOINTMENT_UPDATED("bahmni-appointment"),
+    BAHMNI_RECURRING_APPOINTMENT_CREATED("bahmni-recurring-appointment"),
+    BAHMNI_RECURRING_APPOINTMENT_UPDATED("bahmni-recurring-appointment");
+
+    private final String topic;
+    AppointmentEventType(String topic) {
+        this.topic = topic;
+    }
+
+    public String topic() {
+        return topic;
+    }
+}

api/src/main/java/org/openmrs/module/appointments/events/RecurringAppointmentEvent.java

@@ -0,0 +1,27 @@
+package org.openmrs.module.appointments.events;
+import org.openmrs.api.context.Context;
+import org.openmrs.module.appointments.model.AppointmentRecurringPattern;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+import java.util.UUID;
+
+
+@Component
+public class RecurringAppointmentEvent extends AppointmentEvent {
+    private AppointmentRecurringPattern appointmentRecurringPattern;
+
+    public void createRecurringAppointmentEvent(AppointmentEventType eventType, AppointmentRecurringPattern appointmentRecurringPattern) {
+        this.eventType = eventType;
+        this.appointmentRecurringPattern = appointmentRecurringPattern;
+        this.eventId = UUID.randomUUID().toString();
+        this.payloadId = appointmentRecurringPattern.getAppointments().iterator().next().getUuid();
+        this.publishedDateTime = LocalDateTime.now();
+        this.userContext= Context.getUserContext();
+    }
+
+    public AppointmentRecurringPattern getAppointmentRecurringPattern() {
+        return appointmentRecurringPattern;
+    }
+}
+

api/src/main/java/org/openmrs/module/appointments/events/advice/AppointmentEventsAdvice.java

@@ -0,0 +1,60 @@
+package org.openmrs.module.appointments.events.advice;
+
+import com.google.common.collect.Sets;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.openmrs.api.context.Context;
+import org.openmrs.module.appointments.events.publisher.AppointmentEventPublisher;
+import org.openmrs.module.appointments.model.Appointment;
+import org.openmrs.module.appointments.events.AppointmentBookingEvent;
+import org.openmrs.module.appointments.events.AppointmentEventType;
+import org.springframework.aop.AfterReturningAdvice;
+import org.springframework.aop.MethodBeforeAdvice;
+
+import java.lang.reflect.Method;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Set;
+import java.util.function.Supplier;
+import static org.openmrs.module.appointments.events.AppointmentEventType.BAHMNI_APPOINTMENT_CREATED;
+import static org.openmrs.module.appointments.events.AppointmentEventType.BAHMNI_APPOINTMENT_UPDATED;
+
+public class AppointmentEventsAdvice implements AfterReturningAdvice, MethodBeforeAdvice {
+
+	private final Logger log = LogManager.getLogger(AppointmentEventsAdvice.class);
+	private final AppointmentEventPublisher eventPublisher;
+	private final ThreadLocal<Map<String,Integer>> threadLocal = new ThreadLocal<>();
+	private final String APPOINTMENT_ID_KEY = "appointmentId";
+	private final Set<String> adviceMethodNames = Sets.newHashSet("validateAndSave");
+	private final AppointmentBookingEvent appointmentEvent;
+
+	public AppointmentEventsAdvice() {
+		this.eventPublisher=Context.getRegisteredComponent("appointmentEventPublisher",AppointmentEventPublisher.class);
+		this.appointmentEvent = Context.getRegisteredComponent("appointmentBookingEvent", AppointmentBookingEvent.class);
+	}
+
+	@Override
+	public void afterReturning(Object returnValue, Method method, Object[] arguments, Object target) {
+		if (adviceMethodNames.contains(method.getName())) {
+			Map<String, Integer> patientInfo = threadLocal.get();
+			if (patientInfo != null) {
+				AppointmentEventType eventType = patientInfo.get(APPOINTMENT_ID_KEY) == null ? BAHMNI_APPOINTMENT_CREATED : BAHMNI_APPOINTMENT_UPDATED;
+				threadLocal.remove();
+
+				Appointment appointment = (Appointment) returnValue;
+				appointmentEvent.createAppointmentEvent(eventType, appointment);
+				eventPublisher.publishEvent(appointmentEvent);
+				log.info("Successfully published event with uuid : " + appointment.getUuid());
+			}
+		}
+	}
+	@Override
+	public void before(Method method, Object[] objects, Object o) {
+		if (adviceMethodNames.contains(method.getName())) {
+			Appointment appointment = ((Supplier<Appointment>) objects[0]).get();
+			Map<String, Integer> appointmentInfo = new HashMap<>(1);
+			appointmentInfo.put(APPOINTMENT_ID_KEY, appointment.getId());
+			threadLocal.set(appointmentInfo);
+		}
+	}
+}

api/src/main/java/org/openmrs/module/appointments/events/advice/RecurringAppointmentEventsAdvice.java

@@ -0,0 +1,60 @@
+package org.openmrs.module.appointments.events.advice;
+
+import com.google.common.collect.Sets;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.openmrs.api.context.Context;
+import org.openmrs.module.appointments.events.publisher.AppointmentEventPublisher;
+import org.openmrs.module.appointments.events.AppointmentEventType;
+import org.openmrs.module.appointments.model.AppointmentRecurringPattern;
+import org.openmrs.module.appointments.events.RecurringAppointmentEvent;
+import org.springframework.aop.AfterReturningAdvice;
+import org.springframework.aop.MethodBeforeAdvice;
+
+import java.lang.reflect.Method;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Set;
+
+import static org.openmrs.module.appointments.events.AppointmentEventType.BAHMNI_RECURRING_APPOINTMENT_CREATED;
+import static org.openmrs.module.appointments.events.AppointmentEventType.BAHMNI_RECURRING_APPOINTMENT_UPDATED;
+
+public class RecurringAppointmentEventsAdvice implements AfterReturningAdvice, MethodBeforeAdvice {
+
+    private final Logger log = LogManager.getLogger(RecurringAppointmentEventsAdvice.class);
+    private final AppointmentEventPublisher eventPublisher;
+    private final ThreadLocal<Map<String, Integer>> threadLocal = new ThreadLocal<>();
+    private final String RECURRING_APPOINTMENT_ID_KEY = "recurringAppointmentId";
+    private final Set<String> adviceMethodNames = Sets.newHashSet("validateAndSave");
+    private final RecurringAppointmentEvent recurringAppointmentEvent;
+
+    public RecurringAppointmentEventsAdvice() {
+        this.eventPublisher = Context.getRegisteredComponent("appointmentEventPublisher", AppointmentEventPublisher.class);
+        this.recurringAppointmentEvent = Context.getRegisteredComponent("recurringAppointmentEvent", RecurringAppointmentEvent.class);
+    }
+
+    @Override
+    public void afterReturning(Object returnValue, Method method, Object[] arguments, Object target) {
+        if (adviceMethodNames.contains(method.getName())) {
+            Map<String, Integer> appointmentInfo = threadLocal.get();
+            if (appointmentInfo != null) {
+                AppointmentEventType eventType = appointmentInfo.get(RECURRING_APPOINTMENT_ID_KEY) == null ? BAHMNI_RECURRING_APPOINTMENT_CREATED : BAHMNI_RECURRING_APPOINTMENT_UPDATED;
+                threadLocal.remove();
+                AppointmentRecurringPattern appointmentRecurringPattern = (AppointmentRecurringPattern) returnValue;
+                recurringAppointmentEvent.createRecurringAppointmentEvent(eventType, appointmentRecurringPattern);
+                eventPublisher.publishEvent(recurringAppointmentEvent);
+                log.info("Successfully published event with uuid : " + recurringAppointmentEvent.getPayloadId());
+            }
+        }
+    }
+
+    @Override
+    public void before(Method method, Object[] objects, Object o) {
+        if (adviceMethodNames.contains(method.getName())) {
+            AppointmentRecurringPattern appointmentRecurringPattern = (AppointmentRecurringPattern) objects[0];
+            Map<String, Integer> appointmentInfo = new HashMap<>(1);
+            appointmentInfo.put(RECURRING_APPOINTMENT_ID_KEY, appointmentRecurringPattern.getId());
+            threadLocal.set(appointmentInfo);
+        }
+    }
+}