RDCNDecompressor.cpp 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101
  1. /* Copyright (C) Teemu Suutari */
  2. #include "RDCNDecompressor.hpp"
  3. #include "InputStream.hpp"
  4. #include "OutputStream.hpp"
  5. #include "common/Common.hpp"
  6. namespace ancient::internal
  7. {
  8. bool RDCNDecompressor::detectHeaderXPK(uint32_t hdr) noexcept
  9. {
  10. return hdr==FourCC("RDCN");
  11. }
  12. std::shared_ptr<XPKDecompressor> RDCNDecompressor::create(uint32_t hdr,uint32_t recursionLevel,const Buffer &packedData,std::shared_ptr<XPKDecompressor::State> &state,bool verify)
  13. {
  14. return std::make_shared<RDCNDecompressor>(hdr,recursionLevel,packedData,state,verify);
  15. }
  16. RDCNDecompressor::RDCNDecompressor(uint32_t hdr,uint32_t recursionLevel,const Buffer &packedData,std::shared_ptr<XPKDecompressor::State> &state,bool verify) :
  17. XPKDecompressor(recursionLevel),
  18. _packedData(packedData)
  19. {
  20. if (!detectHeaderXPK(hdr)) throw Decompressor::InvalidFormatError();
  21. }
  22. RDCNDecompressor::~RDCNDecompressor()
  23. {
  24. // nothing needed
  25. }
  26. const std::string &RDCNDecompressor::getSubName() const noexcept
  27. {
  28. static std::string name="XPK-RDCN: Ross data compression";
  29. return name;
  30. }
  31. void RDCNDecompressor::decompressImpl(Buffer &rawData,const Buffer &previousData,bool verify)
  32. {
  33. ForwardInputStream inputStream(_packedData,0,_packedData.size());
  34. MSBBitReader<ForwardInputStream> bitReader(inputStream);
  35. auto readBit=[&]()->uint32_t
  36. {
  37. return bitReader.readBitsBE16(1);
  38. };
  39. auto readByte=[&]()->uint8_t
  40. {
  41. return inputStream.readByte();
  42. };
  43. ForwardOutputStream outputStream(rawData,0,rawData.size());
  44. while (!outputStream.eof())
  45. {
  46. if (!readBit())
  47. {
  48. outputStream.writeByte(readByte());
  49. } else {
  50. uint8_t tmp=readByte();
  51. uint32_t count=tmp&0xf;
  52. uint32_t code=tmp>>4;
  53. uint32_t distance=0;
  54. uint8_t repeatChar=0;
  55. bool doRLE=false;
  56. switch (code)
  57. {
  58. case 0:
  59. repeatChar=readByte();
  60. count+=3;
  61. doRLE=true;
  62. break;
  63. case 1:
  64. count=(count|(uint32_t(readByte())<<4))+19;
  65. repeatChar=readByte();
  66. doRLE=true;
  67. break;
  68. case 2:
  69. distance=(count|(uint32_t(readByte())<<4))+3;
  70. count=uint32_t(readByte())+16;
  71. break;
  72. default: /* 3 to 15 */
  73. distance=(count|(uint32_t(readByte())<<4))+3;
  74. count=code;
  75. break;
  76. }
  77. if (doRLE)
  78. {
  79. for (uint32_t i=0;i<count;i++) outputStream.writeByte(repeatChar);
  80. } else {
  81. outputStream.copy(distance,count);
  82. }
  83. }
  84. }
  85. }
  86. }