cryptix/caberl - Change ST7Y5WTYIQNKUOVXW6T5PQZL6R3VUYC37BAEQOA2FL6AYVPR4OLAC

fix post request dedup

Created by Henry on October 26, 2023

ST7Y5WTYIQNKUOVXW6T5PQZL6R3VUYC37BAEQOA2FL6AYVPR4OLAC

Dependencies

In channels

main

Change contents

Replacement in apps/cable/src/peer.erl at line 273 [3.854]

B:BD[2.2288] → [2.2288:2411]

                               End = os:system_time(1000),
                               Start = End - (12*60*60 * 1000),

[2.2288]

[2.2411]

                               End = 0,
                               Start = os:system_time(1000) - (12*60*60 * 1000),

Replacement in apps/cable/src/peer.erl at line 276 [3.854]

B:BD[2.2478] → [2.2478:2575]

                               } = send_channel_time_range_request(Peer, Chan, Start, End, 100),

[2.2478]

[2.2575]

                               } = send_channel_time_range_request(Peer, Chan, Start, End, 200),

Replacement in apps/cable/src/peer.erl at line 399 [3.854]

B:BD[4.6288] → [2.3983:4107]

    io:format("[DEBUG] new message Type:~p - IsActiveOut: ~p - Size: ~p~n",
              [MsgType, IsActiveOut, MsgSize]),

[4.6288]

[2.4107]

    io:format("[DEBUG] new message ReqId:~p Type:~p - IsActiveOut ~p - Size:~p~n",
              [ReqIdStr, MsgType, IsActiveOut, MsgSize]),

Replacement in apps/cable/src/peer.erl at line 408 [3.854]

B:BD[4.6579] → [4.6579:7293]

                    %% this needs to be spread out across conns
                    %% asking the responder directly should be okay enough for now
                    Hashes = proplists:get_value(hashes, Body),
                    FilterUnknownPosts = fun(H) ->
                                                 IsUnknown = not db:hasPost(Db, H),
                                                 io:format("[DEBUG] skipping post: ~p? ~p~n",
                                                           [hex:bin_to_hexstr(H), IsUnknown]),
                                                 IsUnknown
                                         end,
                    NewHashes = lists:filter(FilterUnknownPosts, Hashes),

[4.6579]

[2.4153]

                    FilterUnknownPosts = fun(H) -> not db:hasPost(Db, H) end,
                    NewHashes = lists:filter(FilterUnknownPosts, proplists:get_value(hashes, Body)),

Insertion in apps/cable/src/peer.erl at line 414 [3.854]

[2.4333]

                            %% this needs to be spread out across conns
                            %% asking the responder directly should be okay enough for now

Replacement in apps/cable/src/peer.erl at line 424 [3.854]
B:BD[2.4848] → [2.4848:4877]
```
                        end;
```
[2.4848]
[4.7727]
```
                    end;
```

Deletion in apps/cable/src/peer.erl at line 428 [3.854]

B:BD[4.7889] → [4.7889:7958]

                    [{ok, _, _} = db:savePost(Db, P) || P <- Posts],

Insertion in apps/cable/src/peer.erl at line 429 [3.854]

[4.8056]

[2.4878]

                    [{ok, _, _} = db:savePost(Db, P) || P <- Posts],

Replacement in apps/cable/src/peer.erl at line 458 [3.854]

B:BD[4.9367] → [4.9367:9483]

                                                  F = fun({received, ChanReqId, _}) -> CancelId =/= ChanReqId  end,

[4.9367]

[4.9483]

                                                  F = fun({received, ChanReqId, _}) ->
                                                              CancelId =/= ChanReqId
                                                      end,

Replacement in apps/cable/src/db.erl at line 77 [6.84]

B:BD[5.1782] → [4.15696:16052]

∅:D[4.16052] → [7.1546:1547]

B:BD[8.6600] → [7.1546:1547]

B:BD[7.1547] → [4.16053:16573]

    PostInsert = [{user_id, UserId}, {raw_post, Binary}] ++
        HeaderTrimmed ++ case proplists:get_value(type, Header) of
                             0 -> Body;
                             1 ->
                                 Concat = iolist_to_binary(proplists:get_value(hashes, Body)),
                                 [{deletedHashes, Concat}];
                             2 -> %% infos
                                 Chan = proplists:get_value(channel, Body),
                                 Infos = proplists:get_value(infos, Body),
                                 [{channel, Chan}, {infos, {blob, jsone:encode(Infos)}}];
                             3 -> %% topic
                                 Body;
                             %% join / leave
                             4 -> Body;
                             5 -> Body
                         end,

[5.1782]

[4.16573]

    PostInsert = [{user_id, UserId}, {raw_post, Binary}] ++ HeaderTrimmed
        ++ case proplists:get_value(type, Header) of
               0 -> Body; %% text
               3 -> Body; %% topic
               4 -> Body; %% join
               5 -> Body; %% leave
               1 -> % delete
                   Concat = iolist_to_binary(proplists:get_value(hashes, Body)),
                   [{deletedHashes, Concat}];
               2 -> %% infos
                   Chan = proplists:get_value(channel, Body),
                   Infos = proplists:get_value(infos, Body),
                   [{channel, Chan}, {infos, {blob, jsone:encode(Infos)}}]
           end,

Deletion in apps/cable/src/db.erl at line 112 [6.84]
B:BD[4.16882] → [2.6686:6743]
```
    io:format("[DB] checking hasPost for ~p~n", [Hash]),
```