Class: Webhookdb::Replicator::TransistorShowV1
- Includes:
- Appydays::Loggable, TransistorV1Mixin
- Defined in:
- lib/webhookdb/replicator/transistor_show_v1.rb
Constant Summary
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
Constants inherited from Base
Instance Attribute Summary
Attributes inherited from Base
Class Method Summary collapse
Instance Method Summary collapse
Methods included from TransistorV1Mixin
#_remote_key_column, #_resource_and_event, #_timestamp_column_name, #_update_where_expr, #_verify_backfill_401_err_msg, #_verify_backfill_err_msg, #_webhook_response, #calculate_backfill_state_machine
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, #_remote_key_column, #_resource_and_event, #_resource_to_data, #_store_enrichment_body?, #_timestamp_column_name, #_to_json, #_update_where_expr, #_upsert_update_expr, #_upsert_webhook, #_verify_backfill_err_msg, #_webhook_response, #_webhook_state_change_fields, #admin_dataset, #backfill, #backfill_not_supported_message, #calculate_and_backfill_state_machine, #calculate_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
Constructor Details
This class inherits a constructor from Webhookdb::Replicator::Base
Class Method Details
.descriptor ⇒ Webhookdb::Replicator::Descriptor
10 11 12 13 14 15 16 17 18 19 |
# File 'lib/webhookdb/replicator/transistor_show_v1.rb', line 10 def self.descriptor return Webhookdb::Replicator::Descriptor.new( name: "transistor_show_v1", ctor: ->(sint) { Webhookdb::Replicator::TransistorShowV1.new(sint) }, feature_roles: [], resource_name_singular: "Transistor Show", supports_backfill: true, api_docs_url: "https://developers.transistor.fm/#Show", ) end |
Instance Method Details
#_denormalized_columns ⇒ Object
21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 |
# File 'lib/webhookdb/replicator/transistor_show_v1.rb', line 21 def _denormalized_columns return [ Webhookdb::Replicator::Column.new(:author, TEXT, data_key: ["attributes", "author"]), Webhookdb::Replicator::Column.new( :created_at, TIMESTAMP, index: true, data_key: ["attributes", "created_at"], ), Webhookdb::Replicator::Column.new(:description, TEXT, data_key: ["attributes", "description"]), Webhookdb::Replicator::Column.new(:title, TEXT, data_key: ["attributes", "title"]), Webhookdb::Replicator::Column.new( :updated_at, TIMESTAMP, index: true, data_key: ["attributes", "updated_at"], ), Webhookdb::Replicator::Column.new(:website, TEXT, data_key: ["attributes", "website"]), ] end |
#_fetch_backfill_page(pagination_token, **_kwargs) ⇒ Object
41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 |
# File 'lib/webhookdb/replicator/transistor_show_v1.rb', line 41 def _fetch_backfill_page(pagination_token, **_kwargs) pagination_token ||= [false, 1] , page = pagination_token url = "https://api.transistor.fm/v1/shows" response = Webhookdb::Http.get( url, headers: {"x-api-key" => self.service_integration.backfill_key}, body: {pagination: {page:}, private: }, logger: self.logger, timeout: Webhookdb::Transistor.http_timeout, ) data = response.parsed_response current_page = data["meta"]["currentPage"] total_pages = data["meta"]["totalPages"] shows = data["data"] if current_page < total_pages # If we still have pages on this list, go to the next one return shows, [, current_page + 1] end # If we are done with the public list, we can now iterate over private shows return shows, [true, 1] unless # Otherwise we are on the last page of our private list return shows, nil end |