diff --git a/services/blob/src/main.rs b/services/blob/src/main.rs
--- a/services/blob/src/main.rs
+++ b/services/blob/src/main.rs
@@ -4,6 +4,7 @@
 pub mod grpc;
 pub mod http;
 pub mod s3;
+pub mod service;
 pub mod tools;
 
 use anyhow::Result;
diff --git a/services/blob/src/service.rs b/services/blob/src/service.rs
new file mode 100644
--- /dev/null
+++ b/services/blob/src/service.rs
@@ -0,0 +1,77 @@
+#![allow(unused)]
+use std::ops::RangeInclusive;
+use std::sync::Arc;
+
+use async_stream::try_stream;
+use chrono::Duration;
+use tokio_stream::StreamExt;
+use tonic::codegen::futures_core::Stream;
+use tracing::{debug, error, trace, warn};
+
+use crate::constants::S3_MULTIPART_UPLOAD_MINIMUM_CHUNK_SIZE;
+use crate::database::types::{
+  BlobItemInput, BlobItemRow, PrimaryKey, UncheckedKind,
+};
+use crate::database::DBError;
+use crate::s3::{Error as S3Error, S3Client, S3Path};
+use crate::tools::{BoxedError, MemOps};
+use crate::{constants::BLOB_DOWNLOAD_CHUNK_SIZE, database::DatabaseClient};
+
+#[derive(
+  Debug, derive_more::Display, derive_more::From, derive_more::Error,
+)]
+pub enum BlobServiceError {
+  BlobNotFound,
+  BlobAlreadyExists,
+  InvalidState,
+  DB(DBError),
+  S3(S3Error),
+  InputError(#[error(ignore)] BoxedError),
+}
+
+type BlobServiceResult<T> = Result<T, BlobServiceError>;
+
+#[derive(Clone, Debug)]
+pub struct BlobServiceConfig {
+  /// Blob data is streamed from S3 in chunks of this size.
+  pub download_chunk_size: usize,
+  /// If enabled, orphaned blobs will be deleted immediately after
+  /// last holder is removed. This option should be enabled
+  /// if maintenance garbage collection tasks are not run.
+  pub instant_delete_orphaned_blobs: bool,
+  /// Minimum age that a orphan must stay unmodified
+  /// before it can be deleted by a garbage collection task
+  /// This option is ignored if `instant_delete_orphaned_blobs` is `true`
+  pub orphan_protection_period: chrono::Duration,
+}
+
+impl Default for BlobServiceConfig {
+  fn default() -> Self {
+    BlobServiceConfig {
+      download_chunk_size: BLOB_DOWNLOAD_CHUNK_SIZE as usize,
+      instant_delete_orphaned_blobs: false,
+      orphan_protection_period: Duration::hours(1),
+    }
+  }
+}
+
+#[derive(Clone)]
+pub struct BlobService {
+  db: Arc<DatabaseClient>,
+  s3: S3Client,
+  config: BlobServiceConfig,
+}
+
+impl BlobService {
+  pub fn new(
+    db: DatabaseClient,
+    s3: S3Client,
+    config: BlobServiceConfig,
+  ) -> Self {
+    Self {
+      db: Arc::new(db),
+      s3,
+      config,
+    }
+  }
+}
diff --git a/services/blob/src/tools.rs b/services/blob/src/tools.rs
--- a/services/blob/src/tools.rs
+++ b/services/blob/src/tools.rs
@@ -1,5 +1,6 @@
+use std::{env, error::Error as StdError};
+
 use crate::constants;
-use std::env;
 
 fn is_env_flag_set(env_var_name: &str) -> bool {
   let flag_value = env::var(env_var_name).unwrap_or_default().to_lowercase();
@@ -11,6 +12,7 @@
   return is_env_flag_set(constants::SANDBOX_ENV_VAR);
 }
 
+pub type BoxedError = Box<dyn StdError>;
 pub trait MemOps {
   fn take_out(&mut self) -> Self;
 }