use std::fmt::Debug;
use std::sync::Arc;
use bytes::Buf;
use bytes::Bytes;
use chrono::Utc;
use http::Request;
use http::Response;
use http::StatusCode;
use serde_json::json;
use super::core::GdriveCore;
use super::core::GdriveFile;
use super::delete::GdriveDeleter;
use super::error::parse_error;
use super::lister::GdriveLister;
use super::writer::GdriveWriter;
use crate::raw::*;
use crate::*;
#[derive(Clone, Debug)]
pub struct GdriveBackend {
pub core: Arc<GdriveCore>,
}
impl Access for GdriveBackend {
type Reader = HttpBody;
type Writer = oio::OneShotWriter<GdriveWriter>;
type Lister = oio::PageLister<GdriveLister>;
type Deleter = oio::OneShotDeleter<GdriveDeleter>;
type BlockingReader = ();
type BlockingWriter = ();
type BlockingLister = ();
type BlockingDeleter = ();
fn info(&self) -> Arc<AccessorInfo> {
self.core.info.clone()
}
async fn create_dir(&self, path: &str, _args: OpCreateDir) -> Result<RpCreateDir> {
let path = build_abs_path(&self.core.root, path);
let _ = self.core.path_cache.ensure_dir(&path).await?;
Ok(RpCreateDir::default())
}
async fn stat(&self, path: &str, _args: OpStat) -> Result<RpStat> {
let resp = self.core.gdrive_stat(path).await?;
if resp.status() != StatusCode::OK {
return Err(parse_error(resp));
}
let bs = resp.into_body();
let gdrive_file: GdriveFile =
serde_json::from_reader(bs.reader()).map_err(new_json_deserialize_error)?;
let file_type = if gdrive_file.mime_type == "application/vnd.google-apps.folder" {
EntryMode::DIR
} else {
EntryMode::FILE
};
let mut meta = Metadata::new(file_type).with_content_type(gdrive_file.mime_type);
if let Some(v) = gdrive_file.size {
meta = meta.with_content_length(v.parse::<u64>().map_err(|e| {
Error::new(ErrorKind::Unexpected, "parse content length").set_source(e)
})?);
}
if let Some(v) = gdrive_file.modified_time {
meta = meta.with_last_modified(v.parse::<chrono::DateTime<Utc>>().map_err(|e| {
Error::new(ErrorKind::Unexpected, "parse last modified time").set_source(e)
})?);
}
Ok(RpStat::new(meta))
}
async fn read(&self, path: &str, args: OpRead) -> Result<(RpRead, Self::Reader)> {
let resp = self.core.gdrive_get(path, args.range()).await?;
let status = resp.status();
match status {
StatusCode::OK | StatusCode::PARTIAL_CONTENT => Ok((RpRead::new(), resp.into_body())),
_ => {
let (part, mut body) = resp.into_parts();
let buf = body.to_buffer().await?;
Err(parse_error(Response::from_parts(part, buf)))
}
}
}
async fn write(&self, path: &str, _: OpWrite) -> Result<(RpWrite, Self::Writer)> {
let path = build_abs_path(&self.core.root, path);
let file_id = self.core.path_cache.get(&path).await?;
Ok((
RpWrite::default(),
oio::OneShotWriter::new(GdriveWriter::new(self.core.clone(), path, file_id)),
))
}
async fn delete(&self) -> Result<(RpDelete, Self::Deleter)> {
Ok((
RpDelete::default(),
oio::OneShotDeleter::new(GdriveDeleter::new(self.core.clone())),
))
}
async fn list(&self, path: &str, _args: OpList) -> Result<(RpList, Self::Lister)> {
let path = build_abs_path(&self.core.root, path);
let l = GdriveLister::new(path, self.core.clone());
Ok((RpList::default(), oio::PageLister::new(l)))
}
async fn copy(&self, from: &str, to: &str, _args: OpCopy) -> Result<RpCopy> {
let from = build_abs_path(&self.core.root, from);
let from_file_id = self.core.path_cache.get(&from).await?.ok_or(Error::new(
ErrorKind::NotFound,
"the file to copy does not exist",
))?;
let to_name = get_basename(to);
let to_path = build_abs_path(&self.core.root, to);
let to_parent_id = self
.core
.path_cache
.ensure_dir(get_parent(&to_path))
.await?;
if let Some(id) = self.core.path_cache.get(&to_path).await? {
let resp = self.core.gdrive_trash(&id).await?;
let status = resp.status();
if status != StatusCode::OK {
return Err(parse_error(resp));
}
self.core.path_cache.remove(&to_path).await;
}
let url = format!(
"https://www.googleapis.com/drive/v3/files/{}/copy",
from_file_id
);
let request_body = &json!({
"name": to_name,
"parents": [to_parent_id],
});
let body = Buffer::from(Bytes::from(request_body.to_string()));
let mut req = Request::post(&url)
.body(body)
.map_err(new_request_build_error)?;
self.core.sign(&mut req).await?;
let resp = self.core.client.send(req).await?;
match resp.status() {
StatusCode::OK => Ok(RpCopy::default()),
_ => Err(parse_error(resp)),
}
}
async fn rename(&self, from: &str, to: &str, _args: OpRename) -> Result<RpRename> {
let source = build_abs_path(&self.core.root, from);
let target = build_abs_path(&self.core.root, to);
if let Some(id) = self.core.path_cache.get(&target).await? {
let resp = self.core.gdrive_trash(&id).await?;
let status = resp.status();
if status != StatusCode::OK {
return Err(parse_error(resp));
}
self.core.path_cache.remove(&target).await;
}
let resp = self
.core
.gdrive_patch_metadata_request(&source, &target)
.await?;
let status = resp.status();
match status {
StatusCode::OK => {
let body = resp.into_body();
let meta: GdriveFile =
serde_json::from_reader(body.reader()).map_err(new_json_deserialize_error)?;
let cache = &self.core.path_cache;
cache.remove(&build_abs_path(&self.core.root, from)).await;
cache
.insert(&build_abs_path(&self.core.root, to), &meta.id)
.await;
Ok(RpRename::default())
}
_ => Err(parse_error(resp)),
}
}
}