1 /*
2  * Copyright (c) 2022 Omar Polo <op@openbsd.org>
3  *
4  * Permission to use, copy, modify, and distribute this software for any
5  * purpose with or without fee is hereby granted, provided that the above
6  * copyright notice and this permission notice appear in all copies.
7  *
8  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
9  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
10  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
11  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
12  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
13  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
14  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
15  */
16 
17 #include "config.h"
18 
19 #include <sys/mman.h>
20 #include <sys/stat.h>
21 
22 #include <limits.h>
23 #include <stdio.h>
24 #include <unistd.h>
25 
26 #include <mpg123.h>
27 
28 #include "amused.h"
29 #include "log.h"
30 
31 static int
32 setup(mpg123_handle *mh)
33 {
34 	long	rate;
35 	int	chan, enc;
36 
37 	if (mpg123_getformat(mh, &rate, &chan, &enc) != MPG123_OK) {
38 		log_warnx("mpg123_getformat failed");
39 		return 0;
40 	}
41 
42 	if (player_setup(mpg123_encsize(enc) * 8, rate, chan) == -1)
43 		err(1, "player_setup");
44 
45 	return 1;
46 }
47 
48 int
49 play_mp3(int fd, const char **errstr)
50 {
51 	static char	 buf[4096];
52 	size_t		 len;
53 	mpg123_handle	*mh;
54 	int64_t		 seek = -1;
55 	int		 err, ret = -1;
56 
57 	if ((mh = mpg123_new(NULL, NULL)) == NULL)
58 		fatal("mpg123_new");
59 
60 	if (mpg123_open_fd(mh, fd) != MPG123_OK) {
61 		*errstr = "mpg123_open_fd failed";
62 		close(fd);
63 		return -1;
64 	}
65 
66 	if (!setup(mh))
67 		goto done;
68 
69 	player_setduration(mpg123_length(mh));
70 
71 	for (;;) {
72 		if (seek != -1) {
73 			seek = mpg123_seek(mh, seek, SEEK_SET);
74 			if (seek < 0) {
75 				ret = 0;
76 				break;
77 			}
78 			player_setpos(seek);
79 		}
80 
81 		err = mpg123_read(mh, buf, sizeof(buf), &len);
82 		switch (err) {
83 		case MPG123_DONE:
84 			ret = 0;
85 			goto done;
86 		case MPG123_NEW_FORMAT:
87 			if (!setup(mh))
88 				goto done;
89 			break;
90 		case MPG123_OK:
91 			if (!play(buf, len, &seek)) {
92 				ret = 1;
93 				goto done;
94 			}
95 			break;
96 		default:
97 			log_warnx("skipping mp3 decoding error");
98 			break;
99 		}
100 	}
101 
102 done:
103 	mpg123_delete(mh);
104 	close(fd);
105 	return ret;
106 }