A lexicon-driven AppView for ATProto.
happyview.dev
backfill
firehose
jetstream
atproto
appview
oauth
lexicon
chore: fix formatting
+6
-9
+6
-9
src/admin/dead_letters.rs
+6
-9
src/admin/dead_letters.rs
···
488
488
}
489
489
490
490
/// Fetch the index_hook script directly from the lexicons table, bypassing the in-memory registry.
491
-
async fn get_index_hook_from_db(state: &AppState, lexicon_id: &str) -> Result<Option<String>, AppError> {
491
+
async fn get_index_hook_from_db(
492
+
state: &AppState,
493
+
lexicon_id: &str,
494
+
) -> Result<Option<String>, AppError> {
492
495
let backend = state.db_backend;
493
-
let sql = adapt_sql(
494
-
"SELECT index_hook FROM lexicons WHERE id = ?",
495
-
backend,
496
-
);
496
+
let sql = adapt_sql("SELECT index_hook FROM lexicons WHERE id = ?", backend);
497
497
let row: Option<(Option<String>,)> = sqlx::query_as(&sql)
498
498
.bind(lexicon_id)
499
499
.fetch_optional(&state.db)
···
509
509
let script = get_index_hook_from_db(state, &dl.lexicon_id)
510
510
.await?
511
511
.ok_or_else(|| {
512
-
AppError::NotFound(format!(
513
-
"no index hook found for lexicon {}",
514
-
dl.lexicon_id
515
-
))
512
+
AppError::NotFound(format!("no index hook found for lexicon {}", dl.lexicon_id))
516
513
})?;
517
514
518
515
let record: Option<Value> = dl