Include.h

Go to the documentation of this file.

 
#ifndef __KINESIS_VIDEO_COMMON_INCLUDE__
#define __KINESIS_VIDEO_COMMON_INCLUDE__
 
#pragma once
 
#ifdef __cplusplus
extern "C" {
#endif
 
// Public headers
#include <com/amazonaws/kinesis/video/client/Include.h>
#ifndef JSMN_HEADER
#define JSMN_HEADER
#endif
#include <com/amazonaws/kinesis/video/common/jsmn.h>
 
 
#define STATUS_COMMON_PRODUCER_BASE                         0x15000000
#define STATUS_INVALID_AWS_CREDENTIALS_VERSION              STATUS_COMMON_PRODUCER_BASE + 0x00000008
#define STATUS_MAX_REQUEST_HEADER_COUNT                     STATUS_COMMON_PRODUCER_BASE + 0x00000009
#define STATUS_MAX_REQUEST_HEADER_NAME_LEN                  STATUS_COMMON_PRODUCER_BASE + 0x0000000a
#define STATUS_MAX_REQUEST_HEADER_VALUE_LEN                 STATUS_COMMON_PRODUCER_BASE + 0x0000000b
#define STATUS_INVALID_API_CALL_RETURN_JSON                 STATUS_COMMON_PRODUCER_BASE + 0x0000000c
#define STATUS_CURL_INIT_FAILED                             STATUS_COMMON_PRODUCER_BASE + 0x0000000d
#define STATUS_CURL_LIBRARY_INIT_FAILED                     STATUS_COMMON_PRODUCER_BASE + 0x0000000e
#define STATUS_HMAC_GENERATION_ERROR                        STATUS_COMMON_PRODUCER_BASE + 0x00000010
#define STATUS_IOT_FAILED                                   STATUS_COMMON_PRODUCER_BASE + 0x00000011
#define STATUS_MAX_ROLE_ALIAS_LEN_EXCEEDED                  STATUS_COMMON_PRODUCER_BASE + 0x00000012
#define STATUS_INVALID_USER_AGENT_LENGTH                    STATUS_COMMON_PRODUCER_BASE + 0x00000015
#define STATUS_IOT_EXPIRATION_OCCURS_IN_PAST                STATUS_COMMON_PRODUCER_BASE + 0x00000017
#define STATUS_IOT_EXPIRATION_PARSING_FAILED                STATUS_COMMON_PRODUCER_BASE + 0x00000018
#define STATUS_MAX_IOT_THING_NAME_LENGTH                    STATUS_COMMON_PRODUCER_BASE + 0x0000001e
#define STATUS_IOT_CREATE_LWS_CONTEXT_FAILED                STATUS_COMMON_PRODUCER_BASE + 0x0000001f
#define STATUS_INVALID_CA_CERT_PATH                         STATUS_COMMON_PRODUCER_BASE + 0x00000020
#define STATUS_FILE_CREDENTIAL_PROVIDER_OPEN_FILE_FAILED    STATUS_COMMON_PRODUCER_BASE + 0x00000022
#define STATUS_FILE_CREDENTIAL_PROVIDER_INVALID_FILE_LENGTH STATUS_COMMON_PRODUCER_BASE + 0x00000023
#define STATUS_FILE_CREDENTIAL_PROVIDER_INVALID_FILE_FORMAT STATUS_COMMON_PRODUCER_BASE + 0x00000024
 
#define STATUS_COMMON_BASE                          0x16000000
#define STATUS_CURL_PERFORM_FAILED                  STATUS_COMMON_BASE + 0x00000001
#define STATUS_IOT_INVALID_RESPONSE_LENGTH          STATUS_COMMON_BASE + 0x00000002
#define STATUS_IOT_NULL_AWS_CREDS                   STATUS_COMMON_BASE + 0x00000003
#define STATUS_IOT_INVALID_URI_LEN                  STATUS_COMMON_BASE + 0x00000004
#define STATUS_TIMESTAMP_STRING_UNRECOGNIZED_FORMAT STATUS_COMMON_BASE + 0x00000005
#define IS_RETRIABLE_COMMON_LIB_ERROR(error)                                                                                                         \
    ((error) == STATUS_INVALID_API_CALL_RETURN_JSON || (error) == STATUS_CURL_INIT_FAILED || (error) == STATUS_CURL_LIBRARY_INIT_FAILED ||           \
     (error) == STATUS_HMAC_GENERATION_ERROR || (error) == STATUS_CURL_PERFORM_FAILED || (error) == STATUS_IOT_INVALID_RESPONSE_LENGTH ||            \
     (error) == STATUS_IOT_NULL_AWS_CREDS || (error) == STATUS_IOT_INVALID_URI_LEN || (error) == STATUS_IOT_EXPIRATION_OCCURS_IN_PAST ||             \
     (error) == STATUS_IOT_EXPIRATION_PARSING_FAILED || (error) == STATUS_IOT_CREATE_LWS_CONTEXT_FAILED ||                                           \
     (error) == STATUS_FILE_CREDENTIAL_PROVIDER_OPEN_FILE_FAILED || (error) == STATUS_FILE_CREDENTIAL_PROVIDER_INVALID_FILE_LENGTH ||                \
     (error) == STATUS_FILE_CREDENTIAL_PROVIDER_INVALID_FILE_FORMAT)
 
 
#define MAX_REGION_NAME_LEN 128
 
#define MAX_USER_AGENT_LEN 256
 
#define MAX_CUSTOM_USER_AGENT_LEN 128
 
#define MAX_CUSTOM_USER_AGENT_NAME_POSTFIX_LEN 32
 
#define MAX_ACCESS_KEY_LEN 128
 
#define MAX_SECRET_KEY_LEN 128
 
#define MAX_SESSION_TOKEN_LEN 2048
 
#define MAX_EXPIRATION_LEN 128
 
#define MAX_ROLE_ALIAS_LEN 128
 
#define MAX_IOT_THING_NAME_LEN 128
 
#define MAX_REQUEST_HEADER_NAME_LEN 128
 
#define MAX_REQUEST_HEADER_VALUE_LEN 2048
 
#define MAX_REQUEST_HEADER_STRING_LEN (MAX_REQUEST_HEADER_NAME_LEN + MAX_REQUEST_HEADER_VALUE_LEN + 3)
 
#define MAX_CREDENTIAL_FILE_LEN MAX_AUTH_LEN
 
#define CALL_INFO_ERROR_BUFFER_LEN 256
 
#define MAX_JSON_PARAMETER_STRING_LEN (10 * 1024)
#define DEFAULT_VIDEO_TRACK_ID 1
 
#define DEFAULT_AUDIO_TRACK_ID 2
 
#define DEFAULT_AUDIO_ONLY_TRACK_ID 1
 
#define DEFAULT_ENDPOINT_CACHE_UPDATE_PERIOD (40 * HUNDREDS_OF_NANOS_IN_A_MINUTE)
 
#define ENDPOINT_UPDATE_PERIOD_SENTINEL_VALUE 0
 
#define MAX_ENDPOINT_CACHE_UPDATE_PERIOD (24 * HUNDREDS_OF_NANOS_IN_AN_HOUR)
 
 
#define ACCESS_KEY_ENV_VAR ((PCHAR) "AWS_ACCESS_KEY_ID")
 
#define SECRET_KEY_ENV_VAR ((PCHAR) "AWS_SECRET_ACCESS_KEY")
 
#define SESSION_TOKEN_ENV_VAR ((PCHAR) "AWS_SESSION_TOKEN")
 
#define DEFAULT_REGION_ENV_VAR ((PCHAR) "AWS_DEFAULT_REGION")
 
#define CACERT_PATH_ENV_VAR ((PCHAR) "AWS_KVS_CACERT_PATH")
 
#define DEBUG_LOG_LEVEL_ENV_VAR ((PCHAR) "AWS_KVS_LOG_LEVEL")
 
#define ENABLE_FILE_LOGGING ((PCHAR) "AWS_ENABLE_FILE_LOGGING")
#ifdef CMAKE_DETECTED_CACERT_PATH
#define DEFAULT_KVS_CACERT_PATH KVS_CA_CERT_PATH
#else
#define DEFAULT_KVS_CACERT_PATH EMPTY_STRING
#endif
 
 
#define HTTPS_SCHEME_NAME "https"
 
#define WSS_SCHEME_NAME "wss"
 
#define HTTP_REQUEST_VERB_GET_STRING (PCHAR) "GET"
#define HTTP_REQUEST_VERB_PUT_STRING (PCHAR) "PUT"
#define HTTP_REQUEST_VERB_POST_STRING (PCHAR) "POST"
 
#define SCHEMA_DELIMITER_STRING (PCHAR) "://"
 
#define DEFAULT_CANONICAL_URI_STRING (PCHAR) "/"
 
#define DEFAULT_AWS_REGION "us-west-2"
 
#define CONTROL_PLANE_URI_PREFIX "https://"
 
#define KINESIS_VIDEO_SERVICE_NAME "kinesisvideo"
 
#define AWS_KVS_FIPS_ENDPOINT_POSTFIX "-fips"
 
#define CONTROL_PLANE_URI_POSTFIX ".amazonaws.com"
 
#define CONTROL_PLANE_URI_POSTFIX_CN ".amazonaws.com.cn"
 
#define CONTROL_PLANE_URI_POSTFIX_ISO ".c2s.ic.gov"
 
#define CONTROL_PLANE_URI_POSTFIX_ISO_B ".sc2s.sgov.gov"
 
#define AWS_ISO_B_REGION_PREFIX "us-isob-"
 
#define AWS_ISO_REGION_PREFIX "us-iso-"
 
#define AWS_GOV_CLOUD_REGION_PREFIX "us-gov-"
 
#define AWS_CN_REGION_PREFIX "cn-"
 
#define DEFAULT_USER_AGENT_NAME "AWS-SDK-KVS"
 
#define TAG_PARAM_JSON_TEMPLATE "\n\t\t\"%s\": \"%s\","
 
#define REQUEST_HEADER_DELIMITER ((PCHAR) ": ")
 
#define KVS_REQUEST_ID_HEADER_NAME "x-amzn-RequestId"
 
// Max header count
#define MAX_REQUEST_HEADER_COUNT 200
 
// Max delimiter characters when packing headers into a string for printout
#define MAX_REQUEST_HEADER_OUTPUT_DELIMITER 5
 
// HTTP status OK
#define HTTP_STATUS_CODE_OK 200
 
// HTTP status Request timed out
#define HTTP_STATUS_CODE_REQUEST_TIMEOUT 408
 
#define MAX_JSON_TOKEN_COUNT 100
 
#define DEFAULT_LOW_SPEED_LIMIT 30
 
#define DEFAULT_LOW_SPEED_TIME_LIMIT (30 * HUNDREDS_OF_NANOS_IN_A_SECOND)
 
#define REQUEST_HEADER_DELIMITER_SIZE (2 * SIZEOF(CHAR))
 
#define AWS_CREDENTIALS_CURRENT_VERSION 0
 
#define DEFAULT_SSL_PORT_NUMBER 443
 
#define DEFAULT_NON_SSL_PORT_NUMBER 8080
 
typedef enum {
    HTTP_REQUEST_VERB_GET,  
    HTTP_REQUEST_VERB_POST, 
    HTTP_REQUEST_VERB_PUT   
} HTTP_REQUEST_VERB;
 
typedef enum {
    SSL_CERTIFICATE_TYPE_NOT_SPECIFIED, 
    SSL_CERTIFICATE_TYPE_DER,           
    SSL_CERTIFICATE_TYPE_PEM,           
    SSL_CERTIFICATE_TYPE_ENG,           
} SSL_CERTIFICATE_TYPE;
 
typedef struct __AwsCredentials AwsCredentials;
struct __AwsCredentials {
    UINT32 version;         
    UINT32 size;            
    PCHAR accessKeyId;      
    UINT32 accessKeyIdLen;  
    PCHAR secretKey;        
    UINT32 secretKeyLen;    
    PCHAR sessionToken;     
    UINT32 sessionTokenLen; 
    UINT64 expiration;      
};
typedef struct __AwsCredentials* PAwsCredentials;
 
typedef struct __RequestHeader RequestHeader;
struct __RequestHeader {
    PCHAR pName;     
    UINT32 nameLen;  
    PCHAR pValue;    
    UINT32 valueLen; 
};
typedef struct __RequestHeader* PRequestHeader;
 
typedef struct __RequestInfo RequestInfo;
struct __RequestInfo {
    volatile ATOMIC_BOOL terminating;         
    HTTP_REQUEST_VERB verb;                   
    PCHAR body;                               
    UINT32 bodySize;                          
    CHAR url[MAX_URI_CHAR_LEN + 1];           
    CHAR certPath[MAX_PATH_LEN + 1];          
    CHAR sslCertPath[MAX_PATH_LEN + 1];       
    CHAR sslPrivateKeyPath[MAX_PATH_LEN + 1]; 
    SSL_CERTIFICATE_TYPE certType;            
    CHAR region[MAX_REGION_NAME_LEN + 1];     
    UINT64 currentTime;                       
    UINT64 completionTimeout;                 
    UINT64 connectionTimeout;                 
    UINT64 callAfter;                         
    UINT64 lowSpeedLimit;                     
    UINT64 lowSpeedTimeLimit;                 
    PAwsCredentials pAwsCredentials;          
    PSingleList pRequestHeaders;              
};
typedef struct __RequestInfo* PRequestInfo;
 
typedef struct __CallInfo CallInfo;
struct __CallInfo {
    PRequestInfo pRequestInfo;                        
    UINT32 httpStatus;                                
    SERVICE_CALL_RESULT callResult;                   
    CHAR errorBuffer[CALL_INFO_ERROR_BUFFER_LEN + 1]; 
    PStackQueue pResponseHeaders;                     
    PRequestHeader pRequestId;                        
    PCHAR responseData;                               
    UINT32 responseDataLen;                           
};
typedef struct __CallInfo* PCallInfo;
 
typedef struct __AwsCredentialProvider* PAwsCredentialProvider;
 
typedef STATUS (*GetCredentialsFunc)(PAwsCredentialProvider, PAwsCredentials*);
typedef struct __AwsCredentialProvider AwsCredentialProvider;
struct __AwsCredentialProvider {
    GetCredentialsFunc getCredentialsFn; 
};
 
PUBLIC_API STATUS createAwsCredentials(PCHAR, UINT32, PCHAR, UINT32, PCHAR, UINT32, UINT64, PAwsCredentials*);
 
PUBLIC_API STATUS freeAwsCredentials(PAwsCredentials*);
 
PUBLIC_API STATUS deserializeAwsCredentials(PBYTE);
 
PUBLIC_API STATUS createStaticCredentialProvider(PCHAR, UINT32, PCHAR, UINT32, PCHAR, UINT32, UINT64, PAwsCredentialProvider*);
 
PUBLIC_API STATUS freeStaticCredentialProvider(PAwsCredentialProvider*);
 
PUBLIC_API STATUS createCurlIotCredentialProvider(PCHAR, PCHAR, PCHAR, PCHAR, PCHAR, PCHAR, PAwsCredentialProvider*);
 
PUBLIC_API STATUS createLwsIotCredentialProvider(PCHAR, PCHAR, PCHAR, PCHAR, PCHAR, PCHAR, PAwsCredentialProvider*);
 
PUBLIC_API STATUS createCurlIotCredentialProviderWithTimeAndTimeout(PCHAR, PCHAR, PCHAR, PCHAR, PCHAR, PCHAR, UINT64, UINT64, GetCurrentTimeFunc,
                                                                    UINT64, PAwsCredentialProvider*);
 
PUBLIC_API STATUS createCurlIotCredentialProviderWithTime(PCHAR, PCHAR, PCHAR, PCHAR, PCHAR, PCHAR, GetCurrentTimeFunc, UINT64,
                                                          PAwsCredentialProvider*);
 
PUBLIC_API STATUS createLwsIotCredentialProviderWithTime(PCHAR, PCHAR, PCHAR, PCHAR, PCHAR, PCHAR, GetCurrentTimeFunc, UINT64,
                                                         PAwsCredentialProvider*);
 
PUBLIC_API STATUS freeIotCredentialProvider(PAwsCredentialProvider*);
 
PUBLIC_API STATUS createFileCredentialProvider(PCHAR, PAwsCredentialProvider*);
 
PUBLIC_API STATUS createFileCredentialProviderWithTime(PCHAR, GetCurrentTimeFunc, UINT64, PAwsCredentialProvider*);
 
PUBLIC_API STATUS freeFileCredentialProvider(PAwsCredentialProvider*);
 
PUBLIC_API STATUS createRequestInfo(PCHAR, PCHAR, PCHAR, PCHAR, PCHAR, PCHAR, SSL_CERTIFICATE_TYPE, PCHAR, UINT64, UINT64, UINT64, UINT64,
                                    PAwsCredentials, PRequestInfo*);
 
PUBLIC_API STATUS freeRequestInfo(PRequestInfo*);
 
PUBLIC_API STATUS signAwsRequestInfo(PRequestInfo);
 
PUBLIC_API STATUS signAwsRequestInfoQueryParam(PRequestInfo);
 
PUBLIC_API STATUS getRequestHost(PCHAR, PCHAR*, PCHAR*);
 
PUBLIC_API BOOL compareJsonString(PCHAR, jsmntok_t*, jsmntype_t, PCHAR);
 
PUBLIC_API STATUS convertTimestampToEpoch(PCHAR, UINT64, PUINT64);
 
PUBLIC_API STATUS getUserAgentString(PCHAR, PCHAR, UINT32, PCHAR);
 
PUBLIC_API STATUS requestRequiresSecureConnection(PCHAR, PBOOL);
 
PUBLIC_API STATUS setRequestHeader(PRequestInfo, PCHAR, UINT32, PCHAR, UINT32);
 
PUBLIC_API STATUS removeRequestHeader(PRequestInfo, PCHAR);
 
PUBLIC_API STATUS removeRequestHeaders(PRequestInfo);
 
PUBLIC_API STATUS createRequestHeader(PCHAR, UINT32, PCHAR, UINT32, PRequestHeader*);
 
PUBLIC_API SERVICE_CALL_RESULT getServiceCallResultFromHttpStatus(UINT32);
 
PUBLIC_API STATUS releaseCallInfo(PCallInfo);
 
PUBLIC_API STATUS createFileLogger(UINT64, UINT64, PCHAR, BOOL, BOOL, logPrintFunc*);
 
PUBLIC_API STATUS freeFileLogger();
#define SET_FILE_LOGGER()                                                                                                                            \
    createFileLogger(FILE_LOGGER_STRING_BUFFER_SIZE, FILE_LOGGER_LOG_FILE_COUNT, (PCHAR) FILE_LOGGER_LOG_FILE_DIRECTORY_PATH, TRUE, TRUE, NULL)
#define RESET_FILE_LOGGER() freeFileLogger()
 
PUBLIC_API STATUS initializeSslCallbacks();
 
PUBLIC_API STATUS releaseSslCallbacks();
 
#ifdef __cplusplus
}
#endif
#endif /* __KINESIS_VIDEO_COMMON_INCLUDE__ */