Soletta™ Framework: src/samples/http/server-sse.c File Reference

Soletta™ Framework

Framework for making IoT devices

Full online documentation | C API Index

All Data Structures Files Functions Variables Typedefs Enumerations Enumerator Macros Groups Pages

HTTP Server sse. More...

#include <getopt.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <fcntl.h>
#include "soletta.h"
#include "sol-http.h"
#include "sol-http-server.h"
#include "sol-util.h"
#include "sol-util-file.h"

Macros
#define	HTML_FILE

Functions
static void	delete_cb (void data, const struct sol_http_progressive_response sse)

static void	on_feed_done_cb (void data, struct sol_http_progressive_response sse, struct sol_blob *blob, int status)

static bool	on_stdin (void *data, int fd, uint32_t flags)

static int	request_cb (void data, struct sol_http_request request)

static int	request_events_cb (void data, struct sol_http_request request)

static void	shutdown_server (void)

	SOL_MAIN_DEFAULT (startup_server, shutdown_server)

static void	startup_server (void)

Variables
static int	port = 8080

static struct sol_ptr_vector	responses = SOL_PTR_VECTOR_INIT

static struct sol_http_server *	server

static bool	should_quit = false

static struct sol_fd *	stdin_watch

Detailed Description

HTTP Server sse.

Sample server that return a response and keep it alive. It implements server sent events. The server sends the data typed in stdin and the data is broadcasted to all the clients connected.

To test it:

run ./server-sse -p 8080 open a browser in http://127.0.0.1:8080 or curl http://127.0.0.1:8080 type something

To see the usage help, -h or –help.

Macro Definition Documentation

#define HTML_FILE

Value:

"<!DOCTYPE html>" \
    "<html>" \
    "<body>" \
    "<h1>Getting server updates</h1>" \
    "<div id=\"result\"></div>" \
    "<script>" \
    "if(typeof(EventSource) !== \"undefined\") {" \
    "var source = new EventSource(\"http://%.*s:%d/events\");" \
    "source.onmessage = function(event) {" \
    "document.getElementById(\"result\").innerHTML += event.data + \"<br>\";" \
    "};" \
    "} else {" \
    "document.getElementById(\"result\").innerHTML = \"Sorry, your browser does not support server-sent events...\";" \
    "}" \
    "</script>" \
    "</body>" \
    "</html>"

Examples:: /src/samples/http/server-sse.c.

Referenced by request_cb().

Function Documentation

static void delete_cb	(	void *	data,
		const struct sol_http_progressive_response *	sse
	)

static

Examples:: /src/samples/http/server-sse.c.

References should_quit, sol_ptr_vector_get_len(), sol_ptr_vector_remove(), and sol_quit().

Referenced by request_events_cb().

static void on_feed_done_cb	(	void *	data,
		struct sol_http_progressive_response *	sse,
		struct sol_blob *	blob,
		int	status
	)

static

Examples:: /src/samples/http/server-sse.c.

References sol_str_slice::data, sol_str_slice::len, sol_str_slice_from_blob(), SOL_STR_SLICE_PRINT, and sol_str_slice_str_eq().

Referenced by request_events_cb().

static bool on_stdin	(	void *	data,
		int	fd,
		uint32_t	flags
	)

static

Examples:: /src/samples/http/server-sse.c, and /src/samples/http/server.c.

References should_quit, sol_blob_unref(), sol_buffer_fini(), SOL_BUFFER_INIT_EMPTY, sol_buffer_to_blob(), sol_http_progressive_response_del(), sol_http_progressive_response_sse_feed(), SOL_PTR_VECTOR_FOREACH_IDX, sol_quit_with_code(), sol_util_load_file_fd_buffer(), sol_util_strerrora, stdin_watch, and sol_buffer::used.

Referenced by startup_server().

static int request_cb	(	void *	data,
		struct sol_http_request *	request
	)

static

static int request_events_cb	(	void *	data,
		struct sol_http_request *	request
	)

static

Examples:: /src/samples/http/server-sse.c.

References sol_http_response::api_version, sol_http_server_progressive_config::api_version, delete_cb(), on_feed_done_cb(), sol_http_response::param, SOL_BUFFER_INIT_EMPTY, sol_http_params_clear(), sol_http_progressive_response_del(), SOL_HTTP_REQUEST_PARAMS_INIT, SOL_HTTP_RESPONSE_API_VERSION, sol_http_response_set_sse_headers(), SOL_HTTP_SERVER_PROGRESSIVE_CONFIG_API_VERSION, sol_http_server_send_progressive_response(), SOL_HTTP_STATUS_OK, sol_ptr_vector_append(), and SOL_SET_API_VERSION.

Referenced by startup_server().

static void shutdown_server ( void )

static

References server, sol_http_progressive_response_del(), sol_http_server_del(), sol_ptr_vector_clear(), SOL_PTR_VECTOR_FOREACH_IDX, and stdin_watch.

SOL_MAIN_DEFAULT	(	startup_server	,
		shutdown_server
	)

static void startup_server ( void )

static

References on_stdin(), port, request_cb(), request_events_cb(), server, sol_argc(), sol_argv(), SOL_HTTP_SERVER_CONFIG_API_VERSION, sol_http_server_new(), sol_http_server_register_handler(), sol_quit_with_code(), SOL_SET_API_VERSION, sol_util_fd_set_flag(), and stdin_watch.

Variable Documentation

int port = 8080

static

Examples:: /src/samples/coap/lwm2m-bs-server.c, /src/samples/flow/c-api/custom-node-types.c, /src/samples/flow/c-api/single-node.c, /src/samples/flow/tilt-angle/arctan-node.c, /src/samples/http/server-https.c, /src/samples/http/server-sse.c, /src/samples/http/server.c, and /src/samples/http/static-files.c.

Referenced by main(), and startup_server().

struct sol_ptr_vector responses = SOL_PTR_VECTOR_INIT

static

Examples:: /src/samples/http/server-sse.c.

struct sol_http_server* server

static

Referenced by shutdown_server(), and startup_server().

bool should_quit = false

static

Examples:: /src/samples/http/server-sse.c.

Referenced by delete_cb(), and on_stdin().

struct sol_fd* stdin_watch

static

Referenced by on_stdin(), shutdown_server(), and startup_server().