debug.go

package main

import (
	"context"
	"fmt"

	"google.golang.org/protobuf/encoding/protojson"
	"mkm.pub/binlog/reader"
)

type DebugCmd struct {
	CmdCommon

	Expand bool `optional:"" help:"Show message bodies"`
}

func (cmd *DebugCmd) Run(cli *Context) error {
	f, err := openFile(cmd.LogInputFile, cli.Follow)
	if err != nil {
		return err
	}
	defer f.Close()

	ctx := context.Background()
	entries, errCh := reader.Read(ctx, f)

	for e := range entries {
		fmt.Printf("%d\t%s\t%s\n", e.CallId, e.GetType(), e.GetClientHeader().GetMethodName())
		if cmd.Expand {
			res, err := protojson.MarshalOptions{Multiline: true}.Marshal(e)
			if err != nil {
				return err
			}
			fmt.Printf("%s\n", res)
		}
	}

	if err := <-errCh; err != nil {
		return err
	}

	return nil
}