module WebhookTrigger::Repository::TriggerRepository
This TriggerRepository
is class for connect to database
Public Class Methods
webhook_insert_pending(event, url, event_source_id)
click to toggle source
# File lib/webhook_trigger/repository/trigger_repository.rb, line 52 def self.webhook_insert_pending(event, url, event_source_id) sql = webhook_insert_query sql += webhook_insert_value(event, url, event_source_id) WebhookTrigger::Repository.client.query(sql) end
webhook_insert_query()
click to toggle source
# File lib/webhook_trigger/repository/trigger_repository.rb, line 39 def self.webhook_insert_query sql = 'INSERT INTO ' + configuration.db + '.' sql += configuration.buffer_table sql += '(url, event, event_source_id) VALUES ' sql end
webhook_insert_value(event, url, event_source_id)
click to toggle source
# File lib/webhook_trigger/repository/trigger_repository.rb, line 46 def self.webhook_insert_value(event, url, event_source_id) sql = "('" + url.to_s + "', '" + event.to_s + "', " sql += event_source_id.to_s + ')' sql end
webhook_list(event, account_id)
click to toggle source
# File lib/webhook_trigger/repository/trigger_repository.rb, line 32 def self.webhook_list(event, account_id) sql = webhook_list_query_select sql += webhook_list_query_condition(event, account_id) results = WebhookTrigger::Repository.client.query(sql) results end
webhook_list_query_condition(event, account_id)
click to toggle source
# File lib/webhook_trigger/repository/trigger_repository.rb, line 24 def self.webhook_list_query_condition(event, account_id) sql = 'WHERE ' + configuration_list sql += '.account_id=' + account_id.to_s sql += ' AND ' + configuration_event sql += ".name like '" + event.to_s + "'" sql end
webhook_list_query_join()
click to toggle source
# File lib/webhook_trigger/repository/trigger_repository.rb, line 16 def self.webhook_list_query_join sql = ' FROM ' + configuration_list sql += ' JOIN ' + configuration_event sql += ' on ' + configuration_list + '.event_id=' sql += configuration_event + '.id ' sql end
webhook_list_query_select()
click to toggle source
# File lib/webhook_trigger/repository/trigger_repository.rb, line 8 def self.webhook_list_query_select sql = 'SELECT ' + configuration_list + '.id, ' sql += configuration_list + '.url, ' sql += configuration_event + '.name ' sql += webhook_list_query_join sql end
Private Instance Methods
configuration()
click to toggle source
# File lib/webhook_trigger/repository/trigger_repository.rb, line 68 def configuration @configuration ||= WebhookTrigger.configuration end
configuration_event()
click to toggle source
# File lib/webhook_trigger/repository/trigger_repository.rb, line 64 def configuration_event configuration.event end
configuration_list()
click to toggle source
# File lib/webhook_trigger/repository/trigger_repository.rb, line 60 def configuration_list configuration_list.list end