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