debug.go

//go:build eng
// +build eng

package portal

import (
	"fmt"
	"os"
	"time"

	"github.com/FrameworkOSS/event"
)

func (opt *PortalOptions) GetLog() bool {
	return opt.log
}

func (opt *PortalOptions) GetDebugger() string {
	return opt.debugger
}

func (opt *PortalOptions) SetLog(log bool) *PortalOptions {
	opt.log = log
	return opt
}

func (opt *PortalOptions) SetDebugger(id string) *PortalOptions {
	opt.debugger = id
	return opt
}

func (opt *PortalOptions) stringDebug() (str string) {
	str += fmt.Sprintf("Log:\t\t\t%t\n", opt.log)
	return
}

func (p *Portal) Log(format string, vars ...any) {
	log := p.OptionsGet().GetLog()
	if !log {
		return
	}

	p.LockKey(KEY_LOG)
	if p.logfile == nil {
		logname := p.id() + ".log"
		p.logfile, _ = os.Create(logname)
	}
	format = fmt.Sprintf("%s: %s", p.id(), format)
	if format[len(format)-1] != '\n' {
		format += "\n"
	}
	format += "\n"
	out := fmt.Sprintf(format, vars...)
	p.logfile.WriteString(out)
	p.UnlockKey(KEY_LOG)
}

// DebugEvent returns a string formatting of an event.
func DebugEvent(e *event.Event) (s string) {
	s += "<<<< portal:" + e.GetPortal() + " producer:" + e.GetProducer() + " >>>>"
	if epochMilli := e.GetEpochMilli(); epochMilli > 0 {
		t := time.UnixMilli(int64(epochMilli))
		s += fmt.Sprintf(" %s", t.Format(time.RFC3339Nano))
	}
	s += fmt.Sprintf("\nid:%s", event.Key(e.GetID()))
	if channel := e.GetChannel(); channel != "" {
		s += fmt.Sprintf(" (channel:%s)", channel)
	}
	if parts := e.GetParticipants(); len(parts) > 0 {
		s += fmt.Sprintf(" targets:%v", parts)
	}
	s += "\n"
	if offsets := e.GetOffsets(); len(offsets) > 0 {
		s += fmt.Sprintf("Offsets: %v\n", e.GetOffsets())
	}
	if data := e.GetData(); len(data) > 0 {
		s += "<<<\n"
		switch e.GetID() {
		case event.EVENT_RESPONSE, event.EVENT_ERROR:
			s += string(data)
		default:
			s += fmt.Sprintf("0x%X\n===\n%s", data, string(data))
		}
		s += "\n>>>\n"
	}
	return s
}