Subversion Repositories SmartDukaan

package in.shop2020.serving.interceptors;

import in.shop2020.serving.services.UserSessionInfo;
import in.shop2020.serving.utils.Utils;

import java.util.HashMap;
import java.util.Map;

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

import org.apache.commons.codec.binary.Base64;
import org.apache.log4j.Logger;
import org.apache.struts2.ServletActionContext;
import org.json.JSONObject;

import com.opensymphony.xwork2.ActionInvocation;
import com.opensymphony.xwork2.interceptor.AbstractInterceptor;

import de.ailis.pherialize.Pherialize;

public class LoginInterceptor extends AbstractInterceptor {


        /**
         * 
         */
        private static final long serialVersionUID = 1L;
        private static Logger log = Logger.getLogger(Class.class);
        
        @Override
        public String intercept(ActionInvocation invocation) throws Exception {
                HttpServletRequest request = ServletActionContext.getRequest();
                HttpServletResponse response = ServletActionContext.getResponse();
        
        UserSessionInfo userInfo = (UserSessionInfo) request.getAttribute(UserInterceptor.USER_INFO_COOKIE_NAME);
        if(userInfo.isPrivateDealUser()){
                response.sendRedirect(getMobileRedirectUrl(String.valueOf(userInfo.getUserId()), request));
                        return null;
        }
        if(userInfo == null || !userInfo.isLoggedIn()){
                response.sendRedirect("/login?redirectUrl=" + getRedirectUrl(request));
                return null;
        }
                return invocation.invoke();
        }
        
        String getMobileRedirectUrl(String userId, HttpServletRequest request){
                UserSessionInfo userInfo = (UserSessionInfo) request.getAttribute(UserInterceptor.USER_INFO_COOKIE_NAME);
                String next = "cart";
                log.info("next " + next);
                String serverName = request.getServerName().replaceFirst("www", "m");
        try {
                String authUrl = "http://localhost:8080/mobileapi/login!authorizeProfitMandiUser?userId=" + 
                                                        String.valueOf(userInfo.getUserId()) + "&source=Saholic";
                        String urlResponse = Utils.fetchUrl(authUrl);
                        JSONObject responseToken = new JSONObject(urlResponse);
                        String token = responseToken.getString("tokenString");
                        log.info("token " +token);
                        
                        
                        Map<String, Object> mapData = new HashMap<String, Object>();
                        mapData.put("next", next);
                        mapData.put("Id", userId);
                        mapData.put("cartId", userInfo.getCartId());
                        mapData.put("email", userInfo.getEmail());
                        mapData.put("isPrivateDealUser", userInfo.isPrivateDealUser());
                        String data = Base64.encodeBase64String(Pherialize.serialize(mapData).getBytes());
                        
                        String url = "http://" + serverName + "/autologin/?data=" + data + "&token=" + token + "&v=2";
                        log.info("url " + url);
                        return url;
        } catch (Exception e) {
                log.info("Could not parse", e);
                log.info(next);
                        return "http://" + serverName + "/" + next;
                }
        }
        
        public String getRedirectUrl(HttpServletRequest request) {
                String queryString = request.getQueryString();
                if (queryString == null) {
                        queryString = "";
                } else {
                        queryString = "?" + queryString;
                }
                log.info("Redirect Url : " + request.getRequestURI() + queryString);
                return request.getRequestURI() + queryString;
        }
}