From 19e69366177799f7ccff75b6f4a1850ff0ca8d09 Mon Sep 17 00:00:00 2001
From: Eric Wong <e@80x24.org>
Date: Wed, 2 Dec 2015 11:11:06 +0000
Subject: dtas-mpd-emu: beginning of the MPD emulation proxy

Get basic commands and output buffering (in-memory) working.
The original mpd buffers large responses into memory, too,
so there probably isn't much concern for DoS-ing with slow
clients like a typical web server has.
---
 test/test_mpd_emu.rb | 73 ++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 73 insertions(+)
 create mode 100644 test/test_mpd_emu.rb

(limited to 'test/test_mpd_emu.rb')

diff --git a/test/test_mpd_emu.rb b/test/test_mpd_emu.rb
new file mode 100644
index 0000000..9c73ae9
--- /dev/null
+++ b/test/test_mpd_emu.rb
@@ -0,0 +1,73 @@
+# Copyright (C) 2013-2015 all contributors <dtas-all@nongnu.org>
+# License: GPLv3 or later (https://www.gnu.org/licenses/gpl-3.0.txt)
+require_relative 'helper'
+require 'socket'
+require 'dtas/mpd_emu_client'
+require 'dtas/server_loop'
+
+class TestMlib < Testcase
+  class Quit
+    attr_reader :to_io
+
+    def initialize
+      @to_io, @w = IO.pipe
+    end
+
+    def quit!
+      @w.close
+    end
+
+    def accept_nonblock(*args)
+      Thread.exit
+    end
+  end
+
+  def setup
+    @host = '127.0.0.1'
+    @l = TCPServer.new(@host, 0)
+    @port = @l.addr[1]
+    @quit = Quit.new
+    @klass = Class.new(DTAS::MpdEmuClient)
+    @svc = DTAS::ServerLoop.new([@l, @quit], @klass)
+    @th = Thread.new { @svc.run_forever }
+    @c = TCPSocket.new(@host, @port)
+    assert_match %r{\AOK.*MPD.*\n\z}, @c.gets
+  end
+
+  def teardown
+    @quit.quit!
+    @th.join
+    @quit.to_io.close
+    @l.close
+    @c.close unless @c.closed?
+  end
+
+  def test_ping
+    @c.write "ping\n"
+    assert_equal "OK\n", @c.gets
+    assert_nil IO.select([@c], nil, nil, 0)
+  end
+
+  # to ensure output buffering works:
+  module BigOutput
+    WAKE = IO.pipe
+    NR = 20000
+    OMG = ('OMG! ' * 99) << "OMG!\n"
+    def mpdcmd_big_output(*_)
+      rv = true
+      NR.times { rv = out(OMG) }
+      # tell the tester we're done writing to our buffer:
+      WAKE[1].write(rv == :wait_writable ? '.' : 'F')
+      rv
+    end
+  end
+
+  def test_big_output
+    @klass.__send__(:include, BigOutput)
+    @c.write "big_output\n"
+    assert_equal '.', BigOutput::WAKE[0].read(1), 'server blocked on write'
+    BigOutput::NR.times do
+      assert_equal BigOutput::OMG, @c.gets
+    end
+  end
+end
-- 
cgit v1.2.3-24-ge0c7