94 lines
2.8 KiB
Go
94 lines
2.8 KiB
Go
package mpvipc
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
|
|
"git.milar.in/milarin/channel"
|
|
)
|
|
|
|
func ObserveEndOfFile(ctx context.Context, socket string) (<-chan string, error) {
|
|
ch, err := ObserveEvent[any](ctx, socket, "end-file")
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
getReason := func(e Event[any]) string { return e.Reason }
|
|
notEmpty := func(str string) bool { return str != "" }
|
|
reasons := channel.Filter(channel.MapSuccessive(ch, getReason), notEmpty)
|
|
return reasons, nil
|
|
}
|
|
|
|
func ObserveDisplayNames(ctx context.Context, socket string) (<-chan []string, error) {
|
|
return ObserveProperty[[]string](ctx, socket, "display-names")
|
|
}
|
|
|
|
func ObserveFullscreen(ctx context.Context, socket string) (<-chan bool, error) {
|
|
return ObserveProperty[bool](ctx, socket, "fullscreen")
|
|
}
|
|
|
|
func ObservePaused(ctx context.Context, socket string) (<-chan bool, error) {
|
|
return ObserveProperty[bool](ctx, socket, "pause")
|
|
}
|
|
|
|
func ObserveFilename(ctx context.Context, socket string) (<-chan string, error) {
|
|
return ObserveProperty[string](ctx, socket, "filename")
|
|
}
|
|
|
|
func ObservePath(ctx context.Context, socket string) (<-chan string, error) {
|
|
return ObserveProperty[string](ctx, socket, "path")
|
|
}
|
|
|
|
func ObserveMediaTitle(ctx context.Context, socket string) (<-chan string, error) {
|
|
return ObserveProperty[string](ctx, socket, "media-title")
|
|
}
|
|
|
|
func ObserveFileFormat(ctx context.Context, socket string) (<-chan string, error) {
|
|
return ObserveProperty[string](ctx, socket, "file-format")
|
|
}
|
|
|
|
func ObserveDuration(ctx context.Context, socket string) (<-chan time.Duration, error) {
|
|
out, err := ObserveProperty[float64](ctx, socket, "duration")
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return channel.MapSuccessive(out, func(v float64) time.Duration {
|
|
return time.Duration(v * float64(time.Second))
|
|
}), nil
|
|
}
|
|
|
|
func ObservePercentPos(ctx context.Context, socket string) (<-chan float64, error) {
|
|
return ObserveProperty[float64](ctx, socket, "percent-pos")
|
|
}
|
|
|
|
func ObserveTimePos(ctx context.Context, socket string) (<-chan time.Duration, error) {
|
|
out, err := ObserveProperty[float64](ctx, socket, "time-pos")
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return channel.MapSuccessive(out, func(v float64) time.Duration {
|
|
return time.Duration(v * float64(time.Second))
|
|
}), nil
|
|
}
|
|
|
|
func ObserveTimeRemaining(ctx context.Context, socket string) (<-chan time.Duration, error) {
|
|
out, err := ObserveProperty[float64](ctx, socket, "time-remaining")
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return channel.MapSuccessive(out, func(v float64) time.Duration {
|
|
return time.Duration(v * float64(time.Second))
|
|
}), nil
|
|
}
|
|
|
|
func ObserveVideoFormat(ctx context.Context, socket string) (<-chan string, error) {
|
|
return ObserveProperty[string](ctx, socket, "video-format")
|
|
}
|
|
|
|
func ObservePlaybackAborted(ctx context.Context, socket string) (<-chan bool, error) {
|
|
return ObserveProperty[bool](ctx, socket, "playback-abort")
|
|
}
|