MCPcopy Index your code
hub / github.com/wavetermdev/waveterm / ControllerInputCommand

Method ControllerInputCommand

pkg/wshrpc/wshserver/wshserver.go:320–334  ·  view source on GitHub ↗
(ctx context.Context, data wshrpc.CommandBlockInputData)

Source from the content-addressed store, hash-verified

318}
319
320func (ws *WshServer) ControllerInputCommand(ctx context.Context, data wshrpc.CommandBlockInputData) error {
321 inputUnion := &blockcontroller.BlockInputUnion{
322 SigName: data.SigName,
323 TermSize: data.TermSize,
324 }
325 if len(data.InputData64) > 0 {
326 inputBuf := make([]byte, base64.StdEncoding.DecodedLen(len(data.InputData64)))
327 nw, err := base64.StdEncoding.Decode(inputBuf, []byte(data.InputData64))
328 if err != nil {
329 return fmt.Errorf("error decoding input data: %w", err)
330 }
331 inputUnion.InputData = inputBuf[:nw]
332 }
333 return blockcontroller.SendInput(data.BlockId, inputUnion)
334}
335
336func (ws *WshServer) ControllerAppendOutputCommand(ctx context.Context, data wshrpc.CommandControllerAppendOutputData) error {
337 outputBuf := make([]byte, base64.StdEncoding.DecodedLen(len(data.Data64)))

Callers

nothing calls this directly

Calls 1

SendInputFunction · 0.92

Tested by

no test coverage detected