Compare commits
29 commits
Author | SHA1 | Date | |
---|---|---|---|
54735fdf06 | |||
3aa9b8d3d0 | |||
50c36bbcbd | |||
72062842e7 | |||
e77b79afae | |||
7d00d6f863 | |||
5bb7fc6eaf | |||
3c6afa56c4 | |||
703a7c4810 | |||
a7d5962d30 | |||
fc275d1bc9 | |||
98efdaaa82 | |||
cb0173c440 | |||
d9e0a55a84 | |||
7966f61894 | |||
6292b5dddf | |||
062d973d8a | |||
b331363d09 | |||
ebc6eaf6ee | |||
e735a3eeec | |||
2298b04eec | |||
06e60dce14 | |||
1c8e868afd | |||
3b69ca58cd | |||
767d77ffcc | |||
e034933fc0 | |||
d00bc97478 | |||
5bc4b24fd9 | |||
4f086f4717 |
6 changed files with 250 additions and 63 deletions
3
.gitignore
vendored
3
.gitignore
vendored
|
@ -1,4 +1,5 @@
|
||||||
/target
|
/target
|
||||||
.env
|
.env
|
||||||
Cargo.lock
|
Cargo.lock
|
||||||
example*.xml
|
scratchpad/
|
||||||
|
*.bak
|
||||||
|
|
77
Cargo.lock
generated
77
Cargo.lock
generated
|
@ -11,6 +11,12 @@ dependencies = [
|
||||||
"memchr",
|
"memchr",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "array_tool"
|
||||||
|
version = "1.0.3"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "8f8cb5d814eb646a863c4f24978cff2880c4be96ad8cde2c0f0678732902e271"
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "atty"
|
name = "atty"
|
||||||
version = "0.2.14"
|
version = "0.2.14"
|
||||||
|
@ -80,6 +86,26 @@ version = "0.8.3"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "5827cebf4670468b8772dd191856768aedcb1b0278a04f989f7766351917b9dc"
|
checksum = "5827cebf4670468b8772dd191856768aedcb1b0278a04f989f7766351917b9dc"
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "dirs"
|
||||||
|
version = "4.0.0"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "ca3aa72a6f96ea37bbc5aa912f6788242832f75369bdfdadcb0e38423f100059"
|
||||||
|
dependencies = [
|
||||||
|
"dirs-sys",
|
||||||
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "dirs-sys"
|
||||||
|
version = "0.3.6"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "03d86534ed367a67548dc68113a0f5db55432fdfbb6e6f9d77704397d95d5780"
|
||||||
|
dependencies = [
|
||||||
|
"libc",
|
||||||
|
"redox_users",
|
||||||
|
"winapi",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "dotenv"
|
name = "dotenv"
|
||||||
version = "0.15.0"
|
version = "0.15.0"
|
||||||
|
@ -574,11 +600,16 @@ dependencies = [
|
||||||
name = "publicise-rs"
|
name = "publicise-rs"
|
||||||
version = "0.1.0"
|
version = "0.1.0"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
|
"array_tool",
|
||||||
"dotenv",
|
"dotenv",
|
||||||
"env_logger",
|
"env_logger",
|
||||||
"log",
|
"log",
|
||||||
"reqwest",
|
"reqwest",
|
||||||
|
"serde",
|
||||||
"tokio",
|
"tokio",
|
||||||
|
"toml",
|
||||||
|
"url",
|
||||||
|
"xdg",
|
||||||
"yaserde",
|
"yaserde",
|
||||||
"yaserde_derive",
|
"yaserde_derive",
|
||||||
]
|
]
|
||||||
|
@ -641,6 +672,16 @@ dependencies = [
|
||||||
"bitflags",
|
"bitflags",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "redox_users"
|
||||||
|
version = "0.4.0"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "528532f3d801c87aec9def2add9ca802fe569e44a544afe633765267840abe64"
|
||||||
|
dependencies = [
|
||||||
|
"getrandom",
|
||||||
|
"redox_syscall",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "regex"
|
name = "regex"
|
||||||
version = "1.5.4"
|
version = "1.5.4"
|
||||||
|
@ -749,9 +790,23 @@ dependencies = [
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "serde"
|
name = "serde"
|
||||||
version = "1.0.131"
|
version = "1.0.136"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "b4ad69dfbd3e45369132cc64e6748c2d65cdfb001a2b1c232d128b4ad60561c1"
|
checksum = "ce31e24b01e1e524df96f1c2fdd054405f8d7376249a5110886fb4b658484789"
|
||||||
|
dependencies = [
|
||||||
|
"serde_derive",
|
||||||
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "serde_derive"
|
||||||
|
version = "1.0.136"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "08597e7152fcd306f41838ed3e37be9eaeed2b61c42e2117266a554fab4662f9"
|
||||||
|
dependencies = [
|
||||||
|
"proc-macro2",
|
||||||
|
"quote",
|
||||||
|
"syn",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "serde_json"
|
name = "serde_json"
|
||||||
|
@ -911,6 +966,15 @@ dependencies = [
|
||||||
"tokio",
|
"tokio",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "toml"
|
||||||
|
version = "0.5.8"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "a31142970826733df8241ef35dc040ef98c679ab14d7c3e54d827099b3acecaa"
|
||||||
|
dependencies = [
|
||||||
|
"serde",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "tower-service"
|
name = "tower-service"
|
||||||
version = "0.3.1"
|
version = "0.3.1"
|
||||||
|
@ -1120,6 +1184,15 @@ dependencies = [
|
||||||
"winapi",
|
"winapi",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "xdg"
|
||||||
|
version = "2.4.1"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "0c4583db5cbd4c4c0303df2d15af80f0539db703fa1c68802d4cbbd2dd0f88f6"
|
||||||
|
dependencies = [
|
||||||
|
"dirs",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "xml-rs"
|
name = "xml-rs"
|
||||||
version = "0.8.4"
|
version = "0.8.4"
|
||||||
|
|
|
@ -6,10 +6,15 @@ edition = "2021"
|
||||||
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
|
array_tool = "1.0.3"
|
||||||
dotenv = "0.15.0"
|
dotenv = "0.15.0"
|
||||||
env_logger = "0.8.4"
|
env_logger = "0.8.4"
|
||||||
log = "0.4.0"
|
log = "0.4.0"
|
||||||
reqwest = { version = "0.11", features = ["json"] }
|
reqwest = { version = "0.11", features = ["json"] }
|
||||||
|
serde = { version = "1.0.136" , features = ["derive"] }
|
||||||
tokio = { version = "1", features = ["full"] }
|
tokio = { version = "1", features = ["full"] }
|
||||||
|
toml = "0.5.8"
|
||||||
|
url = "2.2.2"
|
||||||
|
xdg = "2.4.1"
|
||||||
yaserde = "0.7.1"
|
yaserde = "0.7.1"
|
||||||
yaserde_derive = "0.7.1"
|
yaserde_derive = "0.7.1"
|
||||||
|
|
13
LICENSE
Normal file
13
LICENSE
Normal file
|
@ -0,0 +1,13 @@
|
||||||
|
DO WHAT THE FUCK YOU WANT TO PUBLIC LICENSE
|
||||||
|
Version 2, December 2004
|
||||||
|
|
||||||
|
Copyright (C) 2004 Sam Hocevar <sam@hocevar.net>
|
||||||
|
|
||||||
|
Everyone is permitted to copy and distribute verbatim or modified
|
||||||
|
copies of this license document, and changing it is allowed as long
|
||||||
|
as the name is changed.
|
||||||
|
|
||||||
|
DO WHAT THE FUCK YOU WANT TO PUBLIC LICENSE
|
||||||
|
TERMS AND CONDITIONS FOR COPYING, DISTRIBUTION AND MODIFICATION
|
||||||
|
|
||||||
|
0. You just DO WHAT THE FUCK YOU WANT TO.
|
5
README.md
Normal file
5
README.md
Normal file
|
@ -0,0 +1,5 @@
|
||||||
|
### publicise-rs
|
||||||
|
|
||||||
|
_Publicise_ is an application which traverses a Nextcloud folder and creates a public share for each file.
|
||||||
|
|
||||||
|
The application was originally devised as a way to share photos with people without Instagram accounts, and as an exploration of Rust.
|
210
src/main.rs
210
src/main.rs
|
@ -1,15 +1,36 @@
|
||||||
#[allow(unused)]
|
extern crate xdg;
|
||||||
use env_logger::{Env, Target};
|
|
||||||
#[allow(unused)]
|
|
||||||
use log::{debug, error, info, log_enabled, warn};
|
|
||||||
use reqwest;
|
|
||||||
#[allow(unused)]
|
|
||||||
use std::io::{self, BufReader, Write};
|
|
||||||
#[allow(unused)]
|
|
||||||
use yaserde_derive::{YaDeserialize, YaSerialize};
|
|
||||||
|
|
||||||
#[allow(unused)]
|
use env_logger::Env;
|
||||||
fn publicise() {}
|
use log::debug;
|
||||||
|
use reqwest;
|
||||||
|
use serde::Deserialize;
|
||||||
|
use std::collections::HashMap;
|
||||||
|
use std::fs;
|
||||||
|
use std::process::Command;
|
||||||
|
use std::str;
|
||||||
|
use toml;
|
||||||
|
use url::Url;
|
||||||
|
use yaserde_derive::YaDeserialize;
|
||||||
|
use yaserde::de::from_str;
|
||||||
|
|
||||||
|
#[derive(Debug, Deserialize)]
|
||||||
|
pub struct Config {
|
||||||
|
credentials: Credentials,
|
||||||
|
paths: NextcloudPaths,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Debug, Deserialize)]
|
||||||
|
pub struct Credentials {
|
||||||
|
username: String,
|
||||||
|
password: Option<String>,
|
||||||
|
password_script: Option<String>,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Debug, Deserialize)]
|
||||||
|
pub struct NextcloudPaths {
|
||||||
|
root: String,
|
||||||
|
target: String,
|
||||||
|
}
|
||||||
|
|
||||||
#[derive(Default, PartialEq, Debug, YaDeserialize)]
|
#[derive(Default, PartialEq, Debug, YaDeserialize)]
|
||||||
#[yaserde(
|
#[yaserde(
|
||||||
|
@ -18,7 +39,7 @@ fn publicise() {}
|
||||||
namespace = "d: DAV:",
|
namespace = "d: DAV:",
|
||||||
namespace = "nc: http://nextcloud.org/ns",
|
namespace = "nc: http://nextcloud.org/ns",
|
||||||
namespace = "oc: http://owncloud.org/ns",
|
namespace = "oc: http://owncloud.org/ns",
|
||||||
namespace = "s: http://sabredav.org/ns",
|
namespace = "s: http://sabredav.org/ns"
|
||||||
)]
|
)]
|
||||||
pub struct Multistatus {
|
pub struct Multistatus {
|
||||||
#[yaserde(prefix = "d")]
|
#[yaserde(prefix = "d")]
|
||||||
|
@ -29,7 +50,7 @@ pub struct Multistatus {
|
||||||
#[yaserde(rename = "response", prefix = "d", namespace = "d: DAV:")]
|
#[yaserde(rename = "response", prefix = "d", namespace = "d: DAV:")]
|
||||||
pub struct NextcloudResponse {
|
pub struct NextcloudResponse {
|
||||||
#[yaserde(prefix = "d")]
|
#[yaserde(prefix = "d")]
|
||||||
href: Option<String>,
|
href: String,
|
||||||
#[yaserde(prefix = "d")]
|
#[yaserde(prefix = "d")]
|
||||||
propstat: Vec<Propstat>,
|
propstat: Vec<Propstat>,
|
||||||
}
|
}
|
||||||
|
@ -38,26 +59,30 @@ pub struct NextcloudResponse {
|
||||||
#[yaserde(rename = "propstat", prefix = "d", namespace = "d: DAV:")]
|
#[yaserde(rename = "propstat", prefix = "d", namespace = "d: DAV:")]
|
||||||
pub struct Propstat {
|
pub struct Propstat {
|
||||||
#[yaserde(prefix = "d")]
|
#[yaserde(prefix = "d")]
|
||||||
prop: Option<Prop>,
|
prop: Prop,
|
||||||
#[yaserde(prefix = "d")]
|
#[yaserde(prefix = "d")]
|
||||||
status: Option<String>,
|
status: String,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Default, PartialEq, Debug, YaDeserialize)]
|
#[derive(Default, PartialEq, Debug, YaDeserialize)]
|
||||||
#[yaserde(rename = "prop", namespace = "d: DAV:", namespace = "oc: http://owncloud.org/ns")]
|
#[yaserde(
|
||||||
|
rename = "prop",
|
||||||
|
namespace = "d: DAV:",
|
||||||
|
namespace = "oc: http://owncloud.org/ns"
|
||||||
|
)]
|
||||||
pub struct Prop {
|
pub struct Prop {
|
||||||
#[yaserde(prefix = "d", rename = "getlastmodified")]
|
#[yaserde(prefix = "d", rename = "getlastmodified")]
|
||||||
get_last_modified: Option<String>,
|
get_last_modified: String,
|
||||||
#[yaserde(prefix = "oc")]
|
#[yaserde(prefix = "oc")]
|
||||||
permissions: Option<String>,
|
permissions: String,
|
||||||
#[yaserde(prefix = "d", rename = "resourcetype")]
|
#[yaserde(prefix = "d", rename = "resourcetype")]
|
||||||
resource_type: Option<ResourceType>,
|
resource_type: ResourceType,
|
||||||
#[yaserde(prefix = "d", rename = "getetag")]
|
#[yaserde(prefix = "d", rename = "getetag")]
|
||||||
get_etag: Option<String>,
|
get_etag: String,
|
||||||
#[yaserde(prefix = "d", rename = "getcontentlength")]
|
#[yaserde(prefix = "d", rename = "getcontentlength")]
|
||||||
get_content_length: Option<u32>,
|
get_content_length: u32,
|
||||||
#[yaserde(prefix = "d", rename = "getcontenttype")]
|
#[yaserde(prefix = "d", rename = "getcontenttype")]
|
||||||
get_content_type: Option<String>,
|
get_content_type: String,
|
||||||
#[yaserde(prefix = "oc", rename = "share-types")]
|
#[yaserde(prefix = "oc", rename = "share-types")]
|
||||||
share_types: Vec<ShareType>,
|
share_types: Vec<ShareType>,
|
||||||
}
|
}
|
||||||
|
@ -80,19 +105,26 @@ pub struct ResourceType {
|
||||||
#[yaserde(rename = "collection", namespace = "d: DAV:")]
|
#[yaserde(rename = "collection", namespace = "d: DAV:")]
|
||||||
pub struct Collection {
|
pub struct Collection {
|
||||||
#[yaserde(prefix = "d")]
|
#[yaserde(prefix = "d")]
|
||||||
collection: Option<String>,
|
collection: String,
|
||||||
}
|
}
|
||||||
|
|
||||||
async fn get_folder_contents(
|
fn init() -> Result<Config, Box<dyn std::error::Error>> {
|
||||||
password: String,
|
debug!("[init] Entering function...");
|
||||||
url_tail: &str,
|
let xdg_dirs = xdg::BaseDirectories::with_prefix("publicise-rs").unwrap();
|
||||||
) -> Result<String, Box<dyn std::error::Error>> {
|
let config_path = xdg_dirs.find_config_file("config.toml").unwrap();
|
||||||
debug!("Entering: get_folder_contents()");
|
let config_file_contents = fs::read_to_string(config_path).unwrap();
|
||||||
let root_url = "https://theadamcooper.com";
|
let config: Config = toml::from_str(&config_file_contents).unwrap();
|
||||||
|
debug!("[init] config: {:?}", config);
|
||||||
|
return Ok(config);
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn get_folder_contents(url_tail: &str, config: &Config) -> Result<String, Box<dyn std::error::Error>> {
|
||||||
|
debug!("[get_folder_contents] Entering function...");
|
||||||
|
let root_url = Url::parse(&config.paths.root)?;
|
||||||
let method = reqwest::Method::from_bytes(b"PROPFIND").unwrap();
|
let method = reqwest::Method::from_bytes(b"PROPFIND").unwrap();
|
||||||
let client = reqwest::Client::new();
|
let client = reqwest::Client::new();
|
||||||
let url = format!("{}{}", root_url, url_tail);
|
let url = root_url.join(url_tail)?;
|
||||||
debug!("url: {}", url);
|
debug!("[get_folder_contents] url: {}", url);
|
||||||
let body = String::from(
|
let body = String::from(
|
||||||
r#"<?xml version="1.0" encoding="UTF-8"?>
|
r#"<?xml version="1.0" encoding="UTF-8"?>
|
||||||
<d:propfind xmlns:d="DAV:">
|
<d:propfind xmlns:d="DAV:">
|
||||||
|
@ -109,53 +141,111 @@ async fn get_folder_contents(
|
||||||
);
|
);
|
||||||
let response_text = client
|
let response_text = client
|
||||||
.request(method, url)
|
.request(method, url)
|
||||||
.basic_auth("adam", Some(password))
|
.basic_auth(config.credentials.username.as_str(), config.credentials.password.as_ref())
|
||||||
.body(body)
|
.body(body)
|
||||||
.send()
|
.send()
|
||||||
.await?
|
.await?
|
||||||
.text()
|
.text()
|
||||||
.await?;
|
.await?;
|
||||||
debug!("{:?}", response_text);
|
debug!("[get_folder_contents] response_text: {:?}", response_text);
|
||||||
Ok(response_text)
|
Ok(response_text)
|
||||||
}
|
}
|
||||||
|
|
||||||
fn get_password() -> Result<String, std::io::Error> {
|
async fn publicise_it(path: &str, config: &Config) -> Result<bool, Box<dyn std::error::Error>> {
|
||||||
print!("Nextcloud password: ");
|
debug!("[publicise_it] Entering function...");
|
||||||
io::stdout().flush().unwrap();
|
let base_url = Url::parse(config.paths.root.as_str())?;
|
||||||
let mut buffer = String::new();
|
let url = base_url.join("ocs/v2.php/apps/files_sharing/api/v1/shares")?;
|
||||||
let stdin = io::stdin();
|
let method = reqwest::Method::POST;
|
||||||
match stdin.read_line(&mut buffer) {
|
let client = reqwest::Client::new();
|
||||||
Ok(_) => Ok(buffer),
|
let params = [("path", path), ("shareType", "3")];
|
||||||
Err(error) => Err(error),
|
debug!("[publicise_it] url: {}", url);
|
||||||
}
|
debug!("[publicise_it] params: {:?}", params);
|
||||||
|
let response_text = client
|
||||||
|
.request(method, url)
|
||||||
|
.basic_auth(config.credentials.username.as_str(), config.credentials.password.as_ref())
|
||||||
|
.header("OCS-APIRequest", "true")
|
||||||
|
.form(¶ms)
|
||||||
|
.send()
|
||||||
|
.await?
|
||||||
|
.text()
|
||||||
|
.await?;
|
||||||
|
debug!("[publicise_it] response_text: {:?}", response_text);
|
||||||
|
Ok(true)
|
||||||
}
|
}
|
||||||
|
|
||||||
#[allow(unused)]
|
async fn traverse(mut result: Multistatus, config: &Config) -> Result<bool, Box<dyn std::error::Error>> {
|
||||||
fn indent(size: usize) -> String {
|
debug!("[traverse] Entering function...");
|
||||||
const INDENT: &'static str = " ";
|
let mut current_index: usize = 0;
|
||||||
(0..size)
|
let mut visited_items = HashMap::new();
|
||||||
.map(|_| INDENT)
|
let href_key = (&mut result.response[current_index].href).clone();
|
||||||
.fold(String::with_capacity(size * INDENT.len()), |r, s| r + s)
|
visited_items.insert(href_key, true);
|
||||||
|
current_index += 1;
|
||||||
|
|
||||||
|
while current_index < (&mut result.response).len() {
|
||||||
|
debug!("[traverse] current_index: {:?}", current_index);
|
||||||
|
debug!("[traverse] current href: {}", &result.response[current_index].href);
|
||||||
|
let href_key = (&mut result.response[current_index].href).clone();
|
||||||
|
if !visited_items.contains_key(&href_key) {
|
||||||
|
debug!("[traverse] Fresh item...");
|
||||||
|
if !(&mut result.response[current_index].propstat[0].prop.resource_type.collection).is_empty() {
|
||||||
|
debug!("[traverse] Collection...");
|
||||||
|
let folder_contents: String = get_folder_contents(
|
||||||
|
&result.response[current_index].href,
|
||||||
|
config,
|
||||||
|
)
|
||||||
|
.await
|
||||||
|
.unwrap();
|
||||||
|
let mut new_result: Multistatus = from_str(&String::from(folder_contents)).unwrap();
|
||||||
|
debug!("[traverse] Parsed:\n{:?}", new_result);
|
||||||
|
result.response.append(&mut new_result.response);
|
||||||
|
debug!("[traverse] new vector length: {}", &result.response.len());
|
||||||
|
} else {
|
||||||
|
debug!("[traverse] Node...");
|
||||||
|
if !(&mut result.response[current_index].propstat[0].prop.share_types).contains(&ShareType{ share_type: 3 }) {
|
||||||
|
debug!("[traverse] it's not public");
|
||||||
|
let username = config.credentials.username.as_str();
|
||||||
|
let username_seg_string = format!("/{}/", username);
|
||||||
|
let username_seg = username_seg_string.as_str();
|
||||||
|
let index = &result.response[current_index].href.find(username_seg).unwrap_or(0);
|
||||||
|
let new_index = index + username.len() + 2;
|
||||||
|
let new_href = &result.response[current_index].href[new_index..];
|
||||||
|
publicise_it(new_href, config).await.unwrap();
|
||||||
|
} else {
|
||||||
|
debug!("[traverse] it's already public");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
visited_items.insert(href_key, true);
|
||||||
|
debug!("[traverse] visited items: {:?}", visited_items);
|
||||||
|
} else {
|
||||||
|
debug!("[traverse] Already-visited item.");
|
||||||
|
}
|
||||||
|
current_index += 1;
|
||||||
|
}
|
||||||
|
Ok(true)
|
||||||
}
|
}
|
||||||
|
|
||||||
#[tokio::main]
|
#[tokio::main]
|
||||||
async fn main() -> std::io::Result<()> {
|
async fn main() -> std::io::Result<()> {
|
||||||
use yaserde::de::from_str;
|
env_logger::Builder::from_env(Env::default()).init();
|
||||||
|
println!("Publicise it!\n\n");
|
||||||
|
|
||||||
env_logger::Builder::from_env(Env::default().default_filter_or("trace"))
|
let mut config = init().unwrap();
|
||||||
.target(Target::Stdout)
|
if config.credentials.password == None {
|
||||||
.init();
|
let output = Command::new(&config.credentials.password_script.as_ref().unwrap()).output().unwrap();
|
||||||
println!("Publicise it!");
|
if output.stdout.len() == 0 {
|
||||||
let password = get_password().unwrap().trim().to_string();
|
panic!("[main] Failed to acquire password from provided script.");
|
||||||
debug!("Received password: {}[END]", password);
|
}
|
||||||
|
config.credentials.password = Some(String::from_utf8(output.stdout).unwrap());
|
||||||
|
}
|
||||||
|
debug!("[main] {:?}", &config);
|
||||||
|
|
||||||
let folder_contents =
|
let full_path = &(String::from("/remote.php/dav/files/") + &config.credentials.username + "/" + &config.paths.target);
|
||||||
get_folder_contents(password, "/nextcloud/remote.php/dav/files/adam/test_public/2019_test_public")
|
let folder_contents: String =
|
||||||
|
get_folder_contents(full_path, &config)
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
debug!("{:?}", folder_contents);
|
|
||||||
|
|
||||||
let result: Multistatus = from_str(&folder_contents).unwrap();
|
let result: Multistatus = from_str(&folder_contents).unwrap();
|
||||||
println!("{:?}", result);
|
debug!("[main] {:?}", result);
|
||||||
|
let _ = traverse(result, &config).await.unwrap();
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue