Metacat

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.FileOutputStream;

import java.io.IOException;

import java.sql.SQLException;

import java.util.Enumeration;

import java.util.Hashtable;

import java.util.Timer;

import java.util.TimerTask;

import javax.servlet.http.HttpServletRequest;

import edu.ucsb.nceas.metacat.McdbException;

import edu.ucsb.nceas.metacat.MetacatHandler;

import edu.ucsb.nceas.metacat.client.InsufficientKarmaException;

import edu.ucsb.nceas.metacat.properties.PropertyService;

import edu.ucsb.nceas.utilities.ParseLSIDException;

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

  private static Logger logMetacat = Logger.getLogger(D1NodeService.class);

  /* reference to the metacat handler */

  private MetacatHandler handler;

  /* parameters set in the incoming request */

  private Hashtable<String, String[]> params;

	 * TODO: The D1 Authorization API doesn't provide information on which 

	 * authentication system the Subject belongs to, and so it's not possible to

	 * discern which Person or Group is a valid KNB LDAP DN.  Fix this.

	 * 

		InputStream inputStream = null; // bytes to be returned

    handler = new MetacatHandler(new Timer());

		boolean allowed = false;

		String localId; // the metacat docid for the pid

		Subject subject = session.getSubject(); // the requesting user

		List<Group> groupList; // the user's groups

		// set the public user as a fallback

		if ( subject == null ) {

			subject.setValue("Public");

			session.setSubject(subject);

		}

		// convert groups to a string array (for handler)

		groupList = session.getSubjectList().getGroupList();

		String[] groups = new String[groupList.size()];     

		// get the local docid from Metacat

		try {

	    localId = IdentifierManager.getInstance().getLocalId(pid.getValue());

    } catch (McdbDocNotFoundException e) {

      throw new NotFound("1020", "The object specified by " + 

      		               pid.getValue() +

      		               "does not exist at this node.");

    }

    // check for authorization

		allowed = isAuthorized(session, pid, Permission.READ);

		// if the person is authorized, perform the read

		if ( allowed ) {

			for ( int i = 0; i > groupList.size(); i++ ) {

				groups[i] = groupList.get(i).getGroupName();

			}

			// get the object bytes

			// TODO: stream to file to stream conversion throughout Metacat needs to

			// be resolved

      File tmpDir;

      try

      {

          tmpDir = new File(PropertyService.getProperty("application.tempDir"));

      }

      catch(PropertyNotFoundException pnfe)

      {

          logMetacat.error("D1NodeService.get(): " +

                  "application.tmpDir not found.  Using /tmp instead.");

          tmpDir = new File("/tmp");

      }

      Date d = new Date();

      final File outputFile = new File(tmpDir, "metacat.output." + d.getTime());

      FileOutputStream dataSink;

      try {

	      dataSink = new FileOutputStream(outputFile);

	      handler.readFromMetacat(localId, null, 

            dataSink, localId, "xml",

            subject.getValue(), 

            groups, true, params);

      } catch (FileNotFoundException e) {

        throw new ServiceFailure("1020", "The object specified by " + 

            pid.getValue() +

            "could not be returned due to a file read error: " +

            e.getMessage());

      } catch (PropertyNotFoundException e) {

        throw new ServiceFailure("1020", "The object specified by " + 

            pid.getValue() +

            "could not be returned due to an internal error: " +

            e.getMessage());

      } catch (ClassNotFoundException e) {

        throw new ServiceFailure("1020", "The object specified by " + 

            pid.getValue() +

            "could not be returned due to an internal error: " +

            e.getMessage());

      } catch (IOException e) {

        throw new ServiceFailure("1020", "The object specified by " + 

            pid.getValue() +

            "could not be returned due to a file read error: " +

            e.getMessage());

      } catch (SQLException e) {

        throw new ServiceFailure("1020", "The object specified by " + 

            pid.getValue() +

            "could not be returned due to a database error: " +

            e.getMessage());

      } catch (McdbException e) {

        throw new ServiceFailure("1020", "The object specified by " + 

            pid.getValue() +

            "could not be returned due to database error: " +

            e.getMessage());

      } catch (ParseLSIDException e) {

        throw new ServiceFailure("1020", "The object specified by " + 

            pid.getValue() +

            "could not be returned due to a parse error: " +

            e.getMessage());

      } catch (InsufficientKarmaException e) {

	      // TODO Auto-generated catch block

	      e.printStackTrace();

      }

      //set a timer to clean up the temp files

      Timer t = new Timer();

      TimerTask tt = new TimerTask() {

          @Override

          public void run()

          {

              outputFile.delete();

          }

      };

      t.schedule(tt, 20000); //schedule after 20 secs

      try {

	      inputStream = new FileInputStream(outputFile);

      } catch (FileNotFoundException e) {

        throw new ServiceFailure("1020", "The object specified by " + 

          pid.getValue() +

          "could not be returned due to a file read error: " +

          e.getMessage());

      }			

		}

		// if we fail to set the input stream

		if ( inputStream == null ) {

      throw new NotFound("1020", "The object specified by " + 

                         pid.getValue() +

                         "does not exist at this node.");

		}

		return inputStream;

  /**

   * set the params for this service from an HttpServletRequest param list

   */

  public void setParamsFromRequest(HttpServletRequest request) {

  	@SuppressWarnings("unchecked")

    Enumeration<String> paramlist = request.getParameterNames();

    while (paramlist.hasMoreElements()) {

      String name = (String) paramlist.nextElement();

      String[] value = (String[])request.getParameterValues(name);

      params.put(name, value);

    }

  }