chore: bit of cleanup

concurrent-repos
Jef Roosens 2024-05-27 13:47:53 +02:00
parent bf100049b1
commit 32e27978ec
Signed by: Jef Roosens
GPG Key ID: B75D4F293C7052DB
5 changed files with 7 additions and 26 deletions

View File

@ -1,4 +1,4 @@
use crate::repo::{MetaRepoMgr, RepoGroupManager};
use crate::repo::MetaRepoMgr;
use crate::{Config, Global};
use axum::extract::FromRef;
@ -82,7 +82,6 @@ impl Cli {
let config = Config {
data_dir: self.data_dir.clone(),
api_key: self.api_key.clone(),
};
let repo_manager = MetaRepoMgr::new(&self.data_dir.join("repos"));

View File

@ -9,7 +9,10 @@ pub struct Filter {
impl IntoCondition for Filter {
fn into_condition(self) -> Condition {
Condition::all().add_option(self.name.map(|name| package::Column::Name.like(name)))
Condition::all().add_option(
self.name
.map(|name| repo::Column::Name.like(format!("%{}%", name))),
)
}
}

View File

@ -7,7 +7,6 @@ mod repo;
use clap::Parser;
pub use error::{Result, ServerError};
use repo::MetaRepoMgr;
use repo::RepoGroupManager;
use std::path::PathBuf;
use std::sync::Arc;
use tokio::sync::RwLock;
@ -15,7 +14,6 @@ use tokio::sync::RwLock;
#[derive(Clone)]
pub struct Config {
data_dir: PathBuf,
api_key: String,
}
#[derive(Clone)]

View File

@ -1,17 +1,10 @@
use std::io::{self, Write};
use std::io;
use std::path::{Path, PathBuf};
use std::sync::{Arc, Mutex};
use tokio::sync::{mpsc, oneshot};
use libarchive::write::{Builder, FileWriter, WriteEntry};
use libarchive::{Entry, WriteFilter, WriteFormat};
enum Message {
AppendFilesEntry(oneshot::Sender<io::Result<()>>, String),
AppendLine(oneshot::Sender<io::Result<()>>, String),
Close(oneshot::Sender<io::Result<()>>),
}
/// Struct to abstract away the intrinsics of writing entries to an archive file
pub struct RepoArchiveWriter {
ar: Arc<Mutex<FileWriter>>,

View File

@ -3,13 +3,9 @@ mod manager;
mod manager_new;
pub mod package;
pub use manager::RepoGroupManager;
pub use manager_new::MetaRepoMgr;
use tokio_util::io::StreamReader;
use std::path::PathBuf;
use crate::db;
use axum::body::Body;
use axum::extract::{Path, State};
use axum::http::Request;
@ -18,17 +14,9 @@ use axum::response::IntoResponse;
use axum::routing::{delete, post};
use axum::Router;
use futures::TryStreamExt;
use futures::{Stream, StreamExt};
use regex::Regex;
use sea_orm::ModelTrait;
use std::sync::Arc;
use tokio::{fs, io::AsyncWriteExt};
use tower::util::ServiceExt;
use tower_http::services::{ServeDir, ServeFile};
use tower_http::services::ServeFile;
use tower_http::validate_request::ValidateRequestHeaderLayer;
use uuid::Uuid;
const DB_FILE_EXTS: [&str; 4] = [".db", ".files", ".db.tar.gz", ".files.tar.gz"];
pub fn router(api_key: &str) -> Router<crate::Global> {
Router::new()