[JAMES-2809] DeletedMessageVault implementation of append & search (full scan version) on top of BlobStore

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.4.0
• Component/s: deletedMessageVault
• Assignee: Unassigned
• Reporter: Benoit Tellier
• Created: 24/Jun/19 10:15
• Updated: 09/Jul/19 07:29
• Resolved: 09/Jul/19 07:28

Description

You will write a BlobStore based DeletedMessageVault implementation where it has:

• a dedicated component(DeletedMessageMetadataVault) to store metadata in order to have reasonable searching performance (JAMES-2807)
• the capability of choosing bucket in BlobStore as the proposal JAMES-2806 described

1. Append
   you also have to implement a related method loadMimeMessage()

class BlobStoreDeletedMessageVault implements DeletedMessageVault {
    private final DeletedMessageMetadataVault metadataVault;
    private final BlobStore blobStore;

    Mono<Void> append(User user, DeletedMessage message, InputStream mimeMessage) {
        BlobId deletedMessageFileName = calculateFileName(message);
        blobStore
            .store(mimeMessage, deletedMessageFileName, calculateCurrentBucket());
        metadataVault.store(calculateCurrentBucket(), message);
    }

    Mono<InputStream> loadMimeMessage(User user, MessageId messageId) {
        ....
    }
}

Pattern for BucketName: `deletedMessages-2019-06-01` where 2019 is the year and 06 the month. 01 is used to later allow smaller bucket definition.

1. Searching ontop of DeletedMessageMetadataVault JAMES-2807

• retrieve all available buckets from DeletedMessageMetadataVault
• for each bucket, use retrieve all deleted message metadata of corresponding user
• filter records match with query criteria

class BlobStoreDeletedMessageVault implements DeletedMessageVault {
    
    private DeletedMessageMetadataVault metadataVault;

    Flux<DeletedMessage> search(User user, Query query) {
        return metadataVault.listContainers()
            .flatMap(containerName -> metadataVault.listMessages(containerName, user))
            .filter(deletedMessage -> matches(deletedMessage, query));
    }
}