chore: Use the cucumber tests from the conformance repo (#68)

Signed-off-by: Daniel Azuma <[email protected]>

Author: dazuma

.gitignore

@@ -6,3 +6,4 @@ coverage/
 doc/
 pkg/
 tmp/
+features/conformance

.toys/ci.rb

@@ -17,6 +17,7 @@ def handle_result result
 def run
   ::Dir.chdir context_directory
   exec_tool ["test"], name: "Tests"
+  exec_tool ["cucumber"], name: "Behaviors"
   exec_tool ["rubocop"], name: "Style checker"
   exec_tool ["yardoc"], name: "Docs generation"
   exec_tool ["build"], name: "Gem build"

.toys/cucumber.rb

@@ -0,0 +1,27 @@
+# frozen_string_literal: true
+
+toys_version! ">= 0.12"
+
+desc "Run cucumber tests"
+
+remaining_args :features
+
+include :bundler
+include :exec, e: true
+include :git_cache
+include :fileutils
+
+def run
+  setup_features
+  cmd = ["cucumber", "--publish-quiet"]
+  cmd += (verbosity > 0 ? ["--format=pretty"] : ["--format=progress"])
+  cmd += features
+  exec cmd
+end
+
+def setup_features
+  remote_features = git_cache.find "https://github.com/cloudevents/conformance", path: "features"
+  local_features = File.join context_directory, "features", "conformance"
+  rm_rf local_features
+  cp_r remote_features, local_features
+end

Gemfile

@@ -1,10 +1,12 @@
 source "https://rubygems.org"
 gemspec
 
+gem "cucumber", "7.0"
 gem "google-style", "~> 1.25.1"
 gem "minitest", "~> 5.14"
 gem "minitest-focus", "~> 1.1"
 gem "minitest-rg", "~> 5.2"
 gem "rack", "~> 2.2"
 gem "redcarpet", "~> 3.5" unless ::RUBY_PLATFORM == "java"
+gem "webrick", "~> 1.7"
 gem "yard", "~> 0.9.25"

examples/server/app.rb

@@ -4,6 +4,6 @@
 cloud_events_http = CloudEvents::HttpBinding.default
 
 post "/" do
-  event = cloud_events_http.decode_rack_env request.env
+  event = cloud_events_http.decode_event request.env
   logger.info "Received CloudEvent: #{event.to_h}"
 end

features/step_definitions/steps.rb

@@ -0,0 +1,61 @@
+# frozen_string_literal: true
+
+require "webrick"
+require "stringio"
+require "rack"
+
+Given "HTTP Protocol Binding is supported" do
+  @http_binding = CloudEvents::HttpBinding.default
+end
+
+Given "an HTTP request" do |str|
+  webrick_request = WEBrick::HTTPRequest.new WEBrick::Config::HTTP
+  webrick_request.parse StringIO.new str
+  @rack_request = {}
+  @rack_request[Rack::REQUEST_METHOD] = webrick_request.request_method
+  @rack_request[Rack::SCRIPT_NAME] = webrick_request.script_name
+  @rack_request[Rack::PATH_INFO] = webrick_request.path_info
+  @rack_request[Rack::QUERY_STRING] = webrick_request.query_string
+  @rack_request[Rack::SERVER_NAME] = webrick_request.server_name
+  @rack_request[Rack::SERVER_PORT] = webrick_request.port
+  @rack_request[Rack::RACK_VERSION] = Rack::VERSION
+  @rack_request[Rack::RACK_URL_SCHEME] = webrick_request.ssl? ? "https" : "http"
+  @rack_request[Rack::RACK_INPUT] = StringIO.new webrick_request.body
+  @rack_request[Rack::RACK_ERRORS] = StringIO.new
+  webrick_request.each do |key, value|
+    key = key.upcase.tr "-", "_"
+    key = "HTTP_#{key}" unless key == "CONTENT_TYPE"
+    @rack_request[key] = value
+  end
+end
+
+When "parsed as HTTP request" do
+  @event = @http_binding.decode_event @rack_request
+end
+
+Then "the attributes are:" do |table|
+  table.hashes.each do |hash|
+    assert_equal hash["value"], @event[hash["key"]]
+  end
+end
+
+Then "the data is equal to the following JSON:" do |str|
+  json = JSON.parse str
+  assert_equal json, @event.data
+end
+
+Given "Kafka Protocol Binding is supported" do
+  pending "Kafka Protocol Binding is not yet implemented"
+end
+
+Given "a Kafka message with payload:" do |_str|
+  pending
+end
+
+Given "Kafka headers:" do |_table|
+  pending
+end
+
+When "parsed as Kafka message" do
+  pending
+end

features/support/env.rb

@@ -0,0 +1,3 @@
+dir = ::File.expand_path "../../lib", __dir__
+$LOAD_PATH.unshift dir unless $LOAD_PATH.include? dir
+require "cloud_events"