Class: Imap::Backup::Serializer::DelayedMetadataSerializer
- Inherits:
-
Object
- Object
- Imap::Backup::Serializer::DelayedMetadataSerializer
- Extended by:
- Forwardable
- Defined in:
- lib/imap/backup/serializer/delayed_metadata_serializer.rb
Overview
Wraps the Serializer, delaying metadata appends
Instance Method Summary collapse
-
#append(uid, message, flags) ⇒ void
Appends a message to the mbox file and adds the metadata to the transaction.
-
#initialize(serializer:) ⇒ DelayedMetadataSerializer
constructor
A new instance of DelayedMetadataSerializer.
-
#transaction(&block) ⇒ void
Initializes the metadata and mailbox transactions, then calls the supplied block.
Constructor Details
#initialize(serializer:) ⇒ DelayedMetadataSerializer
Returns a new instance of DelayedMetadataSerializer.
20 21 22 23 |
# File 'lib/imap/backup/serializer/delayed_metadata_serializer.rb', line 20 def initialize(serializer:) @serializer = serializer @tsx = nil end |
Instance Method Details
#append(uid, message, flags) ⇒ void
This method returns an undefined value.
Appends a message to the mbox file and adds the metadata to the transaction
52 53 54 55 56 57 58 |
# File 'lib/imap/backup/serializer/delayed_metadata_serializer.rb', line 52 def append(uid, , flags) tsx.fail_outside_transaction!(:append) = Email::Mboxrd::Message.new() serialized = .to_serialized tsx.data[:metadata] << {uid: uid, length: serialized.bytesize, flags: flags} mbox.append(serialized) end |
#transaction(&block) ⇒ void
This method returns an undefined value.
Initializes the metadata and mailbox transactions, then calls the supplied block. Once the block has finished, commits changes to metadata
31 32 33 34 35 36 37 38 39 40 41 42 43 |
# File 'lib/imap/backup/serializer/delayed_metadata_serializer.rb', line 31 def transaction(&block) tsx.fail_in_transaction!(:transaction, message: "nested transactions are not supported") tsx.begin({metadata: []}) do mbox.transaction do block.call commit serializer.reload end end end |