Adding upstream version 18.2.2.upstream/18.2.2

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 64 insertions, 0 deletions

diff --git a/src/arrow/c_glib/test/flight/test-client.rb b/src/arrow/c_glib/test/flight/test-client.rb
new file mode 100644
index 000000000..f6660a4ca
--- /dev/null
+++ b/src/arrow/c_glib/test/flight/test-client.rb
@@ -0,0 +1,64 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+
+class TestFlightClient < Test::Unit::TestCase
+  include Helper::Omittable
+
+  def setup
+    @server = nil
+    omit("Arrow Flight is required") unless defined?(ArrowFlight)
+    omit("Unstable on Windows") if Gem.win_platform?
+    require_gi_bindings(3, 4, 7)
+    @server = Helper::FlightServer.new
+    host = "127.0.0.1"
+    location = ArrowFlight::Location.new("grpc://#{host}:0")
+    options = ArrowFlight::ServerOptions.new(location)
+    @server.listen(options)
+    @location = ArrowFlight::Location.new("grpc://#{host}:#{@server.port}")
+  end
+
+  def teardown
+    return if @server.nil?
+    @server.shutdown
+  end
+
+  def test_list_flights
+    client = ArrowFlight::Client.new(@location)
+    generator = Helper::FlightInfoGenerator.new
+    assert_equal([generator.page_view],
+                 client.list_flights)
+  end
+
+  sub_test_case("#do_get") do
+    def test_success
+      client = ArrowFlight::Client.new(@location)
+      info = client.list_flights.first
+      endpoint = info.endpoints.first
+      generator = Helper::FlightInfoGenerator.new
+      reader = client.do_get(endpoint.ticket)
+      assert_equal(generator.page_view_table,
+                   reader.read_all)
+    end
+
+    def test_error
+      client = ArrowFlight::Client.new(@location)
+      assert_raise(Arrow::Error::Invalid) do
+        client.do_get(ArrowFlight::Ticket.new("invalid"))
+      end
+    end
+  end
+end