Add support for step fail, properly handle corresponding server err…

…or (#134)

* Add support for step , properly handle corresponding error

* Bump version

Gemfile.lock

@@ -1,7 +1,7 @@
 PATH
   remote: .
   specs:
-    grumlin (1.0.1)
+    grumlin (1.0.2)
       async-pool (~> 0.3.0)
       async-websocket (~> 0.22.0)
       ibsciss-middleware (~> 0.4.0)
@@ -74,8 +74,6 @@ GEM
     nokogiri (1.13.9)
       mini_portile2 (~> 2.8.0)
       racc (~> 1.4)
-    nokogiri (1.13.9-x86_64-linux)
-      racc (~> 1.4)
     oj (3.13.23)
     overcommit (0.59.1)
       childprocess (>= 0.6.3, < 5)

lib/definitions.yml

@@ -21,6 +21,7 @@ steps:
   - drop
   - elementMap
   - emit
+  - fail
   - filter
   - fold
   - from

lib/grumlin.rb

@@ -96,6 +96,9 @@ def initialize(status, query)
     # NOTE: Neptune does not return id.
   end
 
+  class FailStepError < ServerError
+  end
+
   class VertexAlreadyExistsError < AlreadyExistsError; end
 
   class EdgeAlreadyExistsError < AlreadyExistsError; end

lib/grumlin/request_error_factory.rb

@@ -4,6 +4,7 @@ class Grumlin::RequestErrorFactory
   ERRORS = {
     499 => Grumlin::InvalidRequestArgumentsError,
     500 => Grumlin::ServerError,
+    595 => Grumlin::FailStepError,
     597 => Grumlin::ScriptEvaluationError,
     599 => Grumlin::ServerSerializationError,
     598 => Grumlin::ServerTimeoutError,

lib/grumlin/version.rb

@@ -1,5 +1,5 @@
 # frozen_string_literal: true
 
 module Grumlin
-  VERSION = "1.0.1"
+  VERSION = "1.0.2"
 end

spec/grumlin/request_error_factory_spec.rb

@@ -54,6 +54,12 @@
       end
     end
 
+    context "when status is 595" do
+      let(:response) { { requestId: 123, status: { code: 595, message: "" } } }
+
+      include_examples "returns an exception", Grumlin::FailStepError
+    end
+
     context "when status is 597" do
       let(:response) { { requestId: 123, status: { code: 597, message: "" } } }