Contents

# encoding: utf-8
# This file is part of ruby-flores.
# Copyright (C) 2015 Jordan Sissel
# 
require "flores/rspec"
require "flores/random"
require "socket"

RSpec.configure do |config|
  Kernel.srand config.seed
  Flores::RSpec.configure(config)

  # Demonstrate the wonderful Analyze formatter
  config.add_formatter("Flores::RSpec::Formatters::Analyze")
end

# A factory for encapsulating behavior of a tcp server and client for the
# purposes of testing.
#
# This is probably not really a "factory" in a purist-sense, but whatever.
class TCPIntegrationTestFactory
  def initialize(port)
    @listener = Socket.new(Socket::AF_INET, Socket::SOCK_STREAM, 0)
    @client = Socket.new(Socket::AF_INET, Socket::SOCK_STREAM, 0)
    @port = port
  end

  def teardown
    @listener.close unless @listener.closed?
    @client.close unless @listener.closed?
  end

  def sockaddr
    Socket.sockaddr_in(@port, "127.0.0.1")
  end

  def setup
    @listener.bind(sockaddr)
    @listener.listen(5)
  end

  def send_and_receive(text)
    @client.connect(sockaddr)
    server, _ = @listener.accept

    @client.syswrite(text)
    @client.close
    data = server.read
    data.force_encoding(Encoding.default_external).encoding
    data
  ensure
    @client.close unless @client.closed?
    server.close unless server.nil? || server.closed?
  end
end

describe "TCPServer+TCPSocket" do
  analyze_results

  let(:port) { Flores::Random.integer(1024..65535) }
  let(:text) { Flores::Random.text(1..2000) }
  subject { TCPIntegrationTestFactory.new(port) }

  before do
    begin
      subject.setup
    rescue Errno::EADDRINUSE
      skip "Port #{port} was in use. Skipping!"
    end
  end
  
  stress_it "should send data correctly", [:port, :text] do
    begin
      received = subject.send_and_receive(text)
      expect(received.encoding).to(be == text.encoding)
      expect(received).to(be == text)
    ensure
      subject.teardown
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
flores-0.0.8	examples/socket_acceptance_spec.rb