| 94 | |
| 95 | |
| 96 | def apply_replacements(lines: list[str]) -> list[str]: |
| 97 | for i in range(len(lines)): |
| 98 | if "_IS_SYNC = True" in lines[i]: |
| 99 | lines[i] = "_IS_SYNC = False" |
| 100 | if "def test" in lines[i]: |
| 101 | lines[i] = lines[i].replace("def test", "async def test") |
| 102 | for k in replacements: |
| 103 | if k in lines[i]: |
| 104 | lines[i] = lines[i].replace(k, replacements[k]) |
| 105 | for k in async_methods: |
| 106 | if k + "(" in lines[i]: |
| 107 | tokens = lines[i].split(" ") |
| 108 | for j in range(len(tokens)): |
| 109 | if k + "(" in tokens[j]: |
| 110 | if j < 2: |
| 111 | tokens.insert(0, "await") |
| 112 | else: |
| 113 | tokens.insert(j, "await") |
| 114 | break |
| 115 | new_line = " ".join(tokens) |
| 116 | |
| 117 | lines[i] = new_line |
| 118 | |
| 119 | return lines |
| 120 | |
| 121 | |
| 122 | def process_file(input_file: str, output_file: str) -> None: |