Registry manifest and Schema diff

crates/weaver_codegen_test/build.rs

@@ -61,13 +61,9 @@ fn main() {
     engine
         .import_jq_package(SEMCONV_JQ)
         .unwrap_or_else(|e| process_error(&logger, e));
-    let template_registry = ResolvedRegistry::try_from_resolved_registry(
-        schema
-            .registry(REGISTRY_ID)
-            .expect("Failed to get the registry from the resolved schema"),
-        schema.catalog(),
-    )
-    .unwrap_or_else(|e| process_error(&logger, e));
+    let template_registry =
+        ResolvedRegistry::try_from_resolved_registry(&schema.registry, schema.catalog())
+            .unwrap_or_else(|e| process_error(&logger, e));
     let target_dir: PathBuf = target_dir.into();
     engine
         .generate(

crates/weaver_common/src/diagnostic.rs

@@ -180,8 +180,7 @@ impl DiagnosticMessages {
         Self(vec![DiagnosticMessage::new(error)])
     }
 
-    /// Returns true if all the diagnostic messages are explicitly marked as
-    /// warnings or advices.
+    /// Returns true if at least one diagnostic message has an error severity.
     #[must_use]
     pub fn has_error(&self) -> bool {
         let non_error_count = self

crates/weaver_forge/src/lib.rs

@@ -779,16 +779,14 @@ mod tests {
         let schema = SchemaResolver::resolve_semantic_convention_registry(&mut registry)
             .expect("Failed to resolve registry");
 
-        let template_registry = ResolvedRegistry::try_from_resolved_registry(
-            schema.registry(registry_id).expect("registry not found"),
-            schema.catalog(),
-        )
-        .unwrap_or_else(|e| {
-            panic!(
-                "Failed to create the context for the template evaluation: {:?}",
-                e
-            )
-        });
+        let template_registry =
+            ResolvedRegistry::try_from_resolved_registry(&schema.registry, schema.catalog())
+                .unwrap_or_else(|e| {
+                    panic!(
+                        "Failed to create the context for the template evaluation: {:?}",
+                        e
+                    )
+                });
 
         // Delete all the files in the observed_output/target directory
         // before generating the new files.
@@ -959,16 +957,14 @@ mod tests {
         let schema = SchemaResolver::resolve_semantic_convention_registry(&mut registry)
             .expect("Failed to resolve registry");
 
-        let template_registry = ResolvedRegistry::try_from_resolved_registry(
-            schema.registry(registry_id).expect("registry not found"),
-            schema.catalog(),
-        )
-        .unwrap_or_else(|e| {
-            panic!(
-                "Failed to create the context for the template evaluation: {:?}",
-                e
-            )
-        });
+        let template_registry =
+            ResolvedRegistry::try_from_resolved_registry(&schema.registry, schema.catalog())
+                .unwrap_or_else(|e| {
+                    panic!(
+                        "Failed to create the context for the template evaluation: {:?}",
+                        e
+                    )
+                });
 
         engine
             .generate(

crates/weaver_forge/src/registry.rs

@@ -12,6 +12,7 @@ use weaver_resolved_schema::catalog::Catalog;
 use weaver_resolved_schema::lineage::GroupLineage;
 use weaver_resolved_schema::registry::{Constraint, Group, Registry};
 use weaver_semconv::any_value::AnyValueSpec;
+use weaver_semconv::deprecated::Deprecated;
 use weaver_semconv::group::{GroupType, InstrumentSpec, SpanKindSpec};
 use weaver_semconv::stability::Stability;
 
@@ -63,7 +64,7 @@ pub struct ResolvedGroup {
     /// provided as `description` MUST specify why it's deprecated and/or what
     /// to use instead. See also stability.
     #[serde(skip_serializing_if = "Option::is_none")]
-    pub deprecated: Option<String>,
+    pub deprecated: Option<Deprecated>,
     /// Additional constraints.
     /// Allow to define additional requirements on the semantic convention.
     /// It defaults to an empty list.

crates/weaver_otel_schema/Cargo.toml

@@ -0,0 +1,20 @@
+[package]
+name = "weaver_otel_schema"
+version = "0.10.0"
+authors.workspace = true
+repository.workspace = true
+license.workspace = true
+publish.workspace = true
+edition.workspace = true
+rust-version.workspace = true
+
+[lints]
+workspace = true
+
+[dependencies]
+weaver_version = { path = "../weaver_version" }
+
+thiserror.workspace = true
+serde.workspace = true
+serde_yaml.workspace = true
+

crates/weaver_otel_schema/README.md

@@ -0,0 +1,3 @@
+# OpenTelemetry Schema Data Model
+
+This crate describes the data model for the OpenTelemetry telemetry schema.

crates/weaver_otel_schema/allowed-external-types.toml

@@ -0,0 +1,6 @@
+# Copyright The OpenTelemetry Authors
+# SPDX-License-Identifier: Apache-2.0
+# This is used with cargo-check-external-types to reduce the surface area of downstream crates from
+# the public API. Ideally this can have a few exceptions as possible.
+allowed_external_types = [
+]

crates/weaver_otel_schema/src/lib.rs

@@ -0,0 +1,85 @@
+// SPDX-License-Identifier: Apache-2.0
+
+//! OpenTelemetry Schema Definitions
+//! Please refer to the [OpenTelemetry Schema OTEP](https://github.com/open-telemetry/oteps/blob/main/text/0152-telemetry-schemas.md)
+//! for more information.
+
+use crate::Error::{InvalidTelemetrySchema, TelemetrySchemaNotFound};
+use serde::{Deserialize, Serialize};
+use weaver_version::Versions;
+
+/// Errors emitted by this crate.
+#[derive(thiserror::Error, Debug, Clone, Deserialize, Serialize)]
+pub enum Error {
+    /// OTel Telemetry schema not found.
+    #[error("OTel telemetry schema not found (path_or_url: {path_or_url:?}).")]
+    TelemetrySchemaNotFound {
+        /// The path or the url to the telemetry schema file.
+        path_or_url: String,
+    },
+
+    /// Invalid OTel Telemetry schema.
+    #[error("Invalid OTel telemetry schema (path_or_url: {path_or_url:?}). {error}")]
+    InvalidTelemetrySchema {
+        /// The path or the url to the telemetry schema file.
+        path_or_url: String,
+        /// The error that occurred.
+        error: String,
+    },
+}
+
+/// An OpenTelemetry Telemetry Schema.
+#[derive(Serialize, Deserialize, Debug)]
+#[serde(deny_unknown_fields)]
+pub struct TelemetrySchema {
+    /// Version of the file structure.
+    pub file_format: String,
+    /// Schema URL that this file is published at.
+    pub schema_url: String,
+    /// Definitions for each schema version in this family.
+    /// Note: the ordering of versions is defined according to semver
+    /// version number ordering rules.
+    /// This section is described in more details in the OTEP 0152 and in a dedicated
+    /// section below.
+    /// <https://github.com/open-telemetry/oteps/blob/main/text/0152-telemetry-schemas.md>
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub versions: Option<Versions>,
+}
+
+impl TelemetrySchema {
+    /// Attempts to load a telemetry schema from a file.
+    pub fn try_from_file<P: AsRef<std::path::Path>>(path: P) -> Result<Self, Error> {
+        let schema_path_buf = path.as_ref().to_path_buf();
+
+        if !schema_path_buf.exists() {
+            return Err(TelemetrySchemaNotFound {
+                path_or_url: schema_path_buf.as_path().to_string_lossy().to_string(),
+            });
+        }
+
+        let file = std::fs::File::open(path).map_err(|e| InvalidTelemetrySchema {
+            path_or_url: schema_path_buf.as_path().to_string_lossy().to_string(),
+            error: e.to_string(),
+        })?;
+        let reader = std::io::BufReader::new(file);
+        let schema: TelemetrySchema =
+            serde_yaml::from_reader(reader).map_err(|e| InvalidTelemetrySchema {
+                path_or_url: schema_path_buf.as_path().to_string_lossy().to_string(),
+                error: e.to_string(),
+            })?;
+
+        Ok(schema)
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use crate::TelemetrySchema;
+
+    #[test]
+    fn test_try_from_file() {
+        let schema = TelemetrySchema::try_from_file("tests/test_data/1.27.0.yaml").unwrap();
+        assert_eq!(schema.file_format, "1.1.0");
+        assert_eq!(schema.schema_url, "https://opentelemetry.io/schemas/1.27.0");
+    }
+}