Send a typed control command

Send one annotatr-control-v1 operation. The command is a list with operation (one of at_control_capabilities()$operations), payload (a list) and expected_revision (the state_revision the command is based on). request_id and idempotency_key are generated when absent and content_sha256 is always computed from the canonical payload. A stale revision raises an at_conflict_error (REVISION_CONFLICT); re-sending the same command with the same idempotency key returns the original result (replayed = TRUE in the response) instead of applying it twice.

Usage

at_control_command(handle, command, call = rlang::caller_env())

Arguments

handle

An at_control_handle.

command

A list with operation, payload, expected_revision and optionally request_id, idempotency_key and extensions.

call

The calling environment, for error reporting.

Value

The response data (a list) with the response envelope in attr(, "response").

See also

at_control_request_status()

Other control: at_control_capabilities(), at_control_close(), at_control_connect(), at_control_events(), at_control_request_status(), at_control_start(), at_control_state(), at_control_stop()

Examples

h <- at_control_start(at_example_session(3), serve = FALSE)
st <- at_control_state(h)
at_control_command(h, list(operation = "context.goto", payload = list(queue_index = 2),
                           expected_revision = st$state_revision))
#> $queue_index
#> [1] 2
#> 
#> $entry_id
#> [1] "entry-0002"
#> 
#> $image_id
#> [1] "sha256:3fa00078c93c3a7d"
#> 
#> $annotation_revision
#> [1] "sha256:77f4c6171f87df36369045976bf6354c68d0041f4b136ac99fd91ab2e1100246"
#> 
#> attr(,"response")
#> attr(,"response")$protocol
#> [1] "annotatr-control-v1"
#> 
#> attr(,"response")$protocol_version
#> [1] "1.0"
#> 
#> attr(,"response")$request_id
#> [1] "request-f3c4ba73-0248-4616-ac86-8528521f5975"
#> 
#> attr(,"response")$instance_id
#> [1] "instance-72c8f4fe-55c6-4ef1-8a80-02a3b391f95d"
#> 
#> attr(,"response")$state_revision
#> [1] "1"
#> 
#> attr(,"response")$event_cursor
#> [1] "instance-72c8f4fe-55c6-4ef1-8a80-02a3b391f95d:2"
#> 
#> attr(,"response")$warnings
#> list()
#> 
at_control_stop(h)