Encode database label file names using URL encoding (optionally)

Cargo.toml

@@ -34,6 +34,8 @@ base64 = "0.13"
 hex = "0.4"
 regex = "1.5"
 lru = "0.10"
+urlencoding = "2.1.2"
+dyn-clone = "1.0.11"
 
 [dev-dependencies]
 tempfile = "3.1"

benches/bench.rs

@@ -4,12 +4,13 @@ extern crate test;
 use tempfile::tempdir;
 use terminus_store;
 use terminus_store::layer::ValueTriple;
+use terminus_store::storage::directory::NoFilenameEncoding;
 use test::Bencher;
 
 #[bench]
 fn bench_add_string_triple(b: &mut Bencher) {
     let dir = tempdir().unwrap();
-    let sync_store = terminus_store::open_sync_directory_store(dir.path());
+    let sync_store = terminus_store::open_sync_directory_store(dir.path(), NoFilenameEncoding);
     let layer_builder = sync_store.create_base_layer().unwrap();
     let mut count = 1;
     b.iter(|| {

benches/builder/main.rs

@@ -5,14 +5,15 @@ mod data;
 use rand::prelude::*;
 use tempfile::tempdir;
 use terminus_store;
+use terminus_store::storage::directory::NoFilenameEncoding;
 use test::Bencher;
 
 use data::*;
 
 #[bench]
 fn build_empty_base_layer(b: &mut Bencher) {
     let dir = tempdir().unwrap();
-    let store = terminus_store::open_sync_directory_store(dir.path());
+    let store = terminus_store::open_sync_directory_store(dir.path(), NoFilenameEncoding);
 
     b.iter(|| {
         let builder = store.create_base_layer().unwrap();
@@ -23,7 +24,7 @@ fn build_empty_base_layer(b: &mut Bencher) {
 #[bench]
 fn build_base_layer_1000(b: &mut Bencher) {
     let dir = tempdir().unwrap();
-    let store = terminus_store::open_sync_directory_store(dir.path());
+    let store = terminus_store::open_sync_directory_store(dir.path(), NoFilenameEncoding);
 
     let seed = b"the quick brown fox jumped over ";
     let rand = StdRng::from_seed(*seed);
@@ -48,7 +49,7 @@ fn build_base_layer_1000(b: &mut Bencher) {
 #[bench]
 fn build_empty_child_layer_on_empty_base_layer(b: &mut Bencher) {
     let dir = tempdir().unwrap();
-    let store = terminus_store::open_sync_directory_store(dir.path());
+    let store = terminus_store::open_sync_directory_store(dir.path(), NoFilenameEncoding);
     let builder = store.create_base_layer().unwrap();
     let base_layer = builder.commit().unwrap();
 
@@ -61,7 +62,7 @@ fn build_empty_child_layer_on_empty_base_layer(b: &mut Bencher) {
 #[bench]
 fn build_nonempty_child_layer_on_empty_base_layer(b: &mut Bencher) {
     let dir = tempdir().unwrap();
-    let store = terminus_store::open_sync_directory_store(dir.path());
+    let store = terminus_store::open_sync_directory_store(dir.path(), NoFilenameEncoding);
     let builder = store.create_base_layer().unwrap();
     let base_layer = builder.commit().unwrap();
 
@@ -88,7 +89,7 @@ fn build_nonempty_child_layer_on_empty_base_layer(b: &mut Bencher) {
 #[bench]
 fn build_nonempty_child_layer_on_nonempty_base_layer(b: &mut Bencher) {
     let dir = tempdir().unwrap();
-    let store = terminus_store::open_sync_directory_store(dir.path());
+    let store = terminus_store::open_sync_directory_store(dir.path(), NoFilenameEncoding);
 
     let seed = b"the quick brown fox jumped over ";
     let rand = StdRng::from_seed(*seed);

examples/create_graph.rs

@@ -1,5 +1,6 @@
 use std::env;
 
+use terminus_store::storage::directory::NoFilenameEncoding;
 use terminus_store::*;
 use tokio;
 
@@ -10,7 +11,7 @@ async fn main() {
         println!("usage: {} <path> <graph_name>", args[0]);
     } else {
         // open a store at the given path. the directory has to exist.
-        let store = open_directory_store(&args[1]);
+        let store = open_directory_store(&args[1], NoFilenameEncoding);
 
         // then create a graph. if the graph already exists, this will error.
         store.create(&args[2]).await.unwrap();

examples/print_graph.rs

@@ -1,12 +1,13 @@
 use std::env;
 
 use std::io;
+use terminus_store::storage::directory::NoFilenameEncoding;
 use terminus_store::structure::TdbDataType;
 use terminus_store::*;
 use tokio;
 
 async fn print_graph(store_path: &str, graph: &str) -> io::Result<()> {
-    let store = open_directory_store(store_path);
+    let store = open_directory_store(store_path, NoFilenameEncoding);
     let graph = store
         .open(graph)
         .await?

examples/write_to_graph.rs

@@ -2,6 +2,7 @@ use std::env;
 
 use lazy_static::lazy_static;
 use regex::Regex;
+use terminus_store::storage::directory::NoFilenameEncoding;
 use terminus_store::*;
 use tokio;
 use tokio::io::{self, AsyncBufReadExt};
@@ -52,7 +53,7 @@ async fn parse_command(s: &str) -> io::Result<Command> {
 }
 
 async fn process_commands(store_path: &str, graph: &str) -> io::Result<()> {
-    let store = open_directory_store(store_path);
+    let store = open_directory_store(store_path, NoFilenameEncoding);
     let graph = store
         .open(graph)
         .await?