add cmd

ogg.go

@@ -30,6 +30,37 @@ func cutstream(s beep.StreamSeekCloser) {
 	}
 }
 
+// ComposeStream 组合 urls 成为单个 stream, 并留出 sil 采样间隔
+func ComposeStream(sil uint, progress func(p int), urls ...string) (sm beep.Streamer, format beep.Format, err error) {
+	var buf *beep.Buffer
+	for i, u := range urls {
+		var resp *http.Response
+		resp, err = http.Get(u)
+		if err != nil {
+			return
+		}
+		var s beep.StreamSeekCloser
+		s, format, err = vorbis.Decode(resp.Body)
+		if err != nil {
+			_ = resp.Body.Close()
+			return
+		}
+		if i == 0 {
+			buf = beep.NewBuffer(format)
+		}
+		cutstream(s)
+		buf.Append(beep.Silence(int(sil)))
+		buf.Append(s)
+		_ = s.Close()
+		if progress != nil {
+			progress((i + 1) * 100 / len(urls))
+		}
+	}
+	sm = buf.Streamer(0, buf.Len())
+	return
+}
+
+// SaveOggToFile cut leading demo text and save wav to path
 func SaveOggToFile(u, path string) error {
 	resp, err := http.Get(u)
 	if err != nil {
@@ -37,7 +68,7 @@ func SaveOggToFile(u, path string) error {
 	}
 	s, format, err := vorbis.Decode(resp.Body)
 	if err != nil {
-		resp.Body.Close()
+		_ = resp.Body.Close()
 		return err
 	}
 	defer s.Close()
@@ -50,6 +81,7 @@ func SaveOggToFile(u, path string) error {
 	return wav.Encode(f, s, format)
 }
 
+// SaveOggToWriteSeeker cut leading demo text and write wav stream to f
 func SaveOggToWriteSeeker(u string, f io.WriteSeeker) error {
 	resp, err := http.Get(u)
 	if err != nil {
@@ -57,7 +89,7 @@ func SaveOggToWriteSeeker(u string, f io.WriteSeeker) error {
 	}
 	s, format, err := vorbis.Decode(resp.Body)
 	if err != nil {
-		resp.Body.Close()
+		_ = resp.Body.Close()
 		return err
 	}
 	defer s.Close()
@@ -65,6 +97,7 @@ func SaveOggToWriteSeeker(u string, f io.WriteSeeker) error {
 	return wav.Encode(f, s, format)
 }
 
+// PlayOgg cut leading demo text and play directly
 func PlayOgg(u string) error {
 	resp, err := http.Get(u)
 	if err != nil {
@@ -72,7 +105,7 @@ func PlayOgg(u string) error {
 	}
 	s, format, err := vorbis.Decode(resp.Body)
 	if err != nil {
-		resp.Body.Close()
+		_ = resp.Body.Close()
 		return err
 	}
 	defer s.Close()