common_imports.jsp

Sun公司Dream项目

    <%@ page errorPage="Error.jsp" %>
    <%@ page import="javax.ejb.*, javax.naming.*, javax.rmi.PortableRemoteObject, java.rmi.RemoteException" %>
    <%@ page import="com.sun.sjc.idtv.vod.server.subscriber.*" %>
    <%@ page import="com.sun.sjc.idtv.vod.server.mediacatalog.*" %>
    <%@ page import="com.sun.sjc.idtv.vod.server.billing.*" %>
    <%@ page import="com.sun.sjc.idtv.vod.server.auditing.*" %>
    <%@ page import="com.sun.sjc.idtv.vod.shared.data.*" %>
    <%@ page import="com.sun.sjc.idtv.vod.server.rtspsession.*" %>
    <%@ page import="com.sun.dream.*" %>
    <%@ page import="com.sun.dream.shop.SessionCache" %>
    <%@ page import="java.util.*" %>

    <%!
    SubscriberManagementSystem sms;
    MediaCatalog mediacat;
    BillingEngine billing;
    AuditLog auditer;
    Subscriber me;
    RTSPStoredSessionEngine rsse;
    AuthPlugin authPlugin;
    Class authPluginClass;
    SessionCache sessioncache;
    
    public void jspInit() {
        
        sms = (SubscriberManagementSystem)getServletContext().getAttribute("sms");
        if (sms == null) {
            try {
                InitialContext ic = new InitialContext();
                Object objRef = ic.lookup("java:comp/env/ejb/SubscriberManagementSystem");
                sms = (SubscriberManagementSystem) ((SubscriberManagementSystemHome)PortableRemoteObject.narrow(objRef, SubscriberManagementSystemHome.class)).create();
                getServletContext().setAttribute("sms", sms);
            } catch (Exception ex) {
                System.out.println("Unable to create: "+ "java:comp/env/ejb/SubscriberManagementSystem. "+ ex.getMessage());
            }
        }
        
        mediacat = (MediaCatalog)getServletContext().getAttribute("mediacat");
        if (mediacat == null) {
            try {
                InitialContext ic = new InitialContext();
                Object objRef = ic.lookup("java:comp/env/ejb/MediaCatalog");
                mediacat = (MediaCatalog) ((MediaCatalogHome)PortableRemoteObject.narrow(objRef, MediaCatalogHome.class)).create();
                getServletContext().setAttribute("mediacat", mediacat);
            } catch (Exception ex) {
                System.out.println("Unable to create: "+ "java:comp/env/ejb/MediaCatalog. "+ ex.getMessage());
            }
        }
        
        billing = (BillingEngine)getServletContext().getAttribute("billing");
        if (billing == null) {
            try {
                InitialContext ic = new InitialContext();
                Object objRef = ic.lookup("java:comp/env/ejb/BillingEngine");
                billing = (BillingEngine) ((BillingEngineHome)PortableRemoteObject.narrow(objRef, BillingEngineHome.class)).create();
                getServletContext().setAttribute("billing", billing);
            } catch (Exception ex) {
                System.out.println("Unable to create: "+ "java:comp/env/ejb/BillingEngine. "+ ex.getMessage());
            }
        }
        
        rsse = (RTSPStoredSessionEngine)getServletContext().getAttribute("rsse");
        if (rsse == null) {
            try {
                InitialContext ic = new InitialContext();
                Object objRef = ic.lookup("java:comp/env/ejb/RTSPStoredSessionEngine");
                rsse = (RTSPStoredSessionEngine)((RTSPStoredSessionEngineHome)PortableRemoteObject.narrow(objRef, RTSPStoredSessionEngineHome.class)).create();
                getServletContext().setAttribute("rsse", rsse);
            } catch (Exception ex) {
                System.out.println("Unable to create: " + "java:comp/env/ejb/RTSPStoredSessionEngine. "+ex.getMessage());
            }
        }
        
        
        sessioncache = (SessionCache)getServletContext().getAttribute("sessioncache");
        if (sessioncache == null) {
            try {
                sessioncache = new SessionCache();
                getServletContext().setAttribute("sessioncache",sessioncache);
            } catch (Exception ex) {
                System.out.println("Unable to create: SessionCache "+ex.getMessage());
            }
        }
        
        authPluginClass = (Class) getServletContext().getAttribute("authPluginClass");
        try {
            if (authPluginClass == null) {
                /*java.util.Enumeration initParams = getServletContext().getInitParameterNames();
                System.out.println("initParams for "+getServletConfig().getServletName());
                while (initParams.hasMoreElements()) {
                    String recent = (String) initParams.nextElement();
                    System.out.println(recent);
                }*/
                String authPluginClassName = getServletContext().getInitParameter("AuthPluginClassName");
                if (authPluginClassName == null) {
                    authPluginClassName = "com.sun.dream.SimpleAuthPlugin";
                }
                authPluginClass = Class.forName(authPluginClassName);
                Class authPluginInterface = Class.forName("com.sun.dream.AuthPlugin");
                if (authPluginInterface.isAssignableFrom(authPluginClass)) {
                    getServletContext().setAttribute("authPluginClass", authPluginClass);
                } else {
                    authPluginClass = null;
                    System.err.println("authPluginClass is not valid instance of com.sun.dream.AuthPlugin");
                }
            }
            if (authPluginClass != null)
                authPlugin = (AuthPlugin) authPluginClass.newInstance();
        } catch (Exception ex) {
            authPluginClass = null;
            System.err.println("authPluginClass could not be found");
            ex.printStackTrace();
        }
    }
    
    public void jspDestroy() {
        sms = null;
        mediacat = null;
    }
    %>

            <%
            String sessionId = null;
            String userid = null;
            
            String servletPath = request.getServletPath();
            if (servletPath == null)
                servletPath = "Default Path";
            authPlugin.setLoginPage("/login.jsp");
            System.out.println("About to call authenticateuser from: "+servletPath);
            if (authPlugin.authenticateUser(request, response)) {
                userid = authPlugin.getUserId();
                sessionId = authPlugin.getSessionId();
                if (userid != null)
                    System.out.println("userID is: "+ userid);
                if (sessionId != null)
                    System.out.println("sessionId is: "+ sessionId);
                sessioncache.setAttribute(sessionId, "userid", userid);
            } else
                System.err.println("ERROR: User has not authenticated");

            //TODO: Include functionality to determine the correct ipAddress of the Set-top-box
            String ipAddress = "127.0.0.1";

            Subscriber me = sms.getSubscriber(userid,ipAddress);
            if (me == null)
                System.out.println("subscriber is NULL");
        %>