ericchapman / ruby_wamp_client Goto Github PK

connect
TX: HELLO > [1, "ticker", {:roles=>{:caller=>{:features=>{:caller_identification=>true, :call_timeout=>true, :call_canceling=>true, :progressive_call_results=>true}}, :callee=>{:features=>{:caller_identification=>true, :pattern_based_registration=>true, :shared_registration=>true, :call_canceling=>true, :progressive_call_results=>true, :registration_revocation=>true}}, :publisher=>{:features=>{:publisher_identification=>true, :subscriber_blackwhite_listing=>true, :publisher_exclusion=>true}}, :subscriber=>{:features=>{:publisher_identification=>true, :pattern_based_subscription=>true, :subscription_revocation=>true}}}, :agent=>"Ruby-WampClient-0.0.7"}]
RX: ABORT > [3, {:message=>"internal error: realm auto-activation not yet implemented"}, "wamp.error.not_authorized"]
Attempting Reconnect... Next attempt in 8 seconds

require 'wamp_client'

wsuri = 'wss://api.poloniex.com'
options = {
    uri: wsuri,
    realm: 'realm1',
}
connection = WampClient::Connection.new(options)

connection.on_connect do
  puts 'connection established'
end

connection.on_join do |session, details|
  puts 'session created'

  def got_ticker(args, kwargs, details)
    puts args
    puts kwargs
    puts details
  end

  session.subscribe('ticker', method(:got_ticker))
end


connection.open

task :poloniex => :environment do
  wsuri = 'wss://api.poloniex.com'
  options = {
      uri: wsuri,
      realm: 'realm1',
      verbose: true
  }
  connection = WampClient::Connection.new(options)

  connection.on_connect do
    puts 'connection established'
  end
  connection.on_join do |session, details|
    puts 'session created'

    def got_ticker(args, kwargs, details)
      puts args
      puts kwargs
      puts details
    end

    session.subscribe('ticker', method(:got_ticker))
  end

  connection.open
end

require File.expand_path('../../config/environment', __FILE__)


require 'wamp_client'

wsuri = 'wss://api.poloniex.com'
options = {
    uri: wsuri,
    realm: 'realm1',
}
connection = WampClient::Connection.new(options)

connection.on_connect do
  puts 'connection established'
end

connection.on_join do |session, details|
  puts 'session created'

  def got_ticker(args, kwargs, details)
    puts args
    puts kwargs
    puts details
  end

  session.subscribe('ticker', method(:got_ticker))
end


connection.open

connection established
Attempting Reconnect... Next attempt in 2 seconds
connection established
Attempting Reconnect... Next attempt in 4 seconds
``

require 'wamp_client'

wsuri = 'wss://api2.poloniex.com:443/'
  options = {
      uri: wsuri,
      realm: 'realm1',
      headers: {Upgrade: 'websocket',
                Connection: 'Upgrade',}
  }
  connection = WampClient::Connection.new(options)

  connection.on_connect do
    puts 'connection established'
  end

  connection.on_challenge do |authmethod, extra|
    puts 'challenged'
  end

  connection.on_disconnect do |reason|
    puts 'disconnected'
  end

  connection.on_leave do |reason, details|
    puts 'session terminted'
  end

  connection.on_join do |session, details|
    puts 'session created'

    def got_ticker(args, kwargs, details)
      puts args
      puts kwargs
      puts details
    end

    session.subscribe('ticker', method(:got_ticker))
  end

connection.open

current directory: /home/kiju/.gem/ruby/2.4.0/gems/json-1.8.3/ext/json/ext/generator