/*****************************************************************************
#                                                                            #
#    uStreamer - Lightweight and fast MJPG-HTTP streamer.                    #
#                                                                            #
#    Copyright (C) 2018  Maxim Devaev <mdevaev@gmail.com>                    #
#                                                                            #
#    This program is free software: you can redistribute it and/or modify    #
#    it under the terms of the GNU General Public License as published by    #
#    the Free Software Foundation, either version 3 of the License, or       #
#    (at your option) any later version.                                     #
#                                                                            #
#    This program is distributed in the hope that it will be useful,         #
#    but WITHOUT ANY WARRANTY; without even the implied warranty of          #
#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the           #
#    GNU General Public License for more details.                            #
#                                                                            #
#    You should have received a copy of the GNU General Public License       #
#    along with this program.  If not, see <https://www.gnu.org/licenses/>.  #
#                                                                            #
*****************************************************************************/


#pragma once

#include <stdbool.h>

#include <sys/stat.h>

#include <event2/event.h>
#include <event2/http.h>
#include <event2/util.h>

#include "../tools.h"
#include "../stream.h"

#include "blank.h"


struct stream_client_t {
	struct http_server_t	*server;
	struct evhttp_request	*request;

	char					*key;
	bool					extra_headers;
	bool					advance_headers;
	bool					dual_final_frames;

	char					id[37]; // ex. "1b4e28ba-2fa1-11d2-883f-0016d3cca427" + "\0"
	bool					need_initial;
	bool					need_first_frame;
	bool					updated_prev;
	unsigned				fps;
	unsigned				fps_accum;
	long long				fps_accum_second;

	struct stream_client_t	*prev;
	struct stream_client_t	*next;
};

struct exposed_t {
	struct picture_t	picture;
	unsigned			width;
	unsigned			height;
	unsigned			captured_fps;
	unsigned			queued_fps;
	bool				online;
	unsigned			dropped;
	long double			expose_begin_time;
	long double			expose_cmp_time;
	long double			expose_end_time;
};

struct http_server_runtime_t {
	struct event_base		*base;
	struct evhttp			*http;
	evutil_socket_t			unix_fd;
	char					*auth_token;
	struct event			*refresh;
	struct stream_t			*stream;
	struct exposed_t		*exposed;
	struct stream_client_t	*stream_clients;
	unsigned				stream_clients_count;
	struct blank_t			*blank;
	unsigned				drop_same_frames_blank;
};

struct http_server_t {
	char		*host;
	unsigned	port;
	char		*unix_path;
	bool		unix_rm;
	mode_t		unix_mode;
	unsigned	timeout;

	char		*user;
	char		*passwd;
	char		*static_path;

	char		*blank_path;
	unsigned	drop_same_frames;
	bool		slowdown;
	unsigned	fake_width;
	unsigned	fake_height;

	struct http_server_runtime_t *run;
};


struct http_server_t *http_server_init(struct stream_t *stream);
void http_server_destroy(struct http_server_t *server);

int http_server_listen(struct http_server_t *server);
void http_server_loop(struct http_server_t *server);
void http_server_loop_break(struct http_server_t *server);