Class: ROM::Gateway Abstract

Inherits:
Object
  • Object
show all
Extended by:
Dry::Core::ClassAttributes, Notifications::Listener
Defined in:
core/lib/rom/gateway.rb

Overview

This class is abstract.

Abstract gateway class

Every adapter needs to inherit from this class and implement required interface

Direct Known Subclasses

Memory::Gateway

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#connection ⇒ Object (readonly) 



37
38
39
 
# File 'core/lib/rom/gateway.rb', line 37

def connection
  @connection
end

Class Method Details

.adapter ⇒ Symbol .gateway(adapter) ⇒ Object

Get or set gateway's adapter identifier

Overloads:

  • .adapter ⇒ Symbol

    Return adapter identifier

    Returns:

    • (Symbol)
  • .gateway(adapter) ⇒ Object

    Examples:

    class MyGateway < ROM::Gateway
  adapter :my_adapter
end

    Parameters:

    • adapter (Symbol) —

      The adapter identifier



33
 
# File 'core/lib/rom/gateway.rb', line 33

defines :adapter

.class_from_symbol(type) ⇒ Class

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Get gateway subclass for a specific adapter

Parameters:

  • type (Symbol) —

    Adapter identifier

Returns:

  • (Class) 


114
115
116
117
118
119
120
121
122
123
124
125
126
 
# File 'core/lib/rom/gateway.rb', line 114

def self.class_from_symbol(type)
  adapter = ROM.adapters.fetch(type) do
    begin
      require "rom/#{type}"
    rescue LoadError
      raise AdapterLoadError, "Failed to load adapter rom/#{type}"
    end

    ROM.adapters.fetch(type)
  end

  adapter.const_get(:Gateway)
end

.setup(type, *args) ⇒ Gateway .setup(gateway) ⇒ Gateway

Set up a gateway

Overloads:

  • .setup(type, *args) ⇒ Gateway

    Sets up a single-gateway given a gateway type. For custom gateways, create an instance and pass it directly.

    Examples:

    module SuperDB
  class Gateway < ROM::Gateway
    def initialize(options)
    end
  end
end

ROM.register_adapter(:super_db, SuperDB)

Gateway.setup(:super_db, some: 'options')
# SuperDB::Gateway.new(some: 'options') is called

    Parameters:

    • type (Symbol) —

      Registered gateway identifier

    • args (Array) —

      Additional gateway options

  • .setup(gateway) ⇒ Gateway

    Set up a gateway instance

    Examples:

    module SuperDB
  class Gateway < ROM::Gateway
    def initialize(options)
    end
  end
end

ROM.register_adapter(:super_db, SuperDB)

Gateway.setup(SuperDB::Gateway.new(some: 'options'))

    Parameters:

Returns:

  • (Gateway) —

    a specific gateway subclass



81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
 
# File 'core/lib/rom/gateway.rb', line 81

def self.setup(gateway_or_scheme, *args)
  case gateway_or_scheme
  when String
    raise ArgumentError, <<-STRING.gsub(/^ {10}/, '')
      URIs without an explicit scheme are not supported anymore.
      See https://github.com/rom-rb/rom/blob/master/CHANGELOG.md
    STRING
  when Symbol
    klass = class_from_symbol(gateway_or_scheme)

    if klass.instance_method(:initialize).arity.zero?
      klass.new
    else
      klass.new(*args)
    end
  else
    raise ArgumentError, "Can't accept arguments when passing an instance" unless args.empty?

    gateway_or_scheme
  end
end

.subscribe(event_id, query = EMPTY_HASH, &block) ⇒ Object Originally defined in module Notifications::Listener

Subscribe to events

Parameters:

  • event_id (String) —

    The event key

  • query (Hash) (defaults to: EMPTY_HASH) —

    An optional event filter

Returns:

  • (Object) —

    self

Instance Method Details

#adapter ⇒ Symbol

Returns the adapter, defined for the class

Returns:

  • (Symbol) 


133
134
135
136
137
138
 
# File 'core/lib/rom/gateway.rb', line 133

def adapter
  self.class.adapter || raise(
    MissingAdapterIdentifierError,
    "gateway class +#{self}+ is missing the adapter identifier"
  )
end

#disconnect ⇒ Object

Disconnect is optional and it's a no-op by default



166
167
168
 
# File 'core/lib/rom/gateway.rb', line 166

def disconnect
  # noop
end

#logger ⇒ NilClass

A generic interface for returning default logger

Adapters should implement this method as handling loggers is different across adapters. This is a no-op by default and returns nil.

Returns:

  • (NilClass) 


159
160
161
 
# File 'core/lib/rom/gateway.rb', line 159

def logger
  # noop
end

#transaction(opts = EMPTY_HASH, &block) ⇒ Object

Runs a block inside a transaction. The underlying transaction engine is adapter-specific

Parameters:

  • opts (Hash) (defaults to: EMPTY_HASH) —

    Transaction options

Returns:

  • The result of yielding the block or +nil+ if the transaction was rolled back



179
180
181
 
# File 'core/lib/rom/gateway.rb', line 179

def transaction(opts = EMPTY_HASH, &block)
  transaction_runner(opts).run(opts, &block)
end

#use_logger ⇒ Object

This method is abstract.

A generic interface for setting up a logger

This is not a required interface, it's a no-op by default



147
148
149
 
# File 'core/lib/rom/gateway.rb', line 147

def use_logger(*)
  # noop
end