Struct AppTestServer 

pub struct AppTestServer { /* private fields */ }

Implementations

impl AppTestServer

pub fn new(app_schema: AppSchema) -> Self

pub fn with_options( app_schema: AppSchema, options: AppTestServerOptions, ) -> Self

pub fn seed_row(&self, table: &str, row: Value) -> Result<Value>

pub fn set_schema_versions( &self, required_schema_version: Option<i32>, latest_schema_version: Option<i32>, )

pub fn require_schema_version(&self, schema_version: i32)

pub fn require_authorization(&self, authorization: impl Into<String>)

pub fn clear_required_authorization(&self)

pub fn revoke_subscription(&self, subscription_id: impl Into<String>)

pub fn restore_subscription(&self, subscription_id: &str)

pub fn revoked_subscription_ids(&self) -> Vec<String>

pub fn commit_row(&self, table: &str, row: Value) -> Result<i64>

pub fn delete_row(&self, table: &str, row_id: &str) -> Result<i64>

pub fn rows(&self, table: &str) -> Vec<Value>

pub fn row(&self, table: &str, row_id: &str) -> Option<Value>

pub fn requests(&self) -> Vec<CombinedRequest>

pub fn ws_pushes(&self) -> Vec<PushCommitRequest>

pub fn commits(&self) -> Vec<AppTestServerCommit>

pub fn auth_headers(&self) -> Vec<SyncAuthHeaders>

pub fn record_auth_headers(&self, headers: SyncAuthHeaders)

pub fn is_authorized_headers(&self, headers: &SyncAuthHeaders) -> bool

pub fn closed_realtime_count(&self) -> usize

pub fn push_realtime_sync(&self)

pub fn wait_for_commit_count( &self, expected: usize, timeout: Duration, ) -> Vec<AppTestServerCommit>

Trait Implementations

impl BlobTransport for AppTestServer

fn upload_blob(&self, blob: &BlobRef, bytes: &[u8]) -> Result<()>

fn download_blob(&self, blob: &BlobRef) -> Result<Vec<u8>>

fn upload_blob_file( &self, blob: &BlobRef, path: &Path, ) -> Result<(), SyncularError>

fn download_blob_to_file( &self, blob: &BlobRef, path: &Path, ) -> Result<(), SyncularError>

impl Clone for AppTestServer

fn clone(&self) -> AppTestServer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl SyncAuthHeaderStore for AppTestServer

fn set_auth_headers(&mut self, headers: SyncAuthHeaders)

impl SyncTransport for AppTestServer

type Realtime = AppTestRealtime

fn post_sync(&self, request: &CombinedRequest) -> Result<CombinedResponse>

fn fetch_snapshot_chunk_rows( &self, _chunk: &SnapshotChunkRef, _scopes: &Map<String, Value>, ) -> Result<SnapshotChunkRows>

fn connect_realtime(&self) -> Result<Self::Realtime>

fn fetch_snapshot_artifact_bytes( &self, _artifact: &ScopedSnapshotArtifactRef, _scopes: &Map<String, Value>, ) -> Result<Vec<u8>, SyncularError>