Skip to content
This repository has been archived by the owner on Feb 26, 2021. It is now read-only.

Add template props file. Add port variable. #7

Merged
merged 1 commit into from
Aug 27, 2020
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions .gitignore
Original file line number Diff line number Diff line change
@@ -1,3 +1,6 @@
# Config files
.env

# Sensor files
MQ7.h
MQ7.cpp
Expand Down
14 changes: 7 additions & 7 deletions server/routes/devices.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ class devices(object):

def __init__(self):
load_dotenv()
self.logger = logging.getLogger('prometo.device.devices')
self.logger = logging.getLogger('prometeo.device.devices')
self.logger.debug('creating an instance of devices')

def insert_device(self, sensorid, model, version):
Expand All @@ -25,15 +25,15 @@ def insert_device(self, sensorid, model, version):
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = 3306)
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()

cursor.callproc('sp_create_device', (sensorid, model, version))

data = cursor.fetchall()

if len(data[0][0]) is 0:
if len(data[0][0]) == 0:
con.commit()
return True
else:
Expand All @@ -53,15 +53,15 @@ def update_device(self, sensorid, model, version):
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = 3306)
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()

cursor.callproc('sp_update_device', (sensorid, model, version))

data = cursor.fetchall()

if len(data[0][0]) is 0:
if len(data[0][0]) == 0:
con.commit()
return True
else:
Expand All @@ -84,7 +84,7 @@ def get_device(self, sensorid):
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = 3306)
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()

Expand Down Expand Up @@ -116,7 +116,7 @@ def get_alldevices(self):
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = 3306)
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()

Expand Down
4 changes: 2 additions & 2 deletions server/routes/event_types.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ class eventTypes(object):

def __init__(self):
load_dotenv()
self.logger = logging.getLogger('prometo.eventTypes.event_Types')
self.logger = logging.getLogger('prometeo.eventTypes.event_Types')
self.logger.debug('creating an instance of eventTypes')

def get_alleventtypes(self):
Expand All @@ -21,7 +21,7 @@ def get_alleventtypes(self):
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = 3306)
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()
print("get_alleventTypes - llamada a sql")
Expand Down
24 changes: 12 additions & 12 deletions server/routes/events.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ class event(object):

def __init__(self):
load_dotenv()
self.logger = logging.getLogger('prometo.event.events')
self.logger = logging.getLogger('prometeo.event.events')
self.logger.debug('creating an instance of event')

def insert_event(self, data):
Expand All @@ -20,15 +20,15 @@ def insert_event(self, data):
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = 3306)
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()

cursor.callproc('sp_create_event', (data))

data = cursor.fetchall()

if len(data[0][0]) is 0:
if len(data[0][0]) == 0:
con.commit()
return True
else:
Expand All @@ -49,14 +49,14 @@ def update_event(self, data):
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = 3306)
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()
cursor.callproc('sp_update_event', (data))

data = cursor.fetchall()

if len(data[0][0]) is 0:
if len(data[0][0]) == 0:
con.commit()
return True
else:
Expand All @@ -76,7 +76,7 @@ def get_event(self, eventid):
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = 3306)
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()
print("get_event")
Expand Down Expand Up @@ -111,7 +111,7 @@ def get_allevents(self):
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = 3306)
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()

Expand All @@ -137,11 +137,11 @@ def get_allevents(self):
def get_event_firefighters_devices(self, eventid):
try:
conn = mariadb.connect(
user=os.getenv("MARIADB_USERNAME"),
password=os.getenv("MARIADB_PASSWORD"),
host=os.getenv("MARIADB_HOST"),
database="prometeo",
port=3306)
user = os.getenv("MARIADB_USERNAME"),
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()
print("get_event")
Expand Down
46 changes: 23 additions & 23 deletions server/routes/firefighters.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,27 +9,27 @@ class firefighters(object):

def __init__(self):
load_dotenv()
self.logger = logging.getLogger('prometo.firefighters.fire_fighters')
self.logger = logging.getLogger('prometeo.firefighters.fire_fighters')
self.logger.debug('creating an instance of firefighters')

def insert_firefighter(self, bomberoid, nombre, apellidos, email):


try:
conn = mariadb.connect(
user=os.getenv("MARIADB_USERNAME"),
password=os.getenv("MARIADB_PASSWORD"),
host=os.getenv("MARIADB_HOST"),
database="prometeo",
port=3306)
user = os.getenv("MARIADB_USERNAME"),
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()

cursor.callproc('sp_create_firefighter', (bomberoid, nombre, apellidos, email))

data = cursor.fetchall()

if len(data[0][0]) is 0:
if len(data[0][0]) == 0:
con.commit()
return True
else:
Expand All @@ -46,19 +46,19 @@ def insert_firefighter(self, bomberoid, nombre, apellidos, email):
def update_firefighter(self, bomberoid, nombre, apellidos, email):
try:
conn = mariadb.connect(
user=os.getenv("MARIADB_USERNAME"),
password=os.getenv("MARIADB_PASSWORD"),
host=os.getenv("MARIADB_HOST"),
database="prometeo",
port=3306)
user = os.getenv("MARIADB_USERNAME"),
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()

cursor.callproc('sp_update_firefighter', (bomberoid, nombre, apellidos, email))

data = cursor.fetchall()

if len(data[0][0]) is 0:
if len(data[0][0]) == 0:
con.commit()
return True
else:
Expand All @@ -74,11 +74,11 @@ def update_firefighter(self, bomberoid, nombre, apellidos, email):
def get_firefighter(self, bomberoid):
try:
conn = mariadb.connect(
user=os.getenv("MARIADB_USERNAME"),
password=os.getenv("MARIADB_PASSWORD"),
host=os.getenv("MARIADB_HOST"),
database="prometeo",
port=3306)
user = os.getenv("MARIADB_USERNAME"),
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()

Expand All @@ -103,11 +103,11 @@ def get_allfirefighters(self):

try:
conn = mariadb.connect(
user=os.getenv("MARIADB_USERNAME"),
password=os.getenv("MARIADB_PASSWORD"),
host=os.getenv("MARIADB_HOST"),
database="prometeo",
port=3306)
user = os.getenv("MARIADB_USERNAME"),
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()

Expand Down
5 changes: 3 additions & 2 deletions server/routes/fuel_types.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ class fuelTypes(object):
def __init__(self):
load_dotenv()
logging.basicConfig(level=os.environ.get("LOGLEVEL", "INFO"))
self.logger = logging.getLogger('prometo.fuel_types.fuelTypes')
self.logger = logging.getLogger('prometeo.fuel_types.fuelTypes')
self.logger.info('creating an instance of fuelTypes')

def get_allfueltypes(self):
Expand All @@ -18,7 +18,8 @@ def get_allfueltypes(self):
user = os.getenv("MARIADB_USERNAME"),
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo")
database = "prometeo",
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()

Expand Down
2 changes: 1 addition & 1 deletion server/routes/index.py
Original file line number Diff line number Diff line change
Expand Up @@ -159,7 +159,7 @@ def testdb():
user=os.getenv("MARIADB_USERNAME"),
password=os.getenv("MARIADB_PASSWORD"),
host=os.getenv("MARIADB_HOST"),
port=3306)
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()
cursor.execute("SHOW DATABASES")
Expand Down
13 changes: 6 additions & 7 deletions server/routes/metrics.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,20 +8,19 @@ class metrics(object):

def __init__(self):
load_dotenv()
self.logger = logging.getLogger('prometo.metric.metrics')
self.logger = logging.getLogger('prometeo.metric.metrics')
self.logger.debug('creating an instance of metrics')

def get_allmetrics(self, sensorid, event_date, max_mediciones):
print("get_allmetrics - entro en la funcion")

try:
conn = mariadb.connect(
user=os.getenv("MARIADB_USERNAME"),
password=os.getenv("MARIADB_PASSWORD"),
host=os.getenv("MARIADB_HOST"),
database="prometeo",
port=3306)

user = os.getenv("MARIADB_USERNAME"),
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = int(os.getenv("MARIADB_PORT")))
cursor = conn.cursor()

print("get_allmetrics - llamada a sql")
Expand Down
12 changes: 6 additions & 6 deletions server/routes/metrics_new.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,19 +8,19 @@ class metrics(object):

def __init__(self):
load_dotenv()
self.logger = logging.getLogger('prometo.newmetric.new_metrics')
self.logger = logging.getLogger('prometeo.newmetric.new_metrics')
self.logger.debug('creating an instance of metrics')

def get_allmetrics(self, sensorid, event_date, max_mediciones):
print("get_allmetrics - entro en la funcion")

try:
conn = mariadb.connect(
user=os.getenv("MARIADB_USERNAME"),
password=os.getenv("MARIADB_PASSWORD"),
host=os.getenv("MARIADB_HOST"),
database="prometeo",
port=3306)
user = os.getenv("MARIADB_USERNAME"),
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()

Expand Down
12 changes: 6 additions & 6 deletions server/routes/status.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,19 +10,19 @@ class status(object):

def __init__(self):
load_dotenv()
self.logger = logging.getLogger('prometo.status.status_webapp')
self.logger = logging.getLogger('prometeo.status.status_webapp')
self.logger.debug('creating an instance of status')

def get_allstatus(self):
print("get_allstatus - entro en la funcion")

try:
conn = mariadb.connect(
user=os.getenv("MARIADB_USERNAME"),
password=os.getenv("MARIADB_PASSWORD"),
host=os.getenv("MARIADB_HOST"),
database="prometeo",
port=3306)
user = os.getenv("MARIADB_USERNAME"),
password = os.getenv("MARIADB_PASSWORD"),
host = os.getenv("MARIADB_HOST"),
database = "prometeo",
port = int(os.getenv("MARIADB_PORT")))

cursor = conn.cursor()

Expand Down
5 changes: 5 additions & 0 deletions server/template.env
Original file line number Diff line number Diff line change
@@ -0,0 +1,5 @@
# MariaDB
MARIADB_HOST=
MARIADB_PORT=
MARIADB_USERNAME=
MARIADB_PASSWORD=