demo_ws_account.rb

require_relative 'lib/solana_rpc_ruby'
require 'pry'

ws_testnet_cluster = 'ws://api.testnet.solana.com'
ws_mainnet_cluster = 'ws://api.mainnet-beta.solana.com'

cluster = ARGV[0] || ws_mainnet_cluster
raise "Please provide a cluster endpoint in this format: ws://api.mainnet-beta.solana.com" if cluster.nil?

SolanaRpcRuby.config do |c|
  c.json_rpc_version = '2.0'
  c.ws_cluster = cluster
  # c.ws_cluster = ws_mainnet_cluster
end

puts SolanaRpcRuby.json_rpc_version
puts SolanaRpcRuby.ws_cluster

ws_method_wrapper = SolanaRpcRuby::WebsocketsMethodsWrapper.new(cluster: SolanaRpcRuby.cluster)

# SOL/USDC on Serum
account_id = '9wFFyRfZBsuAha4YcuxcXLKwMxJR43S7fPfQLusDBzvT'

interrupted = false
trap('INT') { interrupted = true }

time_last = Time.now
begin
  ws_method_wrapper.account_subscribe(account_id, commitment: 'confirmed', encoding: 'base64') do |message|
    json = JSON.parse(message)
    # puts json['params']
    time_elapsed = Time.now - time_last
    puts "#{time_elapsed.round(4)} seconds. #{json['params']}"
    time_last = Time.now
    break if interrupted
  end
rescue SolanaRpcRuby::ApiError => e
  puts e.inspect
end # begin

# Example of block that can be passed to the method to manipualte the data.
# block = Proc.new do |message|
#   json = JSON.parse(message)
#   puts json['params']
# end

# Methods docs: https://docs.solana.com/developing/clients/jsonrpc-api#subscription-websocket
# Uncomment one of the methods below to see the output.
# Without the block the websocket message will be printed to the console.
#
# ws_method_wrapper.account_subscribe(account_id)
# ws_method_wrapper.account_subscribe(account_id, &block)
# ws_method_wrapper.logs_subscribe('all')
# ws_method_wrapper.logs_subscribe('all', &block)
# ws_method_wrapper.program_subscribe(program_id)
# ws_method_wrapper.program_subscribe(program_id, &block)
# ws_method_wrapper.root_subscribe
# ws_method_wrapper.root_subscribe(&block)
# ws_method_wrapper.signature_subscribe('provide_signature')
# ws_method_wrapper.slot_subscribe(&block)
# ws_method_wrapper.slots_updates_subscribe
# ws_method_wrapper.slots_updates_subscribe(&block)
# ws_method_wrapper.vote_subscribe(&block) # unstable, disabled by default, check the solana docs