KaneAI - World’s First E2E Software Testing Agent.Signup for Private Beta Join TestMu Conference

How to use BodyPart method of com.consol.citrus.mail.model.BodyPart class

Best Citrus code snippet using com.consol.citrus.mail.model.BodyPart.BodyPart

Source:MailMessageConverter.java

...104     * @param bodyPart105     * @param endpointConfiguration106     * @return107     */108    protected MailMessage createMailRequest(Map<String, Object> messageHeaders, BodyPart bodyPart, MailEndpointConfiguration endpointConfiguration) {109        return MailMessage.request(messageHeaders)110                        .marshaller(endpointConfiguration.getMarshaller())111                        .from(messageHeaders.get(CitrusMailMessageHeaders.MAIL_FROM).toString())112                        .to(messageHeaders.get(CitrusMailMessageHeaders.MAIL_TO).toString())113                        .cc(messageHeaders.get(CitrusMailMessageHeaders.MAIL_CC).toString())114                        .bcc(messageHeaders.get(CitrusMailMessageHeaders.MAIL_BCC).toString())115                        .subject(messageHeaders.get(CitrusMailMessageHeaders.MAIL_SUBJECT).toString())116                        .body(bodyPart);117    }118    /**119     * Reads basic message information such as sender, recipients and mail subject to message headers.120     * @param msg121     * @return122     */123    protected Map<String,Object> createMessageHeaders(MimeMailMessage msg) throws MessagingException, IOException {124        Map<String, Object> headers = new HashMap<>();125        headers.put(CitrusMailMessageHeaders.MAIL_MESSAGE_ID, msg.getMimeMessage().getMessageID());126        headers.put(CitrusMailMessageHeaders.MAIL_FROM, StringUtils.arrayToCommaDelimitedString(msg.getMimeMessage().getFrom()));127        headers.put(CitrusMailMessageHeaders.MAIL_TO, StringUtils.arrayToCommaDelimitedString((msg.getMimeMessage().getRecipients(javax.mail.Message.RecipientType.TO))));128        headers.put(CitrusMailMessageHeaders.MAIL_CC, StringUtils.arrayToCommaDelimitedString((msg.getMimeMessage().getRecipients(javax.mail.Message.RecipientType.CC))));129        headers.put(CitrusMailMessageHeaders.MAIL_BCC, StringUtils.arrayToCommaDelimitedString((msg.getMimeMessage().getRecipients(javax.mail.Message.RecipientType.BCC))));130        headers.put(CitrusMailMessageHeaders.MAIL_REPLY_TO, StringUtils.arrayToCommaDelimitedString((msg.getMimeMessage().getReplyTo())));131        headers.put(CitrusMailMessageHeaders.MAIL_DATE, msg.getMimeMessage().getSentDate() != null ? dateFormat.format(msg.getMimeMessage().getSentDate()) : null);132        headers.put(CitrusMailMessageHeaders.MAIL_SUBJECT, msg.getMimeMessage().getSubject());133        headers.put(CitrusMailMessageHeaders.MAIL_CONTENT_TYPE, parseContentType(msg.getMimeMessage().getContentType()));134        return headers;135    }136    /**137     * Process message part. Can be a text, binary or multipart instance.138     * @param part139     * @return140     * @throws java.io.IOException141     */142    protected BodyPart handlePart(MimePart part) throws IOException, MessagingException {143        String contentType = parseContentType(part.getContentType());144        if (part.isMimeType("multipart/*")) {145            return handleMultiPart((Multipart) part.getContent());146        } else if (part.isMimeType("text/*")) {147            return handleTextPart(part, contentType);148        } else if (part.isMimeType("image/*")) {149            return handleImageBinaryPart(part, contentType);150        } else if (part.isMimeType("application/*")) {151            return handleApplicationContentPart(part, contentType);152        } else {153            return handleBinaryPart(part, contentType);154        }155    }156    /**157     * Construct multipart body with first part being the body content and further parts being the attachments.158     * @param body159     * @return160     * @throws IOException161     */162    private BodyPart handleMultiPart(Multipart body) throws IOException, MessagingException {163        BodyPart bodyPart = null;164        for (int i = 0; i < body.getCount(); i++) {165            MimePart entity = (MimePart) body.getBodyPart(i);166            if (bodyPart == null) {167                bodyPart = handlePart(entity);168            } else {169                BodyPart attachment = handlePart(entity);170                bodyPart.addPart(new AttachmentPart(attachment.getContent(), parseContentType(attachment.getContentType()), entity.getFileName()));171            }172        }173        return bodyPart;174    }175    /**176     * Construct body part form special application data. Based on known application content types delegate to text,177     * image or binary body construction.178     * @param applicationData179     * @param contentType180     * @return181     * @throws IOException182     */183    protected BodyPart handleApplicationContentPart(MimePart applicationData, String contentType) throws IOException, MessagingException {184        if (applicationData.isMimeType("application/pdf")) {185            return handleImageBinaryPart(applicationData, contentType);186        } else if (applicationData.isMimeType("application/rtf")) {187            return handleImageBinaryPart(applicationData, contentType);188        } else if (applicationData.isMimeType("application/java")) {189            return handleTextPart(applicationData, contentType);190        } else if (applicationData.isMimeType("application/x-javascript")) {191            return handleTextPart(applicationData, contentType);192        } else if (applicationData.isMimeType("application/xhtml+xml")) {193            return handleTextPart(applicationData, contentType);194        } else if (applicationData.isMimeType("application/json")) {195            return handleTextPart(applicationData, contentType);196        } else if (applicationData.isMimeType("application/postscript")) {197            return handleTextPart(applicationData, contentType);198        } else {199            return handleBinaryPart(applicationData, contentType);200        }201    }202    /**203     * Construct base64 body part from image data.204     * @param image205     * @param contentType206     * @return207     * @throws IOException208     */209    protected BodyPart handleImageBinaryPart(MimePart image, String contentType) throws IOException, MessagingException {210        ByteArrayOutputStream bos = new ByteArrayOutputStream();211        FileCopyUtils.copy(image.getInputStream(), bos);212        String base64 = Base64.encodeBase64String(bos.toByteArray());213        return new BodyPart(base64, contentType);214    }215    /**216     * Construct simple body part from binary data just adding file name as content.217     * @param mediaPart218     * @param contentType219     * @return220     * @throws IOException221     */222    protected BodyPart handleBinaryPart(MimePart mediaPart, String contentType) throws IOException, MessagingException {223        String contentId = mediaPart.getContentID() != null ? "(" + mediaPart.getContentID() + ")" : "";224        return new BodyPart(mediaPart.getFileName() + contentId, contentType);225    }226    /**227     * Construct simple binary body part with base64 data.228     * @param textPart229     * @param contentType230     * @return231     * @throws IOException232     */233    protected BodyPart handleTextPart(MimePart textPart, String contentType) throws IOException, MessagingException {234        String content;235        if (textPart.getContent() instanceof String) {236            content = (String) textPart.getContent();237        } else if (textPart.getContent() instanceof InputStream) {238            content = FileUtils.readToString((InputStream) textPart.getContent(), Charset.forName(parseCharsetFromContentType(contentType)));239        } else {240            throw new CitrusRuntimeException("Cannot handle text content of type: " + textPart.getContent().getClass().toString());241        }242        return new BodyPart(stripMailBodyEnding(content), contentType);243    }244    /**245     * Removes SMTP mail body ending which is defined by single '.' character in separate line marking246     * the mail body end of file.247     * @param textBody248     * @return249     */250    private String stripMailBodyEnding(String textBody) throws IOException {251        BufferedReader reader = null;252        StringBuilder body = new StringBuilder();253        try {254            reader = new BufferedReader(new StringReader(textBody));255            String line = reader.readLine();256            while (line != null && !line.equals(".")) {...

Source:MailServer.java

...28import com.consol.citrus.mail.message.MailMessage;29import com.consol.citrus.mail.message.MailMessageConverter;30import com.consol.citrus.mail.model.AcceptResponse;31import com.consol.citrus.mail.model.AttachmentPart;32import com.consol.citrus.mail.model.BodyPart;33import com.consol.citrus.mail.model.MailMarshaller;34import com.consol.citrus.mail.model.MailRequest;35import com.consol.citrus.mail.model.MailResponse;36import com.consol.citrus.message.Message;37import com.consol.citrus.server.AbstractServer;38import org.springframework.mail.javamail.MimeMailMessage;39import org.subethamail.smtp.RejectException;40import org.subethamail.smtp.helper.SimpleMessageListener;41import org.subethamail.smtp.helper.SimpleMessageListenerAdapter;42import org.subethamail.smtp.server.SMTPServer;43/**44 * Mail server implementation starts new SMTP server instance and listens for incoming mail messages. Incoming mail messages45 * are converted to XML representation and forwarded to some message endpoint adapter (e.g. forwarding mail content to46 * a message channel).47 *48 * By default incoming messages are accepted automatically. When auto accept is disabled the endpoint adapter is invoked with49 * accept request and test case has to decide accept outcome in response.50 *51 * In case of incoming multipart mail messages the server is able to split the body parts into separate XML messages52 * handled by the endpoint adapter.53 *54 * @author Christoph Deppisch55 * @since 1.456 */57public class MailServer extends AbstractServer implements SimpleMessageListener {58    /** Server port */59    private int port = 25;60    /** XML message mapper */61    private MailMarshaller marshaller = new MailMarshaller();62    /** Mail message converter */63    private MailMessageConverter messageConverter = new MailMessageConverter();64    /** Java mail session */65    private Session mailSession;66    /** Java mail properties */67    private Properties javaMailProperties = new Properties();68    /** Should accept automatically or handled via test case */69    private boolean autoAccept = true;70    /** Should split multipart messages for each mime part */71    private boolean splitMultipart = false;72    /** Smtp server instance */73    private SMTPServer smtpServer;74    @Override75    protected void startup() {76        smtpServer = new SMTPServer(new SimpleMessageListenerAdapter(this));77        smtpServer.setSoftwareName(getName());78        smtpServer.setPort(port);79        smtpServer.start();80    }81    @Override82    protected void shutdown() {83        smtpServer.stop();84    }85    @Override86    public boolean accept(String from, String recipient) {87        if (autoAccept) {88            return true;89        }90        Message response = getEndpointAdapter().handleMessage(91                MailMessage.accept(from, recipient)92                           .marshaller(marshaller));93        if (response == null || response.getPayload() == null) {94            throw new CitrusRuntimeException("Did not receive accept response. Missing accept response because autoAccept is disabled.");95        }96        AcceptResponse acceptResponse = null;97        if (response.getPayload() instanceof AcceptResponse) {98            acceptResponse = (AcceptResponse) response.getPayload();99        } else if (response.getPayload() instanceof String) {100            acceptResponse = (AcceptResponse) marshaller.unmarshal(response.getPayload(Source.class));101        }102        if (acceptResponse == null) {103            throw new CitrusRuntimeException("Unable to read accept response from payload: " + response);104        }105        return acceptResponse.isAccept();106    }107    @Override108    public void deliver(String from, String recipient, InputStream data) {109        try {110            MimeMailMessage mimeMailMessage = new MimeMailMessage(new MimeMessage(getSession(), data));111            MailMessage request = messageConverter.convertInbound(mimeMailMessage, getEndpointConfiguration(), null);112            Message response = invokeEndpointAdapter(request);113            if (response != null && response.getPayload() != null) {114                MailResponse mailResponse = null;115                if (response.getPayload() instanceof MailResponse) {116                    mailResponse = (MailResponse) response.getPayload();117                } else if (response.getPayload() instanceof String) {118                    mailResponse = (MailResponse) marshaller.unmarshal(response.getPayload(Source.class));119                }120                if (mailResponse != null && mailResponse.getCode() != MailResponse.OK_CODE) {121                    throw new RejectException(mailResponse.getCode(), mailResponse.getMessage());122                }123            }124        } catch (MessagingException e) {125            throw new CitrusRuntimeException(e);126        }127    }128    /**129     * Invokes the endpoint adapter with constructed mail message and headers.130     * @param mail131     */132    protected Message invokeEndpointAdapter(MailMessage mail) {133        if (splitMultipart) {134            return split(mail.getPayload(MailRequest.class).getBody(), mail.getHeaders());135        } else {136            return getEndpointAdapter().handleMessage(mail);137        }138    }139    /**140     * Split mail message into several messages. Each body and each attachment results in separate message141     * invoked on endpoint adapter. Mail message response if any should be sent only once within test case.142     * However latest mail response sent by test case is returned, others are ignored.143     *144     * @param bodyPart145     * @param messageHeaders146     */147    private Message split(BodyPart bodyPart, Map<String, Object> messageHeaders) {148        MailMessage mailRequest = createMailMessage(messageHeaders, bodyPart.getContent(), bodyPart.getContentType());149        Stack<Message> responseStack = new Stack<>();150        if (bodyPart instanceof AttachmentPart) {151            fillStack(getEndpointAdapter().handleMessage(mailRequest152                    .setHeader(CitrusMailMessageHeaders.MAIL_CONTENT_TYPE, bodyPart.getContentType())153                    .setHeader(CitrusMailMessageHeaders.MAIL_FILENAME, ((AttachmentPart) bodyPart).getFileName())), responseStack);154        } else {155            fillStack(getEndpointAdapter().handleMessage(mailRequest156                    .setHeader(CitrusMailMessageHeaders.MAIL_CONTENT_TYPE, bodyPart.getContentType())), responseStack);157        }158        if (bodyPart.hasAttachments()) {159            for (AttachmentPart attachmentPart : bodyPart.getAttachments().getAttachments()) {160                fillStack(split(attachmentPart, messageHeaders), responseStack);161            }...

Source:MailSteps.java

...20import com.consol.citrus.annotations.CitrusAnnotations;21import com.consol.citrus.annotations.CitrusFramework;22import com.consol.citrus.annotations.CitrusResource;23import com.consol.citrus.context.TestContext;24import com.consol.citrus.mail.model.BodyPart;25import com.consol.citrus.mail.model.MailMarshaller;26import com.consol.citrus.mail.model.MailRequest;27import com.consol.citrus.mail.server.MailServer;28import com.consol.citrus.mail.server.MailServerBuilder;29import com.consol.citrus.message.MessageType;30import com.consol.citrus.message.builder.ObjectMappingPayloadBuilder;31import io.cucumber.java.Before;32import io.cucumber.java.Scenario;33import io.cucumber.java.en.Given;34import io.cucumber.java.en.Then;35import org.citrusframework.yaks.kubernetes.KubernetesSteps;36import static com.consol.citrus.actions.ReceiveMessageAction.Builder.receive;37public class MailSteps {38	@CitrusResource39    private TestCaseRunner runner;40    @CitrusResource41    private TestContext context;42	@CitrusFramework43	private Citrus citrus;44    private MailServer mailServer;45    private int port = 22222;46    private KubernetesSteps kubernetesSteps;47    @Before48    public void before(Scenario scenario) {49        kubernetesSteps = new KubernetesSteps();50        CitrusAnnotations.injectAll(kubernetesSteps, citrus, context);51        CitrusAnnotations.injectTestRunner(kubernetesSteps, runner);52        kubernetesSteps.before(scenario);53    }54    @Given("^mail server port (\\d++)$")55    public void createMailServer(int port) {56        this.port = port;57    }58    @Given("^start mail server$")59    public void createMailServer() {60        MailMarshaller marshaller = new MailMarshaller();61        marshaller.setType(MessageType.JSON.name());62        mailServer = new MailServerBuilder()63                .port(port)64                .marshaller(marshaller)65                .autoStart(true)66                .build();67        citrus.getCitrusContext().getReferenceResolver().bind("mail-server", mailServer);68        kubernetesSteps.createService("mail-server", 25, port);69        mailServer.initialize();70    }71    @Then("verify mail received")72    public void receiveMail() {73        MailRequest request = new MailRequest();74        request.setFrom("${from}");75        request.setTo("${to}");76        request.setCc("");77        request.setBcc("");78        request.setSubject("${subject}");79        request.setBody(new BodyPart("${message}", "text/plain"));80        runner.run(receive(mailServer)81                .message()82                .body(new ObjectMappingPayloadBuilder(request, mailServer.getMarshaller())));83    }84}...

BodyPart

Using AI Code Generation

1package com.consol.citrus.mail.actions;2import com.consol.citrus.mail.message.CitrusMailMessageHeaders;3import com.consol.citrus.mail.model.*;4import com.consol.citrus.message.Message;5import com.consol.citrus.testng.AbstractTestNGUnitTest;6import org.mockito.Mockito;7import org.springframework.beans.factory.annotation.Autowired;8import org.springframework.core.io.ClassPathResource;9import org.springframework.mail.javamail.MimeMessagePreparator;10import org.springframework.mail.javamail.MimeMessageHelp

BodyPart

Using AI Code Generation

1package com.consol.citrus.mail.actions;2import com.consol.citrus.mail.message.MailMessageHeaders;3import com.consol.citrus.mail.model.BodyPart;4import com.consol.citrus.mail.model.MailMessage;5import com.consol.citrus.message.Message;6import com.consol.citrus.testng.AbstractTestNGUnitTest;7import org.testng.Assert;8import org.testng.annotations.Test;9import java.util.ArrayList;10import java.util.List;11public class ReceiveMailActionTest extends AbstractTestNGUnitTest {12    private ReceiveMailAction receiveMailAction = new ReceiveMailAction();13    public void testBodyPart() {14        List<BodyPart> bodyPartList = new ArrayList<>();15        bodyPartList.add(new BodyPart().contentType("text/plain").body("Hello World"));16        bodyPartList.add(new BodyPart().contentType("text/html").body("<b>Hello World</b>"));17        MailMessage mailMessage = new MailMessage()18                .from("

BodyPart

Using AI Code Generation

1import com.consol.citrus.annotations.CitrusTest;2import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;3import com.consol.citrus.mail.model.BodyPart;4import com.consol.citrus.mail.model.MailMessage;5import com.consol.citrus.mail.model.MailMessageMarshaller;6import com.consol.citrus.message.MessageType;7import org.springframework.core.io.ClassPathResource;8import org.testng.annotations.Test;9import java.io.IOException;10import java.util.ArrayList;11import java.util.List;12public class BodyPartTest extends TestNGCitrusTestRunner {13    public void bodyPartTest() throws IOException {14        MailMessageMarshaller marshaller = new MailMessageMarshaller();15        MailMessage mailMessage = marshaller.unmarshalMessage(new ClassPathResource("mail-message.xml"));16        List<BodyPart> bodyParts = new ArrayList<>();17        BodyPart bodyPart = new BodyPart();18        bodyPart.setBody("<html><body><h1>Hello World</h1></body></html>");19        bodyPart.setContentType("text/html");20        bodyParts.add(bodyPart);21        mailMessage.setBodyParts(bodyParts);22        send(mailMessage)23                .messageType(MessageType.XML)24                .endpoint("smtpServer");25    }26}27import com.consol.citrus.annotations.CitrusTest;28import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;29import com.consol.citrus.mail.model.BodyPart;30import com.consol.citrus.mail.model.MailMessage;31import com.consol.citrus.mail.model.MailMessageMarshaller;32import com.consol.citrus.message.MessageType;33import org.springframework.core.io.ClassPathResource;34import org.testng.annotations.Test;35import java.io.IOException;36import java.util.ArrayList;37import java.util.List;38public class BodyPartTest extends TestNGCitrusTestRunner {39    public void bodyPartTest() throws IOException {40        MailMessageMarshaller marshaller = new MailMessageMarshaller();41        MailMessage mailMessage = marshaller.unmarshalMessage(new ClassPathResource("mail-message.xml"));42        List<BodyPart> bodyParts = new ArrayList<>();

BodyPart

Using AI Code Generation

1BodyPart bodyPart = new BodyPart();2bodyPart.setBody("Hello");3bodyPart.setBodyContentType("text/plain");4bodyPart.setBodyEncoding("UTF-8");5bodyPart.setBodyFileName("test.txt");6bodyPart.setBodyTransferEncoding("base64");7bodyPart.setBodyCharset("UTF-8");8bodyPart.setBodyId("testId");9bodyPart.setBodyDescription("testDescription");10bodyPart.setBodyDisposition("testDisposition");11bodyPart.setBodyLanguage("testLanguage");12bodyPart.setBodyMD5("testMD5");13bodyPart.setBodyLocation("testLocation");14bodyPart.setBodySize(10);15bodyPart.setBodyContentId("testContentId");16bodyPart.setBodyContentDescription("testContentDescription");17bodyPart.setBodyContentTransferEncoding("testContentTransferEncoding");18bodyPart.setBodyContentMD5("testContentMD5");19bodyPart.setBodyContentDisposition("testContentDisposition");20bodyPart.setBodyContentLanguage("testContentLanguage");21bodyPart.setBodyContentLocation("testContentLocation");22bodyPart.setBodyContentLength(10);23bodyPart.setBodyContentMD5("testContentMD5");24bodyPart.setBodyContentSubType("testContentSubType");25bodyPart.setBodyContentVersion("testContentVersion");26bodyPart.setBodyContentBase("testContentBase");27bodyPart.setBodyContentExtension("testContentExtension");28bodyPart.setBodyContentParameter("testContentParameter");29bodyPart.setBodyContentParameterValue("testContentParameterValue");30bodyPart.setBodyContentName("testContentName");31bodyPart.setBodyContentFileName("testContentFileName");32bodyPart.setBodyContentFileNameParameter("testContentFileNameParameter");33bodyPart.setBodyContentFileNameParameterValue("testContentFileNameParameterValue");34BodyPart bodyPart = new BodyPart();35bodyPart.setBody("Hello");36bodyPart.setBodyContentType("text/plain");37bodyPart.setBodyEncoding("UTF-8");38bodyPart.setBodyFileName("test.txt");39bodyPart.setBodyTransferEncoding("base64");40bodyPart.setBodyCharset("UTF-8");41bodyPart.setBodyId("testId");42bodyPart.setBodyDescription("testDescription");43bodyPart.setBodyDisposition("testDisposition");44bodyPart.setBodyLanguage("testLanguage");45bodyPart.setBodyMD5("testMD5");46bodyPart.setBodyLocation("testLocation");

BodyPart

Using AI Code Generation

1import com.consol.citrus.mail.model.*;2import com.consol.citrus.mail.model.Message;3import com.consol.citrus.mail.model.Attachment;4import com.consol.citrus.mail.model.TextAttachment;5import com.consol.citrus.mail.model.BinaryAttachment;6import com.consol.citrus.mail.model.MailMessageBuilder;7import com.consol.citrus.mail.model.MailMessage;8class 3{9    public static void main(String[] args) {10        BodyPart bodyPart = new BodyPart();11        bodyPart.setText("Hello World!");12        Message message = new Message();13        message.setBody("Hello World!");14        Attachment attachment = new Attachment();15        attachment.setBody("Hello World!");16        TextAttachment textAttachment = new TextAttachment();17        textAttachment.setBody("Hello World!");

BodyPart

Using AI Code Generation

1package com.consol.citrus.mail.actions;2import com.consol.citrus.mail.model.BodyPart;3import com.consol.citrus.mail.model.MailMessage;4import com.consol.citrus.testng.AbstractTestNGUnitTest;5import org.mockito.Mockito;6import org.springframework.core.io.ClassPathResource;7import org.springframework.mail.javamail.MimeMessageHelper;8import org.testng.Assert;9import org.testng.annotations.Test;10import javax.mail.MessagingException;11import javax.mail.internet.MimeMessage;12public class SendMailActionTest extends AbstractTestNGUnitTest {13    public void testSendMailWithAttachments() throws MessagingException {14        MimeMessage mimeMessage = Mockito.mock(MimeMessage.class);15        MimeMessageHelper mimeMessageHelper = new MimeMessageHelper(mimeMessage, true);16        SendMailAction sendMailAction = new SendMailAction();17        sendMailAction.setJavaMailSender(javaMailSender);18        sendMailAction.setMimeMessageHelper(mimeMessageHelper);19        sendMailAction.setMimeMessage(mimeMessage);20        MailMessage message = new MailMessage();21        message.setFrom("

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.