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.
18 19 20 21 |
# File 'lib/imap/backup/serializer/delayed_metadata_serializer.rb', line 18 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
50 51 52 53 54 55 56 |
# File 'lib/imap/backup/serializer/delayed_metadata_serializer.rb', line 50 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
29 30 31 32 33 34 35 36 37 38 39 40 41 |
# File 'lib/imap/backup/serializer/delayed_metadata_serializer.rb', line 29 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 |