In [2]:
import requests, json, time

In [27]:
url = "http://test.ewetasker.cluster.gsi.dit.upm.es/controllers/eventsManager.php"
payload = {'user': 'admin','inputEvent':'@prefix rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#> . @prefix time: <http://www.w3.org/2006/time#> . time:Clock rdf:type time:inDateTime. time:Clock time:Date "06/06/2017". time:Clock time:Instant "12:00".'}
data_channels = requests.post(url, data=payload).json()
print(data_channels)


{'actions': [], 'success': 1}

In [12]:
url = "http://test.ewetasker.cluster.gsi.dit.upm.es/controllers/eventsManager.php"
payload = {'user': 'admin','inputEvent':'@prefix rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#> . @prefix ewe: <http://gsi.dit.upm.es/ontologies/ewe/ns/#>. @prefix ewe-time: <http://gsi.dit.upm.es/ontologies/ewe-time/ns/#>. ewe-time:Clock rdf:type ewe-time:InDateTime. ewe-time:Clock ewe:Date "06/06/2017". ewe-time:Clock ewe:Instant "12:00".'}        
data_channels = requests.post(url, data=payload).json()
print(data_channels)


{'success': 1, 'actions': [{'channel': 'PresenceSensor1497630254', 'action': 'PresenceDetectedAtDistance', 'parameter': ''}, {'channel': 'PresenceSensor1497630254', 'action': '', 'parameter': ''}, {'channel': 'PresenceSensor1497630254', 'action': '', 'parameter': ''}, {'channel': 'PresenceSensor1497630254', 'action': 'PresenceDetectedAtDistance', 'parameter': ''}, {'channel': 'PresenceSensor1497630254', 'action': '', 'parameter': ''}, {'channel': 'PresenceSensor1497630254', 'action': '', 'parameter': ''}, {'channel': 'PresenceSensor1497630254', 'action': 'PresenceDetectedAtDistance', 'parameter': ''}, {'channel': 'PresenceSensor1497630254', 'action': '', 'parameter': ''}, {'channel': 'PresenceSensor1497630254', 'action': '', 'parameter': ''}, {'channel': 'PresenceSensor1497630254', 'action': 'PresenceDetectedAtDistance', 'parameter': ''}, {'channel': 'PresenceSensor1497630254', 'action': '', 'parameter': ''}, {'channel': 'PresenceSensor1497630254', 'action': '', 'parameter': ''}, {'channel': 'Toast', 'action': 'Show', 'parameter': 'prueba clock'}]}

In [3]:
url = "http://test.ewetasker.cluster.gsi.dit.upm.es/controllers/eventsManager.php"
payload = {"user": "enrique","inputEvent":"@prefix rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>. @prefix ewe: <http://gsi.dit.upm.es/ontologies/ewe/ns/#>. @prefix ewe-presence: <http://gsi.dit.upm.es/ontologies/ewe-connected-home-presence/ns/#>.  ewe-presence:PresenceSensor rdf:type ewe-presence:PresenceDetectedAtDistance. ewe-presence:PresenceSensor ewe:sensorID '64198'. ewe-presence:PresenceSensor ewe:distance 0.5."}
data_channels = requests.post(url, data=payload).json()
print(data_channels)


{'actions': [], 'success': 1}

In [13]:
url = "http://test.ewetasker.cluster.gsi.dit.upm.es/controllers/eventsManager.php"
payload = {"user": "admin","inputEvent":"@prefix rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>. @prefix ewe: <http://gsi.dit.upm.es/ontologies/ewe/ns/#>. @prefix ewe-presence: <http://gsi.dit.upm.es/ontologies/ewe-connected-home-presence/ns/#>.  ewe-presence:PresenceSensor rdf:type ewe-presence:PresenceDetectedAtDistance. ewe-presence:PresenceSensor ewe:sensorID '1234'. ewe-presence:PresenceSensor ewe:distance 0."}
data_channels = requests.post(url, data=payload).json()
print(data_channels)


{'success': 1, 'actions': [{'channel': 'HueLight', 'action': 'TurnOn', 'parameter': ''}, {'channel': 'RobotMip', 'action': 'ControlRobot', 'parameter': 'start'}]}

In [16]:
url = "http://test.ewetasker.cluster.gsi.dit.upm.es/controllers/eventsManager.php"
payload = {"user": "enrique","inputEvent":"@prefix rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>. @prefix ewe: <http://gsi.dit.upm.es/ontologies/ewe/ns/#>. @prefix ewe-presence: <http://gsi.dit.upm.es/ontologies/ewe-connected-home-presence/ns/#>.  ewe-presence:PresenceSensor rdf:type ewe-presence:PresenceDetectedAtDistance. ewe-presence:PresenceSensor ewe:sensorID '1'. ewe-presence:PresenceSensor ewe:distance 0.5."}
data_channels = requests.post(url, data=payload).json()
print(data_channels)


{'actions': [{'parameter': '', 'action': 'TurnOn', 'channel': 'HueLight'}, {'parameter': 'welcome_gsi', 'action': 'PlayVideo', 'channel': 'Chromecast'}, {'parameter': 'go_back', 'action': 'ControlRobot', 'channel': 'RobotMip'}], 'success': 1}

In [21]:
url = "http://localhost:8080/mobileConnectionHelper.php"
payload={}
payload["command"]="createRuleParams"
payload["rule_title"]="light automation"
payload["rule_channel_one"]="presence"
payload["rule_channel_two"]="hueLight"
payload["rule_event_title"]="Presence Detected At Distance Less Than"
payload["event_param_1"]="1234"
payload["event_param_2"]=2
payload["rule_action_title"]="Turn on"
payload["rule_description"]="Presence Light"
payload["rule_creator"]="admin"
payload["rule_place"]="Home"
print(payload)
data_channels = requests.post(url, data=payload)
print(data_channels)


{'rule_channel_one': 'presence', 'rule_channel_two': 'hueLight', 'rule_description': 'Presence Light', 'rule_action_title': 'Turn on', 'command': 'createRuleParams', 'rule_title': 'light automation', 'rule_creator': 'admin', 'event_param_2': 2, 'event_param_1': '1234', 'rule_place': 'Home', 'rule_event_title': 'Presence Detected At Distance Less Than'}
<Response [200]>

In [22]:
url = "http://localhost:8080/mobileConnectionHelper.php"
payload={}
payload["command"]="createRule"
payload["rule_title"]="prueba2"
payload["rule_channel_one"]="presence"
payload["rule_channel_two"]="telegram"
payload["rule_event_title"]="Presence Detected At Distance Greater Than"
payload["rule_action_title"]="Send message"
payload["rule_description"]="prueba2"
payload["rule_creator"]="admin"
payload["rule_place"]="Home"
infile = open('rule.txt', 'r')
payload["rule"]=infile.read()
infile.close()
print(payload)
data_channels = requests.post(url, data=payload)
print(data_channels)


{'rule_channel_one': 'presence', 'rule_channel_two': 'telegram', 'rule_description': 'prueba2', 'rule_action_title': 'Send message', 'command': 'createRule', 'rule_title': 'prueba2', 'rule_creator': 'admin', 'rule_place': 'Home', 'rule': '@prefix rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>.\n@prefix string: <http://www.w3.org/2000/10/swap/string#>.\n@prefix math: <http://www.w3.org/2000/10/swap/math#>.\n@prefix ewe: <http://gsi.dit.upm.es/ontologies/ewe/ns/#>.\n@prefix ewe-presence: <http://gsi.dit.upm.es/ontologies/ewe-connected-home-presence/ns/#>.\n@prefix ewe-telegram: <http://gsi.dit.upm.es/ontologies/ewe-telegram/ns/#>.\n@prefix ov: <http://vocab.org/open/#>.\n\n{\n\t?event0 rdf:type ewe-presence:PresenceDetectedAtDistance.\n\t?event0 ewe:sensorID ?sensorID0.\n\t?sensorID0 string:equalIgnoringCase "1234".\n\t?event0!ewe:distance math:greaterThan "2".\n}\n=>\n{\n\tewe-telegram:Telegram2 rdf:type ewe-telegram:SendMessage;\n\tov:message "Prueba Telegram".\n}.\n\n', 'rule_event_title': 'Presence Detected At Distance Greater Than'}
<Response [200]>

In [6]:
url = "http://localhost:3000/actionTrigger.php"
payload = {'parameter': '', 'channel': 'HueLight', 'action': 'TurnOff'}
data_channels = requests.post(url, data=payload)
print(data_channels.text)




In [ ]:
payload["rule"]="@prefix rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>. @prefix string: <http://www.w3.org/2000/10/swap/string#>. @prefix math: <http://www.w3.org/2000/10/swap/math#>. @prefix ewe: <http://gsi.dit.upm.es/ontologies/ewe/ns/#>. @prefix ewe-presence: <http://gsi.dit.upm.es/ontologies/ewe-connected-home-presence/ns/#>. @prefix ewe-telegram: <http://gsi.dit.upm.es/ontologies/ewe-telegram/ns/#>. @prefix ov: <http://vocab.org/open/#>. { ?event0 rdf:type ewe-presence:PresenceDetectedAtDistance. ?event0 ewe:sensorID ?sensorID0. ?sensorID0 string:equalIgnoringCase '1234'. ?event0!ewe:distance math:lessThan '2'. } => { ewe-telegram:Telegram2 rdf:type ewe-telegram:SendMessage; ov:message 'Prueba Telegram'. }."

In [4]:
url = "http://localhost:8080/controllers/eventsManager.php"
payload = {"user": "admin","inputEvent":"@prefix rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#> . @prefix string: <http://www.w3.org/2000/10/swap/string#>. @prefix math: <http://www.w3.org/2000/10/swap/math#>. @prefix rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#> . @prefix ewe: <http://gsi.dit.upm.es/ontologies/ewe/ns/#> . @prefix ewe-time: <http://gsi.dit.upm.es/ontologies/ewe-time/ns/#> . ewe-time:TimeHasCome rdf:type ewe-time:TimeHasCome. ewe-time:TimeHasCome ewe-time:Hour '15:00'."}
data_channels = requests.post(url, data=payload).json()
print(data_channels)


---------------------------------------------------------------------------
ConnectionRefusedError                    Traceback (most recent call last)
/usr/local/lib/python3.5/dist-packages/requests/packages/urllib3/connection.py in _new_conn(self)
    140             conn = connection.create_connection(
--> 141                 (self.host, self.port), self.timeout, **extra_kw)
    142 

/usr/local/lib/python3.5/dist-packages/requests/packages/urllib3/util/connection.py in create_connection(address, timeout, source_address, socket_options)
     82     if err is not None:
---> 83         raise err
     84 

/usr/local/lib/python3.5/dist-packages/requests/packages/urllib3/util/connection.py in create_connection(address, timeout, source_address, socket_options)
     72                 sock.bind(source_address)
---> 73             sock.connect(sa)
     74             return sock

ConnectionRefusedError: [Errno 111] Connection refused

During handling of the above exception, another exception occurred:

NewConnectionError                        Traceback (most recent call last)
/usr/local/lib/python3.5/dist-packages/requests/packages/urllib3/connectionpool.py in urlopen(self, method, url, body, headers, retries, redirect, assert_same_host, timeout, pool_timeout, release_conn, chunked, body_pos, **response_kw)
    599                                                   body=body, headers=headers,
--> 600                                                   chunked=chunked)
    601 

/usr/local/lib/python3.5/dist-packages/requests/packages/urllib3/connectionpool.py in _make_request(self, conn, method, url, timeout, chunked, **httplib_request_kw)
    355         else:
--> 356             conn.request(method, url, **httplib_request_kw)
    357 

/usr/lib/python3.5/http/client.py in request(self, method, url, body, headers)
   1105         """Send a complete request to the server."""
-> 1106         self._send_request(method, url, body, headers)
   1107 

/usr/lib/python3.5/http/client.py in _send_request(self, method, url, body, headers)
   1150             body = _encode(body, 'body')
-> 1151         self.endheaders(body)
   1152 

/usr/lib/python3.5/http/client.py in endheaders(self, message_body)
   1101             raise CannotSendHeader()
-> 1102         self._send_output(message_body)
   1103 

/usr/lib/python3.5/http/client.py in _send_output(self, message_body)
    933 
--> 934         self.send(msg)
    935         if message_body is not None:

/usr/lib/python3.5/http/client.py in send(self, data)
    876             if self.auto_open:
--> 877                 self.connect()
    878             else:

/usr/local/lib/python3.5/dist-packages/requests/packages/urllib3/connection.py in connect(self)
    165     def connect(self):
--> 166         conn = self._new_conn()
    167         self._prepare_conn(conn)

/usr/local/lib/python3.5/dist-packages/requests/packages/urllib3/connection.py in _new_conn(self)
    149             raise NewConnectionError(
--> 150                 self, "Failed to establish a new connection: %s" % e)
    151 

NewConnectionError: <requests.packages.urllib3.connection.HTTPConnection object at 0x7f3cd36dfeb8>: Failed to establish a new connection: [Errno 111] Connection refused

During handling of the above exception, another exception occurred:

MaxRetryError                             Traceback (most recent call last)
/usr/local/lib/python3.5/dist-packages/requests/adapters.py in send(self, request, stream, timeout, verify, cert, proxies)
    422                     retries=self.max_retries,
--> 423                     timeout=timeout
    424                 )

/usr/local/lib/python3.5/dist-packages/requests/packages/urllib3/connectionpool.py in urlopen(self, method, url, body, headers, retries, redirect, assert_same_host, timeout, pool_timeout, release_conn, chunked, body_pos, **response_kw)
    648             retries = retries.increment(method, url, error=e, _pool=self,
--> 649                                         _stacktrace=sys.exc_info()[2])
    650             retries.sleep()

/usr/local/lib/python3.5/dist-packages/requests/packages/urllib3/util/retry.py in increment(self, method, url, response, error, _pool, _stacktrace)
    375         if new_retry.is_exhausted():
--> 376             raise MaxRetryError(_pool, url, error or ResponseError(cause))
    377 

MaxRetryError: HTTPConnectionPool(host='localhost', port=8080): Max retries exceeded with url: /controllers/eventsManager.php (Caused by NewConnectionError('<requests.packages.urllib3.connection.HTTPConnection object at 0x7f3cd36dfeb8>: Failed to establish a new connection: [Errno 111] Connection refused',))

During handling of the above exception, another exception occurred:

ConnectionError                           Traceback (most recent call last)
<ipython-input-4-eba7a67a659c> in <module>()
      1 url = "http://localhost:8080/controllers/eventsManager.php"
      2 payload = {"user": "admin","inputEvent":"@prefix rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#> . @prefix string: <http://www.w3.org/2000/10/swap/string#>. @prefix math: <http://www.w3.org/2000/10/swap/math#>. @prefix rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#> . @prefix ewe: <http://gsi.dit.upm.es/ontologies/ewe/ns/#> . @prefix ewe-time: <http://gsi.dit.upm.es/ontologies/ewe-time/ns/#> . ewe-time:TimeHasCome rdf:type ewe-time:TimeHasCome. ewe-time:TimeHasCome ewe-time:Hour '15:00'."}
----> 3 data_channels = requests.post(url, data=payload).json()
      4 print(data_channels)

/usr/local/lib/python3.5/dist-packages/requests/api.py in post(url, data, json, **kwargs)
    108     """
    109 
--> 110     return request('post', url, data=data, json=json, **kwargs)
    111 
    112 

/usr/local/lib/python3.5/dist-packages/requests/api.py in request(method, url, **kwargs)
     54     # cases, and look like a memory leak in others.
     55     with sessions.Session() as session:
---> 56         return session.request(method=method, url=url, **kwargs)
     57 
     58 

/usr/local/lib/python3.5/dist-packages/requests/sessions.py in request(self, method, url, params, data, headers, cookies, files, auth, timeout, allow_redirects, proxies, hooks, stream, verify, cert, json)
    486         }
    487         send_kwargs.update(settings)
--> 488         resp = self.send(prep, **send_kwargs)
    489 
    490         return resp

/usr/local/lib/python3.5/dist-packages/requests/sessions.py in send(self, request, **kwargs)
    607 
    608         # Send the request
--> 609         r = adapter.send(request, **kwargs)
    610 
    611         # Total elapsed time of the request (approximately)

/usr/local/lib/python3.5/dist-packages/requests/adapters.py in send(self, request, stream, timeout, verify, cert, proxies)
    485                 raise ProxyError(e, request=request)
    486 
--> 487             raise ConnectionError(e, request=request)
    488 
    489         except ClosedPoolError as e:

ConnectionError: HTTPConnectionPool(host='localhost', port=8080): Max retries exceeded with url: /controllers/eventsManager.php (Caused by NewConnectionError('<requests.packages.urllib3.connection.HTTPConnection object at 0x7f3cd36dfeb8>: Failed to establish a new connection: [Errno 111] Connection refused',))

In [8]:
url = "http://test.ewetasker.cluster.gsi.dit.upm.es/controllers/actionTrigger.php"
payload = {'parameter': '', 'channel': 'HueLight', 'action': 'TurnOn'}
data_channels = requests.post(url, data=payload)
print(data_channels)


<Response [200]>

In [14]:
url = "http://irouter.gsi.dit.upm.es/actionTrigger.php"
payload = {'parameter': 'prueba', 'channel': 'apiai', 'action': 'Send event'}
data_channels = requests.post(url, data=payload)
print(data_channels.text)


ArrayapiaiSend eventevento enviadoevento enviadoDENTRO DEL PERFORMER{
  "id": "3dec7db4-7be3-430a-801e-e509014424a0",
  "timestamp": "2017-05-31T15:05:09.686Z",
  "lang": "en",
  "result": {
    "source": "agent",
    "resolvedQuery": "event_reminder",
    "action": "",
    "actionIncomplete": false,
    "parameters": {
      "reminder_text": "prueba"
    },
    "contexts": [],
    "metadata": {
      "intentId": "e1b905d3-6f31-4f5d-ad1a-e454247623d0",
      "webhookUsed": "false",
      "webhookForSlotFillingUsed": "false",
      "intentName": "event.reminder"
    },
    "fulfillment": {
      "speech": "You asked me to remind you: prueba",
      "messages": [
        {
          "type": 0,
          "speech": "You asked me to remind you: prueba"
        }
      ]
    },
    "score": 1.0
  },
  "status": {
    "code": 200,
    "errorType": "success"
  },
  "sessionId": "62f53181-2f82-4967-a8ca-fec05c13c12c"
}

In [31]:
url = "http://irouter.gsi.dit.upm.es/actionTrigger.php"
payload = {'parameter': 'fire', 'channel': 'Chromecast', 'action': 'PlayVideo'}
data_channels = requests.post(url, data=payload)
print(data_channels.text)


ArrayChromecastPlayVideo

In [14]:
url = "http://irouter.cluster.gsi.dit.upm.es/actionTrigger.php"
payload = {'parameter': 'start', 'channel': 'RobotMip', 'action': 'ControlRobot'}
req=requests.post(url, data=payload)
print(req.text)




In [13]:
t=time.strftime("%X")
t=t[:5]
d=time.strftime("%x")+" "+t
print(t)
print(d)


19:31
06/14/17 19:31

In [ ]: