lash-remote-protocol 0.1.0-alpha.52

impl From<lash_core::SessionScope> for RemoteSessionScope {
    fn from(value: lash_core::SessionScope) -> Self {
        let lash_core::SessionScope {
            session_id,
            agent_frame_id,
        } = value;
        Self {
            session_id,
            agent_frame_id,
        }
    }
}

impl From<RemoteSessionScope> for lash_core::SessionScope {
    fn from(value: RemoteSessionScope) -> Self {
        let RemoteSessionScope {
            session_id,
            agent_frame_id,
        } = value;
        Self {
            session_id,
            agent_frame_id,
        }
    }
}

impl From<lash_core::ProcessOriginator> for RemoteProcessOriginator {
    fn from(value: lash_core::ProcessOriginator) -> Self {
        match value {
            lash_core::ProcessOriginator::Host => Self::Host,
            lash_core::ProcessOriginator::Session { scope } => Self::Session {
                scope: scope.into(),
            },
        }
    }
}

impl From<RemoteProcessOriginator> for lash_core::ProcessOriginator {
    fn from(value: RemoteProcessOriginator) -> Self {
        match value {
            RemoteProcessOriginator::Host => Self::Host,
            RemoteProcessOriginator::Session { scope } => Self::Session {
                scope: scope.into(),
            },
        }
    }
}

impl From<lash_core::ProcessProvenance> for RemoteProcessProvenance {
    fn from(value: lash_core::ProcessProvenance) -> Self {
        let lash_core::ProcessProvenance {
            originator,
            host_profile_id,
            caused_by,
        } = value;
        Self {
            originator: originator.into(),
            host_profile_id,
            caused_by: caused_by.map(Into::into),
        }
    }
}

impl From<RemoteProcessProvenance> for lash_core::ProcessProvenance {
    fn from(value: RemoteProcessProvenance) -> Self {
        let RemoteProcessProvenance {
            originator,
            host_profile_id,
            caused_by,
        } = value;
        Self {
            originator: originator.into(),
            host_profile_id,
            caused_by: caused_by.map(Into::into),
        }
    }
}

impl From<lash_core::ProcessDefinitionSummary> for RemoteProcessDefinitionSummary {
    fn from(value: lash_core::ProcessDefinitionSummary) -> Self {
        let lash_core::ProcessDefinitionSummary { name } = value;
        Self { name }
    }
}

impl From<RemoteProcessDefinitionSummary> for lash_core::ProcessDefinitionSummary {
    fn from(value: RemoteProcessDefinitionSummary) -> Self {
        let RemoteProcessDefinitionSummary { name } = value;
        Self { name }
    }
}

impl From<lash_core::ProcessDefinitionSelector> for RemoteProcessDefinitionIdentity {
    fn from(value: lash_core::ProcessDefinitionSelector) -> Self {
        Self {
            module_ref: value.module_ref().as_str().to_string(),
            host_requirements_ref: value.host_requirements_ref().as_str().to_string(),
            process_ref: value.process_ref().clone().into(),
            process_name: value.process_name().to_string(),
        }
    }
}

impl TryFrom<RemoteProcessDefinitionIdentity> for lash_core::ProcessDefinitionSelector {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessDefinitionIdentity) -> Result<Self, Self::Error> {
        value.validate("RemoteProcessDefinitionIdentity")?;
        let RemoteProcessDefinitionIdentity {
            module_ref,
            host_requirements_ref,
            process_ref,
            process_name,
        } = value;
        Ok(lash_core::ProcessDefinitionSelector::new(
            decode_remote_lashlang_ref(
                module_ref,
                "RemoteProcessDefinitionIdentity",
                "module_ref",
            )?,
            decode_remote_lashlang_ref(
                host_requirements_ref,
                "RemoteProcessDefinitionIdentity",
                "host_requirements_ref",
            )?,
            process_ref.into(),
            process_name,
        ))
    }
}

impl From<lash_core::ProcessHandleDescriptor> for RemoteProcessHandleDescriptor {
    fn from(value: lash_core::ProcessHandleDescriptor) -> Self {
        let lash_core::ProcessHandleDescriptor { kind, label } = value;
        Self { kind, label }
    }
}

impl From<RemoteProcessHandleDescriptor> for lash_core::ProcessHandleDescriptor {
    fn from(value: RemoteProcessHandleDescriptor) -> Self {
        let RemoteProcessHandleDescriptor { kind, label } = value;
        Self { kind, label }
    }
}

impl From<lash_core::ProcessStartGrant> for RemoteProcessStartGrant {
    fn from(value: lash_core::ProcessStartGrant) -> Self {
        let lash_core::ProcessStartGrant {
            session_scope,
            descriptor,
        } = value;
        Self {
            session_scope: session_scope.into(),
            descriptor: descriptor.into(),
        }
    }
}

impl From<RemoteProcessStartGrant> for lash_core::ProcessStartGrant {
    fn from(value: RemoteProcessStartGrant) -> Self {
        let RemoteProcessStartGrant {
            session_scope,
            descriptor,
        } = value;
        Self {
            session_scope: session_scope.into(),
            descriptor: descriptor.into(),
        }
    }
}

impl From<lash_core::ProcessLifecycleStatus> for RemoteProcessLifecycleStatus {
    fn from(value: lash_core::ProcessLifecycleStatus) -> Self {
        match value {
            lash_core::ProcessLifecycleStatus::Running => Self::Running,
            lash_core::ProcessLifecycleStatus::Completed => Self::Completed,
            lash_core::ProcessLifecycleStatus::Failed => Self::Failed,
            lash_core::ProcessLifecycleStatus::Cancelled => Self::Cancelled,
        }
    }
}

impl From<RemoteProcessLifecycleStatus> for lash_core::ProcessLifecycleStatus {
    fn from(value: RemoteProcessLifecycleStatus) -> Self {
        match value {
            RemoteProcessLifecycleStatus::Running => Self::Running,
            RemoteProcessLifecycleStatus::Completed => Self::Completed,
            RemoteProcessLifecycleStatus::Failed => Self::Failed,
            RemoteProcessLifecycleStatus::Cancelled => Self::Cancelled,
        }
    }
}

impl From<lash_core::ToolFailureClass> for RemoteToolFailureClass {
    fn from(value: lash_core::ToolFailureClass) -> Self {
        match value {
            lash_core::ToolFailureClass::InvalidRequest => Self::InvalidRequest,
            lash_core::ToolFailureClass::Unavailable => Self::Unavailable,
            lash_core::ToolFailureClass::PermissionDenied => Self::PermissionDenied,
            lash_core::ToolFailureClass::Timeout => Self::Timeout,
            lash_core::ToolFailureClass::Execution => Self::Execution,
            lash_core::ToolFailureClass::External => Self::External,
            lash_core::ToolFailureClass::ResourceLimit => Self::ResourceLimit,
            lash_core::ToolFailureClass::Internal => Self::Internal,
        }
    }
}

impl From<RemoteToolFailureClass> for lash_core::ToolFailureClass {
    fn from(value: RemoteToolFailureClass) -> Self {
        match value {
            RemoteToolFailureClass::InvalidRequest => Self::InvalidRequest,
            RemoteToolFailureClass::Unavailable => Self::Unavailable,
            RemoteToolFailureClass::PermissionDenied => Self::PermissionDenied,
            RemoteToolFailureClass::Timeout => Self::Timeout,
            RemoteToolFailureClass::Execution => Self::Execution,
            RemoteToolFailureClass::External => Self::External,
            RemoteToolFailureClass::ResourceLimit => Self::ResourceLimit,
            RemoteToolFailureClass::Internal => Self::Internal,
        }
    }
}

impl From<lash_core::ProcessAwaitOutput> for RemoteProcessAwaitOutput {
    fn from(value: lash_core::ProcessAwaitOutput) -> Self {
        match value {
            lash_core::ProcessAwaitOutput::Success { value, control } => Self::Success {
                value,
                control: control.map(|control| {
                    serde_json::to_value(control).expect("tool control serializes")
                }),
            },
            lash_core::ProcessAwaitOutput::Failure {
                class,
                code,
                message,
                raw,
                control,
            } => Self::Failure {
                class: class.into(),
                code,
                message,
                raw,
                control: control.map(|control| {
                    serde_json::to_value(control).expect("tool control serializes")
                }),
            },
            lash_core::ProcessAwaitOutput::Cancelled {
                message,
                raw,
                control,
            } => Self::Cancelled {
                message,
                raw,
                control: control.map(|control| {
                    serde_json::to_value(control).expect("tool control serializes")
                }),
            },
        }
    }
}

impl TryFrom<RemoteProcessAwaitOutput> for lash_core::ProcessAwaitOutput {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessAwaitOutput) -> Result<Self, Self::Error> {
        value.validate("RemoteProcessAwaitOutput")?;
        match value {
            RemoteProcessAwaitOutput::Success { value, control } => Ok(Self::Success {
                value,
                control: decode_remote_tool_control(control, "RemoteProcessAwaitOutput")?,
            }),
            RemoteProcessAwaitOutput::Failure {
                class,
                code,
                message,
                raw,
                control,
            } => Ok(Self::Failure {
                class: class.into(),
                code,
                message,
                raw,
                control: decode_remote_tool_control(control, "RemoteProcessAwaitOutput")?,
            }),
            RemoteProcessAwaitOutput::Cancelled {
                message,
                raw,
                control,
            } => Ok(Self::Cancelled {
                message,
                raw,
                control: decode_remote_tool_control(control, "RemoteProcessAwaitOutput")?,
            }),
        }
    }
}

fn decode_remote_tool_control(
    value: Option<serde_json::Value>,
    type_name: &'static str,
) -> Result<Option<lash_core::ToolControl>, RemoteProtocolError> {
    value
        .map(|value| decode_remote_json(value, type_name, "control"))
        .transpose()
}

impl From<lash_core::ProcessStatus> for RemoteProcessStatus {
    fn from(value: lash_core::ProcessStatus) -> Self {
        match value {
            lash_core::ProcessStatus::Running => Self::Running,
            lash_core::ProcessStatus::Completed { await_output } => Self::Completed {
                await_output: await_output.into(),
            },
            lash_core::ProcessStatus::Failed { await_output } => Self::Failed {
                await_output: await_output.into(),
            },
            lash_core::ProcessStatus::Cancelled { await_output } => Self::Cancelled {
                await_output: await_output.into(),
            },
        }
    }
}

impl TryFrom<RemoteProcessStatus> for lash_core::ProcessStatus {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessStatus) -> Result<Self, Self::Error> {
        match value {
            RemoteProcessStatus::Running => Ok(Self::Running),
            RemoteProcessStatus::Completed { await_output } => Ok(Self::Completed {
                await_output: await_output.try_into()?,
            }),
            RemoteProcessStatus::Failed { await_output } => Ok(Self::Failed {
                await_output: await_output.try_into()?,
            }),
            RemoteProcessStatus::Cancelled { await_output } => Ok(Self::Cancelled {
                await_output: await_output.try_into()?,
            }),
        }
    }
}

impl From<lash_core::ProcessExternalRef> for RemoteProcessExternalRef {
    fn from(value: lash_core::ProcessExternalRef) -> Self {
        let lash_core::ProcessExternalRef {
            backend,
            id,
            metadata,
        } = value;
        Self {
            backend,
            id,
            metadata,
        }
    }
}

impl From<RemoteProcessExternalRef> for lash_core::ProcessExternalRef {
    fn from(value: RemoteProcessExternalRef) -> Self {
        let RemoteProcessExternalRef {
            backend,
            id,
            metadata,
        } = value;
        Self {
            backend,
            id,
            metadata,
        }
    }
}

impl From<lash_core::WaitState> for RemoteProcessWaitState {
    fn from(value: lash_core::WaitState) -> Self {
        let lash_core::WaitState { kind, since_ms } = value;
        Self {
            kind: kind.into(),
            since_ms,
        }
    }
}

impl From<RemoteProcessWaitState> for lash_core::WaitState {
    fn from(value: RemoteProcessWaitState) -> Self {
        let RemoteProcessWaitState { kind, since_ms } = value;
        Self {
            kind: kind.into(),
            since_ms,
        }
    }
}

impl From<lash_core::WaitKind> for RemoteProcessWaitKind {
    fn from(value: lash_core::WaitKind) -> Self {
        match value {
            lash_core::WaitKind::Signal {
                name,
                event_type,
                key,
                ordinal,
            } => Self::Signal {
                name,
                event_type,
                key,
                ordinal,
            },
        }
    }
}

impl From<RemoteProcessWaitKind> for lash_core::WaitKind {
    fn from(value: RemoteProcessWaitKind) -> Self {
        match value {
            RemoteProcessWaitKind::Signal {
                name,
                event_type,
                key,
                ordinal,
            } => Self::Signal {
                name,
                event_type,
                key,
                ordinal,
            },
        }
    }
}

impl TryFrom<lash_core::ProcessInput> for RemoteProcessInput {
    type Error = RemoteProtocolError;

    fn try_from(value: lash_core::ProcessInput) -> Result<Self, Self::Error> {
        match value {
            lash_core::ProcessInput::ToolCall { call } => Ok(Self::ToolCall {
                prepared_tool_call: serde_json::to_value(call).map_err(|err| {
                    RemoteProtocolError::InvalidEnvelope {
                        type_name: "RemoteProcessInput",
                        message: format!("invalid prepared tool call: {err}"),
                    }
                })?,
            }),
            lash_core::ProcessInput::LashlangProcess {
                module_ref,
                process_ref,
                host_requirements_ref,
                process_name,
                args,
            } => Ok(Self::LashlangProcess {
                module_ref: module_ref.as_str().to_string(),
                process_ref: process_ref.into(),
                host_requirements_ref: host_requirements_ref.as_str().to_string(),
                process_name,
                args,
            }),
            lash_core::ProcessInput::SessionTurn {
                create_request,
                turn_input,
                output_contract,
            } => Ok(Self::SessionTurn {
                create_request: serde_json::to_value(create_request.as_ref()).map_err(|err| {
                    RemoteProtocolError::InvalidEnvelope {
                        type_name: "RemoteProcessInput",
                        message: format!("invalid session create request: {err}"),
                    }
                })?,
                turn_input: RemoteTurnInput::try_from(*turn_input)?,
                output_contract: output_contract.into(),
            }),
            lash_core::ProcessInput::External { metadata } => Ok(Self::External { metadata }),
        }
    }
}

impl TryFrom<RemoteProcessInput> for lash_core::ProcessInput {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessInput) -> Result<Self, Self::Error> {
        value.validate("RemoteProcessInput")?;
        match value {
            RemoteProcessInput::ToolCall { prepared_tool_call } => Ok(Self::ToolCall {
                call: decode_remote_json(
                    prepared_tool_call,
                    "RemoteProcessInput",
                    "prepared_tool_call",
                )?,
            }),
            RemoteProcessInput::LashlangProcess {
                module_ref,
                process_ref,
                host_requirements_ref,
                process_name,
                args,
            } => Ok(Self::LashlangProcess {
                module_ref: decode_remote_lashlang_ref(
                    module_ref,
                    "RemoteProcessInput",
                    "module_ref",
                )?,
                process_ref: process_ref.into(),
                host_requirements_ref: decode_remote_lashlang_ref(
                    host_requirements_ref,
                    "RemoteProcessInput",
                    "host_requirements_ref",
                )?,
                process_name,
                args,
            }),
            RemoteProcessInput::SessionTurn {
                create_request,
                turn_input,
                output_contract,
            } => Ok(Self::SessionTurn {
                create_request: Box::new(decode_remote_json(
                    create_request,
                    "RemoteProcessInput",
                    "create_request",
                )?),
                turn_input: Box::new(lash_core::TurnInput::try_from(turn_input)?),
                output_contract: output_contract.into(),
            }),
            RemoteProcessInput::External { metadata } => Ok(Self::External { metadata }),
        }
    }
}

impl From<lash_core::ProcessEventType> for RemoteProcessEventType {
    fn from(value: lash_core::ProcessEventType) -> Self {
        let lash_core::ProcessEventType {
            name,
            payload_schema,
            semantics,
        } = value;
        Self {
            name,
            payload_schema: payload_schema.schema,
            semantics: semantics.into(),
        }
    }
}

impl From<RemoteProcessEventType> for lash_core::ProcessEventType {
    fn from(value: RemoteProcessEventType) -> Self {
        let RemoteProcessEventType {
            name,
            payload_schema,
            semantics,
        } = value;
        Self {
            name,
            payload_schema: lash_core::LashSchema::new(payload_schema),
            semantics: semantics.into(),
        }
    }
}

impl From<lash_core::runtime::ProcessEventSemanticsSpec> for RemoteProcessEventSemanticsSpec {
    fn from(value: lash_core::runtime::ProcessEventSemanticsSpec) -> Self {
        let lash_core::runtime::ProcessEventSemanticsSpec { terminal, wake } = value;
        Self {
            terminal: terminal.map(Into::into),
            wake: wake.map(Into::into),
        }
    }
}

impl From<RemoteProcessEventSemanticsSpec> for lash_core::runtime::ProcessEventSemanticsSpec {
    fn from(value: RemoteProcessEventSemanticsSpec) -> Self {
        let RemoteProcessEventSemanticsSpec { terminal, wake } = value;
        Self {
            terminal: terminal.map(Into::into),
            wake: wake.map(Into::into),
        }
    }
}

impl From<lash_core::ProcessTerminalSpec> for RemoteProcessTerminalSpec {
    fn from(value: lash_core::ProcessTerminalSpec) -> Self {
        let lash_core::ProcessTerminalSpec {
            state,
            await_output,
        } = value;
        Self {
            state: state.into(),
            await_output: await_output.map(Into::into),
        }
    }
}

impl From<RemoteProcessTerminalSpec> for lash_core::ProcessTerminalSpec {
    fn from(value: RemoteProcessTerminalSpec) -> Self {
        let RemoteProcessTerminalSpec {
            state,
            await_output,
        } = value;
        Self {
            state: state.into(),
            await_output: await_output.map(Into::into),
        }
    }
}

impl From<lash_core::ProcessWakeSpec> for RemoteProcessWakeSpec {
    fn from(value: lash_core::ProcessWakeSpec) -> Self {
        let lash_core::ProcessWakeSpec {
            when,
            input,
            dedupe_key,
        } = value;
        Self {
            when: when.map(Into::into),
            input: input.into(),
            dedupe_key: dedupe_key.into(),
        }
    }
}

impl From<RemoteProcessWakeSpec> for lash_core::ProcessWakeSpec {
    fn from(value: RemoteProcessWakeSpec) -> Self {
        let RemoteProcessWakeSpec {
            when,
            input,
            dedupe_key,
        } = value;
        Self {
            when: when.map(Into::into),
            input: input.into(),
            dedupe_key: dedupe_key.into(),
        }
    }
}

impl From<lash_core::runtime::ProcessEventSemantics> for RemoteProcessEventSemantics {
    fn from(value: lash_core::runtime::ProcessEventSemantics) -> Self {
        let lash_core::runtime::ProcessEventSemantics { terminal, wake } = value;
        Self {
            terminal: terminal.map(Into::into),
            wake: wake.map(Into::into),
        }
    }
}

impl TryFrom<RemoteProcessEventSemantics> for lash_core::runtime::ProcessEventSemantics {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessEventSemantics) -> Result<Self, Self::Error> {
        let RemoteProcessEventSemantics { terminal, wake } = value;
        Ok(Self {
            terminal: terminal.map(TryInto::try_into).transpose()?,
            wake: wake.map(Into::into),
        })
    }
}

impl From<lash_core::ProcessTerminalState> for RemoteProcessTerminalState {
    fn from(value: lash_core::ProcessTerminalState) -> Self {
        match value {
            lash_core::ProcessTerminalState::Completed => Self::Completed,
            lash_core::ProcessTerminalState::Failed => Self::Failed,
            lash_core::ProcessTerminalState::Cancelled => Self::Cancelled,
        }
    }
}

impl From<RemoteProcessTerminalState> for lash_core::ProcessTerminalState {
    fn from(value: RemoteProcessTerminalState) -> Self {
        match value {
            RemoteProcessTerminalState::Completed => Self::Completed,
            RemoteProcessTerminalState::Failed => Self::Failed,
            RemoteProcessTerminalState::Cancelled => Self::Cancelled,
        }
    }
}

impl From<lash_core::ProcessTerminalSemantics> for RemoteProcessTerminalSemantics {
    fn from(value: lash_core::ProcessTerminalSemantics) -> Self {
        let lash_core::ProcessTerminalSemantics {
            state,
            await_output,
        } = value;
        Self {
            state: state.into(),
            await_output: await_output.into(),
        }
    }
}

impl TryFrom<RemoteProcessTerminalSemantics> for lash_core::ProcessTerminalSemantics {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessTerminalSemantics) -> Result<Self, Self::Error> {
        let RemoteProcessTerminalSemantics {
            state,
            await_output,
        } = value;
        Ok(Self {
            state: state.into(),
            await_output: await_output.try_into()?,
        })
    }
}

impl From<lash_core::ProcessWake> for RemoteProcessWake {
    fn from(value: lash_core::ProcessWake) -> Self {
        let lash_core::ProcessWake { input, dedupe_key } = value;
        Self { input, dedupe_key }
    }
}

impl From<RemoteProcessWake> for lash_core::ProcessWake {
    fn from(value: RemoteProcessWake) -> Self {
        let RemoteProcessWake { input, dedupe_key } = value;
        Self { input, dedupe_key }
    }
}

impl From<lash_core::ProcessWakeDedupeKey> for RemoteProcessWakeDedupeKey {
    fn from(value: lash_core::ProcessWakeDedupeKey) -> Self {
        match value {
            lash_core::ProcessWakeDedupeKey::EventIdentity => Self::EventIdentity,
            lash_core::ProcessWakeDedupeKey::Selector(selector) => Self::Selector(selector.into()),
            lash_core::ProcessWakeDedupeKey::Const(value) => Self::Const(value),
        }
    }
}

impl From<RemoteProcessWakeDedupeKey> for lash_core::ProcessWakeDedupeKey {
    fn from(value: RemoteProcessWakeDedupeKey) -> Self {
        match value {
            RemoteProcessWakeDedupeKey::EventIdentity => Self::EventIdentity,
            RemoteProcessWakeDedupeKey::Selector(selector) => Self::Selector(selector.into()),
            RemoteProcessWakeDedupeKey::Const(value) => Self::Const(value),
        }
    }
}

impl From<lash_core::ProcessValueSelector> for RemoteProcessValueSelector {
    fn from(value: lash_core::ProcessValueSelector) -> Self {
        match value {
            lash_core::ProcessValueSelector::Payload => Self::Payload,
            lash_core::ProcessValueSelector::Pointer(value) => Self::Pointer(value),
            lash_core::ProcessValueSelector::Const(value) => Self::Const(value),
            lash_core::ProcessValueSelector::Template { template, fields } => Self::Template {
                template,
                fields: fields
                    .into_iter()
                    .map(|(name, selector)| (name, selector.into()))
                    .collect(),
            },
            lash_core::ProcessValueSelector::Present(value) => Self::Present(value),
        }
    }
}

impl From<RemoteProcessValueSelector> for lash_core::ProcessValueSelector {
    fn from(value: RemoteProcessValueSelector) -> Self {
        match value {
            RemoteProcessValueSelector::Payload => Self::Payload,
            RemoteProcessValueSelector::Pointer(value) => Self::Pointer(value),
            RemoteProcessValueSelector::Const(value) => Self::Const(value),
            RemoteProcessValueSelector::Template { template, fields } => Self::Template {
                template,
                fields: fields
                    .into_iter()
                    .map(|(name, selector)| (name, selector.into()))
                    .collect(),
            },
            RemoteProcessValueSelector::Present(value) => Self::Present(value),
        }
    }
}

impl From<lash_core::RuntimeInvocation> for RemoteRuntimeInvocation {
    fn from(value: lash_core::RuntimeInvocation) -> Self {
        let lash_core::RuntimeInvocation {
            scope,
            subject,
            caused_by,
            replay,
        } = value;
        Self {
            scope: scope.into(),
            subject: subject.into(),
            caused_by: caused_by.map(Into::into),
            replay: replay.map(Into::into),
        }
    }
}

impl From<RemoteRuntimeInvocation> for lash_core::RuntimeInvocation {
    fn from(value: RemoteRuntimeInvocation) -> Self {
        let RemoteRuntimeInvocation {
            scope,
            subject,
            caused_by,
            replay,
        } = value;
        Self {
            scope: scope.into(),
            subject: subject.into(),
            caused_by: caused_by.map(Into::into),
            replay: replay.map(Into::into),
        }
    }
}

impl From<lash_core::runtime::RuntimeScope> for RemoteRuntimeScope {
    fn from(value: lash_core::runtime::RuntimeScope) -> Self {
        let lash_core::runtime::RuntimeScope {
            session_id,
            turn_id,
            turn_index,
            protocol_iteration,
        } = value;
        Self {
            session_id,
            turn_id,
            turn_index,
            protocol_iteration,
        }
    }
}

impl From<RemoteRuntimeScope> for lash_core::runtime::RuntimeScope {
    fn from(value: RemoteRuntimeScope) -> Self {
        let RemoteRuntimeScope {
            session_id,
            turn_id,
            turn_index,
            protocol_iteration,
        } = value;
        Self {
            session_id,
            turn_id,
            turn_index,
            protocol_iteration,
        }
    }
}

impl From<lash_core::runtime::RuntimeReplay> for RemoteRuntimeReplay {
    fn from(value: lash_core::runtime::RuntimeReplay) -> Self {
        let lash_core::runtime::RuntimeReplay { key } = value;
        Self { key }
    }
}

impl From<RemoteRuntimeReplay> for lash_core::runtime::RuntimeReplay {
    fn from(value: RemoteRuntimeReplay) -> Self {
        let RemoteRuntimeReplay { key } = value;
        Self { key }
    }
}

impl From<lash_core::runtime::RuntimeSubject> for RemoteRuntimeSubject {
    fn from(value: lash_core::runtime::RuntimeSubject) -> Self {
        match value {
            lash_core::runtime::RuntimeSubject::Effect { effect_id, kind } => Self::Effect {
                effect_id,
                kind: kind.into(),
            },
            lash_core::runtime::RuntimeSubject::Process { process_id } => Self::Process { process_id },
            lash_core::runtime::RuntimeSubject::ProcessEvent {
                process_id,
                sequence,
                event_type,
            } => Self::ProcessEvent {
                process_id,
                sequence,
                event_type,
            },
            lash_core::runtime::RuntimeSubject::TriggerOccurrence { occurrence_id } => {
                Self::TriggerOccurrence { occurrence_id }
            }
            lash_core::runtime::RuntimeSubject::SessionNode { node_id } => Self::SessionNode { node_id },
        }
    }
}

impl From<RemoteRuntimeSubject> for lash_core::runtime::RuntimeSubject {
    fn from(value: RemoteRuntimeSubject) -> Self {
        match value {
            RemoteRuntimeSubject::Effect { effect_id, kind } => Self::Effect {
                effect_id,
                kind: kind.into(),
            },
            RemoteRuntimeSubject::Process { process_id } => Self::Process { process_id },
            RemoteRuntimeSubject::ProcessEvent {
                process_id,
                sequence,
                event_type,
            } => Self::ProcessEvent {
                process_id,
                sequence,
                event_type,
            },
            RemoteRuntimeSubject::TriggerOccurrence { occurrence_id } => {
                Self::TriggerOccurrence { occurrence_id }
            }
            RemoteRuntimeSubject::SessionNode { node_id } => Self::SessionNode { node_id },
        }
    }
}

impl From<lash_core::RuntimeEffectKind> for RemoteRuntimeEffectKind {
    fn from(value: lash_core::RuntimeEffectKind) -> Self {
        match value {
            lash_core::RuntimeEffectKind::LlmCall => Self::LlmCall,
            lash_core::RuntimeEffectKind::Direct => Self::Direct,
            lash_core::RuntimeEffectKind::ToolCall => Self::ToolCall,
            lash_core::RuntimeEffectKind::Process => Self::Process,
            lash_core::RuntimeEffectKind::ExecCode => Self::ExecCode,
            lash_core::RuntimeEffectKind::Checkpoint => Self::Checkpoint,
            lash_core::RuntimeEffectKind::SyncExecutionEnvironment => Self::SyncExecutionEnvironment,
            lash_core::RuntimeEffectKind::Sleep => Self::Sleep,
            lash_core::RuntimeEffectKind::AwaitEvent => Self::AwaitEvent,
            lash_core::RuntimeEffectKind::DurableStep => Self::DurableStep,
        }
    }
}

impl From<RemoteRuntimeEffectKind> for lash_core::RuntimeEffectKind {
    fn from(value: RemoteRuntimeEffectKind) -> Self {
        match value {
            RemoteRuntimeEffectKind::LlmCall => Self::LlmCall,
            RemoteRuntimeEffectKind::Direct => Self::Direct,
            RemoteRuntimeEffectKind::ToolCall => Self::ToolCall,
            RemoteRuntimeEffectKind::Process => Self::Process,
            RemoteRuntimeEffectKind::ExecCode => Self::ExecCode,
            RemoteRuntimeEffectKind::Checkpoint => Self::Checkpoint,
            RemoteRuntimeEffectKind::SyncExecutionEnvironment => Self::SyncExecutionEnvironment,
            RemoteRuntimeEffectKind::Sleep => Self::Sleep,
            RemoteRuntimeEffectKind::AwaitEvent => Self::AwaitEvent,
            RemoteRuntimeEffectKind::DurableStep => Self::DurableStep,
        }
    }
}

impl From<lash_core::ProcessEvent> for RemoteProcessEvent {
    fn from(value: lash_core::ProcessEvent) -> Self {
        let lash_core::ProcessEvent {
            process_id,
            sequence,
            event_type,
            payload,
            invocation,
            semantics,
            occurred_at,
        } = value;
        Self {
            process_id,
            sequence,
            event_type,
            payload,
            invocation: Some(invocation.into()),
            semantics: semantics.into(),
            occurred_at_ms: lash_core::epoch_ms_from_system_time(occurred_at),
        }
    }
}

impl TryFrom<RemoteProcessEvent> for lash_core::ProcessEvent {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessEvent) -> Result<Self, Self::Error> {
        value.validate("RemoteProcessEvent")?;
        let RemoteProcessEvent {
            process_id,
            sequence,
            event_type,
            payload,
            invocation,
            semantics,
            occurred_at_ms,
        } = value;
        let invocation = invocation.ok_or_else(|| RemoteProtocolError::InvalidEnvelope {
            type_name: "RemoteProcessEvent",
            message: "invocation is required to convert to core ProcessEvent".to_string(),
        })?;
        Ok(Self {
            process_id,
            sequence,
            event_type,
            payload,
            invocation: invocation.into(),
            semantics: semantics.try_into()?,
            occurred_at: lash_core::system_time_from_epoch_ms(occurred_at_ms),
        })
    }
}

impl From<lash_core::ObservedProcessEvent> for RemoteObservedProcessEvent {
    fn from(value: lash_core::ObservedProcessEvent) -> Self {
        let lash_core::ObservedProcessEvent {
            sequence,
            event_type,
            occurred_at_ms,
            payload,
        } = value;
        Self {
            sequence,
            event_type,
            occurred_at_ms,
            payload,
        }
    }
}

impl From<RemoteObservedProcessEvent> for lash_core::ObservedProcessEvent {
    fn from(value: RemoteObservedProcessEvent) -> Self {
        let RemoteObservedProcessEvent {
            sequence,
            event_type,
            occurred_at_ms,
            payload,
        } = value;
        Self {
            sequence,
            event_type,
            occurred_at_ms,
            payload,
        }
    }
}

impl From<lash_core::ProcessHandleSummary> for RemoteProcessSummary {
    fn from(value: lash_core::ProcessHandleSummary) -> Self {
        let lash_core::ProcessHandleSummary {
            handle_type,
            id,
            process_id,
            descriptor,
            definition,
            status,
        } = value;
        Self {
            handle_type,
            id,
            process_id,
            descriptor: descriptor.into(),
            definition: definition.map(Into::into),
            status: status.into(),
        }
    }
}

impl From<RemoteProcessSummary> for lash_core::ProcessHandleSummary {
    fn from(value: RemoteProcessSummary) -> Self {
        let RemoteProcessSummary {
            handle_type,
            id,
            process_id,
            descriptor,
            definition,
            status,
        } = value;
        Self {
            handle_type,
            id,
            process_id,
            descriptor: descriptor.into(),
            definition: definition.map(Into::into),
            status: status.into(),
        }
    }
}

impl TryFrom<lash_core::ProcessRecord> for RemoteProcessRecord {
    type Error = RemoteProtocolError;

    fn try_from(value: lash_core::ProcessRecord) -> Result<Self, Self::Error> {
        let lash_core::ProcessRecord {
            id,
            registration_hash: _,
            input,
            event_types,
            provenance,
            env_ref,
            wake_target,
            created_at_ms,
            updated_at_ms,
            external_ref,
            wait,
            status,
        } = value;
        Ok(Self {
            process_id: id,
            input: input.as_ref().clone().try_into()?,
            event_types: event_types.into_iter().map(Into::into).collect(),
            provenance: provenance.into(),
            env_ref: env_ref.map(|env_ref| env_ref.as_str().to_string()),
            wake_target: wake_target.map(Into::into),
            created_at_ms,
            updated_at_ms,
            external_ref: external_ref.map(Into::into),
            wait: wait.map(Into::into),
            status: status.into(),
        })
    }
}

impl TryFrom<RemoteProcessRecord> for lash_core::ProcessRecord {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessRecord) -> Result<Self, Self::Error> {
        value.validate("RemoteProcessRecord")?;
        let RemoteProcessRecord {
            process_id,
            input,
            event_types,
            provenance,
            env_ref,
            wake_target,
            created_at_ms,
            updated_at_ms,
            external_ref,
            wait,
            status,
        } = value;
        let registration = lash_core::ProcessRegistration::new(
            process_id,
            input.try_into()?,
            provenance.into(),
        )
        .with_event_types(event_types.into_iter().map(Into::into))
        .with_execution_env_ref(env_ref.map(lash_core::ProcessExecutionEnvRef::new))
        .with_wake_target(wake_target.map(Into::into));
        let mut record = lash_core::ProcessRecord::from_registration(registration);
        record.created_at_ms = created_at_ms;
        record.updated_at_ms = updated_at_ms;
        record.external_ref = external_ref.map(Into::into);
        record.wait = wait.map(Into::into);
        record.status = status.try_into()?;
        Ok(record)
    }
}

impl TryFrom<lash_core::ObservedProcess> for RemoteObservedProcess {
    type Error = RemoteProtocolError;

    fn try_from(value: lash_core::ObservedProcess) -> Result<Self, Self::Error> {
        let lash_core::ObservedProcess {
            process_id,
            graph_key,
            kind,
            lifecycle,
            status_label,
            terminal,
            error,
            created_at_ms,
            updated_at_ms,
            input,
            originator,
            env_ref,
            wake_target,
            caused_by,
            external_ref,
            wait,
            child_session_id,
            label,
        } = value;
        Ok(Self {
            process_id,
            graph_key,
            kind,
            lifecycle: lifecycle.into(),
            status_label,
            terminal,
            error,
            created_at_ms,
            updated_at_ms,
            input: input.try_into()?,
            originator: originator.into(),
            env_ref: env_ref.map(|env_ref| env_ref.as_str().to_string()),
            wake_target: wake_target.map(Into::into),
            caused_by: caused_by.map(Into::into),
            external_ref: external_ref.map(Into::into),
            wait: wait.map(Into::into),
            child_session_id,
            label,
        })
    }
}

impl TryFrom<RemoteObservedProcess> for lash_core::ObservedProcess {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteObservedProcess) -> Result<Self, Self::Error> {
        value.validate("RemoteObservedProcess")?;
        let RemoteObservedProcess {
            process_id,
            graph_key,
            kind,
            lifecycle,
            status_label,
            terminal,
            error,
            created_at_ms,
            updated_at_ms,
            input,
            originator,
            env_ref,
            wake_target,
            caused_by,
            external_ref,
            wait,
            child_session_id,
            label,
        } = value;
        Ok(Self {
            process_id,
            graph_key,
            kind,
            lifecycle: lifecycle.into(),
            status_label,
            terminal,
            error,
            created_at_ms,
            updated_at_ms,
            input: input.try_into()?,
            originator: originator.into(),
            env_ref: env_ref.map(lash_core::ProcessExecutionEnvRef::new),
            wake_target: wake_target.map(Into::into),
            caused_by: caused_by.map(Into::into),
            external_ref: external_ref.map(Into::into),
            wait: wait.map(Into::into),
            child_session_id,
            label,
        })
    }
}

impl TryFrom<lash_core::ObservedWorkItem> for RemoteProcessWorkItem {
    type Error = RemoteProtocolError;

    fn try_from(value: lash_core::ObservedWorkItem) -> Result<Self, Self::Error> {
        let lash_core::ObservedWorkItem {
            process,
            descriptor,
            events,
            kind,
            label,
        } = value;
        Ok(Self {
            process: process.try_into()?,
            descriptor: descriptor.into(),
            events: events.into_iter().map(Into::into).collect(),
            kind,
            label,
        })
    }
}

impl TryFrom<RemoteProcessWorkItem> for lash_core::ObservedWorkItem {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessWorkItem) -> Result<Self, Self::Error> {
        value.validate("RemoteProcessWorkItem")?;
        let RemoteProcessWorkItem {
            process,
            descriptor,
            events,
            kind,
            label,
        } = value;
        Ok(Self {
            process: process.try_into()?,
            descriptor: descriptor.into(),
            events: events.into_iter().map(Into::into).collect(),
            kind,
            label,
        })
    }
}

impl TryFrom<lash_core::ProcessWorkSnapshot> for RemoteProcessWorkSnapshot {
    type Error = RemoteProtocolError;

    fn try_from(value: lash_core::ProcessWorkSnapshot) -> Result<Self, Self::Error> {
        let lash_core::ProcessWorkSnapshot {
            session_id,
            visible_process_ids,
            items,
        } = value;
        Ok(Self {
            protocol_version: REMOTE_PROTOCOL_VERSION,
            session_id,
            visible_process_ids,
            items: items
                .into_iter()
                .map(TryInto::try_into)
                .collect::<Result<_, _>>()?,
        })
    }
}

impl TryFrom<RemoteProcessWorkSnapshot> for lash_core::ProcessWorkSnapshot {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessWorkSnapshot) -> Result<Self, Self::Error> {
        value.validate()?;
        let RemoteProcessWorkSnapshot {
            protocol_version: _,
            session_id,
            visible_process_ids,
            items,
        } = value;
        Ok(Self {
            session_id,
            visible_process_ids,
            items: items
                .into_iter()
                .map(TryInto::try_into)
                .collect::<Result<_, _>>()?,
        })
    }
}

impl TryFrom<RemoteProcessStartRequest> for lash_core::ProcessStartRequest {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessStartRequest) -> Result<Self, Self::Error> {
        value.validate()?;
        let RemoteProcessStartRequest {
            protocol_version: _,
            id,
            input,
            env_spec,
            originator,
            wake_target,
            grant,
            event_types,
        } = value;
        let mut request =
            lash_core::ProcessStartRequest::new(id, input.try_into()?, originator.into())
                .with_wake_target(wake_target.map(Into::into))
                .with_grant(grant.map(Into::into))
                .with_event_types(event_types.into_iter().map(Into::into));
        request.env_spec = env_spec
            .map(|value| {
                decode_remote_json(value, "RemoteProcessStartRequest", "env_spec")
            })
            .transpose()?;
        Ok(request)
    }
}

impl TryFrom<lash_core::ProcessStartRequest> for RemoteProcessStartRequest {
    type Error = RemoteProtocolError;

    fn try_from(value: lash_core::ProcessStartRequest) -> Result<Self, Self::Error> {
        let lash_core::ProcessStartRequest {
            id,
            input,
            env_spec,
            originator,
            wake_target,
            grant,
            event_types,
        } = value;
        Ok(Self {
            protocol_version: REMOTE_PROTOCOL_VERSION,
            id,
            input: input.try_into()?,
            env_spec: env_spec
                .map(|env_spec| {
                    serde_json::to_value(env_spec).map_err(|err| {
                        RemoteProtocolError::InvalidEnvelope {
                            type_name: "RemoteProcessStartRequest",
                            message: format!("invalid env_spec: {err}"),
                        }
                    })
                })
                .transpose()?,
            originator: originator.into(),
            wake_target: wake_target.map(Into::into),
            grant: grant.map(Into::into),
            event_types: event_types.into_iter().map(Into::into).collect(),
        })
    }
}

impl TryFrom<lash_core::ProcessRecord> for RemoteProcessStartResult {
    type Error = RemoteProtocolError;

    fn try_from(value: lash_core::ProcessRecord) -> Result<Self, Self::Error> {
        Ok(Self {
            protocol_version: REMOTE_PROTOCOL_VERSION,
            record: value.try_into()?,
            summary: None,
        })
    }
}

impl TryFrom<RemoteProcessStartResult> for lash_core::ProcessRecord {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessStartResult) -> Result<Self, Self::Error> {
        value.validate()?;
        let RemoteProcessStartResult {
            protocol_version: _,
            record,
            summary: _,
        } = value;
        record.try_into()
    }
}

impl From<lash_core::ProcessStatusFilter> for RemoteProcessStatusFilter {
    fn from(value: lash_core::ProcessStatusFilter) -> Self {
        match value {
            lash_core::ProcessStatusFilter::Running => Self::Running,
            lash_core::ProcessStatusFilter::Completed => Self::Completed,
            lash_core::ProcessStatusFilter::Failed => Self::Failed,
            lash_core::ProcessStatusFilter::Cancelled => Self::Cancelled,
            lash_core::ProcessStatusFilter::Any => Self::Any,
        }
    }
}

impl From<RemoteProcessStatusFilter> for lash_core::ProcessStatusFilter {
    fn from(value: RemoteProcessStatusFilter) -> Self {
        match value {
            RemoteProcessStatusFilter::Running => Self::Running,
            RemoteProcessStatusFilter::Completed => Self::Completed,
            RemoteProcessStatusFilter::Failed => Self::Failed,
            RemoteProcessStatusFilter::Cancelled => Self::Cancelled,
            RemoteProcessStatusFilter::Any => Self::Any,
        }
    }
}

impl TryFrom<RemoteProcessListFilter> for lash_core::ProcessListFilter {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessListFilter) -> Result<Self, Self::Error> {
        value.validate()?;
        let RemoteProcessListFilter {
            protocol_version: _,
            definition,
            status,
            waiting,
        } = value;
        Ok(Self {
            definition: definition.map(TryInto::try_into).transpose()?,
            status: status.into(),
            waiting,
        })
    }
}

impl From<lash_core::ProcessListFilter> for RemoteProcessListFilter {
    fn from(value: lash_core::ProcessListFilter) -> Self {
        let lash_core::ProcessListFilter {
            definition,
            status,
            waiting,
        } = value;
        Self {
            protocol_version: REMOTE_PROTOCOL_VERSION,
            definition: definition.map(Into::into),
            status: status.into(),
            waiting,
        }
    }
}

impl TryFrom<Vec<lash_core::ObservedProcess>> for RemoteProcessListResponse {
    type Error = RemoteProtocolError;

    fn try_from(value: Vec<lash_core::ObservedProcess>) -> Result<Self, Self::Error> {
        Ok(Self {
            protocol_version: REMOTE_PROTOCOL_VERSION,
            records: value
                .into_iter()
                .map(TryInto::try_into)
                .collect::<Result<_, _>>()?,
        })
    }
}

impl TryFrom<RemoteProcessListResponse> for Vec<lash_core::ObservedProcess> {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessListResponse) -> Result<Self, Self::Error> {
        value.validate()?;
        let RemoteProcessListResponse {
            protocol_version: _,
            records,
        } = value;
        records.into_iter().map(TryInto::try_into).collect()
    }
}

impl From<RemoteProcessCancelRequest> for lash_core::ProcessCommand {
    fn from(value: RemoteProcessCancelRequest) -> Self {
        let RemoteProcessCancelRequest {
            protocol_version: _,
            process_id,
            reason,
        } = value;
        Self::Cancel { process_id, reason }
    }
}

impl From<lash_core::ProcessCancelSummary> for RemoteProcessCancelResult {
    fn from(value: lash_core::ProcessCancelSummary) -> Self {
        let lash_core::ProcessCancelSummary { process_id, status } = value;
        Self {
            protocol_version: REMOTE_PROTOCOL_VERSION,
            process_id,
            status: status.into(),
            record: None,
        }
    }
}

impl TryFrom<RemoteProcessCancelResult> for lash_core::ProcessCancelSummary {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessCancelResult) -> Result<Self, Self::Error> {
        value.validate()?;
        let RemoteProcessCancelResult {
            protocol_version: _,
            process_id,
            status,
            record: _,
        } = value;
        Ok(Self {
            process_id,
            status: status.into(),
        })
    }
}

impl TryFrom<RemoteProcessSignalRequest> for lash_core::ProcessEventAppendRequest {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessSignalRequest) -> Result<Self, Self::Error> {
        value.validate()?;
        let RemoteProcessSignalRequest {
            protocol_version: _,
            process_id: _,
            signal_name,
            signal_id: _,
            payload,
            replay_key,
            wake_target_scope,
        } = value;
        let event_type =
            lash_core::process_signal_event_type(&signal_name).map_err(|err| {
                RemoteProtocolError::InvalidEnvelope {
                    type_name: "RemoteProcessSignalRequest",
                    message: err.to_string(),
                }
            })?;
        Ok(lash_core::ProcessEventAppendRequest {
            event_type,
            payload,
            replay: replay_key.map(|key| lash_core::runtime::RuntimeReplay { key }),
            wake_target_scope: wake_target_scope.map(Into::into),
        })
    }
}

impl TryFrom<RemoteProcessSignalRequest> for lash_core::ProcessCommand {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessSignalRequest) -> Result<Self, Self::Error> {
        value.validate()?;
        let process_id = value.process_id.clone();
        let signal_name = value.signal_name.clone();
        let signal_id = value.signal_id.clone();
        let request = value.try_into()?;
        Ok(Self::Signal {
            process_id,
            signal_name,
            signal_id,
            request,
        })
    }
}

impl From<lash_core::ProcessEvent> for RemoteProcessSignalResult {
    fn from(value: lash_core::ProcessEvent) -> Self {
        Self {
            protocol_version: REMOTE_PROTOCOL_VERSION,
            event: value.into(),
        }
    }
}

impl TryFrom<RemoteProcessSignalResult> for lash_core::ProcessEvent {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessSignalResult) -> Result<Self, Self::Error> {
        value.validate()?;
        let RemoteProcessSignalResult {
            protocol_version: _,
            event,
        } = value;
        event.try_into()
    }
}

impl From<RemoteProcessAwaitRequest> for lash_core::ProcessCommand {
    fn from(value: RemoteProcessAwaitRequest) -> Self {
        let RemoteProcessAwaitRequest {
            protocol_version: _,
            process_id,
        } = value;
        Self::Await { process_id }
    }
}

impl From<(String, lash_core::ProcessAwaitOutput)> for RemoteProcessAwaitResult {
    fn from((process_id, output): (String, lash_core::ProcessAwaitOutput)) -> Self {
        Self {
            protocol_version: REMOTE_PROTOCOL_VERSION,
            process_id,
            output: output.into(),
        }
    }
}

impl TryFrom<RemoteProcessAwaitResult> for (String, lash_core::ProcessAwaitOutput) {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessAwaitResult) -> Result<Self, Self::Error> {
        value.validate()?;
        let RemoteProcessAwaitResult {
            protocol_version: _,
            process_id,
            output,
        } = value;
        Ok((process_id, output.try_into()?))
    }
}

impl From<(String, Vec<lash_core::ProcessEvent>)> for RemoteProcessEventsResponse {
    fn from((process_id, events): (String, Vec<lash_core::ProcessEvent>)) -> Self {
        Self {
            protocol_version: REMOTE_PROTOCOL_VERSION,
            process_id,
            events: events.into_iter().map(Into::into).collect(),
        }
    }
}

impl TryFrom<RemoteProcessEventsResponse> for (String, Vec<lash_core::ProcessEvent>) {
    type Error = RemoteProtocolError;

    fn try_from(value: RemoteProcessEventsResponse) -> Result<Self, Self::Error> {
        value.validate()?;
        let RemoteProcessEventsResponse {
            protocol_version: _,
            process_id,
            events,
        } = value;
        Ok((
            process_id,
            events
                .into_iter()
                .map(TryInto::try_into)
                .collect::<Result<_, _>>()?,
        ))
    }
}