package com.gigaspaces.examples.web;

import com.gigaspaces.client.WriteModifiers;
import com.gigaspaces.examples.data.UserData;
import com.j_spaces.core.IJSpace;
import com.j_spaces.core.client.UpdateModifiers;

import net.jini.core.lease.Lease;

import org.openspaces.core.GigaSpace;
import org.openspaces.core.GigaSpaceConfigurer;
import org.openspaces.core.space.SpaceProxyConfigurer;
import org.springframework.context.ApplicationContext;
import org.springframework.web.context.support.WebApplicationContextUtils;

import java.io.IOException;
import java.util.Enumeration;

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

/**
 * A servlet which updates the space with the content of the request parameters and forwards to the
 * SpaceContents.jsp which displays the contents of the space Getting the space reference is the
 * responsibility of subclasses
 *
 * @author Uri Cohen
 */

public class AccessSpaceServlet extends HttpServlet {
    
    private static final long serialVersionUID = 1L;
    
    protected GigaSpace gigaSpace;
    
    /**
     * Initialize the servlet by creating a space reference using the OpenSpaces API
     */
    @Override
    public void init() throws ServletException {
        System.out.println( ">>>init--"  );
        initGigaSpaces();
        if (gigaSpace == null) {
            throw new IllegalStateException("gigaSpace cannot be null");
        }
    }
    
    /**
     * Creates a reference to the remote space. Make sure you start a data grid with the name
     * "mySpace" before this code is called
     */
    protected void initGigaSpaces() {
        IJSpace space = new SpaceProxyConfigurer("mySpace").lookupTimeout(20000).space();
        gigaSpace = new GigaSpaceConfigurer(space).gigaSpace();

		/*
         * you can uncomment the below line and comment the two above if the application is deployed to the
		 * GigaSpaces environment and the space is defined inside the META-INF/pu.xml file.
		 * In such case the GigaSpaces environment automatically inserts it to the ServletContext of the application
		 */
        Object jettyPortProperty = getServletContext().getAttribute("jetty.port.actual");
        System.out.println( ">>>jettyPortProperty=" + jettyPortProperty );
        
        Enumeration<String> attributeNames = getServletContext().getAttributeNames();
        while(attributeNames.hasMoreElements() ) {
            System.out.println("AttributeName=" +attributeNames.nextElement());
        }
        
        //gigaSpace = (GigaSpace) getServletContext().getAttribute("gigaSpace");
    }
    
    /**
     * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
     */
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        doPost(request, response);
    }
    
    /**
     * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
     */
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        
        Object beanLevelProperties = getServletContext().getAttribute("beanLevelProperties");
        System.out.println( ">>>, do Post, beanLevelProperties=" + beanLevelProperties );
        
        System.out.println("******* Got Request *******");
        
        Object jettySelectChannelConnectorPort = getServletContext().getAttribute("jetty.SelectChannelConnector.port.actual");
        Object jettySelectChannelConnectorPortA = getServletContext().getAttribute("jetty.SslSelectChannelConnector_A.port.actual");
        Object jettySelectChannelConnectorPortB = getServletContext().getAttribute("jetty.SslSelectChannelConnector_B.port.actual");
        System.out.println( ">>>jettySelectChannelConnector=" + jettySelectChannelConnectorPort + " not yet implemented");
        System.out.println( ">>>jettySelectChannelConnectorPortA=" + jettySelectChannelConnectorPortA + " not yet implemented");
        System.out.println( ">>>jettySelectChannelConnectorPortB=" + jettySelectChannelConnectorPortB + " not yet implemented");
        
        String userId = request.getSession().getId();
        String dataName = request.getParameter("dataname");
        String dataValue = request.getParameter("datavalue");
        if (isStringNotEmpty(dataName) && isStringNotEmpty(dataValue)) {
            gigaSpace.write(new UserData(dataName, dataValue, userId), Lease.FOREVER, 30000, WriteModifiers.UPDATE_OR_WRITE);
        }
        UserData[] spaceEntries = gigaSpace.readMultiple(new UserData());
        request.setAttribute("spaceEntries", spaceEntries);
        request.getRequestDispatcher("SpaceContents.jsp").forward(request, response);
    }
    
    private boolean isStringNotEmpty(String str) {
        return (str != null && str.trim().length() > 0);
    }
}