Metacat

/**

 *  '$RCSfile$'

 *

 *   '$Author: Serhan AKIN $'

 *     '$Date: 2009-06-13 15:28:13 +0300  $'

 *

 * This program is free software; you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation; either version 2 of the License, or

 * (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

 */

package edu.ucsb.nceas.metacat.restservice;

import java.io.InputStream;

import java.io.OutputStream;

import java.io.PrintWriter;

import java.util.Enumeration;

import java.util.Hashtable;

import java.util.List;

import java.util.Map;

import javax.servlet.ServletContext;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import org.dataone.mimemultipart.MultipartRequestResolver;

import org.dataone.service.exceptions.ServiceFailure;

import org.dataone.service.types.v1.ReplicationPolicy;

import org.dataone.service.types.v1.SystemMetadata;

import edu.ucsb.nceas.metacat.MetacatHandler;

 *

    /**HTTP Verb GET*/

    public static final byte GET = 1;

    /**HTTP Verb POST*/

    public static final byte POST = 2;

    /**HTTP Verb PUT*/

    public static final byte PUT = 3;

    /**HTTP Verb DELETE*/

    public static final byte DELETE = 4;

    public static final byte HEAD = 5;

    /*

     * API Resources

     */

    protected static final String RESOURCE_META = "meta";

    protected static final String RESOURCE_LOG = "log";

    protected static final String RESOURCE_CHECKSUM = "checksum";

    protected static final String RESOURCE_IS_AUTHORIZED = "isAuthorized";

    protected static final String RESOURCE_ACCESS_RULES = "accessRules";

     * API Functions used as URL parameters

     */

    protected static final String FUNCTION_NAME_UPDATE = "update";

    protected Logger logMetacat;

    protected MetacatHandler handler;

    protected HttpServletRequest request;

    protected HttpServletResponse response;

    // D1 certificate-based authentication

    /**Initializes new instance by setting servlet context,request and response*/

        this.servletContext = servletContext;

        this.request = request;

        this.response = response;

    }

    /**

     * @param httpVerb (GET, POST, PUT or DELETE)

     */

    public void handle(byte httpVerb) {

            session = CertificateManager.getInstance().getSession(request);

            params = new Hashtable<String, String[]>();

            initParams();

            Timer timer = new Timer();

            handler = new MetacatHandler(timer);

        } catch (Exception e) {

        	response.setStatus(400);

            printError("Incorrect resource!", response);

            logMetacat.error(e.getClass() + ": " + e.getMessage(), e);

    }

    	// get the rest

        String extra = null;

        if (resource.indexOf(token) != -1) {

        	// what comes after the token?

            extra = resource.substring(resource.indexOf(token) + token.length());

            // remove the slash

            if (extra.startsWith("/")) {

            	extra = extra.substring(1);

            }

            // is there anything left?

            if (extra.length() == 0) {

            	extra = null;

            }

        }

        return extra;

    }

    /**

     *

     * @return failure  the BaseException failure, one of it's subclasses, or null

     * @throws ServiceFailure

     * @throws InvalidRequest

     * @throws JiBXException

     * @throws IllegalAccessException

     * @throws InstantiationException

     * @throws IOException

     */

    protected BaseException collectReplicationStatus()

        throws ServiceFailure, InvalidRequest, IOException,

        InstantiationException, IllegalAccessException, JiBXException {

        BaseException failure = null;

        File tmpDir = getTempDirectory();

        MultipartRequest mr = null;

        Map<String, File> mmFileParts = null;

        File exceptionFile = null;

        InputStream exceptionFileStream = null;

        // Read the incoming data from its Mime Multipart encoding

        logMetacat.debug("Parsing BaseException from the mime multipart entity");

        // handle MMP inputs

        MultipartRequestResolver mrr =

            new MultipartRequestResolver(tmpDir.getAbsolutePath(),1000000000, 0);

        try {

            mr = mrr.resolveMultipart(request);

            logMetacat.debug("Resolved the replication status BaseException multipart request.");

        } catch (IOException e) {

            throw new ServiceFailure("4700", "Couldn't resolve the multipart request: " +

                e.getMessage());

        } catch (FileUploadException e) {

            throw new ServiceFailure("4700", "Couldn't resolve the multipart request: " +

                e.getMessage());

        } catch (Exception e) {

            throw new ServiceFailure("4700", "Couldn't resolve the multipart request: " +

                e.getMessage());

        }

        // get the map of file parts

        mmFileParts = mr.getMultipartFiles();

        if ( mmFileParts == null || mmFileParts.keySet() == null) {

            logMetacat.debug("BaseException for setReplicationStatus is null");

        }

        multipartparams = mr.getMultipartParameters();

        exceptionFile = mmFileParts.get("failure");

        if ( exceptionFile != null ) {

                failure = ExceptionHandler.deserializeXml(exceptionFileStream,

                    "Replication failed for an unknown reason.");

                throw new ServiceFailure("4700", "Couldn't parse the replication failure exception: " +

                        e.getMessage());

            } catch (SAXException e) {

                throw new ServiceFailure("4700", "Couldn't traverse the replication failure exception: " +

                        e.getMessage());

            }

        return failure;

    }

    /**

     *

     * @return policy  the encoded policy

     * @throws ServiceFailure

     * @throws InvalidRequest

     * @throws IOException

     * @throws InstantiationException

     * @throws IllegalAccessException

     * @throws JiBXException

     */

    protected ReplicationPolicy collectReplicationPolicy()

        throws ServiceFailure, InvalidRequest, IOException, InstantiationException,

        IllegalAccessException, JiBXException {

        ReplicationPolicy policy = null;

        File tmpDir = getTempDirectory();

        MultipartRequest mr = null;

        Map<String, File> mmFileParts = null;

        File replPolicyFile = null;

        InputStream replPolicyStream = null;

        // Read the incoming data from its Mime Multipart encoding

        logMetacat.debug("Parsing ReplicationPolicy from the mime multipart entity");

        // handle MMP inputs

        MultipartRequestResolver mrr =

            new MultipartRequestResolver(tmpDir.getAbsolutePath(),1000000000, 0);

        try {

            mr = mrr.resolveMultipart(request);

            logMetacat.debug("Resolved the ReplicationPolicy multipart request.");

        } catch (IOException e) {

            throw new ServiceFailure("4882", "Couldn't resolve the multipart request: " +

                e.getMessage());

        } catch (FileUploadException e) {

            throw new ServiceFailure("4882", "Couldn't resolve the multipart request: " +

        } catch (Exception e) {

            throw new ServiceFailure("4882", "Couldn't resolve the multipart request: " +

        }

        // get the map of file parts

        mmFileParts = mr.getMultipartFiles();

        if ( mmFileParts == null || mmFileParts.keySet() == null) {

            throw new InvalidRequest("4883", "The multipart request must include " +

                "a file with the name 'policy'.");

        }

        multipartparams = mr.getMultipartParameters();

        replPolicyFile = mmFileParts.get("policy");

        if ( replPolicyFile == null ) {

            throw new InvalidRequest("4883", "The multipart request must include " +

            "a file with the name 'policy'.");

        }

        // deserialize the ReplicationPolicy

        replPolicyStream = new FileInputStream(replPolicyFile);

        policy = TypeMarshaller.unmarshalTypeFromStream(ReplicationPolicy.class, replPolicyStream);

        return policy;

    }

    /**

     * Parse the replica metadata document out of the mime-multipart form data

     *

     * @return replica  the encoded replica

     * @throws ServiceFailure

     * @throws InvalidRequest

     * @throws IOException

     * @throws InstantiationException

     * @throws IllegalAccessException

     * @throws JiBXException

     */

    protected Replica collectReplicaMetadata()

        throws ServiceFailure, InvalidRequest {

        Replica replica = null;

        File tmpDir = getTempDirectory();

        MultipartRequest mr = null;

        Map<String, File> mmFileParts = null;

        File replicaFile = null;

        InputStream replicaStream = null;

        // Read the incoming data from its Mime Multipart encoding

        logMetacat.debug("Parsing Replica from the mime multipart entity");

        // handle MMP inputs

        MultipartRequestResolver mrr =

            new MultipartRequestResolver(tmpDir.getAbsolutePath(),1000000000, 0);

        try {

            mr = mrr.resolveMultipart(request);

            logMetacat.debug("Resolved the Replica multipart request.");

        } catch (IOException e) {

            throw new ServiceFailure("4852", "Couldn't resolve the multipart request: " +

                e.getMessage());

        } catch (FileUploadException e) {

            throw new ServiceFailure("4852", "Couldn't resolve the multipart request: " +

                    e.getMessage());

        } catch (Exception e) {

            throw new ServiceFailure("4852", "Couldn't resolve the multipart request: " +

                    e.getMessage());

        }

        // get the map of file parts

        mmFileParts = mr.getMultipartFiles();

        if ( mmFileParts == null || mmFileParts.keySet() == null) {

            throw new InvalidRequest("4853", "The multipart request must include " +

                "a file with the name 'replicaMetadata'.");

        }

        multipartparams = mr.getMultipartParameters();

        replicaFile = mmFileParts.get("replicaMetadata");

        if ( replicaFile == null ) {

            throw new InvalidRequest("4853", "The multipart request must include " +

            "a file with the name 'replicaMetadata'.");

        }

        // deserialize the ReplicationPolicy

        try {

            replicaStream = new FileInputStream(replicaFile);

        } catch (FileNotFoundException e) {

            throw new ServiceFailure("4852", "Couldn't find the multipart file: " +

                    e.getMessage());

        }

        try {

            replica = TypeMarshaller.unmarshalTypeFromStream(Replica.class, replicaStream);

        } catch (IOException e) {

            throw new ServiceFailure("4852", "Couldn't deserialize the replica document: " +

                    e.getMessage());

        } catch (InstantiationException e) {

            throw new ServiceFailure("4852", "Couldn't deserialize the replica document: " +

                    e.getMessage());

        } catch (IllegalAccessException e) {

            throw new ServiceFailure("4852", "Couldn't deserialize the replica document: " +

                    e.getMessage());

        } catch (JiBXException e) {

            throw new ServiceFailure("4852", "Couldn't deserialize the replica document: " +

                    e.getMessage());

        }

        return replica;

    }

        throws IOException, ServiceFailure, InvalidRequest, JiBXException,

        InstantiationException, IllegalAccessException, ParserConfigurationException,

        SAXException  {

		// Read the incoming data from its Mime Multipart encoding

		logMetacat.debug("Disassembling MIME multipart form");

		InputStream ap = null;

		// handle MMP inputs

		File tmpDir = getTempDirectory();

		logMetacat.debug("temp dir: " + tmpDir.getAbsolutePath());

		MultipartRequestResolver mrr =

			new MultipartRequestResolver(tmpDir.getAbsolutePath(), 1000000000, 0);

		MultipartRequest mr = null;

		try {

			mr = mrr.resolveMultipart(request);

		} catch (Exception e) {

			throw new ServiceFailure("2161",

					"Could not resolve multipart: " + e.getMessage());

		}

		logMetacat.debug("resolved multipart request");

		Map<String, File> files = mr.getMultipartFiles();

		if (files == null || files.keySet() == null) {

			throw new InvalidRequest("2163",

					"must have multipart file with name 'accessPolicy'");

		}

		logMetacat.debug("got multipart files");

		multipartparams = mr.getMultipartParameters();

		File apFile = files.get("accessPolicy");

		if (apFile == null) {

			throw new InvalidRequest("2163",

					"Missing the required file-part 'accessPolicy' from the multipart request.");

		}

		logMetacat.debug("apFile: " + apFile.getAbsolutePath());

		ap = new FileInputStream(apFile);

		AccessPolicy accessPolicy = TypeMarshaller.unmarshalTypeFromStream(AccessPolicy.class, ap);

		return accessPolicy;

	}

        throws IOException, FileUploadException, ServiceFailure, InvalidRequest,

        JiBXException, InstantiationException, IllegalAccessException  {

		// Read the incoming data from its Mime Multipart encoding

		logMetacat.debug("Disassembling MIME multipart form");

		InputStream sysmeta = null;

		// handle MMP inputs

		File tmpDir = getTempDirectory();

		logMetacat.debug("temp dir: " + tmpDir.getAbsolutePath());

		MultipartRequestResolver mrr =

			new MultipartRequestResolver(tmpDir.getAbsolutePath(), 1000000000, 0);

		MultipartRequest mr = null;

		try {

			mr = mrr.resolveMultipart(request);

		} catch (Exception e) {

			throw new ServiceFailure("1202",

					"Could not resolve multipart: " + e.getMessage());

		}

		logMetacat.debug("resolved multipart request");

		Map<String, File> files = mr.getMultipartFiles();

		if (files == null) {

			throw new ServiceFailure("1202",

					"register meta must have multipart file with name 'sysmeta'");

		}

		logMetacat.debug("got multipart files");

		if (files.keySet() == null) {

			logMetacat.error("No file keys in MMP request.");

			throw new ServiceFailure(

					"1202",

					"No file keys found in MMP.  "

							+ "register meta must have multipart file with name 'sysmeta'");

		}

		// for logging purposes, dump out the key-value pairs that

		// constitute the request

		// 3 types exist: request params, multipart params, and

		// multipart files

		Iterator it = files.keySet().iterator();

		logMetacat.debug("iterating through request parts: " + it);

		while (it.hasNext()) {

			String key = (String) it.next();

			logMetacat.debug("files key: " + key);

			logMetacat.debug("files value: " + files.get(key));

		}

		multipartparams = mr.getMultipartParameters();

		it = multipartparams.keySet().iterator();

		while (it.hasNext()) {

			String key = (String) it.next();

			logMetacat.debug("multipartparams key: " + key);

			logMetacat.debug("multipartparams value: " + multipartparams.get(key));

		}

		it = params.keySet().iterator();

		while (it.hasNext()) {

			String key = (String) it.next();

			logMetacat.debug("param key: " + key);

			logMetacat.debug("param value: " + params.get(key));

		}

		logMetacat.debug("done iterating the request...");

		File smFile = files.get("sysmeta");

		if (smFile == null) {

			throw new InvalidRequest("1102",

					"Missing the required file-part 'sysmeta' from the multipart request.");

		}

		logMetacat.debug("smFile: " + smFile.getAbsolutePath());

		sysmeta = new FileInputStream(smFile);

		logMetacat.debug("Commence creation...");

	}

        throws ServiceFailure, InvalidRequest {

        // Read the incoming data from its Mime Multipart encoding

        logMetacat.debug("Disassembling MIME multipart form");

        InputStream object = null;

        InputStream sysmeta = null;

        // handle MMP inputs

        File tmpDir = getTempDirectory();

        	new MultipartRequestResolver(tmpDir.getAbsolutePath(), 1000000000, 0);

        MultipartRequest mr = null;

		try {

			mr = mrr.resolveMultipart(request);

		} catch (Exception e) {

            throw new ServiceFailure("1202",

            		"Could not resolve multipart files: " + e.getMessage());

		}

        if (files == null) {

            throw new ServiceFailure("1202", "create/update must have multipart files with names 'object' and 'sysmeta'");

        }

        if (files.keySet() == null) {

                    "create/update must have multipart files with names 'object' and 'sysmeta'");

        }

		// for logging purposes, dump out the key-value pairs that constitute the request

		// 3 types exist: request params, multipart params, and multipart files

        Iterator it = files.keySet().iterator();

            String key = (String)it.next();

            logMetacat.debug("files value: " + files.get(key));

        multipartparams = mr.getMultipartParameters();

        it = multipartparams.keySet().iterator();

            String key = (String)it.next();

            logMetacat.debug("multipartparams value: " + multipartparams.get(key));

        it = params.keySet().iterator();

            String key = (String)it.next();

            logMetacat.debug("param value: " + params.get(key));

        File smFile = files.get("sysmeta");

		if (smFile == null) {

		    throw new InvalidRequest("1102", "Missing the required file-part 'sysmeta' from the multipart request.");

		}

		if (objFile == null) {

		    throw new InvalidRequest("1102", "Missing the required file-part 'object' from the multipart request.");

		}

        return files;

    }

     *  native metacathandler functions

        String[] value = null;

        Enumeration paramlist = request.getParameterNames();

        while (paramlist.hasMoreElements()) {

            name = (String) paramlist.nextElement();

            value = request.getParameterValues(name);

            params.put(name, value);

        }

    }

    /**

     * Collect the multipart params from the request

     * @throws Exception

     */

	protected void initMultipartParams() throws Exception {

		// Read the incoming data from its Mime Multipart encoding

		logMetacat.debug("Disassembling MIME multipart form");

		// handle MMP inputs

		File tmpDir = getTempDirectory();

		logMetacat.debug("temp dir: " + tmpDir.getAbsolutePath());

		MultipartRequestResolver mrr =

			new MultipartRequestResolver(tmpDir.getAbsolutePath(), 1000000000, 0);

		MultipartRequest mr = mrr.resolveMultipart(request);

		multipartparams = mr.getMultipartParameters();

	}

     * @return

            if(s.indexOf("\"", searchStringIndex + searchString.length() + 1) == -1)

            { //the end of the boundary is in the next byte array

                boundary = s.substring(searchStringIndex + searchString.length() + 1, s.length());

            }

            else if(!boundary.startsWith("--"))

            { //we can read the whole boundary from this byte array

                boundary = s.substring(searchStringIndex + searchString.length() + 1,

                    s.indexOf("\"", searchStringIndex + searchString.length() + 1));

                boundary = "--" + boundary;

                endResult[0] = boundary;

                endResult[1] = s.substring(s.indexOf("\"", searchStringIndex + searchString.length() + 1) + 1,

                        s.length());

                break;

            }

            else

            { //we're now reading the 2nd byte array to get the rest of the boundary

                searchString = "\"";

                searchStringIndex = s.indexOf(searchString);

                boundary += s.substring(0, searchStringIndex);

                boundary = "--" + boundary;

                endResult[0] = boundary;

                endResult[1] = s.substring(s.indexOf("\"", searchStringIndex + searchString.length() + 1) + 1,

                        s.length());

                break;

            }