add timer

Author: hai.lin

event.go

@@ -91,6 +91,7 @@ func (p *eventSink) call(wait bool, data interface{}, doSth func(*eventSink)) {
 
 type eventSinkMgr struct {
 	allWhenStart           *eventSink
+	allWhenTimer           *eventSink
 	allWhenKeyPressed      *eventSink
 	allWhenIReceive        *eventSink
 	allWhenBackdropChanged *eventSink
@@ -102,10 +103,12 @@ type eventSinkMgr struct {
 	allWhenMoving          *eventSink
 	allWhenTurning         *eventSink
 	calledStart            bool
+	calledTimer            bool
 }
 
 func (p *eventSinkMgr) reset() {
 	p.allWhenStart = nil
+	p.allWhenTimer = nil
 	p.allWhenKeyPressed = nil
 	p.allWhenIReceive = nil
 	p.allWhenBackdropChanged = nil
@@ -121,6 +124,7 @@ func (p *eventSinkMgr) reset() {
 
 func (p *eventSinkMgr) doDeleteClone(this interface{}) {
 	p.allWhenStart = p.allWhenStart.doDeleteClone(this)
+	p.allWhenTimer = p.allWhenTimer.doDeleteClone(this)
 	p.allWhenKeyPressed = p.allWhenKeyPressed.doDeleteClone(this)
 	p.allWhenIReceive = p.allWhenIReceive.doDeleteClone(this)
 	p.allWhenBackdropChanged = p.allWhenBackdropChanged.doDeleteClone(this)
@@ -145,6 +149,17 @@ func (p *eventSinkMgr) doWhenStart() {
 	}
 }
 
+func (p *eventSinkMgr) doWhenTimer(time float64) {
+	if !p.calledTimer {
+		p.allWhenTimer.asyncCall(false, time, func(ev *eventSink) {
+			if ev.cond != nil && ev.cond(time) {
+				ev.sink.(func(float64))(time)
+				p.calledTimer = true
+			}
+		})
+	}
+}
+
 func (p *eventSinkMgr) doWhenKeyPressed(key Key) {
 	p.allWhenKeyPressed.asyncCall(false, key, func(ev *eventSink) {
 		ev.sink.(func(Key))(key)
@@ -232,6 +247,7 @@ type IEventSinks interface {
 	OnMsg__0(onMsg func(msg string, data interface{}))
 	OnMsg__1(msg string, onMsg func())
 	OnStart(onStart func())
+	OnTimer(time float64, onTimer func())
 	Stop(kind StopKind)
 }
 
@@ -274,6 +290,22 @@ func (p *eventSinks) OnStart(onStart func()) {
 	}
 }
 
+func (p *eventSinks) OnTimer(time float64, onTimer func()) {
+	p.allWhenTimer = &eventSink{
+		prev:  p.allWhenTimer,
+		pthis: p.pthis,
+		sink: func(float64) {
+			if debugEvent {
+				log.Println("==> OnTimer", time, nameOf(p.pthis))
+			}
+			onTimer()
+		},
+		cond: func(data interface{}) bool {
+			return data.(float64) >= time
+		},
+	}
+}
+
 func (p *eventSinks) OnClick(onClick func()) {
 	pthis := p.pthis
 	p.allWhenClick = &eventSink{

game.go

@@ -717,6 +717,8 @@ func (p *Game) handleEvent(event event) {
 		p.sinkMgr.doWhenKeyPressed(ev.Key)
 	case *eventStart:
 		p.sinkMgr.doWhenStart()
+	case *eventTimer:
+		p.sinkMgr.doWhenTimer(ev.time)
 	}
 }
 
@@ -738,6 +740,8 @@ func (p *Game) eventLoop(me coroutine.Thread) int {
 }
 func (p *Game) logicLoop(me coroutine.Thread) int {
 	for {
+		gtime.Tick(gtime.DeltaTime())
+
 		tempItems := p.getTempShapes()
 		for _, item := range tempItems {
 			if result, ok := item.(interface{ onUpdate(float64) }); ok {
@@ -1197,11 +1201,16 @@ func (p *Game) Wait(secs float64) {
 }
 
 func (p *Game) Timer() float64 {
-	panic("todo")
+	return gtime.Timer()
 }
 
 func (p *Game) ResetTimer() {
-	panic("todo")
+	gtime.ResetTimer()
+}
+
+func (p *Game) OnTimerGreaterThan(secs float64, call func()) {
+	engine.Wait(secs)
+	gco.WaitMainThread(call)
 }
 
 // -----------------------------------------------------------------------------

gdspx.go

@@ -85,6 +85,7 @@ func (p *Game) syncUpdateLogic() error {
 	p.startFlag.Do(func() {
 		p.fireEvent(&eventStart{})
 	})
+	p.fireEvent(&eventTimer{time: p.Timer()})
 
 	return nil
 }

input.go

@@ -246,6 +246,10 @@ type event interface{}
 
 type eventStart struct{}
 
+type eventTimer struct {
+	time float64
+}
+
 type eventKeyDown struct {
 	Key Key
 }

internal/time/timer.go

@@ -0,0 +1,17 @@
+package time
+
+var (
+	gameTimer float64
+)
+
+func Tick(deltaTime float64) {
+	gameTimer += deltaTime
+}
+
+func Timer() float64 {
+	return gameTimer
+}
+
+func ResetTimer() {
+	gameTimer = 0
+}

monitor.go

@@ -20,9 +20,11 @@ import (
 	"fmt"
 	"log"
 	"reflect"
+	"strconv"
 	"strings"
 	"syscall"
 
+	gtime "github.com/goplus/spx/internal/time"
 	"github.com/goplus/spx/internal/tools"
 	"github.com/goplus/spx/internal/ui"
 	"github.com/realdream-ai/mathf"
@@ -124,7 +126,8 @@ func getValueRef(target reflect.Value, name string, from int) reflect.Value {
 }
 
 const (
-	getVarPrefix = "getVar:"
+	getVarPrefix   = "getVar:"
+	getTimerPrefix = "getProp:"
 )
 
 func buildMonitorEval(g reflect.Value, t, val string) func() string {
@@ -142,6 +145,10 @@ func buildMonitorEval(g reflect.Value, t, val string) func() string {
 			}
 		}
 		log.Println("[WARN] Monitor: var not found -", name, target)
+	case strings.HasPrefix(val, getTimerPrefix):
+		return func() string {
+			return strconv.FormatFloat(gtime.Timer(), 'f', 3, 64)
+		}
 	default:
 		log.Println("[WARN] Monitor: unknown command -", val)
 	}