/*
 *  Chromecast core protocol handler
 *
 *  (c) Philippe 2016-2017, philippe_44@outlook.com
 *
 * See LICENSE
 *
 */

#pragma once

#include <stdlib.h>
#include <string.h>
#include <stdio.h>
#include <fcntl.h>

#include "openssl/crypto.h"
#include "openssl/x509.h"
#include "openssl/pem.h"
#include "openssl/ssl.h"
#include "openssl/err.h"

#include "cross_util.h"
#include <pb_encode.h>
#include <pb_decode.h>
#include "jansson.h"
#include "castmessage.pb.h"

#define CAST_BEAT "urn:x-cast:com.google.cast.tp.heartbeat"
#define CAST_RECEIVER "urn:x-cast:com.google.cast.receiver"
#define CAST_CONNECTION "urn:x-cast:com.google.cast.tp.connection"
#define CAST_MEDIA "urn:x-cast:com.google.cast.media"

typedef int sockfd;

typedef struct sCastCtx {
	bool			running;
	enum { CAST_DISCONNECTED, CAST_CONNECTING, CAST_CONNECTED, CAST_AUTOLAUNCH, CAST_LAUNCHING, CAST_LAUNCHED } Status;
	void			*owner;
	SSL 			*ssl;
	sockfd 			sock;
	int				reqId, waitId, waitMedia;
	pthread_t 		Thread, PingThread;
	pthread_mutex_t	Mutex, eventMutex, sslMutex;
	pthread_cond_t	eventCond;
	char 			*sessionId, *transportId;
	int				mediaSessionId;
	enum { CAST_WAIT, CAST_WAIT_MEDIA } State;
	struct in_addr	ip;
	uint16_t		port;
	cross_queue_t	eventQueue, reqQueue;
	double 			mediaVolume;
	uint32_t		lastPong;
	bool			group;
	bool			stopReceiver;
} tCastCtx;

typedef struct {
	char Type[32] ;
	union {
		json_t* msg;
		json_t* customData;
		double volume;
	} data;
} tReqItem;

bool 	SendCastMessage(struct sCastCtx *Ctx, char *ns, char *dest, char *payload, ...);
bool 	LaunchReceiver(tCastCtx *Ctx);
void 	SetVolume(tCastCtx *Ctx, double Volume);
void 	CastQueueFlush(cross_queue_t *Queue);
bool	CastConnect(struct sCastCtx *Ctx);
void 	CastDisconnect(struct sCastCtx *Ctx);