1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
//! Post-publish polling configuration shared by the Chocolatey and WinGet
//! publishers.
//!
//! Both publishers report `HTTP 2xx` from the submission endpoint long
//! before the upstream actually approves the package (Chocolatey
//! moderation queue) or merges the PR (winget-pkgs validation pipeline).
//! When polling is enabled, the publish stage waits for a terminal
//! moderation/validation state up to `timeout`, sampling every
//! `interval`, and surfaces the result as part of the release summary.
//!
//! Defaults: `enabled: true`, `interval: 30s`, `timeout: 30m`. Callers
//! that want a fire-and-forget publish (CI without long-running waits)
//! either set `enabled: false` per-publisher or pass
//! `--no-post-publish-poll` globally.
use schemars::JsonSchema;
use serde::{Deserialize, Serialize};
use super::HumanDuration;
/// Per-publisher post-publish polling config block.
///
/// See module-level docs for the polling lifecycle. Default values:
/// `enabled: true`, `interval: 30s`, `timeout: 30m`.
#[derive(Debug, Clone, Copy, Serialize, Deserialize, JsonSchema)]
#[serde(default, deny_unknown_fields)]
pub struct PostPublishPollConfig {
/// Whether to poll at all. Default `true`. Setting `false` disables
/// polling without removing the config block (parity with every
/// `skip:` toggle elsewhere in the schema).
pub enabled: bool,
/// How long to wait between successive status checks. Default `30s`.
pub interval: HumanDuration,
/// Total wall-clock budget for polling. When exhausted, the poller
/// emits `PostPublishStatus::Timeout` with the last observed state.
/// Default `30m`.
pub timeout: HumanDuration,
}
impl PostPublishPollConfig {
/// Default interval between successive polls (30 seconds).
pub const DEFAULT_INTERVAL: std::time::Duration = std::time::Duration::from_secs(30);
/// Default total polling budget (30 minutes).
pub const DEFAULT_TIMEOUT: std::time::Duration = std::time::Duration::from_secs(30 * 60);
}
impl Default for PostPublishPollConfig {
fn default() -> Self {
Self {
enabled: true,
interval: HumanDuration(Self::DEFAULT_INTERVAL),
timeout: HumanDuration(Self::DEFAULT_TIMEOUT),
}
}
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn defaults_match_spec() {
let c = PostPublishPollConfig::default();
assert!(c.enabled);
assert_eq!(c.interval.duration(), std::time::Duration::from_secs(30));
assert_eq!(
c.timeout.duration(),
std::time::Duration::from_secs(30 * 60)
);
}
#[test]
fn empty_yaml_yields_defaults() {
let c: PostPublishPollConfig = serde_yaml_ng::from_str("{}").unwrap();
assert!(c.enabled);
assert_eq!(c.interval.duration(), std::time::Duration::from_secs(30));
assert_eq!(
c.timeout.duration(),
std::time::Duration::from_secs(30 * 60)
);
}
#[test]
fn parses_explicit_yaml() {
let yaml = "enabled: false\ninterval: 1m\ntimeout: 5m\n";
let c: PostPublishPollConfig = serde_yaml_ng::from_str(yaml).unwrap();
assert!(!c.enabled);
assert_eq!(c.interval.duration(), std::time::Duration::from_secs(60));
assert_eq!(c.timeout.duration(), std::time::Duration::from_secs(5 * 60));
}
#[test]
fn unknown_field_rejected() {
let yaml = "interval: 1m\nbogus: true\n";
let res: Result<PostPublishPollConfig, _> = serde_yaml_ng::from_str(yaml);
assert!(res.is_err(), "deny_unknown_fields must reject typos");
}
}