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.SystemMetadata;

import edu.ucsb.nceas.metacat.MetacatHandler;

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

 *

    /**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;

    }

    protected AccessPolicy collectAccessPolicy() 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;

	}

		// 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...");

	}

    protected Map<String, File> collectMultipartFiles() 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;

    }

     */

        String[] value = null;

        Enumeration paramlist = request.getParameterNames();

        while (paramlist.hasMoreElements()) {

            name = (String) paramlist.nextElement();

            value = request.getParameterValues(name);

            params.put(name, value);

        }

    }

     * @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;

            }

    }

     * @return

     */

        File tmpDir = null;

        }

            tmpDir = new File("/tmp");

        }

     * @param message Message to be displayed

     * @param response Servlet response that xml message will be printed

     * */

            response.setContentType("text/xml");

            out.println("<?xml version=\"1.0\"?>");

            out.println("<error>");

            out.println(message);

            out.println("</error>");

            out.close();

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

     * serialize a D1 exception using jibx

     * @param e

     * @param out

     */

        response.setContentType("text/xml");

        response.setStatus(e.getCode());

            IOUtils.write(e.serialize(BaseException.FMT_XML), out);

        } catch (IOException e1) {

            logMetacat.error("Error writing exception to stream. "

                    + e1.getMessage());

        }

    }