@@ -278,13 +278,10 @@ def test_post_with_get_arguments_to_receivers_stream(self):
278278class TestSocket (BindingTestCase ):
279279 def test_socket (self ):
280280 socket = self .context .connect ()
281- socket .write (("POST %s HTTP/1.1\r \n " % \
282- self .context ._abspath ("some/path/to/post/to" )).encode ('utf-8' ))
283- socket .write (("Host: %s:%s\r \n " % \
284- (self .context .host , self .context .port )).encode ('utf-8' ))
281+ socket .write ((f"POST { self .context ._abspath ('some/path/to/post/to' )} HTTP/1.1\r \n " ).encode ('utf-8' ))
282+ socket .write ((f"Host: { self .context .host } :{ self .context .port } \r \n " ).encode ('utf-8' ))
285283 socket .write ("Accept-Encoding: identity\r \n " .encode ('utf-8' ))
286- socket .write (("Authorization: %s\r \n " % \
287- self .context .token ).encode ('utf-8' ))
284+ socket .write ((f"Authorization: { self .context .token } \r \n " ).encode ('utf-8' ))
288285 socket .write ("X-Splunk-Input-Mode: Streaming\r \n " .encode ('utf-8' ))
289286 socket .write ("\r \n " .encode ('utf-8' ))
290287 socket .close ()
@@ -799,13 +796,10 @@ def test_preexisting_token(self):
799796 self .assertEqual (response .status , 200 )
800797
801798 socket = newContext .connect ()
802- socket .write (("POST %s HTTP/1.1\r \n " % \
803- self .context ._abspath ("some/path/to/post/to" )).encode ('utf-8' ))
804- socket .write (("Host: %s:%s\r \n " % \
805- (self .context .host , self .context .port )).encode ('utf-8' ))
799+ socket .write ((f"POST { self .context ._abspath ('some/path/to/post/to' )} HTTP/1.1\r \n " ).encode ('utf-8' ))
800+ socket .write ((f"Host: { self .context .host } :{ self .context .port } \r \n " ).encode ('utf-8' ))
806801 socket .write ("Accept-Encoding: identity\r \n " .encode ('utf-8' ))
807- socket .write (("Authorization: %s\r \n " % \
808- self .context .token ).encode ('utf-8' ))
802+ socket .write ((f"Authorization: { self .context .token } \r \n " ).encode ('utf-8' ))
809803 socket .write ("X-Splunk-Input-Mode: Streaming\r \n " .encode ('utf-8' ))
810804 socket .write ("\r \n " .encode ('utf-8' ))
811805 socket .close ()
@@ -827,13 +821,10 @@ def test_preexisting_token_sans_splunk(self):
827821 self .assertEqual (response .status , 200 )
828822
829823 socket = newContext .connect ()
830- socket .write (("POST %s HTTP/1.1\r \n " % \
831- self .context ._abspath ("some/path/to/post/to" )).encode ('utf-8' ))
832- socket .write (("Host: %s:%s\r \n " % \
833- (self .context .host , self .context .port )).encode ('utf-8' ))
824+ socket .write ((f"POST { self .context ._abspath ('some/path/to/post/to' )} HTTP/1.1\r \n " ).encode ('utf-8' ))
825+ socket .write ((f"Host: { self .context .host } :{ self .context .port } \r \n " ).encode ('utf-8' ))
834826 socket .write ("Accept-Encoding: identity\r \n " .encode ('utf-8' ))
835- socket .write (("Authorization: %s\r \n " % \
836- self .context .token ).encode ('utf-8' ))
827+ socket .write ((f"Authorization: { self .context .token } \r \n " ).encode ('utf-8' ))
837828 socket .write ("X-Splunk-Input-Mode: Streaming\r \n " .encode ('utf-8' ))
838829 socket .write ("\r \n " .encode ('utf-8' ))
839830 socket .close ()
@@ -850,13 +841,10 @@ def test_connect_with_preexisting_token_sans_user_and_pass(self):
850841 self .assertEqual (response .status , 200 )
851842
852843 socket = newContext .connect ()
853- socket .write (("POST %s HTTP/1.1\r \n " % \
854- self .context ._abspath ("some/path/to/post/to" )).encode ('utf-8' ))
855- socket .write (("Host: %s:%s\r \n " % \
856- (self .context .host , self .context .port )).encode ('utf-8' ))
844+ socket .write ((f"POST { self .context ._abspath ('some/path/to/post/to' )} HTTP/1.1\r \n " ).encode ('utf-8' ))
845+ socket .write ((f"Host: { self .context .host } :{ self .context .port } \r \n " ).encode ('utf-8' ))
857846 socket .write ("Accept-Encoding: identity\r \n " .encode ('utf-8' ))
858- socket .write (("Authorization: %s\r \n " % \
859- self .context .token ).encode ('utf-8' ))
847+ socket .write ((f"Authorization: { self .context .token } \r \n " ).encode ('utf-8' ))
860848 socket .write ("X-Splunk-Input-Mode: Streaming\r \n " .encode ('utf-8' ))
861849 socket .write ("\r \n " .encode ('utf-8' ))
862850 socket .close ()
@@ -973,7 +961,7 @@ def check_response(handler):
973961 length = int (handler .headers .get ('content-length' , 0 ))
974962 body = handler .rfile .read (length )
975963 assert handler .headers ['content-type' ] == 'application/x-www-form-urlencoded'
976- assert body .decode ('utf-8' ) == 'baz=baf&hep=cat' or body . decode ( 'utf-8' ) == ' hep=cat&baz=baf'
964+ assert body .decode ('utf-8' ) in [ 'baz=baf&hep=cat' , ' hep=cat&baz=baf']
977965
978966 with MockServer (POST = check_response ):
979967 ctx = binding .connect (port = 9093 , scheme = 'http' , token = "waffle" )
0 commit comments