supersonic/backend/mpmedia_mac.go

//go:build darwin

package backend

/**
* This file handles implementation of MacOS native controls via the native 'MediaPlayer' framework
**/

/*
#cgo CFLAGS: -x objective-c -I/opt/homebrew/include -I/opt/local/include
#cgo LDFLAGS: -framework Cocoa -framework MediaPlayer -L/opt/homebrew/lib -L/opt/local/lib
#include "mpmediabridge.h"
*/
import (
	"C"
)

import (
	"log"
	"strings"
	"unsafe"

	"github.com/dweymouth/supersonic/backend/mediaprovider"
)

// os_remote_command_callback is called by Objective-C when incoming OS media commands are received.
//
//export os_remote_command_callback
func os_remote_command_callback(command C.Command, value C.double) {
	switch command {
	case C.PLAY:
		mpMediaEventRecipient.OnCommandPlay()
	case C.PAUSE:
		mpMediaEventRecipient.OnCommandPause()
	case C.STOP:
		mpMediaEventRecipient.OnCommandStop()
	case C.TOGGLE:
		mpMediaEventRecipient.OnCommandTogglePlayPause()
	case C.PREVIOUS_TRACK:
		mpMediaEventRecipient.OnCommandPreviousTrack()
	case C.NEXT_TRACK:
		mpMediaEventRecipient.OnCommandNextTrack()
	case C.SEEK:
		mpMediaEventRecipient.OnCommandSeek(float64(value))
	default:
		log.Printf("unknown OS command received: %v", command)
	}
}

// MPMediaHandler is the handler for MacOS media controls and system events.
type MPMediaHandler struct {
	playbackManager *PlaybackManager
	artURLLookup    func(string) (string, error)
}

// global recipient for Object-C callbacks from command center.
// This is global so that it can be called from 'os_remote_command_callback' to avoid passing Go pointers into C.
var mpMediaEventRecipient *MPMediaHandler

// NewMPMediaHandler creates a new MPMediaHandler instances and sets it as the current recipient
// for incoming system events.
func InitMPMediaHandler(playbackManager *PlaybackManager, artURLLookup func(trackID string) (string, error)) error {
	mp := &MPMediaHandler{
		playbackManager: playbackManager,
		artURLLookup:    artURLLookup,
	}

	// register remote commands and set callback target
	mpMediaEventRecipient = mp
	C.register_os_remote_commands()

	mp.playbackManager.OnSongChange(func(item mediaprovider.MediaItem, _ *mediaprovider.Track) {
		// Asynchronously because artwork fetching can take time
		var meta *mediaprovider.MediaItemMetadata
		if item != nil {
			m := item.Metadata()
			meta = &m
		}
		go mp.updateMetadata(meta)
	})
	mp.playbackManager.OnRadioMetadataChange(func(radioName, title, artist string) {
		if title != "" {
			go mp.updateMetadata(&mediaprovider.MediaItemMetadata{
				Name:    title,
				Artists: []string{artist},
				Album:   radioName,
			})
		} else {
			go mp.updateMetadata(&mediaprovider.MediaItemMetadata{
				Name: radioName,
			})
		}
	})

	mp.playbackManager.OnStopped(func() {
		C.set_os_playback_state_stopped()
	})

	mp.playbackManager.OnSeek(func() {
		C.update_os_now_playing_info_position(C.double(mp.playbackManager.PlaybackStatus().TimePos))
	})

	mp.playbackManager.OnPlaying(func() {
		C.set_os_playback_state_playing()
		C.update_os_now_playing_info_position(C.double(mp.playbackManager.PlaybackStatus().TimePos))
	})

	mp.playbackManager.OnPaused(func() {
		C.set_os_playback_state_paused()
		C.update_os_now_playing_info_position(C.double(mp.playbackManager.PlaybackStatus().TimePos))
	})

	return nil
}

func (mp *MPMediaHandler) updateMetadata(meta *mediaprovider.MediaItemMetadata) {
	var title, artist, artURL string
	var duration int
	if meta != nil {
		title = meta.Name
		artist = strings.Join(meta.Artists, ", ")
		duration = int(meta.Duration.Seconds())
	}
	if meta != nil && meta.ID != "" {
		var err error
		if artURL, err = mp.artURLLookup(meta.CoverArtID); err != nil {
			if meta.CoverArtID != "" {
				log.Printf("error fetching art url: %s", err.Error())
			}
		}
	}

	cTitle := C.CString(title)
	defer C.free(unsafe.Pointer(cTitle))

	cArtist := C.CString(artist)
	defer C.free(unsafe.Pointer(cArtist))

	cArtURL := C.CString(artURL)
	defer C.free(unsafe.Pointer(cArtURL))

	cTrackDuration := C.double(duration)

	C.set_os_now_playing_info(cTitle, cArtist, cArtURL, cTrackDuration)
}

/**
* Handle incoming OS commands.
**/

// MPMediaHandler instance received OS command 'pause'
func (mp *MPMediaHandler) OnCommandPause() {
	if mp == nil || mp.playbackManager == nil {
		return
	}
	mp.playbackManager.Pause()
}

// MPMediaHandler instance received OS command 'play'
func (mp *MPMediaHandler) OnCommandPlay() {
	if mp == nil || mp.playbackManager == nil {
		return
	}
	mp.playbackManager.Continue()
}

// MPMediaHandler instance received OS command 'stop'
func (mp *MPMediaHandler) OnCommandStop() {
	if mp == nil || mp.playbackManager == nil {
		return
	}
	mp.playbackManager.Stop()
}

// MPMediaHandler instance received OS command 'toggle'
func (mp *MPMediaHandler) OnCommandTogglePlayPause() {
	if mp == nil || mp.playbackManager == nil {
		return
	}
	mp.playbackManager.PlayPause()
}

// MPMediaHandler instance received OS command 'next track'
func (mp *MPMediaHandler) OnCommandNextTrack() {
	if mp == nil || mp.playbackManager == nil {
		return
	}
	mp.playbackManager.SeekNext()
}

// MPMediaHandler instance received OS command 'previous track'
func (mp *MPMediaHandler) OnCommandPreviousTrack() {
	if mp == nil || mp.playbackManager == nil {
		return
	}
	mp.playbackManager.SeekBackOrPrevious()
}

// MPMediaHandler instance received OS command to 'seek'
func (mp *MPMediaHandler) OnCommandSeek(positionSeconds float64) {
	if mp == nil || mp.playbackManager == nil {
		return
	}
	mp.playbackManager.SeekSeconds(positionSeconds)
}