Contents

# frozen_string_literal: true

require 'avro_turf/test/fake_confluent_schema_registry_server'
require 'avro-resolution_canonical_form'

module AvroSchemaRegistry
  class FakeServer < FakeConfluentSchemaRegistryServer
    get '/subjects/:subject/fingerprints/:fingerprint' do
      subject = params[:subject]
      halt(404, SCHEMA_NOT_FOUND) unless SUBJECTS.key?(subject)

      fingerprint = params[:fingerprint]
      fingerprint = fingerprint.to_i.to_s(16) if /^\d+$/.match?(fingerprint)

      schema_id = SCHEMAS.find_index do |schema|
        Avro::Schema.parse(schema).sha256_resolution_fingerprint.to_s(16) == fingerprint
      end

      halt(404, SCHEMA_NOT_FOUND) unless schema_id && SUBJECTS[subject].include?(schema_id)

      { id: schema_id }.to_json
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
avro_schema_registry-client-0.5.0	lib/avro_schema_registry/test/fake_server.rb
avro_schema_registry-client-0.4.0	lib/avro_schema_registry/test/fake_server.rb