hostsbean.java

openacs source for CPE wan management

package org.openacs;

import java.net.URL;
import java.net.URLConnection;
import java.sql.Timestamp;
import javax.ejb.*;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.UsernamePasswordCredentials;
import org.apache.commons.httpclient.auth.AuthScope;
import org.apache.commons.httpclient.methods.GetMethod;

/**
 * This is the bean class for the HostsBean enterprise bean.
 * Created 2007.10.16 18.27.50
 * @author Administrator
 */
public abstract class HostsBean implements EntityBean, HostsLocalBusiness {
    private EntityContext context;
    
    // <editor-fold defaultstate="collapsed" desc="EJB infrastructure methods. Click on the + sign on the left to edit the code.">
    // TODO Consider creating Transfer Object to encapsulate data
    // TODO Review finder methods
    /**
     * @see javax.ejb.EntityBean#setEntityContext(javax.ejb.EntityContext)
     */
    public void setEntityContext(EntityContext aContext) {
        context = aContext;
    }
    
    /**
     * @see javax.ejb.EntityBean#ejbActivate()
     */
    public void ejbActivate() {
        
    }
    
    /**
     * @see javax.ejb.EntityBean#ejbPassivate()
     */
    public void ejbPassivate() {
        
    }
    
    /**
     * @see javax.ejb.EntityBean#ejbRemove()
     */
    public void ejbRemove() {
        
    }
    
    /**
     * @see javax.ejb.EntityBean#unsetEntityContext()
     */
    public void unsetEntityContext() {
        context = null;
    }
    
    /**
     * @see javax.ejb.EntityBean#ejbLoad()
     */
    public void ejbLoad() {
        
    }
    
    /**
     * @see javax.ejb.EntityBean#ejbStore()
     */
    public void ejbStore() {
        
    }
    // </editor-fold>
    
    
    public abstract String getSerialno();
    public abstract void setSerialno(String serialno);
    
    public abstract String getUrl();
    public abstract void setUrl(String url);

    public abstract String getConfigname();

    public abstract void setConfigname(String configname);

    public abstract String getCurrentsoftware();

    public abstract void setCurrentsoftware(String currentsoftware);

    public abstract Timestamp getSfwupdtime();

    public abstract void setSfwupdtime(Timestamp sfwupdtime);

    public abstract String getSfwupdres();

    public abstract void setSfwupdres(String sfwupdres);

    public abstract String getCfgupdres();

    public abstract void setCfgupdres(String cfgupdres);

    public abstract Timestamp getLastcontact();

    public abstract void setLastcontact(Timestamp lastcontact);

    public abstract Timestamp getCfgupdtime();

    public abstract void setCfgupdtime(Timestamp cfgupdtime);

    public abstract java.lang.String getHardware();

    public abstract void setHardware(java.lang.String hardware);

    public abstract java.lang.String getCfgversion();

    public abstract void setCfgversion(java.lang.String cfgversion);
    
    public abstract Object getId ();
    public abstract void setId (Object id);
    
    public java.lang.Object ejbCreate(Integer hwid, String serialno, String url)  throws CreateException {
        /*
        if (oui == null) {
            throw new CreateException("The field \"oui\" must not be null");
        }
        if (serialno == null) {
            throw new CreateException("The field \"serialno\" must not be null");
        }
        if (url == null) {
            throw new CreateException("The field \"url\" must not be null");
        }
        */
        // TODO add additional validation code, throw CreateException if data is not valid
        setHwid(hwid);
        setSerialno(serialno);
        setUrl(url);
        
        Timestamp never = new Timestamp (24*3600*1000);
        setCfgupdtime(never);
        setSfwupdtime(never);
        setLastcontact(never);
        return null;
    }
    
    public void ejbPostCreate(Integer hwid, String serialno, String url) {
        // TODO populate relationships here if appropriate
        
    }

    public abstract byte [] getProps();

    public abstract void setProps(byte [] props);

    public abstract Integer getHwid();

    public abstract void setHwid(Integer hwid);

    public abstract String getUsername();

    public abstract void setUsername(String username);

    public abstract String getPassword();

    public abstract void setPassword(String password);

    public abstract Integer getAuthtype();

    public abstract void setAuthtype(Integer authtype);
    
    public abstract HardwareModelLocal getModel ();
    public abstract void setModel (HardwareModelLocal m);

    public abstract String getCustomerid();

    public abstract void setCustomerid(String customerid);

    public abstract String getConrequser();

    public abstract void setConrequser(String conrequser);

    public abstract String getConreqpass();

    public abstract void setConreqpass(String conerqpass);

    /*
    public void RequestConnection (int timeout) throws Exception {
        String url = getUrl();
        String user = getConrequser();
        String pass = getConreqpass();
        
        if (user != null && pass != null) {
            url = url.substring(0, 7) + user +":" + pass + "@" + url.substring(7);
        }

        try {
//                URL url = new URL((user!=null && pass != null) ? cpeurl);
            URL u = new URL(url);
            URLConnection httpconn = u.openConnection();
            httpconn.setReadTimeout(timeout);
            httpconn.setConnectTimeout(timeout);
            httpconn.setUseCaches(false);
            httpconn.getContent();
        } catch (Exception ex) {
            if (!ex.getMessage().equals("no content-type")) throw ex;
            return;
        }
    }
    */
    public void RequestConnection (int timeout) throws Exception {
        String url = getUrl();
        String user = getConrequser();
        String pass = getConreqpass();
        
        HttpClient client = new HttpClient();
        if (user != null && pass != null) {
            client.getState().setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(user, pass));
        }
        GetMethod get = new GetMethod (url);
        get.setDoAuthentication(true);

        try {
            int status = client.executeMethod(get);
            if (status != 200) {
                System.out.println(status + "\n" + get.getResponseBodyAsString());
                throw new Exception ("Failed: status="+status);
            }
        } catch (Exception e) {
            throw e;
        } finally {
            get.releaseConnection();
        }
    }
}