triblespace-core 0.35.0

The triblespace core implementation.
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

use crate::blob::Blob;
use crate::blob::BlobSchema;
use crate::blob::ToBlob;
use crate::blob::TryFromBlob;
use crate::id::ExclusiveId;
use crate::id::Id;
use crate::id_hex;
use crate::macros::entity;
use crate::metadata;
use crate::metadata::{ConstDescribe, ConstId};
use crate::repo::BlobStore;
use crate::trible::Fragment;
use crate::value::schemas::hash::Blake3;

use anybytes::Bytes;

/// Raw file bytes stored as a blob.
///
/// Use this schema when the payload represents a file snapshot and you want to
/// preserve that provenance explicitly instead of falling back to UnknownBlob.
pub struct FileBytes;

impl BlobSchema for FileBytes {}

impl ConstId for FileBytes {
    const ID: Id = id_hex!("5DE76157AE4FDEA830019916805E80A4");
}

impl ConstDescribe for FileBytes {
    fn describe<B>(blobs: &mut B) -> Result<Fragment, B::PutError>
    where
        B: BlobStore<Blake3>,
    {
        let id = Self::ID;
        let description = blobs.put(
            "Opaque file bytes captured as a blob. Use when the payload represents a file snapshot (attachments, dataset artifacts, exported archives) and you want to preserve that provenance in the schema rather than treating it as UnknownBlob. The meaning is given by adjacent metadata attributes such as mime type, filename, and dimensions.",
        )?;
        Ok(entity! {
            ExclusiveId::force_ref(&id) @
                metadata::name: blobs.put("filebytes")?,
                metadata::description: description,
                metadata::tag: metadata::KIND_BLOB_SCHEMA,
        })
    }
}

impl TryFromBlob<FileBytes> for Bytes {
    type Error = std::convert::Infallible;

    fn try_from_blob(blob: Blob<FileBytes>) -> Result<Self, Self::Error> {
        Ok(blob.bytes)
    }
}

impl ToBlob<FileBytes> for Bytes {
    fn to_blob(self) -> Blob<FileBytes> {
        Blob::new(self)
    }
}

impl ToBlob<FileBytes> for Vec<u8> {
    fn to_blob(self) -> Blob<FileBytes> {
        Blob::new(Bytes::from_source(self))
    }
}

impl ToBlob<FileBytes> for &[u8] {
    fn to_blob(self) -> Blob<FileBytes> {
        Blob::new(Bytes::from_source(self.to_vec()))
    }
}