org.eclipse.om2m.sdt/org.eclipse.om2m.sdt.home.applications/org.eclipse.om2m.sdt.home.monitoring/src/main/java/org/eclipse/om2m/sdt/home/monitoring/servlet/InCseContextServlet.java

/*******************************************************************************
 * Copyright (c) 2014, 2016 Orange.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License 2.0
 * which accompanies this distribution, and is available at
 * https://www.eclipse.org/legal/epl-2.0/
 *******************************************************************************/
package org.eclipse.om2m.sdt.home.monitoring.servlet;

import java.io.IOException;
import java.util.List;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.eclipse.om2m.commons.constants.Constants;
import org.eclipse.om2m.sdt.home.monitoring.util.AeRegistration;
import org.eclipse.om2m.sdt.home.monitoring.util.HttpSessionHelper;
import org.json.simple.JSONArray;
import org.json.simple.JSONObject;
import org.json.simple.parser.JSONParser;

public class InCseContextServlet extends HttpServlet {

	private static Log LOGGER = LogFactory.getLog(InCseContextServlet.class);
	
	private static final long serialVersionUID = 1L;
	private static final String RESOURCE_ID = "resourceId";
	private static final String GET_NOTIFICATIONS= "/notifications";

	public InCseContextServlet() {
	}

	@SuppressWarnings("unchecked")
	@Override
	protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
		HttpSessionHelper sessionHelper = new HttpSessionHelper(req.getSession());
		
//		String sessionId = req.getParameter(SessionManager.SESSION_ID_PARAMETER);
//		if (! SessionManager.getInstance().checkTokenExists(sessionId)) {
		if (!sessionHelper.getAuthenticatedUser()) {
			resp.sendError(HttpServletResponse.SC_FORBIDDEN);
			return;
		}
		
		String pathInfo = req.getPathInfo();
		if (pathInfo == null) {
			String cseId = Constants.CSE_ID;
			String cseName = Constants.CSE_NAME;
			resp.setStatus(HttpServletResponse.SC_OK);
			resp.getWriter().print("~/" + cseId + "/" + cseName);
		} else if (GET_NOTIFICATIONS.equals(pathInfo)) {
			// retrieve notifications
			String sessionId = req.getSession().getId();
			
			List<JSONObject> notifications = AeRegistration.getInstance().getNotificationsAndClears(sessionId);
			JSONArray globalJson = new JSONArray();
			for (JSONObject notification : notifications) {
				globalJson.add(notification);
			}
			if (! notifications.isEmpty())
				LOGGER.info("Get notifs: " + globalJson);
			resp.setHeader("Content-Type", "application/json");
			resp.getWriter().print(globalJson.toJSONString());
			resp.setStatus(HttpServletResponse.SC_OK);
		}
	}

	@Override
	protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
		try {
			JSONParser parser = new JSONParser();
			JSONObject jsonObject = (JSONObject) parser.parse(req.getReader());
			String resourceId = (String) jsonObject.get(RESOURCE_ID);
			String sessionId = req.getSession().getId();
			LOGGER.info("doPost(subscribeTo) " + resourceId);
			if (AeRegistration.getInstance().createSubscription(resourceId, sessionId)) {
				resp.setStatus(HttpServletResponse.SC_OK);
				return;
			}
			resp.sendError(HttpServletResponse.SC_NOT_ACCEPTABLE,
					"unable to create subscription");
		} catch (Exception e) {
			resp.sendError(HttpServletResponse.SC_NOT_ACCEPTABLE,
					"json payload is incorrect: valid format is {'resourceId':'url'}");
		}
	}

}