Function state_write_durable 

pub fn state_write_durable<S, R, E>(
    storage: &S,
    operation: impl FnOnce(&mut StateTx<'_, <S as XmtpMlsStorageProvider>::TxQuery>) -> Result<TransactionOutcome<R>, E>,
) -> Result<TransactionOutcome<R>, E>
where
    S: XmtpMlsStorageProvider,
    E: From<Error> + From<ConnectionError> + Error,

Sync the write before returning queued work or publishing it.