Implement basic RPC API

Author: noteflakes

CHANGELOG.md

@@ -1,3 +1,4 @@
 ## 0.1 2025-06-17
 
+- Implement context param validation
 - Preliminary version

lib/syntropy/rpc_api.rb

@@ -12,8 +12,6 @@ def initialize(mount_path)
 
     def call(ctx)
       response, status = invoke(ctx)
-      p response: response
-      p status: status
       ctx.request.respond(
         response.to_json,
         ':status'       => status,
@@ -22,7 +20,7 @@ def call(ctx)
     end
 
     def invoke(ctx)
-      q = ctx.params[:q]
+      q = ctx.validate_param(:q, String)
       response = case ctx.request.method
       when 'get'
         send(q.to_sym, ctx)
@@ -33,7 +31,10 @@ def invoke(ctx)
       end
       [{ status: 'OK', response: response }, Qeweney::Status::OK]
     rescue => e
-      p e.backtrace
+      if !e.is_a?(Syntropy::Error)
+        p e
+        p e.backtrace
+      end
       error_response(e)
     end
 

test/helper.rb

@@ -84,6 +84,15 @@ def response_status
     adapter.status
   end
 
+  def response_body
+    adapter.body
+  end
+
+  def response_json
+    raise if response_content_type != 'application/json'
+    JSON.parse(response_body, symbolize_names: true)
+  end
+
   def response_content_type
     response_headers['Content-Type']
   end

test/test_rpc_api.rb

@@ -10,6 +10,7 @@ def get(ctx)
 
     def set!(ctx)
       @value = ctx.params[:v]
+      true
     end
   end
 
@@ -23,10 +24,28 @@ def test_kernel_version
     assert_in_range 600..700, v
   end
 
-  def test_req_harness
+  def test_rpc_api
     req = mock_req(':method' => 'GET', ':path' => '/foo')
     ctx = Syntropy::Context.new(req)
-    ret = @app.call(ctx)
-    assert_equal Qeweney::Status::NOT_FOUND, req.response_status
+    @app.call(ctx)
+    assert_equal Qeweney::Status::BAD_REQUEST, req.response_status
+
+    req = mock_req(':method' => 'GET', ':path' => '/foo?q=get')
+    ctx = Syntropy::Context.new(req)
+    @app.call(ctx)
+    assert_equal Qeweney::Status::OK, req.response_status
+    assert_equal({ status: 'OK', response: nil }, req.response_json)
+
+    req = mock_req(':method' => 'POST', ':path' => '/foo?q=set&v=foo')
+    ctx = Syntropy::Context.new(req)
+    @app.call(ctx)
+    assert_equal Qeweney::Status::OK, req.response_status
+    assert_equal({ status: 'OK', response: true }, req.response_json)
+
+    req = mock_req(':method' => 'GET', ':path' => '/foo?q=get')
+    ctx = Syntropy::Context.new(req)
+    @app.call(ctx)
+    assert_equal Qeweney::Status::OK, req.response_status
+    assert_equal({ status: 'OK', response: 'foo' }, req.response_json)
   end
 end