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

// Copyright 2018 Dmitry Tantsur <divius.inside@gmail.com>
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

//! Foundation bits exposing the Image API.

use std::fmt::Debug;

use osauth::services::IMAGE;
use serde::Serialize;

use super::super::session::Session;
use super::super::utils::{self, ResultExt};
use super::super::Result;
use super::protocol::*;

/// Get an image.
pub fn get_image<S: AsRef<str>>(session: &Session, id_or_name: S) -> Result<Image> {
    let s = id_or_name.as_ref();
    get_image_by_id(session, s).if_not_found_then(|| get_image_by_name(session, s))
}

/// Get an image by its ID.
pub fn get_image_by_id<S: AsRef<str>>(session: &Session, id: S) -> Result<Image> {
    trace!("Fetching image {}", id.as_ref());
    let image: Image = session.get_json(IMAGE, &["images", id.as_ref()], None)?;
    trace!("Received {:?}", image);
    Ok(image)
}

/// Get an image by its name.
pub fn get_image_by_name<S: AsRef<str>>(session: &Session, name: S) -> Result<Image> {
    trace!("Get image by name {}", name.as_ref());
    let root: ImagesRoot =
        session.get_json_query(IMAGE, &["images"], &[("name", name.as_ref())], None)?;
    let result = utils::one(
        root.images,
        "Image with given name or ID not found",
        "Too many images found with given name",
    )?;
    trace!("Received {:?}", result);
    Ok(result)
}

/// List images.
pub fn list_images<Q: Serialize + Sync + Debug>(
    session: &Session,
    query: &Q,
) -> Result<Vec<Image>> {
    trace!("Listing images with {:?}", query);
    let root: ImagesRoot = session.get_json_query(IMAGE, &["images"], query, None)?;
    trace!("Received images: {:?}", root.images);
    Ok(root.images)
}