fluxerapp/fluxer
1
0
Fork 0
mirror of https://github.com/fluxerapp/fluxer.git synced 2026-09-02 21:04:06 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix(gateway): rate limit resume like identify (#2353)

Browse Source
This commit is contained in:
Hampus
2026-09-02 17:24:58 +02:00
committed by GitHub
parent d5a752c338
commit 9f33177eab
1 changed files with 16 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
fluxer_gateway/src/gateway/gateway_handler_dispatch.erl
+16 -2
View File
@@ -41,8 +41,12 @@ handle_opcode(identify, _, State) ->
gateway_handler_encode:close_with_reason(
already_authenticated, <<"Already authenticated">>, State
);
handle_opcode(resume, #{<<"d">> := Data}, State) ->
gateway_handler_identify:handle_resume(Data, State);
handle_opcode(resume, #{<<"d">> := Data}, #{session_pid := undefined} = State) ->
handle_rate_limited_resume(Data, State);
handle_opcode(resume, _, State) ->
gateway_handler_encode:close_with_reason(
already_authenticated, <<"Already authenticated">>, State
);
handle_opcode(Op, #{<<"d">> := Data}, State) ->
handle_authenticated_opcode(Op, Data, State);
handle_opcode(_, _, State) ->
@@ -84,6 +88,16 @@ handle_authenticated_opcode(
handle_authenticated_opcode(_, _, State) ->
gateway_handler_encode:close_with_reason(unknown_opcode, <<"Unknown opcode">>, State).
-spec handle_rate_limited_resume(map(), state()) -> ws_result().
handle_rate_limited_resume(Data, State) ->
case session_abuse_protection:check_identify_rate(peer_ip(State)) of
{error, identify_rate_limited} ->
logger:debug("Holding gateway resume: reason=rate_limited"),
{ok, State};
ok ->
gateway_handler_identify:handle_resume(Data, State)
end.
-spec handle_dispatch(
atom() | binary(), map() | null | {pre_encoded, binary()}, integer(), state()
) -> ws_result().