cryptix/caberl - Change CZG24QKIB45EL7PK4UA6XVG3VEVKI7OAQXN4YMFUKKI2MXLHRANQC

two more requests

Created by Henry on October 9, 2023

CZG24QKIB45EL7PK4UA6XVG3VEVKI7OAQXN4YMFUKKI2MXLHRANQC

Dependencies

In channels

main

Change contents

Replacement in test/cable_basic_SUITE.erl at line 7 [4.22]

B:BD[2.66] → [2.66:328]

∅:D[2.328] → [4.641:720]

B:BD[4.641] → [4.641:720]

B:BD[4.720] → [2.329:416]

    [{header, Header},  {ttl, Ttl}, {hashes, Hashes}] = wire:decode_hash_response(Bin),
    ?assert(proplists:get_value(msgLen, Header) =:= maps:get(<<"msgLen">>, TestObj)),
    ?assert(proplists:get_value(msgType, Header) =:= maps:get(<<"msgType">>, TestObj)),
    ReqId = hex:hexstr_to_bin(binary_to_list(maps:get(<<"reqid">>, TestObj))),
    ?assert(proplists:get_value(requestId, Header) =:= ReqId),
    ?assert(Ttl =:= 1),

[2.66]

[2.416]

    [{header, Header},  {ttl, 1}, {hashes, Hashes}] = wire:decode_hash_response(Bin),
    assert_header(Header, TestObj),

Replacement in test/cable_basic_SUITE.erl at line 10 [4.22]
∅:D[2.451] → [4.782:783]
B:BD[4.782] → [4.782:783]
[2.451]
[4.783]
```
    % TODO: assert
```

Replacement in test/cable_basic_SUITE.erl at line 14 [4.22]

B:BD[2.542] → [2.542:1059]

    [{header, Header}, {ttl, Ttl}, {cancelid, CancelId}] = wire:decode_cancel_request(Bin),
    ?assert(proplists:get_value(msgLen, Header) =:= maps:get(<<"msgLen">>, TestObj)),
    ?assert(proplists:get_value(msgType, Header) =:= maps:get(<<"msgType">>, TestObj)),
    CancelId = hex:hexstr_to_bin(binary_to_list(maps:get(<<"cancelid">>, TestObj))),
    ReqId = hex:hexstr_to_bin(binary_to_list(maps:get(<<"reqid">>, TestObj))),
    ?assert(proplists:get_value(requestId, Header) =:= ReqId),
    ?assert(Ttl =:= 1).

[2.542]

[4.1132]

    [{header, Header}, {ttl, 1}, {cancelid, CancelId}] = wire:decode_cancel_request(Bin),
    assert_header(Header, TestObj),
    CancelId = hex:hexstr_to_bin(binary_to_list(maps:get(<<"cancelid">>, TestObj))).

Replacement in test/cable_basic_SUITE.erl at line 21 [4.22]
B:BD[2.1233] → [2.1233:1268]
```
    [{header, Header}, {ttl, Ttl},
```
[2.1233]
[2.1268]
```
    [{header, Header}, {ttl, 1},
```

Insertion in test/cable_basic_SUITE.erl at line 27 [4.22]

[2.1396]

    assert_header(Header, TestObj),
    ?assert(Channel =:= maps:get(<<"channel">>, TestObj)),
    ?assert(TimeStart =:= maps:get(<<"timeStart">>, TestObj)),
    ?assert(TimeEnd =:= maps:get(<<"timeEnd">>, TestObj)),
    ?assert(Limit =:= maps:get(<<"limit">>, TestObj)).
channel_state_request_test() ->
    [{binary, Bin}, {obj, TestObj}] = examples:channel_state_request(),
    Decoded = wire:decode_channel_state_request(Bin),
    [{header, Header}, {ttl, 1},
        {channel, Channel},
        {future, Future}
    ] = Decoded,
    assert_header(Header, TestObj),
    ?assert(Channel =:= maps:get(<<"channel">>, TestObj)),
    ?assert(Future =:= maps:get(<<"future">>, TestObj)).
channel_list_request_test() ->
    [{binary, Bin}, {obj, TestObj}] = examples:channel_list_request(),
    Decoded = wire:decode_channel_list_request(Bin),
    [{header, Header}, {ttl, 1},
        {offset, 0},
        {limit, 20}
    ] = Decoded,
    assert_header(Header, TestObj).
% Helpers
%%%%%%%%%
assert_header(Header, TestObj) ->

Replacement in test/cable_basic_SUITE.erl at line 60 [4.22]

B:BD[2.1649] → [2.1649:1972]

    ?assert(proplists:get_value(requestId, Header) =:= ReqId),
    ?assert(Channel =:= maps:get(<<"channel">>, TestObj)),
    ?assert(TimeStart =:= maps:get(<<"timeStart">>, TestObj)),
    ?assert(TimeEnd =:= maps:get(<<"timeEnd">>, TestObj)),
    ?assert(Limit =:= maps:get(<<"limit">>, TestObj)),
    ?assert(Ttl =:= 1).

[2.1649]

    ?assert(proplists:get_value(requestId, Header) =:= ReqId).

Replacement in apps/cable/src/wire.erl at line 3 [4.5336]

B:BD[4.5353] → [2.1981:2078]

-export([decode_hash_response/1, decode_cancel_request/1, decode_channel_time_range_request/1]).

[4.5353]

[4.5390]

-export([decode_hash_response/1, decode_cancel_request/1, decode_channel_time_range_request/1, decode_channel_state_request/1, decode_channel_list_request/1]).

Replacement in apps/cable/src/wire.erl at line 6 [4.5336]
B:BD[2.2091] → [2.2091:2128]
```
-export([decode_response_header/1]).
```
[2.2091]
[4.5391]
```
-export([decode_response_header/1, decode_varints/2]).
```

Replacement in apps/cable/src/wire.erl at line 47 [4.5336]

B:BD[2.3067] → [2.3067:3347]

    {Ttl, Rest} = decode_varint(Payload),
    {ChannelLen, Rest2} = decode_varint(Rest),
    <<Channel:ChannelLen/binary, Rest3/binary>> = Rest2,
    {TimeStart, Rest4} = decode_varint(Rest3),
    {TimeEnd, Rest5} = decode_varint(Rest4),
    {Limit, <<>>} = decode_varint(Rest5),

[2.3067]

[2.3347]

    [Ttl, ChannelLen, Rest] = decode_varints(Payload, 2),
    <<Channel:ChannelLen/binary, Rest2/binary>> = Rest,
    [TimeStart, TimeEnd, Limit, <<>>] = decode_varints(Rest2, 3),

Insertion in apps/cable/src/wire.erl at line 58 [4.5336]

[2.3522]

[4.5776]

decode_channel_state_request(Data) ->
    Header = decode_response_header(Data),
    Payload = proplists:get_value(payload, Header),
    [Ttl, ChannelLen, Rest] = decode_varints(Payload, 2),
    <<Channel:ChannelLen/binary, Rest2/binary>> = Rest,
    {Future, <<>>} = decode_varint(Rest2),
    [ {header, proplists:delete(payload, Header)}
    , {ttl, Ttl}
    , {channel, Channel}
    , {future, Future}
    ].
decode_channel_list_request(Data) ->
    Header = decode_response_header(Data),
    Payload = proplists:get_value(payload, Header),
    [Ttl, Offset, Limit, <<>>] = decode_varints(Payload, 3),
    [ {header, proplists:delete(payload, Header)}
    , {ttl, Ttl}
    , {offset, Offset}
    , {limit, Limit}
    ].
% Helpers
decode_varints(Data, N) when N >= 0 ->
    decode_varints(Data, N, []).
% private
decode_varints(Data, 0, Acc) -> 
    Acc ++ [Data];
decode_varints(Data, N, Acc) when N >= 0 -> 
    {Int, Rest} = decode_varint(Data),
    decode_varints(Rest, N-1, Acc ++ [Int]).

Insertion in apps/cable/src/examples.erl at line 4 [3.11]

[3.68]


-export([hash_response/0, cancel_request/0, channel_time_range_request/0, channel_state_request/0, channel_list_request/0]).

Deletion in apps/cable/src/examples.erl at line 7 [3.11]
B:BD[3.69] → [3.69:145]
```
-export([hash_response/0, cancel_request/0, channel_time_range_request/0]).
```

Insertion in apps/cable/src/examples.erl at line 19 [3.11]

[3.1394]

channel_state_request() ->
  D = <<"{\"name\":\"channel state request\",\"type\":\"request\",\"id\":5,\"binary\":\"13050000000095050429010764656661756c7400\",\"obj\":{\"msgLen\":19,\"msgType\":5,\"reqid\":\"95050429\",\"ttl\":1,\"channel\":\"default\",\"future\":0}}">>,
  decode_example_json(D).
channel_list_request() ->
  D = <<"{\"name\":\"channel list request\",\"type\":\"request\",\"id\":6,\"binary\":\"0c060000000095050429010014\",\"obj\":{\"msgLen\":12,\"msgType\":6,\"reqid\":\"95050429\",\"ttl\":1,\"offset\":0,\"limit\":20}}">>,
  decode_example_json(D).