|
3 | 3 |
|
4 | 4 | from .core.base import BaseCaptcha
|
5 | 5 | from .core.enums import RotateCaptchaEnm
|
| 6 | +from .core.serializer import GetTaskResultResponseSer |
6 | 7 |
|
7 | 8 |
|
8 | 9 | class RotateCaptcha(BaseCaptcha):
|
@@ -78,6 +79,7 @@ def __init__(self, method: str = RotateCaptchaEnm.ROTATECAPTCHA.value, *args, **
|
78 | 79 | """
|
79 | 80 | super().__init__(method=method, *args, **kwargs)
|
80 | 81 |
|
| 82 | + self.result = GetTaskResultResponseSer() |
81 | 83 | # check user params
|
82 | 84 | if method not in RotateCaptchaEnm.list_values():
|
83 | 85 | raise ValueError(f"Invalid method parameter set, available - {RotateCaptchaEnm.list_values()}")
|
@@ -117,25 +119,27 @@ def captcha_handler(
|
117 | 119 |
|
118 | 120 | # if a local file link is passed
|
119 | 121 | if captcha_file:
|
120 |
| - self.post_payload.update({"body": base64.b64encode(self._local_file_captcha(captcha_file)).decode("utf-8")}) |
| 122 | + self.create_task_payload["task"].update( |
| 123 | + {"body": base64.b64encode(self._local_file_captcha(captcha_file)).decode("utf-8")} |
| 124 | + ) |
121 | 125 | # if the file is transferred in base64 encoding
|
122 | 126 | elif captcha_base64:
|
123 |
| - self.post_payload.update({"body": base64.b64encode(captcha_base64).decode("utf-8")}) |
| 127 | + self.create_task_payload["task"].update({"body": base64.b64encode(captcha_base64).decode("utf-8")}) |
124 | 128 | # if a URL is passed
|
125 | 129 | elif captcha_link:
|
126 | 130 | try:
|
127 | 131 | content = self.url_open(url=captcha_link, **kwargs).content
|
128 |
| - self.post_payload.update({"body": base64.b64encode(content).decode("utf-8")}) |
| 132 | + self.create_task_payload["task"].update({"body": base64.b64encode(content).decode("utf-8")}) |
129 | 133 | except Exception as error:
|
130 | 134 | self.result.error = True
|
131 | 135 | self.result.errorBody = str(error)
|
132 |
| - return self.result.dict() |
| 136 | + return self.result.to_dict() |
133 | 137 |
|
134 | 138 | else:
|
135 | 139 | # if none of the parameters are passed
|
136 | 140 | self.result.error = True
|
137 | 141 | self.result.errorBody = self.NO_CAPTCHA_ERR
|
138 |
| - return self.result.dict() |
| 142 | + return self.result.to_dict() |
139 | 143 | return self._processing_response(**kwargs)
|
140 | 144 |
|
141 | 145 | async def aio_captcha_handler(
|
@@ -173,24 +177,26 @@ async def aio_captcha_handler(
|
173 | 177 |
|
174 | 178 | # if a local file link is passed
|
175 | 179 | if captcha_file:
|
176 |
| - self.post_payload.update({"body": base64.b64encode(self._local_file_captcha(captcha_file)).decode("utf-8")}) |
| 180 | + self.create_task_payload["task"].update( |
| 181 | + {"body": base64.b64encode(self._local_file_captcha(captcha_file)).decode("utf-8")} |
| 182 | + ) |
177 | 183 | # if the file is transferred in base64 encoding
|
178 | 184 | elif captcha_base64:
|
179 |
| - self.post_payload.update({"body": base64.b64encode(captcha_base64).decode("utf-8")}) |
| 185 | + self.create_task_payload["task"].update({"body": base64.b64encode(captcha_base64).decode("utf-8")}) |
180 | 186 | # if a URL is passed
|
181 | 187 | elif captcha_link:
|
182 | 188 | try:
|
183 | 189 | content = await self.aio_url_read(url=captcha_link, **kwargs)
|
184 |
| - self.post_payload.update({"body": base64.b64encode(content).decode("utf-8")}) |
| 190 | + self.create_task_payload["task"].update({"body": base64.b64encode(content).decode("utf-8")}) |
185 | 191 | except Exception as error:
|
186 | 192 | self.result.error = True
|
187 | 193 | self.result.errorBody = str(error)
|
188 |
| - return self.result.dict() |
| 194 | + return self.result.to_dict() |
189 | 195 |
|
190 | 196 | else:
|
191 | 197 | # if none of the parameters are passed
|
192 | 198 | self.result.error = True
|
193 | 199 | self.result.errorBody = self.NO_CAPTCHA_ERR
|
194 |
| - return self.result.dict() |
| 200 | + return self.result.to_dict() |
195 | 201 |
|
196 | 202 | return await self._aio_processing_response()
|
0 commit comments