[WIP] Video uploads

Aleksbgbg · Mar 1, 2024 · 9ebe1b9 · 9ebe1b9
1 parent 7d596fc
commit 9ebe1b9
Show file tree

Hide file tree

Showing 13 changed files with 519 additions and 9 deletions.
diff --git a/backend-rs/.env.toml b/backend-rs/.env.toml
@@ -1,5 +1,6 @@
 [config.app]
 config_root = "streamfox_home_local/config"
+data_root = "streamfox_home_local/data"
 host = [0, 0, 0, 0]
 port = 8601
 # Half a year, in seconds

diff --git a/backend-rs/Cargo.lock b/backend-rs/Cargo.lock
diff --git a/backend-rs/Cargo.toml b/backend-rs/Cargo.toml
@@ -1,3 +1,16 @@
 [workspace]
 resolver = "2"
 members = ["streamfox", "migration", "entity", "fs", "fs-file"]
+
+[profile.release]
+opt-level = 3
+debug = "full"
+# split-debuginfo = '...'  # Platform-specific.
+strip = "none"
+debug-assertions = false
+overflow-checks = false
+lto = "fat"
+panic = "unwind"
+incremental = true
+codegen-units = 16
+rpath = false
diff --git a/backend-rs/entity/src/id.rs b/backend-rs/entity/src/id.rs
@@ -49,6 +49,12 @@ impl Display for Id {
   }
 }
 
+impl From<Id> for String {
+  fn from(value: Id) -> Self {
+    value.to_string()
+  }
+}
+
 impl FromStr for Id {
   type Err = bs58::decode::Error;
 

diff --git a/backend-rs/entity/src/video.rs b/backend-rs/entity/src/video.rs
@@ -2,7 +2,9 @@ use crate::id::Id;
 use sea_orm::entity::prelude::*;
 use serde::{Deserialize, Serialize};
 
-#[derive(Clone, Debug, PartialEq, Eq, EnumIter, DeriveActiveEnum, Serialize, Deserialize)]
+#[derive(
+  Clone, Debug, PartialEq, Eq, PartialOrd, EnumIter, DeriveActiveEnum, Serialize, Deserialize,
+)]
 #[sea_orm(rs_type = "i16", db_type = "SmallInteger")]
 #[serde(untagged)]
 pub enum Status {

diff --git a/backend-rs/fs-file/src/lib.rs b/backend-rs/fs-file/src/lib.rs
@@ -1,5 +1,5 @@
 use std::path::{Path, PathBuf};
-use tokio::fs::{self, File as TokioFile};
+use tokio::fs::{self, File as TokioFile, OpenOptions};
 
 #[derive(Debug)]
 pub struct File {
@@ -24,4 +24,12 @@ impl File {
 
     TokioFile::create(&self.path).await
   }
+
+  pub async fn open(&self) -> std::io::Result<TokioFile> {
+    if self.path.exists() {
+      OpenOptions::new().append(true).open(&self.path).await
+    } else {
+      self.create().await
+    }
+  }
 }
diff --git a/backend-rs/streamfox/Cargo.toml b/backend-rs/streamfox/Cargo.toml
@@ -6,6 +6,7 @@ edition = "2021"
 [dependencies]
 axum = "0.7.4"
 axum-extra = { version = "0.9.2", features = ["cookie"] }
+axum-range = { version = "0.4.0", default-features = false }
 base64 = "0.21.7"
 bcrypt = "0.15.0"
 bs58 = { version = "0.5.0", default-features = false }
@@ -15,6 +16,7 @@ convert_case = "0.6.0"
 entity = { version = "0.0.0", path = "../entity", default-features = false }
 fs = { version = "0.0.0", path = "../fs", default-features = false }
 fs-file = { version = "0.0.0", path = "../fs-file", default-features = false }
+futures = { version = "0.3.30", default-features = false }
 jsonwebtoken = { version = "9.2.0", default-features = false }
 lazy_static = "1.4.0"
 migration = { version = "0.0.0", path = "../migration", default-features = false }
@@ -23,11 +25,13 @@ ring = "0.17.7"
 sea-orm = { version = "0.12.14", features = ["runtime-tokio-rustls", "sqlx-postgres", "debug-print"] }
 sea-orm-migration = { version = "0.12.14", default-features = false }
 serde = { version = "1.0.196", features = ["derive"] }
+serde-this-or-that = { version = "0.4.2", default-features = false }
 serde_json = "1.0.113"
 serde_with = { version = "3.6.0", features = ["chrono_0_4"] }
 thiserror = "1.0.56"
 time = "0.3.34"
-tokio = { version = "1.36.0", features = ["rt-multi-thread"] }
+tokio = { version = "1.36.0", features = ["rt-multi-thread", "process"] }
+tokio-util = { version = "0.7.10", default-features = false, features = ["io"] }
 toml-env = "1.1.1"
 tower-http = { version = "0.5.1", features = ["trace"] }
 tracing = "0.1.40"