Metacat

	public InputStream getPackage(Session session, Identifier pid) throws InvalidToken, ServiceFailure, NotAuthorized, NotFound, NotImplemented {

		// catch non-D1 service errors and throw as ServiceFailures

		try {

			// find the package contents

			SystemMetadata sysMeta = this.getSystemMetadata(session, pid);

			if (ObjectFormatService.getInstance().getFormat(sysMeta.getFormatId()).getFormatType().equals("RESOURCE")) {

				InputStream oreInputStream = this.get(session, pid);

				Map<Identifier, Map<Identifier, List<Identifier>>> resourceMapStructure = ResourceMapFactory.getInstance().parseResourceMap(oreInputStream);

				packagePids.addAll(resourceMapStructure.keySet());

				for (Map<Identifier, List<Identifier>> entries: resourceMapStructure.values()) {

					packagePids.addAll(entries.keySet());

					for (List<Identifier> dataPids: entries.values()) {

						packagePids.addAll(dataPids);

					}

			} else {

				// just the lone pid in this package

				packagePids.add(pid);

			// track the pid-to-file mapping

			StringBuffer pidMapping = new StringBuffer();

			// loop through the package contents

			for (Identifier entryPid: packagePids) {

				SystemMetadata entrySysMeta = this.getSystemMetadata(session, entryPid);

				String extension = ObjectFormatInfo.instance().getExtension(entrySysMeta.getFormatId().getValue());

		        String prefix = entryPid.getValue();

		        prefix = "entry";

				File tempFile = File.createTempFile(prefix + ".", extension);

				tempFiles.add(tempFile);

				InputStream entryInputStream = this.get(session, entryPid);

				IOUtils.copy(entryInputStream, new FileOutputStream(tempFile));

				bag.addFileToPayload(tempFile);

				pidMapping.append(entryPid.getValue() + "\t" + "data/" + tempFile.getName() + "\n");

			}

			//add the the pid to data file map

			File pidMappingFile = File.createTempFile("pid-mapping.", ".txt");

			IOUtils.write(pidMapping.toString(), new FileOutputStream(pidMappingFile));

			bag.addFileAsTag(pidMappingFile);

			bag = bag.makeComplete();

			File bagFile = File.createTempFile("bag.", ".zip");

			// TODO: delete more confidently

			bagFile.deleteOnExit();

			bag.setFile(bagFile);

			Writer zipWriter = new ZipWriter(bagFactory);

			bag.write(zipWriter, bagFile);

			bagFile = bag.getFile();

			bagInputStream = new FileInputStream(bagFile);

			// clean up temp entry files

			for (File tf: tempFiles) {

				tf.delete();

			}

		} catch (IOException e) {

			// report as service failure

			ServiceFailure sf = new ServiceFailure("1030", e.getMessage());

			sf.initCause(e);

			throw sf;

		} catch (OREException e) {

			// report as service failure

			ServiceFailure sf = new ServiceFailure("1030", e.getMessage());

			sf.initCause(e);

			throw sf;

		} catch (URISyntaxException e) {

			// report as service failure

			ServiceFailure sf = new ServiceFailure("1030", e.getMessage());

			sf.initCause(e);

			throw sf;

		} catch (OREParserException e) {

			// report as service failure

			ServiceFailure sf = new ServiceFailure("1030", e.getMessage());

			sf.initCause(e);

			throw sf;