1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
import asyncio
from aiohttp import ClientResponse
from unittest.mock import Mock
from aiopvapi.helpers.aiorequest import AioRequest, PvApiResponseStatusError
from aiopvapi.resources.scene import Scene
from tests.fake_server import FAKE_BASE_URL
from tests.test_apiresource import TestApiResource
from tests.test_scene_members import AsyncMock
SCENE_RAW_DATA = {
"roomId": 26756,
"name": "RGluaW5nIFZhbmVzIE9wZW4=", # "Dining Vanes Open"
"colorId": 0,
"iconId": 0,
"id": 37217,
"order": 1,
}
class TestScene(TestApiResource):
def get_resource_raw_data(self):
return SCENE_RAW_DATA
def get_resource_uri(self):
return "http://{}/api/scenes/37217".format(FAKE_BASE_URL)
def get_resource(self):
_request = Mock(spec=AioRequest)
_request.hub_ip = FAKE_BASE_URL
_request.api_version = 2
_request.api_path = "api"
return Scene(SCENE_RAW_DATA, _request)
def test_name_property(self):
# No name_unicode, although name is base64 encoded
# thus base64 decoded is returned
self.assertEqual("Dining Vanes Open", self.resource.name)
def test_room_id_property(self):
self.assertEqual(26756, self.resource.room_id)
def test_full_path(self):
self.assertEqual(
self.resource.base_path,
"http://{}/api/scenes".format(FAKE_BASE_URL),
)
def test_activate_200(self):
"""Test scene activation"""
async def go():
await self.start_fake_server()
scene = self.get_resource()
scene.request.get = AsyncMock(return_value={'shadeIds': [10]})
resp = await scene.activate()
return resp
resp = self.loop.run_until_complete(go())
self.assertEqual(resp[0], 10)
def test_activate_404(self):
"""Test scene activation"""
async def go():
await self.start_fake_server()
# scene = self.get_resource()
loop = asyncio.get_event_loop()
request = AioRequest(FAKE_BASE_URL, loop, api_version=2)
response = Mock(spec=ClientResponse)
response.status = 404
response.release = AsyncMock(return_value=None)
request.websession.get = AsyncMock(return_value=response)
scene = Scene(SCENE_RAW_DATA, request)
scene._resource_path += "1"
resp = await scene.activate()
return resp
with self.assertRaises(PvApiResponseStatusError):
resp = self.loop.run_until_complete(go())
# @aioresponses()
# def test_activate_200(self, mocked):
# mocked.get('http://127.0.0.1/api/scenes',
# body='"ok"',
# status=200,
# headers={'content-type': 'application/json'})
# resp = self.loop.run_until_complete(self.resource.activate())
# self.assertEqual('ok', resp)
# request = mocked.requests[('GET', 'http://127.0.0.1/api/scenes')][-1]
# self.assertEqual({'sceneId': 37217}, request.kwargs['params'])
#
# @aioresponses()
# def test_activate_201(self, mocked):
# """Test scene activation with wrong status."""
# mocked.get('http://127.0.0.1/api/scenes',
# body='"ok"',
# status=201,
# headers={'content-type': 'application/json'})
# with self.assertRaises(PvApiResponseStatusError):
# resp = self.loop.run_until_complete(self.resource.activate())
|
