Enum TargetRexProgram 

#[non_exhaustive]
#[repr(u16)]
pub enum TargetRexProgram {
    HttpGet {
        url: RexUrl,
        filter: Option<Vec<HttpFilter>>,
        headers: Headers,
    },
    HttpPost {
        url: RexUrl,
        filter: Option<Vec<HttpFilter>>,
        body: RexValue,
        content_type: String,
        headers: Headers,
    },
    Time = 2,
    Number = 3,
    SecretKeyGeneration {
        committee_id: String,
        committee_members: Vec<String>,
    },
    SecretKeyEncryption {
        target_tee_id: String,
        secret_data: Vec<u8>,
        committee_id: String,
    },
    SecretKeyDecryption {
        encrypted_data: Vec<u8>,
        source_committee_id: String,
    },
    WebSocket(WebSocketOperation),
    Wasm {
        bytecode_account: Pubkey,
        input: Vec<RexValue>,
        program_index: Option<u32>,
    },
}

Enum that represents the target REX Program of the REX request.

Discriminant values are fixed to ensure stable serialization across builds with different feature flags.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

HttpGet

HTTP GET request to the REX. The URL is specified in the RexDutyRequest. The URL must be an HTTPS URL. The filter is optional, and if provided, it is used to filter the response.

Fields

url: RexUrl

filter: Option<Vec<HttpFilter>>

headers: Headers

HttpPost

HTTP POST request to the REX. The URL is specified in the RexDutyRequest. The URL must be an HTTPS URL. This REX type is restricted to single-validator assignment to prevent duplicate operations on non-idempotent endpoints.

Fields

url: RexUrl

filter: Option<Vec<HttpFilter>>

body: RexValue

content_type: String

headers: Headers

Time = 2

Get the current time from several NIST servers.

Number = 3

Only used for testing purposes, to simulate an REX that always returns a fixed value. TODO: remove this variant with a cfg testing flag.

SecretKeyGeneration

Generate a shared secret key within a committee of TEEs. The manager TEE generates the key and distributes it to all committee members.

Fields

committee_id: String

committee_members: Vec<String>

SecretKeyEncryption

Encrypt a secret key for a target TEE using their public key. This is used to share keys with TEEs outside the original committee.

Fields

target_tee_id: String

secret_data: Vec<u8>

committee_id: String

SecretKeyDecryption

Decrypt a secret key that was encrypted for this TEE. This is used by TEEs to access keys shared with them.

Fields

encrypted_data: Vec<u8>

source_committee_id: String

WebSocket(WebSocketOperation)

WebSocket REX operations for persistent connections

Wasm

Execute WASM bytecode inside the TEE. The bytecode must be a WASI-compatible component deployed to an on-chain account.

Fields

bytecode_account: Pubkey

Account pubkey containing the deployed WASM component(s)

input: Vec<RexValue>

Per-argument input data for the WASM module. Each entry is one argument, independently Plain (borsh-serialized) or Encrypted (HPKE ciphertext the TEE decrypts). The TEE decrypts each Encrypted entry and concatenates all bytes into a borsh tuple. From CLI: pass base64-encoded bytes (single plain argument).

program_index: Option<u32>

Index into the program table within the account (defaults to 0)

Implementations

impl TargetRexProgram

pub fn websocket_op(&self) -> Option<WebSocketOperation>

Extracts the WebSocket operation if this is a WebSocket target.

pub fn encrypted_payloads(&self) -> Box<dyn Iterator<Item = &[u8]> + '_>

Ciphertext bytes of every field on this program that can carry an encrypted payload: the encrypted URL, body, WebSocket Send message(s), or WASM input(s). Single source of truth for which fields are ciphertext carriers; the version-gated routing (Router::dkg_payload_bytes) and the on-chain ciphertext-match check (encrypted_payload_iter) build on this and additionally require the DKG_PAYLOAD_VERSION byte (a constant that lives above this crate, so it is applied by those callers).

pub fn is_dkg_encrypted(&self) -> bool

True if this program carries any encrypted payload, meaning the duty cannot be served by a direct fetch and must go through the threshold-decryption committee + combine pipeline before any result can exist. Used to size the encrypted duty’s collection window (DutyRequest::inner); does not inspect DKG_PAYLOAD_VERSION — encryption alone is sufficient (and conservative) for that purpose.

impl TargetRexProgram

pub fn is_websocket(&self) -> bool

Returns true if this is a WebSocket operation.

Trait Implementations

impl AsRef<str> for TargetRexProgram

fn as_ref(&self) -> &str

Converts this type into a shared reference of the (usually inferred) input type.

impl Clone for TargetRexProgram

fn clone(&self) -> TargetRexProgram

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TargetRexProgram

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TargetRexProgram

fn deserialize<__D>( __deserializer: __D, ) -> Result<TargetRexProgram, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for TargetRexProgram

impl FromStr for TargetRexProgram

type Err = String

The associated error which can be returned from parsing.

fn from_str( s: &str, ) -> Result<TargetRexProgram, <TargetRexProgram as FromStr>::Err>

Parses a string s to return a value of this type.

impl PartialEq for TargetRexProgram

fn eq(&self, other: &TargetRexProgram) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for TargetRexProgram

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for TargetRexProgram