opendal/services/seafile/
lister.rs

1// Licensed to the Apache Software Foundation (ASF) under one
2// or more contributor license agreements.  See the NOTICE file
3// distributed with this work for additional information
4// regarding copyright ownership.  The ASF licenses this file
5// to you under the Apache License, Version 2.0 (the
6// "License"); you may not use this file except in compliance
7// with the License.  You may obtain a copy of the License at
8//
9//   http://www.apache.org/licenses/LICENSE-2.0
10//
11// Unless required by applicable law or agreed to in writing,
12// software distributed under the License is distributed on an
13// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
14// KIND, either express or implied.  See the License for the
15// specific language governing permissions and limitations
16// under the License.
17
18use std::sync::Arc;
19
20use bytes::Buf;
21use http::header;
22use http::Request;
23use http::StatusCode;
24use serde::Deserialize;
25
26use super::core::SeafileCore;
27use super::error::parse_error;
28use crate::raw::oio::Entry;
29use crate::raw::*;
30use crate::*;
31
32pub struct SeafileLister {
33    core: Arc<SeafileCore>,
34
35    path: String,
36}
37
38impl SeafileLister {
39    pub(super) fn new(core: Arc<SeafileCore>, path: &str) -> Self {
40        SeafileLister {
41            core,
42            path: path.to_string(),
43        }
44    }
45}
46
47impl oio::PageList for SeafileLister {
48    async fn next_page(&self, ctx: &mut oio::PageContext) -> Result<()> {
49        let path = build_rooted_abs_path(&self.core.root, &self.path);
50
51        let auth_info = self.core.get_auth_info().await?;
52
53        let url = format!(
54            "{}/api2/repos/{}/dir/?p={}",
55            self.core.endpoint,
56            auth_info.repo_id,
57            percent_encode_path(&path)
58        );
59
60        let req = Request::get(url);
61
62        let req = req
63            .header(header::AUTHORIZATION, format!("Token {}", auth_info.token))
64            .body(Buffer::new())
65            .map_err(new_request_build_error)?;
66
67        let resp = self.core.send(req).await?;
68
69        let status = resp.status();
70
71        match status {
72            StatusCode::OK => {
73                let resp_body = resp.into_body();
74                let infos: Vec<Info> = serde_json::from_reader(resp_body.reader())
75                    .map_err(new_json_deserialize_error)?;
76
77                // add path itself
78                ctx.entries.push_back(Entry::new(
79                    self.path.as_str(),
80                    Metadata::new(EntryMode::DIR),
81                ));
82
83                for info in infos {
84                    if !info.name.is_empty() {
85                        let rel_path =
86                            build_rel_path(&self.core.root, &format!("{}{}", path, info.name));
87
88                        let entry = if info.type_field == "file" {
89                            let meta = Metadata::new(EntryMode::FILE)
90                                .with_last_modified(parse_datetime_from_from_timestamp(info.mtime)?)
91                                .with_content_length(info.size.unwrap_or(0));
92                            Entry::new(&rel_path, meta)
93                        } else {
94                            let path = format!("{}/", rel_path);
95                            Entry::new(&path, Metadata::new(EntryMode::DIR))
96                        };
97
98                        ctx.entries.push_back(entry);
99                    }
100                }
101
102                ctx.done = true;
103
104                Ok(())
105            }
106            // return nothing when not exist
107            StatusCode::NOT_FOUND => {
108                ctx.done = true;
109                Ok(())
110            }
111            _ => Err(parse_error(resp)),
112        }
113    }
114}
115
116#[derive(Debug, Deserialize)]
117struct Info {
118    #[serde(rename = "type")]
119    pub type_field: String,
120    pub mtime: i64,
121    pub size: Option<u64>,
122    pub name: String,
123}
opendal/services/seafile/lister.rs

opendal/services/seafile/
lister.rs
