vars.rs

  1use std::cell::RefCell;
  2
  3use gh_workflow::{
  4    Concurrency, Env, Expression, Step, WorkflowCallInput, WorkflowCallSecret,
  5    WorkflowDispatchInput,
  6};
  7
  8use crate::tasks::workflows::{runners::Platform, steps::NamedJob};
  9
 10macro_rules! secret {
 11    ($secret_name:ident) => {
 12        pub const $secret_name: &str = concat!("${{ secrets.", stringify!($secret_name), " }}");
 13    };
 14}
 15
 16macro_rules! var {
 17    ($var_name:ident) => {
 18        pub const $var_name: &str = concat!("${{ vars.", stringify!($var_name), " }}");
 19    };
 20}
 21
 22secret!(ANTHROPIC_API_KEY);
 23secret!(OPENAI_API_KEY);
 24secret!(GOOGLE_AI_API_KEY);
 25secret!(GOOGLE_CLOUD_PROJECT);
 26secret!(APPLE_NOTARIZATION_ISSUER_ID);
 27secret!(APPLE_NOTARIZATION_KEY);
 28secret!(APPLE_NOTARIZATION_KEY_ID);
 29secret!(AZURE_SIGNING_CLIENT_ID);
 30secret!(AZURE_SIGNING_CLIENT_SECRET);
 31secret!(AZURE_SIGNING_TENANT_ID);
 32secret!(CACHIX_AUTH_TOKEN);
 33secret!(CLUSTER_NAME);
 34secret!(DIGITALOCEAN_ACCESS_TOKEN);
 35secret!(DIGITALOCEAN_SPACES_ACCESS_KEY);
 36secret!(DIGITALOCEAN_SPACES_SECRET_KEY);
 37secret!(GITHUB_TOKEN);
 38secret!(MACOS_CERTIFICATE);
 39secret!(MACOS_CERTIFICATE_PASSWORD);
 40secret!(SENTRY_AUTH_TOKEN);
 41secret!(ZED_CLIENT_CHECKSUM_SEED);
 42secret!(ZED_CLOUD_PROVIDER_ADDITIONAL_MODELS_JSON);
 43secret!(ZED_SENTRY_MINIDUMP_ENDPOINT);
 44secret!(SLACK_APP_ZED_UNIT_EVALS_BOT_TOKEN);
 45secret!(ZED_ZIPPY_APP_ID);
 46secret!(ZED_ZIPPY_APP_PRIVATE_KEY);
 47secret!(DISCORD_WEBHOOK_RELEASE_NOTES);
 48secret!(WINGET_TOKEN);
 49secret!(VERCEL_TOKEN);
 50secret!(SLACK_WEBHOOK_WORKFLOW_FAILURES);
 51secret!(R2_ACCOUNT_ID);
 52secret!(R2_ACCESS_KEY_ID);
 53secret!(R2_SECRET_ACCESS_KEY);
 54secret!(CLOUDFLARE_API_TOKEN);
 55secret!(CLOUDFLARE_ACCOUNT_ID);
 56secret!(DOCS_AMPLITUDE_API_KEY);
 57
 58// todo(ci) make these secrets too...
 59var!(AZURE_SIGNING_ACCOUNT_NAME);
 60var!(AZURE_SIGNING_CERT_PROFILE_NAME);
 61var!(AZURE_SIGNING_ENDPOINT);
 62
 63pub fn bundle_envs(platform: Platform) -> Env {
 64    let env = Env::default()
 65        .add("CARGO_INCREMENTAL", 0)
 66        .add("ZED_CLIENT_CHECKSUM_SEED", ZED_CLIENT_CHECKSUM_SEED)
 67        .add("ZED_MINIDUMP_ENDPOINT", ZED_SENTRY_MINIDUMP_ENDPOINT);
 68
 69    match platform {
 70        Platform::Linux => env,
 71        Platform::Mac => env
 72            .add("MACOS_CERTIFICATE", MACOS_CERTIFICATE)
 73            .add("MACOS_CERTIFICATE_PASSWORD", MACOS_CERTIFICATE_PASSWORD)
 74            .add("APPLE_NOTARIZATION_KEY", APPLE_NOTARIZATION_KEY)
 75            .add("APPLE_NOTARIZATION_KEY_ID", APPLE_NOTARIZATION_KEY_ID)
 76            .add("APPLE_NOTARIZATION_ISSUER_ID", APPLE_NOTARIZATION_ISSUER_ID),
 77        Platform::Windows => env
 78            .add("AZURE_TENANT_ID", AZURE_SIGNING_TENANT_ID)
 79            .add("AZURE_CLIENT_ID", AZURE_SIGNING_CLIENT_ID)
 80            .add("AZURE_CLIENT_SECRET", AZURE_SIGNING_CLIENT_SECRET)
 81            .add("ACCOUNT_NAME", AZURE_SIGNING_ACCOUNT_NAME)
 82            .add("CERT_PROFILE_NAME", AZURE_SIGNING_CERT_PROFILE_NAME)
 83            .add("ENDPOINT", AZURE_SIGNING_ENDPOINT)
 84            .add("FILE_DIGEST", "SHA256")
 85            .add("TIMESTAMP_DIGEST", "SHA256")
 86            .add("TIMESTAMP_SERVER", "http://timestamp.acs.microsoft.com"),
 87    }
 88}
 89
 90pub fn one_workflow_per_non_main_branch() -> Concurrency {
 91    one_workflow_per_non_main_branch_and_token("")
 92}
 93
 94pub fn one_workflow_per_non_main_branch_and_token<T: AsRef<str>>(token: T) -> Concurrency {
 95    Concurrency::default()
 96        .group(format!(
 97            concat!(
 98                "${{{{ github.workflow }}}}-${{{{ github.ref_name }}}}-",
 99                "${{{{ github.ref_name == 'main' && github.sha || 'anysha' }}}}{}"
100            ),
101            token.as_ref()
102        ))
103        .cancel_in_progress(true)
104}
105
106pub(crate) fn allow_concurrent_runs() -> Concurrency {
107    Concurrency::default()
108        .group("${{ github.workflow }}-${{ github.ref_name }}-${{ github.run_id }}")
109        .cancel_in_progress(true)
110}
111
112// Represents a pattern to check for changed files and corresponding output variable
113pub struct PathCondition {
114    pub name: &'static str,
115    pub pattern: &'static str,
116    pub invert: bool,
117    pub set_by_step: RefCell<Option<String>>,
118}
119impl PathCondition {
120    pub fn new(name: &'static str, pattern: &'static str) -> Self {
121        Self {
122            name,
123            pattern,
124            invert: false,
125            set_by_step: Default::default(),
126        }
127    }
128    pub fn inverted(name: &'static str, pattern: &'static str) -> Self {
129        Self {
130            name,
131            pattern,
132            invert: true,
133            set_by_step: Default::default(),
134        }
135    }
136    pub fn guard(&self, job: NamedJob) -> NamedJob {
137        let set_by_step = self
138            .set_by_step
139            .borrow()
140            .clone()
141            .unwrap_or_else(|| panic!("condition {},is never set", self.name));
142        NamedJob {
143            name: job.name,
144            job: job
145                .job
146                .add_need(set_by_step.clone())
147                .cond(Expression::new(format!(
148                    "needs.{}.outputs.{} == 'true'",
149                    &set_by_step, self.name
150                ))),
151        }
152    }
153}
154
155pub(crate) struct StepOutput {
156    pub name: &'static str,
157    step_id: String,
158}
159
160impl StepOutput {
161    pub fn new<T>(step: &Step<T>, name: &'static str) -> Self {
162        Self {
163            name,
164            step_id: step
165                .value
166                .id
167                .clone()
168                .expect("Steps that produce outputs must have an ID"),
169        }
170    }
171
172    pub fn expr(&self) -> String {
173        format!("steps.{}.outputs.{}", self.step_id, self.name)
174    }
175
176    pub fn as_job_output(self, job: &NamedJob) -> JobOutput {
177        JobOutput {
178            job_name: job.name.clone(),
179            name: self.name,
180        }
181    }
182}
183
184impl serde::Serialize for StepOutput {
185    fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
186    where
187        S: serde::Serializer,
188    {
189        serializer.serialize_str(&self.to_string())
190    }
191}
192
193impl std::fmt::Display for StepOutput {
194    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
195        write!(f, "${{{{ {} }}}}", self.expr())
196    }
197}
198
199pub(crate) struct JobOutput {
200    job_name: String,
201    name: &'static str,
202}
203
204impl JobOutput {
205    pub fn expr(&self) -> String {
206        format!("needs.{}.outputs.{}", self.job_name, self.name)
207    }
208}
209
210impl serde::Serialize for JobOutput {
211    fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
212    where
213        S: serde::Serializer,
214    {
215        serializer.serialize_str(&self.to_string())
216    }
217}
218
219impl std::fmt::Display for JobOutput {
220    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
221        write!(f, "${{{{ {} }}}}", self.expr())
222    }
223}
224
225pub struct WorkflowInput {
226    pub input_type: &'static str,
227    pub name: &'static str,
228    pub default: Option<String>,
229    pub description: Option<String>,
230}
231
232impl WorkflowInput {
233    pub fn string(name: &'static str, default: Option<String>) -> Self {
234        Self {
235            input_type: "string",
236            name,
237            default,
238            description: None,
239        }
240    }
241
242    pub fn bool(name: &'static str, default: Option<bool>) -> Self {
243        Self {
244            input_type: "boolean",
245            name,
246            default: default.as_ref().map(ToString::to_string),
247            description: None,
248        }
249    }
250
251    pub fn description(mut self, description: impl ToString) -> Self {
252        self.description = Some(description.to_string());
253        self
254    }
255
256    pub fn input(&self) -> WorkflowDispatchInput {
257        WorkflowDispatchInput {
258            description: self
259                .description
260                .clone()
261                .unwrap_or_else(|| self.name.to_owned()),
262            required: self.default.is_none(),
263            input_type: self.input_type.to_owned(),
264            default: self.default.clone(),
265        }
266    }
267
268    pub fn call_input(&self) -> WorkflowCallInput {
269        WorkflowCallInput {
270            description: self.name.to_owned(),
271            required: self.default.is_none(),
272            input_type: self.input_type.to_owned(),
273            default: self.default.clone(),
274        }
275    }
276
277    pub(crate) fn expr(&self) -> String {
278        format!("inputs.{}", self.name)
279    }
280}
281
282impl std::fmt::Display for WorkflowInput {
283    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
284        write!(f, "${{{{ {} }}}}", self.expr())
285    }
286}
287
288impl serde::Serialize for WorkflowInput {
289    fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
290    where
291        S: serde::Serializer,
292    {
293        serializer.serialize_str(&self.to_string())
294    }
295}
296
297pub(crate) struct WorkflowSecret {
298    pub name: &'static str,
299    description: String,
300    required: bool,
301}
302
303impl WorkflowSecret {
304    pub fn new(name: &'static str, description: impl ToString) -> Self {
305        Self {
306            name,
307            description: description.to_string(),
308            required: true,
309        }
310    }
311
312    pub fn secret_configuration(&self) -> WorkflowCallSecret {
313        WorkflowCallSecret {
314            description: self.description.clone(),
315            required: self.required,
316        }
317    }
318}
319
320impl std::fmt::Display for WorkflowSecret {
321    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
322        write!(f, "${{{{ secrets.{} }}}}", self.name)
323    }
324}
325
326impl serde::Serialize for WorkflowSecret {
327    fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
328    where
329        S: serde::Serializer,
330    {
331        serializer.serialize_str(&self.to_string())
332    }
333}
334
335pub mod assets {
336    // NOTE: these asset names also exist in the zed.dev codebase.
337    pub const MAC_AARCH64: &str = "Zed-aarch64.dmg";
338    pub const MAC_X86_64: &str = "Zed-x86_64.dmg";
339    pub const LINUX_AARCH64: &str = "zed-linux-aarch64.tar.gz";
340    pub const LINUX_X86_64: &str = "zed-linux-x86_64.tar.gz";
341    pub const WINDOWS_X86_64: &str = "Zed-x86_64.exe";
342    pub const WINDOWS_AARCH64: &str = "Zed-aarch64.exe";
343
344    pub const REMOTE_SERVER_MAC_AARCH64: &str = "zed-remote-server-macos-aarch64.gz";
345    pub const REMOTE_SERVER_MAC_X86_64: &str = "zed-remote-server-macos-x86_64.gz";
346    pub const REMOTE_SERVER_LINUX_AARCH64: &str = "zed-remote-server-linux-aarch64.gz";
347    pub const REMOTE_SERVER_LINUX_X86_64: &str = "zed-remote-server-linux-x86_64.gz";
348    pub const REMOTE_SERVER_WINDOWS_AARCH64: &str = "zed-remote-server-windows-aarch64.zip";
349    pub const REMOTE_SERVER_WINDOWS_X86_64: &str = "zed-remote-server-windows-x86_64.zip";
350
351    pub fn all() -> Vec<&'static str> {
352        vec![
353            MAC_AARCH64,
354            MAC_X86_64,
355            LINUX_AARCH64,
356            LINUX_X86_64,
357            WINDOWS_X86_64,
358            WINDOWS_AARCH64,
359            REMOTE_SERVER_MAC_AARCH64,
360            REMOTE_SERVER_MAC_X86_64,
361            REMOTE_SERVER_LINUX_AARCH64,
362            REMOTE_SERVER_LINUX_X86_64,
363            REMOTE_SERVER_WINDOWS_AARCH64,
364            REMOTE_SERVER_WINDOWS_X86_64,
365        ]
366    }
367}