Class: ROM::Gateway Abstract

Inherits:
Object
  • Object
show all
Extended by:
Dry::Core::ClassAttributes, Notifications::Listener
Defined in:
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

Methods included from Notifications::Listener

subscribe

Instance Attribute Details

#connection ⇒ Object (readonly) 



37
38
39
 
# File '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 '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) 


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

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

    ROM.adapters.fetch(type)
  }

  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
102
103
 
# File 'lib/rom/gateway.rb', line 81

def self.setup(gateway_or_scheme, *args)
  case gateway_or_scheme
  when String
    raise ArgumentError, "      URIs without an explicit scheme are not supported anymore.\n      See https://github.com/rom-rb/rom/blob/master/CHANGELOG.md\n    STRING\n  when Symbol\n    klass = class_from_symbol(gateway_or_scheme)\n\n    if klass.instance_method(:initialize).arity == 0\n      klass.new\n    else\n      klass.new(*args)\n    end\n  else\n    if args.empty?\n      gateway_or_scheme\n    else\n      raise ArgumentError, \"Can't accept arguments when passing an instance\"\n    end\n  end\nend\n".gsub(/^ {10}/, '')

Instance Method Details

#adapter ⇒ Symbol

Returns the adapter, defined for the class

Returns:

  • (Symbol) 


131
132
133
134
135
136
 
# File 'lib/rom/gateway.rb', line 131

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



164
165
166
 
# File 'lib/rom/gateway.rb', line 164

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) 


157
158
159
 
# File 'lib/rom/gateway.rb', line 157

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



177
178
179
 
# File 'lib/rom/gateway.rb', line 177

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



145
146
147
 
# File 'lib/rom/gateway.rb', line 145

def use_logger(*)
  # noop
end