DAEMON's docs/adr/0013-task-state-machine-ownership.md needs a wire signal
for the difference between a paused task the daemon entered unilaterally
(auth_required, server_file_changed, disk_full) and one that was requested
(user, schedule, queue stop, admission reconcile) -- without it, DAEMON's §3
resume rule ("resume only when the reason matches the event that justifies
resuming") has nothing correctness-preserving to key on, and would have to
guess from timing. CORE has already accepted the ADR; this was the sole
remaining blocker per DAEMON's own status line on it.
No retype, no new field -- error was already TaskError | null on both
event.task.state and TaskSummary, exactly as DAEMON characterized the ask.
Only the *description* of when it is populated widens: previously "failed or
retry_wait", now also "paused, when the daemon entered it on its own
initiative". A deliberate pause still carries error: null. TaskError's own
top-level description gets the same widening, since it previously also said
"failed or retry_wait" and would otherwise contradict the field that embeds
it.
New fixture (event.task.state.auto-paused.json) exercises the case directly:
an auth_required pause with error populated, contrasted in its own
description against download.pause.json's error: null for a requested pause.
The existing event.task.state.json fixture's first assertion was stale
("error is present exactly when failed or retry_wait") and is corrected.
Minor bump, 1.2.0 -> 1.3.0: a description widening on an already-nullable,
already-optional field changes no JSON Schema shape, but it is a real
behavioral commitment change worth a version bump so downstream regenerates
and notices, per the same reasoning ADR 0010 applied to TaskErrorCode.
Co-Authored-By: Claude Sonnet 5 <[email protected]>
Claude-Session: https://claude.ai/code/session_012fgjnqFCS5h5L7gZTZo3rV
238 lines
9.4 KiB
C++
238 lines
9.4 KiB
C++
// ---------------------------------------------------------------------------
|
|
// GENERATED FILE — DO NOT EDIT.
|
|
//
|
|
// Source: contracts/schema/**
|
|
// Generator: contracts/codegen/gen_cpp.py
|
|
// Contract: v1.3.0
|
|
//
|
|
// Hand-editing this file is a merge blocker. Fix the schema and regenerate:
|
|
// python3 contracts/codegen/gen_cpp.py
|
|
// Only lane PROTO commits to contracts/.
|
|
// ---------------------------------------------------------------------------
|
|
|
|
#pragma once
|
|
|
|
#include "velox_proto.hpp"
|
|
|
|
#include <functional>
|
|
#include <string>
|
|
|
|
namespace velox::conformance {
|
|
|
|
/// Answers every method from its golden fixture, so the generated dispatch path
|
|
/// itself is under test: envelope, transport check, param parse, result serialise.
|
|
class FixtureDispatcher final : public proto::Dispatcher {
|
|
public:
|
|
/// `results` maps a method name to that method's golden result JSON.
|
|
explicit FixtureDispatcher(std::function<const nlohmann::json*(const std::string&)> results)
|
|
: results_(std::move(results)) {}
|
|
|
|
proto::Result<proto::CaptureRules> on_capture_getRules(const proto::CaptureGetRulesParams& params) override {
|
|
(void)params;
|
|
return golden<proto::CaptureRules>("capture.getRules");
|
|
}
|
|
|
|
proto::Result<proto::CaptureOfferResult> on_capture_offer(const proto::CaptureOfferParams& params) override {
|
|
(void)params;
|
|
return golden<proto::CaptureOfferResult>("capture.offer");
|
|
}
|
|
|
|
proto::Result<proto::CategoryListResult> on_category_list(const proto::CategoryListParams& params) override {
|
|
(void)params;
|
|
return golden<proto::CategoryListResult>("category.list");
|
|
}
|
|
|
|
proto::Result<proto::CategoryRemoveResult> on_category_remove(const proto::CategoryRemoveParams& params) override {
|
|
(void)params;
|
|
return golden<proto::CategoryRemoveResult>("category.remove");
|
|
}
|
|
|
|
proto::Result<proto::CategoryUpsertResult> on_category_upsert(const proto::CategoryUpsertParams& params) override {
|
|
(void)params;
|
|
return golden<proto::CategoryUpsertResult>("category.upsert");
|
|
}
|
|
|
|
proto::Result<proto::DownloadAddResult> on_download_add(const proto::DownloadSpec& params) override {
|
|
(void)params;
|
|
return golden<proto::DownloadAddResult>("download.add");
|
|
}
|
|
|
|
proto::Result<proto::DownloadAddBatchResult> on_download_addBatch(const proto::DownloadAddBatchParams& params) override {
|
|
(void)params;
|
|
return golden<proto::DownloadAddBatchResult>("download.addBatch");
|
|
}
|
|
|
|
proto::Result<proto::BulkTaskResult> on_download_cancel(const proto::DownloadCancelParams& params) override {
|
|
(void)params;
|
|
return golden<proto::BulkTaskResult>("download.cancel");
|
|
}
|
|
|
|
proto::Result<proto::TaskDetail> on_download_get(const proto::DownloadGetParams& params) override {
|
|
(void)params;
|
|
return golden<proto::TaskDetail>("download.get");
|
|
}
|
|
|
|
proto::Result<proto::DownloadListResult> on_download_list(const proto::DownloadListParams& params) override {
|
|
(void)params;
|
|
return golden<proto::DownloadListResult>("download.list");
|
|
}
|
|
|
|
proto::Result<proto::BulkTaskResult> on_download_pause(const proto::DownloadPauseParams& params) override {
|
|
(void)params;
|
|
return golden<proto::BulkTaskResult>("download.pause");
|
|
}
|
|
|
|
proto::Result<proto::DownloadProbeResult> on_download_probe(const proto::DownloadProbeParams& params) override {
|
|
(void)params;
|
|
return golden<proto::DownloadProbeResult>("download.probe");
|
|
}
|
|
|
|
proto::Result<proto::DownloadProvideAuthResult> on_download_provideAuth(const proto::DownloadProvideAuthParams& params) override {
|
|
(void)params;
|
|
return golden<proto::DownloadProvideAuthResult>("download.provideAuth");
|
|
}
|
|
|
|
proto::Result<proto::DownloadRefreshUrlResult> on_download_refreshUrl(const proto::DownloadRefreshUrlParams& params) override {
|
|
(void)params;
|
|
return golden<proto::DownloadRefreshUrlResult>("download.refreshUrl");
|
|
}
|
|
|
|
proto::Result<proto::DownloadRemoveResult> on_download_remove(const proto::DownloadRemoveParams& params) override {
|
|
(void)params;
|
|
return golden<proto::DownloadRemoveResult>("download.remove");
|
|
}
|
|
|
|
proto::Result<proto::BulkTaskResult> on_download_resume(const proto::DownloadResumeParams& params) override {
|
|
(void)params;
|
|
return golden<proto::BulkTaskResult>("download.resume");
|
|
}
|
|
|
|
proto::Result<proto::BulkTaskResult> on_download_start(const proto::DownloadStartParams& params) override {
|
|
(void)params;
|
|
return golden<proto::BulkTaskResult>("download.start");
|
|
}
|
|
|
|
proto::Result<proto::TaskSummary> on_download_update(const proto::DownloadUpdateParams& params) override {
|
|
(void)params;
|
|
return golden<proto::TaskSummary>("download.update");
|
|
}
|
|
|
|
proto::Result<proto::GrabberHarvestResult> on_grabber_harvest(const proto::GrabberHarvestParams& params) override {
|
|
(void)params;
|
|
return golden<proto::GrabberHarvestResult>("grabber.harvest");
|
|
}
|
|
|
|
proto::Result<proto::GrabberStartResult> on_grabber_start(const proto::GrabberStartParams& params) override {
|
|
(void)params;
|
|
return golden<proto::GrabberStartResult>("grabber.start");
|
|
}
|
|
|
|
proto::Result<proto::GrabberStatusResult> on_grabber_status(const proto::GrabberStatusParams& params) override {
|
|
(void)params;
|
|
return golden<proto::GrabberStatusResult>("grabber.status");
|
|
}
|
|
|
|
proto::Result<proto::Limiter> on_limiter_get(const proto::LimiterGetParams& params) override {
|
|
(void)params;
|
|
return golden<proto::Limiter>("limiter.get");
|
|
}
|
|
|
|
proto::Result<proto::Limiter> on_limiter_set(const proto::Limiter& params) override {
|
|
(void)params;
|
|
return golden<proto::Limiter>("limiter.set");
|
|
}
|
|
|
|
proto::Result<proto::MediaAddVariantResult> on_media_addVariant(const proto::MediaAddVariantParams& params) override {
|
|
(void)params;
|
|
return golden<proto::MediaAddVariantResult>("media.addVariant");
|
|
}
|
|
|
|
proto::Result<proto::MediaListVariantsResult> on_media_listVariants(const proto::MediaListVariantsParams& params) override {
|
|
(void)params;
|
|
return golden<proto::MediaListVariantsResult>("media.listVariants");
|
|
}
|
|
|
|
proto::Result<proto::QueueListResult> on_queue_list(const proto::QueueListParams& params) override {
|
|
(void)params;
|
|
return golden<proto::QueueListResult>("queue.list");
|
|
}
|
|
|
|
proto::Result<proto::QueueReorderResult> on_queue_reorder(const proto::QueueReorderParams& params) override {
|
|
(void)params;
|
|
return golden<proto::QueueReorderResult>("queue.reorder");
|
|
}
|
|
|
|
proto::Result<proto::QueueStartResult> on_queue_start(const proto::QueueStartParams& params) override {
|
|
(void)params;
|
|
return golden<proto::QueueStartResult>("queue.start");
|
|
}
|
|
|
|
proto::Result<proto::QueueStopResult> on_queue_stop(const proto::QueueStopParams& params) override {
|
|
(void)params;
|
|
return golden<proto::QueueStopResult>("queue.stop");
|
|
}
|
|
|
|
proto::Result<proto::QueueUpsertResult> on_queue_upsert(const proto::QueueUpsertParams& params) override {
|
|
(void)params;
|
|
return golden<proto::QueueUpsertResult>("queue.upsert");
|
|
}
|
|
|
|
proto::Result<proto::RulesListResult> on_rules_list(const proto::RulesListParams& params) override {
|
|
(void)params;
|
|
return golden<proto::RulesListResult>("rules.list");
|
|
}
|
|
|
|
proto::Result<proto::RulesUpsertResult> on_rules_upsert(const proto::RulesUpsertParams& params) override {
|
|
(void)params;
|
|
return golden<proto::RulesUpsertResult>("rules.upsert");
|
|
}
|
|
|
|
proto::Result<proto::ScheduleGetResult> on_schedule_get(const proto::ScheduleGetParams& params) override {
|
|
(void)params;
|
|
return golden<proto::ScheduleGetResult>("schedule.get");
|
|
}
|
|
|
|
proto::Result<proto::ScheduleSetResult> on_schedule_set(const proto::ScheduleSetParams& params) override {
|
|
(void)params;
|
|
return golden<proto::ScheduleSetResult>("schedule.set");
|
|
}
|
|
|
|
proto::Result<proto::SessionHelloResult> on_session_hello(const proto::SessionHelloParams& params) override {
|
|
(void)params;
|
|
return golden<proto::SessionHelloResult>("session.hello");
|
|
}
|
|
|
|
proto::Result<proto::SessionPairResult> on_session_pair(const proto::SessionPairParams& params) override {
|
|
(void)params;
|
|
return golden<proto::SessionPairResult>("session.pair");
|
|
}
|
|
|
|
proto::Result<proto::SessionSubscribeResult> on_session_subscribe(const proto::SessionSubscribeParams& params) override {
|
|
(void)params;
|
|
return golden<proto::SessionSubscribeResult>("session.subscribe");
|
|
}
|
|
|
|
proto::Result<proto::SettingsGetResult> on_settings_get(const proto::SettingsGetParams& params) override {
|
|
(void)params;
|
|
return golden<proto::SettingsGetResult>("settings.get");
|
|
}
|
|
|
|
proto::Result<proto::SettingsSetResult> on_settings_set(const proto::SettingsSetParams& params) override {
|
|
(void)params;
|
|
return golden<proto::SettingsSetResult>("settings.set");
|
|
}
|
|
|
|
private:
|
|
template <class T>
|
|
proto::Result<T> golden(const std::string& method) {
|
|
const nlohmann::json* value = results_(method);
|
|
if (value == nullptr)
|
|
return std::unexpected(proto::ParseError{method, "no fixture for this method"});
|
|
return proto::parse<T>(*value, method);
|
|
}
|
|
|
|
std::function<const nlohmann::json*(const std::string&)> results_;
|
|
};
|
|
|
|
} // namespace velox::conformance
|