DSrSSKJr SSKJr SSKJr SSKJr SSKrSSKrSSKrSSK r SSK r SSK r SSK J r SSKJr SS KJr SS KJr SS KJr SS KJr SS KJr SSKJr SSKJr SSKJr SSKJr SSK J!r! SSK"J#s J$r$ SSK"J%r% SSK"J&r& SSK'J(r( SSK)J*r* Sr+"SS\,5r-\%R\"\$R^S5"SS\!R`55r1g)z*Contains gsutil base unit test case class.)absolute_import)print_function)division)unicode_literalsN)get_utf8able_str) project_id)wildcard_iterator)BotoTranslation)CloudApiDelegator) CommandRunner)ApiMapConstants) ApiSelector)DiscardMessagesQueue) GcsJsonApi)MockLoggingHandler)base)unittest)WorkingDirectory)UTF8) print_to_fdc[R(dUR5 gUR5 g![a gf=f)zCSuppress IOError when closing sys.stdout or sys.stderr in tearDown.N)sixPY2closeIOError)fds 5platform/gsutil/gslib/tests/testcase/unit_testcase.py_AttemptToCloseSysFdr1s7 HHJ  HHJ   s9 AAc(\rSrSrSr\S5rSrg) GsutilApiUnitTestClassMapFactory@zClass map factory for use in unit tests. BotoTranslation is used for all cases so that GSMockBucketStorageUri can be used to communicate with the mock XML service. c[R[[R[0n[R[0nXS.nU$)z*Returns a class map for use in unit tests.gss3)rXMLr JSON)cls gs_class_map s3_class_map class_maps r GetClassMap,GsutilApiUnitTestClassMapFactory.GetClassMapGsA     L OO_5L#8I N)__name__ __module__ __qualname____firstlineno____doc__ classmethodr,__static_attributes__r/r.rr r @s   r.r zNot running integration tests.c^\rSrSrSr\S5rU4SjrU4SjrS Sjr \SSj5r \SSj5r \ SS j5r SS jrSS jrS rU=r$)GsUtilUnitTestCaseWz!Base class for gsutil unit tests.c[RR5 [RUl[ Ul[R"5Ul [UR URS9Ul S[lg)N)bucket_storage_uri_classgsutil_api_class_map_factoryzmock-project-id-for-unit-tests)rGsUtilTestCase setUpClassutilGSMockBucketStorageUrimock_bucket_storage_urir !mock_gsutil_api_class_map_factorylogging getLoggerloggerr command_runnerrUNIT_TEST_PROJECT_ID)r(s rr>GsUtilUnitTestCase.setUpClass[se""$"&"="=C,LC)""$CJ&!$![[U] 5 /Ul[R Ul[RUl[R"5uol [R(a![R"US5[lO[R"USSS9[l[R"5uol[R(a![R"US5[lO[R"USSS9[l/Ul/Ul[&R("5UlUR*R-[&R.5UlUR*R2Ul[R"5uol[R"US5Ul[&R:"UR85UlUR</UR*lg)Nzw+zutf-8)encoding)superr8setUp bucket_urissysstdout stdout_savestderr stderr_savetempfilemkstemp stdout_filerrosfdopen stderr_fileaccumulated_stdoutaccumulated_stderrrCrD root_logger isEnabledForDEBUG is_debugginghandlerslog_handlers_savelog_handler_filelog_handler_stream StreamHandlertemp_log_handler)selfr __class__s rrLGsUtilUnitTestCase.setUphs^ d)+DzzDzzD#++-B ww99R&cj99R8cj#++-B ww99R&cj99R8cj D D((*D((55gmmDD!--66D ( 0 0 2B iiD1D#11$2I2IJD!%!6!6 7Dr.cd >[[U] 5 URURlUR R5 UR R5 URRS5 URR5nURR5 [R"UR5 [R RS5 [R"RS5 [$R&(a=[R R5n[R"R5nO=[R R5n[R"R5nUR,Vs/sHn[$R."U5PM nUR0Vs/sHn[$R."U5PM n[$R."[3U55n[$R."[3U55nUSR5UR05- nUSR5UR,5- n[7[R 5 [7[R"5 UR8[lUR:[l[R"UR<5 [R"UR>5 [$R."URA55nURB(a^U(aW[ESRGU5[R"S9 [EU[R"S9 [ES[R"S9 URB(a^U(aW[ESRGU5[R"S9 [EU[R"S9 [ES[R"S9 URB(a`U(aX[ESRGU5[R"S9 [EU[R"S9 [ES [R"S9 ggg![(a [R RS5 [R"RS5 [R R*R5n[R"R*R5nGNf=fs snfs snf) Nrz==== stdout {} ==== file==== end stdout ==== z==== stderr {} ==== ==== end stderr ==== z==== log output {} ==== z==== end log output ==== )$rKr8tearDownr`r[r_rdflushrrbseekreadrVunlinkrarNrOrQrrUnicodeDecodeErrorbufferrZ ensure_textrYrjoinrrPrRrUrXidr^rformat)re log_outputrOrQstring_idrfs rrnGsUtilUnitTestCase.tearDownsD d,. $ 6 6D!!  #((--/J!!#IId##$JJOOAJJOOA wwzz fzz f*"" ,0+B+BC+BS__V+BC+/+B+BC+BS__V+BC __-f5 6F __-f5 6F bggd--..F bggd--..F$$!!CJ!!CJIIdIId //$'') $C V)005CJJG&szz**< V)005CJJG&szz**< Z-44S9 K*3::..SZZ@(7 *  ""'')""'') * DCs#555n [R"URA55nUR(aQU (aJ[ S R X5UR S9 [ XR S9 [ S UR S9 UR(aQU (aJ[ S R X5UR S9 [ XR S9 [ S UR S9 UR(aQU (aJ[ SR X5UR S9 [ XR S9 [ SUR S9 [RRS5 [RRS5 [RR5 [RR5 /nU(aURU 5 U(aURU 5 U(aURU 5 [CU5S:XaUS$[EU5$!,(df  GNt=f![4a [RRS5 [RRS5 [RR6R5n [RR6R5n GNEf=f![RRS5 [RRS5 [R2(a=[RR5n [RR5n O[RR5n [RR5n O![4a [RRS5 [RRS5 [RR6R5n [RR6R5n Of=f["R$"U5R9U 5 U R;5 SRS [R<"U R>555n [R"URA55nUR(aQU (aJ[ S R X5UR S9 [ XR S9 [ S UR S9 UR(aQU (aJ[ S R X5UR S9 [ XR S9 [ S UR S9 UR(aQU (aJ[ SR X5UR S9 [ XR S9 [ SUR S9 [RRS5 [RRS5 [RR5 [RR5 f=f)aMethod for calling gslib.command_runner.CommandRunner. Passes parallel_operations=False for all tests, optionally saving/returning stdout output. We run all tests multi-threaded, to exercise those more complicated code paths. TODO: Change to run with parallel_operations=True for all tests. At present when you do this it causes many test failures. Args: command_name: The name of the command being run. args: Command-line args (arg0 = actual arg, not command name ala bash). headers: Dictionary containing optional HTTP headers to pass to boto. debug: Debug level to pass in to boto connection (range 0..3). return_stdout: If True, will save and return stdout produced by command. return_stderr: If True, will save and return stderr produced by command. return_log_handler: If True, will return a MockLoggingHandler instance that was attached to the command's logger while running. cwd: The working directory that should be switched to before running the command. The working directory will be reset back to its original value after running the command. If not specified, the working directory is left unchanged. Returns: One or a tuple of requested return values, depending on whether return_stdout, return_stderr, and/or return_log_handler were specified. Return Types: stdout - str (binary in Py2, text in Py3) stderr - str (binary in Py2, text in Py3) log_handler - MockLoggingHandler  z RunCommand of {} rjrF)argsheadersdebugparallel_operations do_shutdownN c3f# UH'upU(dMSU-SRU5-v M) g7f)z%s: z N)rv).0levelrecordss r 0GsUtilUnitTestCase.RunCommand..s1 Hne  3)e fkk'2 2 Hs 11z#==== logging RunCommand {} {} ==== z ==== end logging ==== z"==== stdout RunCommand {} {} ==== rlz"==== stderr RunCommand {} {} ==== rm)#rrurvr^rrxrRrNrOrprQrqrYappendrZtruncaterrCrD addHandlersetLevelr]rrFRunNamedCommandrrsrt removeHandlerr iteritemsmessagesrwlentuple)re command_namerrr return_stdout return_stderrreturn_log_handlercwd command_linerOrQmock_log_handlerryr{ to_returns r RunCommandGsUtilUnitTestCase.RunCommandsN :2D??388\NT,A#BCL (// ='') JJOOAJJOOA ZZ__ F ZZ__ F  $$V,  $$V,JJOOAJJOOAJJJJ)+ l#../?@   %..w}}=8 C  ++L154;27@E8= , ? ! jjooa jjooa "" ,::??$&::??$&  %334DE99 # .>.G.G Hj OODGGI &c  z:AA )) + J%5%56/d6F6FG  v9@@ )) + F!1!12,43C3CD  v9@@ )) + F!1!12,43C3CD jjooa jjooa jj jjIvv'( 9~ q\  E ! "" , **//!  **//! ::$$))+&::$$))+&  , jjooa jjooa "" ,::??$&::??$&! , **//!  **//! ::$$))+&::$$))+&  ,  %334DE99 # .>.G.G Hj OODGGI &c  z:AA )) + J%5%56/d6F6FG  v9@@ )) + F!1!12,43C3CD  v9@@ )) + F!1!12,43C3CD jjooa jjooa jj jjs^ YV"5Y > @##??K$4$45??#&  ##""//&  N S88+ ZZ13#(  **r.cUn[US5(a URn[R"UUR U5US9$)ajConvenience method for instantiating a test instance of WildcardIterator. This makes it unnecessary to specify all the params of that class (like bucket_storage_uri_class=mock_storage_service.MockBucketStorageUri). Also, naming the factory method this way makes it clearer in the test code that WildcardIterator needs to be set up for testing. Args are same as for wildcard_iterator.wildcard_iterator(), except there are no class args for bucket_storage_uri_class or gsutil_api_class. Args: uri_or_str: StorageUri or string representing the wildcard string. exclude_tuple: (base_url, exclude_pattern), where base_url is top-level URL to list; exclude_pattern is a regex of paths to ignore during iteration. debug: debug level to pass to the underlying connection (0..3) Returns: WildcardIterator, over which caller can iterate. uri) exclude_tuple)hasattrrr CreateWildcardIteratorr)r( uri_or_strrr uri_strings r_test_wildcard_iterator*GsUtilUnitTestCase._test_wildcard_iteratorVsG.Jz5!!>>j  3 3J474E4Ee4LBO QQr.cN[R"XX#[R5$)aConvenience method for instantiating a testing instance of StorageUri. This makes it unnecessary to specify bucket_storage_uri_class=mock_storage_service.MockBucketStorageUri. Also naming the factory method this way makes it clearer in the test code that StorageUri needs to be set up for testing. Args, Returns, and Raises are same as for boto.storage_uri(), except there's no bucket_storage_uri_class arg. Args: uri_str: Uri string to create StorageUri for. default_scheme: Default scheme for the StorageUri debug: debug level to pass to the underlying connection (0..3) validate: If True, validate the resource that the StorageUri refers to. Returns: StorageUri based on the arguments. )boto storage_urir?r@)uri_strdefault_schemervalidates r_test_storage_uri$GsUtilUnitTestCase._test_storage_urius$*   GU 77 99r.c$U=(d URS5n[R"U<SUR5<3S[R S9nUR US9 URRU5 [U5 [U5H8upxURUUSRU5R[ 5S9 M: U$![a2 [U5Vs/sHo`RS5PM Os snfnnNf=f) a1Creates a test bucket. The bucket and all of its contents will be deleted after the test. Args: bucket_name: Create the bucket with this name. If not provided, a temporary test bucket name is constructed. test_objects: The number of objects that should be placed in the bucket or a list of object names to place in the bucket. Defaults to 0. storage_class: storage class to use. If not provided we us standard. provider: string provider to use, default gs. Returns: StorageUri for the created bucket. bucketz://F)suppress_consec_slashesr;) storage_classobjztest {}) bucket_uri object_namecontents) MakeTempNamerrlowerr?r@ create_bucketrMriter TypeErrorrange enumerate CreateObjectrxencoder) re bucket_name test_objectsrproviderr_inames r CreateBucketGsUtilUnitTestCase.CreateBuckets*<!2!28!J=9J'M <\* :$(!*!1!1!!4!;!;D!AC+  M8=l8KL8K1''.8KLlLlMs? CD*DDDcU=(d URURS9nU=(d URS5nURU5nUbUR U5 U$)aCreates a test object. Args: bucket_uri: The URI of the bucket to place the object in. If not specified, a new temporary bucket is created. object_name: The name to use for the object. If not specified, a temporary test object name is constructed. contents: The contents to write to the object. If not specified, the key is not written to, which means that it isn't actually created yet on the server. Returns: A StorageUri for the created object. )rr)rdefault_providerrclone_replace_nameset_contents_from_string)rerrrkey_uris rrGsUtilUnitTestCase.CreateObjects`Pt00$:O:O0PJ9!2!25!9K++K8G &&x0 Nr.) rZrYrMr^rarbr`r[rXrRrUrPrd)NNrFFFN)r)Nr)rkrT)NrNr$)NNN)r0r1r2r3r4r5r>rLrnrrr staticmethodrrrr6 __classcell__)rfs@rr8r8Ws) G G8:2Al$$$)FP**(QQ<990 $ !!% $Lr.r8)2r4 __future__rrrrrCrVrNrSrr boto.utilsrgslibrr gslib.boto_translationr gslib.cloud_api_delegatorr gslib.command_runnerr gslib.cs_api_mapr rgslib.discard_messages_queuergslib.gcs_json_apir gslib.tests.mock_logging_handlerrgslib.tests.testcasergslib.tests.utiltestsr?rrgslib.utils.constantsrgslib.utils.text_utilrrobjectr skipUnlessRUN_UNIT_TESTSr=r8r/r.rrs1&%'  '#27.,(=)?%%-&-  v. T((*JKo,,oLor.