


'''simple docstring'''

import os
import unittest

from transformers.models.transfo_xl.tokenization_transfo_xl import VOCAB_FILES_NAMES, TransfoXLTokenizer

from ...test_tokenization_common import TokenizerTesterMixin
class   __lowerCAmelCase						(lowercase_  ,     unittest.TestCase     ):





      '''simple docstring'''






      lowerCAmelCase__					:     List[Any]  					=							TransfoXLTokenizer
      lowerCAmelCase__					:     int  					=							False
      lowerCAmelCase__					:     List[str]  					=							False



      def       UpperCamelCase__		(self    :    Dict ):

             '''simple docstring'''







             super().setUp()

             lowercase__      			= [
                 '''<unk>''',
                 '''[CLS]''',
                 '''[SEP]''',
                 '''want''',
                 '''unwanted''',
                 '''wa''',
                 '''un''',
                 '''running''',
                 ''',''',
                 '''low''',
                 '''l''',
             ]
             lowercase__      			= os.path.join(self.tmpdirname   ,						VOCAB_FILES_NAMES['''vocab_file'''] )
             with open(self.vocab_file   ,						'''w'''   ,						encoding='''utf-8''' ) as vocab_writer:
                    vocab_writer.write(''''''.join([x + '''\n''' for x in vocab_tokens] ) )



      def       UpperCamelCase__		(self    :    List[str]   ,						**UpperCamelCase    :    int ):

             '''simple docstring'''







             lowercase__      			= True
             return TransfoXLTokenizer.from_pretrained(self.tmpdirname   ,						**UpperCamelCase )



      def       UpperCamelCase__		(self    :    int   ,						UpperCamelCase    :    int ):

             '''simple docstring'''







             lowercase__      			= '''<unk> UNwanted , running'''
             lowercase__      			= '''<unk> unwanted, running'''
             return input_text, output_text



      def       UpperCamelCase__		(self    :    Dict ):

             '''simple docstring'''







             lowercase__      			= TransfoXLTokenizer(vocab_file=self.vocab_file   ,						lower_case=UpperCamelCase )

             lowercase__      			= tokenizer.tokenize('''<unk> UNwanted , running''' )
             self.assertListEqual(UpperCamelCase   ,						['''<unk>''', '''unwanted''', ''',''', '''running'''] )

             self.assertListEqual(tokenizer.convert_tokens_to_ids(UpperCamelCase )   ,						[0, 4, 8, 7] )



      def       UpperCamelCase__		(self    :    Optional[int] ):

             '''simple docstring'''







             lowercase__      			= TransfoXLTokenizer(lower_case=UpperCamelCase )

             self.assertListEqual(
                 tokenizer.tokenize(''' \tHeLLo ! how  \n Are yoU ?  ''' )   ,						['''hello''', '''!''', '''how''', '''are''', '''you''', '''?'''] )



      def       UpperCamelCase__		(self    :    List[str] ):

             '''simple docstring'''







             lowercase__      			= TransfoXLTokenizer(lower_case=UpperCamelCase )

             self.assertListEqual(
                 tokenizer.tokenize(''' \tHeLLo ! how  \n Are yoU ?  ''' )   ,						['''HeLLo''', '''!''', '''how''', '''Are''', '''yoU''', '''?'''] )



      def       UpperCamelCase__		(self    :    Optional[int] ):

             '''simple docstring'''







             lowercase__      			= TransfoXLTokenizer(lower_case=UpperCamelCase )
             lowercase__      			= '''Hello (bracket) and side-scrolled [and] Henry\'s $5,000 with 3.34 m. What\'s up!?'''
             lowercase__      			= [
                 '''Hello''',
                 '''(''',
                 '''bracket''',
                 ''')''',
                 '''and''',
                 '''side''',
                 '''@-@''',
                 '''scrolled''',
                 '''[''',
                 '''and''',
                 ''']''',
                 '''Henry''',
                 '''\'s''',
                 '''$''',
                 '''5''',
                 '''@,@''',
                 '''000''',
                 '''with''',
                 '''3''',
                 '''@.@''',
                 '''34''',
                 '''m''',
                 '''.''',
                 '''What''',
                 '''\'s''',
                 '''up''',
                 '''!''',
                 '''?''',
             ]

             self.assertListEqual(tokenizer.tokenize(UpperCamelCase )   ,						UpperCamelCase )

             self.assertEqual(tokenizer.convert_tokens_to_string(UpperCamelCase )   ,						UpperCamelCase )






      def       UpperCamelCase__		(self    :    Tuple ):

             '''simple docstring'''







             lowercase__      			= self.get_tokenizer()
             lowercase__      			= len(UpperCamelCase )

             tokenizer.add_tokens(['''new1''', '''new2'''] )
             tokenizer.move_added_token('''new1'''   ,						1 )

             # Check that moved token is not copied (duplicate)
             self.assertEqual(len(UpperCamelCase )   ,						original_len + 2 )
             # Check that token is moved to specified id
             self.assertEqual(tokenizer.encode('''new1''' )   ,						[1] )
             self.assertEqual(tokenizer.decode([1] )   ,						'''new1''' )





import io
import json

import fsspec
import pytest

from datasets import Dataset, DatasetDict, Features, NamedSplit, Value
from datasets.io.json import JsonDatasetReader, JsonDatasetWriter

from ..utils import assert_arrow_memory_doesnt_increase, assert_arrow_memory_increases

def 			lowercase_				(			_lowerCamelCase							:       Optional[Any]		,	_lowerCamelCase							:       int):
    assert isinstance(_lowerCamelCase		,	_lowerCamelCase)
    assert dataset.num_rows == 4
    assert dataset.num_columns == 3
    assert dataset.column_names == ["col_1", "col_2", "col_3"]
    for feature, expected_dtype in expected_features.items():
        assert dataset.features[feature].dtype == expected_dtype

@pytest.mark.parametrize("keep_in_memory"		,	[False, True])
def 			lowercase_				(			_lowerCamelCase							:       List[Any]		,	_lowerCamelCase							:       Any		,	_lowerCamelCase							:       str):
    lowercase__ :   Optional[int]    					=				tmp_path / "cache"
    lowercase__ :   str    					=				{"col_1": "string", "col_2": "int64", "col_3": "float64"}
    with assert_arrow_memory_increases() if keep_in_memory else assert_arrow_memory_doesnt_increase():
        lowercase__ :   Union[str, Any]    					=				JsonDatasetReader(_lowerCamelCase		,	cache_dir=_lowerCamelCase		,	keep_in_memory=_lowerCamelCase).read()
    _check_json_dataset(_lowerCamelCase		,	_lowerCamelCase)

@pytest.mark.parametrize(
    "features"		,	[
        None,
        {"col_1": "string", "col_2": "int64", "col_3": "float64"},
        {"col_1": "string", "col_2": "string", "col_3": "string"},
        {"col_1": "int32", "col_2": "int32", "col_3": "int32"},
        {"col_1": "float32", "col_2": "float32", "col_3": "float32"},
    ]		,	)
def 			lowercase_				(			_lowerCamelCase							:       List[str]		,	_lowerCamelCase							:       Dict		,	_lowerCamelCase							:       Dict):
    lowercase__ :   List[Any]    					=				tmp_path / "cache"
    lowercase__ :   Union[str, Any]    					=				{"col_1": "string", "col_2": "int64", "col_3": "float64"}
    lowercase__ :   List[Any]    					=				features.copy() if features else default_expected_features
    lowercase__ :   List[Any]    					=				(
        Features({feature: Value(_lowerCamelCase) for feature, dtype in features.items()}) if features is not None else None
    )
    lowercase__ :   Any    					=				JsonDatasetReader(_lowerCamelCase		,	features=_lowerCamelCase		,	cache_dir=_lowerCamelCase).read()
    _check_json_dataset(_lowerCamelCase		,	_lowerCamelCase)

@pytest.mark.parametrize(
    "features"		,	[
        None,
        {"col_3": "float64", "col_1": "string", "col_2": "int64"},
    ]		,	)
def 			lowercase_				(			_lowerCamelCase							:       Any		,	_lowerCamelCase							:       Any		,	_lowerCamelCase							:       List[str]):
    lowercase__ :   Optional[Any]    					=				tmp_path / "cache"
    lowercase__ :   Tuple    					=				{"col_3": "float64", "col_1": "string", "col_2": "int64"}
    lowercase__ :   List[Any]    					=				features.copy() if features else default_expected_features
    lowercase__ :   int    					=				(
        Features({feature: Value(_lowerCamelCase) for feature, dtype in features.items()}) if features is not None else None
    )
    lowercase__ :   Any    					=				JsonDatasetReader(_lowerCamelCase		,	features=_lowerCamelCase		,	cache_dir=_lowerCamelCase).read()
    assert isinstance(_lowerCamelCase		,	_lowerCamelCase)
    assert dataset.num_rows == 2
    assert dataset.num_columns == 3
    assert dataset.column_names == ["col_3", "col_1", "col_2"]
    for feature, expected_dtype in expected_features.items():
        assert dataset.features[feature].dtype == expected_dtype

def 			lowercase_				(			_lowerCamelCase							:       List[Any]		,	_lowerCamelCase							:       Optional[int]):
    # jsonl_312_path features are {"col_3": "float64", "col_1": "string", "col_2": "int64"}
    lowercase__ :   Any    					=				{"col_2": "int64", "col_3": "float64", "col_1": "string"}
    lowercase__ :   str    					=				features.copy()
    lowercase__ :   str    					=				(
        Features({feature: Value(_lowerCamelCase) for feature, dtype in features.items()}) if features is not None else None
    )
    lowercase__ :   Optional[int]    					=				tmp_path / "cache"
    lowercase__ :   Any    					=				JsonDatasetReader(_lowerCamelCase		,	features=_lowerCamelCase		,	cache_dir=_lowerCamelCase).read()
    assert isinstance(_lowerCamelCase		,	_lowerCamelCase)
    assert dataset.num_rows == 2
    assert dataset.num_columns == 3
    assert dataset.column_names == ["col_2", "col_3", "col_1"]
    for feature, expected_dtype in expected_features.items():
        assert dataset.features[feature].dtype == expected_dtype

@pytest.mark.parametrize("split"		,	[None, NamedSplit("train"), "train", "test"])
def 			lowercase_				(			_lowerCamelCase							:       Dict		,	_lowerCamelCase							:       Optional[int]		,	_lowerCamelCase							:       List[str]):
    lowercase__ :   Union[str, Any]    					=				tmp_path / "cache"
    lowercase__ :   List[Any]    					=				{"col_1": "string", "col_2": "int64", "col_3": "float64"}
    lowercase__ :   Union[str, Any]    					=				JsonDatasetReader(_lowerCamelCase		,	cache_dir=_lowerCamelCase		,	split=_lowerCamelCase).read()
    _check_json_dataset(_lowerCamelCase		,	_lowerCamelCase)
    assert dataset.split == split if split else "train"

@pytest.mark.parametrize("path_type"		,	[str, list])
def 			lowercase_				(			_lowerCamelCase							:       Union[str, Any]		,	_lowerCamelCase							:       str		,	_lowerCamelCase							:       int):
    if issubclass(_lowerCamelCase		,	_lowerCamelCase):
        lowercase__ :   Tuple    					=				jsonl_path
    elif issubclass(_lowerCamelCase		,	_lowerCamelCase):
        lowercase__ :   str    					=				[jsonl_path]
    lowercase__ :   str    					=				tmp_path / "cache"
    lowercase__ :   Optional[Any]    					=				{"col_1": "string", "col_2": "int64", "col_3": "float64"}
    lowercase__ :   Tuple    					=				JsonDatasetReader(_lowerCamelCase		,	cache_dir=_lowerCamelCase).read()
    _check_json_dataset(_lowerCamelCase		,	_lowerCamelCase)

def 			lowercase_				(			_lowerCamelCase							:       List[Any]		,	_lowerCamelCase							:       Optional[Any]		,	_lowerCamelCase							:       Optional[int]=("train",)):
    assert isinstance(_lowerCamelCase		,	_lowerCamelCase)
    for split in splits:
        lowercase__ :   Optional[Any]    					=				dataset_dict[split]
        assert dataset.num_rows == 4
        assert dataset.num_columns == 3
        assert dataset.column_names == ["col_1", "col_2", "col_3"]
        for feature, expected_dtype in expected_features.items():
            assert dataset.features[feature].dtype == expected_dtype

@pytest.mark.parametrize("keep_in_memory"		,	[False, True])
def 			lowercase_				(			_lowerCamelCase							:       Union[str, Any]		,	_lowerCamelCase							:       str		,	_lowerCamelCase							:       str):
    lowercase__ :   List[str]    					=				tmp_path / "cache"
    lowercase__ :   str    					=				{"col_1": "string", "col_2": "int64", "col_3": "float64"}
    with assert_arrow_memory_increases() if keep_in_memory else assert_arrow_memory_doesnt_increase():
        lowercase__ :   Optional[Any]    					=				JsonDatasetReader({"train": jsonl_path}		,	cache_dir=_lowerCamelCase		,	keep_in_memory=_lowerCamelCase).read()
    _check_json_datasetdict(_lowerCamelCase		,	_lowerCamelCase)

@pytest.mark.parametrize(
    "features"		,	[
        None,
        {"col_1": "string", "col_2": "int64", "col_3": "float64"},
        {"col_1": "string", "col_2": "string", "col_3": "string"},
        {"col_1": "int32", "col_2": "int32", "col_3": "int32"},
        {"col_1": "float32", "col_2": "float32", "col_3": "float32"},
    ]		,	)
def 			lowercase_				(			_lowerCamelCase							:       Any		,	_lowerCamelCase							:       List[str]		,	_lowerCamelCase							:       List[str]):
    lowercase__ :   str    					=				tmp_path / "cache"
    lowercase__ :   Tuple    					=				{"col_1": "string", "col_2": "int64", "col_3": "float64"}
    lowercase__ :   Tuple    					=				features.copy() if features else default_expected_features
    lowercase__ :   Union[str, Any]    					=				(
        Features({feature: Value(_lowerCamelCase) for feature, dtype in features.items()}) if features is not None else None
    )
    lowercase__ :   Tuple    					=				JsonDatasetReader({"train": jsonl_path}		,	features=_lowerCamelCase		,	cache_dir=_lowerCamelCase).read()
    _check_json_datasetdict(_lowerCamelCase		,	_lowerCamelCase)

@pytest.mark.parametrize("split"		,	[None, NamedSplit("train"), "train", "test"])
def 			lowercase_				(			_lowerCamelCase							:       str		,	_lowerCamelCase							:       Dict		,	_lowerCamelCase							:       Tuple):
    if split:
        lowercase__ :   Tuple    					=				{split: jsonl_path}
    else:
        lowercase__ :   Tuple    					=				"train"
        lowercase__ :   int    					=				{"train": jsonl_path, "test": jsonl_path}
    lowercase__ :   Dict    					=				tmp_path / "cache"
    lowercase__ :   Union[str, Any]    					=				{"col_1": "string", "col_2": "int64", "col_3": "float64"}
    lowercase__ :   Union[str, Any]    					=				JsonDatasetReader(_lowerCamelCase		,	cache_dir=_lowerCamelCase).read()
    _check_json_datasetdict(_lowerCamelCase		,	_lowerCamelCase		,	splits=list(path.keys()))
    assert all(dataset[split].split == split for split in path.keys())

def 			lowercase_				(			_lowerCamelCase							:       Union[str, Any]):
    return json.load(_lowerCamelCase)

def 			lowercase_				(			_lowerCamelCase							:       Optional[int]):
    return [json.loads(_lowerCamelCase) for line in buffer]



class   snake_case_       :






   @pytest.mark.parametrize("lines, load_json_function"	,						[(True, load_json_lines), (False, load_json)]  )
   def       __UpperCamelCase     (      self				:     List[Any]	,						lowercase_				:     Any	,						lowercase_				:     Optional[Any]	,						lowercase_				:     Dict  )					->						Optional[Any]:
       with io.BytesIO() as buffer:
           JsonDatasetWriter(lowercase_	,						lowercase_	,						lines=lowercase_  ).write()
           buffer.seek(0  )
           lowercase__ :   Optional[int]    					=				load_json_function(lowercase_  )
       assert isinstance(lowercase_	,						lowercase_  )
       assert isinstance(exported_content[0]	,						lowercase_  )
       assert len(lowercase_  ) == 10






   @pytest.mark.parametrize(
       "orient, container, keys, len_at"	,						[
           ("records", list, {"tokens", "labels", "answers", "id"}, None),
           ("split", dict, {"columns", "data"}, "data"),
           ("index", dict, set("0123456789"  ), None),
           ("columns", dict, {"tokens", "labels", "answers", "id"}, "tokens"),
           ("values", list, None, None),
           ("table", dict, {"schema", "data"}, "data"),
       ]	,						)
   def       __UpperCamelCase     (      self				:     str	,						lowercase_				:     int	,						lowercase_				:     str	,						lowercase_				:     Union[str, Any]	,						lowercase_				:     Dict	,						lowercase_				:     Tuple  )					->						List[str]:
       with io.BytesIO() as buffer:
           JsonDatasetWriter(lowercase_	,						lowercase_	,						lines=lowercase_	,						orient=lowercase_  ).write()
           buffer.seek(0  )
           lowercase__ :   str    					=				load_json(lowercase_  )
       assert isinstance(lowercase_	,						lowercase_  )
       if keys:
           if container is dict:
               assert exported_content.keys() == keys
           else:
               assert exported_content[0].keys() == keys
       else:
           assert not hasattr(lowercase_	,						"keys"  ) and not hasattr(exported_content[0]	,						"keys"  )
       if len_at:
           assert len(exported_content[len_at]  ) == 10
       else:
           assert len(lowercase_  ) == 10






   @pytest.mark.parametrize("lines, load_json_function"	,						[(True, load_json_lines), (False, load_json)]  )
   def       __UpperCamelCase     (      self				:     List[Any]	,						lowercase_				:     int	,						lowercase_				:     Optional[Any]	,						lowercase_				:     Dict  )					->						Optional[int]:
       with io.BytesIO() as buffer:
           JsonDatasetWriter(lowercase_	,						lowercase_	,						lines=lowercase_	,						num_proc=2  ).write()
           buffer.seek(0  )
           lowercase__ :   str    					=				load_json_function(lowercase_  )
       assert isinstance(lowercase_	,						lowercase_  )
       assert isinstance(exported_content[0]	,						lowercase_  )
       assert len(lowercase_  ) == 10






   @pytest.mark.parametrize(
       "orient, container, keys, len_at"	,						[
           ("records", list, {"tokens", "labels", "answers", "id"}, None),
           ("split", dict, {"columns", "data"}, "data"),
           ("index", dict, set("0123456789"  ), None),
           ("columns", dict, {"tokens", "labels", "answers", "id"}, "tokens"),
           ("values", list, None, None),
           ("table", dict, {"schema", "data"}, "data"),
       ]	,						)
   def       __UpperCamelCase     (      self				:     Union[str, Any]	,						lowercase_				:     Dict	,						lowercase_				:     Dict	,						lowercase_				:     Optional[int]	,						lowercase_				:     Optional[Any]	,						lowercase_				:     Dict  )					->						Any:
       with io.BytesIO() as buffer:
           JsonDatasetWriter(lowercase_	,						lowercase_	,						lines=lowercase_	,						orient=lowercase_	,						num_proc=2  ).write()
           buffer.seek(0  )
           lowercase__ :   Optional[Any]    					=				load_json(lowercase_  )
       assert isinstance(lowercase_	,						lowercase_  )
       if keys:
           if container is dict:
               assert exported_content.keys() == keys
           else:
               assert exported_content[0].keys() == keys
       else:
           assert not hasattr(lowercase_	,						"keys"  ) and not hasattr(exported_content[0]	,						"keys"  )
       if len_at:
           assert len(exported_content[len_at]  ) == 10
       else:
           assert len(lowercase_  ) == 10






   def       __UpperCamelCase     (      self				:     Dict	,						lowercase_				:     List[str]  )					->						str:
       with pytest.raises(lowercase_  ):
           with io.BytesIO() as buffer:
               JsonDatasetWriter(lowercase_	,						lowercase_	,						num_proc=0  )







   @pytest.mark.parametrize("compression, extension"	,						[("gzip", "gz"), ("bz2", "bz2"), ("xz", "xz")]  )
   def       __UpperCamelCase     (      self				:     List[Any]	,						lowercase_				:     Tuple	,						lowercase_				:     List[str]	,						lowercase_				:     Optional[Any]	,						lowercase_				:     str	,						lowercase_				:     List[Any]  )					->						Any:
       lowercase__ :   Dict    					=				tmp_path_factory.mktemp("data"  ) / F'''test.json.{extension}'''
       lowercase__ :   Optional[int]    					=				str(shared_datadir / F'''test_file.json.{extension}'''  )
       JsonDatasetWriter(lowercase_	,						lowercase_	,						compression=lowercase_  ).write()

       with fsspec.open(lowercase_	,						"rb"	,						compression="infer"  ) as f:
           lowercase__ :   List[Any]    					=				f.read()
       with fsspec.open(lowercase_	,						"rb"	,						compression="infer"  ) as f:
           lowercase__ :   str    					=				f.read()
       assert exported_content == original_content



