Class: Webhookdb::Replicator::IntercomMarketplaceRootV1

Inherits:
Base
  • Object
show all
Includes:
Appydays::Loggable
Defined in:
lib/webhookdb/replicator/intercom_marketplace_root_v1.rb

Constant Summary

Constants inherited from Base

Base::MAX_INDEX_NAME_LENGTH

Constants included from DBAdapter::ColumnTypes

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_and_event, #_resource_to_data, #_store_enrichment_body?, #_timestamp_column_name, #_to_json, #_update_where_expr, #_upsert_update_expr, #_verify_backfill_err_msg, #_webhook_response, #_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

Constructor Details

This class inherits a constructor from Webhookdb::Replicator::Base

Class Method Details

.descriptor ⇒ Webhookdb::Replicator::Descriptor

Returns:



7
8
9
10
11
12
13
14
15
16
17
18
 
# File 'lib/webhookdb/replicator/intercom_marketplace_root_v1.rb', line 7

def self.descriptor
  return Webhookdb::Replicator::Descriptor.new(
    name: "intercom_marketplace_root_v1",
    ctor: self,
    feature_roles: ["intercom"],
    resource_name_singular: "Intercom Auth",
    resource_name_plural: "Intercom Auth",
    supports_backfill: true,
    description: "You can replicate your Intercom data to WebhookDB Cloud in one click using  " \
                 "the [Intercom App Store](https://www.intercom.com/app-store).",
  )
end

Instance Method Details

#_denormalized_columns ⇒ Object 



24
25
26
 
# File 'lib/webhookdb/replicator/intercom_marketplace_root_v1.rb', line 24

def _denormalized_columns
  return []
end

#_fetch_backfill_page ⇒ Object 



30
31
32
 
# File 'lib/webhookdb/replicator/intercom_marketplace_root_v1.rb', line 30

def _fetch_backfill_page(*)
  return [], nil
end

#_remote_key_column ⇒ Object 



20
21
22
 
# File 'lib/webhookdb/replicator/intercom_marketplace_root_v1.rb', line 20

def _remote_key_column
  return Webhookdb::Replicator::Column.new(:ignore_id, INTEGER)
end

#_upsert_webhook(**_kwargs) ⇒ Object 



28
 
# File 'lib/webhookdb/replicator/intercom_marketplace_root_v1.rb', line 28

def _upsert_webhook(**_kwargs) = raise NotImplementedError("This is a stub integration only for auth purposes.")

#build_dependents ⇒ Object 



43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
 
# File 'lib/webhookdb/replicator/intercom_marketplace_root_v1.rb', line 43

def build_dependents
  org = self.service_integration.organization
  contact_sint = Webhookdb::ServiceIntegration.create_disambiguated(
    "intercom_contact_v1",
    organization: org,
    depends_on: self.service_integration,
  )
  conversation_sint = Webhookdb::ServiceIntegration.create_disambiguated(
    "intercom_conversation_v1",
    organization: org,
    depends_on: self.service_integration,
  )
  contact_sint.replicator._enqueue_backfill_jobs(incremental: true)
  conversation_sint.replicator._enqueue_backfill_jobs(incremental: true)
end

#calculate_backfill_state_machine ⇒ Object 



36
37
38
39
40
41
 
# File 'lib/webhookdb/replicator/intercom_marketplace_root_v1.rb', line 36

def calculate_backfill_state_machine
  step = Webhookdb::Replicator::StateMachineStep.new
  step.output = "This integration cannot be modified through the command line."
  step.completed
  return step
end

#webhook_response(_request) ⇒ Object 



34
 
# File 'lib/webhookdb/replicator/intercom_marketplace_root_v1.rb', line 34

def webhook_response(_request) = raise NotImplementedError("This is a stub integration only for auth purposes.")