Module: SourceMonitor

Defined in:: lib/source_monitor/configuration/deprecation_registry.rb,
lib/source_monitor.rb,
lib/source_monitor/http.rb,
lib/source_monitor/assets.rb,
lib/source_monitor/engine.rb,
lib/source_monitor/events.rb,
lib/source_monitor/health.rb,
lib/source_monitor/metrics.rb,
lib/source_monitor/queries.rb,
lib/source_monitor/version.rb,
lib/source_monitor/realtime.rb,
lib/source_monitor/scheduler.rb,
lib/source_monitor/setup/cli.rb,
lib/source_monitor/logs/query.rb,
app/models/source_monitor/item.rb,
app/models/source_monitor/source.rb,
lib/source_monitor/configuration.rb,
lib/source_monitor/scrapers/base.rb,
lib/source_monitor/assets/bundler.rb,
lib/source_monitor/release/runner.rb,
lib/source_monitor/scraping/state.rb,
lib/source_monitor/setup/prompter.rb,
lib/source_monitor/setup/workflow.rb,
lib/source_monitor/sources/params.rb,
lib/source_monitor/instrumentation.rb,
lib/source_monitor/jobs/visibility.rb,
lib/source_monitor/logs/entry_sync.rb,
lib/source_monitor/logs/filter_set.rb,
lib/source_monitor/scraping/runner.rb,
lib/source_monitor/setup/detectors.rb,
app/models/source_monitor/fetch_log.rb,
app/models/source_monitor/log_entry.rb,
lib/source_monitor/favicons/fetcher.rb,
lib/source_monitor/images/processor.rb,
lib/source_monitor/model_extensions.rb,
lib/source_monitor/realtime/adapter.rb,
app/models/source_monitor/scrape_log.rb,
lib/source_monitor/dashboard/queries.rb,
lib/source_monitor/http/aia_resolver.rb,
lib/source_monitor/images/downloader.rb,
lib/source_monitor/release/changelog.rb,
lib/source_monitor/scraping/enqueuer.rb,
lib/source_monitor/items/item_creator.rb,
lib/source_monitor/models/sanitizable.rb,
lib/source_monitor/scraping/scheduler.rb,
lib/source_monitor/setup/requirements.rb,
lib/source_monitor/setup/shell_runner.rb,
app/jobs/source_monitor/fetch_feed_job.rb,
app/models/source_monitor/item_content.rb,
lib/source_monitor/favicons/discoverer.rb,
lib/source_monitor/feedjira_extensions.rb,
app/jobs/source_monitor/application_job.rb,
app/jobs/source_monitor/import_opml_job.rb,
app/jobs/source_monitor/log_cleanup_job.rb,
app/jobs/source_monitor/scrape_item_job.rb,
lib/source_monitor/configuration/events.rb,
lib/source_monitor/configuration/models.rb,
lib/source_monitor/fetching/fetch_error.rb,
lib/source_monitor/jobs/cleanup_options.rb,
lib/source_monitor/logs/table_presenter.rb,
lib/source_monitor/pagination/paginator.rb,
lib/source_monitor/realtime/broadcaster.rb,
lib/source_monitor/scrapers/readability.rb,
lib/source_monitor/setup/gemfile_editor.rb,
lib/source_monitor/setup/node_installer.rb,
app/jobs/source_monitor/item_cleanup_job.rb,
app/models/source_monitor/import_history.rb,
app/models/source_monitor/import_session.rb,
lib/source_monitor/fetching/feed_fetcher.rb,
lib/source_monitor/fetching/fetch_runner.rb,
lib/source_monitor/fetching/retry_policy.rb,
lib/source_monitor/scraping/item_scraper.rb,
lib/source_monitor/setup/upgrade_command.rb,
app/jobs/source_monitor/favicon_fetch_job.rb,
lib/source_monitor/dashboard/quick_action.rb,
lib/source_monitor/favicons/svg_converter.rb,
lib/source_monitor/fetching/advisory_lock.rb,
lib/source_monitor/import_sessions/wizard.rb,
lib/source_monitor/items/normalized_entry.rb,
lib/source_monitor/items/retention_pruner.rb,
lib/source_monitor/setup/bundle_installer.rb,
lib/source_monitor/setup/procfile_patcher.rb,
lib/source_monitor/setup/skills_installer.rb,
app/models/source_monitor/health_check_log.rb,
lib/source_monitor/images/content_rewriter.rb,
lib/source_monitor/models/url_normalizable.rb,
lib/source_monitor/security/authentication.rb,
lib/source_monitor/setup/install_generator.rb,
app/models/concerns/source_monitor/loggable.rb,
lib/source_monitor/items/batch_item_creator.rb,
lib/source_monitor/jobs/solid_queue_metrics.rb,
lib/source_monitor/setup/dependency_checker.rb,
app/components/source_monitor/icon_component.rb,
app/helpers/source_monitor/table_sort_helper.rb,
app/jobs/source_monitor/schedule_fetches_job.rb,
app/models/source_monitor/application_record.rb,
app/presenters/source_monitor/base_presenter.rb,
lib/source_monitor/dashboard/recent_activity.rb,
lib/source_monitor/setup/initializer_patcher.rb,
lib/source_monitor/setup/migration_installer.rb,
lib/source_monitor/setup/verification/result.rb,
lib/source_monitor/setup/verification/runner.rb,
app/helpers/source_monitor/application_helper.rb,
app/mailers/source_monitor/application_mailer.rb,
lib/source_monitor/fetching/cloudflare_bypass.rb,
lib/source_monitor/health/source_health_check.rb,
lib/source_monitor/health/source_health_reset.rb,
lib/source_monitor/items/retention_strategies.rb,
lib/source_monitor/setup/queue_config_patcher.rb,
lib/source_monitor/setup/verification/printer.rb,
app/controllers/source_monitor/logs_controller.rb,
app/helpers/source_monitor/health_badge_helper.rb,
lib/source_monitor/configuration/http_settings.rb,
lib/source_monitor/dashboard/turbo_broadcaster.rb,
lib/source_monitor/fetching/retry_orchestrator.rb,
app/controllers/source_monitor/items_controller.rb,
app/jobs/source_monitor/source_health_check_job.rb,
lib/source_monitor/health/source_health_monitor.rb,
lib/source_monitor/scraping/bulk_source_scraper.rb,
lib/source_monitor/security/parameter_sanitizer.rb,
app/controllers/source_monitor/health_controller.rb,
lib/source_monitor/configuration/health_settings.rb,
lib/source_monitor/configuration/images_settings.rb,
lib/source_monitor/dashboard/queries/stats_query.rb,
lib/source_monitor/import_sessions/opml_importer.rb,
lib/source_monitor/jobs/fetch_failure_subscriber.rb,
app/controllers/source_monitor/sources_controller.rb,
lib/source_monitor/configuration/model_definition.rb,
lib/source_monitor/configuration/scraper_registry.rb,
lib/source_monitor/scrapers/fetchers/http_fetcher.rb,
lib/source_monitor/scraping/bulk_result_presenter.rb,
lib/source_monitor/sources/turbo_stream_presenter.rb,
lib/source_monitor/turbo_streams/stream_responder.rb,
app/controllers/concerns/source_monitor/set_source.rb,
lib/source_monitor/analytics/source_activity_rates.rb,
lib/source_monitor/analytics/sources_index_metrics.rb,
lib/source_monitor/configuration/favicons_settings.rb,
lib/source_monitor/configuration/fetching_settings.rb,
lib/source_monitor/configuration/realtime_settings.rb,
lib/source_monitor/configuration/scraping_settings.rb,
lib/source_monitor/items/item_creator/entry_parser.rb,
lib/source_monitor/queries/scrape_candidates_query.rb,
app/components/source_monitor/application_component.rb,
app/controllers/source_monitor/dashboard_controller.rb,
app/jobs/source_monitor/download_content_images_job.rb,
lib/source_monitor/analytics/scrape_recommendations.rb,
lib/source_monitor/configuration/retention_settings.rb,
lib/source_monitor/import_sessions/entry_normalizer.rb,
app/components/source_monitor/status_badge_component.rb,
app/controllers/source_monitor/fetch_logs_controller.rb,
lib/source_monitor/dashboard/quick_actions_presenter.rb,
lib/source_monitor/dashboard/upcoming_fetch_schedule.rb,
lib/source_monitor/fetching/stalled_fetch_reconciler.rb,
lib/source_monitor/health/import_source_health_check.rb,
lib/source_monitor/scraping/item_scraper/persistence.rb,
app/controllers/source_monitor/application_controller.rb,
app/controllers/source_monitor/scrape_logs_controller.rb,
app/controllers/source_monitor/source_turbo_responses.rb,
lib/source_monitor/configuration/deprecation_registry.rb,
lib/source_monitor/items/retention_strategies/destroy.rb,
app/controllers/source_monitor/item_scrapes_controller.rb,
app/presenters/source_monitor/source_details_presenter.rb,
app/presenters/source_monitor/sources_filter_presenter.rb,
lib/source_monitor/configuration/validation_definition.rb,
lib/source_monitor/dashboard/recent_activity_presenter.rb,
lib/source_monitor/fetching/completion/event_publisher.rb,
lib/source_monitor/scrapers/parsers/readability_parser.rb,
lib/source_monitor/setup/verification/telemetry_logger.rb,
app/components/source_monitor/filter_dropdown_component.rb,
app/jobs/source_monitor/import_session_health_check_job.rb,
lib/generators/source_monitor/install/install_generator.rb,
lib/source_monitor/fetching/feed_fetcher/source_updater.rb,
lib/source_monitor/import_sessions/health_check_updater.rb,
lib/source_monitor/items/item_creator/content_extractor.rb,
app/controllers/source_monitor/source_fetches_controller.rb,
app/controllers/source_monitor/source_retries_controller.rb,
lib/source_monitor/configuration/authentication_settings.rb,
lib/source_monitor/fetching/completion/follow_up_handler.rb,
lib/source_monitor/fetching/completion/retention_handler.rb,
lib/source_monitor/fetching/feed_fetcher/entry_processor.rb,
lib/source_monitor/fetching/feed_fetcher/failure_outcome.rb,
lib/source_monitor/fetching/feed_fetcher/success_outcome.rb,
app/controllers/source_monitor/import_sessions_controller.rb,
lib/source_monitor/items/retention_strategies/soft_delete.rb,
lib/source_monitor/scraping/item_scraper/adapter_resolver.rb,
lib/source_monitor/dashboard/queries/recent_activity_query.rb,
lib/source_monitor/fetching/feed_fetcher/adaptive_interval.rb,
lib/source_monitor/health/source_health_check_orchestrator.rb,
lib/source_monitor/setup/verification/solid_queue_verifier.rb,
lib/source_monitor/import_sessions/health_check_broadcaster.rb,
lib/source_monitor/setup/verification/action_cable_verifier.rb,
app/controllers/source_monitor/source_bulk_scrapes_controller.rb,
app/controllers/source_monitor/source_scrape_tests_controller.rb,
app/controllers/source_monitor/source_health_checks_controller.rb,
app/controllers/source_monitor/source_health_resets_controller.rb,
app/controllers/concerns/source_monitor/sanitizes_search_params.rb,
lib/source_monitor/analytics/source_fetch_interval_distribution.rb,
app/controllers/source_monitor/source_favicon_fetches_controller.rb,
app/controllers/source_monitor/bulk_scrape_enablements_controller.rb,
app/controllers/source_monitor/import_sessions/bulk_configuration.rb,
lib/source_monitor/setup/verification/pending_migrations_verifier.rb,
lib/source_monitor/setup/verification/recurring_schedule_verifier.rb,
app/controllers/source_monitor/import_history_dismissals_controller.rb,
lib/source_monitor/items/item_creator/entry_parser/media_extraction.rb

Overview

Add a helper method to settings classes and Configuration for resolving replacement targets. This allows “http.proxy” to resolve as self.http.proxy from within a Configuration instance, or as self.proxy from within an HTTPSettings instance.

Defined Under Namespace

Modules: Analytics, ApplicationHelper, Assets, Dashboard, Events, Favicons, FeedjiraExtensions, Fetching, Generators, HTTP, Health, HealthBadgeHelper, Images, ImportSessions, Instrumentation, Items, Jobs, Loggable, Logs, Metrics, ModelExtensions, Models, Pagination, Queries, Realtime, Release, SanitizesSearchParams, Scrapers, Scraping, Security, SetSource, Setup, SourceTurboResponses, Sources, TableSortHelper, TurboStreams Classes: ApplicationComponent, ApplicationController, ApplicationJob, ApplicationMailer, ApplicationRecord, BasePresenter, BulkScrapeEnablementsController, Configuration, DashboardController, DeprecatedOptionError, DownloadContentImagesJob, Engine, FaviconFetchJob, FetchFeedJob, FetchLog, FetchLogsController, FilterDropdownComponent, HealthCheckLog, HealthController, IconComponent, ImportHistory, ImportHistoryDismissalsController, ImportOpmlJob, ImportSession, ImportSessionHealthCheckJob, ImportSessionsController, Item, ItemCleanupJob, ItemContent, ItemScrapesController, ItemsController, LogCleanupJob, LogEntry, LogsController, ScheduleFetchesJob, Scheduler, ScrapeItemJob, ScrapeLog, ScrapeLogsController, Source, SourceBulkScrapesController, SourceDetailsPresenter, SourceFaviconFetchesController, SourceFetchesController, SourceHealthCheckJob, SourceHealthChecksController, SourceHealthResetsController, SourceRetriesController, SourceScrapeTestsController, SourcesController, SourcesFilterPresenter, StatusBadgeComponent

Constant Summary collapse

VERSION =

"0.13.1"

Class Method Details

.config ⇒ `Object`



226
227
228

# File 'lib/source_monitor.rb', line 226

def config
  @config ||= CONFIG_MONITOR.synchronize { @config ||= Configuration.new }
end

.configure ⇒ `Object`

# File 'lib/source_monitor.rb', line 218

def configure
  CONFIG_MONITOR.synchronize do
    yield config
    config.check_deprecations!
    SourceMonitor::ModelExtensions.reload!
  end
end

.events ⇒ `Object`



230
231
232

# File 'lib/source_monitor.rb', line 230

def events
  config.events
end

.mission_control_dashboard_path ⇒ `Object`

# File 'lib/source_monitor.rb', line 260

def mission_control_dashboard_path
  raw_path = config.mission_control_dashboard_path
  resolved = resolve_callable(raw_path)
  return if resolved.blank?

  valid_dashboard_path?(resolved) ? resolved : nil
rescue StandardError
  nil
end

.mission_control_enabled? ⇒ `Boolean`

Returns:

(Boolean)



256
257
258

# File 'lib/source_monitor.rb', line 256

def mission_control_enabled?
  config.mission_control_enabled
end

.queue_concurrency(role) ⇒ `Object`



248
249
250

# File 'lib/source_monitor.rb', line 248

def queue_concurrency(role)
  config.concurrency_for(role)
end

.queue_name(role) ⇒ `Object`



244
245
246

# File 'lib/source_monitor.rb', line 244

def queue_name(role)
  config.queue_name_for(role)
end

.reset_configuration! ⇒ `Object`

# File 'lib/source_monitor.rb', line 234

def reset_configuration!
  CONFIG_MONITOR.synchronize do
    @config = Configuration.new
    SourceMonitor::ModelExtensions.reload!
    SourceMonitor::Health.setup!
    SourceMonitor::Realtime.setup!
    SourceMonitor::Dashboard::TurboBroadcaster.setup!
  end
end

.table_name_prefix ⇒ `Object`



252
253
254

# File 'lib/source_monitor.rb', line 252

def table_name_prefix
  SourceMonitor::Engine.table_name_prefix
end

Module: SourceMonitor

Overview

Defined Under Namespace

Constant Summary collapse

Class Method Summary collapse

Class Method Details

.config ⇒ Object

.configure ⇒ Object

.events ⇒ Object

.mission_control_dashboard_path ⇒ Object

.mission_control_enabled? ⇒ Boolean

.queue_concurrency(role) ⇒ Object

.queue_name(role) ⇒ Object

.reset_configuration! ⇒ Object

.table_name_prefix ⇒ Object