Sha256: 239f4723c8b5789a67b1f2c681326c2bb7c874c1f803325f19a383c35d7e7859
Contents?: true
Size: 1.1 KB
Versions: 9
Compression:
Stored size: 1.1 KB
Contents
require "symmetric-encryption"
module RocketJob
module Sliced
# Compress the records within a slice
class EncryptedSlice < ::RocketJob::Sliced::Slice
private
def parse_records
# Convert BSON::Binary to a string
encrypted_str = attributes.delete("records").data
header = SymmetricEncryption::Header.new
header.parse(encrypted_str)
# Use the header that is present to decrypt the data, since its version could be different
decrypted_str = header.cipher.binary_decrypt(encrypted_str, header: header)
@records = Hash.from_bson(BSON::ByteBuffer.new(decrypted_str))["r"]
end
def serialize_records
return [] if @records.nil? || @records.empty?
# Convert slice of records into a single string
str = {"r" => to_a}.to_bson.to_s
# Encrypt to binary without applying an encoding such as Base64
# Use a random_iv with each encryption for better security
data = SymmetricEncryption.cipher.binary_encrypt(str, random_iv: true, compress: true)
BSON::Binary.new(data)
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems