





'''simple docstring'''







import importlib
import inspect
from functools import wraps
from typing import TYPE_CHECKING, Optional, Union

from .download.streaming_download_manager import (
    xbasename,
    xdirname,
    xet_parse,
    xexists,
    xgetsize,
    xglob,
    xgzip_open,
    xisdir,
    xisfile,
    xjoin,
    xlistdir,
    xnumpy_load,
    xopen,
    xpandas_read_csv,
    xpandas_read_excel,
    xPath,
    xrelpath,
    xsio_loadmat,
    xsplit,
    xsplitext,
    xwalk,
    xxml_dom_minidom_parse,
)
from .utils.logging import get_logger
from .utils.patching import patch_submodule
from .utils.py_utils import get_imports


A						    =							get_logger(__name__)


if TYPE_CHECKING:
    from .builder import DatasetBuilder

def 		SCREAMING_SNAKE_CASE      (					lowerCAmelCase__     :	Any       ,  lowerCAmelCase__     :	Optional[Union[str, bool]] = None):

     '''simple docstring'''




     _lowercase							:      Optional[int]  						=							importlib.import_module(snake_case__)

     # TODO(QL): always update the module to add subsequent new authentication
     if hasattr(snake_case__       ,  '_patched_for_streaming') and module._patched_for_streaming:
          return

     def wrap_auth(lowerCAmelCase__     :	List[Any]):
          @wraps(snake_case__)
          def wrapper(*lowerCAmelCase__     :	Dict       ,  **lowerCAmelCase__     :	Union[str, Any]):
               return function(*snake_case__       ,  use_auth_token=snake_case__       ,  **snake_case__)

          _lowercase							:      int  						=							'wrap_auth'
          return wrapper

     # open files in a streaming fashion
     patch_submodule(snake_case__       ,  'open'       ,  wrap_auth(snake_case__)).start()
     patch_submodule(snake_case__       ,  'os.listdir'       ,  wrap_auth(snake_case__)).start()
     patch_submodule(snake_case__       ,  'os.walk'       ,  wrap_auth(snake_case__)).start()
     patch_submodule(snake_case__       ,  'glob.glob'       ,  wrap_auth(snake_case__)).start()
     # allow to navigate in remote zip files
     patch_submodule(snake_case__       ,  'os.path.join'       ,  snake_case__).start()
     patch_submodule(snake_case__       ,  'os.path.dirname'       ,  snake_case__).start()
     patch_submodule(snake_case__       ,  'os.path.basename'       ,  snake_case__).start()
     patch_submodule(snake_case__       ,  'os.path.relpath'       ,  snake_case__).start()
     patch_submodule(snake_case__       ,  'os.path.split'       ,  snake_case__).start()
     patch_submodule(snake_case__       ,  'os.path.splitext'       ,  snake_case__).start()
     # allow checks on paths
     patch_submodule(snake_case__       ,  'os.path.exists'       ,  wrap_auth(snake_case__)).start()
     patch_submodule(snake_case__       ,  'os.path.isdir'       ,  wrap_auth(snake_case__)).start()
     patch_submodule(snake_case__       ,  'os.path.isfile'       ,  wrap_auth(snake_case__)).start()
     patch_submodule(snake_case__       ,  'os.path.getsize'       ,  wrap_auth(snake_case__)).start()
     patch_submodule(snake_case__       ,  'pathlib.Path'       ,  snake_case__).start()
     # file readers
     patch_submodule(snake_case__       ,  'gzip.open'       ,  wrap_auth(snake_case__)).start()
     patch_submodule(snake_case__       ,  'numpy.load'       ,  wrap_auth(snake_case__)).start()
     patch_submodule(snake_case__       ,  'pandas.read_csv'       ,  wrap_auth(snake_case__)       ,  attrs=['__version__']).start()
     patch_submodule(snake_case__       ,  'pandas.read_excel'       ,  wrap_auth(snake_case__)       ,  attrs=['__version__']).start()
     patch_submodule(snake_case__       ,  'scipy.io.loadmat'       ,  wrap_auth(snake_case__)       ,  attrs=['__version__']).start()
     patch_submodule(snake_case__       ,  'xml.etree.ElementTree.parse'       ,  wrap_auth(snake_case__)).start()
     patch_submodule(snake_case__       ,  'xml.dom.minidom.parse'       ,  wrap_auth(snake_case__)).start()
     _lowercase							:      List[Any]  						=							True



def 		SCREAMING_SNAKE_CASE      (					lowerCAmelCase__     :	"DatasetBuilder"):

     '''simple docstring'''




     extend_module_for_streaming(builder.__module__       ,  use_auth_token=builder.use_auth_token)
     # if needed, we also have to extend additional internal imports (like wmt14 -> wmt_utils)
     if not builder.__module__.startswith('datasets.'):  # check that it's not a packaged builder like csv
          for imports in get_imports(inspect.getfile(builder.__class__)):
               if imports[0] == "internal":
                    _lowercase							:      Optional[int]  						=							imports[1]
                    _lowercase							:      Union[str, Any]  						=							'.'.join(builder.__module__.split('.')[:-1] + [internal_import_name])
                    extend_module_for_streaming(snake_case__       ,  use_auth_token=builder.use_auth_token)

    # builders can inherit from other builders that might use streaming functionality
    # (for example, ImageFolder and AudioFolder inherit from FolderBuilder which implements examples generation)
    # but these parents builders are not patched automatically as they are not instantiated, so we patch them here
     from .builder import DatasetBuilder

     _lowercase							:      Dict  						=							[
         cls.__module__
         for cls in type(snake_case__).__mro__[1:]  # make sure it's not the same module we've already patched
         if issubclass(cls       ,  snake_case__) and cls.__module__ != DatasetBuilder.__module__
     ]  # check it's not a standard builder from datasets.builder
     for module in parent_builder_modules:
          extend_module_for_streaming(snake_case__       ,  use_auth_token=builder.use_auth_token)






'''simple docstring'''







from __future__ import annotations

import math
import random

def 		SCREAMING_SNAKE_CASE      (					lowerCAmelCase__     :	int       ,  lowerCAmelCase__     :	int       ,  lowerCAmelCase__     :	int)			->						list[int]:

     '''simple docstring'''




     _lowercase							:      Optional[Any]  						=							d * e - 1
     _lowercase							:      Optional[Any]  						=							0
     _lowercase							:      Dict  						=							0
     while p == 0:
          _lowercase							:      Optional[Any]  						=							random.randint(2       ,  n - 1)
          _lowercase							:      int  						=							k
          while True:
               if t % 2 == 0:
                    _lowercase							:      int  						=							t // 2
                    _lowercase							:      Any  						=							(g**t) % n
                    _lowercase							:      Tuple  						=							math.gcd(x - 1       ,  lowerCAmelCase__)
                    if x > 1 and y > 1:
                         _lowercase							:      Union[str, Any]  						=							y
                         _lowercase							:      Dict  						=							n // y
                         break  # find the correct factors
               else:
                    break  # t is not divisible by 2, break and choose another g
     return sorted([p, q])


if __name__ == "__main__":
    import doctest

    doctest.testmod()