stackless_integrations/providers/cloudflare/
browser_run.rs1use std::collections::BTreeMap;
5
6use serde::Serialize;
7use stackless_stripe_projects::catalog::verify::CatalogService;
8use stackless_stripe_projects::provision::ProvisionContext;
9
10use super::CloudflareResource;
11use crate::error::IntegrationError;
12use crate::hostable::{ConfigScope, Hostable, IntegrationHosting};
13
14pub const RESOURCE_KIND: &str = "integration-cloudflare-browser-run";
15
16#[derive(Debug, Serialize)]
17pub struct BrowserRunConfig {}
18
19impl CatalogService for BrowserRunConfig {
20 const REFERENCE: &'static str = "cloudflare/browser-run";
21}
22
23#[derive(Debug)]
24pub struct CloudflareBrowserRun;
25
26impl Hostable for CloudflareBrowserRun {
27 const PROVIDER: &'static str = "cloudflare-browser-run";
28 const HOSTING: IntegrationHosting = IntegrationHosting::Managed;
29 const CONFIG_SCOPE: ConfigScope = ConfigScope::GlobalOnly;
30 const RESOURCE_KIND: &'static str = RESOURCE_KIND;
31 const OUTPUTS: &'static [&'static str] = super::WORKERS_FAMILY_OUTPUTS;
32}
33
34impl CloudflareResource for CloudflareBrowserRun {
35 type Config = BrowserRunConfig;
36 const PROVIDER_PREFIX: &'static str = "CLOUDFLARE";
37 const OUTPUT_FIELDS: &'static [(&'static str, &'static str, bool)] =
39 super::WORKERS_FAMILY_OUTPUT_FIELDS;
40
41 fn build_config(_ctx: &ProvisionContext<'_>) -> Result<BrowserRunConfig, IntegrationError> {
42 Ok(BrowserRunConfig {})
43 }
44}
45
46pub fn validate_config(
47 _name: &str,
48 _config: &BTreeMap<String, toml::Value>,
49) -> Result<(), IntegrationError> {
50 Ok(())
51}
52
53#[cfg(test)]
54mod tests {
55 use super::*;
56 use crate::ProviderOps;
57 use crate::resource::ResourcePayload as CloudflarePayload;
58 use stackless_core::def::StackDef;
59 use stackless_stripe_projects::stripe::{CommandOutput, StripeProjects};
60 use stackless_stripe_projects::test_support::ScriptedRunner;
61
62 fn out(stdout: &str) -> CommandOutput {
63 CommandOutput {
64 status: 0,
65 stdout: stdout.to_owned(),
66 stderr: String::new(),
67 }
68 }
69
70 #[test]
71 fn browser_run_config_matches_catalog() {
72 const FIXTURE: &str = include_str!(concat!(
73 env!("CARGO_MANIFEST_DIR"),
74 "/../stackless-stripe-projects/tests/fixtures/catalog.json"
75 ));
76 let catalog = stackless_stripe_projects::Catalog::from_json_envelope(FIXTURE).unwrap();
77 let failures = stackless_stripe_projects::verify_service(&catalog, &BrowserRunConfig {});
78 assert!(
79 failures.is_empty(),
80 "cloudflare/browser-run catalog gaps:\n{}",
81 failures.join("\n")
82 );
83 }
84
85 const CATALOG_ENVELOPE: &str = r#"{"ok":true,"command":"projects catalog","data":{
86 "last_updated":"2026-06-16T00:00:00Z","services":[{
87 "id":"prvsvc_br","object":"v2.provisioning.provider_service_detail",
88 "provider_id":"prvdr_cloudflare","provider_name":"Cloudflare","service_id":"browser-run",
89 "categories":["compute"],"kind":"deployable","scope":"project","availability":"available",
90 "development":false,"livemode":true,"pricing":{"type":"component"},
91 "configuration_schema":{"type":"object","additionalProperties":false,"properties":{}}
92 }]}}"#;
93
94 fn test_def() -> StackDef {
95 StackDef::parse(
96 r#"
97[stack]
98name = "atto"
99[stack.projects.stripe]
100project = "project_1"
101[integrations.browser]
102provider = "cloudflare-browser-run"
103[services.api]
104source = { repo = "r", ref = "main" }
105env = { CF_SUBDOMAIN = "${integrations.browser.workers_dev_subdomain}" }
106health = { path = "/health" }
107[services.api.local]
108run = "true"
109"#,
110 )
111 .unwrap()
112 }
113
114 #[tokio::test]
115 async fn provision_browser_run_records_outputs() {
116 let runner = ScriptedRunner::new(vec![
117 out(CATALOG_ENVELOPE),
118 out(r#"{"ok":true,"data":{"project":{"id":"project_1"}}}"#),
119 out(r#"{"ok":true,"data":{"environments":[{"name":"demo"}]}}"#),
120 out(r#"{"ok":true,"data":null}"#),
121 out(r#"{"ok":true,"data":{"services":[]}}"#),
122 out(&serde_json::json!({"ok":true,"data":{"variables":{
123 "CLOUDFLARE_ACCOUNT_ID": "acc_1",
124 "CLOUDFLARE_WORKERS_DEV_SUBDOMAIN": "atto-demo"
125 }}})
126 .to_string()),
127 out(r#"{"ok":true,"data":null}"#),
128 out(r#"{"ok":true,"data":null}"#),
129 ]);
130 let dir = tempfile::tempdir().unwrap();
131 std::fs::write(
132 dir.path().join("stackless.toml"),
133 "[stack]\nname=\"atto\"\n",
134 )
135 .unwrap();
136 let stripe = StripeProjects::new(&runner, dir.path());
137
138 let resource = CloudflareBrowserRun
139 .provision(
140 &stripe.as_dyn(),
141 &test_def(),
142 dir.path(),
143 "demo",
144 "browser",
145 "local",
146 false,
147 )
148 .await
149 .unwrap();
150 assert_eq!(resource.resource_kind, "integration-cloudflare-browser-run");
151 let payload: CloudflarePayload = serde_json::from_str(&resource.payload).unwrap();
152 assert_eq!(payload.outputs["workers_dev_subdomain"], "atto-demo");
153 }
154}