crab_rocket_task 0.1.0

Task package for the crab rocket project
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

use crate::mappers::task_mapper;
use crab_rocket_schema::establish_pg_connection;

use crate::models::task::{NewTask, Task};
use crate::routes::task_param::TaskParam;
use crate::services::task_service::GetTask;
use crab_rocket_utils::time::get_e8_time;

// GOOD:
pub fn get_all_tasks_controller() -> (i32, String, Vec<Task>) {
    match Task::get_all_tasks() {
        Ok(all_tasks) => (200, String::from("OK"), all_tasks),
        Err(e) => {
            println!("{e:?}");
            (200, e.to_string(), Vec::new())
        }
    }
}

// GOOD:
pub fn get_task_by_id_controller(id: i32) -> (i32, String, Task) {
    match Task::get_task_by_id(id) {
        Ok(task) => (200, String::from("OK"), task),
        Err(e) => {
            println!("{e:?}");
            (200, e.to_string(), Task::default())
        }
    }
}

pub fn insert_single_task_controller(raw_task: &mut NewTask) -> (i32, String, Task) {
    // Handle None date time
    if raw_task.created_at() == None {
        raw_task.set_created_at(Some(get_e8_time()));
    }
    if raw_task.updated_at() == None {
        raw_task.set_updated_at(Some(get_e8_time()));
    }
    match Task::insert_single_task(&raw_task.clone()) {
        Ok(result_task) => (201, String::from("Created"), result_task),
        Err(e) => (204, e.to_string(), Task::default()),
    }
}

pub fn put_task_by_id_controller(
    id: i32,
    task: &crate::models::task::PutTask,
) -> (i32, String, Task) {
    match establish_pg_connection() {
        Ok(mut conn) => {
            if task_mapper::check_exist_task_by_id(&mut conn, id) {
                // Update all fields if exists.
                println!("Update all fields.");
                match Task::update_task_by_id(id, &task.clone().into()) {
                    Ok(task) => (200, String::from("PUT OK"), task),
                    Err(e) => (204, e.to_string(), Task::default()),
                }
            } else {
                // Insert a new task if not exists.
                println!("Insert a new task.");
                match Task::insert_full_single_task(&task.clone().into()) {
                    Ok(inserted_new_task) => {
                        (200, String::from("PUT -> INSERT NEW OK"), inserted_new_task)
                    }
                    Err(e) => (204, e.to_string(), Task::default()),
                }
            }
        }
        Err(e) => (504, e.to_string(), Task::default()),
    }
}

pub fn update_task_by_id_controller(
    id: i32,
    patch_task: &crate::models::task::PatchTask,
) -> (i32, String, Task) {
    match Task::update_task_by_id(id, patch_task) {
        Ok(patched_task) => (200, String::from("PATCH OK"), patched_task),
        Err(e) => (204, e.to_string(), Task::default()),
    }
}

pub fn delete_task_by_id_controller(id: i32) -> (i32, String, Task) {
    match Task::delete_task_by_id(id) {
        Ok(deleted_task) => (204, String::from("Deleted"), deleted_task),
        Err(e) => (204, e.to_string(), Task::default()),
    }
}

pub fn get_tasks_by_params_controller(params: &TaskParam) -> (i32, String, Vec<Task>) {
    match Task::filter_tasks_by_params(params) {
        Ok(filtered_tasks) => (200, String::from("GET TASKS BY PARAMS OK"), filtered_tasks),
        Err(e) => (204, e.to_string(), Vec::new()),
    }
}