1 files changed, 127 insertions, 0 deletions
diff --git a/src/fuse/fs.rs b/src/fuse/fs.rs
new file mode 100644
index 0000000..4cf3282
--- /dev/null
+++ b/src/fuse/fs.rs
@@ -0,0 +1,127 @@
+use async_trait::async_trait;
+use nix::errno::Errno;
+
+use std::{
+    num::NonZeroUsize,
+    ops::{Deref, DerefMut},
+    sync::Arc,
+};
+
+use crate::{Ino, TimeToLive};
+
+use super::{
+    io::{Attrs, EntryType},
+    ops::*,
+    Done, Op, Reply,
+};
+
+#[async_trait]
+pub trait Fuse: Sized + Send + Sync + 'static {
+    type Inode: Inode<Fuse = Self> + ?Sized;
+    type Farc: Deref<Target = Self::Inode> + Clone + Send + Sync = Arc<Self::Inode>;
+
+    async fn init<'o>(&self, reply: Reply<'o, Self, Init>) -> Done<'o>;
+
+    async fn statfs<'o>(&self, (_, reply, _): Op<'o, Self, Statfs>) -> Done<'o> {
+        reply.not_implemented()
+    }
+
+    fn request_buffers(&self) -> NonZeroUsize {
+        NonZeroUsize::new(16).unwrap()
+    }
+
+    fn request_buffer_pages(&self) -> NonZeroUsize {
+        NonZeroUsize::new(4).unwrap()
+    }
+}
+
+#[async_trait]
+pub trait Inode: Send + Sync {
+    type Fuse: Fuse<Inode = Self>;
+
+    fn ino(self: &FarcTo<Self>) -> Ino;
+    fn attrs(self: &FarcTo<Self>) -> (Attrs, TimeToLive);
+    fn inode_type(self: &FarcTo<Self>) -> EntryType;
+
+    fn direct_io<'o>(self: &FarcTo<Self>) -> bool {
+        false
+    }
+
+    fn access<'o>(self: &FarcTo<Self>, (_, reply, _): Op<'o, Self::Fuse, Access>) -> Done<'o> {
+        reply.not_implemented()
+    }
+
+    async fn lookup<'o>(self: FarcTo<Self>, (_, reply, _): Op<'o, Self::Fuse, Lookup>) -> Done<'o> {
+        reply.not_implemented()
+    }
+
+    async fn readlink<'o>(
+        self: FarcTo<Self>,
+        (_, reply, _): Op<'o, Self::Fuse, Readlink>,
+    ) -> Done<'o> {
+        reply.not_implemented()
+    }
+
+    async fn open<'o>(self: FarcTo<Self>, (_, reply, _): Op<'o, Self::Fuse, Open>) -> Done<'o> {
+        // Calling not_implemented() here would ignore direct_io() and similar flags
+        reply.ok()
+    }
+
+    async fn opendir<'o>(
+        self: FarcTo<Self>,
+        (_, reply, _): Op<'o, Self::Fuse, Opendir>,
+    ) -> Done<'o> {
+        reply.not_implemented()
+    }
+
+    async fn readdir<'o>(
+        self: FarcTo<Self>,
+        (_, reply, _): Op<'o, Self::Fuse, Readdir>,
+    ) -> Done<'o> {
+        reply.not_implemented()
+    }
+}
+
+#[async_trait]
+pub trait Tape: Send + Sync {
+    type Fuse: Fuse;
+
+    async fn seek(self: &mut Head<Self>, offset: u64) -> Result<(), Errno>;
+
+    async fn rewind(self: &mut Head<Self>) -> Result<(), Errno> {
+        self.seek(0).await
+    }
+
+    async fn read<'o>(self: &mut Head<Self>, (_, reply, _): Op<'o, Self::Fuse, Read>) -> Done<'o> {
+        reply.not_implemented()
+    }
+
+    async fn write<'o>(
+        self: &mut Head<Self>,
+        (_, reply, _): Op<'o, Self::Fuse, Write>,
+    ) -> Done<'o> {
+        reply.not_implemented()
+    }
+}
+
+pub type FarcTo<I> = <<I as Inode>::Fuse as Fuse>::Farc;
+
+pub struct Head<T: Tape + ?Sized> {
+    offset: u64,
+    inode: <T::Fuse as Fuse>::Farc,
+    tape: T,
+}
+
+impl<T: Tape + ?Sized> Deref for Head<T> {
+    type Target = T;
+
+    fn deref(&self) -> &Self::Target {
+        &self.tape
+    }
+}
+
+impl<T: Tape + ?Sized> DerefMut for Head<T> {
+    fn deref_mut(&mut self) -> &mut Self::Target {
+        &mut self.tape
+    }
+}