Function push_restore

nodedb/tests/sql_backup_restore_wire.rs:41–61

(
    server: &TestServer,
    tenant: u64,
    bytes: Vec<u8>,
    dry_run: bool,
)

}

async fn push_restore(
    server: &TestServer,
    tenant: u64,
    bytes: Vec<u8>,
    dry_run: bool,
) -> Result<(), String> {
    use futures::SinkExt;

    let suffix = if dry_run { " DRY RUN" } else { "" };
    let sink = server
        .client
        .copy_in::<_, Bytes>(&format!("COPY tenant_restore({tenant}) FROM STDIN{suffix}"))
        .await
        .map_err(detail)?;
    let mut sink = Box::pin(sink);
    sink.as_mut()
        .send(Bytes::from(bytes))
        .await
        .map_err(detail)?;
    sink.as_mut().finish().await.map(|_| ()).map_err(detail)
}

/// Extract the server-side error detail from a tokio_postgres error.
/// `e.to_string()` returns "db error"; the actual message lives on