|
8 | 8 |
|
9 | 9 | import requests |
10 | 10 | from plexapi import (BASE_HEADERS, CONFIG, TIMEOUT, X_PLEX_CONTAINER_SIZE, |
11 | | - X_PLEX_ENABLE_FAST_CONNECT, X_PLEX_IDENTIFIER, log, logfilter, utils) |
| 11 | + X_PLEX_ENABLE_FAST_CONNECT, X_PLEX_IDENTIFIER, log, |
| 12 | + logfilter, reset_base_headers, utils) |
12 | 13 | from plexapi.base import PlexObject |
13 | 14 | from plexapi.client import PlexClient |
14 | 15 | from plexapi.exceptions import BadRequest, NotFound, Unauthorized |
@@ -94,6 +95,7 @@ def __init__(self, username=None, password=None, token=None, session=None, timeo |
94 | 95 | self._session = session or requests.Session() |
95 | 96 | self._sonos_cache = [] |
96 | 97 | self._sonos_cache_timestamp = 0 |
| 98 | + self._base_headers = reset_base_headers() |
97 | 99 | data, initpath = self._signin(username, password, code, timeout) |
98 | 100 | super(MyPlexAccount, self).__init__(self, data, initpath) |
99 | 101 |
|
@@ -168,7 +170,7 @@ def devices(self): |
168 | 170 |
|
169 | 171 | def _headers(self, **kwargs): |
170 | 172 | """ Returns dict containing base headers for all requests to the server. """ |
171 | | - headers = BASE_HEADERS.copy() |
| 173 | + headers = self._base_headers.copy() |
172 | 174 | if self._token: |
173 | 175 | headers['X-Plex-Token'] = self._token |
174 | 176 | headers.update(kwargs) |
@@ -1539,6 +1541,7 @@ def __init__(self, session=None, requestTimeout=None, headers=None, oauth=False) |
1539 | 1541 | super(MyPlexPinLogin, self).__init__() |
1540 | 1542 | self._session = session or requests.Session() |
1541 | 1543 | self._requestTimeout = requestTimeout or TIMEOUT |
| 1544 | + self._base_headers = reset_base_headers() |
1542 | 1545 | self.headers = headers |
1543 | 1546 |
|
1544 | 1547 | self._oauth = oauth |
@@ -1706,7 +1709,7 @@ def _pollLogin(self): |
1706 | 1709 |
|
1707 | 1710 | def _headers(self, **kwargs): |
1708 | 1711 | """ Returns dict containing base headers for all requests for pin login. """ |
1709 | | - headers = BASE_HEADERS.copy() |
| 1712 | + headers = self._base_headers.copy() |
1710 | 1713 | if self.headers: |
1711 | 1714 | headers.update(self.headers) |
1712 | 1715 | headers.update(kwargs) |
|
0 commit comments