castdaemon/player.go at master · RuinedMango/castdaemon · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
package main

import (
	"io"
	"log"
	"net/http"
	"os"
	"strconv"
	"time"

	"github.com/gopxl/beep/v2"
	"github.com/gopxl/beep/v2/mp3"
	"github.com/gopxl/beep/v2/speaker"
	"github.com/mmcdole/gofeed"
)

var globalformat beep.Format
var globalstreamer beep.StreamSeekCloser
var globalresampled *beep.Resampler

func play(podcastName string, epNum uint64) {
	f, err := os.Open(downloadDir() + "/" + podcastName + "/" + strconv.FormatUint(epNum, 32) + ".mp3")
	var streamer beep.StreamSeekCloser
	var format beep.Format
	if os.IsNotExist(err) {
		streamer, format, err = mp3.Decode(playweb(podcastName, epNum))
		if err != nil {
			log.Fatal(err)
		}
	} else {
		streamer, format, err = mp3.Decode(f)
		if err != nil {
			log.Fatal(err)
		}
	}
	globalstreamer = streamer
	globalformat = format
	defer streamer.Close()

	speaker.Init(format.SampleRate, format.SampleRate.N(time.Second/10))

	resampled := beep.ResampleRatio(5, 1.0, streamer)
	globalresampled = resampled

	done := make(chan bool)
	speaker.Play(beep.Seq(resampled, beep.Callback(func() {
		done <- true
	})))

	<-done
}

func playweb(podcastName string, epNum uint64) io.ReadCloser {
	fp := gofeed.NewParser()
	content, err := os.ReadFile(programDir() + "/feeds/" + podcastName + ".rss")
	if err != nil {
		log.Fatal(err)
	}
	feed, err := fp.ParseString(string(content))
	ep := feed.Items[uint64(len(feed.Items)-1)-(epNum-1)]
	epurl := ep.Enclosures[0].URL
	resp, err := http.Get(epurl)
	if err != nil {
		log.Fatal(err)
	}
	returner := resp.Body
	return returner
}

func stop() {
	speaker.Close()
}