module Gorsse

# File lib/gorsse.rb, line 20
def self.close_connections
  @conn && @conn.close
  @receiver_conn && @receiver_conn.close
  Connection::ZCTX.terminate
end

# File lib/gorsse.rb, line 16
def self.config
  @config ||= Config.new
end

# File lib/gorsse.rb, line 12
def self.configure(&block)
  block.call(config)
end

# File lib/gorsse.rb, line 26
def self.conn
  @conn ||= Connection.new(config.handler, mode: :push, method: :connect)
end

# File lib/gorsse.rb, line 30
def self.receiver_conn
  @receiver_conn ||= Connection.new(config.receiver, mode: :pull, method: :bind)
end

# File lib/gorsse.rb, line 34
def self.start_receiver_loop!
  loop do
    message = receiver_conn.receive
    command = Command.new(message)
    command.run!
  end
end