Compare commits
2
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
a435a5281b | ||
|
|
a2eb04ceee |
@@ -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
|
||||||
|
|||||||
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
|
||||||
|
|||||||
@@ -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}"
|
||||||
|
|
||||||
|
|||||||
@@ -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,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
|
||||||
|
|||||||
@@ -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
|
|
||||||
|
|||||||
@@ -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())
|
|
||||||
|
|||||||
@@ -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)
|
||||||
|
|||||||
@@ -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")
|
|
||||||
|
|||||||
Reference in New Issue
Block a user