path: root/4a-hal-utilities/4a-hal-utilities-hal-streams-handler.c

/*
 * Copyright (C) 2019 "IoT.bzh"
 * Author Jonathan Aillet <jonathan.aillet@iot.bzh>
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#define _GNU_SOURCE

#include <stdio.h>
#include <json-c/json.h>

#include <afb/afb-binding.h>

#include <ctl-config.h>

#include "4a-hal-utilities-data.h"
#include "4a-hal-utilities-appfw-responses-handler.h"
#include "4a-hal-utilities-hal-streams-handler.h"

/*******************************************************************************
 *		Actions to be call when a stream verb is called		       *
 ******************************************************************************/

void HalUtlActionOnMixer(afb_req_t request, enum ActionOnMixerType actionType)
{
	int idx, count;

	char *apiToCall;

	afb_api_t apiHandle;
	CtlConfigT *ctrlConfig;

	struct SpecificHalData *currentCtlHalData;
	struct CtlHalMixerData *currentMixerData = NULL;

	json_object *requestJson, *returnJ = NULL, *responseJ, *toReturnJ = NULL;

	if(! (apiHandle = afb_req_get_api(request))) {
		afb_req_fail(request, "api_handle", "Can't get current hal controller api handle");
		return;
	}

	if(! (ctrlConfig = (CtlConfigT *) afb_api_get_userdata(apiHandle))) {
		afb_req_fail(request, "hal_controller_config", "Can't get current hal controller config");
		return;
	}

	if(! (currentCtlHalData = (struct SpecificHalData *) getExternalData(ctrlConfig))) {
		afb_req_fail(request, "hal_controller_data", "Can't get current hal controller data");
		return;
	}

	if(! (requestJson = afb_req_json(request))) {
		afb_req_fail(request, "request_json", "Can't get request json");
		return;
	}

	if(json_object_is_type(requestJson, json_type_object) && json_object_get_object(requestJson)->count > 0)
		json_object_object_add(requestJson, "verbose", json_object_new_boolean(1));

	apiToCall = currentCtlHalData->ctlHalSpecificData->mixerApiName;
	if(! apiToCall) {
		afb_req_fail(request, "mixer_api", "Can't get mixer api");
		return;
	}

	if(currentCtlHalData->status != HAL_STATUS_READY) {
		afb_req_fail(request, "hal_not_ready", "Seems that hal is not ready");
		return;
	}

	if(! (currentMixerData = (struct CtlHalMixerData *) afb_req_get_vcbdata(request))) {
		afb_req_fail(request, "hal_call_data", "Can't get current call data");
		return;
	}

	switch(actionType) {
		case ACTION_ON_MIXER_STREAM:
			count = 1;
			break;

		case ACTION_ON_MIXER_PLAYBACK:
		case ACTION_ON_MIXER_CAPTURE:
		case ACTION_ON_MIXER_ALL_STREAM:
			count = (int) HalUtlGetNumberOfMixerDataInList(&currentMixerData);
			toReturnJ = json_object_new_object();
			break;

		default:
			afb_req_fail(request, "hal_call_data", "Can't get current call data");
			return;
	}

	for(idx = 0; idx < count; idx++) {
		if(afb_api_call_sync_legacy(apiHandle,
					    apiToCall,
					    currentMixerData->verbToCall,
					    json_object_get(requestJson),
					    &returnJ)) {
			HalUtlHandleAppFwCallErrorInRequest(request, apiToCall, currentMixerData->verbToCall, returnJ, "call_action");
			json_object_put(returnJ);
			if(toReturnJ)
				json_object_put(toReturnJ);
			return;
		}

		if(wrap_json_unpack(returnJ, "{s:o}", "response", &responseJ)) {
			afb_req_fail_f(request,
				       "Seems that %s call to api %s succeed, but no response was found in : '%s'",
				       currentMixerData->verbToCall,
				       apiToCall,
				       json_object_get_string(returnJ));
			json_object_put(returnJ);
			if(toReturnJ)
				json_object_put(toReturnJ);
			return;
		}

		// TBD JAI : When mixer events will be available, use them instead of generating events at calls
		if((actionType == ACTION_ON_MIXER_STREAM ||
		    actionType == ACTION_ON_MIXER_ALL_STREAM) &&
		   ((! currentMixerData->event) ||
		    (afb_event_push(currentMixerData->event, json_object_get(responseJ)) < 0))) {
			AFB_API_ERROR(apiHandle, "Could not generate an event for stream %s", currentMixerData->verb);
		}

		switch(actionType) {
			case ACTION_ON_MIXER_STREAM:
				toReturnJ = json_object_get(responseJ);
				break;

			case ACTION_ON_MIXER_PLAYBACK:
			case ACTION_ON_MIXER_CAPTURE:
				json_object_object_add(toReturnJ, currentMixerData->verbToCall, json_object_get(responseJ));
				break;

			case ACTION_ON_MIXER_ALL_STREAM:
				json_object_object_add(toReturnJ, currentMixerData->verb, json_object_get(responseJ));
				break;

			default:
				break;
		}

		json_object_put(returnJ);

		switch(actionType) {
			case ACTION_ON_MIXER_PLAYBACK:
			case ACTION_ON_MIXER_CAPTURE:
			case ACTION_ON_MIXER_ALL_STREAM:
				currentMixerData = currentMixerData->next;
				break;

			default:
				break;
		}
	}

	switch(actionType) {
		case ACTION_ON_MIXER_STREAM:
			afb_req_success_f(request,
					  toReturnJ,
					  "Action %s correctly transferred to %s without any error raised",
					  currentMixerData->verbToCall,
					  apiToCall);
			break;

		case ACTION_ON_MIXER_PLAYBACK:
			afb_req_success(request,
					toReturnJ,
					"Actions correctly transferred to all playbacks without any error raised");
			break;

		case ACTION_ON_MIXER_CAPTURE:
			afb_req_success(request,
					toReturnJ,
					"Actions correctly transferred to all captures without any error raised");
			break;

		case ACTION_ON_MIXER_ALL_STREAM:
			afb_req_success(request,
					toReturnJ,
					"Actions correctly transferred to all streams without any error raised");
			break;

		default:
			break;
	}
}

void HalUtlActionOnStream(afb_req_t request)
{
	HalUtlActionOnMixer(request, ACTION_ON_MIXER_STREAM);
}

void HalUtlActionOnPlayback(afb_req_t request)
{
	HalUtlActionOnMixer(request, ACTION_ON_MIXER_PLAYBACK);
}

void HalUtlActionOnCapture(afb_req_t request)
{
	HalUtlActionOnMixer(request, ACTION_ON_MIXER_CAPTURE);
}

void HalUtlActionOnAllStream(afb_req_t request)
{
	HalUtlActionOnMixer(request, ACTION_ON_MIXER_ALL_STREAM);
}

/*******************************************************************************
 *		Add stream data and verb function			       *
 ******************************************************************************/

struct CtlHalMixerData *HalUtlAddStreamDataAndCreateStreamVerb(afb_api_t apiHandle,
							       char *verb,
							       char *verbToCall,
							       char *streamCardId)
{
	json_object *streamAddedEventJ;

	CtlConfigT *ctrlConfig;

	struct SpecificHalData *currentSpecificHalData;
	struct CtlHalMixerData *createdStreamData;

	if(! apiHandle || ! verb || ! verbToCall || ! streamCardId)
		return NULL;

	if((! (ctrlConfig = (CtlConfigT *) afb_api_get_userdata(apiHandle))) ||
	   (! (currentSpecificHalData = (struct SpecificHalData *) getExternalData(ctrlConfig))) ||
	   (! currentSpecificHalData->ctlHalSpecificData))
		return NULL;

	if(! (createdStreamData = HalUtlAddMixerDataToMixerDataList(&currentSpecificHalData->ctlHalSpecificData->ctlHalStreamsData)))
		return NULL;

	createdStreamData->verb = strdup(verb);
	createdStreamData->verbToCall = strdup(verbToCall);
	createdStreamData->streamCardId = strdup(streamCardId);

	if((! createdStreamData->verb) ||
	   (! createdStreamData->verbToCall) ||
	   (! createdStreamData->streamCardId)) {
		HalUtlRemoveSelectedMixerData(&currentSpecificHalData->ctlHalSpecificData->ctlHalStreamsData, createdStreamData);
		return NULL;
	}

	if(! (createdStreamData->event = afb_api_make_event(apiHandle, createdStreamData->verb))) {
		HalUtlRemoveSelectedMixerData(&currentSpecificHalData->ctlHalSpecificData->ctlHalStreamsData, createdStreamData);
		return NULL;
	}

	if(afb_api_add_verb(apiHandle,
			    createdStreamData->verb,
			    "Stream action transferred to mixer",
			    HalUtlActionOnStream,
			    (void *) createdStreamData,
			    NULL,
			    0,
			    0)) {
		AFB_API_ERROR(apiHandle,"Error while creating verb for stream : '%s'", createdStreamData->verb);
		HalUtlRemoveSelectedMixerData(&currentSpecificHalData->ctlHalSpecificData->ctlHalStreamsData, createdStreamData);
		return NULL;
	}

	wrap_json_pack(&streamAddedEventJ,
		       "{s:s, s:s, s:s}",
		       "action", "added",
		       "name", createdStreamData->verb,
		       "cardId", createdStreamData->streamCardId);

	afb_event_push(currentSpecificHalData->ctlHalSpecificData->streamUpdates, streamAddedEventJ);

	return createdStreamData;
}

int8_t HalUtlRemoveStreamDataAndDeleteStreamVerb(afb_api_t apiHandle,
						 char *verb,
						 char *verbToCall,
						 char *streamCardId)
{
	int8_t returnedErr = 0;

	json_object *streamRemovedEventJ;

	CtlConfigT *ctrlConfig;

	struct SpecificHalData *currentSpecificHalData;
	struct CtlHalMixerData *toRemoveStreamData;

	if(! apiHandle || ! verb || ! verbToCall || ! streamCardId)
		return -1;

	if((! (ctrlConfig = (CtlConfigT *) afb_api_get_userdata(apiHandle))) ||
	   (! (currentSpecificHalData = (struct SpecificHalData *) getExternalData(ctrlConfig))) ||
	   (! currentSpecificHalData->ctlHalSpecificData))
		return -2;

	if(! (toRemoveStreamData = HalUtlSearchMixerDataByProperties(&currentSpecificHalData->ctlHalSpecificData->ctlHalStreamsData,
								     verb,
								     verbToCall,
								     streamCardId)))
		return -3;

	wrap_json_pack(&streamRemovedEventJ,
		       "{s:s, s:s, s:s}",
		       "action", "removed",
		       "name", toRemoveStreamData->verb,
		       "cardId", toRemoveStreamData->streamCardId);

	if(afb_api_del_verb(apiHandle, verb, NULL)) {
		AFB_API_ERROR(apiHandle,"Error while deleting verb for stream : '%s'", verb);
		json_object_put(streamRemovedEventJ);
		return -4;
	}

	if((returnedErr = HalUtlRemoveSelectedMixerData(&currentSpecificHalData->ctlHalSpecificData->ctlHalStreamsData, toRemoveStreamData))) {
		AFB_API_ERROR(apiHandle,"Error %i while removing data for stream : '%s'", returnedErr, verb);
		json_object_put(streamRemovedEventJ);
		return -5;
	}

	afb_event_push(currentSpecificHalData->ctlHalSpecificData->streamUpdates, streamRemovedEventJ);

	return 0;
}