moparisthebest/davmail
1
0
Fork 0
mirror of https://github.com/moparisthebest/davmail synced 2024-08-13 16:53:51 -04:00
Code Issues Releases Wiki Activity

IMAP: workaround for broken message (500 error), rebuild mime message from properties

Browse Source 
git-svn-id: http://svn.code.sf.net/p/davmail/code/trunk@1483 3d1905a2-6b24-0410-a738-b14d5a86fcbd
This commit is contained in:
mguessan 2010-09-29 23:28:22 +00:00
parent 15e49fe372
commit 890c7e425e
2 changed files with 72 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

79
src/java/davmail/exchange/dav/DavExchangeSession.java
View File

@ -47,6 +47,7 @@ import org.apache.jackrabbit.webdav.property.DavPropertySet;
import org.w3c.dom.Node;
import javax.mail.MessagingException;
import javax.mail.Session;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import javax.mail.internet.MimeMultipart;
@ -2411,7 +2412,7 @@ public class DavExchangeSession extends ExchangeSession {
@Override
protected byte[] getContent(ExchangeSession.Message message) throws IOException {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
InputStream contentInputStream;
InputStream contentInputStream = null;
try {
try {
contentInputStream = getContentInputStream(message.messageUrl);
@ -2419,24 +2420,84 @@ public class DavExchangeSession extends ExchangeSession {
LOGGER.debug("Message not found at: " + message.messageUrl + ", retrying with permanenturl");
contentInputStream = getContentInputStream(message.permanentUrl);
}
} catch (HttpException e) {
try {
IOUtil.write(contentInputStream, baos);
} finally {
contentInputStream.close();
}
} catch (IOException e) {
LOGGER.warn("Broken message at: " + message.messageUrl + " permanentUrl: " + message.permanentUrl + ", trying to rebuild from properties");
try {
DavPropertyNameSet messageProperties = new DavPropertyNameSet();
messageProperties.add(Field.getPropertyName("contentclass"));
messageProperties.add(Field.getPropertyName("message-id"));
messageProperties.add(Field.getPropertyName("from"));
messageProperties.add(Field.getPropertyName("to"));
messageProperties.add(Field.getPropertyName("cc"));
messageProperties.add(Field.getPropertyName("subject"));
messageProperties.add(Field.getPropertyName("htmldescription"));
messageProperties.add(Field.getPropertyName("body"));
PropFindMethod propFindMethod = new PropFindMethod(URIUtil.encodePath(message.permanentUrl), messageProperties, 0);
DavGatewayHttpClientFacade.executeMethod(httpClient, propFindMethod);
MultiStatus responses = propFindMethod.getResponseBodyAsMultiStatus();
if (responses.getResponses().length > 0) {
MimeMessage mimeMessage = new MimeMessage((Session) null);
DavPropertySet properties = responses.getResponses()[0].getProperties(HttpStatus.SC_OK);
String propertyValue = getPropertyIfExists(properties, "contentclass");
if (propertyValue != null) {
mimeMessage.addHeader("Content-class", propertyValue);
}
propertyValue = getPropertyIfExists(properties, "from");
if (propertyValue != null) {
mimeMessage.addHeader("From", propertyValue);
}
propertyValue = getPropertyIfExists(properties, "to");
if (propertyValue != null) {
mimeMessage.addHeader("To", propertyValue);
}
propertyValue = getPropertyIfExists(properties, "cc");
if (propertyValue != null) {
mimeMessage.addHeader("Cc", propertyValue);
}
propertyValue = getPropertyIfExists(properties, "subject");
if (propertyValue != null) {
mimeMessage.setSubject(propertyValue);
}
propertyValue = getPropertyIfExists(properties, "htmldescription");
if (propertyValue != null) {
mimeMessage.setContent(propertyValue, "text/html");
} else {
propertyValue = getPropertyIfExists(properties, "body");
mimeMessage.setText(propertyValue);
}
mimeMessage.writeTo(baos);
}
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("Rebuilt message content: " + new String(baos.toByteArray()));
}
} catch (IOException e2) {
LOGGER.warn(e2);
} catch (DavException e2) {
LOGGER.warn(e2);
} catch (MessagingException e2) {
LOGGER.warn(e2);
}
// other exception
if (Settings.getBooleanProperty("davmail.deleteBroken")) {
if (baos.size() == 0 && Settings.getBooleanProperty("davmail.deleteBroken")) {
LOGGER.warn("Deleting broken message at: " + message.messageUrl + " permanentUrl: " + message.permanentUrl);
try {
message.delete();
} catch (IOException ioe) {
LOGGER.warn("Unable to delete broken message at: " + message.permanentUrl);
}
throw e;
}
throw e;
}
try {
IOUtil.write(contentInputStream, baos);
} finally {
contentInputStream.close();
}
return baos.toByteArray();
}

2
src/java/davmail/exchange/dav/Field.java
View File

@ -145,6 +145,8 @@ public class Field {
//createField("from", DistinguishedPropertySetType.PublicStrings, 0x001f);//urn:schemas:httpmail:from
createField(URN_SCHEMAS_MAILHEADER, "to"); // DistinguishedPropertySetType.InternetHeaders/To/String
createField(URN_SCHEMAS_MAILHEADER, "cc"); // DistinguishedPropertySetType.InternetHeaders/To/String
createField(URN_SCHEMAS_MAILHEADER, "message-id"); // DistinguishedPropertySetType.InternetHeaders/message-id/String
createField(URN_SCHEMAS_MAILHEADER, "htmldescription"); // DistinguishedPropertySetType.InternetHeaders/htmldescription/String
createField("lastmodified", DAV, "getlastmodified"); // PR_LAST_MODIFICATION_TIME 0x3008 SystemTime