qubit-fs 0.2.0

Provider-neutral synchronous and asynchronous filesystem abstraction for Rust
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

// =============================================================================
//    Copyright (c) 2026 Haixing Hu.
//
//    SPDX-License-Identifier: Apache-2.0
//
//    Licensed under the Apache License, Version 2.0.
// =============================================================================
//! Shared validation for provider-reported rename outcomes.

use super::rename_outcome_validation_error::RenameOutcomeValidationError;
use crate::metadata::AchievedAtomicity;
use crate::metadata::DurabilityRequirement;
use crate::metadata::PublicationMethod;
use crate::path::Path;
use crate::rename::RenameFailureState;
use crate::rename::RenameOptions;
use crate::rename::RenameOutcome;

/// Validates provider outcome guarantees shared by sync and async facades.
pub(crate) fn validate_rename_outcome(
    outcome: &RenameOutcome,
    options: &RenameOptions,
    source: &Path,
    target: &Path,
) -> Option<RenameOutcomeValidationError> {
    if options.atomicity() == crate::metadata::AtomicityRequirement::Required
        && outcome.atomicity() != AchievedAtomicity::Atomic
    {
        return Some(RenameOutcomeValidationError {
            message: "provider reported non-atomic success for an atomic-required rename",
            state: RenameFailureState::Renamed,
        });
    }
    if outcome.method() == PublicationMethod::CopyThenDelete {
        return Some(RenameOutcomeValidationError {
            message: "provider returned copy-then-delete for rename",
            state: RenameFailureState::Renamed,
        });
    }
    if options.durability() == DurabilityRequirement::Required && !outcome.durable() {
        return Some(RenameOutcomeValidationError {
            message: "provider reported non-durable success for a durability-required rename",
            state: RenameFailureState::Renamed,
        });
    }
    if outcome.source() != source || outcome.target() != target {
        return Some(RenameOutcomeValidationError {
            message: "provider returned a rename outcome with different identities",
            state: RenameFailureState::Indeterminate,
        });
    }
    None
}