2596464d49
* Workspace forks: add endpoint to create a branch before creating a fork * Update hubPaths + create branch before creating fork on frontend * Update tmp ee-repo-ref * Remove debug hubPath * Prepare sqlx * Fix ee imports * Update ee-ref * Update ee-repo-ref final * Prepare sqlx
106 lines
4.5 KiB
Rust
106 lines
4.5 KiB
Rust
/*
|
|
* Author: Ruben Fiszel
|
|
* Copyright: Windmill Labs, Inc 2022
|
|
* This file and its contents are licensed under the AGPLv3 License.
|
|
* Please see the included NOTICE for copyright information and
|
|
* LICENSE-AGPL for a copy of the license.
|
|
*/
|
|
|
|
use windmill_common::{scripts::ScriptHash, DB};
|
|
|
|
#[cfg(feature = "private")]
|
|
pub mod git_sync_ee;
|
|
pub mod git_sync_oss;
|
|
|
|
pub use git_sync_oss::{handle_deployment_metadata, handle_fork_branch_creation};
|
|
|
|
#[derive(Clone, Debug)]
|
|
pub enum DeployedObject {
|
|
Script { hash: ScriptHash, path: String, parent_path: Option<String> },
|
|
Flow { path: String, parent_path: Option<String>, version: i64 },
|
|
App { path: String, version: i64, parent_path: Option<String> },
|
|
Folder { path: String },
|
|
Resource { path: String, parent_path: Option<String> },
|
|
Variable { path: String, parent_path: Option<String> },
|
|
Schedule { path: String },
|
|
ResourceType { path: String },
|
|
User { email: String },
|
|
Group { name: String },
|
|
HttpTrigger { path: String },
|
|
WebsocketTrigger { path: String },
|
|
KafkaTrigger { path: String },
|
|
NatsTrigger { path: String },
|
|
PostgresTrigger { path: String },
|
|
MqttTrigger { path: String },
|
|
SqsTrigger { path: String },
|
|
GcpTrigger { path: String },
|
|
EmailTrigger { path: String },
|
|
Settings { setting_type: String },
|
|
Key { key_type: String },
|
|
}
|
|
|
|
impl DeployedObject {
|
|
pub fn get_path(&self) -> String {
|
|
match self {
|
|
DeployedObject::Script { path, .. } => path.to_owned(),
|
|
DeployedObject::Flow { path, .. } => path.to_owned(),
|
|
DeployedObject::App { path, .. } => path.to_owned(),
|
|
DeployedObject::Folder { path, .. } => path.to_owned(),
|
|
DeployedObject::Resource { path, .. } => path.to_owned(),
|
|
DeployedObject::Variable { path, .. } => path.to_owned(),
|
|
DeployedObject::Schedule { path, .. } => path.to_owned(),
|
|
DeployedObject::ResourceType { path, .. } => path.to_owned(),
|
|
DeployedObject::User { email } => format!("users/{email}"),
|
|
DeployedObject::Group { name } => format!("groups/{name}"),
|
|
DeployedObject::HttpTrigger { path } => path.to_owned(),
|
|
DeployedObject::WebsocketTrigger { path } => path.to_owned(),
|
|
DeployedObject::KafkaTrigger { path } => path.to_owned(),
|
|
DeployedObject::NatsTrigger { path } => path.to_owned(),
|
|
DeployedObject::PostgresTrigger { path } => path.to_owned(),
|
|
DeployedObject::MqttTrigger { path } => path.to_owned(),
|
|
DeployedObject::SqsTrigger { path } => path.to_owned(),
|
|
DeployedObject::GcpTrigger { path } => path.to_owned(),
|
|
DeployedObject::EmailTrigger { path } => path.to_owned(),
|
|
DeployedObject::Settings { .. } => "settings.yaml".to_string(),
|
|
DeployedObject::Key { .. } => "encryption_key.yaml".to_string(),
|
|
}
|
|
}
|
|
|
|
pub fn get_ignore_regex_filter(&self) -> bool {
|
|
match self {
|
|
Self::User { .. }
|
|
| Self::Group { .. }
|
|
| Self::ResourceType { .. }
|
|
| Self::Settings { .. }
|
|
| Self::Key { .. } => true,
|
|
_ => false,
|
|
}
|
|
}
|
|
|
|
pub fn get_parent_path(&self) -> Option<String> {
|
|
match self {
|
|
DeployedObject::Script { parent_path, .. } => parent_path.to_owned(),
|
|
DeployedObject::Flow { parent_path, .. } => parent_path.to_owned(),
|
|
DeployedObject::App { parent_path, .. } => parent_path.to_owned(),
|
|
DeployedObject::Folder { .. } => None,
|
|
DeployedObject::Resource { parent_path, .. } => parent_path.to_owned(),
|
|
DeployedObject::Variable { parent_path, .. } => parent_path.to_owned(),
|
|
DeployedObject::Schedule { .. } => None,
|
|
DeployedObject::ResourceType { .. } => None,
|
|
DeployedObject::User { .. } => None,
|
|
DeployedObject::Group { .. } => None,
|
|
DeployedObject::HttpTrigger { .. } => None,
|
|
DeployedObject::WebsocketTrigger { .. } => None,
|
|
DeployedObject::KafkaTrigger { .. } => None,
|
|
DeployedObject::NatsTrigger { .. } => None,
|
|
DeployedObject::PostgresTrigger { .. } => None,
|
|
DeployedObject::MqttTrigger { .. } => None,
|
|
DeployedObject::SqsTrigger { .. } => None,
|
|
DeployedObject::GcpTrigger { .. } => None,
|
|
DeployedObject::EmailTrigger { .. } => None,
|
|
DeployedObject::Settings { .. } => None,
|
|
DeployedObject::Key { .. } => None,
|
|
}
|
|
}
|
|
}
|