test(ft): do not rely on fs backend implementation details
This commit is contained in:
parent
93865a79e9
commit
5014cc15f4
|
@ -22,7 +22,6 @@
|
||||||
-include_lib("common_test/include/ct.hrl").
|
-include_lib("common_test/include/ct.hrl").
|
||||||
-include_lib("stdlib/include/assert.hrl").
|
-include_lib("stdlib/include/assert.hrl").
|
||||||
-include_lib("kernel/include/file.hrl").
|
-include_lib("kernel/include/file.hrl").
|
||||||
-include_lib("snabbkaffe/include/snabbkaffe.hrl").
|
|
||||||
|
|
||||||
all() ->
|
all() ->
|
||||||
[
|
[
|
||||||
|
@ -86,11 +85,6 @@ t_assemble_empty_transfer(Config) ->
|
||||||
),
|
),
|
||||||
Status = complete_assemble(Storage, Transfer, 0),
|
Status = complete_assemble(Storage, Transfer, 0),
|
||||||
?assertEqual({shutdown, ok}, Status),
|
?assertEqual({shutdown, ok}, Status),
|
||||||
?assertEqual(
|
|
||||||
{ok, <<>>},
|
|
||||||
% TODO
|
|
||||||
file:read_file(mk_assembly_filename(Config, Transfer, Filename))
|
|
||||||
),
|
|
||||||
{ok, [Result = #{size := Size = 0}]} = emqx_ft_storage_fs:list(Storage, Transfer, result),
|
{ok, [Result = #{size := Size = 0}]} = emqx_ft_storage_fs:list(Storage, Transfer, result),
|
||||||
?assertEqual(
|
?assertEqual(
|
||||||
{error, eof},
|
{error, eof},
|
||||||
|
@ -135,17 +129,16 @@ t_assemble_complete_local_transfer(Config) ->
|
||||||
Status = complete_assemble(Storage, Transfer, TransferSize),
|
Status = complete_assemble(Storage, Transfer, TransferSize),
|
||||||
?assertEqual({shutdown, ok}, Status),
|
?assertEqual({shutdown, ok}, Status),
|
||||||
|
|
||||||
AssemblyFilename = mk_assembly_filename(Config, Transfer, Filename),
|
|
||||||
?assertMatch(
|
?assertMatch(
|
||||||
{ok, [
|
{ok, [
|
||||||
#{
|
#{
|
||||||
path := AssemblyFilename,
|
|
||||||
size := TransferSize,
|
size := TransferSize,
|
||||||
fragment := {result, #{}}
|
fragment := {result, #{}}
|
||||||
}
|
}
|
||||||
]},
|
]},
|
||||||
emqx_ft_storage_fs:list(Storage, Transfer, result)
|
emqx_ft_storage_fs:list(Storage, Transfer, result)
|
||||||
),
|
),
|
||||||
|
{ok, [#{path := AssemblyFilename}]} = emqx_ft_storage_fs:list(Storage, Transfer, result),
|
||||||
?assertMatch(
|
?assertMatch(
|
||||||
{ok, #file_info{type = regular, size = TransferSize}},
|
{ok, #file_info{type = regular, size = TransferSize}},
|
||||||
file:read_file_info(AssemblyFilename)
|
file:read_file_info(AssemblyFilename)
|
||||||
|
@ -194,9 +187,6 @@ complete_assemble(Storage, Transfer, Size, Timeout) ->
|
||||||
ct:fail("Assembler did not finish in time")
|
ct:fail("Assembler did not finish in time")
|
||||||
end.
|
end.
|
||||||
|
|
||||||
mk_assembly_filename(Config, {ClientID, FileID}, Filename) ->
|
|
||||||
filename:join([?config(storage_root, Config), ClientID, FileID, result, Filename]).
|
|
||||||
|
|
||||||
%%
|
%%
|
||||||
|
|
||||||
t_list_transfers(Config) ->
|
t_list_transfers(Config) ->
|
||||||
|
|
Loading…
Reference in New Issue