add test

internal/sysmediacontrol/smc_linux_test.go

@@ -0,0 +1,153 @@
+//go:build linux
+
+package sysmediacontrol
+
+import (
+	"AynaLivePlayer/core/events"
+	"AynaLivePlayer/global"
+	"AynaLivePlayer/pkg/eventbus"
+	"errors"
+	"sync"
+	"testing"
+
+	"github.com/godbus/dbus/v5"
+	"github.com/stretchr/testify/require"
+)
+
+type publishRecord struct {
+	id   string
+	data interface{}
+}
+
+type mockBus struct {
+	mu        sync.Mutex
+	published []publishRecord
+}
+
+func (m *mockBus) Start() error                                       { return nil }
+func (m *mockBus) Wait() error                                        { return nil }
+func (m *mockBus) Stop() error                                        { return nil }
+func (m *mockBus) Subscribe(string, string, string, eventbus.HandlerFunc) error {
+	return nil
+}
+func (m *mockBus) SubscribeAny(string, string, eventbus.HandlerFunc) error { return nil }
+func (m *mockBus) SubscribeOnce(string, string, string, eventbus.HandlerFunc) error {
+	return nil
+}
+func (m *mockBus) Unsubscribe(string, string) error { return nil }
+func (m *mockBus) Publish(eventID string, data interface{}) error {
+	m.mu.Lock()
+	defer m.mu.Unlock()
+	m.published = append(m.published, publishRecord{id: eventID, data: data})
+	return nil
+}
+func (m *mockBus) PublishToChannel(string, string, interface{}) error { return nil }
+func (m *mockBus) PublishEvent(*eventbus.Event) error                 { return nil }
+func (m *mockBus) Call(string, string, interface{}) (*eventbus.Event, error) {
+	return nil, errors.New("not implemented")
+}
+func (m *mockBus) Reply(*eventbus.Event, string, interface{}) error { return nil }
+
+func (m *mockBus) snapshot() []publishRecord {
+	m.mu.Lock()
+	defer m.mu.Unlock()
+	out := make([]publishRecord, len(m.published))
+	copy(out, m.published)
+	return out
+}
+
+func setupSMCTest(t *testing.T) *mockBus {
+	t.Helper()
+	oldBus := global.EventBus
+	oldSMC := linuxSMC
+	mb := &mockBus{}
+	global.EventBus = mb
+	linuxSMC = nil
+	t.Cleanup(func() {
+		global.EventBus = oldBus
+		linuxSMC = oldSMC
+	})
+	return mb
+}
+
+func TestMprisPlayerPublishesControlEvents(t *testing.T) {
+	mb := setupSMCTest(t)
+	p := &mprisPlayer{}
+
+	require.Nil(t, p.Next())
+	require.Nil(t, p.Previous())
+	require.Nil(t, p.Pause())
+	require.Nil(t, p.Play())
+	require.Nil(t, p.PlayPause())
+	require.Nil(t, p.Stop())
+	require.Nil(t, p.Seek(3_000_000))
+
+	pubs := mb.snapshot()
+	require.Len(t, pubs, 7)
+
+	require.Equal(t, events.PlayerPlayNextCmd, pubs[0].id)
+	_, ok := pubs[0].data.(events.PlayerPlayNextCmdEvent)
+	require.True(t, ok)
+
+	require.Equal(t, events.PlayerSeekCmd, pubs[1].id)
+	prevSeek, ok := pubs[1].data.(events.PlayerSeekCmdEvent)
+	require.True(t, ok)
+	require.True(t, prevSeek.Absolute)
+	require.Equal(t, 0.0, prevSeek.Position)
+
+	require.Equal(t, events.PlayerSetPauseCmd, pubs[2].id)
+	pauseEvt, ok := pubs[2].data.(events.PlayerSetPauseCmdEvent)
+	require.True(t, ok)
+	require.True(t, pauseEvt.Pause)
+
+	require.Equal(t, events.PlayerSetPauseCmd, pubs[3].id)
+	playEvt, ok := pubs[3].data.(events.PlayerSetPauseCmdEvent)
+	require.True(t, ok)
+	require.False(t, playEvt.Pause)
+
+	require.Equal(t, events.PlayerToggleCmd, pubs[4].id)
+	_, ok = pubs[4].data.(events.PlayerToggleCmdEvent)
+	require.True(t, ok)
+
+	require.Equal(t, events.PlayerSetPauseCmd, pubs[5].id)
+	stopEvt, ok := pubs[5].data.(events.PlayerSetPauseCmdEvent)
+	require.True(t, ok)
+	require.True(t, stopEvt.Pause)
+
+	require.Equal(t, events.PlayerSeekCmd, pubs[6].id)
+	seekEvt, ok := pubs[6].data.(events.PlayerSeekCmdEvent)
+	require.True(t, ok)
+	require.False(t, seekEvt.Absolute)
+	require.InDelta(t, 3.0, seekEvt.Position, 1e-6)
+}
+
+func TestMprisPlayerSetPositionTrackGuard(t *testing.T) {
+	mb := setupSMCTest(t)
+	p := &mprisPlayer{}
+
+	linuxSMC = &linuxMpris{
+		trackPath: dbus.ObjectPath("/org/mpris/MediaPlayer2/track/1"),
+	}
+
+	require.Nil(t, p.SetPosition(dbus.ObjectPath("/org/mpris/MediaPlayer2/track/2"), 5_000_000))
+	require.Len(t, mb.snapshot(), 0)
+
+	require.Nil(t, p.SetPosition(dbus.ObjectPath("/org/mpris/MediaPlayer2/track/1"), 5_000_000))
+	pubs := mb.snapshot()
+	require.Len(t, pubs, 1)
+	require.Equal(t, events.PlayerSeekCmd, pubs[0].id)
+	seekEvt, ok := pubs[0].data.(events.PlayerSeekCmdEvent)
+	require.True(t, ok)
+	require.True(t, seekEvt.Absolute)
+	require.InDelta(t, 5.0, seekEvt.Position, 1e-6)
+
+	linuxSMC.trackPath = noTrackPath
+	require.Nil(t, p.SetPosition(dbus.ObjectPath("/org/mpris/MediaPlayer2/track/whatever"), 2_000_000))
+	pubs = mb.snapshot()
+	require.Len(t, pubs, 2)
+	lastEvt, ok := pubs[1].data.(events.PlayerSeekCmdEvent)
+	require.True(t, ok)
+	require.True(t, lastEvt.Absolute)
+	require.InDelta(t, 2.0, lastEvt.Position, 1e-6)
+}
+