Class: X::Connection

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/x/connection.rb

Overview

Manages HTTP connections to the X API

Constant Summary collapse

DEFAULT_HOST =

Default host for the X API

"api.twitter.com".freeze
DEFAULT_PORT =

Default port for HTTPS connections

443
DEFAULT_OPEN_TIMEOUT =

Default timeout for opening connections in seconds

60
DEFAULT_READ_TIMEOUT =

Default timeout for reading responses in seconds

60
DEFAULT_WRITE_TIMEOUT =

Default timeout for writing requests in seconds

60
DEFAULT_DEBUG_OUTPUT =

Default debug output destination

File.open(IO::NULL, "w")
NETWORK_ERRORS =

Network errors that should be wrapped in NetworkError

[
  Errno::ECONNREFUSED,
  Errno::ECONNRESET,
  Net::OpenTimeout,
  Net::ReadTimeout,
  OpenSSL::SSL::SSLError
].freeze

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(open_timeout: DEFAULT_OPEN_TIMEOUT, read_timeout: DEFAULT_READ_TIMEOUT, write_timeout: DEFAULT_WRITE_TIMEOUT, debug_output: DEFAULT_DEBUG_OUTPUT, proxy_url: nil) ⇒ Connection

Initialize a new connection

Examples:

Create a connection with default settings

connection = X::Connection.new

Create a connection with custom timeouts

connection = X::Connection.new(open_timeout: 30, read_timeout: 30)

Parameters:

  • open_timeout (Integer) (defaults to: DEFAULT_OPEN_TIMEOUT) —

    the timeout for opening connections in seconds

  • read_timeout (Integer) (defaults to: DEFAULT_READ_TIMEOUT) —

    the timeout for reading responses in seconds

  • write_timeout (Integer) (defaults to: DEFAULT_WRITE_TIMEOUT) —

    the timeout for writing requests in seconds

  • debug_output (IO) (defaults to: DEFAULT_DEBUG_OUTPUT) —

    the IO object for debug output

  • proxy_url (String, nil) (defaults to: nil) —

    the proxy URL for requests



94
95
96
97
98
99
100
101
 
# File 'lib/x/connection.rb', line 94

def initialize(open_timeout: DEFAULT_OPEN_TIMEOUT, read_timeout: DEFAULT_READ_TIMEOUT,
  write_timeout: DEFAULT_WRITE_TIMEOUT, debug_output: DEFAULT_DEBUG_OUTPUT, proxy_url: nil)
  @open_timeout = open_timeout
  @read_timeout = read_timeout
  @write_timeout = write_timeout
  @debug_output = debug_output
  self.proxy_url = proxy_url unless proxy_url.nil?
end

Instance Attribute Details

#debug_output ⇒ IO

The IO object for debug output

Examples:

Get or set the debug output

connection.debug_output = $stderr

Returns:

  • (IO) —

    the IO object for debug output



60
61
62
 
# File 'lib/x/connection.rb', line 60

def debug_output
  @debug_output
end

#open_timeout ⇒ Integer

The timeout for opening connections in seconds

Examples:

Get or set the open timeout

connection.open_timeout = 30

Returns:

  • (Integer) —

    the timeout for opening connections in seconds



39
40
41
 
# File 'lib/x/connection.rb', line 39

def open_timeout
  @open_timeout
end

#proxy_uri ⇒ URI? (readonly)

The parsed proxy URI

Examples:

Get the proxy URI

connection.proxy_uri

Returns:

  • (URI, nil) —

    the parsed proxy URI



74
75
76
 
# File 'lib/x/connection.rb', line 74

def proxy_uri
  @proxy_uri
end

#proxy_url ⇒ String?

The proxy URL for requests

Examples:

Get the proxy URL

connection.proxy_url

Returns:

  • (String, nil) —

    the proxy URL for requests



67
68
69
 
# File 'lib/x/connection.rb', line 67

def proxy_url
  @proxy_url
end

#read_timeout ⇒ Integer

The timeout for reading responses in seconds

Examples:

Get or set the read timeout

connection.read_timeout = 30

Returns:

  • (Integer) —

    the timeout for reading responses in seconds



46
47
48
 
# File 'lib/x/connection.rb', line 46

def read_timeout
  @read_timeout
end

#write_timeout ⇒ Integer

The timeout for writing requests in seconds

Examples:

Get or set the write timeout

connection.write_timeout = 30

Returns:

  • (Integer) —

    the timeout for writing requests in seconds



53
54
55
 
# File 'lib/x/connection.rb', line 53

def write_timeout
  @write_timeout
end

Instance Method Details

#perform(request:) ⇒ Net::HTTPResponse

Perform an HTTP request

Examples:

Perform a request

response = connection.perform(request: request)

Parameters:

  • request (Net::HTTPRequest) —

    the HTTP request to perform

Returns:

  • (Net::HTTPResponse) —

    the HTTP response

Raises:



111
112
113
114
115
116
117
118
119
 
# File 'lib/x/connection.rb', line 111

def perform(request:)
  host = request.uri.host || DEFAULT_HOST
  port = request.uri.port || DEFAULT_PORT
  http_client = build_http_client(host, port)
  http_client.use_ssl = request.uri.scheme.eql?("https")
  http_client.request(request)
rescue *NETWORK_ERRORS => e
  raise NetworkError, "Network error: #{e}"
end