in mailbox/event/json/src/main/scala/org/apache/james/event/json/MailboxEventSerializer.scala [139:243]
private def toScala(event: JavaMailboxACLUpdated): DTO.MailboxACLUpdated = DTO.MailboxACLUpdated(
eventId = event.getEventId,
sessionId = event.getSessionId,
user = event.getUsername,
mailboxPath = MailboxPath.fromJava(event.getMailboxPath),
aclDiff = ACLDiff.fromJava(event.getAclDiff),
mailboxId = event.getMailboxId)
private def toScala(event: JavaMailboxAdded): DTO.MailboxAdded = DTO.MailboxAdded(
eventId = event.getEventId,
mailboxPath = MailboxPath.fromJava(event.getMailboxPath),
mailboxId = event.getMailboxId,
user = event.getUsername,
sessionId = event.getSessionId)
private def toScala(event: JavaMailboxDeletion): DTO.MailboxDeletion = DTO.MailboxDeletion(
eventId = event.getEventId,
sessionId = event.getSessionId,
user = event.getUsername,
quotaRoot = event.getQuotaRoot,
path = MailboxPath.fromJava(event.getMailboxPath),
mailboxACL = MailboxACL.fromJava(event.getMailboxACL),
deletedMessageCount = event.getDeletedMessageCount,
totalDeletedSize = event.getTotalDeletedSize,
mailboxId = event.getMailboxId)
private def toScala(event: JavaMailboxRenamed): DTO.MailboxRenamed = DTO.MailboxRenamed(
eventId = event.getEventId,
sessionId = event.getSessionId,
user = event.getUsername,
path = MailboxPath.fromJava(event.getMailboxPath),
mailboxId = event.getMailboxId,
newPath = MailboxPath.fromJava(event.getNewPath))
private def toScala(event: JavaQuotaUsageUpdatedEvent): DTO.QuotaUsageUpdatedEvent = DTO.QuotaUsageUpdatedEvent(
eventId = event.getEventId,
user = event.getUsername,
quotaRoot = event.getQuotaRoot,
countQuota = Quota.toScala(event.getCountQuota),
sizeQuota = Quota.toScala(event.getSizeQuota),
time = event.getInstant)
private def toScala(event: JavaAdded): DTO.Added = DTO.Added(
eventId = event.getEventId,
sessionId = event.getSessionId,
user = event.getUsername,
path = MailboxPath.fromJava(event.getMailboxPath),
mailboxId = event.getMailboxId,
added = event.getAdded.asScala.view.mapValues(DTOs.MessageMetaData.fromJava).toMap,
isDelivery = Option(IsDelivery(event.isDelivery)),
isAppended = Option(IsAppended(event.isAppended)),
movedFromMailboxId = event.movedFromMailboxId().toScala)
private def toScala(event: JavaExpunged): DTO.Expunged = DTO.Expunged(
eventId = event.getEventId,
sessionId = event.getSessionId,
user = event.getUsername,
path = MailboxPath.fromJava(event.getMailboxPath),
mailboxId = event.getMailboxId,
expunged = event.getExpunged.asScala.view.mapValues(DTOs.MessageMetaData.fromJava).toMap,
movedToMailboxId = event.movedToMailboxId.toScala)
private def toScala(event: JavaMessageMoveEvent): DTO.MessageMoveEvent = DTO.MessageMoveEvent(
eventId = event.getEventId,
user = event.getUsername,
previousMailboxIds = event.getMessageMoves.getPreviousMailboxIds.asScala.toSet,
targetMailboxIds = event.getMessageMoves.getTargetMailboxIds.asScala.toSet,
messageIds = event.getMessageIds.asScala.toSet)
private def toScala(event: JavaFlagsUpdated): DTO.FlagsUpdated = DTO.FlagsUpdated(
eventId = event.getEventId,
sessionId = event.getSessionId,
user = event.getUsername,
path = DTOs.MailboxPath.fromJava(event.getMailboxPath),
mailboxId = event.getMailboxId,
updatedFlags = event.getUpdatedFlags.asScala.toList.map(DTOs.UpdatedFlags.toUpdatedFlags))
private def toScala(event: JavaMailboxSubscribedEvent): DTO.MailboxSubscribedEvent = DTO.MailboxSubscribedEvent(
eventId = event.getEventId,
mailboxPath = MailboxPath.fromJava(event.getMailboxPath),
mailboxId = event.getMailboxId,
user = event.getUsername,
sessionId = event.getSessionId)
private def toScala(event: JavaMailboxUnsubscribedEvent): DTO.MailboxUnSubscribedEvent = DTO.MailboxUnSubscribedEvent(
eventId = event.getEventId,
mailboxPath = MailboxPath.fromJava(event.getMailboxPath),
mailboxId = event.getMailboxId,
user = event.getUsername,
sessionId = event.getSessionId)
def toScala(javaEvent: JavaEvent): Event = javaEvent match {
case e: JavaAdded => toScala(e)
case e: JavaExpunged => toScala(e)
case e: JavaFlagsUpdated => toScala(e)
case e: JavaMailboxACLUpdated => toScala(e)
case e: JavaMailboxAdded => toScala(e)
case e: JavaMailboxDeletion => toScala(e)
case e: JavaMailboxRenamed => toScala(e)
case e: JavaMessageMoveEvent => toScala(e)
case e: JavaQuotaUsageUpdatedEvent => toScala(e)
case e: JavaMailboxSubscribedEvent => toScala(e)
case e: JavaMailboxUnsubscribedEvent => toScala(e)
case _ => throw new RuntimeException("no Scala conversion known")
}