Class: SalesforceStreamer::SalesforceClient

Inherits:
Object
  • Object
show all
Defined in:
lib/salesforce_streamer/salesforce_client.rb

Constant Summary collapse

QUERY =
<<~SOQL.chomp.freeze
  SELECT Id, Name, ApiVersion, Description, NotifyForFields, Query, isActive
  FROM PushTopic
  WHERE Name = '{{NAME}}'
SOQL

Instance Method Summary collapse

Constructor Details

#initialize(client: Restforce.new) ⇒ SalesforceClient

Returns a new instance of SalesforceClient.


3
4
5
# File 'lib/salesforce_streamer/salesforce_client.rb', line 3

def initialize(client: Restforce.new)
  @client = client
end

Instance Method Details

#authenticate!Object


7
8
9
# File 'lib/salesforce_streamer/salesforce_client.rb', line 7

def authenticate!
  @client.authenticate!
end

#find_push_topic_by_name(name) ⇒ Object

Returns nil or an instance of Restforce::SObject


16
17
18
19
# File 'lib/salesforce_streamer/salesforce_client.rb', line 16

def find_push_topic_by_name(name)
  query = QUERY.dup.gsub(/\s+/, ' ').gsub('{{NAME}}', name)
  @client.query(query).first
end

#subscribe(*args, &block) ⇒ Object


11
12
13
# File 'lib/salesforce_streamer/salesforce_client.rb', line 11

def subscribe(*args, &block)
  @client.subscribe(args, &block)
end

#upsert_push_topic(push_topic) ⇒ Object

Returns true or raises an exception if the upsert fails


22
23
24
25
26
27
28
29
30
31
32
# File 'lib/salesforce_streamer/salesforce_client.rb', line 22

def upsert_push_topic(push_topic)
  @client.upsert!(
    'PushTopic', :Id,
    'Id' => push_topic.id,
    'Name' => push_topic.name,
    'ApiVersion' => push_topic.api_version,
    'Description' => push_topic.description,
    'NotifyForFields' => push_topic.notify_for_fields,
    'Query' => push_topic.query
  )
end