firefox.rb

begin
    to_process = []
    h2g = H2.new
    host = ARGV[0] || "www.fastly.com"
    puts "#######################"
    puts "# #{host}"
    puts "#######################"
    h2g.connect(host)
    h2g.send_prefix()
    h2g.send_settings([[2,0]])
    open_streams = {}
    # Ack settings
    while true do
        f = h2g.read(-1)
        puts f.to_s
        if f.type == "SETTINGS" and (f.flags & 1 == 1) then
            next
        elsif f.type == "SETTINGS" then
            h2g.send_settings_ack()
            break
        else
            to_process << f
        end
    end
    to_process.each do |f|
        puts f.to_s
    end

    h2g.send_priority(3, 0, 1, 201)
    h2g.send_priority(5, 0, 0, 101)
    h2g.send_priority(7, 0, 0, 1)
    h2g.send_priority(9, 7, 0, 1)
    h2g.send_priority(11, 3, 0, 1)
    prio_low = H2Priority.new(0, 0, 16)
    prio_high = H2Priority.new(0, 0, 32)
    req = {
        ":method" => "GET",
        ":authority" => host,
        ":scheme" => "https",
    }
    req1 = req.merge(":path" => "/?1")
    req2 = req.merge(":path" => "/?2")
    h2g.send_headers(req1, 15, PRIORITY | END_STREAM, prio_low)
    h2g.send_continuation({}, 15, END_HEADERS)
    h2g.send_headers(req2, 17, 37, prio_low)
    # Send ping frame (type=0x6) to test send_raw_frame
    h2g.send_raw_frame(0, 0x6, 0, "76543210")
    open_streams[15] = 1
    open_streams[17] = 1
    while open_streams.length > 0
        f = h2g.read(-1)
        puts "type:#{f.type}, stream_id:#{f.stream_id}, len:#{f.len}, flags:#{f.flags}"
        if f.type == "GOAWAY" then
            puts f.to_s
        elsif f.type == "PING" then
            f.ack()
        elsif f.type == "SETTINGS" then
            puts f.to_s
        elsif f.type == "DATA" and f.len > 0 then
            h2g.send_window_update(0, f.len)
            h2g.send_window_update(f.stream_id, f.len)
        elsif f.type == "HEADERS" then
            puts f.to_s
        end

        if f.type == "DATA" or f.type == "HEADERS" then
            if f.is_end_stream
                open_streams.delete(f.stream_id)
            end
        end
    end
    h2g.close()
    h2g.destroy()
rescue => e
    p e
    exit 1
end