Class: EventStoreClient::GRPC::Commands::Command

Inherits:

Object

• Object
• EventStoreClient::GRPC::Commands::Command

Includes:

Configuration

Defined in:

lib/event_store_client/adapters/grpc/commands/command.rb

Direct Known Subclasses

PersistentSubscriptions::Create, PersistentSubscriptions::Delete, PersistentSubscriptions::Read, PersistentSubscriptions::Update, Projections::Create, Projections::Delete, Projections::Update, Streams::Append, Streams::Delete, Streams::LinkTo, Streams::Read, Streams::ReadAll, Streams::Subscribe, Streams::Tombstone

Defined Under Namespace

Classes: GRPCUnavailableRetryFailed

Class Method Summary

• .inherited(klass) ⇒ Object

Instance Method Summary

• #metadata ⇒ Object

Methods included from Configuration

#config

Class Method Details

.inherited(klass) ⇒ Object

# File 'lib/event_store_client/adapters/grpc/commands/command.rb', line 14

def self.inherited(klass)
  super
  klass.class_eval do
    include Dry::Monads[:try, :result]

    def self.use_request(request_klass)
      CommandRegistrar.register_request(self, request: request_klass)
    end

    def self.use_service(service_klass)
      CommandRegistrar.register_service(self, service: service_klass)
    end

    def request
      CommandRegistrar.request(self.class)
    end

    def service
      CommandRegistrar.service(self.class)
    end
  end
end

Instance Method Details

#metadata ⇒ Object

# File 'lib/event_store_client/adapters/grpc/commands/command.rb', line 37

def metadata
  credentials =
    Base64.encode64("#{config.eventstore_user}:#{config.eventstore_password}")
  { 'authorization' => "Basic #{credentials.delete("\n")}" }
end