whiley 0.6.3

A command-line build tool and package manager for Whiley.
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
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121

use std::error::Error;
use std::fmt;
use std::fs;
use std::path::{Path,PathBuf};
use log::{info,error};
use reqwest;
use reqwest::Url;

#[derive(Clone,Debug,PartialEq)]
pub struct MavenArtifact<'a> {
    group_id : &'a str,
    artifact_id : &'a str,
    version: &'a str
}

impl<'a> MavenArtifact<'a> {
    pub fn new(desc : &str) -> Result<MavenArtifact,()> {
	let parts = desc.split(":").collect::<Vec<&str>>();
	//
	if parts.len() != 3 {
	    Err(())
	} else {
	    Ok(MavenArtifact{group_id:parts[0],artifact_id:parts[1],version:parts[2]})
	}
    }

    pub fn to_jarname(&self) -> String {
	let mut n = String::new();
	n.push_str(self.artifact_id);
	n.push_str("-");
	n.push_str(self.version);
	n.push_str(".jar");
	n
    }

    pub fn to_url(&self, base: &Url) -> Url {
	let mut s = String::new();
	s.push_str(self.group_id.replace(".","/").as_str());
	s.push_str("/");
	s.push_str(self.artifact_id);
	s.push_str("/");
	s.push_str(self.version);
	s.push_str("/");
	s.push_str(self.to_jarname().as_str());
	// ERROR HANDLING
	base.join(&s).unwrap()
    }
}

impl<'a> fmt::Display for MavenArtifact<'a> {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        write!(f,"{}:{}:{}",self.group_id,self.artifact_id,self.version)
    }
}

// ==========================================================
// Resolver
// ==========================================================

#[derive(Clone,Debug,PartialEq)]
pub struct MavenResolver<T: AsRef<Path>> {
    /// Path to cache root on local filesyste
    dir: T,
    /// Base URL for downloading Maven Jars (e.g. Maven Central)
    url: Url
}

impl<T: AsRef<Path>> MavenResolver<T> {
    pub fn new(dir: T, url: Url) -> MavenResolver<T> {
	// Ensure cache directory exists
	fs::create_dir_all(dir.as_ref()).unwrap();
	// Done
	MavenResolver{dir,url}
    }

    pub fn get<'b>(&self, artifact: MavenArtifact<'b>) -> Result<PathBuf,Box<dyn Error>> {
	// Determine jar name
	let mut jar = PathBuf::new();
	jar.push(self.dir.as_ref());
	jar.push(artifact.to_jarname());
	//
	if !jar.as_path().exists() {
            // cache miss, try to download
	    let url = artifact.to_url(&self.url);
	    let response = reqwest::blocking::get(url.clone())?;
            // Check status code
            if response.status().is_success() {
                info!("Downloaded {}",url.as_str());
	        fs::write(jar.as_path(),response.bytes()?)?;
            } else {
                error!("Downloading {} ({:?})",url.as_str(),response.status());
                return Err(Box::new(ResolutionError{name:artifact.to_jarname()}));
            }
	}
	//
	Ok(jar)
    }
}

// ================================================================
// Resolution Error
// ================================================================

#[derive(Clone)]
struct ResolutionError {
    name: String
}

impl fmt::Display for ResolutionError {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        write!(f, "failed resolving maven package {}",self.name)
    }
}

impl fmt::Debug for ResolutionError {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        write!(f, "failed resolving maven package {}",self.name)
    }
}

impl Error for ResolutionError {}