event.go

package exec

import (
	"fmt"
	"github.com/viant/endly/model/msg"
	"strings"
)

// StdinEvent represents an execution event start
type StdinEvent struct {
	SessionID string
	Stdin     string
}

// Messages returns messages
func (e *StdinEvent) Messages() []*msg.Message {
	return []*msg.Message{
		msg.NewMessage(msg.NewStyled(fmt.Sprintf("%v", e.SessionID), msg.MessageStyleGeneric), msg.NewStyled("stdin", msg.MessageStyleGeneric),
			msg.NewStyled(e.Stdin, msg.MessageStyleInput)),
	}
}

// NewSdtinEvent crates a new execution start event value
func NewSdtinEvent(sessionID string, stdin string) *StdinEvent {
	return &StdinEvent{
		SessionID: sessionID,
		Stdin:     strings.Trim(stdin, "\n\r"),
	}
}

// StdoutEvent represents an execution event end
type StdoutEvent struct {
	SessionID string
	Stdout    string
	Error     string
}

// Messages returns messages
func (e *StdoutEvent) Messages() []*msg.Message {
	return []*msg.Message{
		msg.NewMessage(msg.NewStyled(fmt.Sprintf("%v", e.SessionID), msg.MessageStyleGeneric), msg.NewStyled("stdout", msg.MessageStyleGeneric),
			msg.NewStyled(e.Stdout, msg.MessageStyleOutput)),
	}
}

// NewStdoutEvent crates a new execution start event value
func NewStdoutEvent(sessionID string, stdout string, err error) *StdoutEvent {
	return &StdoutEvent{
		SessionID: sessionID,
		Stdout:    stdout,
	}
}