dbg.go

package runn

import (
	"context"
	"fmt"
	"os"
	"sort"
	"strconv"
	"strings"
	"sync"

	"github.com/elk-language/go-prompt"
	pstrings "github.com/elk-language/go-prompt/strings"
	"github.com/k0kubun/pp/v3"
	"github.com/k1LoW/runn/internal/expr"
	"github.com/k1LoW/runn/internal/store"
	"github.com/olekukonko/tablewriter"
	"github.com/samber/lo"
)

const (
	dbgCmdNext          = "next"
	dbgCmdNextShort     = "n"
	dbgCmdQuit          = "quit"
	dbgCmdQuitShort     = "q"
	dbgCmdPrint         = "print"
	dbgCmdPrintShort    = "p"
	dbgCmdBreak         = "break"
	dbgCmdBreakShort    = "b"
	dbgCmdContinue      = "continue"
	dbgCmdContinueShort = "c"
	dbgCmdInfo          = "info"
	dbgCmdInfoShort     = "i"
	dbgCmdList          = "list"
	dbgCmdListShort     = "l"
)

const bpSep = ":"

type breakpoint struct {
	runbookID string
	stepKey   string
}

// dbg is runn debugger.
type dbg struct {
	enable      bool
	showPrompt  bool
	quit        bool
	history     []string
	breakpoints []breakpoint
	opn         *operatorN
	pp          *pp.PrettyPrinter
	mu          sync.Mutex
}

func newDBG(enable bool) *dbg {
	return &dbg{
		enable:     enable,
		showPrompt: true,
		pp:         pp.New(),
	}
}

type completer struct {
	dbg  *dbg
	step *step
}

func newCompleter(dbg *dbg, step *step) *completer {
	return &completer{
		dbg:  dbg,
		step: step,
	}
}

func (c *completer) do(d prompt.Document) ([]prompt.Suggest, pstrings.RuneNumber, pstrings.RuneNumber) {
	endIndex := d.CurrentRuneIndex()
	w := d.GetWordBeforeCursor()
	startIndex := endIndex - pstrings.RuneCount([]byte(w))

	cmd := d.Text
	splitted := strings.Split(cmd, " ")
	var s []prompt.Suggest
	switch {
	case !strings.Contains(cmd, " "):
		s = []prompt.Suggest{
			{Text: dbgCmdNext, Description: "(n) run current step and next"},
			{Text: dbgCmdQuit, Description: "(q) quit debugger and skip all steps"},
			{Text: dbgCmdContinue, Description: "(c) continue to run until next breakpoint"},
			{Text: dbgCmdPrint, Description: "(p) print variable. ('print [variable]')"},
			{Text: dbgCmdBreak, Description: "(b) set breakpoint. ('break [id]' 'break [id]:[step]' 'break :[step]')"},
			{Text: dbgCmdInfo, Description: "(i) show information"},
			{Text: dbgCmdList, Description: "(l) list codes of step. ('list' 'list [id]' 'list [id]:[step]' 'list :[step]')"},
		}
	case splitted[0] == dbgCmdPrint || splitted[0] == dbgCmdPrintShort:
		// print
		sm := c.step.parent.store.ToMap()
		sm[store.RootKeyIncluded] = c.step.parent.included
		if !c.step.deferred {
			sm[store.RootKeyPrevious] = c.step.parent.store.Latest()
		}
		keys := storeKeys(sm)
		for _, k := range keys {
			if strings.HasPrefix(k, w) {
				s = append(s, prompt.Suggest{Text: k})
			}
		}
	case splitted[0] == dbgCmdBreak || splitted[0] == dbgCmdBreakShort || splitted[0] == dbgCmdList || splitted[0] == dbgCmdListShort:
		// break, list
		for _, o := range c.dbg.opn.ops {
			id := o.ID()[:7]
			s = append(s, prompt.Suggest{Text: id})
		}
		if c.step.idx != len(c.step.parent.steps)-1 {
			for i := c.step.idx + 1; i < len(c.step.parent.steps); i++ {
				step := c.step.parent.steps[i]
				s = append(s, prompt.Suggest{Text: fmt.Sprintf(":%s", step.key)})
			}
		}
		for _, o := range c.dbg.opn.ops {
			id := o.ID()[:7]
			for _, step := range o.steps {
				s = append(s, prompt.Suggest{Text: fmt.Sprintf("%s:%s", id, step.key)})
			}
		}
	case splitted[0] == dbgCmdInfo || splitted[0] == dbgCmdInfoShort:
		// info
		s = append(s, prompt.Suggest{Text: "breakpoints", Description: "(b) show breakpoints"})
		s = append(s, prompt.Suggest{Text: "variables", Description: "(v) show variables"})
	}

	return prompt.FilterHasPrefix(s, w, true), startIndex, endIndex
}

func (d *dbg) attach(ctx context.Context, s *step) error {
	prpt := "> "

	if d.quit {
		s.parent.skipped = true
		return errStepSkipped
	}
	if !d.enable {
		return nil
	}

	if s != nil {
		id := s.parent.ID()
		stepKey := s.key
		stepIdx := strconv.Itoa(s.idx)
		// check breakpoints
		for _, bp := range d.breakpoints {
			if !strings.HasPrefix(id, bp.runbookID) {
				continue
			}
			if bp.stepKey != stepKey && bp.stepKey != stepIdx {
				continue
			}
			d.showPrompt = true
		}
		prpt = fmt.Sprintf("%s[%s]> ", id[:7], s.key)
	}

	if !d.showPrompt {
		return nil
	}
	d.showPrompt = false

L:
	for {
		in := prompt.Input(
			prompt.WithPrefix(prpt),
			prompt.WithCompleter(newCompleter(d, s).do),
			prompt.WithHistory(d.history),
		)
		d.history = append(d.history, in)
		cmd := strings.SplitN(strings.TrimSpace(in), " ", 2)
		prog := cmd[0]
		switch prog {
		case dbgCmdNext, dbgCmdNextShort:
			// next
			d.showPrompt = true
			break L
		case dbgCmdContinue, dbgCmdContinueShort:
			// continue
			break L
		case dbgCmdQuit, dbgCmdQuitShort:
			// quit
			d.quit = true
			s.parent.skipped = true
			return errStepSkipped
		case dbgCmdPrint, dbgCmdPrintShort:
			// print
			if len(cmd) != 2 {
				_, _ = fmt.Fprintf(os.Stderr, "args required")
				continue
			}
			sm := s.parent.store.ToMapForDbg()
			sm[store.RootKeyIncluded] = s.parent.included
			if !s.deferred {
				sm[store.RootKeyPrevious] = s.parent.store.Latest()
			}
			e, err := expr.Eval(cmd[1], sm)
			if err != nil {
				_, _ = fmt.Fprintf(os.Stderr, "%s\n", err.Error())
				continue
			}
			d.pp.Println(e)
		case dbgCmdBreak, dbgCmdBreakShort:
			// break
			if len(cmd) != 2 {
				_, _ = fmt.Fprintf(os.Stderr, "args required")
				continue
			}
			splitted := strings.Split(cmd[1], bpSep)
			bp := breakpoint{}
			if splitted[0] != "" {
				bp.runbookID = splitted[0]
			} else {
				bp.runbookID = s.parent.ID()
			}
			if len(splitted) > 1 && splitted[1] != "" {
				bp.stepKey = splitted[1]
			} else {
				bp.stepKey = "0"
			}
			d.breakpoints = append(d.breakpoints, bp)
		case dbgCmdInfo, dbgCmdInfoShort:
			// info
			if len(cmd) != 2 {
				_, _ = fmt.Fprintf(os.Stderr, "args required")
				continue
			}
			switch cmd[1] {
			case "breakpoints", "b":
				table := tablewriter.NewWriter(os.Stdout)
				table.SetHeader([]string{"Num", "ID", "Step"})
				table.SetAutoWrapText(false)
				table.SetHeaderAlignment(tablewriter.ALIGN_LEFT)
				table.SetAutoFormatHeaders(false)
				table.SetCenterSeparator("")
				table.SetColumnSeparator("")
				table.SetRowSeparator("-")
				table.SetHeaderLine(false)
				table.SetBorder(false)
				for i, bp := range d.breakpoints {
					table.Append([]string{strconv.Itoa(i + 1), bp.runbookID, bp.stepKey})
				}
				table.Render()
			case "variables", "v":
				sm := s.parent.store.ToMapForDbg()
				sm[store.RootKeyIncluded] = s.parent.included
				if !s.deferred {
					sm[store.RootKeyPrevious] = s.parent.store.Latest()
				}
				keys := lo.Keys(sm)
				sort.Strings(keys)
				for _, k := range keys {
					fmt.Println(k)
				}
			default:
				_, _ = fmt.Fprintf(os.Stderr, "unknown args %s\n", cmd[1])
				continue
			}
		case dbgCmdList, dbgCmdListShort:
			// list
			var (
				path string
				idx  int
			)
			if len(cmd) != 2 {
				if s == nil {
					_, _ = fmt.Fprintf(os.Stderr, "invalid args %s\n", cmd[1])
					continue
				}
				path = s.parent.bookPath
				idx = s.idx
			} else {
				splitted := strings.Split(cmd[1], bpSep)
				var (
					id string
					o  *operator
				)
				if splitted[0] != "" {
					id = splitted[0]
				} else {
					id = s.parent.ID()
				}

				// search runbook
				found := false
				for _, op := range d.opn.ops {
					if strings.HasPrefix(op.ID(), id) {
						if found {
							_, _ = fmt.Fprintf(os.Stderr, "unable to identify runbook: %s\n", id)
							continue L
						}
						o = op
						found = true
					}
				}
				if !found {
					_, _ = fmt.Fprintf(os.Stderr, "runbook not found: %s\n", id)
					continue L
				}
				path = o.bookPath

				if len(splitted) > 1 && splitted[1] != "" {
					i, err := strconv.Atoi(splitted[1])
					if err != nil {
						found := false
						for _, s := range o.steps {
							if s.key == splitted[1] {
								found = true
								idx = s.idx
							}
						}
						if !found {
							_, _ = fmt.Fprintf(os.Stderr, "step not found: %s\n", splitted[1])
							continue L
						}
					} else {
						idx = i
					}
				} else {
					idx = 0
				}

			}
			b, err := readFile(path)
			if err != nil {
				_, _ = fmt.Fprintf(os.Stderr, "%v\n", err)
				continue
			}
			picked, err := pickStepYAML(string(b), idx)
			if err != nil {
				_, _ = fmt.Fprintf(os.Stderr, "%v\n", err)
				continue
			}
			fmt.Println(picked)
		default:
			_, _ = fmt.Fprintf(os.Stderr, "unknown command %s\n", in)
		}
		select {
		case <-ctx.Done():
			return ctx.Err()
		default:
		}
	}
	return nil
}

func (d *dbg) setOperatorN(opn *operatorN) {
	d.mu.Lock()
	defer d.mu.Unlock()
	d.opn = opn
}

// storeKeys lists all keys in the store.
func storeKeys(store map[string]any) []string {
	const storeKeySep = "."
	var keys []string
	for k := range store {
		keys = append(keys, k)
		switch v := store[k].(type) {
		case map[string]any:
			subKeys := storeKeys(v)
			for _, sk := range subKeys {
				keys = append(keys, k+storeKeySep+sk)
			}
		}
	}
	sort.Strings(keys)
	return keys
}