Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 7 additions & 6 deletions crates/stackless-integrations/src/providers/mod.rs
Original file line number Diff line number Diff line change
@@ -1,18 +1,14 @@
pub mod clerk;
pub mod cloudflare;
pub mod railway;

#[cfg(test)]
mod tests {
use stackless_provider_sdk::CatalogResource;
use stackless_provider_sdk::Hostable;

use crate::providers::cloudflare;
use crate::providers::{cloudflare, railway};

/// `Hostable::OUTPUTS` (the names referenceable as `${integrations.*.<out>}`)
/// must stay in lockstep with the names column of `OUTPUT_FIELDS` — the two
/// are co-located but hand-written, so this makes drift a test failure rather
/// than a silent validation bug. Bespoke providers (Clerk) aren't
/// `CatalogResource`, so they're out of scope here by construction.
fn assert_outputs_match<T: CatalogResource>() {
let fields: Vec<&str> = T::OUTPUT_FIELDS.iter().map(|(_, name, _)| *name).collect();
let outputs: Vec<&str> = <T as Hostable>::OUTPUTS.to_vec();
Expand All @@ -34,5 +30,10 @@ mod tests {
assert_outputs_match::<cloudflare::workers::CloudflareWorkers>();
assert_outputs_match::<cloudflare::workers_ai::CloudflareWorkersAi>();
assert_outputs_match::<cloudflare::browser_run::CloudflareBrowserRun>();
assert_outputs_match::<railway::bucket::RailwayBucket>();
assert_outputs_match::<railway::hosting::RailwayHosting>();
assert_outputs_match::<railway::mongo::RailwayMongo>();
assert_outputs_match::<railway::postgres::RailwayPostgres>();
assert_outputs_match::<railway::redis::RailwayRedis>();
}
}
145 changes: 145 additions & 0 deletions crates/stackless-integrations/src/providers/railway/bucket.rs
Original file line number Diff line number Diff line change
@@ -0,0 +1,145 @@
//! `railway/bucket` integration.

use std::collections::BTreeMap;

use serde::Serialize;
use stackless_stripe_projects::catalog::verify::CatalogService;
use stackless_stripe_projects::provision::ProvisionContext;

use super::FamilyResource;
use crate::error::IntegrationError;
use crate::hostable::{ConfigScope, Hostable, IntegrationHosting};

pub const RESOURCE_KIND: &str = "integration-railway-bucket";

#[derive(Debug, Serialize)]
pub struct RailwayBucketConfig {
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub region: Option<String>,
}

impl CatalogService for RailwayBucketConfig {
const REFERENCE: &'static str = "railway/bucket";
}

#[derive(Debug)]
pub struct RailwayBucket;

impl Hostable for RailwayBucket {
const PROVIDER: &'static str = "railway-bucket";
const HOSTING: IntegrationHosting = IntegrationHosting::Managed;
const CONFIG_SCOPE: ConfigScope = ConfigScope::GlobalOnly;
const RESOURCE_KIND: &'static str = RESOURCE_KIND;
const OUTPUTS: &'static [&'static str] = &["bucket"];
}

impl FamilyResource for RailwayBucket {
type Config = RailwayBucketConfig;
const PROVIDER_PREFIX: &'static str = "RAILWAY";
// Provisional until pinned by `mise run discover railway/bucket`.
const OUTPUT_FIELDS: &'static [(&'static str, &'static str, bool)] =
&[("BUCKET", "bucket", true)];

fn build_config(ctx: &ProvisionContext<'_>) -> Result<RailwayBucketConfig, IntegrationError> {
let config = super::integration_config(ctx)?;
Ok(RailwayBucketConfig {
name: super::interp_optional(ctx, &config, "name")?,
region: super::interp_optional(ctx, &config, "region")?,
})
}
}

pub fn validate_config(
name: &str,
config: &BTreeMap<String, toml::Value>,
) -> Result<(), IntegrationError> {
let _ = (name, config);
Ok(())
}

#[cfg(test)]
mod tests {
use super::*;
use crate::ProviderOps;
use crate::resource::ResourcePayload;
use stackless_core::def::StackDef;
use stackless_stripe_projects::stripe::StripeProjects;
use stackless_stripe_projects::test_support;

#[test]
fn config_matches_catalog() {
const FIXTURE: &str = include_str!(concat!(
env!("CARGO_MANIFEST_DIR"),
"/../stackless-stripe-projects/tests/fixtures/catalog.json"
));
let catalog = stackless_stripe_projects::Catalog::from_json_envelope(FIXTURE).unwrap();
let failures = stackless_stripe_projects::verify_service(
&catalog,
&RailwayBucketConfig {
name: None,
region: None,
},
);
assert!(
failures.is_empty(),
"railway/bucket catalog gaps:\n{}",
failures.join("\n")
);
}

const CATALOG_ENVELOPE: &str = r##"{"ok":true,"command":"projects catalog","data":{"last_updated":"2026-07-11T00:00:00Z","services":[{"id":"prvsvc_bucket","object":"v2.provisioning.provider_service_detail","provider_id":"prvdr_railway","provider_name":"Railway","service_id":"bucket","categories":["database"],"kind":"deployable","scope":"project","availability":"available","development":false,"livemode":true,"pricing":{"type":"component"},"configuration_schema":{"properties":{"name":{"description":"Bucket name (auto-generated if omitted).","type":"string"},"region":{"description":"Storage region (e.g. sjc, iad, ams, sin).","type":"string"}},"type":"object"}}]}}"##;

fn test_def() -> StackDef {
StackDef::parse(
r#"
[stack]
name = "atto"
[stack.projects.stripe]
project = "project_1"
[integrations.res]
provider = "railway-bucket"
[services.api]
source = { repo = "r", ref = "main" }
env = { OUT = "${integrations.res.bucket}" }
health = { path = "/health" }
[services.api.local]
run = "true"
"#,
)
.unwrap()
}

#[tokio::test]
async fn provision_records_outputs() {
let runner = test_support::provision_script(
CATALOG_ENVELOPE,
serde_json::json!({"RAILWAY_BUCKET": "val_bucket"}),
0,
);
let dir = tempfile::tempdir().unwrap();
std::fs::write(
dir.path().join("stackless.toml"),
"[stack]\nname=\"atto\"\n",
)
.unwrap();
let stripe = StripeProjects::new(&runner, dir.path());

let resource = RailwayBucket
.provision(
&stripe.as_dyn(),
&test_def(),
dir.path(),
"demo",
"res",
"local",
false,
)
.await
.unwrap();
assert_eq!(resource.resource_kind, "integration-railway-bucket");
let payload: ResourcePayload = serde_json::from_str(&resource.payload).unwrap();
assert_eq!(payload.outputs["bucket"], "val_bucket");
}
}
132 changes: 132 additions & 0 deletions crates/stackless-integrations/src/providers/railway/hosting.rs
Original file line number Diff line number Diff line change
@@ -0,0 +1,132 @@
//! `railway/hosting` integration.

use std::collections::BTreeMap;

use serde::Serialize;
use stackless_stripe_projects::catalog::verify::CatalogService;
use stackless_stripe_projects::provision::ProvisionContext;

use super::FamilyResource;
use crate::error::IntegrationError;
use crate::hostable::{ConfigScope, Hostable, IntegrationHosting};

pub const RESOURCE_KIND: &str = "integration-railway-hosting";

#[derive(Debug, Serialize)]
pub struct RailwayHostingConfig {}

impl CatalogService for RailwayHostingConfig {
const REFERENCE: &'static str = "railway/hosting";
}

#[derive(Debug)]
pub struct RailwayHosting;

impl Hostable for RailwayHosting {
const PROVIDER: &'static str = "railway-hosting";
const HOSTING: IntegrationHosting = IntegrationHosting::Managed;
const CONFIG_SCOPE: ConfigScope = ConfigScope::GlobalOnly;
const RESOURCE_KIND: &'static str = RESOURCE_KIND;
const OUTPUTS: &'static [&'static str] = &["project_id"];
}

impl FamilyResource for RailwayHosting {
type Config = RailwayHostingConfig;
const PROVIDER_PREFIX: &'static str = "RAILWAY";
// Provisional until pinned by `mise run discover railway/hosting`.
const OUTPUT_FIELDS: &'static [(&'static str, &'static str, bool)] =
&[("PROJECT_ID", "project_id", true)];

fn build_config(ctx: &ProvisionContext<'_>) -> Result<RailwayHostingConfig, IntegrationError> {
let _ = super::integration_config(ctx)?;
Ok(RailwayHostingConfig {})
}
}

pub fn validate_config(
name: &str,
config: &BTreeMap<String, toml::Value>,
) -> Result<(), IntegrationError> {
let _ = (name, config);
Ok(())
}

#[cfg(test)]
mod tests {
use super::*;
use crate::ProviderOps;
use crate::resource::ResourcePayload;
use stackless_core::def::StackDef;
use stackless_stripe_projects::stripe::StripeProjects;
use stackless_stripe_projects::test_support;

#[test]
fn config_matches_catalog() {
const FIXTURE: &str = include_str!(concat!(
env!("CARGO_MANIFEST_DIR"),
"/../stackless-stripe-projects/tests/fixtures/catalog.json"
));
let catalog = stackless_stripe_projects::Catalog::from_json_envelope(FIXTURE).unwrap();
let failures =
stackless_stripe_projects::verify_service(&catalog, &RailwayHostingConfig {});
assert!(
failures.is_empty(),
"railway/hosting catalog gaps:\n{}",
failures.join("\n")
);
}

const CATALOG_ENVELOPE: &str = r##"{"ok":true,"command":"projects catalog","data":{"last_updated":"2026-07-11T00:00:00Z","services":[{"id":"prvsvc_hosting","object":"v2.provisioning.provider_service_detail","provider_id":"prvdr_railway","provider_name":"Railway","service_id":"hosting","categories":["database"],"kind":"deployable","scope":"project","availability":"available","development":false,"livemode":true,"pricing":{"type":"component"},"configuration_schema":{"properties":{},"type":"object"}}]}}"##;

fn test_def() -> StackDef {
StackDef::parse(
r#"
[stack]
name = "atto"
[stack.projects.stripe]
project = "project_1"
[integrations.res]
provider = "railway-hosting"
[services.api]
source = { repo = "r", ref = "main" }
env = { OUT = "${integrations.res.project_id}" }
health = { path = "/health" }
[services.api.local]
run = "true"
"#,
)
.unwrap()
}

#[tokio::test]
async fn provision_records_outputs() {
let runner = test_support::provision_script(
CATALOG_ENVELOPE,
serde_json::json!({"RAILWAY_PROJECT_ID": "val_project_id"}),
0,
);
let dir = tempfile::tempdir().unwrap();
std::fs::write(
dir.path().join("stackless.toml"),
"[stack]\nname=\"atto\"\n",
)
.unwrap();
let stripe = StripeProjects::new(&runner, dir.path());

let resource = RailwayHosting
.provision(
&stripe.as_dyn(),
&test_def(),
dir.path(),
"demo",
"res",
"local",
false,
)
.await
.unwrap();
assert_eq!(resource.resource_kind, "integration-railway-hosting");
let payload: ResourcePayload = serde_json::from_str(&resource.payload).unwrap();
assert_eq!(payload.outputs["project_id"], "val_project_id");
}
}
15 changes: 15 additions & 0 deletions crates/stackless-integrations/src/providers/railway/mod.rs
Original file line number Diff line number Diff line change
@@ -0,0 +1,15 @@
//! Railway catalog resources via Stripe Projects.
//!
//! Output envelopes are provisional until pinned by `xtask discover`.

pub mod bucket;
pub mod hosting;
pub mod mongo;
pub mod postgres;
pub mod redis;

#[allow(unused_imports)]
pub(crate) use crate::resource::{
CatalogResource as FamilyResource, bool_optional, bool_required, int_optional, int_required,
integration_config, interp_optional, interp_required,
};
Loading
Loading