Contents

module Oxidized
  class RestClient
    require 'net/http'
    require 'json'
    require 'uri'
    require 'asetus'

    class Config
      Root = Root = ENV['OXIDIZED_HOME'] || File.join(ENV['HOME'], '.config', 'oxidized')
    end

    CFGS = Asetus.new name: 'oxidized', load: false, key_to_s: true
    CFGS.default.rest = '127.0.0.1:8888'

    begin
      CFGS.load
    rescue StandardError => error
      raise InvalidConfig, "Error loading config: #{error.message}"
    end

    restcfg = CFGS.cfg.rest
    restcfg.insert(0, 'http://') unless restcfg =~ /^http:\/\//

    HOST = URI(restcfg).host
    PORT = URI(restcfg).port
    PATH = URI(restcfg).path

    class << self
      def next(opt = {}, host = HOST, port = PORT)
        web = new host, port
        web.next opt
      end
    end

    def initialize(host = HOST, port = PORT)
      @web = Net::HTTP.new host, port
    end

    def next(opt)
      data = JSON.dump opt
      @web.put PATH + '/node/next/' + opt[:name].to_s, data
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
oxidized-0.28.0	extra/rest_client.rb
oxidized-0.27.0	extra/rest_client.rb
oxidized-0.26.3	extra/rest_client.rb
oxidized-0.26.2	extra/rest_client.rb
oxidized-0.26.1	extra/rest_client.rb
oxidized-0.26.0	extra/rest_client.rb