aboutsummaryrefslogtreecommitdiffstats
path: root/test/utils/server.rb
diff options
context:
space:
mode:
Diffstat (limited to 'test/utils/server.rb')
-rw-r--r--test/utils/server.rb62
1 files changed, 0 insertions, 62 deletions
diff --git a/test/utils/server.rb b/test/utils/server.rb
deleted file mode 100644
index 001a3fe..0000000
--- a/test/utils/server.rb
+++ /dev/null
@@ -1,62 +0,0 @@
-require "timeout"
-
-module ServerUtils
- def open_server_connection(scheme = :https)
- @_io = StringIO.new
- @_con = (scheme == :https ? ServerConnection : HTTPServerConnection).new(@_io.method(:write))
- @_con << Connection::CLIENT_CONNECTION_PREFACE
- @_con << Frame::Settings.new.assemble
- if block_given?
- yield @_con
- else
- @_con
- end
- end
-
- def open_new_stream(arg1 = nil, state: :idle, **kwargs)
- if arg1.is_a?(ServerConnection)
- con = arg1
- else
- con = open_server_connection
- end
-
- @_stream = con.instance_eval { stream(@max_stream_ids[1] + 2) }
- @_stream.set_state(state)
- @_stream.update_dependency(**kwargs)
- if block_given?
- yield @_stream
- else
- @_stream
- end
- end
-
- def sent_frames(io = nil)
- resp = (io || @_io).string.dup.force_encoding(Encoding::BINARY)
- frames = []
- while f = Frame.parse!(resp)
- frames << f
- end
- frames
- end
-
- def parse_frames(io, &blk)
- pos = io.string.bytesize
- blk.call
- resp = io.string.byteslice(pos, io.string.bytesize - pos).force_encoding(Encoding::BINARY)
- frames = []
- while f = Frame.parse!(resp)
- frames << f
- end
- frames
- end
-
- def parse_frame(io, &blk)
- frames = capture_frames(io, &blk)
- assert_equal(1, frames.size, "Supplied block sent no frames or more than 1 frame")
- frames.first
- end
-end
-
-class Minitest::Test
- include ServerUtils
-end