Function drain_backup

nodedb/tests/sql_backup_restore_wire.rs:26–39

(server: &TestServer, tenant: u64)

const TENANT: u64 = 1;

async fn drain_backup(server: &TestServer, tenant: u64) -> Result<Vec<u8>, String> {
    let stream = server
        .client
        .copy_out(&format!("COPY (BACKUP TENANT {tenant}) TO STDOUT"))
        .await
        .map_err(|e| format!("copy_out failed: {e}"))?;
    let mut bytes = Vec::new();
    let mut s = Box::pin(stream);
    while let Some(chunk) = s.next().await {
        let c = chunk.map_err(|e| format!("copy_out chunk: {e}"))?;
        bytes.extend_from_slice(&c);
    }
    Ok(bytes)
}

async fn push_restore(
    server: &TestServer,