pristine-store-test.c [plain text]
#include <apr_pools.h>
#include <apr_general.h>
#include "svn_types.h"
#ifdef SVN_DEPRECATED
#undef SVN_DEPRECATED
#endif
#define SVN_DEPRECATED
#include "svn_io.h"
#include "svn_dirent_uri.h"
#include "svn_pools.h"
#include "svn_repos.h"
#include "svn_wc.h"
#include "svn_client.h"
#include "utils.h"
#include "../../libsvn_wc/wc.h"
#include "../../libsvn_wc/wc_db.h"
#include "../../libsvn_wc/wc-queries.h"
#include "../../libsvn_wc/workqueue.h"
#include "private/svn_wc_private.h"
#include "../svn_test.h"
static svn_error_t *
create_repos_and_wc(const char **wc_abspath,
svn_wc__db_t **db,
const char *test_name,
const svn_test_opts_t *opts,
apr_pool_t *pool)
{
svn_test__sandbox_t sandbox;
SVN_ERR(svn_test__sandbox_create(&sandbox, test_name, opts, pool));
*wc_abspath = sandbox.wc_abspath;
*db = sandbox.wc_ctx->db;
return SVN_NO_ERROR;
}
static svn_error_t *
write_and_checksum_temp_file(const char **file_abspath,
svn_checksum_t **sha1_checksum,
svn_checksum_t **md5_checksum,
const char *data,
const char *dir_abspath,
apr_pool_t *pool)
{
apr_file_t *file;
SVN_ERR(svn_io_open_unique_file3(&file, file_abspath,
dir_abspath, svn_io_file_del_none,
pool, pool));
SVN_ERR(svn_io_file_write_full(file, data, strlen(data), NULL, pool));
SVN_ERR(svn_io_file_close(file, pool));
if (sha1_checksum)
SVN_ERR(svn_io_file_checksum2(sha1_checksum, *file_abspath,
svn_checksum_sha1, pool));
if (md5_checksum)
SVN_ERR(svn_io_file_checksum2(md5_checksum, *file_abspath,
svn_checksum_md5, pool));
return SVN_NO_ERROR;
}
static svn_error_t *
pristine_write_read(const svn_test_opts_t *opts,
apr_pool_t *pool)
{
svn_wc__db_t *db;
const char *wc_abspath;
const char *pristine_tmp_abspath;
const char data[] = "Blah";
svn_string_t *data_string = svn_string_create(data, pool);
svn_checksum_t *data_sha1, *data_md5;
SVN_ERR(create_repos_and_wc(&wc_abspath, &db,
"pristine_write_read", opts, pool));
{
const char *pristine_tmp_dir;
SVN_ERR(svn_wc__db_pristine_get_tempdir(&pristine_tmp_dir, db,
wc_abspath, pool, pool));
SVN_ERR(write_and_checksum_temp_file(&pristine_tmp_abspath,
&data_sha1, &data_md5,
data, pristine_tmp_dir, pool));
}
{
svn_boolean_t present;
SVN_ERR(svn_wc__db_pristine_check(&present, db, wc_abspath, data_sha1,
pool));
SVN_TEST_ASSERT(! present);
}
SVN_ERR(svn_wc__db_pristine_install(db, pristine_tmp_abspath,
data_sha1, data_md5, pool));
{
svn_boolean_t present;
SVN_ERR(svn_wc__db_pristine_check(&present, db, wc_abspath, data_sha1,
pool));
SVN_TEST_ASSERT(present);
}
{
const svn_checksum_t *looked_up_md5;
SVN_ERR(svn_wc__db_pristine_get_md5(&looked_up_md5, db, wc_abspath,
data_sha1, pool, pool));
SVN_TEST_ASSERT(looked_up_md5->kind == svn_checksum_md5);
SVN_TEST_ASSERT(svn_checksum_match(data_md5, looked_up_md5));
}
{
svn_stream_t *data_stream = svn_stream_from_string(data_string, pool);
svn_stream_t *data_read_back;
svn_boolean_t same;
SVN_ERR(svn_wc__db_pristine_read(&data_read_back, NULL, db, wc_abspath,
data_sha1, pool, pool));
SVN_ERR(svn_stream_contents_same2(&same, data_read_back, data_stream,
pool));
SVN_TEST_ASSERT(same);
}
{
svn_error_t *err;
svn_stream_t *data_read_back;
SVN_ERR(svn_wc__db_pristine_remove(db, wc_abspath, data_sha1, pool));
err = svn_wc__db_pristine_read(&data_read_back, NULL, db, wc_abspath,
data_sha1, pool, pool);
SVN_TEST_ASSERT(err != NULL);
svn_error_clear(err);
}
{
svn_boolean_t present;
SVN_ERR(svn_wc__db_pristine_check(&present, db, wc_abspath, data_sha1,
pool));
SVN_TEST_ASSERT(! present);
}
return SVN_NO_ERROR;
}
static svn_error_t *
pristine_delete_while_open(const svn_test_opts_t *opts,
apr_pool_t *pool)
{
svn_wc__db_t *db;
const char *wc_abspath;
const char *pristine_tmp_dir;
svn_stream_t *contents;
const char data[] = "Blah";
svn_checksum_t *data_sha1, *data_md5;
SVN_ERR(create_repos_and_wc(&wc_abspath, &db,
"pristine_delete_while_open", opts, pool));
SVN_ERR(svn_wc__db_pristine_get_tempdir(&pristine_tmp_dir, db,
wc_abspath, pool, pool));
{
const char *path;
SVN_ERR(write_and_checksum_temp_file(&path, &data_sha1, &data_md5,
data, pristine_tmp_dir, pool));
SVN_ERR(svn_wc__db_pristine_install(db, path, data_sha1, data_md5, pool));
}
SVN_ERR(svn_wc__db_pristine_read(&contents, NULL, db, wc_abspath, data_sha1,
pool, pool));
SVN_ERR(svn_wc__db_pristine_remove(db, wc_abspath, data_sha1, pool));
{
char buffer[4];
apr_size_t len = 4;
SVN_ERR(svn_stream_read(contents, buffer, &len));
SVN_TEST_ASSERT(len == 4);
SVN_TEST_ASSERT(memcmp(buffer, data, len) == 0);
}
{
svn_boolean_t present;
SVN_ERR(svn_wc__db_pristine_check(&present, db, wc_abspath, data_sha1,
pool));
SVN_TEST_ASSERT(! present);
}
SVN_ERR(svn_stream_close(contents));
return SVN_NO_ERROR;
}
static svn_error_t *
reject_mismatching_text(const svn_test_opts_t *opts,
apr_pool_t *pool)
{
#ifdef SVN_DEBUG
svn_wc__db_t *db;
const char *wc_abspath;
const char *pristine_tmp_dir;
const char data[] = "Blah";
svn_checksum_t *data_sha1, *data_md5;
const char data2[] = "Baz";
SVN_ERR(create_repos_and_wc(&wc_abspath, &db,
"reject_mismatching_text", opts, pool));
SVN_ERR(svn_wc__db_pristine_get_tempdir(&pristine_tmp_dir, db,
wc_abspath, pool, pool));
{
const char *path;
SVN_ERR(write_and_checksum_temp_file(&path, &data_sha1, &data_md5,
data, pristine_tmp_dir, pool));
SVN_ERR(svn_wc__db_pristine_install(db, path, data_sha1, data_md5, pool));
}
{
svn_error_t *err;
const char *path;
SVN_ERR(write_and_checksum_temp_file(&path, NULL, NULL,
data2, pristine_tmp_dir, pool));
err = svn_wc__db_pristine_install(db, path, data_sha1, data_md5, pool);
SVN_TEST_ASSERT(err != NULL);
SVN_TEST_ASSERT(err->apr_err == SVN_ERR_WC_CORRUPT_TEXT_BASE);
svn_error_clear(err);
}
return SVN_NO_ERROR;
#else
return svn_error_create(SVN_ERR_TEST_SKIPPED, NULL,
"The consistency check to be tested is only "
"active in debug-mode builds");
#endif
}
struct svn_test_descriptor_t test_funcs[] =
{
SVN_TEST_NULL,
SVN_TEST_OPTS_PASS(pristine_write_read,
"pristine_write_read"),
SVN_TEST_OPTS_PASS(pristine_delete_while_open,
"pristine_delete_while_open"),
SVN_TEST_OPTS_PASS(reject_mismatching_text,
"reject_mismatching_text"),
SVN_TEST_NULL
};