diff --git a/zero.Core/FileStorage/FileSystemException.cs b/zero.Core/FileStorage/FileSystemException.cs
new file mode 100644
index 00000000..fc9d39b0
--- /dev/null
+++ b/zero.Core/FileStorage/FileSystemException.cs
@@ -0,0 +1,10 @@
+namespace zero.FileStorage;
+
+public class FileSystemException : Exception
+{
+  public FileSystemException() { }
+ 
+  public FileSystemException(string message) : base(message) { }
+
+  public FileSystemException(string message, Exception innerException) : base(message, innerException) { }
+}
\ No newline at end of file
diff --git a/zero.Core/FileStorage/IFileMeta.cs b/zero.Core/FileStorage/IFileMeta.cs
new file mode 100644
index 00000000..48edc66c
--- /dev/null
+++ b/zero.Core/FileStorage/IFileMeta.cs
@@ -0,0 +1,39 @@
+namespace zero.FileStorage;
+
+public interface IFileInfo
+{
+  /// <summary>
+  /// Full path of the item within the file system
+  /// </summary>
+  string Path { get; }
+
+  /// <summary>
+  /// Name of the item
+  /// </summary>
+  string Name { get; }
+
+  /// <summary>
+  /// Full path to the directory containing the item
+  /// </summary>
+  string DirectoryPath { get; }
+
+  /// <summary>
+  /// Length of the file in bytes
+  /// </summary>
+  long Length { get; }
+
+  /// <summary>
+  /// Date when the item was last modified
+  /// </summary>
+  DateTimeOffset LastModifiedDate { get; }
+
+  /// <summary>
+  /// Whether this item is directory or a file
+  /// </summary>
+  bool IsDirectory { get; }
+
+  /// <summary>
+  /// Additional properties
+  /// </summary>
+  Dictionary<string, object> Properties { get; }
+}
diff --git a/zero.Core/FileStorage/IFileSystem.cs b/zero.Core/FileStorage/IFileSystem.cs
new file mode 100644
index 00000000..6d34bcc5
--- /dev/null
+++ b/zero.Core/FileStorage/IFileSystem.cs
@@ -0,0 +1,56 @@
+using System.IO;
+
+namespace zero.FileStorage;
+
+public interface IFileSystem
+{
+  /// <summary>
+  /// Get information of a file
+  /// </summary>
+  Task<IFileMeta> GetFileInfo(string path, CancellationToken cancellationToken = default);
+
+  /// <summary>
+  /// Returns a readable stream for a file
+  /// </summary>
+  Task<Stream> StreamFile(string path, CancellationToken cancellationToken = default);
+
+  /// <summary>
+  /// Creates a file at the given path
+  /// </summary>
+  Task CreateFile(string path, Stream fileStream, bool overwrite = false, CancellationToken cancellationToken = default);
+
+  /// <summary>
+  /// Deletes a file at the given path. This method returns if the file does not exist.
+  /// </summary>
+  Task DeleteFile(string path, CancellationToken cancellationToken = default);
+
+  /// <summary>
+  /// Moves a file to another path (can also be used to rename resources)
+  /// </summary>
+  Task MoveFile(string oldPath, string newPath, CancellationToken cancellationToken = default);
+
+  /// <summary>
+  /// Copies a file to another path
+  /// </summary>
+  Task CopyFile(string oldPath, string newPath, CancellationToken cancellationToken = default);
+
+  /// <summary>
+  /// Get information of a directory
+  /// </summary>
+  Task<IFileMeta> GetDirectoryInfo(string path, CancellationToken cancellationToken = default);
+
+  /// <summary>
+  /// Get all items within a directory
+  /// </summary>
+  IAsyncEnumerable<IFileMeta> GetDirectoryContent(string path = null, bool recursive = false, CancellationToken cancellationToken = default);
+
+  /// <summary>
+  /// Tries to create a directory at the given path. This method returns if the directory already exists.
+  /// </summary>
+  Task CreateDirectory(string path, CancellationToken cancellationToken = default);
+
+  /// <summary>
+  /// Deletes a directory at the given path. This method returns if the directory does not exist.
+  /// </summary>
+  Task DeleteDirectory(string path, bool recursive = false, CancellationToken cancellationToken = default);
+}
\ No newline at end of file
diff --git a/zero.Core/FileStorage/PhysicalFileMeta.cs b/zero.Core/FileStorage/PhysicalFileMeta.cs
new file mode 100644
index 00000000..13aa767f
--- /dev/null
+++ b/zero.Core/FileStorage/PhysicalFileMeta.cs
@@ -0,0 +1,39 @@
+using Microsoft.Extensions.FileProviders;
+
+namespace zero.FileStorage;
+
+public class PhysicalFileMeta : IFileMeta
+{
+  /// <inheritdoc />
+  public string Path { get; }
+
+  /// <inheritdoc />
+  public string Name { get; }
+
+  /// <inheritdoc />
+  public string DirectoryPath { get; }
+
+  /// <inheritdoc />
+  public long Length { get; }
+
+  /// <inheritdoc />
+  public DateTimeOffset LastModifiedDate { get; }
+
+  /// <inheritdoc />
+  public bool IsDirectory { get; }
+
+  /// <inheritdoc />
+  public Dictionary<string, object> Properties { get; }
+
+
+  public PhysicalFileMeta(IFileInfo fileInfo, string path)
+  {
+    Path = path;
+    Name = fileInfo.Name;
+    DirectoryPath = path.Substring(0, path.Length - fileInfo.Name.Length).TrimEnd('/');
+    LastModifiedDate = fileInfo.LastModified;
+    Length = fileInfo.Length;
+    IsDirectory = fileInfo.IsDirectory;
+    Properties = new();
+  }
+}
\ No newline at end of file
diff --git a/zero.Core/FileStorage/PhysicalFileSystem.cs b/zero.Core/FileStorage/PhysicalFileSystem.cs
new file mode 100644
index 00000000..8ef5d01a
--- /dev/null
+++ b/zero.Core/FileStorage/PhysicalFileSystem.cs
@@ -0,0 +1,275 @@
+using Microsoft.Extensions.FileProviders.Physical;
+using System.IO;
+
+namespace zero.FileStorage;
+
+public class PhysicalFileSystem : IFileSystem
+{
+  readonly string basePath;
+
+
+  public PhysicalFileSystem(string basePath)
+  {
+    this.basePath = basePath;
+  }
+
+
+  /// <inheritdoc />
+  public Task<IFileMeta> GetFileInfo(string path, CancellationToken cancellationToken = default)
+  {
+    try
+    {
+      string resolvedPath = ResolvePath(path);
+
+      PhysicalFileInfo fileInfo = new(new FileInfo(resolvedPath));
+
+      if (!fileInfo.Exists)
+      {
+        return Task.FromResult<IFileMeta>(default);
+      }
+
+      return Task.FromResult<IFileMeta>(new PhysicalFileMeta(fileInfo, path));
+    }
+    catch (Exception ex) when (ex is not FileSystemException)
+    {
+      throw new FileSystemException($"Could not get file info for path '{path}'", ex);
+    }
+  }
+
+
+  /// <inheritdoc />
+  public Task<Stream> StreamFile(string path, CancellationToken cancellationToken = default)
+  {
+    try
+    {
+      string resolvedPath = ResolvePath(path);
+
+      if (resolvedPath.IsNullOrEmpty() || !File.Exists(resolvedPath))
+      {
+        throw new FileSystemException($"The path '{path}' does not exist in the file system");
+      }
+
+      return Task.FromResult<Stream>(File.OpenRead(resolvedPath));
+    }
+    catch (Exception ex) when (ex is not FileSystemException)
+    {
+      throw new FileSystemException($"Could not get file stream for path '{path}'", ex);
+    }
+  }
+
+
+  /// <inheritdoc />
+  public async Task CreateFile(string path, Stream fileStream, bool overwrite = false, CancellationToken cancellationToken = default)
+  {
+    try
+    {
+      string resolvedPath = ResolvePath(path);
+
+      if ((!overwrite && File.Exists(resolvedPath)) || Directory.Exists(resolvedPath))
+      {
+        throw new FileSystemException($"A file/directory at the path '{path}' already existsin the file system");
+      }
+
+      string directoryPath = Path.GetDirectoryName(resolvedPath);
+      Directory.CreateDirectory(directoryPath);
+
+      FileInfo fileInfo = new(resolvedPath);
+      using var outputStream = fileInfo.Create();
+      await fileStream.CopyToAsync(outputStream, cancellationToken);
+    }
+    catch (Exception ex) when (ex is not FileSystemException)
+    {
+      throw new FileSystemException($"Could not get file stream for path '{path}'", ex);
+    }
+  }
+
+
+  /// <inheritdoc />
+  public Task DeleteFile(string path, CancellationToken cancellationToken = default)
+  {
+    try
+    {
+      string resolvedPath = ResolvePath(path);
+      File.Delete(resolvedPath);
+      return Task.CompletedTask;
+    }
+    catch (Exception ex) when (ex is not FileSystemException)
+    {
+      throw new FileSystemException($"Could not delete file for path '{path}'", ex);
+    }
+  }
+
+
+  /// <inheritdoc />
+  public Task MoveFile(string oldPath, string newPath, CancellationToken cancellationToken = default)
+  {
+    try
+    {
+      string resolvedOldPath = ResolvePath(oldPath);
+      string resolvedNewPath = ResolvePath(newPath);
+
+      if (!File.Exists(resolvedOldPath))
+      {
+        throw new FileSystemException($"The path '{oldPath}' does not exist in the file system");
+      }
+
+      if (File.Exists(resolvedNewPath) || Directory.Exists(resolvedNewPath))
+      {
+        throw new FileSystemException($"A file/directory at the path '{newPath}' already exists in the file system");
+      }
+
+      File.Move(resolvedOldPath, resolvedNewPath);
+      return Task.CompletedTask;
+    }
+    catch (Exception ex) when (ex is not FileSystemException)
+    {
+      throw new FileSystemException($"Could not move file from path '{oldPath}' to '{newPath}'", ex);
+    }
+  }
+
+
+  /// <inheritdoc />
+  public Task CopyFile(string oldPath, string newPath, CancellationToken cancellationToken = default)
+  {
+    try
+    {
+      string resolvedOldPath = ResolvePath(oldPath);
+      string resolvedNewPath = ResolvePath(newPath);
+
+      if (!File.Exists(resolvedOldPath))
+      {
+        throw new FileSystemException($"The path '{oldPath}' does not exist in the file system");
+      }
+
+      if (File.Exists(resolvedNewPath) || Directory.Exists(resolvedNewPath))
+      {
+        throw new FileSystemException($"A file/directory at the path '{newPath}' already exists in the file system");
+      }
+
+      File.Copy(resolvedOldPath, resolvedNewPath);
+      return Task.CompletedTask;
+    }
+    catch (Exception ex) when (ex is not FileSystemException)
+    {
+      throw new FileSystemException($"Could not copy file from path '{oldPath}' to '{newPath}'", ex);
+    }
+  }
+
+
+  /// <inheritdoc />
+  public Task<IFileMeta> GetDirectoryInfo(string path, CancellationToken cancellationToken = default) => GetFileInfo(path, cancellationToken);
+
+
+  /// <inheritdoc />
+  public IAsyncEnumerable<IFileMeta> GetDirectoryContent(string path = null, bool recursive = false, CancellationToken cancellationToken = default)
+  {
+    try
+    {
+      string resolvedPath = ResolvePath(path);
+      List<IFileMeta> results = new();
+      SearchOption searchOption = recursive ? SearchOption.AllDirectories : SearchOption.TopDirectoryOnly;
+
+      if (!Directory.Exists(resolvedPath))
+      {
+        return results.ToAsyncEnumerable();
+      }
+
+      results.AddRange(Directory.GetDirectories(resolvedPath, "*", searchOption).Select(f =>
+      {
+        PhysicalDirectoryInfo fileSystemInfo = new(new DirectoryInfo(f));
+        return new PhysicalFileMeta(fileSystemInfo, ResolvePath(f.Substring(basePath.Length)));
+      }));
+
+      results.AddRange(Directory.GetFiles(resolvedPath, "*", searchOption).Select(f =>
+      {
+        PhysicalFileInfo fileSystemInfo = new(new FileInfo(f));
+        return new PhysicalFileMeta(fileSystemInfo, ResolvePath(f.Substring(basePath.Length)));
+      }));
+
+      return results.ToAsyncEnumerable();
+    }
+    catch (Exception ex) when (ex is not FileSystemException)
+    {
+      throw new FileSystemException($"Could not get directory content for path '{path}'", ex);
+    }
+  }
+
+
+  /// <inheritdoc />
+  public Task CreateDirectory(string path, CancellationToken cancellationToken = default)
+  {
+    try
+    {
+      string resolvedPath = ResolvePath(path);
+
+      if (File.Exists(resolvedPath))
+      {
+        throw new FileSystemException($"A file at the path '{path}' already exists in the file system");
+      }
+
+      if (!Directory.Exists(resolvedPath))
+      {
+        Directory.CreateDirectory(resolvedPath);
+      }
+
+      return Task.CompletedTask;
+    }
+    catch (Exception ex) when (ex is not FileSystemException)
+    {
+      throw new FileSystemException($"Could not create directory at path '{path}'", ex);
+    }
+  }
+
+
+  /// <inheritdoc />
+  public Task DeleteDirectory(string path, bool recursive = false, CancellationToken cancellationToken = default)
+  {
+    try
+    {
+      string resolvedPath = ResolvePath(path);
+      Directory.Delete(resolvedPath, recursive);
+      return Task.CompletedTask;
+    }
+    catch (Exception ex) when (ex is not FileSystemException)
+    {
+      throw new FileSystemException($"Could not delete directory at path '{path}'", ex);
+    }
+  }
+
+
+  /// <summary>
+  /// Creates a fully-usable absolte path from the given path
+  /// </summary>
+  protected string ResolvePath(string path)
+  {
+    try
+    {
+      if (path.IsNullOrWhiteSpace())
+      {
+        return basePath;
+      }
+
+      // normalize path
+      path = path.Replace('\\', '/').FullTrim().Trim('/');
+
+      string physicalPath = Path.Combine(basePath, path);
+
+      // do not allow paths which are outside this file system
+      // the boundaries are set be the basePath which is assigned in the file system constructor
+      if (!Path.GetFullPath(physicalPath).StartsWith(basePath, StringComparison.InvariantCultureIgnoreCase))
+      {
+        throw new FileSystemException($"The path '{path}' is outside the file system");
+      }
+
+      return physicalPath;
+    }
+    catch (FileSystemException)
+    {
+      throw;
+    }
+    catch (Exception ex)
+    {
+      throw new FileSystemException($"Could not resolve path '{path}'", ex);
+    }
+  }
+}