/*
 * Copyright (c) 2019 Intel Corporation
 *
 * SPDX-License-Identifier: Apache-2.0
 */

#define LOG_LEVEL LOG_LEVEL_INF
#include <logging/log.h>
LOG_MODULE_REGISTER(audio_core);

#include <zephyr.h>
#include "audio_core.h"

/*
 * stereo mic in
 * stereo host in
 * stereo speaker out
 * stereo host out
 */
#define AUDIO_ACTIVE_CHANNELS	2

/* core audio processing buffers with interleaved samples */
static int32_t mic_input[AUDIO_ACTIVE_CHANNELS][AUDIO_SAMPLES_PER_FRAME];
static int32_t host_input[AUDIO_ACTIVE_CHANNELS][AUDIO_SAMPLES_PER_FRAME];

static bool tuning_reply_ready;
static uint32_t *tuning_command_buffer;
static uint32_t tuning_cmd_buf_size_in_words;

#define CMD_START_AUDIO		1
#define CMD_STOP_AUDIO		2

int audio_core_initialize(void)
{
	return 0;
}

int audio_core_process_mic_source(int32_t *buffer, int channels)
{
	int sample;
	int channel;
	int32_t *read;

	read = buffer;

	/* copy audio samples from mic source buffer to mic_input */
	for (sample = 0; sample < AUDIO_SAMPLES_PER_FRAME; sample++) {
		for (channel = 0; channel < AUDIO_ACTIVE_CHANNELS; channel++) {
			mic_input[channel][sample] = read[channel];
		}
		read += channels;
	}

	return 0;
}

int audio_core_process_host_source(int32_t *buffer, int channels)
{
	int sample;
	int channel;
	int32_t *read;

	read = buffer;

	/* copy audio samples from host source buffer to host_input */
	for (sample = 0; sample < AUDIO_SAMPLES_PER_FRAME; sample++) {
		for (channel = 0; channel < AUDIO_ACTIVE_CHANNELS; channel++) {
			host_input[channel][sample] = read[channel];
		}
		read += channels;
	}

	return 0;
}

int audio_core_process_speaker_sink(int32_t *buffer, int channels)
{
	int sample;
	int channel;
	int32_t *write;

	write = buffer;

	/* copy audio samples from host_input to speaker sink buffer */
	for (sample = 0; sample < AUDIO_SAMPLES_PER_FRAME; sample++) {
		for (channel = 0; channel < AUDIO_ACTIVE_CHANNELS; channel++) {
			write[channel] = host_input[channel][sample];
		}
		write += channels;
	}

	return 0;
}

int audio_core_process_host_sink(int32_t *buffer, int channels)
{
	int sample;
	int channel;
	int32_t *write;

	write = buffer;

	/* copy audio samples from mic_input to host sink buffer */
	for (sample = 0; sample < AUDIO_SAMPLES_PER_FRAME; sample++) {
		for (channel = 0; channel < AUDIO_ACTIVE_CHANNELS; channel++) {
			write[channel] = mic_input[channel][sample];
		}
		write += channels;
	}

	return 0;
}

int audio_core_notify_frame_tick(void)
{
	return 0;
}

int audio_core_tuning_interface_init(uint32_t *command_buffer, uint32_t size_in_words)
{
	tuning_command_buffer = command_buffer;
	tuning_cmd_buf_size_in_words = size_in_words;
	return 0;
}

int audio_core_notify_tuning_cmd(void)
{
	uint32_t first_word = *((uint32_t *)tuning_command_buffer);
	uint32_t command = (first_word << 16) >> 16;

	switch (command) {
	case CMD_START_AUDIO:
		audio_driver_start();
		break;

	case CMD_STOP_AUDIO:
		audio_driver_stop();
		break;

	default:
		LOG_INF("Unknown command %d", command);
	}

	tuning_reply_ready = true;
	return 0;
}

bool audio_core_is_tuning_reply_ready(void)
{
	if (tuning_reply_ready == true) {
		tuning_reply_ready = false;
		return true;
	}

	return false;
}

int audio_core_process_background_tasks(void)
{
	return 0;
}

int audio_core_process_small_blocks(void)
{
	return 0;
}

int audio_core_process_large_blocks(void)
{
	return 0;
}