Initial commit

Author: georgeclaghorn

.gitignore

@@ -0,0 +1,2 @@
+*.gem
+.byebug_history

Gemfile

@@ -0,0 +1,3 @@
+source "https://rubygems.org"
+
+gemspec

Gemfile.lock

@@ -0,0 +1,50 @@
+PATH
+  remote: .
+  specs:
+    rspamd (0.1.0)
+      activesupport (>= 6.0.0)
+      addressable (>= 2.7.0)
+
+GEM
+  remote: https://rubygems.org/
+  specs:
+    activesupport (6.0.2.1)
+      concurrent-ruby (~> 1.0, >= 1.0.2)
+      i18n (>= 0.7, < 2)
+      minitest (~> 5.1)
+      tzinfo (~> 1.1)
+      zeitwerk (~> 2.2)
+    addressable (2.7.0)
+      public_suffix (>= 2.0.2, < 5.0)
+    byebug (9.1.0)
+    concurrent-ruby (1.1.5)
+    crack (0.4.3)
+      safe_yaml (~> 1.0.0)
+    hashdiff (1.0.0)
+    i18n (1.8.2)
+      concurrent-ruby (~> 1.0)
+    minitest (5.14.0)
+    public_suffix (4.0.3)
+    rake (12.3.3)
+    safe_yaml (1.0.5)
+    thread_safe (0.3.6)
+    tzinfo (1.2.6)
+      thread_safe (~> 0.1)
+    webmock (3.8.0)
+      addressable (>= 2.3.6)
+      crack (>= 0.3.2)
+      hashdiff (>= 0.4.0, < 2.0.0)
+    zeitwerk (2.2.2)
+
+PLATFORMS
+  ruby
+
+DEPENDENCIES
+  byebug (~> 9.1)
+  minitest (~> 5.11)
+  rake (~> 12.0)
+  rspamd!
+  webmock (~> 3.0)
+
+BUNDLED WITH
+   2.1.4

Rakefile

@@ -0,0 +1,9 @@
+require "bundler/setup"
+require "rake/testtask"
+
+Rake::TestTask.new do |test|
+  test.libs << "test"
+  test.test_files = FileList["test/**/*_test.rb"]
+end
+
+task default: :test

lib/rspamd.rb

@@ -0,0 +1 @@
+require "rspamd/client"

lib/rspamd/client.rb

@@ -0,0 +1,14 @@
+require "rspamd/service"
+
+module Rspamd
+  class Client
+    def initialize(scheme: "http", host:)
+      @service = Service.new(scheme: scheme, host: host)
+    end
+
+    def ping
+      @service.get("/ping")
+        .then { |response| response.is_a?(Net::HTTPOK) && response.body == "pong" }
+    end
+  end
+end

lib/rspamd/endpoint.rb

@@ -0,0 +1,24 @@
+require "addressable"
+
+require "active_support/core_ext/object/blank"
+require "active_support/core_ext/object/inclusion"
+require "active_support/core_ext/object/to_query"
+
+module Rspamd
+  class Endpoint
+    attr_reader :scheme, :host
+
+    def initialize(scheme: "http", host:)
+      @scheme = scheme.presence_in(%w[ http https ]) || raise(ArgumentError, "Unsupported scheme: #{scheme.inspect}")
+      @host   = host.presence || raise(ArgumentError, "Expected host, got #{host.inspect}")
+    end
+
+    def base
+      @base ||= Addressable::URI.new(scheme: scheme, host: host)
+    end
+
+    def url_for(path, params = {})
+      base.merge(path: path, query: params.to_query).normalize!
+    end
+  end
+end

lib/rspamd/service.rb

@@ -0,0 +1,13 @@
+require "rspamd/endpoint"
+
+module Rspamd
+  class Service
+    def initialize(scheme: "http", host:)
+      @endpoint = Endpoint.new(scheme: scheme, host: host)
+    end
+
+    def get(path)
+      Net::HTTP.get_response @endpoint.url_for(path)
+    end
+  end
+end

rspamd.gemspec

@@ -0,0 +1,21 @@
+Gem::Specification.new do |s|
+  s.name     = "rspamd"
+  s.version  = "0.1.0"
+  s.authors  = "George Claghorn"
+  s.email    = "[email protected]"
+  s.summary  = "Client for Rspamd's HTTP API"
+  s.homepage = "https://github.com/basecamp/rspamd-ruby"
+
+  s.required_ruby_version = ">= 2.6.0"
+
+  s.add_dependency "activesupport", ">= 6.0.0"
+  s.add_dependency "addressable",   ">= 2.7.0"
+
+  s.add_development_dependency "rake",     "~> 12.0"
+  s.add_development_dependency "minitest", "~> 5.11"
+  s.add_development_dependency "webmock",  "~> 3.0"
+  s.add_development_dependency "byebug",   "~> 9.1"
+
+  s.files      = `git ls-files`.split("\n")
+  s.test_files = `git ls-files -- test/*`.split("\n")
+end

test/client_test.rb

@@ -0,0 +1,17 @@
+require "test_helper"
+
+class Rspamd::ClientTest < Minitest::Test
+  def setup
+    @client = Rspamd::Client.new(host: "localhost:11333")
+  end
+
+  def test_successfully_pinging
+    stub_request(:get, "http://localhost:11333/ping").to_return(status: 200, body: "pong")
+    assert @client.ping
+  end
+
+  def test_unsuccessfully_pinging
+    stub_request(:get, "http://localhost:11333/ping").to_return(status: 500)
+    assert !@client.ping
+  end
+end

test/test_helper.rb

@@ -0,0 +1,4 @@
+require "minitest/autorun"
+require "webmock/minitest"
+require "rspamd"
+require "byebug"