| // Copyright 2021 The Chromium OS Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| #include <string> |
| |
| #include <base/memory/ref_counted.h> |
| #include <base/optional.h> |
| #include <base/strings/string_piece.h> |
| |
| #include "missive/proto/record.pb.h" |
| |
| #ifndef MISSIVE_COMPRESSION_DECOMPRESSION_H_ |
| #define MISSIVE_COMPRESSION_DECOMPRESSION_H_ |
| |
| namespace reporting { |
| |
| class Decompression : public base::RefCountedThreadSafe<Decompression> { |
| public: |
| // Not copyable or movable |
| Decompression(const Decompression& other) = delete; |
| Decompression& operator=(const Decompression& other) = delete; |
| |
| // Factory method creates |Decompression| object. |
| static scoped_refptr<Decompression> Create(); |
| |
| // DecompressRecord will decompress the provided |record| and respond |
| // with the callback. The compression_information provided will determine |
| // which compression algorithm is used. On success the returned std::string |
| // sink will contain a decompressed EncryptedWrappedRecord string. The sink |
| // string then can be further updated by the caller. std::string is used |
| // instead of base::StringPiece because ownership is taken of |record| through |
| // std::move(record). |
| static std::string DecompressRecord( |
| std::string record, CompressionInformation compression_information); |
| |
| protected: |
| // Constructor can only be called by |Create| factory method. |
| Decompression(); |
| |
| // Refcounted object must have destructor declared protected or private. |
| virtual ~Decompression(); |
| |
| private: |
| friend base::RefCountedThreadSafe<Decompression>; |
| |
| // Decompresses a record using snappy |
| static std::string DecompressRecordSnappy(std::string record); |
| }; |
| |
| } // namespace reporting |
| |
| #endif // MISSIVE_COMPRESSION_DECOMPRESSION_H_ |