Client request for an InfluxDB server. More...

#include <tsInfluxRequest.h>

Inheritance diagram for ts::InfluxRequest:

Collaboration diagram for ts::InfluxRequest:

Public Member Functions
	InfluxRequest (Report &report, const InfluxArgs &args)
	Constructor.

virtual	~InfluxRequest () override
	Destructor.

void	abort ()
	Abort a transfer in progress.

void	add (const UString &measurement, const UString &tags, const UString &value)
	Add a line in the request being built.

template<typename INT_T > requires std::integral<INT_T>
void	add (const UString &measurement, const UString &tags, INT_T value)
	Add a line in the request being built.

size_t	announdedContentSize () const
	Get the announced content size in bytes.

void	clearPostData ()
	Clear previous POST data.

void	clearRequestHeaders ()
	Clear all headers which will be sent with the request.

bool	close ()
	Close the transfer.

size_t	contentSize () const
	Get the size in bytes of the downloaded content.

const UString &	currentContent () const
	Get the current content of the request being built.

bool	deleteCookiesFile () const
	Delete the cookies file, if one was defined.

void	deleteRequestHeader (const UString &name)
	Delete all headers with a given name.

void	disableCookies ()
	Disable the use of cookies for all requests.

bool	downloadBinaryContent (const UString &url, ByteBlock &data, size_t chunkSize=DEFAULT_CHUNK_SIZE)
	Download the content of the URL as binary data in one operation.

bool	downloadFile (const UString &url, const fs::path &fileName, size_t chunkSize=DEFAULT_CHUNK_SIZE)
	Download the content of the URL in a file in one operation.

bool	downloadTextContent (const UString &url, UString &text, size_t chunkSize=DEFAULT_CHUNK_SIZE)
	Download the content of the URL as text in one operation.

void	enableCompression (bool on=true)
	Enable compression.

void	enableCookies (const fs::path &fileName=fs::path())
	Enable the use of cookies for all requests using this instance.

UString	finalURL () const
	Get the final URL of the actual download operation.

fs::path	getCookiesFileName () const
	Get the file name to use for cookies for all requests using this instance.

void	getResponseHeaders (UStringToUStringMultiMap &headers) const
	Get all response headers.

int	httpStatus () const
	Get the HTTP status code (200, 404, etc).

int	httpSuccess () const
	Check if the HTTP status code indicates success.

bool	isOpen () const
	Check if a transfer is open.

UString	mimeType (bool simple=true, bool lowercase=true) const
	Get the MIME type in the response headers.

bool	open (const UString &url)
	Open an URL and start the transfer.

UString	originalURL () const
	Get the original URL, as set by setURL().

const UString &	proxyHost () const
	Get the current actual proxy host.

const UString &	proxyPassword () const
	Get the current actual proxy user password.

uint16_t	proxyPort () const
	Get the current actual proxy port number.

const UString &	proxyUser () const
	Get the current actual proxy user name.

bool	receive (void *buffer, size_t maxSize, size_t &retSize)
	Receive data.

UString	reponseHeader (const UString &name) const
	Get the value of one header.

Report &	report ()
	Use the Report object of this instance.

const UStringToUStringMultiMap &	responseHeaders () const
	Get all response headers.

bool	send ()
	Complete the request being built and send it to the InfluxDB server.

void	setArgs (const WebRequestArgs &args)
	Set various arguments from command line.

void	setAutoRedirect (bool on)
	Enable or disable the automatic redirection of HTTP requests.

void	setConnectionTimeout (cn::milliseconds timeout)
	Set the connection timeout for this request.

void	setInsecure (bool on=true)
	Enable or disable HTTPS security (certificate validation).

void	setPostData (const ByteBlock &data)
	Set data to POST.

void	setPostData (const UString &data, const UString content_type=u"text/plain; charset=utf-8")
	Set data to POST.

void	setProxyHost (const UString &host, uint16_t port)
	Set the optional proxy host and port for this request.

void	setProxyUser (const UString &user, const UString &password)
	Set the optional proxy authentication for this request.

void	setReceiveTimeout (cn::milliseconds timeout)
	Set the timeout for each receive operation.

void	setRequestHeader (const UString &name, const UString &value)
	Set a header which will be sent with the request.

void	setUserAgent (const UString &name=UString())
	Set the user agent name to use in HTTP headers.

template<class Rep , class Period >
void	start (const cn::duration< Rep, Period > &timestamp)
	Start building a request to the InfluxDB server.

void	start (std::intmax_t timestamp, const UString &precision)
	Start building a request to the InfluxDB server.

const UString &	userAgent () const
	Get the current user agent name to use in HTTP headers.

Static Public Member Functions
static UString	GetLibraryVersion ()
	Get the version of the underlying HTTP library.

static void	SetDefaultProxyHost (const UString &host, uint16_t port)
	Set the default proxy host and port for all subsequent requests.

static void	SetDefaultProxyUser (const UString &user, const UString &password)
	Set the default proxy authentication for all subsequent requests.

static UString	ToKey (const UString &name)
	Escape characters in a string to be used as tag key, tag value, or field key.

static UString	ToMeasurement (const UString &name)
	Escape characters in a string to be used as measurement.

static UString	ToStringValue (const UString &name)
	Escape characters in a string to be used as field value of type string.

Static Public Attributes
static constexpr size_t	DEFAULT_CHUNK_SIZE = 64 * 1024
	Default download chunk size for bulk transfers.

static constexpr uint16_t	DEFAULT_HTTP_PORT = 80
	Default TCP port for HTTP.

static constexpr uint16_t	DEFAULT_HTTPS_PORT = 443
	Default TCP port for HTTPS.

static constexpr const UChar *	DEFAULT_USER_AGENT = u"tsduck"
	Default user agent string ("tsduck").

Detailed Description

Client request for an InfluxDB server.

See also: https://docs.influxdata.com/influxdb/v2/; https://docs.influxdata.com/influxdb/v2/reference/syntax/line-protocol/; https://docs.influxdata.com/influxdb/v2/api/v2/#operation/PostWrite

Constructor & Destructor Documentation

◆ InfluxRequest()

ts::InfluxRequest::InfluxRequest	(	Report &	report,
		const InfluxArgs &	args
	)

Constructor.

Parameters

[in,out]	report	Where to report errors.
[in]	args	The connection information to the InfluxDB server. A reference is kept in this object.

Member Function Documentation

◆ start() [1/2]

template<class Rep , class Period >

void ts::InfluxRequest::start ( const cn::duration< Rep, Period > & timestamp )

inline

Start building a request to the InfluxDB server.

Parameters

[in] timestamp Value of the timestamp for that request, in cn::duration format.

◆ start() [2/2]

void ts::InfluxRequest::start	(	std::intmax_t	timestamp,
		const UString &	precision
	)

Start building a request to the InfluxDB server.

Parameters

[in]	timestamp	Value of the timestamp for that request.
[in]	precision	Precision of timestamps. Must be one of "s", "ms", "us", "ns".

◆ add() [1/2]

template<typename INT_T >
requires std::integral<INT_T>

void ts::InfluxRequest::add	(	const UString &	measurement,
		const UString &	tags,
		INT_T	value
	)

inline

Add a line in the request being built.

Parameters

[in]	measurement	The name of the measurement.
[in]	tags	Comma-separated list of tags "name=value". The names and values must be compatible with the InfluxDB line protocol (use ToKey() if necessary.
[in]	value	The measurement value.

◆ add() [2/2]

void ts::InfluxRequest::add	(	const UString &	measurement,
		const UString &	tags,
		const UString &	value
	)

inline

Add a line in the request being built.

Parameters

[in]	measurement	The name of the measurement.
[in]	tags	Comma-separated list of tags "name=value". The names and values must be compatible with the InfluxDB line protocol (use ToKey() if necessary.
[in]	value	The measurement value.

◆ currentContent()

const UString & ts::InfluxRequest::currentContent ( ) const

inline

Get the current content of the request being built.

For debug purpose only.

Returns: A constant reference to a string object containing the currnet content.

◆ send()

bool ts::InfluxRequest::send ( )

Complete the request being built and send it to the InfluxDB server.

Returns: True on success, false on error.

◆ ToMeasurement()

static UString ts::InfluxRequest::ToMeasurement ( const UString & name )

inlinestatic

Escape characters in a string to be used as measurement.

Parameters

[in] name The name to transform.

Returns: The transformed string with escaped special characters.

See also: https://docs.influxdata.com/influxdb/v2/reference/syntax/line-protocol/

◆ ToKey()

static UString ts::InfluxRequest::ToKey ( const UString & name )

inlinestatic

Escape characters in a string to be used as tag key, tag value, or field key.

Parameters

[in] name The name to transform.

Returns: The transformed string with escaped special characters.

See also: https://docs.influxdata.com/influxdb/v2/reference/syntax/line-protocol/

◆ ToStringValue()

static UString ts::InfluxRequest::ToStringValue ( const UString & name )

inlinestatic

Escape characters in a string to be used as field value of type string.

Do not use for numerical field values. This function adds surrounding quotes.

Parameters

[in] name The name to transform.

Returns: The transformed string with escaped special characters and surrounding quotes.

See also: https://docs.influxdata.com/influxdb/v2/reference/syntax/line-protocol/

◆ report()

Report & ts::WebRequest::report ( )

inlineinherited

Use the Report object of this instance.

Returns: A reference to the Report object of this instance.

◆ setConnectionTimeout()

void ts::WebRequest::setConnectionTimeout ( cn::milliseconds timeout )

inlineinherited

Set the connection timeout for this request.

Parameters

[in] timeout Connection timeout in milliseconds.

◆ setReceiveTimeout()

void ts::WebRequest::setReceiveTimeout ( cn::milliseconds timeout )

inlineinherited

Set the timeout for each receive operation.

Parameters

[in] timeout Reception timeout in milliseconds.

◆ setProxyHost()

void ts::WebRequest::setProxyHost	(	const UString &	host,
		uint16_t	port
	)

inherited

Set the optional proxy host and port for this request.

Parameters

[in]	host	Proxy host name or address.
[in]	port	Proxy port number.

◆ setProxyUser()

void ts::WebRequest::setProxyUser	(	const UString &	user,
		const UString &	password
	)

inherited

Set the optional proxy authentication for this request.

Parameters

[in]	user	Proxy user name.
[in]	password	Proxy user's password.

◆ SetDefaultProxyHost()

static void ts::WebRequest::SetDefaultProxyHost	(	const UString &	host,
		uint16_t	port
	)

staticinherited

Set the default proxy host and port for all subsequent requests.

Parameters

[in]	host	Proxy host name or address.
[in]	port	Proxy port number.

◆ SetDefaultProxyUser()

static void ts::WebRequest::SetDefaultProxyUser	(	const UString &	user,
		const UString &	password
	)

staticinherited

Set the default proxy authentication for all subsequent requests.

Parameters

[in]	user	Proxy user name.
[in]	password	Proxy user's password.

◆ proxyHost()

const UString & ts::WebRequest::proxyHost ( ) const

inherited

Get the current actual proxy host.

Returns: A constant reference to the proxy host name.

◆ proxyPort()

uint16_t ts::WebRequest::proxyPort ( ) const

inherited

Get the current actual proxy port number.

Returns: The proxy port number.

◆ proxyUser()

const UString & ts::WebRequest::proxyUser ( ) const

inherited

Get the current actual proxy user name.

Returns: A constant reference to the proxy user name.

◆ proxyPassword()

const UString & ts::WebRequest::proxyPassword ( ) const

inherited

Get the current actual proxy user password.

Returns: A constant reference to the proxy user password.

◆ enableCookies()

void ts::WebRequest::enableCookies ( const fs::path & fileName = fs::path() )

inherited

Enable the use of cookies for all requests using this instance.

Parameters

[in] fileName The name of the file to use to load and store cookies. On Windows, there is an implicit per-user cookie repository and fileName is ignored. On Unix systems, this file is used to store and retrieve cookies in the libcurl format. When fileName is empty, use a temporary file name.

◆ disableCookies()

void ts::WebRequest::disableCookies ( )

inherited

Disable the use of cookies for all requests.

Cookies are initially disabled by default.

◆ getCookiesFileName()

fs::path ts::WebRequest::getCookiesFileName ( ) const

inherited

Get the file name to use for cookies for all requests using this instance.

On Linux, return the current cookie file name, possibly the name of a temporary file if EnableCookies() was called with an empty string.
On Windows, the cookie repository is defined per user. There is no specific per-application file and this method always report an empty string.
Returns
The cookie file name.

◆ deleteCookiesFile()

bool ts::WebRequest::deleteCookiesFile ( ) const

inherited

Delete the cookies file, if one was defined.

Returns: True on success, false on error.

◆ setUserAgent()

void ts::WebRequest::setUserAgent ( const UString & name = UString() )

inlineinherited

Set the user agent name to use in HTTP headers.

Parameters

[in] name The user agent name. If empty, DEFAULT_USER_AGENT is used.

◆ userAgent()

const UString & ts::WebRequest::userAgent ( ) const

inlineinherited

Get the current user agent name to use in HTTP headers.

Returns: A constant reference to the user agent name to use in HTTP headers.

◆ enableCompression()

void ts::WebRequest::enableCompression ( bool on = true )

inlineinherited

Enable compression.

Compression is disabled by default.

Parameters

[in] on Boolean setting compression on or off.

◆ setInsecure()

void ts::WebRequest::setInsecure ( bool on = true )

inlineinherited

Enable or disable HTTPS security (certificate validation).

Certificate validation is enabled by default.

Parameters

[in] on If true, disable certificate validation.

◆ setAutoRedirect()

void ts::WebRequest::setAutoRedirect ( bool on )

inlineinherited

Enable or disable the automatic redirection of HTTP requests.

This option is active by default.

Parameters

[in] on If true, allow automatic redirection of HTTP requests.

◆ setArgs()

void ts::WebRequest::setArgs ( const WebRequestArgs & args )

inherited

Set various arguments from command line.

Parameters

[in] args Command line arguments.

◆ setRequestHeader()

void ts::WebRequest::setRequestHeader	(	const UString &	name,
		const UString &	value
	)

inherited

Set a header which will be sent with the request.

If the same header already exists with another value, a new header is added.

Parameters

[in]	name	The header name.
[in]	value	The header value.

◆ deleteRequestHeader()

void ts::WebRequest::deleteRequestHeader ( const UString & name )

inherited

Delete all headers with a given name.

Parameters

[in] name The header name.

◆ setPostData() [1/2]

void ts::WebRequest::setPostData	(	const UString &	data,
		const UString	content_type = `u"text/plain; charset=utf-8"`
	)

inherited

Set data to POST.

The request will be a POST one.

Parameters

[in]	data	Text POST data. The text will be sent in UTF-8 format.
[in]	content_type	The content type to set in the request headers. The default "Content-Type" header is "text/plain; charset=utf-8", which is usually appropriate. When set to the empty string, no header is set.

◆ setPostData() [2/2]

void ts::WebRequest::setPostData ( const ByteBlock & data )

inherited

Set data to POST.

The request will be a POST one.

Parameters

[in] data Binary POST data.

◆ clearPostData()

void ts::WebRequest::clearPostData ( )

inherited

Clear previous POST data.

The request will be a GET one.

◆ open()

bool ts::WebRequest::open ( const UString & url )

inherited

Open an URL and start the transfer.

For HTTP request, perform all redirections and get response headers.

Parameters

[in] url The complete URL to fetch.

Returns: True on success, false on error.

◆ isOpen()

bool ts::WebRequest::isOpen ( ) const

inlineinherited

Check if a transfer is open.

Returns: True if a transfer is open, false otherwise.

◆ httpStatus()

int ts::WebRequest::httpStatus ( ) const

inlineinherited

Get the HTTP status code (200, 404, etc).

Returns: The HTTP status code.

◆ httpSuccess()

int ts::WebRequest::httpSuccess ( ) const

inlineinherited

Check if the HTTP status code indicates success.

The HTTP status codes are classified as follow (Wikipedia):

1xx informational response – the request was received, continuing process
2xx successful – the request was successfully received, understood, and accepted
3xx redirection – further action needs to be taken in order to complete the request
4xx client error – the request contains bad syntax or cannot be fulfilled
5xx server error – the server failed to fulfil an apparently valid request
Returns
True if the HTTP status code indicates success.

◆ announdedContentSize()

size_t ts::WebRequest::announdedContentSize ( ) const

inlineinherited

Get the announced content size in bytes.

This is the value which was sent in the content headers. This mat be zero, this may not be the actual size of the content to download.

Returns: Announced content size in bytes.

◆ getResponseHeaders()

void ts::WebRequest::getResponseHeaders ( UStringToUStringMultiMap & headers ) const

inlineinherited

Get all response headers.

Parameters

[out] headers A multimap of all response headers.

◆ responseHeaders()

const UStringToUStringMultiMap & ts::WebRequest::responseHeaders ( ) const

inlineinherited

Get all response headers.

Returns: A constant reference to a map of response headers.

◆ reponseHeader()

UString ts::WebRequest::reponseHeader ( const UString & name ) const

inherited

Get the value of one header.

Parameters

[in] name Header name, case sensitive.

Returns: Header value or an empty string when the header is not found. If the header is present more than once, the first value is returned.

◆ mimeType()

UString ts::WebRequest::mimeType	(	bool	simple = `true`,
		bool	lowercase = `true`
	)		const

inherited

Get the MIME type in the response headers.

Parameters

[in]	simple	If true, simple type name. If false, return the full specification with options.
[in]	lowercase	Force lowercase in the result.

Returns: The MIME type.

◆ originalURL()

UString ts::WebRequest::originalURL ( ) const

inlineinherited

Get the original URL, as set by setURL().

Returns: The original URL.

◆ finalURL()

UString ts::WebRequest::finalURL ( ) const

inlineinherited

Get the final URL of the actual download operation.

It can be different from originalURL() if some HTTP redirections were performed. When called before a download operation, return originalURL().

If redirections are disabled using setAutoRedirect() and the site returned a redirection, finalURL() returns the redirected URL.

Returns: The final / redirected URL.

◆ receive()

bool ts::WebRequest::receive	(	void *	buffer,
		size_t	maxSize,
		size_t &	retSize
	)

inherited

Receive data.

Parameters

[out]	buffer	Address of the buffer for the received data.
[in]	maxSize	Size in bytes of the reception buffer.
[out]	retSize	Size in bytes of the received data. Will never be larger than max_size. When ret_size is zero, this is the end of the transfer.

Returns: True on success, false on error. A successful end of transfer is reported when ret_size is zero and the returned value is true.

◆ close()

bool ts::WebRequest::close ( )

inherited

Close the transfer.

Returns: True on success, false on error.

◆ abort()

void ts::WebRequest::abort ( )

inherited

Abort a transfer in progress.

Can be called from another thread.

◆ contentSize()

size_t ts::WebRequest::contentSize ( ) const

inlineinherited

Get the size in bytes of the downloaded content.

Returns: Size in bytes of the downloaded content.

◆ downloadBinaryContent()

bool ts::WebRequest::downloadBinaryContent	(	const UString &	url,
		ByteBlock &	data,
		size_t	chunkSize = `DEFAULT_CHUNK_SIZE`
	)

inherited

Download the content of the URL as binary data in one operation.

The open/read/close session is embedded in this method.

Parameters

[in]	url	The complete URL to fetch.
[out]	data	The content of the URL.
[in]	chunkSize	Individual download chunk size.

Returns: True on success, false on error.

◆ downloadTextContent()

bool ts::WebRequest::downloadTextContent	(	const UString &	url,
		UString &	text,
		size_t	chunkSize = `DEFAULT_CHUNK_SIZE`
	)

inherited

Download the content of the URL as text in one operation.

The open/read/close session is embedded in this method.. The downloaded text is converted from UTF-8. End of lines are normalized as LF.

Parameters

[in]	url	The complete URL to fetch.
[out]	text	The content of the URL.
[in]	chunkSize	Individual download chunk size.

Returns: True on success, false on error.

◆ downloadFile()

bool ts::WebRequest::downloadFile	(	const UString &	url,
		const fs::path &	fileName,
		size_t	chunkSize = `DEFAULT_CHUNK_SIZE`
	)

inherited

Download the content of the URL in a file in one operation.

The open/read/close session is embedded in this method.. No transformation is applied to the data.

Parameters

[in]	url	The complete URL to fetch.
[in]	fileName	Name of the file to create.
[in]	chunkSize	Individual download chunk size.

Returns: True on success, false on error.

◆ GetLibraryVersion()

static UString ts::WebRequest::GetLibraryVersion ( )

staticinherited

Get the version of the underlying HTTP library.

Returns: The library version.

The documentation for this class was generated from the following file:

tsInfluxRequest.h

Public Member Functions

Static Public Member Functions

Static Public Attributes

Detailed Description

Constructor & Destructor Documentation

◆ InfluxRequest()

Member Function Documentation

◆ start() [1/2]

◆ start() [2/2]

◆ add() [1/2]

◆ add() [2/2]

◆ currentContent()

◆ send()

◆ ToMeasurement()

◆ ToKey()

◆ ToStringValue()

◆ report()

◆ setConnectionTimeout()

◆ setReceiveTimeout()

◆ setProxyHost()

◆ setProxyUser()

◆ SetDefaultProxyHost()

◆ SetDefaultProxyUser()

◆ proxyHost()

◆ proxyPort()

◆ proxyUser()

◆ proxyPassword()

◆ enableCookies()

◆ disableCookies()

◆ getCookiesFileName()

◆ deleteCookiesFile()

◆ setUserAgent()

◆ userAgent()

◆ enableCompression()

◆ setInsecure()

◆ setAutoRedirect()

◆ setArgs()

◆ setRequestHeader()

◆ deleteRequestHeader()

◆ setPostData() [1/2]

◆ setPostData() [2/2]

◆ clearPostData()

◆ open()

◆ isOpen()

◆ httpStatus()

◆ httpSuccess()

◆ announdedContentSize()

◆ getResponseHeaders()

◆ responseHeaders()

◆ reponseHeader()

◆ mimeType()

◆ originalURL()

◆ finalURL()

◆ receive()

◆ close()

◆ abort()

◆ contentSize()

◆ downloadBinaryContent()

◆ downloadTextContent()

◆ downloadFile()

◆ GetLibraryVersion()