python/chickenhouse
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

project: reorder

Browse Source 
Signed-off-by: Thomas Klaehn <thomas.klaehn@u-blox.com>
This commit is contained in:
Thomas Klaehn 2017-03-30 15:15:00 +02:00
parent e541023bba
commit 4646c7d7a6
14 changed files with 24 additions and 125 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
.gitlab-ci.yml
View File

@ -9,8 +9,8 @@ stages:
tests:
stage: test
script:
- "python scripts/pylint_wrapper.py -s source -s tests"
- "nosetests --with-coverage --cover-package=source --cover-xml"
- "python scripts/pylint_wrapper.py -s gate_guard -s tests"
- "nosetests --with-coverage --cover-package=gate_guard --cover-xml"
- "nosetests --with-xunit tests/unittests/"
- "sonar-runner"

1
.pydevproject
View File

@ -1,7 +1,6 @@
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<?eclipse-pydev version="1.0"?><pydev_project>
<pydev_pathproperty name="org.python.pydev.PROJECT_SOURCE_PATH">
<path>/${PROJECT_DIR_NAME}/source</path>
<path>/${PROJECT_DIR_NAME}/scripts</path>
<path>/${PROJECT_DIR_NAME}/tests</path>
</pydev_pathproperty>

2
source/gate_guard.py → gate_guard/__init__.py
View File

@ -3,8 +3,6 @@ Created on Dec 19, 2016
@author: klaehn
'''
import sys
sys.path.append('source/')
import time
import gate

5
source/data_buffer/__init__.py → gate_guard/data_buffer.py
View File

@ -1,3 +1,8 @@
'''
Created on Mar 30, 2017
@author: tkla
'''
class DataBuffer(object):
def __init__(self, length):

5
source/engine/__init__.py → gate_guard/engine.py
View File

@ -1,3 +1,8 @@
'''
Created on Mar 30, 2017
@author: tkla
'''
import gpio
class Engine(object):

7
source/gate/__init__.py → gate_guard/gate.py
View File

@ -3,14 +3,13 @@ Created on Dec 19, 2016
@author: klaehn
'''
import sys
sys.path.append('source/')
import time
import mqtt
import data_buffer
import light_sensor
import engine
from power_sensor import PowerSensor
import power_sensor
from numpy.core.umath import power
STATE_INIT = "init"
STATE_OPENED = "open"
@ -54,7 +53,7 @@ class Gate(object):
self.__light_data = data_buffer.DataBuffer(LIGHT_CONSECUTIVE_READS)
self.__comserver = mqtt.Mqtt(MQTT_HOST)
self.__engine = engine.Engine(gpio_1=13, gpio_2=19)
self.__power_sensor = PowerSensor(POWER_SENSOR_I2C_BUS, \
self.__power_sensor = power_sensor.PowerSensor(POWER_SENSOR_I2C_BUS, \
POWER_SENSOR_I2C_ADDRESS)
self.__power_data = data_buffer.DataBuffer(POWER_CONSECUTIVE_READS)
self.__gate_move_timeout = 0

5
source/light_sensor/__init__.py → gate_guard/light_sensor.py
View File

@ -1,3 +1,8 @@
'''
Created on Mar 30, 2017
@author: tkla
'''
import smbus
class LightSensor(object):

1
source/power_sensor/__init__.py → gate_guard/power_sensor.py
View File

@ -3,7 +3,6 @@ Created on Dec 19, 2016
@author: klaehn
'''
import smbus
class PowerSensor(object):

2
sonar-project.properties
View File

@ -2,7 +2,7 @@ sonar.projectKey=chickenhouse:python
sonar.projectName=chickenhouse:python
sonar.projectVersion=1.0
sonar.host.url=http://sonarqube:9000
sonar.sources=source
sonar.sources=gate_guard
sonar.tests=tests/unittests
sonar.language=py
sonar.sourceEncoding=UTF-8

0
source/__init__.py
View File

45
source/close.py
View File

@ -1,45 +0,0 @@
'''
Created on Dec 23, 2016
@author: klaehn
'''
import sys
sys.path.append('source/')
import time
import data_buffer
import engine
import power_sensor
POWER_SENSOR_I2C_BUS = 1
POWER_SENSOR_I2C_ADDRESS = 0x40
CONSECUTIVE_POWER_READS = 1000
MAX_ENGINE_POWER = {"up":330, "down":280}
def main(argv):
__engine = engine.Engine(gpio_1=13, gpio_2=19)
__power_sensor = power_sensor.PowerSensor(POWER_SENSOR_I2C_BUS, POWER_SENSOR_I2C_ADDRESS)
__power_data = data_buffer.DataBuffer(CONSECUTIVE_POWER_READS)
__engine.down()
try:
while True:
rd = __power_sensor.power_mw()
__power_data.push(rd)
average = __power_data.average()
print str(time.time()) + " " + str(rd)
if average != None:
if average > MAX_ENGINE_POWER["down"]:
__engine.stop()
# print "Gate successfully closed"
return 0
except KeyboardInterrupt:
__engine.stop()
# print "Closing procedure interrupted."
return 1
if __name__ == "__main__":
sys.exit(main(sys.argv[1:]))

19
source/light.py
View File

@ -1,19 +0,0 @@
'''
Created on Dec 24, 2016
@author: tkl
'''
import sys
sys.path.append('source/')
import time
import light_sensor
import mqtt
def main():
conn = mqtt.Mqtt(hostname='proxy')
light = light_sensor.LightSensor(1, 0x23)
conn.transmit("outdoor/chickenhouse/sensors/light", \
str(int(time.time())) + " " + str(light.read()))
if __name__ == "__main__":
sys.exit(main())

45
source/open.py
View File

@ -1,45 +0,0 @@
'''
Created on Dec 23, 2016
@author: klaehn
'''
import sys
sys.path.append('source/')
import time
import data_buffer
import engine
import power_sensor
POWER_SENSOR_I2C_BUS = 1
POWER_SENSOR_I2C_ADDRESS = 0x40
CONSECUTIVE_POWER_READS = 1000
MAX_ENGINE_POWER = {"up":330, "down":290}
def main(argv):
__engine = engine.Engine(gpio_1=13, gpio_2=19)
__power_sensor = power_sensor.PowerSensor(POWER_SENSOR_I2C_BUS, POWER_SENSOR_I2C_ADDRESS)
power_data = data_buffer.DataBuffer(CONSECUTIVE_POWER_READS)
__engine.up()
try:
while True:
rd = __power_sensor.power_mw()
power_data.push(rd)
average = power_data.average()
print str(time.time()) + " " + str(rd)
if average != None:
if average > MAX_ENGINE_POWER["up"]:
__engine.stop()
# print "Gate successfully opened"
return 0
except KeyboardInterrupt:
__engine.stop()
print "Closing procedure interrupted."
return 1
if __name__ == "__main__":
sys.exit(main(sys.argv[1:]))

8
tests/unittests/test_data_buffer.py
View File

@ -3,24 +3,22 @@ Created on Dec 19, 2016
@author: klaehn
'''
import sys
sys.path.append('source/')
import unittest
import random
import data_buffer
import gate_guard.data_buffer
class Test(unittest.TestCase):
def test_zero_space(self):
dut = data_buffer.DataBuffer(0)
dut = gate_guard.data_buffer.DataBuffer(0)
result = dut.push(10)
self.assertFalse(result, "test_zero_space - exp: False res: True")
def test_max_data(self):
buffer_size = 10
dut = data_buffer.DataBuffer(buffer_size)
dut = gate_guard.data_buffer.DataBuffer(buffer_size)
for _ in range(11):
dut.push(random.random())
result = dut.length()