--- /dev/null
+/*
+ * Copyright (c) 1997, 2018 Oracle and/or its affiliates. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v. 2.0, which is available at
+ * http://www.eclipse.org/legal/epl-2.0.
+ *
+ * This Source Code may also be made available under the following Secondary
+ * Licenses when the conditions for such availability set forth in the
+ * Eclipse Public License v. 2.0 are satisfied: GNU General Public License,
+ * version 2 with the GNU Classpath Exception, which is available at
+ * https://www.gnu.org/software/classpath/license.html.
+ *
+ * SPDX-License-Identifier: EPL-2.0 OR GPL-2.0 WITH Classpath-exception-2.0
+ */
+
+package com.sun.mail.mbox;
+
+import javax.mail.*;
+import javax.mail.internet.*;
+import javax.activation.*;
+import java.util.*;
+import java.io.*;
+import java.nio.charset.StandardCharsets;
+import com.sun.mail.util.LineInputStream;
+
+/**
+ * The SunV3Multipart class is an implementation of the abstract Multipart
+ * class that uses SunV3 conventions for the multipart data. <p>
+ *
+ * @author Bill Shannon
+ */
+
+public class SunV3Multipart extends MimeMultipart {
+ private boolean parsing;
+
+ /**
+ * Constructs a SunV3Multipart object and its bodyparts from the
+ * given DataSource. <p>
+ *
+ * @param ds DataSource, can be a MultipartDataSource
+ */
+ public SunV3Multipart(DataSource ds) throws MessagingException {
+ super(ds);
+ }
+
+ /**
+ * Set the subtype. Throws MethodNotSupportedException.
+ *
+ * @param subtype Subtype
+ */
+ public void setSubType(String subtype) throws MessagingException {
+ throw new MethodNotSupportedException(
+ "can't change SunV3Multipart subtype");
+ }
+
+ /**
+ * Get the BodyPart referred to by the given ContentID (CID).
+ * Throws MethodNotSupportException.
+ */
+ public synchronized BodyPart getBodyPart(String CID)
+ throws MessagingException {
+ throw new MethodNotSupportedException(
+ "SunV3Multipart doesn't support Content-ID");
+ }
+
+ /**
+ * Update headers. Throws MethodNotSupportException.
+ */
+ protected void updateHeaders() throws MessagingException {
+ throw new MethodNotSupportedException("SunV3Multipart not writable");
+ }
+
+ /**
+ * Iterates through all the parts and outputs each SunV3 part
+ * separated by a boundary.
+ */
+ public void writeTo(OutputStream os)
+ throws IOException, MessagingException {
+ throw new MethodNotSupportedException(
+ "SunV3Multipart writeTo not supported");
+ }
+
+ private static final String boundary = "----------";
+
+ /*
+ * Parse the contents of this multipart message and create the
+ * child body parts.
+ */
+ protected synchronized void parse() throws MessagingException {
+ /*
+ * If the data has already been parsed, or we're in the middle of
+ * parsing it, there's nothing to do. The latter will occur when
+ * we call addBodyPart, which will call parse again. We really
+ * want to be able to call super.super.addBodyPart.
+ */
+ if (parsed || parsing)
+ return;
+
+ InputStream in = null;
+
+ try {
+ in = ds.getInputStream();
+ if (!(in instanceof ByteArrayInputStream) &&
+ !(in instanceof BufferedInputStream))
+ in = new BufferedInputStream(in);
+ } catch (IOException ex) {
+ throw new MessagingException("No inputstream from datasource");
+ } catch (RuntimeException ex) {
+ throw new MessagingException("No inputstream from datasource");
+ }
+
+ byte[] bndbytes = boundary.getBytes(StandardCharsets.ISO_8859_1);
+ int bl = bndbytes.length;
+
+ String line;
+ parsing = true;
+ try {
+ /*
+ * Skip any kind of junk until we get to the first
+ * boundary line.
+ */
+ LineInputStream lin = new LineInputStream(in);
+ while ((line = lin.readLine()) != null) {
+ if (line.trim().equals(boundary))
+ break;
+ }
+ if (line == null)
+ throw new MessagingException("Missing start boundary");
+
+ /*
+ * Read and process body parts until we see the
+ * terminating boundary line (or EOF).
+ */
+ for (;;) {
+ /*
+ * Collect the headers for this body part.
+ */
+ InternetHeaders headers = new InternetHeaders(in);
+
+ if (!in.markSupported())
+ throw new MessagingException("Stream doesn't support mark");
+
+ ByteArrayOutputStream buf = new ByteArrayOutputStream();
+ int b;
+
+ /*
+ * Read and save the content bytes in buf.
+ */
+ while ((b = in.read()) >= 0) {
+ if (b == '\r' || b == '\n') {
+ /*
+ * Found the end of a line, check whether the
+ * next line is a boundary.
+ */
+ int i;
+ in.mark(bl + 4 + 1); // "4" for possible "--\r\n"
+ if (b == '\r' && in.read() != '\n') {
+ in.reset();
+ in.mark(bl + 4);
+ }
+ // read bytes, matching against the boundary
+ for (i = 0; i < bl; i++)
+ if (in.read() != bndbytes[i])
+ break;
+ if (i == bl) {
+ int b2 = in.read();
+ // check for end of line
+ if (b2 == '\n')
+ break; // got it! break out of the while loop
+ if (b2 == '\r') {
+ in.mark(1);
+ if (in.read() != '\n')
+ in.reset();
+ break; // got it! break out of the while loop
+ }
+ }
+ // failed to match, reset and proceed normally
+ in.reset();
+ }
+ buf.write(b);
+ }
+
+ /*
+ * Create a SunV3BodyPart to represent this body part.
+ */
+ SunV3BodyPart body =
+ new SunV3BodyPart(headers, buf.toByteArray());
+ addBodyPart(body);
+ if (b < 0)
+ break;
+ }
+ } catch (IOException e) {
+ throw new MessagingException("IO Error"); // XXX
+ } finally {
+ parsing = false;
+ }
+
+ parsed = true;
+ }
+}
projects / gpl / argeo-slc.git / blobdiff