Class: HTTP2::Header::Decompressor
- Inherits:
-
Object
- Object
- HTTP2::Header::Decompressor
- Defined in:
- lib/http/2/compressor.rb
Overview
Responsible for decoding received headers and maintaining compression context of the opposing peer. Decompressor must be initialized with appropriate starting context based on local role: client or server.
Instance Method Summary collapse
-
#decode(buf) ⇒ Array
Decodes and processes header commands within provided buffer.
-
#header(buf) ⇒ Hash
Decodes header command from provided buffer.
-
#initialize(**options) ⇒ Decompressor
constructor
A new instance of Decompressor.
-
#integer(buf, n) ⇒ Integer
Decodes integer value from provided buffer.
-
#set_table_size(size) ⇒ Object
Set header table size in EncodingContext.
-
#string(buf) ⇒ String
Decodes string value from provided buffer.
Constructor Details
#initialize(**options) ⇒ Decompressor
Returns a new instance of Decompressor.
477 478 479 |
# File 'lib/http/2/compressor.rb', line 477 def initialize(**) @cc = EncodingContext.new() end |
Instance Method Details
#decode(buf) ⇒ Array
Decodes and processes header commands within provided buffer.
561 562 563 564 565 |
# File 'lib/http/2/compressor.rb', line 561 def decode(buf) list = [] list << @cc.process(header(buf)) while !buf.empty? list.compact end |
#header(buf) ⇒ Hash
Decodes header command from provided buffer.
526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 |
# File 'lib/http/2/compressor.rb', line 526 def header(buf) peek = buf.readbyte(0) header = {} header[:type], type = HEADREP.select do |t, desc| mask = (peek >> desc[:prefix]) << desc[:prefix] mask == desc[:pattern] end.first header[:type] or raise CompressionError header[:name] = integer(buf, type[:prefix]) case header[:type] when :indexed header[:name] == 0 and raise CompressionError.new header[:name] -= 1 when :changetablesize header[:value] = header[:name] else if header[:name] == 0 header[:name] = string(buf) else header[:name] -= 1 end header[:value] = string(buf) end header end |
#integer(buf, n) ⇒ Integer
Decodes integer value from provided buffer.
492 493 494 495 496 497 498 499 500 501 502 503 504 505 |
# File 'lib/http/2/compressor.rb', line 492 def integer(buf, n) limit = 2**n - 1 i = !n.zero? ? (buf.getbyte & limit) : 0 m = 0 while byte = buf.getbyte do i += ((byte & 127) << m) m += 7 break if (byte & 128).zero? end if (i == limit) i end |
#set_table_size(size) ⇒ Object
Set header table size in EncodingContext
483 484 485 |
# File 'lib/http/2/compressor.rb', line 483 def set_table_size(size) @cc.set_table_size(size) end |
#string(buf) ⇒ String
Decodes string value from provided buffer.
512 513 514 515 516 517 518 519 520 |
# File 'lib/http/2/compressor.rb', line 512 def string(buf) huffman = (buf.readbyte(0) & 0x80) == 0x80 len = integer(buf, 7) str = buf.read(len) str.bytesize == len or raise CompressionError.new("string too short") huffman and str = Huffman.new.decode(Buffer.new(str)) str = str.force_encoding('utf-8') str end |