Class: Webhookdb::Replicator::TwilioSmsV1
- Inherits:
-
Base
- Object
- Base
- Webhookdb::Replicator::TwilioSmsV1
show all
- Includes:
- Appydays::Loggable
- Defined in:
- lib/webhookdb/replicator/twilio_sms_v1.rb
Constant Summary
Constants inherited
from Base
Base::MAX_INDEX_NAME_LENGTH
DBAdapter::ColumnTypes::BIGINT, DBAdapter::ColumnTypes::BIGINT_ARRAY, DBAdapter::ColumnTypes::BOOLEAN, DBAdapter::ColumnTypes::COLUMN_TYPES, DBAdapter::ColumnTypes::DATE, DBAdapter::ColumnTypes::DECIMAL, DBAdapter::ColumnTypes::DOUBLE, DBAdapter::ColumnTypes::FLOAT, DBAdapter::ColumnTypes::INTEGER, DBAdapter::ColumnTypes::INTEGER_ARRAY, DBAdapter::ColumnTypes::OBJECT, DBAdapter::ColumnTypes::TEXT, DBAdapter::ColumnTypes::TEXT_ARRAY, DBAdapter::ColumnTypes::TIMESTAMP, DBAdapter::ColumnTypes::UUID
Instance Attribute Summary
Attributes inherited from Base
#service_integration
Class Method Summary
collapse
Instance Method Summary
collapse
Methods inherited from Base
#_any_subscriptions_to_notify?, #_backfill_state_change_fields, #_backfillers, #_clear_backfill_information, #_clear_webook_information, #_coalesce_excluded_on_update, #_enqueue_backfill_jobs, #_extra_index_specs, #_fetch_enrichment, #_find_dependency_candidate, #_notify_dependents, #_parallel_backfill, #_prepare_for_insert, #_publish_rowupsert, #_resource_to_data, #_store_enrichment_body?, #_to_json, #_upsert_update_expr, #_upsert_webhook, #_webhook_state_change_fields, #admin_dataset, #backfill, #backfill_not_supported_message, #calculate_and_backfill_state_machine, #calculate_dependency_state_machine_step, #calculate_preferred_create_state_machine, #calculate_webhook_state_machine, chunked_row_update_bounds, #clear_backfill_information, #clear_webhook_information, #create_table, #create_table_modification, #data_column, #dbadapter_table, #denormalized_columns, #descriptor, #dispatch_request_to, #documentation_url, #enqueue_sync_targets, #enrichment_column, #ensure_all_columns, #ensure_all_columns_modification, #find_dependent, #find_dependent!, #indices, #initialize, #on_dependency_webhook_upsert, #preferred_create_state_machine_method, #preprocess_headers_for_logging, #primary_key_column, #process_state_change, #process_webhooks_synchronously?, #qualified_table_sequel_identifier, #readonly_dataset, #remote_key_column, #requires_sequence?, #resource_name_plural, #resource_name_singular, #schema_and_table_symbols, #storable_columns, #synchronous_processing_response_body, #timestamp_column, #upsert_has_deps?, #upsert_webhook, #upsert_webhook_body, #verify_backfill_credentials, #webhook_endpoint, #webhook_response
Class Method Details
9
10
11
12
13
14
15
16
17
18
|
# File 'lib/webhookdb/replicator/twilio_sms_v1.rb', line 9
def self.descriptor
return Webhookdb::Replicator::Descriptor.new(
name: "twilio_sms_v1",
ctor: ->(sint) { Webhookdb::Replicator::TwilioSmsV1.new(sint) },
feature_roles: [],
resource_name_singular: "Twilio SMS Message",
supports_backfill: true,
api_docs_url: "https://www.twilio.com/docs/usage/api#send-an-sms-with-twilios-api",
)
end
|
Instance Method Details
#_denormalized_columns ⇒ Object
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
# File 'lib/webhookdb/replicator/twilio_sms_v1.rb', line 89
def _denormalized_columns
return [
Webhookdb::Replicator::Column.new(
:date_created,
TIMESTAMP,
index: true,
converter: Webhookdb::Replicator::Column::CONV_PARSE_TIME,
),
Webhookdb::Replicator::Column.new(
:date_sent,
TIMESTAMP,
index: true,
converter: Webhookdb::Replicator::Column::CONV_PARSE_TIME,
),
Webhookdb::Replicator::Column.new(
:date_updated,
TIMESTAMP,
index: true,
converter: Webhookdb::Replicator::Column::CONV_PARSE_TIME,
),
Webhookdb::Replicator::Column.new(:direction, TEXT),
Webhookdb::Replicator::Column.new(:from, TEXT, index: true),
Webhookdb::Replicator::Column.new(:status, TEXT),
Webhookdb::Replicator::Column.new(:to, TEXT, index: true),
]
end
|
#_fetch_backfill_page(pagination_token, last_backfilled:) ⇒ Object
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
|
# File 'lib/webhookdb/replicator/twilio_sms_v1.rb', line 128
def _fetch_backfill_page(, last_backfilled:)
url = "https://api.twilio.com"
if .blank?
date_send_max = (Time.now.utc + 2.days).to_date
url += "/2010-04-01/Accounts/#{self.service_integration.backfill_key}/Messages.json" \
"?PageSize=100&DateSend%3C=#{date_send_max}"
else
url +=
end
response = Webhookdb::Http.get(
url,
basic_auth: {username: self.service_integration.backfill_key,
password: self.service_integration.backfill_secret,},
logger: self.logger,
timeout: Webhookdb::Twilio.http_timeout,
)
data = response.parsed_response
messages = data["messages"]
if last_backfilled.present?
earliest_data_created = messages.empty? ? Time.at(0) : messages[-1].fetch("date_created")
paged_to_already_seen_records = earliest_data_created < last_backfilled
return messages, nil if paged_to_already_seen_records
end
return messages, data["next_page_uri"]
end
|
#_remote_key_column ⇒ Object
85
86
87
|
# File 'lib/webhookdb/replicator/twilio_sms_v1.rb', line 85
def _remote_key_column
return Webhookdb::Replicator::Column.new(:twilio_id, TEXT, data_key: "sid")
end
|
#_resource_and_event(request) ⇒ Object
120
121
122
|
# File 'lib/webhookdb/replicator/twilio_sms_v1.rb', line 120
def _resource_and_event(request)
return request.body, nil
end
|
#_timestamp_column_name ⇒ Object
116
117
118
|
# File 'lib/webhookdb/replicator/twilio_sms_v1.rb', line 116
def _timestamp_column_name
return :date_updated
end
|
#_update_where_expr ⇒ Object
124
125
126
|
# File 'lib/webhookdb/replicator/twilio_sms_v1.rb', line 124
def _update_where_expr
return self.qualified_table_sequel_identifier[:date_updated] < Sequel[:excluded][:date_updated]
end
|
#_verify_backfill_401_err_msg ⇒ Object
77
78
79
|
# File 'lib/webhookdb/replicator/twilio_sms_v1.rb', line 77
def _verify_backfill_401_err_msg
return "It looks like that API Key is invalid. Please reenter the API Key you just created:"
end
|
#_verify_backfill_err_msg ⇒ Object
81
82
83
|
# File 'lib/webhookdb/replicator/twilio_sms_v1.rb', line 81
def _verify_backfill_err_msg
return "An error occurred. Please reenter the API Key you just created:"
end
|
#_webhook_response(request) ⇒ Object
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
# File 'lib/webhookdb/replicator/twilio_sms_v1.rb', line 20
def _webhook_response(request)
auth = request.("Authorization")
if auth.nil? || !auth.match(/^Basic /)
return Webhookdb::WebhookResponse.new(
status: 401,
body: "",
reason: "challenge",
headers: {"Content-Type" => "text/plain", "WWW-Authenticate" => 'Basic realm="Webhookdb"'},
)
end
user_and_pass = Base64.decode64(auth.gsub(/^Basic /, ""))
if user_and_pass != self.service_integration.webhook_secret
return Webhookdb::WebhookResponse.new(
status: 401,
body: "",
reason: "invalid",
headers: {"Content-Type" => "text/plain"},
)
end
return Webhookdb::WebhookResponse.new(
status: 202,
headers: {"Content-Type" => "text/xml"},
body: "<Response></Response>",
)
end
|
#calculate_backfill_state_machine ⇒ Object
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
# File 'lib/webhookdb/replicator/twilio_sms_v1.rb', line 46
def calculate_backfill_state_machine
step = Webhookdb::Replicator::StateMachineStep.new
unless self.service_integration.backfill_key.present?
step.needs_input = true
step.output = %(Great! We've created your Twilio SMS integration.
Rather than using your Twilio Webhooks (of which each number can have only one),
we poll Twilio for changes, and will also backfill historical SMS.
To do this, we need your Account SID and Auth Token.
Both of these values should be visible from the homepage of your Twilio admin Dashboard.
)
return step.secret_prompt("Account SID").backfill_key(self.service_integration)
end
unless self.service_integration.backfill_secret.present?
return step.secret_prompt("Auth Token").backfill_secret(self.service_integration)
end
unless (result = self.verify_backfill_credentials).verified
self.service_integration.replicator.clear_backfill_information
step.output = result.message
return step.secret_prompt("API Key").backfill_key(self.service_integration)
end
step.output = %(We are going to start replicating your Twilio SMS information, and will keep it updated.
#{self._query_help_output}
)
return step.completed
end
|