solana_rpc_ruby

A Solana RPC Client for Ruby. This gem provides a wrapper methods for Solana RPC JSON API https://solana.com/docs/rpc.

This gem requires Ruby 3.2+ (as denoted in the .ruby-version file) and it has Rails 6.0+ on board. It MIGHT work with lower versions, but was not tested with them.

Add the following line to your Gemfile:

gem 'solana_rpc_ruby'

Then run bundle install

Next, you need to run the generator:

rails g solana_rpc_ruby:install

The latter command will generate a new config file config/initializers/solana_rpc_ruby_config.rb looking like this:

require 'solana_rpc_ruby'

SolanaRpcRuby.config do |c|
  c.cluster = 'https://api.testnet.solana.com'
  c.json_rpc_version = '2.0'
  # ...other options
end

You can customize it to your needs.

# If you set default cluster you don't need to pass it every time.
method_wrapper = SolanaRpcRuby::MethodsWrapper.new(
  # optional, if not passed, default cluster from config will be used
  cluster: 'https://api.testnet.solana.com',

  # optional, if not passed, default random number 
  # from range 1 to 99_999 will be used
  id: 123 
)

response = method_wrapper.get_account_info(account_pubkey)
puts response

# You can check cluster and id that are used.
method_wrapper.cluster
method_wrapper.id

ws_method_wrapper = SolanaRpcRuby::WebsocketsMethodsWrapper.new(
  # optional, if not passed, default ws_cluster from config will be used
  cluster: 'ws://api.testnet.solana.com',

  # optional, if not passed, default random number 
  # from range 1 to 99_999 will be used
  id: 123 
)

# You should see stream of messages in your console.
ws_method_wrapper.root_subscribe

# You can pass a block to do something with websocket's messages, ie:
block = Proc.new do |message|
  json = JSON.parse(message)
  puts json['params']
end

ws_method_wrapper.root_subscribe(&block)

# You can check cluster and id that are used.
ws_method_wrapper.cluster
ws_method_wrapper.id

You can easily plug-in websockets connection to your rails app by using ActionCable. Here is an example for development environment. More explanation on Action Cable here: https://www.pluralsight.com/guides/updating-a-rails-app's-wall-feed-in-real-time-with-actioncable

0. Make sure that you have action_cable and solana_rpc_ruby gems installed properly. Also install redis unless you have it.

1. Mount action_cable in routes.rb.

Rails.application.routes.draw do
  mount ActionCable.server => '/cable'
  ...
end

2. Update config/environments/development.rb.

config.action_cable.url = "ws://localhost:3000/cable"
config.action_cable.allowed_request_origins = [/http:\/\/*/, /https:\/\/*/]

3. Update adapter in cable.yml.

development:
  adapter: redis
  url: <%= ENV.fetch("REDIS_URL") { "redis://localhost:6379/1" } %>

4. Create a channel.

rails g channel wall

5. Your wall_channel.rb should look like this:

class WallChannel < ApplicationCable::Channel
  def subscribed
    stream_from "wall_channel"
  end

  def unsubscribed
    # Any cleanup needed when channel is unsubscribed
  end
end

6. Your wall_channel.js should look like this (json keys are configured for root_subscription method response):

import consumer from "./consumer"

consumer.subscriptions.create("WallChannel", {
  connected() {
    console.log("Connected to WallChannel");
    // Called when the subscription is ready for use on the server
  },

  disconnected() {
    // Called when the subscription has been terminated by the server
  },

  received(data) {
    let wall = document.getElementById('wall');

    wall.innerHTML += "<p>Result: "+ data['message']['result'] + "</p>";
    // Called when there's incoming data on the websocket for this channel
  }
});

7. Create placeholder somewhere in your view for messages.

<div id='wall' style='overflow-y: scroll; height:400px;''>
  <h1>Solana subscription messages</h1>
</div>

8. Create a script with a block to run websockets (script/websockets_solana.rb).

require_relative '../config/environment'

ws_method_wrapper = SolanaRpcRuby::WebsocketsMethodsWrapper.new

# Example of block that can be passed to the method to manipulate the data.
block = Proc.new do |message|
  json = JSON.parse(message)

  ActionCable.server.broadcast(
    "wall_channel",
    {
      message: json['params']
    }
  )
end

ws_method_wrapper.root_subscribe(&block)

9. Run rails s, open webpage where you put your placeholder.
10. Open http://localhost:3000/address_with_websockets_view.
11. Run rails r script/websockets_solana.rb in another terminal window.
12. You should see incoming websocket messages on your webpage.

Gem is coming with demo scripts that you can run and test API and Websockets.

1. Clone the repo
2. Set the gemset
3. Run ruby demo.rb or ruby demo_ws_METHOD.rb to see example output.
4. Check the gem or Solana JSON RPC API docs to get more information about method usage and modify demo scripts loosely.

Current methods: get_account_info, get_balance, get_block, get_block_height, get_block_production, get_block_commitment, get_blocks, get_blocks_with_limit, get_block_time, get_cluster_nodes, get_epoch_info, get_epoch_schedule, get_fee_for_message, get_first_available_block, get_genesis_hash, get_health, get_highest_snapshot_slot, get_identity, get_inflation_governor, get_inflation_rate, get_inflation_reward, get_largest_accounts, get_latest_blockhash, get_leader_schedule, get_max_retransmit_slot, get_max_shred_insert_slot, get_minimum_balance_for_rent_exemption, get_multiple_accounts, get_program_accounts, get_recent_performance_samples, get_recent_prioritization_fees, get_signatures_for_address, get_signature_statuses, get_slot, get_slot_leader, get_slot_leaders, get_stake_activation, get_stake_minimum_delegation, get_supply, get_token_account_balance, get_token_accounts_by_delegate, get_token_accounts_by_owner, get_token_largest_accounts, get_token_supply, get_transaction, get_transaction_count, get_version, get_vote_accounts, is_blockhash_valid, minimum_ledger_slot, request_airdrop, send_transaction, simulate_transaction.

Deprecated compatibility methods: get_confirmed_blocks, get_fee_calculator_for_blockhash, get_fee_rate_governor, get_fees, get_recent_blockhash, get_snapshot_slot.

account_subscribe, account_unsubscribe, block_subscribe, block_unsubscribe, logs_subscribe, logs_unsubscribe, program_subscribe, program_unsubscribe, signature_subscribe, signature_unsubscribe, slot_subscribe, slot_unsubscribe, slots_updates_subscribe, slots_updates_unsubscribe, root_subscribe, root_unsubscribe, vote_subscribe, vote_unsubscribe.

All info about methods you can find in the docs on: https://www.rubydoc.info/github/Block-Logic/solana-rpc-ruby/main/SolanaRpcRuby

Also, as a reference you can use docs from solana: https://solana.com/docs/rpc

Copyright (c) [Block Logic Team]. License type is MIT.