@smbcloud / cli
Code Commits Issues Pulls Cloud Agent CI/CD
feature/apps
claude/smbcloud-github-app-k9641p development feature/apps feature/build-release feature/ci-docs feature/ci-ruby-gems feature/cicd feature/completion feature/dist-nuget feature/fix-ci-sdk-pypi-rubygem feature/fix-clippy-on-stable-channel feature/fix-deployment-script feature/github-email feature/gresiq-v1 feature/project-new-structure feature/rsync-deploy feature/ruby-runner feature/sdk-npm feature/sdk-workflows feature/smbcloud-cli-release-npm feature/smbcloud-deploy feature/wasm main release/v0.7.4
rs 89 lines 2.34 KB
Raw
1 pub mod cli;
2 pub mod handler;
3
4 use anyhow::{anyhow, Result};
5 use log::debug;
6 use reqwest::Client;
7 use smbpndk_model::{create_params, Oten};
8 use smbpndk_networking::{constants::BASE_URL, get_token};
9
10 async fn get_oten_apps() -> Result<Vec<Oten>> {
11 // Get current token
12 let token = get_token().await?;
13
14 let response = Client::new()
15 .get([BASE_URL, "v1/oten_apps"].join(""))
16 .header("Authorization", token)
17 .send()
18 .await?;
19
20 match response.status() {
21 reqwest::StatusCode::OK => {
22 let oten_apps: Vec<Oten> = response.json().await?;
23 Ok(oten_apps)
24 }
25 _ => Err(anyhow!("Failed to fetch oten apps.")),
26 }
27 }
28
29 async fn get_oten_app(id: &str) -> Result<Oten> {
30 // Get current token
31 let token = get_token().await?;
32
33 let response = Client::new()
34 .get([BASE_URL, "v1/oten_apps/", id].join(""))
35 .header("Authorization", token)
36 .send()
37 .await?;
38
39 match response.status() {
40 reqwest::StatusCode::OK => {
41 let oten_app: Oten = response.json().await?;
42 println!("Auth app requested: {oten_app:#?}");
43 Ok(oten_app)
44 }
45 _ => Err(anyhow!(format!(
46 "Failed to find an oten app with id: {id}."
47 ))),
48 }
49 }
50
51 async fn delete_oten_app(id: String) -> Result<()> {
52 // Get current token
53 let token = get_token().await?;
54
55 let response = Client::new()
56 .delete([BASE_URL, "v1/oten_apps/", &id].join(""))
57 .header("Authorization", token)
58 .send()
59 .await?;
60
61 match response.status() {
62 reqwest::StatusCode::OK => {
63 debug!("Project deleted.");
64 Ok(())
65 }
66 _ => Err(anyhow!("Failed to delete an oten app.")),
67 }
68 }
69
70 async fn create_oten_app(oten_app: create_params::Oten) -> Result<Oten> {
71 // Get current token
72 let token = get_token().await?;
73
74 let response = Client::new()
75 .post([BASE_URL, "v1/oten_apps"].join(""))
76 .json(&oten_app)
77 .header("Authorization", token)
78 .send()
79 .await?;
80
81 match response.status() {
82 reqwest::StatusCode::CREATED => {
83 let oten_app: Oten = response.json().await?;
84 println!("Project created: {oten_app:#?}");
85 Ok(oten_app)
86 }
87 _ => Err(anyhow!("Failed to create an oten app.")),
88 }
89 }