package com.example.core.servlets;
import org.apache.sling.api.SlingHttpServletRequest;
import org.apache.sling.api.SlingHttpServletResponse;
import org.apache.sling.api.servlets.SlingAllMethodsServlet;
import org.apache.sling.api.servlets.ServletResolverConstants;
import org.json.JSONArray;
import org.json.JSONObject;
import org.osgi.service.component.annotations.Component;
import javax.servlet.Servlet;
import javax.servlet.ServletException;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
/**
* AEM Path-Based Servlet for User Notifications (Mock API for now).
*/
@component(
service = Servlet.class,
property = {
ServletResolverConstants.SLING_SERVLET_PATHS + "=/bin/user/notifications",
ServletResolverConstants.SLING_SERVLET_METHODS + "=GET",
ServletResolverConstants.SLING_SERVLET_METHODS + "=POST"
}
)
public class UserNotificationServlet extends SlingAllMethodsServlet {
private static final long serialVersionUID = 1L;
@Override
protected void doGet(SlingHttpServletRequest request, SlingHttpServletResponse response)
throws ServletException, IOException {
response.setContentType("application/json");
response.setCharacterEncoding("UTF-8");
// ===== MOCK RESPONSE =====
JSONArray notificationsArray = new JSONArray();
JSONObject notification1 = new JSONObject();
notification1.put("id", 101);
notification1.put("title", "New Feature Release");
notification1.put("message", "We have launched a new feature in the portal.");
notification1.put("date", "2025-04-03");
JSONObject notification2 = new JSONObject();
notification2.put("id", 102);
notification2.put("title", "System Maintenance");
notification2.put("message", "The system will undergo maintenance on Sunday.");
notification2.put("date", "2025-04-07");
notificationsArray.put(notification1);
notificationsArray.put(notification2);
response.getWriter().write(notificationsArray.toString(4)); // Pretty JSON Output
// ===== ACTUAL REST API CALL (Commented Out) =====
/*
try {
String apiUrl = "https://api.example.com/user/notifications"; // Replace with real API
String apiResponse = makeHttpRequest(apiUrl);
response.getWriter().write(apiResponse);
} catch (Exception e) {
response.getWriter().write("{\"error\": \"Failed to fetch notifications\"}");
}
*/
}
@Override
protected void doPost(SlingHttpServletRequest request, SlingHttpServletResponse response)
throws ServletException, IOException {
response.setContentType("application/json");
response.setCharacterEncoding("UTF-8");
// ===== MOCK RESPONSE =====
JSONObject responseObject = new JSONObject();
responseObject.put("status", "success");
responseObject.put("message", "Notification sent successfully");
responseObject.put("notificationId", 2001); // Simulated ID
response.getWriter().write(responseObject.toString(4)); // Pretty JSON Output
// ===== ACTUAL REST API CALL (Commented Out) =====
/*
try {
String apiUrl = "https://api.example.com/user/notifications"; // Replace with real API
String requestData = "{\"title\": \"New Alert\", \"message\": \"Check your dashboard.\"}"; // Sample JSON
String apiResponse = makeHttpPostRequest(apiUrl, requestData);
response.getWriter().write(apiResponse);
} catch (Exception e) {
response.getWriter().write("{\"error\": \"Failed to send notification\"}");
}
*/
}
/**
* Makes an HTTP GET request to a given URL.
*/
private String makeHttpRequest(String apiUrl) throws IOException {
StringBuilder result = new StringBuilder();
URL url = new URL(apiUrl);
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setRequestMethod("GET");
conn.setRequestProperty("Accept", "application/json");
try (BufferedReader reader = new BufferedReader(new InputStreamReader(conn.getInputStream()))) {
String line;
while ((line = reader.readLine()) != null) {
result.append(line);
}
}
conn.disconnect();
return result.toString();
}
/**
* Makes an HTTP POST request to a given URL with JSON payload.
*/
private String makeHttpPostRequest(String apiUrl, String jsonData) throws IOException {
URL url = new URL(apiUrl);
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setRequestMethod("POST");
conn.setRequestProperty("Content-Type", "application/json");
conn.setRequestProperty("Accept", "application/json");
conn.setDoOutput(true);
conn.getOutputStream().write(jsonData.getBytes());
StringBuilder result = new StringBuilder();
try (BufferedReader reader = new BufferedReader(new InputStreamReader(conn.getInputStream()))) {
String line;
while ((line = reader.readLine()) != null) {
result.append(line);
}
}
conn.disconnect();
return result.toString();
}
}
