lux-lib 0.36.2

Library for the lux package manager for Lua
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

use std::io;

use fs_extra::dir::CopyOptions;
use itertools::Itertools;
use thiserror::Error;

use crate::{
    lockfile::{FlushLockfileError, LocalPackageId, PinnedState},
    package::PackageSpec,
    tree::{Tree, TreeError},
};

// TODO(vhyrro): Differentiate pinned LocalPackages at the type level?

#[derive(Error, Debug)]
pub enum PinError {
    #[error("package with ID {0} not found in the lockfile")]
    PackageNotFound(LocalPackageId),
    #[error("rock {rock} is already {}pinned!", if *.pin_state == PinnedState::Unpinned { "un" } else { "" })]
    PinStateUnchanged {
        pin_state: PinnedState,
        rock: PackageSpec,
    },
    #[error("cannot change pin state of {rock}, since a second version of {rock} is already installed with `pin: {}`", .pin_state.as_bool())]
    PinStateConflict {
        pin_state: PinnedState,
        rock: PackageSpec,
    },
    #[error(transparent)]
    FlushLockfile(#[from] FlushLockfileError),
    #[error(transparent)]
    Tree(#[from] TreeError),
    #[error("failed to move old package: {0}")]
    MoveItemsFailure(#[from] fs_extra::error::Error),
    #[error("cannot change pin state of {rock}, because it is not an entrypoint")]
    NotAnEntrypoint { rock: PackageSpec },
    #[error("error reading directory {0}:\n{1}")]
    ReadDir(String, io::Error),
    #[error("error creating directory {0}:\n{1}")]
    CreateDir(String, io::Error),
}

pub fn set_pinned_state(
    package_id: &LocalPackageId,
    tree: &Tree,
    pin: PinnedState,
) -> Result<(), PinError> {
    let lockfile = tree.lockfile()?;
    let mut package = lockfile
        .get(package_id)
        .ok_or_else(|| PinError::PackageNotFound(package_id.clone()))?
        .clone();

    if !lockfile.is_entrypoint(&package.id()) {
        return Err(PinError::NotAnEntrypoint {
            rock: package.to_package(),
        });
    }

    if pin == package.pinned() {
        return Err(PinError::PinStateUnchanged {
            pin_state: package.pinned(),
            rock: package.to_package(),
        });
    }

    let old_package = package.clone();
    let package_root = tree.root_for(&package);
    let items = std::fs::read_dir(&package_root)
        .map_err(|err| PinError::ReadDir(package_root.to_string_lossy().to_string(), err))?
        .filter_map(Result::ok)
        .map(|dir| dir.path())
        .collect_vec();

    package.spec.pinned = pin;

    if lockfile.get(&package.id()).is_some() {
        return Err(PinError::PinStateConflict {
            pin_state: package.pinned(),
            rock: package.to_package(),
        });
    }

    let new_root = tree.root_for(&package);

    std::fs::create_dir_all(&new_root)
        .map_err(|err| PinError::CreateDir(new_root.to_string_lossy().to_string(), err))?;

    fs_extra::move_items(&items, new_root, &CopyOptions::new())?;

    lockfile.map_then_flush(|lockfile| {
        lockfile.remove(&old_package);
        lockfile.add_entrypoint(&package);

        Ok::<_, io::Error>(())
    })?;

    Ok(())
}