rtnstate.go

// Copyright 2023, Command Line Inc.
// SPDX-License-Identifier: Apache-2.0

package rtnstate

import (
	"bytes"
	"context"
	"fmt"
	"strings"

	"github.com/alessio/shellescape"
	"github.com/wavetermdev/waveterm/waveshell/pkg/packet"
	"github.com/wavetermdev/waveterm/waveshell/pkg/shellapi"
	"github.com/wavetermdev/waveterm/waveshell/pkg/shellenv"
	"github.com/wavetermdev/waveterm/waveshell/pkg/simpleexpand"
	"github.com/wavetermdev/waveterm/waveshell/pkg/utilfn"
	"github.com/wavetermdev/waveterm/wavesrv/pkg/sstore"
	"mvdan.cc/sh/v3/syntax"
)

func parseAliasStmt(stmt *syntax.Stmt, sourceStr string) (string, string, error) {
	cmd := stmt.Cmd
	callExpr, ok := cmd.(*syntax.CallExpr)
	if !ok {
		return "", "", fmt.Errorf("wrong cmd type for alias")
	}
	if len(callExpr.Args) != 2 {
		return "", "", fmt.Errorf("wrong number of words in alias expr wordslen=%d", len(callExpr.Args))
	}
	firstWord := callExpr.Args[0]
	if firstWord.Lit() != "alias" {
		return "", "", fmt.Errorf("invalid alias cmd word (not 'alias')")
	}
	secondWord := callExpr.Args[1]
	var ectx simpleexpand.SimpleExpandContext // no homedir, do not want ~ expansion
	val, _ := simpleexpand.SimpleExpandWord(ectx, secondWord, sourceStr)
	eqIdx := strings.Index(val, "=")
	if eqIdx == -1 {
		return "", "", fmt.Errorf("no '=' in alias definition")
	}
	return val[0:eqIdx], val[eqIdx+1:], nil
}

func ParseAliases(aliases string) (map[string]string, error) {
	r := strings.NewReader(aliases)
	parser := syntax.NewParser(syntax.Variant(syntax.LangBash))
	file, err := parser.Parse(r, "aliases")
	if err != nil {
		return nil, err
	}
	rtn := make(map[string]string)
	for _, stmt := range file.Stmts {
		aliasName, aliasVal, err := parseAliasStmt(stmt, aliases)
		if err != nil {
			// fmt.Printf("stmt-err: %v\n", err)
			continue
		}
		if aliasName != "" {
			rtn[aliasName] = aliasVal
		}
	}
	return rtn, nil
}

func parseFuncStmt(stmt *syntax.Stmt, source string) (string, string, error) {
	cmd := stmt.Cmd
	funcDecl, ok := cmd.(*syntax.FuncDecl)
	if !ok {
		return "", "", fmt.Errorf("cmd not FuncDecl")
	}
	name := funcDecl.Name.Value
	// fmt.Printf("func: [%s]\n", name)
	funcBody := funcDecl.Body
	// fmt.Printf("  %d:%d\n", funcBody.Cmd.Pos().Offset(), funcBody.Cmd.End().Offset())
	bodyStr := source[funcBody.Cmd.Pos().Offset():funcBody.Cmd.End().Offset()]
	// fmt.Printf("<<<\n%s\n>>>\n", bodyStr)
	// fmt.Printf("\n")
	return name, bodyStr, nil
}

func ParseFuncs(funcs string) (map[string]string, error) {
	r := strings.NewReader(funcs)
	parser := syntax.NewParser(syntax.Variant(syntax.LangBash))
	file, err := parser.Parse(r, "funcs")
	if err != nil {
		return nil, err
	}
	rtn := make(map[string]string)
	for _, stmt := range file.Stmts {
		funcName, funcVal, err := parseFuncStmt(stmt, funcs)
		if err != nil {
			// TODO where to put parse errors
			continue
		}
		if strings.HasPrefix(funcName, "_mshell_") {
			continue
		}
		if funcName != "" {
			rtn[funcName] = funcVal
		}
	}
	return rtn, nil
}

const MaxDiffKeyLen = 40
const MaxDiffValLen = 50

var IgnoreVars = map[string]bool{
	"PROMPT":               true,
	"PROMPT_VERSION":       true,
	"MSHELL":               true,
	"MSHELL_VERSION":       true,
	"WAVESHELL":            true,
	"WAVESHELL_VERSION":    true,
	"WAVETERM":             true,
	"WAVETERM_VERSION":     true,
	"WAVETERM_DEV":         true,
	"TERM_PROGRAM":         true,
	"TERM_PROGRAM_VERSION": true,
	"TERM_SESSION_ID":      true,
}

func makeBashAliasesDiff(buf *bytes.Buffer, oldAliases string, newAliases string) {
	newAliasMap, _ := ParseAliases(newAliases)
	oldAliasMap, _ := ParseAliases(oldAliases)
	for aliasName, newAliasVal := range newAliasMap {
		oldAliasVal, found := oldAliasMap[aliasName]
		if !found || newAliasVal != oldAliasVal {
			buf.WriteString(fmt.Sprintf("alias %s\n", utilfn.EllipsisStr(shellescape.Quote(aliasName), MaxDiffKeyLen)))
		}
	}
	for aliasName := range oldAliasMap {
		_, found := newAliasMap[aliasName]
		if !found {
			buf.WriteString(fmt.Sprintf("unalias %s\n", utilfn.EllipsisStr(shellescape.Quote(aliasName), MaxDiffKeyLen)))
		}
	}
}

func makeZshAlisesDiff(buf *bytes.Buffer, oldAliases string, newAliases string) {
	newAliasMap, err := shellapi.DecodeZshMap([]byte(newAliases))
	if err != nil {
		return
	}
	oldAliasMap, err := shellapi.DecodeZshMap([]byte(oldAliases))
	if err != nil {
		return
	}
	for aliasKey, newAliasVal := range newAliasMap {
		oldAliasVal, found := oldAliasMap[aliasKey]
		if !found || newAliasVal != oldAliasVal {
			buf.WriteString(fmt.Sprintf("%s %s=%s\n", aliasKey.ParamType, aliasKey.ParamName, utilfn.EllipsisStr(shellescape.Quote(newAliasVal), MaxDiffKeyLen)))
		}
	}
	for aliasKey := range oldAliasMap {
		_, found := newAliasMap[aliasKey]
		if !found {
			buf.WriteString(fmt.Sprintf("remove %s %s\n", aliasKey.ParamType, aliasKey.ParamName))
		}
	}
}

func makeZshFuncsDiff(buf *bytes.Buffer, oldFuncs string, newFuncs string) {
	newFuncMap, err := shellapi.DecodeZshMap([]byte(newFuncs))
	if err != nil {
		return
	}
	oldFuncMap, err := shellapi.DecodeZshMap([]byte(oldFuncs))
	if err != nil {
		return
	}
	for funcKey, newFuncVal := range newFuncMap {
		oldFuncVal, found := oldFuncMap[funcKey]
		if !found || newFuncVal != oldFuncVal {
			buf.WriteString(fmt.Sprintf("%s %s\n", funcKey.ParamType, funcKey.ParamName))
		}
	}
	for funcKey := range oldFuncMap {
		_, found := newFuncMap[funcKey]
		if !found {
			buf.WriteString(fmt.Sprintf("remove %s %s\n", funcKey.ParamType, funcKey.ParamName))
		}
	}
}

func DisplayStateUpdateDiff(buf *bytes.Buffer, oldState packet.ShellState, newState packet.ShellState) {
	if newState.Cwd != oldState.Cwd {
		buf.WriteString(fmt.Sprintf("cwd %s\n", newState.Cwd))
	}
	if !bytes.Equal(newState.ShellVars, oldState.ShellVars) {
		newEnvMap := shellenv.DeclMapFromState(&newState)
		oldEnvMap := shellenv.DeclMapFromState(&oldState)
		for key, newVal := range newEnvMap {
			if IgnoreVars[key] {
				continue
			}
			oldVal, found := oldEnvMap[key]
			if !found || !shellenv.DeclsEqual(false, oldVal, newVal) {
				var exportStr string
				if newVal.IsExport() {
					exportStr = "export "
				}
				buf.WriteString(fmt.Sprintf("%s%s=%s\n", exportStr, utilfn.EllipsisStr(key, MaxDiffKeyLen), utilfn.EllipsisStr(newVal.Value, MaxDiffValLen)))
			}
		}
		for key := range oldEnvMap {
			if IgnoreVars[key] {
				continue
			}
			_, found := newEnvMap[key]
			if !found {
				buf.WriteString(fmt.Sprintf("unset %s\n", utilfn.EllipsisStr(key, MaxDiffKeyLen)))
			}
		}
	}
	if newState.GetShellType() == packet.ShellType_zsh {
		makeZshAlisesDiff(buf, oldState.Aliases, newState.Aliases)
		makeZshFuncsDiff(buf, oldState.Funcs, newState.Funcs)
	} else {
		makeBashAliasesDiff(buf, oldState.Aliases, newState.Aliases)
		makeBashFuncsDiff(newState, oldState, buf)
	}
}

func makeBashFuncsDiff(newState packet.ShellState, oldState packet.ShellState, buf *bytes.Buffer) {
	if newState.Funcs == oldState.Funcs {
		return
	}
	newFuncMap, _ := ParseFuncs(newState.Funcs)
	oldFuncMap, _ := ParseFuncs(oldState.Funcs)
	for funcName, newFuncVal := range newFuncMap {
		oldFuncVal, found := oldFuncMap[funcName]
		if !found || newFuncVal != oldFuncVal {
			buf.WriteString(fmt.Sprintf("function %s\n", utilfn.EllipsisStr(shellescape.Quote(funcName), MaxDiffKeyLen)))
		}
	}
	for funcName := range oldFuncMap {
		_, found := newFuncMap[funcName]
		if !found {
			buf.WriteString(fmt.Sprintf("unset -f %s\n", utilfn.EllipsisStr(shellescape.Quote(funcName), MaxDiffKeyLen)))
		}
	}
}

func GetRtnStateDiff(ctx context.Context, screenId string, lineId string) ([]byte, error) {
	cmd, err := sstore.GetCmdByScreenId(ctx, screenId, lineId)
	if err != nil {
		return nil, err
	}
	if cmd == nil {
		return nil, nil
	}
	if !cmd.RtnState {
		return nil, nil
	}
	if cmd.RtnStatePtr.IsEmpty() {
		return nil, nil
	}
	var outputBytes bytes.Buffer
	initialState, err := sstore.GetFullState(ctx, cmd.StatePtr)
	if err != nil {
		return nil, fmt.Errorf("getting initial full state: %v", err)
	}
	rtnState, err := sstore.GetFullState(ctx, cmd.RtnStatePtr)
	if err != nil {
		return nil, fmt.Errorf("getting rtn full state: %v", err)
	}
	DisplayStateUpdateDiff(&outputBytes, *initialState, *rtnState)
	return outputBytes.Bytes(), nil
}