grokify / ringcentral-sdk-ruby

require 'ringcentral_sdk'

require 'pp'

# Set your credentials in the .env file

# Use the rc_config_sample.env.txt file as a scaffold

config = RingCentralSdk::REST::Config.new.load_dotenv

client = RingCentralSdk::REST::Client.new

client.app_config(config.app)

client.authorize_user(config.user)

# An SMS event poster. Takes a message store subscription

# event and posts inbound SMS as chats.

class RcEventFaxDownloader

  attr_accessor :event

  def initialize(client, posters=[], event_data={})

    @client = client

    @posters = posters

    @event = RingCentralSdk::REST::Event.new event_data

    @retriever = RingCentralSdk::REST::MessagesRetriever.new @client

    @retriever.range = 0.5 # minutes

  end

end

# An observer object that uses RcEventSMSChatPoster to post

# to multiple chat posters

class RcDownloadNewFaxObserver

  def initialize(client, posters)

    @client = client

    @posters = posters

  end

  def update(message)

    puts "DEMO_RECEIVED_NEW_MESSAGE"

    pp message

    event = RcEventFaxDownloader.new @client, @posters, message

    event.download_fax

    puts JSON.dump(message)

  end

end

class RcFaxPosterFilesystem

  def initialize(dir = '.')

    @dir = dir

  end

  def write_file(filename, response)

    filepath = File.join(@dir, filename)

    File.open(filepath, 'wb') { |fp| fp.write(response.body) }

  end

end

def run_subscription(config, client)

  # Create an observable subscription and add your observer

  sub = client.create_subscription

  sub.subscribe ['/restapi/v1.0/account/~/extension/~/message-store']

  # Create and add first chat poster

  posters = []

  posters.push RcFaxPosterFilesystem.new '.'

  # Add observer

  sub.add_observer RcDownloadNewFaxObserver.new client, posters

  # Run until key is clicked

  puts "Click any key to finish"

  stop_script = gets

  # End the subscription

  sub.destroy()

end

run_subscription config, client

puts "DONE"