Add !Snippets, see Use traefik labels as label prefix #105

README.md

@@ -311,6 +311,23 @@ Keyword monitor with custom status_codes:
 kuma.__web: '{ "name": "Example HTTP", "url": "https://example.com", "keyword": "Example Domain", "status_codes": ["200"] }'
 ```
 
+#### !Snippets
+There's a special case for snippets starting with a `!`, these snippets will apply to labels without requiring the prefix (i.e. `kuma.__`). The purpose of these is to be able to reuse existing labels from other tools. (Note: Due to this !Snippets will always receive a single string argument containing the label value instead of a structured list). 
+
+For example you could create a snippet to reuse traefik labels by defining a snippet called `!traefik.enable`:
+```jinja
+{# Only apply if value is "true" #}
+{% if args[0] == "true" %}
+    {# Extract some information from existing labels, note that this will likely not fit your setup and you will need to adjust this to get the required data #}
+    {% set traefik_service = container_name %}
+    {% set domain = container_name + ".example.com" %}
+    {% set port = container["Labels"]["traefik.http.services." + traefik_service + ".loadbalancer.server.port"] %}
+
+    {{ container_name }}_http.http.name: {{ container_name }}
+    {{ container_name }}_http.http.url: https://{{ domain }}:{{ port }}
+{% endif %}
+```
+
 
 ### Static Monitors 📊
 In addition to reading Monitors from Docker labels, AutoKuma can create Monitors from files. This can be usefull if you have want AutoKuma to manage monitors which aren't directly related to a container.

autokuma/src/entity.rs

@@ -181,11 +181,15 @@ pub fn get_entities_from_labels(
                         format!("Snippet '{}' not found!", key)
                     });
 
-                let args = serde_json::from_str::<Vec<serde_json::Value>>(&format!("[{}]", value))
-                    .log_warn(std::module_path!(), |e| {
-                        format!("Error while parsing snippet arguments: {}", e.to_string())
-                    })
-                    .ok();
+                let args = if key.starts_with("__!") {
+                    Some(vec![serde_json::Value::String(value.to_owned())])
+                } else {
+                    serde_json::from_str::<Vec<serde_json::Value>>(&format!("[{}]", value))
+                        .log_warn(std::module_path!(), |e| {
+                            format!("Error while parsing snippet arguments: {}", e.to_string())
+                        })
+                        .ok()
+                };
 
                 if let (Some(snippet), Some(args)) = (snippet, args) {
                     let mut template_values = template_values.clone();
@@ -248,7 +252,7 @@ pub fn get_entities_from_labels(
                     match result {
                         Err(Error::NameNotFound(name)) => {
                             warn!(
-                                "Cannot create monitor {} because referenced {} with {} is not found",
+                                "Cannot create monitor {} because referenced {} with name {} is not found",
                                 id,
                                 name.type_name(),
                                 name.name()

autokuma/src/sources/docker_source.rs

@@ -40,6 +40,7 @@ async fn get_kuma_containers(
                 |labels| {
                     labels.keys().any(|key| {
                         key.starts_with(&format!("{}.", state.config.docker.label_prefix))
+                            || state.config.snippets.contains_key(&format!("!{}", key))
                     })
                 },
             )
@@ -69,6 +70,7 @@ async fn get_kuma_services(state: Arc<AppState>, docker: &Docker) -> Result<Vec<
                         |labels| {
                             labels.keys().any(|key| {
                                 key.starts_with(&format!("{}.", state.config.docker.label_prefix))
+                                    || state.config.snippets.contains_key(&format!("!{}", key))
                             })
                         },
                     )