Disable URL-encoding on file paths (#1892)
This commit is contained in:
parent
453d368e69
commit
357a5320ef
1 changed files with 23 additions and 12 deletions
|
@ -5,6 +5,7 @@ use crate::api::conn::Param;
|
|||
use crate::api::conn::Route;
|
||||
use crate::api::conn::Router;
|
||||
use crate::api::engine::local::Db;
|
||||
use crate::api::err::Error;
|
||||
use crate::api::opt::Endpoint;
|
||||
use crate::api::ExtraFeatures;
|
||||
use crate::api::Result;
|
||||
|
@ -87,12 +88,21 @@ pub(crate) fn router(
|
|||
tokio::spawn(async move {
|
||||
let url = address.endpoint;
|
||||
|
||||
let kvs = {
|
||||
let path = match url.scheme() {
|
||||
"mem" => "memory",
|
||||
_ => url.as_str(),
|
||||
"mem" => "memory".to_owned(),
|
||||
"fdb" | "rocksdb" | "file" => match url.to_file_path() {
|
||||
Ok(path) => format!("{}://{}", url.scheme(), path.display()),
|
||||
Err(_) => {
|
||||
let error = Error::InvalidUrl(url.as_str().to_owned());
|
||||
let _ = conn_tx.into_send_async(Err(error.into())).await;
|
||||
return;
|
||||
}
|
||||
},
|
||||
_ => url.as_str().to_owned(),
|
||||
};
|
||||
|
||||
let kvs = match Datastore::new(path).await {
|
||||
match Datastore::new(&path).await {
|
||||
Ok(kvs) => {
|
||||
let _ = conn_tx.into_send_async(Ok(())).await;
|
||||
kvs
|
||||
|
@ -101,6 +111,7 @@ pub(crate) fn router(
|
|||
let _ = conn_tx.into_send_async(Err(error.into())).await;
|
||||
return;
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
let mut session = Session::for_kv();
|
||||
|
|
Loading…
Reference in a new issue