You've already forked AstralRinth
forked from didirus/AstralRinth
aecsocket
f0224dfff7
* initial elasticsearch impl * working elastic cluster * replace SearchError with ApiError for preparation of search backend * start factoring meili out to trait * move meili to backend * update routes to use search backend trait * wip * Update projects.rs * search backend is only init'd once in config * wip * wip: backend agnostic * change search internal routes to delegate to backend * initial elasticsearch impl * fix filtering * elastic impl * refactor indexing into its own module * clean up elastic code * fix ci * fix tests * fix elastic health check * fix up env rebase * fix compile * dummy commit to update github pr * Fix rebase * Elastic basic https auth * Fix duplicate projects showing up * Fix up tests * Replace search `ApiErrors` with `eyre::Reports`, propagate background task errors * clean up agents files * make index chunk size configurable * make `match_phrase` in elastic case-insensitive * use current/next indices and swap between them * test case for error body * Fix failing case * da merge * factor out common stuff from search backends * allow fetching hit metadata from search results * allow customising elasticsearch search config * bit of docs * add mappings to indices for elastic * Implement Typesense * wip * fix up some sort fields stuff * use different approach to filterable field sets * remove a bunch of search fields which weren't used for filtering * bucket text matches * Bucketing by text_match for typesense * fix tombi lint * fix some sentry errors and dont prioritise 2+ term matches * tweak ts query settings * expose some more search settings * query sort changes * small fixes * should fix pagination stuff * fix healthcheck maybe * ragebait ci * tests * tests * revert environment
68 lines
2.0 KiB
Rust
68 lines
2.0 KiB
Rust
use crate::env::ENV;
|
|
use crate::queue::email::EmailQueue;
|
|
use crate::util::anrok;
|
|
use crate::util::gotenberg::GotenbergClient;
|
|
use crate::{LabrinthConfig, file_hosting};
|
|
use crate::{clickhouse, env};
|
|
use std::sync::Arc;
|
|
|
|
pub mod api_common;
|
|
pub mod api_v2;
|
|
pub mod api_v3;
|
|
pub mod asserts;
|
|
pub mod database;
|
|
pub mod db;
|
|
pub mod dummy_data;
|
|
pub mod environment;
|
|
pub mod pats;
|
|
pub mod permissions;
|
|
pub mod scopes;
|
|
pub mod search;
|
|
|
|
// Testing equivalent to 'setup' function, producing a LabrinthConfig
|
|
// If making a test, you should probably use environment::TestEnvironment::build() (which calls this)
|
|
pub async fn setup(db: &database::TemporaryDatabase) -> LabrinthConfig {
|
|
println!("Setting up labrinth config");
|
|
env::init().expect("failed to initialize environment variables");
|
|
|
|
let _ = rustls::crypto::aws_lc_rs::default_provider().install_default();
|
|
|
|
let pool = db.pool.clone();
|
|
let ro_pool = db.ro_pool.clone();
|
|
let redis_pool = db.redis_pool.clone();
|
|
let search_backend = db.search_backend.clone();
|
|
let file_host: Arc<dyn file_hosting::FileHost + Send + Sync> =
|
|
Arc::new(file_hosting::MockHost::new());
|
|
let mut clickhouse = clickhouse::init_client().await.unwrap();
|
|
|
|
let stripe_client = stripe::Client::new(ENV.STRIPE_API_KEY.clone());
|
|
|
|
let anrok_client = anrok::Client::from_env().unwrap();
|
|
let email_queue =
|
|
EmailQueue::init(pool.clone(), redis_pool.clone()).unwrap();
|
|
let gotenberg_client = GotenbergClient::from_env(redis_pool.clone())
|
|
.expect("Failed to create Gotenberg client");
|
|
|
|
crate::app_setup(
|
|
pool.clone(),
|
|
ro_pool.clone(),
|
|
redis_pool.clone(),
|
|
search_backend.into(),
|
|
&mut clickhouse,
|
|
file_host.clone(),
|
|
stripe_client,
|
|
anrok_client,
|
|
email_queue,
|
|
gotenberg_client,
|
|
false,
|
|
)
|
|
}
|
|
|
|
pub fn get_json_val_str(val: impl serde::Serialize) -> String {
|
|
serde_json::to_value(val)
|
|
.unwrap()
|
|
.as_str()
|
|
.unwrap()
|
|
.to_string()
|
|
}
|