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 <sys/types.h>
18
#include <sys/queue.h>
19
#include <sys/uio.h>
20

21
#include <err.h>
22
#include <event.h>
23
#include <inttypes.h>
24
#include <limits.h>
25
#include <sndio.h>
26
#include <stdio.h>
27
#include <stdlib.h>
28
#include <stdint.h>
29
#include <imsg.h>
30

31
#include <FLAC/stream_decoder.h>
32

33
#include "amused.h"
34
#include "log.h"
35

36
static FLAC__StreamDecoderWriteStatus
37
writecb(const FLAC__StreamDecoder *decoder, const FLAC__Frame *frame,
38
    const int32_t * const *buffer, void *data)
39
{
40
	static uint8_t buf[BUFSIZ];
41
	int i;
42
	size_t len;
43

44
	for (i = 0, len = 0; i < frame->header.blocksize; ++i) {
45
		if (len+4 >= sizeof(buf)) {
46
			if (!play(buf, len))
47
				goto quit;
48
		}
49

50
		buf[len++] = buffer[0][i] & 0xff;
51
		buf[len++] = (buffer[0][i] >> 8) & 0xff;
52

53
		buf[len++] = buffer[1][i] & 0xff;
54
		buf[len++] = (buffer[1][i] >> 8) & 0xff;
55
	}
56

57
	if (len != 0 && !play(buf, len))
58
		goto quit;
59

60
	return FLAC__STREAM_DECODER_WRITE_STATUS_CONTINUE;
61
quit:
62
	return FLAC__STREAM_DECODER_WRITE_STATUS_ABORT;
63
}
64

65
static void
66
metacb(const FLAC__StreamDecoder *decoder, const FLAC__StreamMetadata *meta,
67
    void *d)
68
{
69
	uint32_t sample_rate;
70
	int channels;
71

72
	if (meta->type == FLAC__METADATA_TYPE_STREAMINFO) {
73
		sample_rate = meta->data.stream_info.sample_rate;
74
		channels = meta->data.stream_info.channels;
75

76
		if (player_setup(16, sample_rate, channels) == -1)
77
			err(1, "player_setrate");
78
	}
79
}
80

81
static void
82
errcb(const FLAC__StreamDecoder *decoder, FLAC__StreamDecoderErrorStatus status,
83
    void *data)
84
{
85
	log_warnx("flac error: %s", FLAC__StreamDecoderErrorStatusString[status]);
86
}
87

88
void
89
play_flac(int fd)
90
{
91
	FILE *f;
92
	int s, ok = 1;
93
	const char *state;
94
	FLAC__StreamDecoder *decoder = NULL;
95
	FLAC__StreamDecoderInitStatus init_status;
96

97
	if ((f = fdopen(fd, "r")) == NULL)
98
		err(1, "fdopen");
99

100
	decoder = FLAC__stream_decoder_new();
101
	if (decoder == NULL)
102
		err(1, "flac stream decoder");
103

104
	FLAC__stream_decoder_set_md5_checking(decoder, 1);
105

106
	init_status = FLAC__stream_decoder_init_FILE(decoder, f, writecb,
107
	    metacb, errcb, NULL);
108
	if (init_status != FLAC__STREAM_DECODER_INIT_STATUS_OK)
109
		errx(1, "flac decoder: %s",
110
		    FLAC__StreamDecoderInitStatusString[init_status]);
111

112
	ok = FLAC__stream_decoder_process_until_end_of_stream(decoder);
113
	s = FLAC__stream_decoder_get_state(decoder);
114
	if (!ok && s != FLAC__STREAM_DECODER_ABORTED) {
115
		state = FLAC__StreamDecoderStateString[s];
116
		log_warnx("decoding failed; state: %s", state);
117
	}
118

119
	FLAC__stream_decoder_delete(decoder);
120

121
	fclose(f);
122
}