test_http_media_cache.c File Reference

Tests for the HTTP media cache backend. More...

#include "asterisk.h"
#include <fcntl.h>
#include "asterisk/module.h"
#include "asterisk/http.h"
#include "asterisk/bucket.h"
#include "asterisk/test.h"

Include dependency graph for test_http_media_cache.c:

Go to the source code of this file.

Data Structures
struct	test_options

Macros
#define	CATEGORY   "/res/http_media_cache/"
#define	SET_OR_APPEND_CACHE_CONTROL(str)
#define	TEST_URI   "test_media_cache"
#define	VALIDATE_EXPIRES(test, bucket_file, expected, delta)
#define	VALIDATE_STR_METADATA(test, bucket_file, key, expected)

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
struct ast_module *	AST_MODULE_SELF_SYM (void)
	AST_TEST_DEFINE (create_nominal)
	AST_TEST_DEFINE (retrieve_cache_control_age)
	AST_TEST_DEFINE (retrieve_cache_control_directives)
	AST_TEST_DEFINE (retrieve_content_type)
	AST_TEST_DEFINE (retrieve_etag)
	AST_TEST_DEFINE (retrieve_etag_expired)
	AST_TEST_DEFINE (retrieve_expires)
	AST_TEST_DEFINE (retrieve_nominal)
	AST_TEST_DEFINE (retrieve_parsed_uri)
static void	bucket_file_cleanup (void *obj)
static int	http_callback (struct ast_tcptls_session_instance *ser, const struct ast_http_uri *urih, const char *uri, enum ast_http_method method, struct ast_variable *get_params, struct ast_variable *headers)
static int	load_module (void)
static int	pre_test_cb (struct ast_test_info *info, struct ast_test *test)
static int	process_config (int reload)
static int	reload_module (void)
static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "HTTP Media Cache Backend Tests" , .key = ASTERISK_GPL_KEY , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .reload = reload_module, .unload = unload_module, .requires = "res_http_media_cache", }
static const struct ast_module_info *	ast_module_info = &__mod_info
static struct test_options	options
static char	server_uri [512]
static struct ast_http_uri	test_uri

Detailed Description

Tests for the HTTP media cache backend.

Author

Matt Jordan <mjordan@digium.com> 

Definition in file test_http_media_cache.c.

Macro Definition Documentation

CATEGORY

#define CATEGORY   "/res/http_media_cache/"

Definition at line 44 of file test_http_media_cache.c.

SET_OR_APPEND_CACHE_CONTROL

#define SET_OR_APPEND_CACHE_CONTROL

(

str

)

Definition at line 84 of file test_http_media_cache.c.

                                            { \
    if (!ast_str_strlen((str))) { \
        ast_str_set(&(str), 0, "%s", "cache-control: "); \
    } else { \
        ast_str_append(&(str), 0, "%s", ", "); \
    } \
} while (0)

TEST_URI

#define TEST_URI   "test_media_cache"

Definition at line 46 of file test_http_media_cache.c.

VALIDATE_EXPIRES

#define VALIDATE_EXPIRES	(		test,
			bucket_file,
			expected,
			delta
	)

Definition at line 67 of file test_http_media_cache.c.

                                                                { \
    RAII_VAR(struct ast_bucket_metadata *, metadata, ast_bucket_file_metadata_get((bucket_file), "__actual_expires"), ao2_cleanup); \
    int actual_expires; \
    ast_test_validate(test, metadata != NULL); \
    ast_test_validate(test, sscanf(metadata->value, "%d", &actual_expires) == 1); \
    ast_test_status_update(test, "Checking %d >= %d and %d <= %d\n", \
            (int) ((expected) + (delta)), actual_expires, \
            (int) ((expected) - (delta)), actual_expires); \
    ast_test_validate(test, (((expected) + (delta) >= actual_expires) && ((expected) - (delta) <= actual_expires))); \
} while (0)

VALIDATE_STR_METADATA

#define VALIDATE_STR_METADATA	(		test,
			bucket_file,
			key,
			expected
	)

Value:

    do { \
    RAII_VAR(struct ast_bucket_metadata *, metadata, ast_bucket_file_metadata_get((bucket_file), (key)), ao2_cleanup); \
    ast_test_validate(test, metadata != NULL); \
    ast_test_validate(test, !strcmp(metadata->value, (expected))); \
} while (0)

Definition at line 78 of file test_http_media_cache.c.

                                                                   { \
    RAII_VAR(struct ast_bucket_metadata *, metadata, ast_bucket_file_metadata_get((bucket_file), (key)), ao2_cleanup); \
    ast_test_validate(test, metadata != NULL); \
    ast_test_validate(test, !strcmp(metadata->value, (expected))); \
} while (0)

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 779 of file test_http_media_cache.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 779 of file test_http_media_cache.c.

AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM

(

void

)

Definition at line 779 of file test_http_media_cache.c.

AST_TEST_DEFINE() [1/9]

AST_TEST_DEFINE

(

create_nominal

)

Definition at line 647 of file test_http_media_cache.c.

{
    RAII_VAR(struct ast_bucket_file *, bucket_file, NULL, bucket_file_cleanup);
    struct timeval now = ast_tvnow();
    char uri[1024];
 
    switch (cmd) {
    case TEST_INIT:
        info->name = __func__;
        info->category = CATEGORY;
        info->summary = "Test nominal creation";
        info->description =
            "Test nominal creation of a resource.";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    options.send_file = 1;
    options.status_code = 200;
    options.status_text = "OK";
 
    snprintf(uri, sizeof(uri), "%s/%s", server_uri, "foo.wav");
 
    bucket_file = ast_bucket_file_alloc(uri);
    ast_test_validate(test, bucket_file != NULL);
    ast_test_validate(test, ast_bucket_file_temporary_create(bucket_file) == 0);
    ast_test_validate(test, ast_bucket_file_create(bucket_file) == 0);
    VALIDATE_EXPIRES(test, bucket_file, now.tv_sec, 3);
 
    return AST_TEST_PASS;
}

References ast_bucket_file_alloc(), ast_bucket_file_create(), ast_bucket_file_temporary_create(), AST_TEST_NOT_RUN, AST_TEST_PASS, ast_tvnow(), bucket_file_cleanup(), CATEGORY, NULL, options, RAII_VAR, test_options::send_file, server_uri, test_options::status_code, test_options::status_text, TEST_EXECUTE, TEST_INIT, and VALIDATE_EXPIRES.

AST_TEST_DEFINE() [2/9]

AST_TEST_DEFINE

(

retrieve_cache_control_age

)

Definition at line 379 of file test_http_media_cache.c.

{
    RAII_VAR(struct ast_bucket_file *, bucket_file, NULL, bucket_file_cleanup);
    struct timeval now = ast_tvnow();
    char uri[1024];
 
    switch (cmd) {
    case TEST_INIT:
        info->name = __func__;
        info->category = CATEGORY;
        info->summary = "Test retrieval of a resource with age specifiers in Cache-Control";
        info->description =
            "This test covers retrieval of a resource with the Cache-Control header,\n"
            "which specifies max-age and/or s-maxage. The test verifies proper precedence\n"
            "ordering of the header attributes, along with its relation if the Expires\n"
            "header is present.";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    snprintf(uri, sizeof(uri), "%s/%s", server_uri, "foo.wav");
 
    options.send_file = 1;
    options.status_code = 200;
    options.status_text = "OK";
 
    ast_test_status_update(test, "Testing max-age...\n");
    options.cache_control.maxage = 300;
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    VALIDATE_EXPIRES(test, bucket_file, now.tv_sec + 300, 3);
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 0);
    bucket_file_cleanup(bucket_file);
 
    ast_test_status_update(test, "Testing s-maxage...\n");
    now = ast_tvnow();
    options.cache_control.maxage = 0;
    options.cache_control.s_maxage = 300;
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    VALIDATE_EXPIRES(test, bucket_file, now.tv_sec + 300, 3);
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 0);
    bucket_file_cleanup(bucket_file);
 
    ast_test_status_update(test, "Testing max-age and s-maxage...\n");
    now = ast_tvnow();
    options.cache_control.maxage = 300;
    options.cache_control.s_maxage = 600;
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    VALIDATE_EXPIRES(test, bucket_file, now.tv_sec + 600, 3);
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 0);
    bucket_file_cleanup(bucket_file);
 
    ast_test_status_update(test, "Testing max-age and Expires...\n");
    now = ast_tvnow();
    options.cache_control.maxage = 300;
    options.cache_control.s_maxage = 0;
    options.expires.tv_sec = now.tv_sec + 3000;
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    VALIDATE_EXPIRES(test, bucket_file, now.tv_sec + 300, 3);
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 0);
    bucket_file_cleanup(bucket_file);
 
    ast_test_status_update(test, "Testing s-maxage and Expires...\n");
    now = ast_tvnow();
    options.cache_control.maxage = 0;
    options.cache_control.s_maxage = 300;
    options.expires.tv_sec = now.tv_sec + 3000;
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    VALIDATE_EXPIRES(test, bucket_file, now.tv_sec + 300, 3);
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 0);
    bucket_file_cleanup(bucket_file);
 
    ast_test_status_update(test, "Testing s-maxage and Expires...\n");
    now = ast_tvnow();
    options.cache_control.maxage = 0;
    options.cache_control.s_maxage = 300;
    options.expires.tv_sec = now.tv_sec + 3000;
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    VALIDATE_EXPIRES(test, bucket_file, now.tv_sec + 300, 3);
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 0);
    bucket_file_cleanup(bucket_file);
 
    ast_test_status_update(test, "Testing max-age, s-maxage, and Expires...\n");
    now = ast_tvnow();
    options.cache_control.maxage = 300;
    options.cache_control.s_maxage = 600;
    options.expires.tv_sec = now.tv_sec + 3000;
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    VALIDATE_EXPIRES(test, bucket_file, now.tv_sec + 600, 3);
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 0);
 
    return AST_TEST_PASS;
}

References ast_bucket_file_is_stale(), ast_bucket_file_retrieve(), AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, ast_tvnow(), bucket_file_cleanup(), test_options::cache_control, CATEGORY, test_options::expires, test_options::maxage, NULL, options, RAII_VAR, test_options::s_maxage, test_options::send_file, server_uri, test_options::status_code, test_options::status_text, TEST_EXECUTE, TEST_INIT, and VALIDATE_EXPIRES.

AST_TEST_DEFINE() [3/9]

AST_TEST_DEFINE

(

retrieve_cache_control_directives

)

Definition at line 297 of file test_http_media_cache.c.

{
    RAII_VAR(struct ast_bucket_file *, bucket_file, NULL, bucket_file_cleanup);
    struct timeval now = ast_tvnow();
    char uri[1024];
 
    switch (cmd) {
    case TEST_INIT:
        info->name = __func__;
        info->category = CATEGORY;
        info->summary = "Test retrieval of a resource with Cache-Control directives that affect staleness";
        info->description =
            "This test covers retrieval of a resource with the Cache-Control header,\n"
            "which specifies no-cache and/or must-revalidate.";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    snprintf(uri, sizeof(uri), "%s/%s", server_uri, "foo.wav");
 
    options.send_file = 1;
    options.status_code = 200;
    options.status_text = "OK";
 
    ast_test_status_update(test, "Testing no-cache...\n");
    options.cache_control.no_cache = 1;
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 1);
    bucket_file_cleanup(bucket_file);
 
    ast_test_status_update(test, "Testing no-cache with ETag...\n");
    options.cache_control.no_cache = 1;
    options.etag = "123456789";
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 0);
    bucket_file_cleanup(bucket_file);
 
    options.etag = NULL;
 
    ast_test_status_update(test, "Testing no-cache with max-age...\n");
    options.cache_control.no_cache = 1;
    options.cache_control.maxage = 300;
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    VALIDATE_EXPIRES(test, bucket_file, now.tv_sec + 300, 3);
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 1);
    bucket_file_cleanup(bucket_file);
 
    options.cache_control.maxage = 0;
    options.cache_control.no_cache = 0;
 
    ast_test_status_update(test, "Testing must-revalidate...\n");
    options.cache_control.must_revalidate = 1;
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 1);
    bucket_file_cleanup(bucket_file);
 
    ast_test_status_update(test, "Testing must-revalidate with ETag...\n");
    options.cache_control.must_revalidate = 1;
    options.etag = "123456789";
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 0);
    bucket_file_cleanup(bucket_file);
 
    options.etag = NULL;
 
    ast_test_status_update(test, "Testing must-revalidate with max-age...\n");
    options.cache_control.must_revalidate = 1;
    options.cache_control.maxage = 300;
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    VALIDATE_EXPIRES(test, bucket_file, now.tv_sec + 300, 3);
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 1);
 
    return AST_TEST_PASS;
}

References ast_bucket_file_is_stale(), ast_bucket_file_retrieve(), AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, ast_tvnow(), bucket_file_cleanup(), test_options::cache_control, CATEGORY, test_options::etag, test_options::maxage, test_options::must_revalidate, test_options::no_cache, NULL, options, RAII_VAR, test_options::send_file, server_uri, test_options::status_code, test_options::status_text, TEST_EXECUTE, TEST_INIT, and VALIDATE_EXPIRES.

AST_TEST_DEFINE() [4/9]

AST_TEST_DEFINE

(

retrieve_content_type

)

Definition at line 228 of file test_http_media_cache.c.

{
    RAII_VAR(struct ast_bucket_file *, bucket_file, NULL, bucket_file_cleanup);
    char uri[1024];
 
    switch (cmd) {
    case TEST_INIT:
        info->name = __func__;
        info->category = CATEGORY;
        info->summary = "Test retrieval of a resource with a Content-Type header";
        info->description =
            "This test covers retrieval of a resource whose URL does not end with\n"
            "a parseable extension and whose response includes a Content-Type\n"
            "header that we recognize.";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    options.send_file = 1;
    options.status_code = 200;
    options.status_text = "OK";
    options.content_type = "audio/wav";
 
    snprintf(uri, sizeof(uri), "%s/%s", server_uri, "foo.wav?account_id=1234");
 
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    ast_test_validate(test, !strcmp(uri, ast_sorcery_object_get_id(bucket_file)));
    ast_test_validate(test, !ast_strlen_zero(bucket_file->path));
    VALIDATE_STR_METADATA(test, bucket_file, "ext", ".wav");
 
    return AST_TEST_PASS;
}

References ast_bucket_file_retrieve(), ast_sorcery_object_get_id(), ast_strlen_zero(), AST_TEST_NOT_RUN, AST_TEST_PASS, bucket_file_cleanup(), CATEGORY, test_options::content_type, NULL, options, RAII_VAR, test_options::send_file, server_uri, test_options::status_code, test_options::status_text, TEST_EXECUTE, TEST_INIT, and VALIDATE_STR_METADATA.

AST_TEST_DEFINE() [5/9]

AST_TEST_DEFINE

(

retrieve_etag

)

Definition at line 571 of file test_http_media_cache.c.

{
    RAII_VAR(struct ast_bucket_file *, bucket_file, NULL, bucket_file_cleanup);
    struct timeval now = ast_tvnow();
    char uri[1024];
 
    switch (cmd) {
    case TEST_INIT:
        info->name = __func__;
        info->category = CATEGORY;
        info->summary = "Test retrieval with an ETag";
        info->description =
            "This test covers retrieving a resource that has an ETag.\n"
            "After retrieval of the resource, staleness is checked. With\n"
            "matching ETags, we expect the resource to not be stale. When\n"
            "the ETag does not match, we expect the resource to be stale.";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    options.send_file = 1;
    options.status_code = 200;
    options.status_text = "OK";
    options.etag = "123456789";
 
    snprintf(uri, sizeof(uri), "%s/%s", server_uri, "foo.wav");
 
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    ast_test_validate(test, !strcmp(uri, ast_sorcery_object_get_id(bucket_file)));
    ast_test_validate(test, !ast_strlen_zero(bucket_file->path));
    VALIDATE_STR_METADATA(test, bucket_file, "etag", options.etag);
    VALIDATE_EXPIRES(test, bucket_file, now.tv_sec, 3);
 
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 0);
 
    options.etag = "99999999";
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 1);
 
    return AST_TEST_PASS;
}

References ast_bucket_file_is_stale(), ast_bucket_file_retrieve(), ast_sorcery_object_get_id(), ast_strlen_zero(), AST_TEST_NOT_RUN, AST_TEST_PASS, ast_tvnow(), bucket_file_cleanup(), CATEGORY, test_options::etag, NULL, options, RAII_VAR, test_options::send_file, server_uri, test_options::status_code, test_options::status_text, TEST_EXECUTE, TEST_INIT, VALIDATE_EXPIRES, and VALIDATE_STR_METADATA.

AST_TEST_DEFINE() [6/9]

AST_TEST_DEFINE

(

retrieve_etag_expired

)

Definition at line 480 of file test_http_media_cache.c.

{
    RAII_VAR(struct ast_bucket_file *, bucket_file, NULL, bucket_file_cleanup);
    struct timeval now = ast_tvnow();
    char uri[1024];
 
    switch (cmd) {
    case TEST_INIT:
        info->name = __func__;
        info->category = CATEGORY;
        info->summary = "Test retrieval of an expired resource with an ETag";
        info->description =
            "This test covers a staleness check of a resource with an ETag\n"
            "that has also expired. It guarantees that even if a resource\n"
            "is expired, we will still not consider it stale if the resource\n"
            "has not changed per the ETag value.";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    options.send_file = 1;
    options.status_code = 200;
    options.status_text = "OK";
    options.etag = "123456789";
    options.expires.tv_sec = now.tv_sec - 1;
 
    snprintf(uri, sizeof(uri), "%s/%s", server_uri, "foo.wav");
 
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    ast_test_validate(test, !strcmp(uri, ast_sorcery_object_get_id(bucket_file)));
    ast_test_validate(test, !ast_strlen_zero(bucket_file->path));
    VALIDATE_STR_METADATA(test, bucket_file, "etag", options.etag);
    VALIDATE_EXPIRES(test, bucket_file, now.tv_sec - 1, 3);
 
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 0);
 
    return AST_TEST_PASS;
}

References ast_bucket_file_is_stale(), ast_bucket_file_retrieve(), ast_sorcery_object_get_id(), ast_strlen_zero(), AST_TEST_NOT_RUN, AST_TEST_PASS, ast_tvnow(), bucket_file_cleanup(), CATEGORY, test_options::etag, test_options::expires, NULL, options, RAII_VAR, test_options::send_file, server_uri, test_options::status_code, test_options::status_text, TEST_EXECUTE, TEST_INIT, VALIDATE_EXPIRES, and VALIDATE_STR_METADATA.

AST_TEST_DEFINE() [7/9]

AST_TEST_DEFINE

(

retrieve_expires

)

Definition at line 521 of file test_http_media_cache.c.

{
    RAII_VAR(struct ast_bucket_file *, bucket_file, NULL, bucket_file_cleanup);
    struct timeval now = ast_tvnow();
    char uri[1024];
 
    switch (cmd) {
    case TEST_INIT:
        info->name = __func__;
        info->category = CATEGORY;
        info->summary = "Test retrieval with explicit expiration";
        info->description =
            "This test covers retrieving a resource that has an Expires.\n"
            "After retrieval of the resource, staleness is checked. With\n"
            "a non-expired resource, we expect the resource to not be stale.\n"
            "When the expiration has occurred, we expect the staleness check\n"
            "to fail.";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    options.send_file = 1;
    options.status_code = 200;
    options.status_text = "OK";
    options.expires.tv_sec = now.tv_sec + 3000;
 
    snprintf(uri, sizeof(uri), "%s/%s", server_uri, "foo.wav");
 
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    ast_test_validate(test, !strcmp(uri, ast_sorcery_object_get_id(bucket_file)));
    ast_test_validate(test, !ast_strlen_zero(bucket_file->path));
    VALIDATE_EXPIRES(test, bucket_file, now.tv_sec + 3000, 3);
 
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 0);
 
    /* Clean up previous result */
    bucket_file_cleanup(bucket_file);
 
    options.expires.tv_sec = now.tv_sec - 1;
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    VALIDATE_EXPIRES(test, bucket_file, now.tv_sec - 1, 3);
 
    ast_test_validate(test, ast_bucket_file_is_stale(bucket_file) == 1);
 
    return AST_TEST_PASS;
}

References ast_bucket_file_is_stale(), ast_bucket_file_retrieve(), ast_sorcery_object_get_id(), ast_strlen_zero(), AST_TEST_NOT_RUN, AST_TEST_PASS, ast_tvnow(), bucket_file_cleanup(), CATEGORY, test_options::expires, NULL, options, RAII_VAR, test_options::send_file, server_uri, test_options::status_code, test_options::status_text, TEST_EXECUTE, TEST_INIT, and VALIDATE_EXPIRES.

AST_TEST_DEFINE() [8/9]

AST_TEST_DEFINE

(

retrieve_nominal

)

Definition at line 614 of file test_http_media_cache.c.

{
    RAII_VAR(struct ast_bucket_file *, bucket_file, NULL, bucket_file_cleanup);
    struct timeval now = ast_tvnow();
    char uri[1024];
 
    switch (cmd) {
    case TEST_INIT:
        info->name = __func__;
        info->category = CATEGORY;
        info->summary = "Test nominal retrieval";
        info->description =
            "Test nominal retrieval of a resource.";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    options.send_file = 1;
    options.status_code = 200;
    options.status_text = "OK";
 
    snprintf(uri, sizeof(uri), "%s/%s", server_uri, "foo.wav");
 
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    ast_test_validate(test, !strcmp(uri, ast_sorcery_object_get_id(bucket_file)));
    ast_test_validate(test, !ast_strlen_zero(bucket_file->path));
    VALIDATE_EXPIRES(test, bucket_file, now.tv_sec, 3);
 
    return AST_TEST_PASS;
}

References ast_bucket_file_retrieve(), ast_sorcery_object_get_id(), ast_strlen_zero(), AST_TEST_NOT_RUN, AST_TEST_PASS, ast_tvnow(), bucket_file_cleanup(), CATEGORY, NULL, options, RAII_VAR, test_options::send_file, server_uri, test_options::status_code, test_options::status_text, TEST_EXECUTE, TEST_INIT, and VALIDATE_EXPIRES.

AST_TEST_DEFINE() [9/9]

AST_TEST_DEFINE

(

retrieve_parsed_uri

)

Definition at line 263 of file test_http_media_cache.c.

{
    RAII_VAR(struct ast_bucket_file *, bucket_file, NULL, bucket_file_cleanup);
    char uri[1024];
 
    switch (cmd) {
    case TEST_INIT:
        info->name = __func__;
        info->category = CATEGORY;
        info->summary = "Test retrieval of a resource with a complex URI";
        info->description =
            "This test covers retrieval of a resource whose URL does not end with\n"
            "a parseable extension, but the path portion of the URL does end with\n"
            "parseable extension.";
        return AST_TEST_NOT_RUN;
    case TEST_EXECUTE:
        break;
    }
 
    options.send_file = 1;
    options.status_code = 200;
    options.status_text = "OK";
 
    snprintf(uri, sizeof(uri), "%s/%s", server_uri, "foo.wav?account_id=1234");
 
    bucket_file = ast_bucket_file_retrieve(uri);
    ast_test_validate(test, bucket_file != NULL);
    ast_test_validate(test, !strcmp(uri, ast_sorcery_object_get_id(bucket_file)));
    ast_test_validate(test, !ast_strlen_zero(bucket_file->path));
    VALIDATE_STR_METADATA(test, bucket_file, "ext", ".wav");
 
    return AST_TEST_PASS;
}

References ast_bucket_file_retrieve(), ast_sorcery_object_get_id(), ast_strlen_zero(), AST_TEST_NOT_RUN, AST_TEST_PASS, bucket_file_cleanup(), CATEGORY, NULL, options, RAII_VAR, test_options::send_file, server_uri, test_options::status_code, test_options::status_text, TEST_EXECUTE, TEST_INIT, and VALIDATE_STR_METADATA.

bucket_file_cleanup()

static void bucket_file_cleanup ( void *  obj )

static

Definition at line 218 of file test_http_media_cache.c.

{
    struct ast_bucket_file *bucket_file = obj;
 
    if (bucket_file) {
        ast_bucket_file_delete(bucket_file);
        ao2_ref(bucket_file, -1);
    }
}

References ao2_ref, and ast_bucket_file_delete().

Referenced by AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), and AST_TEST_DEFINE().

http_callback()

static int http_callback ( struct ast_tcptls_session_instance *  ser, const struct ast_http_uri *  urih, const char *  uri, enum ast_http_method  method, struct ast_variable *  get_params, struct ast_variable *  headers  )

static

Definition at line 92 of file test_http_media_cache.c.

{
    char file_name[64] = "/tmp/test-media-cache-XXXXXX";
    struct ast_str *http_header = ast_str_create(128);
    struct ast_str *cache_control = ast_str_create(128);
    int fd = -1;
    int unmodified = 0;
    int send_file = options.send_file && method == AST_HTTP_GET;
 
    if (!http_header) {
        goto error;
    }
 
    if (send_file) {
        char buf[1024];
 
        fd = mkstemp(file_name);
        if (fd == -1) {
            ast_log(LOG_ERROR, "Unable to open temp file for testing: %s (%d)", strerror(errno), errno);
            goto error;
        }
 
        memset(buf, 1, sizeof(buf));
        if (write(fd, buf, sizeof(buf)) != sizeof(buf)) {
            ast_log(LOG_ERROR, "Failed to write expected number of bytes to pipe\n");
            close(fd);
            goto error;
        }
        close(fd);
 
        fd = open(file_name, 0);
        if (fd == -1) {
            ast_log(LOG_ERROR, "Unable to open temp file for testing: %s (%d)", strerror(errno), errno);
            goto error;
        }
    }
 
    if (!ast_strlen_zero(options.content_type)) {
        ast_str_append(&http_header, 0, "Content-Type: %s\r\n", options.content_type);
    }
 
    if (options.cache_control.maxage) {
        SET_OR_APPEND_CACHE_CONTROL(cache_control);
        ast_str_append(&cache_control, 0, "max-age=%d", options.cache_control.maxage);
    }
 
    if (options.cache_control.s_maxage) {
        SET_OR_APPEND_CACHE_CONTROL(cache_control);
        ast_str_append(&cache_control, 0, "s-maxage=%d", options.cache_control.s_maxage);
    }
 
    if (options.cache_control.no_cache) {
        SET_OR_APPEND_CACHE_CONTROL(cache_control);
        ast_str_append(&cache_control, 0, "%s", "no-cache");
    }
 
    if (options.cache_control.must_revalidate) {
        SET_OR_APPEND_CACHE_CONTROL(cache_control);
        ast_str_append(&cache_control, 0, "%s", "must-revalidate");
    }
 
    if (ast_str_strlen(cache_control)) {
        ast_str_append(&http_header, 0, "%s\r\n", ast_str_buffer(cache_control));
    }
 
    if (options.expires.tv_sec) {
        struct ast_tm now_time;
        char tmbuf[64];
 
        ast_localtime(&options.expires, &now_time, NULL);
        ast_strftime(tmbuf, sizeof(tmbuf), "%a, %d %b %Y %T %z", &now_time);
        ast_str_append(&http_header, 0, "Expires: %s\r\n", tmbuf);
    }
 
    if (!ast_strlen_zero(options.etag)) {
        struct ast_variable *v;
 
        ast_str_append(&http_header, 0, "ETag: %s\r\n", options.etag);
        for (v = headers; v; v = v->next) {
            if (!strcasecmp(v->name, "If-None-Match") && !strcasecmp(v->value, options.etag)) {
                unmodified = 1;
                break;
            }
        }
    }
 
    if (!unmodified) {
        ast_http_send(ser, method, options.status_code, options.status_text, http_header, NULL, send_file ? fd : 0, 1);
    } else {
        ast_http_send(ser, method, 304, "Not Modified", http_header, NULL, 0, 1);
    }
 
    if (send_file) {
        close(fd);
        unlink(file_name);
    }
 
    ast_free(cache_control);
 
    return 0;
 
error:
    ast_free(http_header);
    ast_free(cache_control);
    ast_http_request_close_on_completion(ser);
    ast_http_error(ser, 418, "I'm a Teapot", "Please don't ask me to brew coffee.");
 
    return 0;
}

References ast_free, ast_http_error(), AST_HTTP_GET, ast_http_request_close_on_completion(), ast_http_send(), ast_localtime(), ast_log, ast_str_append(), ast_str_buffer(), ast_str_create, ast_str_strlen(), ast_strftime(), ast_strlen_zero(), buf, test_options::cache_control, test_options::content_type, errno, error(), test_options::etag, test_options::expires, LOG_ERROR, test_options::maxage, method, test_options::must_revalidate, ast_variable::name, ast_variable::next, test_options::no_cache, NULL, options, test_options::s_maxage, test_options::send_file, SET_OR_APPEND_CACHE_CONTROL, test_options::status_code, test_options::status_text, and ast_variable::value.

load_module()

static int load_module ( void  )

static

Definition at line 729 of file test_http_media_cache.c.

{
    if (process_config(0)) {
        return AST_MODULE_LOAD_DECLINE;
    }
 
    if (ast_http_uri_link(&test_uri)) {
        return AST_MODULE_LOAD_DECLINE;
    }
 
    AST_TEST_REGISTER(create_nominal);
 
    AST_TEST_REGISTER(retrieve_nominal);
    AST_TEST_REGISTER(retrieve_etag);
    AST_TEST_REGISTER(retrieve_expires);
    AST_TEST_REGISTER(retrieve_etag_expired);
    AST_TEST_REGISTER(retrieve_cache_control_age);
    AST_TEST_REGISTER(retrieve_cache_control_directives);
    AST_TEST_REGISTER(retrieve_parsed_uri);
    AST_TEST_REGISTER(retrieve_content_type);
 
    ast_test_register_init(CATEGORY, pre_test_cb);
 
    return AST_MODULE_LOAD_SUCCESS;
}

References ast_http_uri_link(), AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, AST_TEST_REGISTER, CATEGORY, pre_test_cb(), process_config(), and test_uri.

pre_test_cb()

static int pre_test_cb ( struct ast_test_info *  info, struct ast_test *  test  )

static

Definition at line 211 of file test_http_media_cache.c.

{
    memset(&options, 0, sizeof(options));
 
    return 0;
}

References options.

Referenced by load_module().

process_config()

static int process_config ( int  reload )

static

Definition at line 681 of file test_http_media_cache.c.

{
    struct ast_config *config;
    struct ast_flags config_flags = { reload ? CONFIG_FLAG_FILEUNCHANGED : 0 };
    const char *bindaddr;
    const char *bindport;
    const char *prefix;
    const char *enabled;
 
    config = ast_config_load("http.conf", config_flags);
    if (!config || config == CONFIG_STATUS_FILEINVALID) {
        return -1;
    } else if (config == CONFIG_STATUS_FILEUNCHANGED) {
        return 0;
    }
 
    enabled = ast_config_option(config, "general", "enabled");
    if (!enabled || ast_false(enabled)) {
        ast_config_destroy(config);
        return -1;
    }
 
    /* Construct our Server URI */
    bindaddr = ast_config_option(config, "general", "bindaddr");
    if (!bindaddr) {
        ast_config_destroy(config);
        return -1;
    }
 
    bindport = ast_config_option(config, "general", "bindport");
    if (!bindport) {
        bindport = "8088";
    }
 
    prefix = ast_config_option(config, "general", "prefix");
 
    snprintf(server_uri, sizeof(server_uri), "http://%s:%s%s/%s", bindaddr, bindport, S_OR(prefix, ""), TEST_URI);
 
    ast_config_destroy(config);
 
    return 0;
}

References ast_config_destroy(), ast_config_load, ast_config_option(), ast_false(), bindaddr, config, CONFIG_FLAG_FILEUNCHANGED, CONFIG_STATUS_FILEINVALID, CONFIG_STATUS_FILEUNCHANGED, enabled, prefix, reload(), S_OR, server_uri, and TEST_URI.

Referenced by load_module(), and reload_module().

reload_module()

static int reload_module ( void  )

static

Definition at line 724 of file test_http_media_cache.c.

{
    return process_config(1);
}

References process_config().

unload_module()

static int unload_module ( void  )

static

Definition at line 755 of file test_http_media_cache.c.

{
    ast_http_uri_unlink(&test_uri);
 
    AST_TEST_UNREGISTER(create_nominal);
 
    AST_TEST_UNREGISTER(retrieve_nominal);
    AST_TEST_UNREGISTER(retrieve_etag);
    AST_TEST_UNREGISTER(retrieve_expires);
    AST_TEST_UNREGISTER(retrieve_etag_expired);
    AST_TEST_UNREGISTER(retrieve_cache_control_age);
    AST_TEST_UNREGISTER(retrieve_cache_control_directives);
    AST_TEST_UNREGISTER(retrieve_parsed_uri);
    AST_TEST_UNREGISTER(retrieve_content_type);
 
    return 0;
}

References ast_http_uri_unlink(), AST_TEST_UNREGISTER, and test_uri.

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "HTTP Media Cache Backend Tests" , .key = ASTERISK_GPL_KEY , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .reload = reload_module, .unload = unload_module, .requires = "res_http_media_cache", }

static

Definition at line 779 of file test_http_media_cache.c.

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 779 of file test_http_media_cache.c.

options

struct test_options options

static

Examples

app_skel.c.

Definition at line 63 of file test_http_media_cache.c.

Referenced by __ao2_alloc(), __ast_sorcery_apply_config(), __ssl_setup(), aeap_cli_show(), agent_connect_caller(), agent_login_exec(), app_exec(), app_exec(), app_exec(), apply_options(), aqm_exec(), ast_app_options2str64(), ast_app_parse_options(), ast_app_parse_options64(), ast_ari_bridges_record(), ast_ari_channels_record(), ast_cdr_fork(), ast_fax_maxrate(), ast_fax_minrate(), ast_get_enum(), ast_multicast_rtp_create_options(), ast_rtp_codecs_payloads_set_rtpmap_type(), ast_rtp_codecs_payloads_set_rtpmap_type_rate(), ast_rtp_lookup_mime_multiple2(), ast_rtp_lookup_mime_subtype2(), ast_say_enumeration(), ast_say_enumeration_full_da(), ast_say_enumeration_full_de(), ast_say_enumeration_full_he(), ast_say_enumeration_full_is(), ast_say_number(), ast_say_number_full_cs(), ast_say_number_full_da(), ast_say_number_full_de(), ast_say_number_full_es(), ast_say_number_full_fr(), ast_say_number_full_he(), ast_say_number_full_is(), ast_say_number_full_no(), ast_say_number_full_pl(), ast_say_number_full_pt(), ast_say_number_full_ru(), ast_say_number_full_se(), ast_say_number_full_ur(), ast_say_ordinal(), ast_smdi_md_message_wait(), ast_smdi_mwi_message_wait(), ast_smdi_mwi_message_wait_station(), ast_sorcery_init(), ast_start_mixmonitor(), ast_taskpool_create(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), ast_threadpool_create(), ast_websocket_client_connect(), ast_websocket_client_create(), ast_websocket_client_create_with_options(), audiosocket_request(), auth_exec(), bridge_exec(), bridgewait_exec(), broadcast_exec(), cdr_prop_write_callback(), cdr_read_callback(), cdr_write(), cdr_write_callback(), chanavail_exec(), chanspy_exec(), cli_fax_show_settings(), conf_exec(), config_object_cli_show(), controlplayback_exec(), detect_write(), dial_exec_full(), directory_exec(), disa_exec(), do_say(), dundi_query_read(), dundifunc_read(), enable_jack_hook(), extenspy_exec(), feature_automixmonitor(), file_read(), file_write(), forkcdr_exec(), function_enum(), g722_decode_init(), g722_encode_init(), generate_rtpmap_attr(), generate_rtpmap_attr2(), geoloc_profile_read(), geoloc_profile_write(), get_codecs(), get_general_options(), handle_cli_presencestate_change(), handle_cli_presencestate_list(), handle_cli_taskpool_push_efficiency(), handle_cli_taskpool_push_serializer_efficiency(), handle_cli_threadpool_push_efficiency(), handle_cli_threadpool_push_serializer_efficiency(), handle_options(), handle_updates(), hash_ao2_container_init(), hash_ao2_insert_node(), hint_read(), http_callback(), internal_ao2_alloc(), json_decode_read(), leave_voicemail(), leave_voicemail(), load_module(), manager_mixmonitor(), milliwatt_exec(), mixmonitor_exec(), multicast_rtp_request(), originate_exec(), page_exec(), page_state_callback(), park_and_announce_app_exec(), park_app_parse_data(), parse_data(), parse_options(), pbx_builtin_answer(), pbx_builtin_background(), pbx_builtin_incomplete(), pbx_builtin_saycharacters_case(), pbx_builtin_saynumber(), pbx_builtin_sayordinal(), pbx_builtin_waitexten(), pickupchan_exec(), playback_exec(), pqm_exec(), pre_session_setup(), pre_test_cb(), presence_read(), presence_write(), privacy_exec(), process_dahdi(), queue_exec(), queue_match(), rb_ao2_container_init(), rb_ao2_insert_node(), read_exec(), read_mf_exec(), read_sf_exec(), readexten_exec(), receivefax_exec(), record_exec(), recording_options_dtor(), say_enumeration_full(), say_enumeration_full(), say_full(), say_number_full(), say_number_full(), sayunixtime_exec(), scan_exec(), search_directory_sub(), senddtmf_exec(), sendfax_exec(), session_details_new(), set_config(), set_general_options(), setup_profile_bridge(), setup_profile_caller(), setup_profile_paged(), sla_add_trunk_to_station(), sla_trunk_exec(), smdi_message_wait(), smdi_msg_find(), smdi_msg_retrieve_read(), sms_exec(), softhangup_exec(), sorcery_memory_cache_open(), speech_background(), start_mixmonitor_callback(), stasis_app_control_record(), stasis_app_recording_options_create(), test_make_nonsorted(), test_make_sorted(), threadpool_alloc(), unicast_rtp_request(), upqm_exec(), vmauthenticate(), volume_read(), volume_write(), wait_exec(), webchan_request(), websocket_client_create(), xmpp_pubsub_build_publish_skeleton(), xmpp_pubsub_subscribe(), and zapateller_exec().

server_uri

char server_uri[512]

static

Definition at line 65 of file test_http_media_cache.c.

Referenced by AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), handle_registration_response(), load_module(), load_module(), process_config(), schedule_retry(), sip_outbound_publisher_init(), sip_outbound_publisher_set_uris(), and sip_outbound_registration_regc_alloc().

test_uri

struct ast_http_uri test_uri

static

Definition at line 202 of file test_http_media_cache.c.

                                      {
    .description = "HTTP Media Cache Test URI",
    .uri = TEST_URI,
    .callback = http_callback,
    .has_subtree = 1,
    .data = NULL,
    .key = __FILE__,
};

Referenced by load_module(), and unload_module().