Compare commits

..
13 changed files with 58 additions and 94 deletions
+3 -2
View File
@@ -33,9 +33,10 @@ jobs:
run: | run: |
tox -r -e cov tox -r -e cov
- name: Codecov - name: Codecov
uses: codecov/codecov-action@v1 uses: codecov/codecov-action@v1.0.6
env:
CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}
with: with:
token: ${{ secrets.CODECOV_TOKEN }}
flags: unittests flags: unittests
file: ./coverage.xml file: ./coverage.xml
name: blinkpy name: blinkpy
+2 -2
View File
@@ -8,12 +8,12 @@ repos:
- --quiet - --quiet
files: ^((blinkpy|tests)/.+)?[^/]+\.py$ files: ^((blinkpy|tests)/.+)?[^/]+\.py$
- repo: https://gitlab.com/pycqa/flake8 - repo: https://gitlab.com/pycqa/flake8
rev: 3.8.3 rev: 3.8.2
hooks: hooks:
- id: flake8 - id: flake8
additional_dependencies: additional_dependencies:
- flake8-docstrings==1.5.0 - flake8-docstrings==1.5.0
- pydocstyle==5.1.1 - pydocstyle==5.0.2
files: ^(blinkpy|tests)/.+\.py$ files: ^(blinkpy|tests)/.+\.py$
- repo: https://github.com/Lucas-C/pre-commit-hooks-markup - repo: https://github.com/Lucas-C/pre-commit-hooks-markup
rev: v1.0.0 rev: v1.0.0
-25
View File
@@ -4,31 +4,6 @@ Changelog
A list of changes between each release A list of changes between each release
0.16.4 (2020-11-22)
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
**Bugfixes:**
- Updated liveview endpoint (`#389 <https://github.com/fronzbot/blinkpy/pull/389>`__)
- Fixed mini thumbnail not updating (`#388 <https://github.com/fronzbot/blinkpy/pull/388>`__)
- Add exception catch to prevent NoneType error on refresh, added test to check behavior as well (`#401 <https://github.com/fronzbot/blinkpy/pull/401>`__)
- Unrelated: had to add two force methods to refresh for testing purposes. Should not change normal usage.
- Fix malformed stream url (`#395 <https://github.com/fronzbot/blinkpy/pull/395>`__)
**All:**
- Moved testtools to requirements_test.txt (`#387 <https://github.com/fronzbot/blinkpy/pull/387>`__)
- Bumped pytest to 6.1.1
- Bumped flake8 to 3.8.4
- Fixed README spelling ((`#381 <https://github.com/fronzbot/blinkpy/pull/381>`__) via @rohitsud)
- Bumped pygments to 2.7.1
- Bumped coverage to 5.3
- Bumped pydocstyle to 5.1.1
- Bumped pre-commit to 2.7.1
- Bumped pylint to 2.6.0
- Bumped pytest-cov to 2.10.1
0.16.3 (2020-08-02) 0.16.3 (2020-08-02)
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+3 -1
View File
@@ -244,7 +244,9 @@ def request_camera_liveview(blink, network, camera_id):
:param network: Sync module network id. :param network: Sync module network id.
:param camera_id: Camera ID of camera to request liveview from. :param camera_id: Camera ID of camera to request liveview from.
""" """
url = f"{blink.urls.base_url}/api/v5/accounts/{blink.account_id}/networks/{network}/cameras/{camera_id}/liveview" url = (
f"{blink.urls.base_url}/api/v3/networks/{network}/cameras/{camera_id}/liveview"
)
return http_post(blink, url) return http_post(blink, url)
+5 -7
View File
@@ -76,22 +76,20 @@ class Blink:
self.no_owls = no_owls self.no_owls = no_owls
@util.Throttle(seconds=MIN_THROTTLE_TIME) @util.Throttle(seconds=MIN_THROTTLE_TIME)
def refresh(self, force=False, force_cache=False): def refresh(self, force=False):
""" """
Perform a system refresh. Perform a system refresh.
:param force: Used to override throttle, resets refresh :param force: Force an update of the camera data
:param force_cache: Used to force update without overriding throttle
""" """
if self.check_if_ok_to_update() or force or force_cache: if self.check_if_ok_to_update() or force:
if not self.available: if not self.available:
self.setup_post_verify() self.setup_post_verify()
self.get_homescreen()
for sync_name, sync_module in self.sync.items(): for sync_name, sync_module in self.sync.items():
_LOGGER.debug("Attempting refresh of sync %s", sync_name) _LOGGER.debug("Attempting refresh of sync %s", sync_name)
sync_module.refresh(force_cache=(force or force_cache)) sync_module.refresh(force_cache=force)
if not force_cache: if not force:
# Prevents rapid clearing of motion detect property # Prevents rapid clearing of motion detect property
self.last_refresh = int(time.time()) self.last_refresh = int(time.time())
return True return True
+17 -15
View File
@@ -98,15 +98,6 @@ class BlinkCamera:
self.sync.blink, self.network_id, self.camera_id self.sync.blink, self.network_id, self.camera_id
) )
def get_media(self, media_type="image"):
"""Download media (image or video)."""
url = self.thumbnail
if media_type.lower() == "video":
url = self.clip
return api.http_get(
self.sync.blink, url=url, stream=True, json=False, timeout=TIMEOUT_MEDIA,
)
def snap_picture(self): def snap_picture(self):
"""Take a picture with camera to create a new thumbnail.""" """Take a picture with camera to create a new thumbnail."""
return api.request_new_image(self.sync.blink, self.network_id, self.camera_id) return api.request_new_image(self.sync.blink, self.network_id, self.camera_id)
@@ -189,10 +180,21 @@ class BlinkCamera:
update_cached_video = True update_cached_video = True
if new_thumbnail is not None and (update_cached_image or force_cache): if new_thumbnail is not None and (update_cached_image or force_cache):
self._cached_image = self.get_media() self._cached_image = api.http_get(
self.sync.blink,
url=self.thumbnail,
stream=True,
json=False,
timeout=TIMEOUT_MEDIA,
)
if clip_addr is not None and (update_cached_video or force_cache): if clip_addr is not None and (update_cached_video or force_cache):
self._cached_video = self.get_media(media_type="video") self._cached_video = api.http_get(
self.sync.blink,
url=self.clip,
stream=True,
json=False,
timeout=TIMEOUT_MEDIA,
)
def get_liveview(self): def get_liveview(self):
"""Get livewview rtsps link.""" """Get livewview rtsps link."""
@@ -208,7 +210,7 @@ class BlinkCamera:
:param path: Path to write file :param path: Path to write file
""" """
_LOGGER.debug("Writing image from %s to %s", self.name, path) _LOGGER.debug("Writing image from %s to %s", self.name, path)
response = self.get_media() response = self._cached_image
if response.status_code == 200: if response.status_code == 200:
with open(path, "wb") as imgfile: with open(path, "wb") as imgfile:
copyfileobj(response.raw, imgfile) copyfileobj(response.raw, imgfile)
@@ -224,7 +226,7 @@ class BlinkCamera:
:param path: Path to write file :param path: Path to write file
""" """
_LOGGER.debug("Writing video from %s to %s", self.name, path) _LOGGER.debug("Writing video from %s to %s", self.name, path)
response = self.get_media(media_type="video") response = self._cached_video
if response is None: if response is None:
_LOGGER.error("No saved video exist for %s.", self.name) _LOGGER.error("No saved video exist for %s.", self.name)
return return
@@ -266,6 +268,6 @@ class BlinkCameraMini(BlinkCamera):
response = api.http_post(self.sync.blink, url) response = api.http_post(self.sync.blink, url)
server = response["server"] server = response["server"]
server_split = server.split(":") server_split = server.split(":")
server_split[0] = "rtsps:" server_split[0] = "rtsps"
link = "".join(server_split) link = "".join(server_split)
return link return link
+2 -2
View File
@@ -3,8 +3,8 @@
import os import os
MAJOR_VERSION = 0 MAJOR_VERSION = 0
MINOR_VERSION = 16 MINOR_VERSION = 17
PATCH_VERSION = 4 PATCH_VERSION = "0.dev0"
__version__ = f"{MAJOR_VERSION}.{MINOR_VERSION}.{PATCH_VERSION}" __version__ = f"{MAJOR_VERSION}.{MINOR_VERSION}.{PATCH_VERSION}"
+2 -2
View File
@@ -145,7 +145,7 @@ class BlinkSyncModule:
for owl in self.blink.homescreen["owls"]: for owl in self.blink.homescreen["owls"]:
if owl["name"] == name: if owl["name"] == name:
return owl return owl
except (TypeError, KeyError): except KeyError:
pass pass
return None return None
@@ -270,7 +270,7 @@ class BlinkOwl(BlinkSyncModule):
if owl["name"] == self.name: if owl["name"] == self.name:
self.status = owl["enabled"] self.status = owl["enabled"]
return owl return owl
except (TypeError, KeyError): except KeyError:
pass pass
return None return None
+1
View File
@@ -1,3 +1,4 @@
python-dateutil>=2.8.1 python-dateutil>=2.8.1
requests>=2.24.0 requests>=2.24.0
python-slugify>=4.0.1 python-slugify>=4.0.1
testtools>=2.4.0
+5 -6
View File
@@ -1,14 +1,13 @@
black==19.10b0 black==19.10b0
coverage==5.3 coverage==5.3
flake8==3.8.4 flake8==3.8.3
flake8-docstrings==1.5.0 flake8-docstrings==1.5.0
pre-commit==2.7.1 pre-commit==2.6.0
pylint==2.6.0 pylint==2.5.3
pydocstyle==5.1.1 pydocstyle==5.0.2
pytest==6.1.1 pytest==6.1.1
pytest-cov==2.10.1 pytest-cov==2.10.1
pytest-sugar==0.9.4 pytest-sugar==0.9.4
pytest-timeout==1.4.2 pytest-timeout==1.4.2
restructuredtext-lint==1.3.1 restructuredtext-lint==1.3.1
pygments==2.7.1 pygments==2.6.1
testtools>=2.4.0
+16 -23
View File
@@ -5,23 +5,29 @@ import logging
from blinkpy import blinkpy from blinkpy import blinkpy
from blinkpy.sync_module import BlinkSyncModule from blinkpy.sync_module import BlinkSyncModule
from blinkpy.camera import BlinkCamera
from blinkpy.helpers.util import get_time, BlinkURLHandler from blinkpy.helpers.util import get_time, BlinkURLHandler
class MockSyncModule(BlinkSyncModule): class MockSyncModule(BlinkSyncModule):
"""Mock blink sync module object.""" """Mock http requests from sync module."""
def get_network_info(self): def __init__(self, blink, header):
"""Mock network info method.""" """Create mock sync module instance."""
return True super().__init__(blink, header, network_id=None, camera_list=None)
self.blink = blink
self.header = header
self.return_value = None
self.return_value2 = None
def http_get(self, url, stream=False, json=True):
"""Mock get request."""
if stream and self.return_value2 is not None:
return self.return_value2
return self.return_value
class MockCamera(BlinkCamera): def http_post(self, url):
"""Mock blink camera object.""" """Mock post request."""
return self.return_value
def update(self, config, force_cache=False, **kwargs):
"""Mock camera update method."""
class TestBlinkFunctions(unittest.TestCase): class TestBlinkFunctions(unittest.TestCase):
@@ -115,16 +121,3 @@ class TestBlinkFunctions(unittest.TestCase):
with self.assertLogs() as dl_log: with self.assertLogs() as dl_log:
blink.download_videos("/tmp", camera="bar", stop=2) blink.download_videos("/tmp", camera="bar", stop=2)
self.assertEqual(dl_log.output, expected_log) self.assertEqual(dl_log.output, expected_log)
@mock.patch("blinkpy.blinkpy.api.request_network_update")
@mock.patch("blinkpy.auth.Auth.query")
def test_refresh(self, mock_req, mock_update):
"""Test ability to refresh system."""
mock_update.return_value = {"network": {"sync_module_error": False}}
mock_req.return_value = None
self.blink.last_refresh = 0
self.blink.available = True
self.blink.sync["foo"] = MockSyncModule(self.blink, "foo", 1, [])
self.blink.cameras = {"bar": MockCamera(self.blink.sync)}
self.blink.sync["foo"].cameras = self.blink.cameras
self.assertTrue(self.blink.refresh())
+2 -2
View File
@@ -68,8 +68,8 @@ class TestBlinkSetup(unittest.TestCase):
self.assertEqual(self.blink.last_refresh, None) self.assertEqual(self.blink.last_refresh, None)
with mock.patch( with mock.patch(
"blinkpy.sync_module.BlinkSyncModule.refresh", return_value=True "blinkpy.sync_module.BlinkSyncModule.refresh", return_value=True
), mock.patch("blinkpy.blinkpy.Blink.get_homescreen", return_value=True): ):
self.blink.refresh(force=True) self.blink.refresh()
self.assertEqual(self.blink.last_refresh, now) self.assertEqual(self.blink.last_refresh, now)
self.assertEqual(self.blink.check_if_ok_to_update(), False) self.assertEqual(self.blink.check_if_ok_to_update(), False)
-7
View File
@@ -176,10 +176,3 @@ class TestBlinkCameraSetup(unittest.TestCase):
attr = camera.attributes attr = camera.attributes
for key in attr: for key in attr:
self.assertEqual(attr[key], None) self.assertEqual(attr[key], None)
def test_camera_stream(self, mock_resp):
"""Test that camera stream returns correct url."""
mock_resp.return_value = {"server": "rtsps://foo.bar"}
mini_camera = BlinkCameraMini(self.blink.sync["test"])
self.assertEqual(self.camera.get_liveview(), "rtsps://foo.bar")
self.assertEqual(mini_camera.get_liveview(), "rtsps://foo.bar")