pub async fn insert_source_context( pool: &DbPool, source_type: &str, config_json: &str, ) -> Result<i64, StorageError>
Insert a new source context and return its ID.