Method append

atomic-cli/src/commands/agent/owner.rs:288–327

(
        &self,
        reservation: JournalTurnReservation,
        envelopes: Vec<ProvenanceJournalEnvelope>,
        now: i64,
    )

    }

    fn append(
        &self,
        reservation: JournalTurnReservation,
        envelopes: Vec<ProvenanceJournalEnvelope>,
        now: i64,
    ) -> Result<Vec<JournalAppendAck>, String> {
        let repository = self.repository.clone();
        let envelopes = envelopes
            .into_iter()
            .map(|envelope| {
                Ok(WireEnvelope {
                    event_id: envelope.event_id.clone(),
                    bytes: envelope.to_json_bytes()?,
                })
            })
            .collect::<Result<Vec<_>, atomic_agent::ProvenanceJournalError>>()
            .map_err(|error| error.to_string())?;
        run_outside_async_runtime(move || {
            let mut acknowledgements = Vec::new();
            for chunk in chunk_wire_envelopes(envelopes) {
                let response = request_with_reconnect(
                    &repository,
                    OwnerRequest::AppendProvenanceEnvelopes {
                        provenance_id: reservation.provenance_id,
                        expected_generation: reservation.generation,
                        envelopes: chunk,
                        now,
                    },
                )?;
                match response {
                    OwnerResponse::ProvenanceEnvelopesCommitted {
                        acknowledgements: acks,
                    } => acknowledgements.extend(acks),
                    other => return Err(unexpected_response("append provenance", other)),
                }
            }
            Ok(acknowledgements)
        })
        .map_err(|error| error.to_string())
    }

    fn prepare_checkpoint(
        &self,