This is an automated email from the ASF dual-hosted git repository.
btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit a96ce1486b3b1cdadca517dd85bdc46a5a7af080
Author: Rémi Kowalski <rkowal...@linagora.com>
AuthorDate: Thu Sep 19 09:35:51 2019 +0200
JAMES-2813 add dto to serialize ReprocessingContextInformation
---
.../indexer/ReprocessingContextInformationDTO.java | 137 +++++++++++++++++++++
1 file changed, 137 insertions(+)
diff --git
a/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/ReprocessingContextInformationDTO.java
b/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/ReprocessingContextInformationDTO.java
new file mode 100644
index 0000000..7d5c27d
--- /dev/null
+++
b/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/ReprocessingContextInformationDTO.java
@@ -0,0 +1,137 @@
+/****************************************************************
+ * Licensed to the Apache Software Foundation (ASF) under one *
+ * or more contributor license agreements. See the NOTICE file *
+ * distributed with this work for additional information *
+ * regarding copyright ownership. The ASF licenses this file *
+ * to you under the Apache License, Version 2.0 (the *
+ * "License"); you may not use this file except in compliance *
+ * with the License. You may obtain a copy of the License at *
+ * *
+ * http://www.apache.org/licenses/LICENSE-2.0 *
+ * *
+ * Unless required by applicable law or agreed to in writing, *
+ * software distributed under the License is distributed on an *
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY *
+ * KIND, either express or implied. See the License for the *
+ * specific language governing permissions and limitations *
+ * under the License. *
+ ****************************************************************/
+package org.apache.mailbox.tools.indexer;
+
+import java.util.Collection;
+import java.util.List;
+import java.util.Map;
+import java.util.function.Function;
+import java.util.stream.Stream;
+
+import org.apache.james.json.DTOModule;
+import org.apache.james.mailbox.MessageUid;
+import org.apache.james.mailbox.indexer.ReIndexingExecutionFailures;
+import org.apache.james.mailbox.model.MailboxId;
+import org.apache.james.server.task.json.dto.AdditionalInformationDTO;
+import org.apache.james.server.task.json.dto.AdditionalInformationDTOModule;
+import org.apache.james.task.TaskType;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.github.steveash.guavate.Guavate;
+import com.google.common.collect.ImmutableList;
+import com.google.common.collect.ImmutableListMultimap;
+
+public class ReprocessingContextInformationDTO implements
AdditionalInformationDTO {
+
+ public static class ReindexingFailureDTO {
+
+ private final String mailboxId;
+ private final List<Long> uids;
+
+ private ReindexingFailureDTO(@JsonProperty("mailboxId") String
mailboxId, @JsonProperty("uids") List<Long> uids) {
+ this.mailboxId = mailboxId;
+ this.uids = uids;
+ }
+
+ public String getMailboxId() {
+ return mailboxId;
+ }
+
+ public List<Long> getUids() {
+ return uids;
+ }
+ }
+
+ public static final Function<TaskType, Function<MailboxId.Factory,
AdditionalInformationDTOModule<ReprocessingContextInformation,
ReprocessingContextInformationDTO>>> SERIALIZATION_MODULE =
+ taskType -> factory ->
+ DTOModule.forDomainObject(ReprocessingContextInformation.class)
+ .convertToDTO(ReprocessingContextInformationDTO.class)
+ .toDomainObjectConverter(dto -> new
ReprocessingContextInformation(dto.successfullyReprocessedMailCount,
dto.failedReprocessedMailCount, deserializeFailures(factory, dto.failures)))
+ .toDTOConverter((details, type) -> new
ReprocessingContextInformationDTO(details.getSuccessfullyReprocessedMailCount(),
details.getFailedReprocessedMailCount(),
serializeFailures(details.failures())))
+ .typeName(taskType.asString())
+ .withFactory(AdditionalInformationDTOModule::new);
+
+ static ReIndexingExecutionFailures deserializeFailures(MailboxId.Factory
mailboxIdFactory,
+
List<ReindexingFailureDTO> failures) {
+ List<ReIndexingExecutionFailures.ReIndexingFailure> reIndexingFailures
= failures
+ .stream()
+ .flatMap(failuresForMailbox ->
+ getReIndexingFailureStream(mailboxIdFactory,
failuresForMailbox))
+ .collect(Guavate.toImmutableList());
+
+ return new ReIndexingExecutionFailures(reIndexingFailures);
+ }
+
+ private static Stream<ReIndexingExecutionFailures.ReIndexingFailure>
getReIndexingFailureStream(MailboxId.Factory mailboxIdFactory,
ReindexingFailureDTO failuresForMailbox) {
+ return failuresForMailbox.uids
+ .stream()
+ .map(uid ->
+ new
ReIndexingExecutionFailures.ReIndexingFailure(mailboxIdFactory.fromString(failuresForMailbox.mailboxId),
MessageUid.of(uid)));
+ }
+
+
+ static List<ReindexingFailureDTO>
serializeFailures(ReIndexingExecutionFailures failures) {
+ ImmutableListMultimap<MailboxId,
ReIndexingExecutionFailures.ReIndexingFailure> failuresByMailbox =
failures.failures()
+ .stream()
+
.collect(Guavate.toImmutableListMultimap(ReIndexingExecutionFailures.ReIndexingFailure::getMailboxId));
+
+ return failuresByMailbox
+ .asMap()
+ .entrySet()
+ .stream()
+ .map(failureByMailbox ->
+ new ReindexingFailureDTO(
+ failureByMailbox.getKey().serialize(),
+ extractMessageUidsFromFailure(failureByMailbox)))
+ .collect(Guavate.toImmutableList());
+ }
+
+ private static ImmutableList<Long>
extractMessageUidsFromFailure(Map.Entry<MailboxId,
Collection<ReIndexingExecutionFailures.ReIndexingFailure>> failureByMailbox) {
+ return failureByMailbox
+ .getValue()
+ .stream()
+ .map(failure -> failure.getUid().asLong())
+ .collect(Guavate.toImmutableList());
+ }
+
+ private final int successfullyReprocessedMailCount;
+ private final int failedReprocessedMailCount;
+ private final List<ReindexingFailureDTO> failures;
+
+
+
ReprocessingContextInformationDTO(@JsonProperty("successfullyReprocessedMailCount")
int successfullyReprocessedMailCount,
+
@JsonProperty("failedReprocessedMailCount") int failedReprocessedMailCount,
+ @JsonProperty("failures")
List<ReindexingFailureDTO> failures) {
+ this.successfullyReprocessedMailCount =
successfullyReprocessedMailCount;
+ this.failedReprocessedMailCount = failedReprocessedMailCount;
+ this.failures = failures;
+ }
+
+ public int getSuccessfullyReprocessedMailCount() {
+ return successfullyReprocessedMailCount;
+ }
+
+ public int getFailedReprocessedMailCount() {
+ return failedReprocessedMailCount;
+ }
+
+ public List<ReindexingFailureDTO> getFailures() {
+ return failures;
+ }
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org
