summaryrefslogtreecommitdiff
path: root/1.1.x/test/etap/113-replication-attachment-comp.t
diff options
context:
space:
mode:
Diffstat (limited to '1.1.x/test/etap/113-replication-attachment-comp.t')
-rwxr-xr-x1.1.x/test/etap/113-replication-attachment-comp.t314
1 files changed, 0 insertions, 314 deletions
diff --git a/1.1.x/test/etap/113-replication-attachment-comp.t b/1.1.x/test/etap/113-replication-attachment-comp.t
deleted file mode 100755
index e30a96bc..00000000
--- a/1.1.x/test/etap/113-replication-attachment-comp.t
+++ /dev/null
@@ -1,314 +0,0 @@
-#!/usr/bin/env escript
-%% -*- erlang -*-
-
-% Licensed under the Apache License, Version 2.0 (the "License"); you may not
-% use this file except in compliance with the License. You may obtain a copy of
-% the License at
-%
-% http://www.apache.org/licenses/LICENSE-2.0
-%
-% Unless required by applicable law or agreed to in writing, software
-% distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
-% WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
-% License for the specific language governing permissions and limitations under
-% the License.
-
--record(user_ctx, {
- name = null,
- roles = [],
- handler
-}).
-
-test_db_a_name() ->
- <<"couch_test_rep_att_comp_a">>.
-
-test_db_b_name() ->
- <<"couch_test_rep_att_comp_b">>.
-
-main(_) ->
- test_util:init_code_path(),
- etap:plan(45),
- case (catch test()) of
- ok ->
- etap:end_tests();
- Other ->
- etap:diag(io_lib:format("Test died abnormally: ~p", [Other])),
- etap:bail(Other)
- end,
- ok.
-
-test() ->
- couch_server_sup:start_link(test_util:config_files()),
- put(addr, couch_config:get("httpd", "bind_address", "127.0.0.1")),
- put(port, integer_to_list(mochiweb_socket_server:get(couch_httpd, port))),
- application:start(inets),
- ibrowse:start(),
- timer:sleep(1000),
-
- %
- % test pull replication
- %
-
- delete_db(test_db_a_name()),
- delete_db(test_db_b_name()),
- create_db(test_db_a_name()),
- create_db(test_db_b_name()),
-
- % enable compression
- couch_config:set("attachments", "compression_level", "8", false),
- couch_config:set("attachments", "compressible_types", "text/*", false),
-
- % store doc with text attachment in DB A
- put_text_att(test_db_a_name()),
-
- % disable attachment compression
- couch_config:set("attachments", "compression_level", "0", false),
-
- % do pull replication
- do_pull_replication(test_db_a_name(), test_db_b_name()),
-
- % verify that DB B has the attachment stored in compressed form
- check_att_is_compressed(test_db_b_name()),
- check_server_can_decompress_att(test_db_b_name()),
- check_att_stubs(test_db_a_name(), test_db_b_name()),
-
- %
- % test push replication
- %
-
- delete_db(test_db_a_name()),
- delete_db(test_db_b_name()),
- create_db(test_db_a_name()),
- create_db(test_db_b_name()),
-
- % enable compression
- couch_config:set("attachments", "compression_level", "8", false),
- couch_config:set("attachments", "compressible_types", "text/*", false),
-
- % store doc with text attachment in DB A
- put_text_att(test_db_a_name()),
-
- % disable attachment compression
- couch_config:set("attachments", "compression_level", "0", false),
-
- % do push replication
- do_push_replication(test_db_a_name(), test_db_b_name()),
-
- % verify that DB B has the attachment stored in compressed form
- check_att_is_compressed(test_db_b_name()),
- check_server_can_decompress_att(test_db_b_name()),
- check_att_stubs(test_db_a_name(), test_db_b_name()),
-
- %
- % test local replication
- %
-
- delete_db(test_db_a_name()),
- delete_db(test_db_b_name()),
- create_db(test_db_a_name()),
- create_db(test_db_b_name()),
-
- % enable compression
- couch_config:set("attachments", "compression_level", "8", false),
- couch_config:set("attachments", "compressible_types", "text/*", false),
-
- % store doc with text attachment in DB A
- put_text_att(test_db_a_name()),
-
- % disable attachment compression
- couch_config:set("attachments", "compression_level", "0", false),
-
- % do local-local replication
- do_local_replication(test_db_a_name(), test_db_b_name()),
-
- % verify that DB B has the attachment stored in compressed form
- check_att_is_compressed(test_db_b_name()),
- check_server_can_decompress_att(test_db_b_name()),
- check_att_stubs(test_db_a_name(), test_db_b_name()),
-
- timer:sleep(3000), % to avoid mochiweb socket closed exceptions
- delete_db(test_db_a_name()),
- delete_db(test_db_b_name()),
- couch_server_sup:stop(),
- ok.
-
-put_text_att(DbName) ->
- {ok, {{_, Code, _}, _Headers, _Body}} = http:request(
- put,
- {db_url(DbName) ++ "/testdoc1/readme.txt", [],
- "text/plain", test_text_data()},
- [],
- [{sync, true}]),
- etap:is(Code, 201, "Created text attachment"),
- ok.
-
-do_pull_replication(SourceDbName, TargetDbName) ->
- RepObj = {[
- {<<"source">>, list_to_binary(db_url(SourceDbName))},
- {<<"target">>, TargetDbName}
- ]},
- {ok, {{_, Code, _}, _Headers, Body}} = http:request(
- post,
- {rep_url(), [],
- "application/json", list_to_binary(couch_util:json_encode(RepObj))},
- [],
- [{sync, true}]),
- etap:is(Code, 200, "Pull replication successfully triggered"),
- Json = couch_util:json_decode(Body),
- RepOk = couch_util:get_nested_json_value(Json, [<<"ok">>]),
- etap:is(RepOk, true, "Pull replication completed with success"),
- ok.
-
-do_push_replication(SourceDbName, TargetDbName) ->
- RepObj = {[
- {<<"source">>, SourceDbName},
- {<<"target">>, list_to_binary(db_url(TargetDbName))}
- ]},
- {ok, {{_, Code, _}, _Headers, Body}} = http:request(
- post,
- {rep_url(), [],
- "application/json", list_to_binary(couch_util:json_encode(RepObj))},
- [],
- [{sync, true}]),
- etap:is(Code, 200, "Push replication successfully triggered"),
- Json = couch_util:json_decode(Body),
- RepOk = couch_util:get_nested_json_value(Json, [<<"ok">>]),
- etap:is(RepOk, true, "Push replication completed with success"),
- ok.
-
-do_local_replication(SourceDbName, TargetDbName) ->
- RepObj = {[
- {<<"source">>, SourceDbName},
- {<<"target">>, TargetDbName}
- ]},
- {ok, {{_, Code, _}, _Headers, Body}} = http:request(
- post,
- {rep_url(), [],
- "application/json", list_to_binary(couch_util:json_encode(RepObj))},
- [],
- [{sync, true}]),
- etap:is(Code, 200, "Local replication successfully triggered"),
- Json = couch_util:json_decode(Body),
- RepOk = couch_util:get_nested_json_value(Json, [<<"ok">>]),
- etap:is(RepOk, true, "Local replication completed with success"),
- ok.
-
-check_att_is_compressed(DbName) ->
- {ok, {{_, Code, _}, Headers, Body}} = http:request(
- get,
- {db_url(DbName) ++ "/testdoc1/readme.txt",
- [{"Accept-Encoding", "gzip"}]},
- [],
- [{sync, true}]),
- etap:is(Code, 200, "HTTP response code for the attachment request is 200"),
- Gziped = lists:member({"content-encoding", "gzip"}, Headers),
- etap:is(Gziped, true, "The attachment was received in compressed form"),
- Uncompressed = binary_to_list(zlib:gunzip(list_to_binary(Body))),
- etap:is(
- Uncompressed,
- test_text_data(),
- "The attachment content is valid after decompression at the client side"
- ),
- ok.
-
-check_server_can_decompress_att(DbName) ->
- {ok, {{_, Code, _}, Headers, Body}} = http:request(
- get,
- {db_url(DbName) ++ "/testdoc1/readme.txt", []},
- [],
- [{sync, true}]),
- etap:is(Code, 200, "HTTP response code for the attachment request is 200"),
- Gziped = lists:member({"content-encoding", "gzip"}, Headers),
- etap:is(
- Gziped, false, "The attachment was not received in compressed form"
- ),
- etap:is(
- Body,
- test_text_data(),
- "The attachment content is valid after server decompression"
- ),
- ok.
-
-check_att_stubs(SourceDbName, TargetDbName) ->
- {ok, {{_, Code1, _}, _Headers1, Body1}} = http:request(
- get,
- {db_url(SourceDbName) ++ "/testdoc1?att_encoding_info=true", []},
- [],
- [{sync, true}]),
- etap:is(
- Code1,
- 200,
- "HTTP response code is 200 for the source DB doc request"
- ),
- Json1 = couch_util:json_decode(Body1),
- SourceAttStub = couch_util:get_nested_json_value(
- Json1,
- [<<"_attachments">>, <<"readme.txt">>]
- ),
- {ok, {{_, Code2, _}, _Headers2, Body2}} = http:request(
- get,
- {db_url(TargetDbName) ++ "/testdoc1?att_encoding_info=true", []},
- [],
- [{sync, true}]),
- etap:is(
- Code2,
- 200,
- "HTTP response code is 200 for the target DB doc request"
- ),
- Json2 = couch_util:json_decode(Body2),
- TargetAttStub = couch_util:get_nested_json_value(
- Json2,
- [<<"_attachments">>, <<"readme.txt">>]
- ),
- IdenticalStubs = (SourceAttStub =:= TargetAttStub),
- etap:is(IdenticalStubs, true, "Attachment stubs are identical"),
- TargetAttStubLength = couch_util:get_nested_json_value(
- TargetAttStub,
- [<<"length">>]
- ),
- TargetAttStubEnc = couch_util:get_nested_json_value(
- TargetAttStub,
- [<<"encoding">>]
- ),
- etap:is(
- TargetAttStubEnc,
- <<"gzip">>,
- "Attachment stub has encoding property set to gzip"
- ),
- TargetAttStubEncLength = couch_util:get_nested_json_value(
- TargetAttStub,
- [<<"encoded_length">>]
- ),
- EncLengthDefined = is_integer(TargetAttStubEncLength),
- etap:is(
- EncLengthDefined,
- true,
- "Stubs have the encoded_length field properly defined"
- ),
- EncLengthSmaller = (TargetAttStubEncLength < TargetAttStubLength),
- etap:is(
- EncLengthSmaller,
- true,
- "Stubs have the encoded_length field smaller than their length field"
- ),
- ok.
-
-admin_user_ctx() ->
- {user_ctx, #user_ctx{roles=[<<"_admin">>]}}.
-
-create_db(DbName) ->
- {ok, _} = couch_db:create(DbName, [admin_user_ctx()]).
-
-delete_db(DbName) ->
- couch_server:delete(DbName, [admin_user_ctx()]).
-
-db_url(DbName) ->
- "http://" ++ get(addr) ++ ":" ++ get(port) ++ "/" ++
- binary_to_list(DbName).
-
-rep_url() ->
- "http://" ++ get(addr) ++ ":" ++ get(port) ++ "/_replicate".
-
-test_text_data() ->
- {ok, Data} = file:read_file(test_util:source_file("README")),
- binary_to_list(Data).
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-08 01:08:15 +0000