Support for operations endpoint

Author: jasonbosco

lib/typesense.rb

@@ -22,4 +22,5 @@ module Typesense
 require_relative 'typesense/debug'
 require_relative 'typesense/health'
 require_relative 'typesense/metrics'
+require_relative 'typesense/operations'
 require_relative 'typesense/error'

lib/typesense/client.rb

@@ -2,7 +2,7 @@
 
 module Typesense
   class Client
-    attr_reader :configuration, :collections, :aliases, :keys, :debug, :health, :metrics
+    attr_reader :configuration, :collections, :aliases, :keys, :debug, :health, :metrics, :operations
 
     def initialize(options = {})
       @configuration = Configuration.new(options)
@@ -13,6 +13,7 @@ def initialize(options = {})
       @debug = Debug.new(@api_call)
       @health = Health.new(@api_call)
       @metrics = Metrics.new(@api_call)
+      @operations = Operations.new(@api_call)
     end
   end
 end

lib/typesense/operations.rb

@@ -0,0 +1,15 @@
+# frozen_string_literal: true
+
+module Typesense
+  class Operations
+    RESOURCE_PATH = '/operations'
+
+    def initialize(api_call)
+      @api_call = api_call
+    end
+
+    def perform(operation_name, query_params = {})
+      @api_call.post("#{RESOURCE_PATH}/#{operation_name}", {}, query_params)
+    end
+  end
+end

spec/typesense/operations_spec.rb

@@ -0,0 +1,28 @@
+# frozen_string_literal: true
+
+require_relative '../spec_helper'
+require_relative 'shared_configuration_context'
+
+describe Typesense::Operations do
+  subject(:operations) { typesense.operations }
+
+  include_context 'with Typesense configuration'
+
+  describe '#perform' do
+    it 'performs the specificied operation' do
+      stub_request(:post, Typesense::ApiCall.new(typesense.configuration).send(:uri_for, '/operations/snapshot', typesense.configuration.nodes[0]))
+        .with(headers: {
+                'X-Typesense-Api-Key' => typesense.configuration.api_key,
+                'Content-Type' => 'application/json'
+              },
+              query: {
+                snapshot_path: '/tmp/dbsnap'
+              })
+        .to_return(status: 200, body: '{}', headers: { 'Content-Type': 'application/json' })
+
+      result = operations.perform(:snapshot, { snapshot_path: '/tmp/dbsnap' })
+
+      expect(result).to eq({})
+    end
+  end
+end