15
15
import functools
16
16
import logging
17
17
import re
18
- from typing import Container , Dict , List , Mapping , Optional , Sequence , Tuple , Type , Union
18
+ from typing import (
19
+ Container ,
20
+ Dict ,
21
+ List ,
22
+ Mapping ,
23
+ Optional ,
24
+ Sequence ,
25
+ Tuple ,
26
+ Type ,
27
+ Union ,
28
+ )
19
29
20
30
from typing_extensions import Literal
21
31
@@ -573,10 +583,10 @@ async def on_GET(
573
583
if supported_versions is None :
574
584
supported_versions = ["1" ]
575
585
576
- content = await self .handler .on_make_join_request (
586
+ result = await self .handler .on_make_join_request (
577
587
origin , room_id , user_id , supported_versions = supported_versions
578
588
)
579
- return 200 , content
589
+ return 200 , result
580
590
581
591
582
592
class FederationMakeLeaveServlet (BaseFederationServerServlet ):
@@ -590,8 +600,8 @@ async def on_GET(
590
600
room_id : str ,
591
601
user_id : str ,
592
602
) -> Tuple [int , JsonDict ]:
593
- content = await self .handler .on_make_leave_request (origin , room_id , user_id )
594
- return 200 , content
603
+ result = await self .handler .on_make_leave_request (origin , room_id , user_id )
604
+ return 200 , result
595
605
596
606
597
607
class FederationV1SendLeaveServlet (BaseFederationServerServlet ):
@@ -605,8 +615,8 @@ async def on_PUT(
605
615
room_id : str ,
606
616
event_id : str ,
607
617
) -> Tuple [int , Tuple [int , JsonDict ]]:
608
- content = await self .handler .on_send_leave_request (origin , content )
609
- return 200 , (200 , content )
618
+ result = await self .handler .on_send_leave_request (origin , content )
619
+ return 200 , (200 , result )
610
620
611
621
612
622
class FederationV2SendLeaveServlet (BaseFederationServerServlet ):
@@ -622,8 +632,8 @@ async def on_PUT(
622
632
room_id : str ,
623
633
event_id : str ,
624
634
) -> Tuple [int , JsonDict ]:
625
- content = await self .handler .on_send_leave_request (origin , content )
626
- return 200 , content
635
+ result = await self .handler .on_send_leave_request (origin , content )
636
+ return 200 , result
627
637
628
638
629
639
class FederationMakeKnockServlet (BaseFederationServerServlet ):
@@ -643,10 +653,10 @@ async def on_GET(
643
653
except KeyError :
644
654
raise SynapseError (400 , "Missing required query parameter 'ver'" )
645
655
646
- content = await self .handler .on_make_knock_request (
656
+ result = await self .handler .on_make_knock_request (
647
657
origin , room_id , user_id , supported_versions = supported_versions
648
658
)
649
- return 200 , content
659
+ return 200 , result
650
660
651
661
652
662
class FederationV1SendKnockServlet (BaseFederationServerServlet ):
@@ -660,8 +670,8 @@ async def on_PUT(
660
670
room_id : str ,
661
671
event_id : str ,
662
672
) -> Tuple [int , JsonDict ]:
663
- content = await self .handler .on_send_knock_request (origin , content , room_id )
664
- return 200 , content
673
+ result = await self .handler .on_send_knock_request (origin , content , room_id )
674
+ return 200 , result
665
675
666
676
667
677
class FederationEventAuthServlet (BaseFederationServerServlet ):
@@ -691,8 +701,8 @@ async def on_PUT(
691
701
) -> Tuple [int , Tuple [int , JsonDict ]]:
692
702
# TODO(paul): assert that room_id/event_id parsed from path actually
693
703
# match those given in content
694
- content = await self .handler .on_send_join_request (origin , content )
695
- return 200 , (200 , content )
704
+ result = await self .handler .on_send_join_request (origin , content )
705
+ return 200 , (200 , result )
696
706
697
707
698
708
class FederationV2SendJoinServlet (BaseFederationServerServlet ):
@@ -710,8 +720,8 @@ async def on_PUT(
710
720
) -> Tuple [int , JsonDict ]:
711
721
# TODO(paul): assert that room_id/event_id parsed from path actually
712
722
# match those given in content
713
- content = await self .handler .on_send_join_request (origin , content )
714
- return 200 , content
723
+ result = await self .handler .on_send_join_request (origin , content )
724
+ return 200 , result
715
725
716
726
717
727
class FederationV1InviteServlet (BaseFederationServerServlet ):
@@ -729,13 +739,13 @@ async def on_PUT(
729
739
# v2. This is "fine" as the only difference between V1 and V2 is the
730
740
# state resolution algorithm, and we don't use that for processing
731
741
# invites
732
- content = await self .handler .on_invite_request (
742
+ result = await self .handler .on_invite_request (
733
743
origin , content , room_version_id = RoomVersions .V1 .identifier
734
744
)
735
745
736
746
# V1 federation API is defined to return a content of `[200, {...}]`
737
747
# due to a historical bug.
738
- return 200 , (200 , content )
748
+ return 200 , (200 , result )
739
749
740
750
741
751
class FederationV2InviteServlet (BaseFederationServerServlet ):
@@ -763,10 +773,10 @@ async def on_PUT(
763
773
764
774
event .setdefault ("unsigned" , {})["invite_room_state" ] = invite_room_state
765
775
766
- content = await self .handler .on_invite_request (
776
+ result = await self .handler .on_invite_request (
767
777
origin , event , room_version_id = room_version
768
778
)
769
- return 200 , content
779
+ return 200 , result
770
780
771
781
772
782
class FederationThirdPartyInviteExchangeServlet (BaseFederationServerServlet ):
@@ -830,15 +840,15 @@ async def on_POST(
830
840
earliest_events = content .get ("earliest_events" , [])
831
841
latest_events = content .get ("latest_events" , [])
832
842
833
- content = await self .handler .on_get_missing_events (
843
+ result = await self .handler .on_get_missing_events (
834
844
origin ,
835
845
room_id = room_id ,
836
846
earliest_events = earliest_events ,
837
847
latest_events = latest_events ,
838
848
limit = limit ,
839
849
)
840
850
841
- return 200 , content
851
+ return 200 , result
842
852
843
853
844
854
class On3pidBindServlet (BaseFederationServerServlet ):
0 commit comments