mirror of
https://github.com/bloeys/nterm.git
synced 2025-12-29 06:28:20 +00:00
1124 lines
27 KiB
Go
Executable File
1124 lines
27 KiB
Go
Executable File
package main
|
|
|
|
import (
|
|
"bytes"
|
|
"fmt"
|
|
"io"
|
|
"math"
|
|
"os"
|
|
"os/exec"
|
|
"runtime"
|
|
"runtime/pprof"
|
|
"strings"
|
|
"sync"
|
|
"syscall"
|
|
"time"
|
|
"unicode/utf8"
|
|
|
|
"github.com/bloeys/gglm/gglm"
|
|
"github.com/bloeys/nmage/engine"
|
|
"github.com/bloeys/nmage/input"
|
|
"github.com/bloeys/nmage/materials"
|
|
"github.com/bloeys/nmage/meshes"
|
|
"github.com/bloeys/nmage/renderer/rend3dgl"
|
|
"github.com/bloeys/nmage/timing"
|
|
nmageimgui "github.com/bloeys/nmage/ui/imgui"
|
|
"github.com/bloeys/nterm/ansi"
|
|
"github.com/bloeys/nterm/assert"
|
|
"github.com/bloeys/nterm/consts"
|
|
"github.com/bloeys/nterm/glyphs"
|
|
"github.com/bloeys/nterm/ring"
|
|
"github.com/golang/freetype/truetype"
|
|
"github.com/veandco/go-sdl2/sdl"
|
|
"golang.org/x/exp/constraints"
|
|
"golang.org/x/image/font"
|
|
)
|
|
|
|
type Settings struct {
|
|
DefaultColor gglm.Vec4
|
|
StringColor gglm.Vec4
|
|
|
|
MaxFps int
|
|
LimitFps bool
|
|
}
|
|
|
|
type Cmd struct {
|
|
C *exec.Cmd
|
|
Stdout io.ReadCloser
|
|
Stdin io.WriteCloser
|
|
Stderr io.ReadCloser
|
|
}
|
|
|
|
// Para represents a paragraph, a series of characters between two new-lines.
|
|
// The indices are in terms of total written elements to the ring buffer
|
|
type Para struct {
|
|
StartIndex_WriteCount uint64
|
|
EndIndex_WriteCount uint64
|
|
}
|
|
|
|
func (l *Para) Size() uint64 {
|
|
size := l.EndIndex_WriteCount - l.StartIndex_WriteCount
|
|
return size
|
|
}
|
|
|
|
var _ engine.Game = &nterm{}
|
|
|
|
type nterm struct {
|
|
win *engine.Window
|
|
rend *rend3dgl.Rend3DGL
|
|
imguiInfo nmageimgui.ImguiInfo
|
|
|
|
FontSize uint32
|
|
Dpi float64
|
|
GlyphRend *glyphs.GlyphRend
|
|
|
|
gridMesh *meshes.Mesh
|
|
gridMat *materials.Material
|
|
|
|
ParaBeingParsed Para
|
|
Paras *ring.Buffer[Para]
|
|
|
|
textBuf *ring.Buffer[byte]
|
|
textBufMutex sync.Mutex
|
|
|
|
cmdBuf []rune
|
|
cmdBufLen int64
|
|
|
|
cursorCharIndex int64
|
|
// lastCmdCharPos is the screen pos of the last cmdBuf char drawn this frame
|
|
lastCmdCharPos *gglm.Vec3
|
|
scrollPosRel int64
|
|
scrollSpd int64
|
|
|
|
CellCountX int64
|
|
CellCountY int64
|
|
CellCount int64
|
|
|
|
activeCmd *Cmd
|
|
Settings *Settings
|
|
|
|
frameStartTime time.Time
|
|
|
|
SepLinePos gglm.Vec3
|
|
|
|
firstValidPara *Para
|
|
}
|
|
|
|
const (
|
|
subPixelX = 64
|
|
subPixelY = 64
|
|
hinting = font.HintingNone
|
|
|
|
defaultCmdBufSize = 4 * 1024
|
|
defaultParaBufSize = 10 * 1024 // Max number of paragraphs
|
|
defaultTextBufSize = 8 * 1024 * 1024
|
|
|
|
defaultScrollSpd = 1
|
|
)
|
|
|
|
var (
|
|
drawGrid bool
|
|
drawManyLines = false
|
|
|
|
textToShow = ""
|
|
|
|
xOff float32 = 0
|
|
yOff float32 = 0
|
|
)
|
|
|
|
func main() {
|
|
|
|
err := engine.Init()
|
|
if err != nil {
|
|
panic("Failed to init engine. Err: " + err.Error())
|
|
}
|
|
|
|
rend := rend3dgl.NewRend3DGL()
|
|
win, err := engine.CreateOpenGLWindowCentered("nTerm", 1280, 720, engine.WindowFlags_ALLOW_HIGHDPI|engine.WindowFlags_RESIZABLE, rend)
|
|
if err != nil {
|
|
panic("Failed to create window. Err: " + err.Error())
|
|
}
|
|
|
|
// We do our own fps limiting because (at least some) drivers vsync by doing a busy loop and spiking
|
|
// CPU to 100% doing nothing instead of a sleep
|
|
engine.SetVSync(false)
|
|
|
|
p := &nterm{
|
|
win: win,
|
|
rend: rend,
|
|
imguiInfo: nmageimgui.NewImGUI(),
|
|
FontSize: 40,
|
|
|
|
Paras: ring.NewBuffer[Para](defaultParaBufSize),
|
|
|
|
textBuf: ring.NewBuffer[byte](defaultTextBufSize),
|
|
|
|
cursorCharIndex: 0,
|
|
lastCmdCharPos: gglm.NewVec3(0, 0, 0),
|
|
cmdBuf: make([]rune, defaultCmdBufSize),
|
|
cmdBufLen: 0,
|
|
|
|
scrollSpd: defaultScrollSpd,
|
|
|
|
Settings: &Settings{
|
|
DefaultColor: *gglm.NewVec4(1, 1, 1, 1),
|
|
StringColor: *gglm.NewVec4(242/255.0, 244/255.0, 10/255.0, 1),
|
|
MaxFps: 120,
|
|
LimitFps: true,
|
|
},
|
|
|
|
firstValidPara: &Para{},
|
|
}
|
|
|
|
p.win.EventCallbacks = append(p.win.EventCallbacks, p.handleSDLEvent)
|
|
|
|
//Don't flash white
|
|
p.win.SDLWin.GLSwap()
|
|
|
|
if consts.Mode_Debug {
|
|
var pf, _ = os.Create("pprof.cpu")
|
|
defer pf.Close()
|
|
pprof.StartCPUProfile(pf)
|
|
}
|
|
|
|
engine.Run(p, p.win, p.imguiInfo)
|
|
|
|
if consts.Mode_Debug {
|
|
pprof.StopCPUProfile()
|
|
}
|
|
}
|
|
|
|
func (p *nterm) handleSDLEvent(e sdl.Event) {
|
|
|
|
switch e := e.(type) {
|
|
|
|
case *sdl.TextInputEvent:
|
|
p.WriteToCmdBuf([]rune(e.GetText()))
|
|
case *sdl.WindowEvent:
|
|
if e.Event == sdl.WINDOWEVENT_SIZE_CHANGED {
|
|
p.HandleWindowResize()
|
|
}
|
|
}
|
|
}
|
|
|
|
func (p *nterm) Init() {
|
|
|
|
dpi, _, _, err := sdl.GetDisplayDPI(0)
|
|
if err != nil {
|
|
panic("Failed to get display DPI. Err: " + err.Error())
|
|
}
|
|
fmt.Printf("DPI: %f, font size: %d\n", dpi, p.FontSize)
|
|
|
|
w, h := p.win.SDLWin.GetSize()
|
|
// p.GlyphRend, err = glyphs.NewGlyphRend("./res/fonts/tajawal-regular-var.ttf", &truetype.Options{Size: float64(p.FontSize), DPI: p.Dpi, SubPixelsX: subPixelX, SubPixelsY: subPixelY, Hinting: hinting}, w, h)
|
|
p.GlyphRend, err = glyphs.NewGlyphRend("./res/fonts/alm-fixed.ttf", &truetype.Options{Size: float64(p.FontSize), DPI: p.Dpi, SubPixelsX: subPixelX, SubPixelsY: subPixelY, Hinting: hinting}, w, h)
|
|
if err != nil {
|
|
panic("Failed to create atlas from font file. Err: " + err.Error())
|
|
}
|
|
|
|
if consts.Mode_Debug {
|
|
glyphs.SaveImgToPNG(p.GlyphRend.Atlas.Img, "./debug-atlas.png")
|
|
}
|
|
|
|
//Load resources
|
|
p.gridMesh, err = meshes.NewMesh("grid", "./res/models/quad.obj", 0)
|
|
if err != nil {
|
|
panic(err.Error())
|
|
}
|
|
|
|
p.gridMat = materials.NewMaterial("grid", "./res/shaders/grid.glsl")
|
|
p.HandleWindowResize()
|
|
|
|
//Set initial cursor pos
|
|
p.lastCmdCharPos.SetY(p.GlyphRend.Atlas.LineHeight)
|
|
}
|
|
|
|
func (p *nterm) Update() {
|
|
|
|
p.frameStartTime = time.Now()
|
|
|
|
if input.IsQuitClicked() || input.KeyClicked(sdl.K_ESCAPE) {
|
|
engine.Quit()
|
|
}
|
|
|
|
if consts.Mode_Debug {
|
|
p.DebugUpdate()
|
|
}
|
|
|
|
//Font sizing
|
|
oldFont := p.FontSize
|
|
fontSizeChanged := false
|
|
if input.KeyClicked(sdl.K_KP_PLUS) {
|
|
p.FontSize += 2
|
|
fontSizeChanged = true
|
|
} else if input.KeyClicked(sdl.K_KP_MINUS) {
|
|
p.FontSize -= 2
|
|
fontSizeChanged = true
|
|
}
|
|
|
|
if fontSizeChanged {
|
|
|
|
err := p.GlyphRend.SetFace(&truetype.Options{Size: float64(p.FontSize), DPI: p.Dpi, SubPixelsX: subPixelX, SubPixelsY: subPixelY, Hinting: hinting})
|
|
if err != nil {
|
|
p.FontSize = oldFont
|
|
fmt.Println("Failed to update font face. Err: " + err.Error())
|
|
} else {
|
|
glyphs.SaveImgToPNG(p.GlyphRend.Atlas.Img, "./debug-atlas.png")
|
|
fmt.Println("New font size:", p.FontSize, "; New texture size:", p.GlyphRend.Atlas.Img.Rect.Max.X)
|
|
}
|
|
}
|
|
|
|
p.MainUpdate()
|
|
}
|
|
|
|
func (nt *nterm) MainUpdate() {
|
|
|
|
// Keep a reference to the first valid para
|
|
if !IsParaValid(nt.textBuf, nt.firstValidPara) || nt.firstValidPara.Size() == 0 {
|
|
|
|
paraIt := nt.Paras.Iterator()
|
|
for p, done := paraIt.NextPtr(); !done; p, done = paraIt.NextPtr() {
|
|
|
|
if !IsParaValid(nt.textBuf, p) {
|
|
continue
|
|
}
|
|
|
|
nt.firstValidPara = p
|
|
break
|
|
}
|
|
}
|
|
|
|
// We might have way more chars than lines and so the first line might not start
|
|
// at the first char, but midway in the buffer, so we ensure that scrollPosRel
|
|
// starts at the first line
|
|
firstValidParaStartIndexRel := int64(nt.textBuf.RelIndexFromWriteCount(nt.firstValidPara.StartIndex_WriteCount))
|
|
if nt.scrollPosRel < firstValidParaStartIndexRel {
|
|
nt.scrollPosRel = firstValidParaStartIndexRel
|
|
}
|
|
|
|
nt.ReadInputs()
|
|
|
|
// Line separator
|
|
nt.SepLinePos.SetY(2 * nt.GlyphRend.Atlas.LineHeight)
|
|
|
|
// Draw textBuf
|
|
gw, gh := nt.GridSize()
|
|
v1, v2 := nt.textBuf.ViewsFromToRelIndex(uint64(nt.scrollPosRel), uint64(nt.scrollPosRel)+uint64(gw*gh))
|
|
|
|
nt.lastCmdCharPos.Data = gglm.NewVec3(0, float32(nt.GlyphRend.ScreenHeight)-nt.GlyphRend.Atlas.LineHeight, 0).Data
|
|
nt.lastCmdCharPos.Data = nt.DrawTextAnsiCodes(v1, *nt.lastCmdCharPos).Data
|
|
nt.lastCmdCharPos.Data = nt.DrawTextAnsiCodes(v2, *nt.lastCmdCharPos).Data
|
|
|
|
// Draw cmd buf
|
|
nt.lastCmdCharPos.SetX(0)
|
|
nt.lastCmdCharPos.SetY(nt.SepLinePos.Y() - nt.GlyphRend.Atlas.LineHeight)
|
|
nt.lastCmdCharPos.Data = nt.SyntaxHighlightAndDraw(nt.cmdBuf[:nt.cmdBufLen], *nt.lastCmdCharPos).Data
|
|
}
|
|
|
|
func (nt *nterm) ReadInputs() {
|
|
|
|
if input.KeyClicked(sdl.K_RETURN) || input.KeyClicked(sdl.K_KP_ENTER) {
|
|
nt.cursorCharIndex = nt.cmdBufLen // This is so \n is written to the end of the cmdBuf
|
|
nt.WriteToCmdBuf([]rune{'\n'})
|
|
nt.HandleReturn()
|
|
}
|
|
|
|
// Cursor movement and scroll
|
|
if input.KeyClicked(sdl.K_LEFT) {
|
|
nt.cursorCharIndex = clamp(nt.cursorCharIndex-1, 0, nt.cmdBufLen)
|
|
} else if input.KeyClicked(sdl.K_RIGHT) {
|
|
nt.cursorCharIndex = clamp(nt.cursorCharIndex+1, 0, nt.cmdBufLen)
|
|
}
|
|
|
|
if input.KeyClicked(sdl.K_HOME) {
|
|
nt.cursorCharIndex = 0
|
|
} else if input.KeyClicked(sdl.K_END) {
|
|
nt.cursorCharIndex = nt.cmdBufLen
|
|
}
|
|
|
|
if input.KeyDown(sdl.K_LCTRL) && input.KeyClicked(sdl.K_END) {
|
|
nt.scrollPosRel = nt.textBuf.Len - 1
|
|
} else if input.KeyDown(sdl.K_LCTRL) && input.KeyClicked(sdl.K_HOME) {
|
|
nt.scrollPosRel = 0
|
|
}
|
|
|
|
if mouseWheelYNorm := -int64(input.GetMouseWheelYNorm()); mouseWheelYNorm != 0 {
|
|
|
|
charsPerLine, _ := nt.GridSize()
|
|
if mouseWheelYNorm < 0 {
|
|
nt.scrollPosRel = FindNLinesIndexIterator(nt.textBuf.Iterator(), nt.Paras.Iterator(), nt.scrollPosRel, -nt.scrollSpd, charsPerLine-1)
|
|
} else {
|
|
nt.scrollPosRel = FindNLinesIndexIterator(nt.textBuf.Iterator(), nt.Paras.Iterator(), nt.scrollPosRel, nt.scrollSpd, charsPerLine-1)
|
|
}
|
|
|
|
nt.scrollPosRel = clamp(nt.scrollPosRel, int64(nt.textBuf.RelIndexFromWriteCount(nt.firstValidPara.StartIndex_WriteCount)), nt.textBuf.Len-1)
|
|
}
|
|
|
|
// Delete inputs
|
|
// @TODO: Implement hold to delete
|
|
if input.KeyClicked(sdl.K_BACKSPACE) {
|
|
nt.DeletePrevChar()
|
|
}
|
|
|
|
if input.KeyClicked(sdl.K_DELETE) {
|
|
nt.DeleteNextChar()
|
|
}
|
|
}
|
|
|
|
func (p *nterm) DrawTextAnsiCodes(bs []byte, pos gglm.Vec3) gglm.Vec3 {
|
|
|
|
currColor := p.Settings.DefaultColor
|
|
|
|
draw := func(rs []rune) {
|
|
|
|
startIndex := 0
|
|
for i := 0; i < len(rs); i++ {
|
|
|
|
r := rs[i]
|
|
|
|
// @PERF We could probably use bytes.IndexByte here
|
|
if r == '\n' {
|
|
pos.Data = p.GlyphRend.DrawTextOpenGLAbsRectWithStartPos(rs[startIndex:i], &pos, gglm.NewVec3(0, 0, 0), gglm.NewVec2(float32(p.GlyphRend.ScreenWidth), 2*p.GlyphRend.Atlas.LineHeight), &currColor).Data
|
|
pos.SetX(0)
|
|
pos.AddY(-p.GlyphRend.Atlas.LineHeight)
|
|
startIndex = i + 1
|
|
continue
|
|
}
|
|
}
|
|
|
|
if startIndex < len(rs) {
|
|
pos.Data = p.GlyphRend.DrawTextOpenGLAbsRectWithStartPos(rs[startIndex:], &pos, gglm.NewVec3(0, 0, 0), gglm.NewVec2(float32(p.GlyphRend.ScreenWidth), 2*p.GlyphRend.Atlas.LineHeight), &currColor).Data
|
|
}
|
|
}
|
|
|
|
for {
|
|
|
|
index, code := ansi.NextAnsiCode(bs)
|
|
if index == -1 {
|
|
draw(bytesToRunes(bs))
|
|
break
|
|
}
|
|
|
|
// Draw text before the code
|
|
before := bytesToRunes(bs[:index])
|
|
draw(before)
|
|
|
|
//Apply code
|
|
info := ansi.InfoFromAnsiCode(code)
|
|
if info.Options&ansi.AnsiCodeOptions_ColorFg != 0 {
|
|
|
|
if info.Info1.X() == -1 {
|
|
currColor = p.Settings.DefaultColor
|
|
} else {
|
|
currColor = info.Info1
|
|
}
|
|
}
|
|
|
|
// Advance beyond the code chars
|
|
bs = bs[index+len(code):]
|
|
}
|
|
|
|
return pos
|
|
}
|
|
|
|
func (p *nterm) SyntaxHighlightAndDraw(text []rune, pos gglm.Vec3) gglm.Vec3 {
|
|
|
|
startIndex := 0
|
|
startPos := pos.Clone()
|
|
currColor := &p.Settings.DefaultColor
|
|
|
|
inSingleString := false
|
|
inDoubleString := false
|
|
for i := 0; i < len(text); i++ {
|
|
|
|
r := text[i]
|
|
switch r {
|
|
|
|
// Text might be drawn in multiple calls, once per color for example. If the first half
|
|
// of the text gets drawn and the second half has a newline, the renderer will reset the X pos
|
|
// to the middle of the text not the start as it uses the start X position of the second half.
|
|
// So to get correct new line handling we handle newlines here
|
|
case '\n':
|
|
pos.Data = p.GlyphRend.DrawTextOpenGLAbs(text[startIndex:i], &pos, currColor).Data
|
|
pos.SetX(startPos.X())
|
|
pos.AddY(-p.GlyphRend.Atlas.LineHeight)
|
|
startIndex = i + 1
|
|
continue
|
|
|
|
case '"':
|
|
|
|
if inSingleString {
|
|
continue
|
|
}
|
|
|
|
if !inDoubleString {
|
|
pos.Data = p.GlyphRend.DrawTextOpenGLAbs(text[startIndex:i], &pos, currColor).Data
|
|
|
|
startIndex = i
|
|
inDoubleString = true
|
|
currColor = &p.Settings.StringColor
|
|
continue
|
|
}
|
|
|
|
pos.Data = p.GlyphRend.DrawTextOpenGLAbs(text[startIndex:i+1], &pos, currColor).Data
|
|
startIndex = i + 1
|
|
inDoubleString = false
|
|
currColor = &p.Settings.DefaultColor
|
|
|
|
case '\'':
|
|
if inDoubleString {
|
|
continue
|
|
}
|
|
|
|
if !inSingleString {
|
|
pos.Data = p.GlyphRend.DrawTextOpenGLAbs(text[startIndex:i], &pos, currColor).Data
|
|
|
|
startIndex = i
|
|
inSingleString = true
|
|
currColor = &p.Settings.StringColor
|
|
continue
|
|
}
|
|
|
|
pos.Data = p.GlyphRend.DrawTextOpenGLAbs(text[startIndex:i+1], &pos, &p.Settings.StringColor).Data
|
|
startIndex = i + 1
|
|
inSingleString = false
|
|
currColor = &p.Settings.DefaultColor
|
|
}
|
|
}
|
|
|
|
if startIndex < len(text) {
|
|
if inDoubleString || inSingleString {
|
|
pos.Data = p.GlyphRend.DrawTextOpenGLAbs(text[startIndex:], &pos, &p.Settings.StringColor).Data
|
|
} else {
|
|
pos.Data = p.GlyphRend.DrawTextOpenGLAbs(text[startIndex:], &pos, &p.Settings.DefaultColor).Data
|
|
}
|
|
}
|
|
|
|
return pos
|
|
}
|
|
|
|
func (p *nterm) DeletePrevChar() {
|
|
|
|
if p.cursorCharIndex == 0 || p.cmdBufLen == 0 {
|
|
return
|
|
}
|
|
|
|
copy(p.cmdBuf[p.cursorCharIndex-1:], p.cmdBuf[p.cursorCharIndex:])
|
|
|
|
p.cmdBufLen--
|
|
p.cursorCharIndex--
|
|
}
|
|
|
|
func (p *nterm) DeleteNextChar() {
|
|
|
|
if p.cmdBufLen == 0 || p.cursorCharIndex == p.cmdBufLen {
|
|
return
|
|
}
|
|
|
|
copy(p.cmdBuf[p.cursorCharIndex:], p.cmdBuf[p.cursorCharIndex+1:])
|
|
|
|
p.cmdBufLen--
|
|
}
|
|
|
|
func (p *nterm) HandleReturn() {
|
|
|
|
cmdRunes := p.cmdBuf[:p.cmdBufLen]
|
|
p.cmdBufLen = 0
|
|
p.cursorCharIndex = 0
|
|
|
|
cmdStr := string(cmdRunes)
|
|
cmdBytes := []byte(cmdStr)
|
|
p.WriteToTextBuf(cmdBytes)
|
|
|
|
if p.activeCmd != nil {
|
|
|
|
// println("Wrote:", string(cmdBytes))
|
|
_, err := p.activeCmd.Stdin.Write(cmdBytes)
|
|
if err != nil {
|
|
p.WriteToTextBuf([]byte(fmt.Sprintf("Writing to stdin pipe of '%s' failed. Error: %s\n", p.activeCmd.C.Path, err.Error())))
|
|
p.ClearActiveCmd()
|
|
return
|
|
}
|
|
|
|
return
|
|
}
|
|
|
|
cmdSplit := strings.Split(strings.TrimSpace(cmdStr), " ")
|
|
cmdName := cmdSplit[0]
|
|
var args []string
|
|
if len(cmdSplit) >= 2 {
|
|
args = cmdSplit[1:]
|
|
}
|
|
|
|
cmd := exec.Command(cmdName, args...)
|
|
if runtime.GOOS == "windows" {
|
|
cmd.SysProcAttr = &syscall.SysProcAttr{
|
|
CmdLine: strings.TrimSpace(cmdStr),
|
|
}
|
|
}
|
|
|
|
outPipe, err := cmd.StdoutPipe()
|
|
if err != nil {
|
|
p.WriteToTextBuf([]byte(fmt.Sprintf("Creating stdout pipe of '%s' failed. Error: %s\n", cmdName, err.Error())))
|
|
return
|
|
}
|
|
|
|
inPipe, err := cmd.StdinPipe()
|
|
if err != nil {
|
|
p.WriteToTextBuf([]byte(fmt.Sprintf("Creating stdin pipe of '%s' failed. Error: %s\n", cmdName, err.Error())))
|
|
return
|
|
}
|
|
|
|
errPipe, err := cmd.StderrPipe()
|
|
if err != nil {
|
|
p.WriteToTextBuf([]byte(fmt.Sprintf("Creating stderr pipe of '%s' failed. Error: %s\n", cmdName, err.Error())))
|
|
return
|
|
}
|
|
|
|
startTime := time.Now()
|
|
err = cmd.Start()
|
|
if err != nil {
|
|
p.WriteToTextBuf([]byte(fmt.Sprintf("Running '%s' failed. Error: %s\n", cmdName, err.Error())))
|
|
return
|
|
}
|
|
p.activeCmd = &Cmd{
|
|
C: cmd,
|
|
Stdout: outPipe,
|
|
Stdin: inPipe,
|
|
Stderr: errPipe,
|
|
}
|
|
|
|
//Stdout
|
|
go func() {
|
|
|
|
defer func() {
|
|
fmt.Printf("Cmd '%s' took %0.2fs\n", cmdName, time.Since(startTime).Seconds())
|
|
}()
|
|
|
|
defer p.ClearActiveCmd()
|
|
buf := make([]byte, 4*1024)
|
|
for p.activeCmd != nil {
|
|
|
|
readBytes, err := p.activeCmd.Stdout.Read(buf)
|
|
if err != nil {
|
|
|
|
if err == io.EOF {
|
|
break
|
|
}
|
|
|
|
p.WriteToTextBuf([]byte("Stdout pipe failed. Error: " + err.Error()))
|
|
return
|
|
}
|
|
|
|
if readBytes == 0 {
|
|
continue
|
|
}
|
|
|
|
// @Todo We need to parse ansi codes as data is coming in to update the drawing settings (e.g. color)
|
|
b := buf[:readBytes]
|
|
p.WriteToTextBuf(b)
|
|
// println("Read:", string(buf[:readBytes]))
|
|
}
|
|
}()
|
|
|
|
//Stderr
|
|
go func() {
|
|
|
|
buf := make([]byte, 1024)
|
|
for p.activeCmd != nil {
|
|
|
|
readBytes, err := p.activeCmd.Stderr.Read(buf)
|
|
if err != nil {
|
|
|
|
if err == io.EOF {
|
|
break
|
|
}
|
|
|
|
p.WriteToTextBuf([]byte("Stderr pipe failed. Error: " + err.Error()))
|
|
return
|
|
}
|
|
|
|
if readBytes == 0 {
|
|
continue
|
|
}
|
|
|
|
p.WriteToTextBuf(buf[:readBytes])
|
|
}
|
|
}()
|
|
}
|
|
|
|
func (p *nterm) ParseParas(bs []byte) {
|
|
|
|
checkedBytes := uint64(0)
|
|
for len(bs) > 0 {
|
|
|
|
// IndexByte is assembly optimized for different platforms and is much faster than checking one byte at a time
|
|
index := bytes.IndexByte(bs, '\n')
|
|
if index == -1 {
|
|
break
|
|
}
|
|
bs = bs[index+1:]
|
|
|
|
checkedBytes += uint64(index + 1)
|
|
p.ParaBeingParsed.EndIndex_WriteCount = p.textBuf.WrittenElements + checkedBytes
|
|
p.WritePara(&p.ParaBeingParsed)
|
|
p.ParaBeingParsed.StartIndex_WriteCount = p.textBuf.WrittenElements + checkedBytes
|
|
}
|
|
}
|
|
|
|
func (p *nterm) WritePara(para *Para) {
|
|
assert.T(para.StartIndex_WriteCount <= para.EndIndex_WriteCount, "Invalid line: %+v\n", para)
|
|
p.Paras.Write(*para)
|
|
}
|
|
|
|
func IsParaValid(textBuf *ring.Buffer[byte], p *Para) bool {
|
|
isValid := textBuf.WrittenElements-p.StartIndex_WriteCount < uint64(textBuf.Cap)
|
|
return isValid
|
|
}
|
|
|
|
func (p *nterm) ClearActiveCmd() {
|
|
|
|
if p.activeCmd == nil {
|
|
return
|
|
}
|
|
|
|
p.activeCmd = nil
|
|
}
|
|
|
|
func (p *nterm) DrawCursor() {
|
|
|
|
//Position cursor by placing it at the end of the drawn characters then walking backwards
|
|
pos := p.lastCmdCharPos.Clone()
|
|
p.ScreenPosToGridPos(pos)
|
|
|
|
pos.AddY(p.GlyphRend.Atlas.LineHeight * 0.5)
|
|
for i := clamp(p.cmdBufLen, 0, int64(len(p.cmdBuf))); i > p.cursorCharIndex; i-- {
|
|
|
|
if p.cmdBuf[i] == '\n' {
|
|
pos.AddY(p.GlyphRend.Atlas.LineHeight)
|
|
continue
|
|
}
|
|
pos.AddX(-p.GlyphRend.Atlas.SpaceAdvance)
|
|
}
|
|
|
|
p.rend.Draw(p.gridMesh, gglm.NewTrMatId().Translate(pos).Scale(gglm.NewVec3(0.1*p.GlyphRend.Atlas.SpaceAdvance, p.GlyphRend.Atlas.LineHeight, 1)), p.gridMat)
|
|
}
|
|
|
|
// GridSize returns how many cells horizontally (aka chars per line) and how many cells vertically (aka lines)
|
|
func (p *nterm) GridSize() (w, h int64) {
|
|
return int64(p.GlyphRend.ScreenWidth) / int64(p.GlyphRend.Atlas.SpaceAdvance), int64(p.GlyphRend.ScreenHeight) / int64(p.GlyphRend.Atlas.LineHeight)
|
|
}
|
|
|
|
func (p *nterm) ScreenPosToGridPos(screenPos *gglm.Vec3) {
|
|
screenPos.SetX(screenPos.X() / p.GlyphRend.Atlas.SpaceAdvance * p.GlyphRend.Atlas.SpaceAdvance)
|
|
screenPos.SetY(screenPos.Y() / p.GlyphRend.Atlas.LineHeight * p.GlyphRend.Atlas.LineHeight)
|
|
}
|
|
|
|
func (p *nterm) DebugUpdate() {
|
|
|
|
//Move text
|
|
var speed float32 = 1
|
|
if input.KeyDown(sdl.K_RIGHT) {
|
|
xOff += speed
|
|
} else if input.KeyDown(sdl.K_LEFT) {
|
|
xOff -= speed
|
|
}
|
|
|
|
if input.KeyDown(sdl.K_UP) {
|
|
yOff += speed
|
|
} else if input.KeyDown(sdl.K_DOWN) {
|
|
yOff -= speed
|
|
}
|
|
|
|
//Grid
|
|
if input.KeyDown(sdl.K_LCTRL) && input.KeyClicked(sdl.K_SPACE) {
|
|
drawGrid = !drawGrid
|
|
}
|
|
}
|
|
|
|
func (p *nterm) Render() {
|
|
|
|
defer p.GlyphRend.Draw()
|
|
|
|
if consts.Mode_Debug {
|
|
p.DebugRender()
|
|
|
|
sizeX := float32(p.GlyphRend.ScreenWidth)
|
|
p.rend.Draw(p.gridMesh, gglm.NewTrMatId().Translate(gglm.NewVec3(sizeX/2, p.SepLinePos.Y(), 0)).Scale(gglm.NewVec3(sizeX, 1, 1)), p.gridMat)
|
|
}
|
|
|
|
p.DrawCursor()
|
|
}
|
|
|
|
func (p *nterm) DebugRender() {
|
|
|
|
if drawGrid {
|
|
p.DrawGrid()
|
|
}
|
|
|
|
fps := int(timing.GetAvgFPS())
|
|
if len(textToShow) > 0 {
|
|
str := textToShow
|
|
charCount := len([]rune(str))
|
|
if drawManyLines {
|
|
const charsPerFrame = 500_000
|
|
for i := 0; i < charsPerFrame/charCount; i++ {
|
|
p.GlyphRend.DrawTextOpenGLAbsString(str, gglm.NewVec3(xOff, float32(p.GlyphRend.Atlas.LineHeight)*5+yOff, 0), &p.Settings.DefaultColor)
|
|
}
|
|
p.win.SDLWin.SetTitle(fmt.Sprint("FPS: ", fps, " Draws/f: ", math.Ceil(charsPerFrame/glyphs.DefaultGlyphsPerBatch), " chars/f: ", charsPerFrame, " chars/s: ", fps*charsPerFrame))
|
|
} else {
|
|
charsPerFrame := float64(charCount)
|
|
p.GlyphRend.DrawTextOpenGLAbsString(str, gglm.NewVec3(xOff, float32(p.GlyphRend.Atlas.LineHeight)*5+yOff, 0), &p.Settings.DefaultColor)
|
|
p.win.SDLWin.SetTitle(fmt.Sprint("FPS: ", fps, " Draws/f: ", math.Ceil(charsPerFrame/glyphs.DefaultGlyphsPerBatch), " chars/f: ", int(charsPerFrame), " chars/s: ", fps*int(charsPerFrame)))
|
|
}
|
|
} else {
|
|
p.win.SDLWin.SetTitle(fmt.Sprint("FPS: ", fps))
|
|
}
|
|
}
|
|
|
|
func (p *nterm) DrawGrid() {
|
|
|
|
sizeX := float32(p.GlyphRend.ScreenWidth)
|
|
sizeY := float32(p.GlyphRend.ScreenHeight)
|
|
|
|
//columns
|
|
adv := p.GlyphRend.Atlas.SpaceAdvance
|
|
for i := 0; i < int(p.GlyphRend.ScreenWidth); i++ {
|
|
p.rend.Draw(p.gridMesh, gglm.NewTrMatId().Translate(gglm.NewVec3(adv*float32(i), sizeY/2, 0)).Scale(gglm.NewVec3(1, sizeY, 1)), p.gridMat)
|
|
}
|
|
|
|
//rows
|
|
for i := int32(0); i < p.GlyphRend.ScreenHeight; i += int32(p.GlyphRend.Atlas.LineHeight) {
|
|
p.rend.Draw(p.gridMesh, gglm.NewTrMatId().Translate(gglm.NewVec3(sizeX/2, float32(i), 0)).Scale(gglm.NewVec3(sizeX, 1, 1)), p.gridMat)
|
|
}
|
|
}
|
|
|
|
func (p *nterm) FrameEnd() {
|
|
assert.T(p.cursorCharIndex <= p.cmdBufLen, "Cursor char index is larger than cmdBufLen! You probablly forgot to move/reset the cursor index along with the buffer length somewhere. Cursor=%d, cmdBufLen=%d\n", p.cursorCharIndex, p.cmdBufLen)
|
|
|
|
if p.Settings.LimitFps {
|
|
|
|
elapsed := time.Since(p.frameStartTime)
|
|
microSecondsPerFrame := int64(1 / float32(p.Settings.MaxFps) * 1000_000)
|
|
|
|
// Sleep time is reduced by a millisecond to compensate for the (nearly) inevitable over-sleeping that will happen.
|
|
timeToSleep := time.Duration((microSecondsPerFrame - elapsed.Microseconds()) * 1000)
|
|
timeToSleep -= 1000 * time.Microsecond
|
|
|
|
if timeToSleep.Milliseconds() > 0 {
|
|
time.Sleep(timeToSleep)
|
|
}
|
|
}
|
|
}
|
|
|
|
func (p *nterm) DeInit() {
|
|
}
|
|
|
|
func (p *nterm) HandleWindowResize() {
|
|
w, h := p.win.SDLWin.GetSize()
|
|
p.GlyphRend.SetScreenSize(w, h)
|
|
|
|
projMtx := gglm.Ortho(0, float32(w), float32(h), 0, 0.1, 20)
|
|
viewMtx := gglm.LookAt(gglm.NewVec3(0, 0, -10), gglm.NewVec3(0, 0, 0), gglm.NewVec3(0, 1, 0))
|
|
p.gridMat.SetUnifMat4("projViewMat", &projMtx.Mul(viewMtx).Mat4)
|
|
|
|
p.CellCountX, p.CellCountY = p.GridSize()
|
|
p.CellCount = p.CellCountX * p.CellCountY
|
|
}
|
|
|
|
func (p *nterm) WriteToTextBuf(text []byte) {
|
|
// This is locked because running cmds are potentially writing to it same time we are
|
|
p.textBufMutex.Lock()
|
|
|
|
p.ParseParas(text)
|
|
p.textBuf.Write(text...)
|
|
|
|
p.textBufMutex.Unlock()
|
|
}
|
|
|
|
func (p *nterm) WriteToCmdBuf(text []rune) {
|
|
|
|
delta := int64(len(text))
|
|
newHeadPos := p.cmdBufLen + delta
|
|
if newHeadPos <= defaultCmdBufSize {
|
|
|
|
copy(p.cmdBuf[p.cursorCharIndex+delta:], p.cmdBuf[p.cursorCharIndex:])
|
|
copy(p.cmdBuf[p.cursorCharIndex:], text)
|
|
|
|
p.cursorCharIndex += delta
|
|
p.cmdBufLen = newHeadPos
|
|
return
|
|
}
|
|
|
|
assert.T(false, "Circular buffer not implemented for cmd buf")
|
|
}
|
|
|
|
func FloorF32(x float32) float32 {
|
|
return float32(math.Floor(float64(x)))
|
|
}
|
|
|
|
func CeilF32(x float32) float32 {
|
|
return float32(math.Ceil(float64(x)))
|
|
}
|
|
|
|
func clamp[T constraints.Ordered](x, min, max T) T {
|
|
|
|
if max < min {
|
|
min, max = max, min
|
|
}
|
|
|
|
if x < min {
|
|
return min
|
|
}
|
|
|
|
if x > max {
|
|
return max
|
|
}
|
|
|
|
return x
|
|
}
|
|
|
|
func bytesToRunes(b []byte) []rune {
|
|
|
|
runeCount := utf8.RuneCount(b)
|
|
if runeCount == 0 {
|
|
return []rune{}
|
|
}
|
|
|
|
// @PERF We should use a pre-allocated buffer here
|
|
out := make([]rune, 0, runeCount)
|
|
for {
|
|
|
|
r, size := utf8.DecodeRune(b)
|
|
if r == utf8.RuneError {
|
|
break
|
|
}
|
|
|
|
out = append(out, r)
|
|
b = b[size:]
|
|
}
|
|
|
|
return out
|
|
}
|
|
|
|
func FindNthOrLastIndex[T comparable](arr []T, x T, startIndex, n int64) (lastIndex int64) {
|
|
|
|
lastIndex = -1
|
|
if n >= 0 {
|
|
|
|
for i := startIndex; i < int64(len(arr)); i++ {
|
|
|
|
if arr[i] != x {
|
|
continue
|
|
}
|
|
lastIndex = i
|
|
|
|
n--
|
|
if n <= 0 {
|
|
return i
|
|
}
|
|
}
|
|
|
|
} else {
|
|
|
|
for i := startIndex; i >= 0; i-- {
|
|
|
|
if arr[i] != x {
|
|
continue
|
|
}
|
|
lastIndex = i
|
|
|
|
n++
|
|
if n >= 0 {
|
|
return i
|
|
}
|
|
}
|
|
}
|
|
|
|
return lastIndex
|
|
}
|
|
|
|
// FindNLinesIndexIterator starts at startIndex and moves n lines forward/backward, depending on whether 'n' is negative or positive,
|
|
// then returns the starting index of the nth line.
|
|
//
|
|
// A line is counted when either a '\n' is seen or by seeing enough chars that a wrap is required.
|
|
func FindNLinesIndexIterator(it ring.Iterator[byte], paraIt ring.Iterator[Para], startIndex, n, charsPerLine int64) (newIndex int64) {
|
|
|
|
done := false
|
|
read := 0
|
|
bytesToKeep := 0
|
|
buf := make([]byte, 4)
|
|
it.GotoIndex(startIndex)
|
|
|
|
// @Todo we should ignore zero width glyphs
|
|
// @Note is this better in glyphs package?
|
|
bytesSeen := int64(0)
|
|
charsSeenThisLine := int64(0)
|
|
|
|
if n >= 0 {
|
|
|
|
// If nothing changes (e.g. already at end of iterator) then we will stay at the same place
|
|
newIndex = startIndex
|
|
|
|
for !done || bytesToKeep > 0 {
|
|
|
|
read, done = it.NextN(buf[bytesToKeep:], 4)
|
|
|
|
r, size := utf8.DecodeRune(buf[:bytesToKeep+read])
|
|
bytesToKeep += read - size
|
|
copy(buf, buf[size:size+bytesToKeep])
|
|
|
|
charsSeenThisLine++
|
|
bytesSeen += int64(size)
|
|
|
|
// If this is true we covered one line
|
|
if charsSeenThisLine > charsPerLine || r == '\n' {
|
|
|
|
newIndex = startIndex + bytesSeen
|
|
|
|
// Don't stop at newlines, but the char right after
|
|
if charsSeenThisLine > charsPerLine {
|
|
charsSeenThisLine = 0
|
|
} else {
|
|
charsSeenThisLine = 0
|
|
}
|
|
|
|
n--
|
|
if n <= 0 {
|
|
break
|
|
}
|
|
}
|
|
}
|
|
|
|
} else {
|
|
|
|
// If on the empty line between paragraphs we want to know where the last char of the previous
|
|
// para is so we can take into account position differences with wrapping
|
|
startIndexByte := it.Buf.Get(uint64(startIndex))
|
|
startMinusOneIndexByte := it.Buf.Get(uint64(startIndex - 1))
|
|
if startIndexByte == '\n' {
|
|
|
|
if startMinusOneIndexByte == '\n' {
|
|
|
|
charsIntoLine := getCharGridPosX(it.Buf.Iterator(), paraIt, startIndex-2, charsPerLine)
|
|
if charsIntoLine > 0 {
|
|
charsSeenThisLine = charsPerLine - charsIntoLine
|
|
}
|
|
}
|
|
}
|
|
|
|
// Skip the extra new line so the decoder starts with normal characters instead of seeing a newline
|
|
// and immediately quitting
|
|
if startIndexByte == '\n' || startMinusOneIndexByte == '\n' {
|
|
it.Prev()
|
|
}
|
|
|
|
for !done || bytesToKeep > 0 {
|
|
|
|
read, done = it.PrevN(buf[bytesToKeep:], 4)
|
|
|
|
r, size := utf8.DecodeRune(buf[:bytesToKeep+read])
|
|
bytesToKeep += read - size
|
|
copy(buf, buf[size:size+bytesToKeep])
|
|
|
|
charsSeenThisLine++
|
|
bytesSeen += int64(size)
|
|
|
|
// If this is true we covered one line
|
|
if charsSeenThisLine > charsPerLine || r == '\n' {
|
|
|
|
newIndex = startIndex - bytesSeen
|
|
|
|
n++
|
|
if n >= 0 {
|
|
break
|
|
}
|
|
|
|
charsSeenThisLine = 1
|
|
}
|
|
}
|
|
|
|
// If we reached beginning of buffer before finding a new line then newIndex is zero
|
|
if startIndex-bytesSeen == 0 {
|
|
newIndex = 0
|
|
}
|
|
}
|
|
|
|
return newIndex
|
|
}
|
|
|
|
func getCharGridPosX(it ring.Iterator[byte], paraIt ring.Iterator[Para], textBufStartIndexRel, charsPerLine int64) int64 {
|
|
|
|
// Find para that contains the start index
|
|
para, _ := GetParaFromTextBufIndex(it, paraIt, uint64(textBufStartIndexRel))
|
|
if para == nil {
|
|
return 0
|
|
}
|
|
|
|
// println("-----------------------------------", it.Buf.RelIndexFromWriteCount(para.StartIndex_WriteCount), it.Buf.Get(uint64(textBufStartIndexRel)))
|
|
// PrintPara(it.Buf, para)
|
|
// println("-----------------------------------", it.Buf.RelIndexFromWriteCount(para.EndIndex_WriteCount), "\n")
|
|
|
|
// This doesn't consider non-printing chars for wrapping, but should be good enough
|
|
v1, v2 := it.Buf.ViewsFromToRelIndex(it.Buf.RelIndexFromWriteCount(para.StartIndex_WriteCount+1), uint64(textBufStartIndexRel))
|
|
runeCount := utf8.RuneCount(v1)
|
|
runeCount += utf8.RuneCount(v2)
|
|
lastCharGridPosX := runeCount % int(charsPerLine+1)
|
|
return int64(lastCharGridPosX)
|
|
}
|
|
|
|
func PrintPara(textBuf *ring.Buffer[byte], p *Para) {
|
|
|
|
if !IsParaValid(textBuf, p) {
|
|
return
|
|
}
|
|
|
|
v1, v2 := textBuf.ViewsFromToWriteCount(p.StartIndex_WriteCount, p.EndIndex_WriteCount)
|
|
fmt.Println(string(v1) + string(v2))
|
|
}
|
|
|
|
func GetParaFromTextBufIndex(it ring.Iterator[byte], paraIt ring.Iterator[Para], textBufStartIndexRel uint64) (outPara *Para, pIndex uint64) {
|
|
|
|
if paraIt.Buf.Len == 0 {
|
|
return
|
|
}
|
|
|
|
ticks := 0
|
|
|
|
//Find first valid para
|
|
paraIt.GotoStart()
|
|
for p, done := paraIt.NextPtr(); !done; p, done = paraIt.NextPtr() {
|
|
|
|
ticks++
|
|
if !IsParaValid(it.Buf, p) {
|
|
continue
|
|
}
|
|
|
|
paraIt.Prev()
|
|
break
|
|
}
|
|
|
|
// @PERF We need a faster way of finding the current paragraph. Binary search?
|
|
for p, done := paraIt.NextPtr(); !done; p, done = paraIt.NextPtr() {
|
|
|
|
ticks++
|
|
startIndexRel := it.Buf.RelIndexFromWriteCount(p.StartIndex_WriteCount)
|
|
endIndexRel := it.Buf.RelIndexFromWriteCount(p.EndIndex_WriteCount)
|
|
if textBufStartIndexRel < startIndexRel || textBufStartIndexRel > endIndexRel {
|
|
continue
|
|
}
|
|
|
|
outPara = p
|
|
pIndex = paraIt.CurrToRelIndex()
|
|
break
|
|
}
|
|
|
|
// println("Ticks to finding para:", ticks)
|
|
|
|
if outPara == nil {
|
|
panic("Could not find para")
|
|
}
|
|
|
|
return outPara, pIndex
|
|
}
|