Method spawn

crates/opencode-plugin/src/subprocess/client.rs:143–196

Spawn a plugin host subprocess and run the `initialize` handshake. `cwd` sets the working directory for the subprocess so that bare-specifier `import("pkg")` calls resolve against the correct `node_modules/`.

(
        runtime: JsRuntime,
        host_script: &str,
        plugin_path: &str,
        context: PluginContext,
        cwd: Option<&std::path::Path>,
    )

    /// `cwd` sets the working directory for the subprocess so that bare-specifier
    /// `import("pkg")` calls resolve against the correct `node_modules/`.
    pub async fn spawn(
        runtime: JsRuntime,
        host_script: &str,
        plugin_path: &str,
        context: PluginContext,
        cwd: Option<&std::path::Path>,
    ) -> Result<Self, PluginSubprocessError> {
        let args = runtime.run_args(host_script);
        let mut cmd = Command::new(runtime.command());
        cmd.args(&args)
            .stdin(Stdio::piped())
            .stdout(Stdio::piped())
            .stderr(Stdio::inherit()) // plugin logs go to parent stderr
            .kill_on_drop(true);
        if let Some(dir) = cwd {
            cmd.current_dir(dir);
        }

        let mut child = cmd.spawn()?;

        let stdin = child
            .stdin
            .take()
            .ok_or_else(|| PluginSubprocessError::Protocol("no stdin".into()))?;
        let stdout = child
            .stdout
            .take()
            .ok_or_else(|| PluginSubprocessError::Protocol("no stdout".into()))?;

        let mut this = Self {
            name: String::new(),
            stdin: Arc::new(Mutex::new(stdin)),
            stdout: Arc::new(Mutex::new(BufReader::new(stdout))),
            rpc_lock: Arc::new(Mutex::new(())),
            process: Mutex::new(child),
            request_id: AtomicU64::new(1),
            hooks: Vec::new(),
            auth_meta: None,
            timeout: Duration::from_secs(30),
        };

        // Send initialize
        let params = serde_json::json!({
            "pluginPath": plugin_path,
            "context": context,
        });
        let result: InitializeResult = this.call("initialize", Some(params)).await?;

        this.name = result.name;
        this.hooks = result.hooks;
        this.auth_meta = result.auth;

        Ok(this)
    }

    // -- Accessors ----------------------------------------------------------