mockforge-intelligence 0.3.241

AI-powered behavior, response generation, and behavioral cloning for MockForge
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101

//! Atomically publish complete immutable snapshots without replacing a winner.
use super::{
    bundles, fs, loading, validate_artifact_type, ArtifactFreezer, FreezeRequest, FrozenArtifact,
    Result,
};

impl ArtifactFreezer {
    pub(crate) async fn load_snapshot(
        &self,
        artifact_type: &str,
        identifier: &str,
        format: &str,
    ) -> Result<Option<FrozenArtifact>> {
        let mut path = self.snapshot_path(artifact_type, identifier, format)?;
        match fs::symlink_metadata(&path).await {
            Ok(metadata) if metadata.file_type().is_file() => {}
            Ok(_) => {
                return Err(mockforge_foundation::Error::config(
                    "Frozen snapshot must be a regular file",
                ))
            }
            Err(error) if error.kind() == std::io::ErrorKind::NotFound => {
                let directory = bundles::path(&path);
                match fs::symlink_metadata(&directory).await {
                    Ok(metadata) if metadata.file_type().is_dir() => {
                        path = bundles::payload(&directory).ok_or_else(|| {
                            mockforge_foundation::Error::config("Invalid snapshot bundle format")
                        })?;
                    }
                    Ok(_) => {
                        return Err(mockforge_foundation::Error::config(
                            "Snapshot bundle must be a directory",
                        ))
                    }
                    Err(error) if error.kind() == std::io::ErrorKind::NotFound => return Ok(None),
                    Err(error) => {
                        return Err(mockforge_foundation::Error::io_with_context(
                            "inspect snapshot bundle",
                            error.to_string(),
                        ))
                    }
                }
            }
            Err(error) => {
                return Err(mockforge_foundation::Error::io_with_context(
                    "read frozen snapshot",
                    error.to_string(),
                ))
            }
        }
        let frozen =
            loading::read(&path, artifact_type, Some(identifier)).await?.ok_or_else(|| {
                mockforge_foundation::Error::config("Frozen snapshot identity mismatch")
            })?;
        if !self.verify_frozen_artifact(&frozen).await? {
            return Err(mockforge_foundation::Error::config(
                "Frozen snapshot integrity check failed",
            ));
        }
        Ok(Some(frozen))
    }

    fn snapshot_path(
        &self,
        artifact_type: &str,
        identifier: &str,
        format: &str,
    ) -> Result<std::path::PathBuf> {
        validate_artifact_type(artifact_type)?;
        if identifier.len() != 64 || !identifier.bytes().all(|byte| byte.is_ascii_hexdigit()) {
            return Err(mockforge_foundation::Error::config("Invalid frozen snapshot identity"));
        }
        let extension = match format {
            "json" => "json",
            "yaml" | "yml" => "yaml",
            _ => {
                return Err(mockforge_foundation::Error::config(
                    "Frozen artifact format must be json or yaml",
                ))
            }
        };
        Ok(self.base_dir.join(format!("{artifact_type}_{identifier}.{extension}")))
    }

    /// Publish one immutable snapshot for an exact generation identity.
    /// A complete temporary directory is renamed into place without overwriting a
    /// winner from another process. All callers return that same snapshot.
    pub(crate) async fn freeze_once(
        &self,
        request: &FreezeRequest,
        identifier: &str,
    ) -> Result<FrozenArtifact> {
        let path = self.snapshot_path(&request.artifact_type, identifier, &request.format)?;
        if let Some(winner) =
            self.load_snapshot(&request.artifact_type, identifier, &request.format).await?
        {
            return Ok(winner);
        }
        bundles::publish(self, request, identifier, &path).await
    }
}