sm-job

Solid Queue job conventions for the SourceMonitor engine. Use when creating new background jobs, modifying existing jobs, configuring queues, or working with job scheduling and retry policies.

Aller à l'installation

Dépôt: dchuk/source_monitor
Dernière activité de la source: 17 mars 2026 à 14:57
Langue détectée de SKILL.md: anglais
Étoiles: 3
Forks: 0

Options d'installation

Le prompt qui vérifie d'abord la source est sélectionné par défaut. Vous pouvez passer à une commande directe ou télécharger une copie locale.

Installer avec Codex ou Claude Copiez ce prompt, collez-le dans Codex, Claude ou un autre assistant, puis laissez-le vérifier la page du skill et l'installer pour vous.

Une commande directe contourne le prompt de vérification. Examinez la source avant de l'exécuter.

npx skills add https://github.com/dchuk/source_monitor --skill sm-job

La commande reste sur une seule ligne. Faites défiler horizontalement pour la vérifier avant de la copier.

Vous préférez une copie locale ? Téléchargez les fichiers actuellement disponibles dans SkillsMP.

Vérifiez les fichiers source

Lisez SKILL.md et les fichiers associés affichés par SkillsMP avant de décider de l'installer.

Explorateur de fichiers

2 fichiers

SKILL.md

Instructions source · Aperçu en lecture seule

Retour à la recherche Retour à l’installation

sm-upgrade

Use when upgrading SourceMonitor to a new gem version, including CHANGELOG review, running the upgrade command, interpreting verification results, and handling configuration deprecations.

2026-06-18

sm-configuration-setting

How to add or modify configuration settings in the Source Monitor engine. Use when adding a new config option, modifying defaults, creating a new settings section, or understanding the configuration architecture.

2026-05-28

sm-configure

Use when configuring SourceMonitor engine settings via the DSL, including queue settings, HTTP client, fetching, health, scrapers, retention, scraping controls, events, model extensions, realtime, and authentication.

2026-05-28

Tout voir dans ce dépôt

ScheduleFetchesJob

# CORRECT -- shallow delegation
def perform(source_id)
  source = SourceMonitor::Source.find_by(id: source_id)
  return unless source
  SourceMonitor::Fetching::FetchRunner.new(source: source).run
end

# WRONG -- business logic in job
def perform(source_id)
  source = SourceMonitor::Source.find(source_id)
  response = Faraday.get(source.feed_url)  # Don't do this
  feed = Feedjira.parse(response.body)      # Business logic belongs elsewhere
end

class MyJob < SourceMonitor::ApplicationJob
  source_monitor_queue :fetch  # Uses SourceMonitor.queue_name(:fetch)
end

def perform(source_id)
  source = SourceMonitor::Source.find_by(id: source_id)
  return unless source  # Silently skip if deleted
  # ...
end

discard_on ActiveJob::DeserializationError  # Record deleted between enqueue and perform
retry_on SomeTransientError, wait: 30.seconds, attempts: 5

def log(stage, **extra)
  return unless defined?(Rails) && Rails.respond_to?(:logger) && Rails.logger
  payload = { stage: "SourceMonitor::MyJob##{stage}", **extra }.compact
  Rails.logger.info("[SourceMonitor::MyJob] #{payload.to_json}")
rescue StandardError
  nil
end

# app/jobs/source_monitor/my_new_job.rb
# frozen_string_literal: true

module SourceMonitor
  class MyNewJob < ApplicationJob
    source_monitor_queue :fetch  # or :scrape

    discard_on ActiveJob::DeserializationError

    def perform(record_id)
      record = SourceMonitor::Source.find_by(id: record_id)
      return unless record

      # Delegate to a service/model method
      SourceMonitor::MyService.new(record: record).call
    end
  end
end

SourceMonitor.configure do |config|
  config.queue_namespace = "source_monitor"        # Base namespace
  config.fetch_queue_name = "source_monitor_fetch"  # Fetch queue name
  config.scrape_queue_name = "source_monitor_scrape" # Scrape queue name
  config.fetch_queue_concurrency = 2                # Concurrent fetch workers
  config.scrape_queue_concurrency = 2               # Concurrent scrape workers
end

SourceMonitor.queue_name(:fetch)  # => "source_monitor_fetch"
# With host app prefix "myapp":   => "myapp_source_monitor_fetch"

options = CleanupOptions.normalize(options)  # Symbolize keys, handle nil
now = CleanupOptions.resolve_time(options[:now])  # Parse time strings
ids = CleanupOptions.extract_ids(options[:source_ids])  # Flatten/parse IDs
batch_size = CleanupOptions.batch_size(options, default: 100)  # Safe integer

# test/jobs/source_monitor/my_new_job_test.rb
# frozen_string_literal: true

require "test_helper"

module SourceMonitor
  class MyNewJobTest < ActiveJob::TestCase
    setup do
      @source = create_source!
    end

    test "performs work for valid source" do
      # Stub external calls
      MyService.any_instance.expects(:call).once

      MyNewJob.perform_now(@source.id)
    end

    test "silently skips missing source" do
      assert_nothing_raised do
        MyNewJob.perform_now(-1)
      end
    end

    test "enqueues on correct queue" do
      assert_enqueued_with(job: MyNewJob, queue: SourceMonitor.queue_name(:fetch).to_s) do
        MyNewJob.perform_later(@source.id)
      end
    end
  end
end

test "fetching enqueues via FetchRunner.enqueue" do
  with_inline_jobs do
    stub_request(:get, source.feed_url).to_return(status: 200, body: feed_xml)
    SourceMonitor::Fetching::FetchRunner.enqueue(source)
  end
end

Queue Role	Default Name	Jobs
`:fetch`	`source_monitor_fetch`	FetchFeedJob, ScheduleFetchesJob, ItemCleanupJob, LogCleanupJob, SourceHealthCheckJob, ImportOpmlJob, ImportSessionHealthCheckJob
`:scrape`	`source_monitor_scrape`	ScrapeItemJob

Job	Queue	Purpose	Pattern
`FetchFeedJob`	`:fetch`	Fetches a single source's feed	Delegates to `FetchRunner`

Queue Role	Default Name	Jobs
`:fetch`	`source_monitor_fetch`	FetchFeedJob, ScheduleFetchesJob, ItemCleanupJob, LogCleanupJob, SourceHealthCheckJob, ImportOpmlJob, ImportSessionHealthCheckJob
`:scrape`	`source_monitor_scrape`	ScrapeItemJob

Job	Queue	Purpose	Pattern
`FetchFeedJob`	`:fetch`	Fetches a single source's feed	Delegates to `FetchRunner`

Job	Schedule
`SourceMonitor::ScheduleFetchesJob`	every minute
`SourceMonitor::Scraping::Scheduler.run`	every 2 minutes
`SourceMonitor::ItemCleanupJob`	at 2am every day
`SourceMonitor::LogCleanupJob`	at 3am every day

sm-job

Options d'installation

Vérifiez les fichiers source

SourceMonitor Job Development

Overview

Queue Architecture

Existing Jobs

SourceMonitor Job Development

Overview

Queue Architecture

Existing Jobs

Key Conventions

1. Shallow Jobs

2. Queue Declaration

3. ID-Based Arguments

4. Error Handling

5. Logging Pattern

Creating a New Job

Template

Steps

Queue Configuration

Engine Configuration

Queue Name Resolution

Recurring Jobs

Retry Policies

CleanupOptions Helper

Testing

Test Template

Testing Enqueue from Models

Checklist

References

name	sm-job
description	Solid Queue job conventions for the SourceMonitor engine. Use when creating new background jobs, modifying existing jobs, configuring queues, or working with job scheduling and retry policies.
allowed-tools	Read, Write, Edit, Bash, Glob, Grep

Error Type	Retry Attempts	Wait	Circuit Breaker
Timeout	2	2 min	1 hour
Connection	3	5 min	1 hour
HTTP 429	2	15 min	90 min
HTTP 5xx	2	10 min	90 min
HTTP 4xx	1	45 min	2 hours
Parsing	1	30 min	2 hours
Unexpected	1	30 min	2 hours

sm-job

Informations de source

Options d'installation

Vérifiez les fichiers source

Plus depuis ce dépôt

Plus depuis ce dépôt

SourceMonitor Job Development

Overview

Queue Architecture

Existing Jobs

SourceMonitor Job Development

Overview

Queue Architecture

Existing Jobs

Key Conventions

1. Shallow Jobs

2. Queue Declaration

3. ID-Based Arguments

4. Error Handling

5. Logging Pattern

Creating a New Job

Template

Steps

Queue Configuration

Engine Configuration

Queue Name Resolution

Recurring Jobs

Retry Policies

CleanupOptions Helper

Testing

Test Template

Testing Enqueue from Models

Checklist

References