|
6 | 6 |
|
7 | 7 | import requests |
8 | 8 | from plexapi import (BASE_HEADERS, CONFIG, TIMEOUT, X_PLEX_ENABLE_FAST_CONNECT, |
9 | | - log, logfilter, utils) |
| 9 | + log, logfilter, utils, reset_base_headers) |
10 | 10 | from plexapi.base import PlexObject |
11 | 11 | from plexapi.client import PlexClient |
12 | 12 | from plexapi.exceptions import BadRequest, NotFound, Unauthorized |
@@ -92,6 +92,7 @@ def __init__(self, username=None, password=None, token=None, session=None, timeo |
92 | 92 | self._session = session or requests.Session() |
93 | 93 | self._sonos_cache = [] |
94 | 94 | self._sonos_cache_timestamp = 0 |
| 95 | + self._base_headers = reset_base_headers() |
95 | 96 | data, initpath = self._signin(username, password, timeout) |
96 | 97 | super(MyPlexAccount, self).__init__(self, data, initpath) |
97 | 98 |
|
@@ -173,7 +174,7 @@ def devices(self): |
173 | 174 |
|
174 | 175 | def _headers(self, **kwargs): |
175 | 176 | """ Returns dict containing base headers for all requests to the server. """ |
176 | | - headers = BASE_HEADERS.copy() |
| 177 | + headers = self._base_headers.copy() |
177 | 178 | if self._token: |
178 | 179 | headers['X-Plex-Token'] = self._token |
179 | 180 | headers.update(kwargs) |
@@ -1150,6 +1151,7 @@ def __init__(self, session=None, requestTimeout=None, headers=None): |
1150 | 1151 | super(MyPlexPinLogin, self).__init__() |
1151 | 1152 | self._session = session or requests.Session() |
1152 | 1153 | self._requestTimeout = requestTimeout or TIMEOUT |
| 1154 | + self._base_headers = reset_base_headers() |
1153 | 1155 | self.headers = headers |
1154 | 1156 |
|
1155 | 1157 | self._loginTimeout = None |
@@ -1282,7 +1284,7 @@ def _pollLogin(self): |
1282 | 1284 |
|
1283 | 1285 | def _headers(self, **kwargs): |
1284 | 1286 | """ Returns dict containing base headers for all requests for pin login. """ |
1285 | | - headers = BASE_HEADERS.copy() |
| 1287 | + headers = self._base_headers.copy() |
1286 | 1288 | if self.headers: |
1287 | 1289 | headers.update(self.headers) |
1288 | 1290 | headers.update(kwargs) |
|
0 commit comments