Hi,
message/rfc822 are NestedMessage !!!!.
So we implement a special route to process them. We extract 822 and save it on
specific eml file
We using Camel 3.14.3 with blueprint bundles in OSGI Karaf 4.33
Here some code we made, hope it help you.
2 cases for 822
1- BODY Nested Mail, no TEXT in MAIL
<choice>
<when><simple>${body} is "com.sun.mail.imap.IMAPNestedMessage"</simple> <!--
seulement msg822 en pieceJointe -->
<setHeader name="zzBody">
<simple> ( Impossible d'extraire le Corps du message, voir pièce
jointe msg822 )</simple>
</setHeader>
<filter><simple>${properties:devlogFlag} == 'O' </simple>
<log message="000 Null BODY: "/>
</filter>
<to uri="direct:sdiInsertBodyCourriel" />
<to uri="direct:sdiExtractMsg822" />
</when>
2- Multipart BODY
<when><simple>${body} is "javax.mail.internet.MimeMultipart"</simple>
<filter><simple>${properties:devlogFlag} == 'O' </simple>
<log message="000 BODY: Multipart"/>
</filter>
<to uri="direct:sdiExtractPJ" />
<to uri="direct:sdiExtractBodyMPart" />
<to uri="direct:sdiInsertBodyCourriel" />
<to uri="direct:sdiExtractMsg822" />
<setHeader name="zzSwitchlirePj">
<groovy>
zPjTemp = new File( request.headers['zzTEMPPJ'] )
zzPj = zPjTemp.listFiles();
if ( zzPj.length > 0 ) { result="OUI"}
else { result="NON" }
</groovy>
</setHeader>
<filter><simple>${properties:devlogFlag} == 'O' </simple>
<log message="SwitchlirePj: ${header.zzSwitchlirePj} " />
</filter>
<filter><simple>${header.zzSwitchlirePj} == "OUI" </simple>
<to uri="direct:sdiLirePjCourriel" />
</filter>
</when>
.....
.....
<route id="rte.{{SYS.SHQ}}.ExtractBodyMPart" streamCache="true">
<from uri="direct:sdiExtractBodyMPart"/>
<log message="555 Extract BODY" />
<setHeader name="zzBody">
<groovy>
part = request.body.getBodyPart(0)
//part =
request.getOriginalMessage().getContent().getBodyPart(0)
def Jsoup = new org.jsoup.Jsoup();
def wlist(org.jsoup.safety.Whitelist basic ) {
return new org.jsoup.safety.Whitelist()
.addTags(
"a", "b", "blockquote", "br", "cite", "code",
"dd", "dl", "dt", "em",
"i", "li", "ol", "p", "pre", "q", "small",
"span", "strike", "strong", "sub",
"sup", "u", "ul")
.addAttributes("a", "href")
.addAttributes("blockquote", "cite")
.addAttributes("q", "cite")
.addProtocols("a", "href", "ftp", "http", "https",
"mailto")
.addProtocols("blockquote", "cite", "http", "https")
.addProtocols("cite", "cite", "http", "https")
}
if (
part.getContent().getClass().equals(com.sun.mail.imap.IMAPNestedMessage)) {
result = "( PAS DE CORPS DE MESSAGE / voir piece jointe ) ";
}
else if ( part.getContentType().toLowerCase().contains('html')) {
zbody = part.getContent();
zbody = Jsoup.clean(zbody,wlist()); // conserve
seulement certains tags de bases
zbody = zbody.replaceAll("<a .*href=","")
zbody = zbody.replaceAll("></a>","")
result = Jsoup.parse(zbody).wholeText(); // preserve CRLF
}
else if (
part.getContent().getClass().equals(javax.mail.internet.MimeMultipart)) {
result = part.getContent().getBodyPart(0).getContent();
}
else {
result = part.getContent();
}
</groovy>
</setHeader>
</route>
<route id="rte.{{SYS.SHQ}}.InsertBodyCourriel" streamCache="true">
<from uri="direct:sdiInsertBodyCourriel"/>
<doTry>
... insert in SQL Database
<doCatch>
<exception>org.springframework.jdbc.BadSqlGrammarException</exception>
<exception>java.sql.SQLSyntaxErrorException</exception>
<exception>java.sql.SQLException</exception>
<exception>java.sql.SQLIntegrityConstraintViolationException</exception>
<exception>java.lang.IllegalArgumentException</exception>
</doCatch>
...
...
</doTry>
...
...
</route>
<route id="rte.{{SYS.SHQ}}.ExtractMsg822" streamCache="true">
<description>
=======================================================================
Permet d'extraire et d'écrire les parties messages/822 dans un fichier
Ce(s) fichier(s) seront par la suite inscrit dans la BD comme PJ_Courriel_nn.eml
=======================================================================
</description>
<from uri="direct:sdiExtractMsg822"/>
<filter><simple>${properties:devlogFlag} == 'O' </simple>
<log message="777 Extract MSG822 ?" />
<filter/>
<setHeader name="zz822">
<groovy>
zresult = 0
if ( request.body.getClass().equals(com.sun.mail.imap.IMAPNestedMessage)) {
zHeaders=""
crlf="\r\n"
headerEnum = request.body.getAllHeaders();
while (headerEnum.hasMoreElements()) {
header = headerEnum.nextElement();
name = header.getName();
<!-- Anonymise les information de securite, adresse IP des serveurs
Internes -->
value = header.getValue().replaceAll('10.100.','192.168.');
zHeaders = zHeaders + name +": " + value + "\r\n"
}
mail822filename = request.headers['zzTEMP822']+"PJ_Courriel_1.eml"
mailoriginal = new File(mail822filename);
mailoriginal.write(zHeaders+crlf);
mailoriginal.append(request.body.getContentStream().getText()+crlf);
zresult = zresult + 1;
} else {
mimeMultipart = request.body
partCount = mimeMultipart.getCount();
for (i = 0; i != mimeMultipart.getCount(); i++) {
ii = i;
bodyPart = mimeMultipart.getBodyPart(i);
if (bodyPart.isMimeType("message/rfc822")) {
zresult = zresult + 1;
mail822filename =
request.headers['zzTEMP822']+"PJ_Courriel_" + zresult + ".eml"
bodyPart.getContent().writeTo(new FileOutputStream(new
File(mail822filename)));
}
}
// if ( zresult > 1){ zresult = zresult - 1; } // replace le bon
nombre de PJ extraite apres la LOOP
}
result = zresult
</groovy>
</setHeader>
<filter><simple>${properties:devlogFlag} == 'O' </simple>
<log message="777 N822= ${header.zz822}" />
</filter>
<setHeader name="zzLoop"> <constant>0</constant></setHeader>
<loop doWhile="true"><simple>${header.zzLoop} != ${header.zz822}</simple>
<log message="Loop ? ${header.zzLoop} = ${header.zz822}" />
<setHeader name="zzLoop"><simple>${header.zzLoop}++</simple></setHeader>
<setHeader name="zzPJ" ><groovy>new
File(request.headers['zzTEMP822']+"PJ_Courriel_"+request.headers['zzLoop']+".eml").bytes</groovy></setHeader>
<setHeader name="utlRecCourrielPjContentType"
><constant>message/rfc822</constant></setHeader>
<setHeader name="utlNomPj"
><simple>PJ_Courriel_${header.utlNoSeqCommunication}_${header.zzLoop}.eml</simple></setHeader>
<setHeader name="zzTypeCode"><constant>REGUL</constant></setHeader>
<to uri="direct:sdiInsertPjCourriel" />
</loop>
</route>
<route id="rte.{{SYS.SHQ}}.LirePjCourriel" streamCache="true">
<from uri="direct:sdiLirePjCourriel"/>
<setHeader name="zzPJtmp">
<groovy>
zPjTemp = new File( request.headers['zzTEMPPJ'] )
zz = zPjTemp.listFiles();
zresult = ""
for (int i = 0; i < zz.length; i++) {
zresult = zresult + zz[i].getName()+","
}
zresultArray = zresult.tokenize(',');
result = zresultArray;
</groovy>
</setHeader>
<setBody><simple>${header.zzPJtmp}</simple></setBody>
<split><tokenize token="," />
<setHeader name="utlNomPjEncode"
><simple>${header.zzPJtmp[${header.CamelSplitIndex}]}</simple></setHeader>
<setHeader name="utlNomPj" ><groovy>
// replace le nom de fichier si contient Caracteres Speciaux (rfc5987)
def MimeUtility = new javax.mail.internet.MimeUtility();
result = MimeUtility.decodeText(request.headers['utlNomPjEncode']);
</groovy></setHeader>
<setHeader name="zzTypeCode"><constant>REGUL</constant></setHeader>
<setHeader name="utlRecCourrielPjContentType" >
<groovy>
zFile = new File(
request.headers['zzTEMPPJ']+request.headers['utlNomPjEncode'] )
result = java.nio.file.Files.probeContentType(zFile.toPath())
</groovy>
</setHeader>
<setHeader name="zzPJ"><groovy>new
File(request.headers['zzTEMPPJ']+request.headers['utlNomPjEncode']).bytes</groovy></setHeader>
<to uri="direct:sdiInsertPjCourriel" />
</split>
</route>
Daniel Langevin
-----Message d'origine-----
De : Shenavai, Manuel <manuel.shena...@sap.com.INVALID>
Envoyé : 6 juillet 2022 10:46
À : users@camel.apache.org
Objet : Mail Attachment not available after mail consumer
Hi everyone,
we are using the mail component (consumer) to poll emails and we found that
mail-attachments without a filename are ignored. Is there any workaround to get
attachment that don't have a name?
There is one client sending a mail containing an attachment (its of
Content-Type: message/rfc822). For some reason, no filename is provided (see in
the pseudo-mimemessage highlighted below). Due to missing filename, the
attachment will not be set into the attachmentList (filename is null):
https://can01.safelinks.protection.outlook.com/?url=https%3A%2F%2Fgithub.com%2Fapache%2Fcamel%2Fblob%2Fmain%2Fcomponents%2Fcamel-mail%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fcamel%2Fcomponent%2Fmail%2FMailBinding.java%23L353&data=05%7C01%7Cdaniel.langevin%40shq.gouv.qc.ca%7C33e11d4b7fba4be7c80c08da5f5e55b9%7C8377d97d01504e07b82ad67c55dc2c05%7C0%7C0%7C637927157485289751%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C2000%7C%7C%7C&sdata=o%2FIuiTCT%2F4YJDqltQrmv8D3QLA7KQ%2B%2F4DsmRt%2FqsiJ8%3D&reserved=0
Any ideas?
Best regards,
Manuel
MimeMessage:
Content-Type: multipart/mixed;
boundary="_004_AM9PR02MB74107D2A35952A65E4234BBBE8809AM9PR02MB7410eurp_"
[...]
--_004_AM9PR02MB74107D2A35952A65E4234BBBE8809AM9PR02MB7410eurp_
Content-Type: multipart/alternative;
boundary="_000_AM9PR02MB74107D2A35952A65E4234BBBE8809AM9PR02MB7410eurp_"
--_000_AM9PR02MB74107D2A35952A65E4234BBBE8809AM9PR02MB7410eurp_
Content-Type: text/plain; charset="us-ascii"
Content-Transfer-Encoding: quoted-printable
test
--_000_AM9PR02MB74107D2A35952A65E4234BBBE8809AM9PR02MB7410eurp_
Content-Type: text/html; charset="us-ascii"
Content-Transfer-Encoding: quoted-printable
[...]
--_000_AM9PR02MB74107D2A35952A65E4234BBBE8809AM9PR02MB7410eurp_--
--_004_AM9PR02MB74107D2A35952A65E4234BBBE8809AM9PR02MB7410eurp_
Content-Type: message/rfc822
Content-Disposition: attachment;
creation-date="Wed, 06 Jul 2022 14:27:01 GMT";
modification-date="Wed, 06 Jul 2022 14:27:01 GMT"
The attachment content
--_004_AM9PR02MB74107D2A35952A65E4234BBBE8809AM9PR02MB7410eurp_--
