CON-72-story(notifications): admin receives notification when device is not seen in a while

- setup queue manager for when notifications are sent
- implement notifications when device is not seen in a while

[Delivers CON-72]

Author: [Arusey]

admin_notifications/helpers/device_last_seen.py

@@ -0,0 +1,36 @@
+from datetime import datetime
+from api.devices.models import Devices as DevicesModel
+from utilities.utility import update_entity_fields
+from admin_notifications.helpers.create_notification import create_notification
+from admin_notifications.helpers.notification_templates import device_offline_notification  # noqa 501
+import celery
+
+
+@celery.task(name='check-device-last-seen')
+def notify_when_device_is_offline(**kwargs):
+    query = DevicesModel.query
+    online_devices = query.filter(DevicesModel.activity == "online").all()
+    for device in online_devices:
+        device_last_seen = device.last_seen
+        current_time = datetime.now()
+        duration_offline = current_time - device_last_seen
+
+        if duration_offline.days > 1:
+            update_entity_fields(device, activity="offline")
+            device.save()
+    return online_devices
+
+
+@celery.task(name='notify')
+def notify():
+    query = DevicesModel.query
+    offline_device = query.filter(DevicesModel.activity == "offline").all()
+    for device in offline_device:
+        if device:
+            room_name = device.room.name
+            room_id = device.room.id
+            notification_payload = device_offline_notification(
+                room_name, room_id)
+            create_notification(title=notification_payload['title'],
+                                message=notification_payload['message'],
+                                location_id=device.room.location_id)

admin_notifications/models.py

@@ -6,7 +6,7 @@
 class AdminNotification(Base, Utility):
     __tablename__ = 'admin_notifications'
 
-    id = Column(Integer, primary_key=True) # noqa
+    id = Column(Integer, primary_key=True)  # noqa
     title = Column(String, nullable=True)
     message = Column(String, nullable=True)
     date_received = Column(String, nullable=True)

alembic/versions/79ef610dbd41_add_activity_column_to_devices_table.py

@@ -0,0 +1,33 @@
+"""add activity column to devices table
+
+Revision ID: 79ef610dbd41
+Revises: a36af2be7b0c
+Create Date: 2019-06-28 08:05:37.542613
+
+"""
+from alembic import op
+import sqlalchemy as sa
+from sqlalchemy.dialects import postgresql
+
+
+
+# revision identifiers, used by Alembic.
+revision = '79ef610dbd41'
+down_revision = 'a36af2be7b0c'
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    activitytype = postgresql.ENUM(
+        'online', 'offline', name='activitytype')
+    activitytype.create(op.get_bind())
+    op.add_column('devices', sa.Column('activity', sa.Enum('online', 'offline', name='activitytype'), nullable=True))
+    # ### end Alembic commands ###
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_column('devices', 'activity')
+    # ### end Alembic commands ###

alembic/versions/c65718cd4ed8_add_admin_notifications_table.py renamed to alembic/versions/a36af2be7b0c_add_admin_notifications_table.py

@@ -1,23 +1,24 @@
 """add admin notifications table
 
-Revision ID: c65718cd4ed8
-Revises: a5a4841351d7
-Create Date: 2019-06-21 08:38:07.110402
+Revision ID: a36af2be7b0c
+Revises: 50173cb0491f
+Create Date: 2019-06-28 07:51:40.249610
 
 """
 from alembic import op
 import sqlalchemy as sa
 
 
 # revision identifiers, used by Alembic.
-revision = 'c65718cd4ed8'
-down_revision = 'a5a4841351d7'
+revision = 'a36af2be7b0c'
+down_revision = '50173cb0491f'
 branch_labels = None
 depends_on = None
 
 
 def upgrade():
     # ### commands auto generated by Alembic - please adjust! ###
+    op.execute('DROP TYPE statustype;')
     op.create_table('admin_notifications',
     sa.Column('id', sa.Integer(), nullable=False),
     sa.Column('title', sa.String(), nullable=True),

api/devices/models.py

@@ -17,7 +17,7 @@ class Devices(Base, Utility):
     location = Column(String, nullable=False)
     room_id = Column(Integer, ForeignKey('rooms.id', ondelete="CASCADE"))
     room = relationship('Room')
-    activity = Column(Enum(ActivityType), default="active")
+    activity = Column(Enum(ActivityType), default="online")
 
     def __init__(self, **kwargs):
         validate_empty_fields(**kwargs)

app.py

@@ -3,7 +3,6 @@
 from flask_graphql import GraphQLView
 from flask_cors import CORS
 from flask_json import FlaskJSON
-from flask_socketio import SocketIO
 
 from flask_mail import Mail
 from config import config
@@ -20,7 +19,6 @@ def create_app(config_name):
     app = Flask(__name__)
     CORS(app)
     FlaskJSON(app)
-    SocketIO(app)
     app.config.from_object(config[config_name])
     config[config_name].init_app(app)
     mail.init_app(app)

cworker.py

@@ -8,8 +8,8 @@
 
 
 app.config.update(
-    CELERY_BROKER_URL='redis://localhost:6379',
-    CELERY_RESULT_BACKEND='redis://localhost:6379',
+    CELERY_BROKER_URL=os.getenv('CELERY_BROKER_URL'),
+    CELERY_RESULT_BACKEND=os.getenv('CELERY_RESULT_BACKEND'),
     CELERY_ACCEPT_CONTENT=['pickle'],
     CELERYBEAT_SCHEDULE=beat_schedule
 )
@@ -34,5 +34,6 @@ def __call__(self, *args, **kwargs):
 
 
 celery = make_celery(app)
+
 celery_scheduler = Celery(app.name, broker=app.config['CELERY_BROKER_URL'])
-celery_scheduler.conf.update(app.config)
+celery_scheduler.conf.enable_utc = False

requirements.txt

@@ -1,86 +1,39 @@
 alembic==0.9.8
-amqp==1.4.9
-aniso8601==3.0.2
-anyjson==0.3.3
-astroid==2.2.5
-attrs==19.1.0
-autopep8==1.4.4
-billiard==3.3.0.23
-blinker==1.4
 bugsnag==3.4.2
+blinker==1.4
 celery==3.1.17
-certifi==2019.3.9
-chardet==3.0.4
-Click==7.0
 coverage==4.5.1
-coveralls==1.8.0
-decorator==4.4.0
-docopt==0.6.2
-flake8==3.5.0
 Flask==0.12.2
 Flask-Cors==3.0.4
-Flask-GraphQL==1.4.1
 Flask-JSON==0.3.2
-Flask-Mail==0.9.1
 Flask-Script==2.0.6
-Flask-SocketIO==4.1.0
-Flask-Testing==0.7.1
+Flask-GraphQL==1.4.1
+Flask-Mail==0.9.1
 google-api-python-client==1.6.7
-graphene==2.1
 graphene-sqlalchemy==2.0.0
-graphql-core==2.2
-graphql-relay==0.4.5
-httplib2==0.13.0
-idna==2.8
+graphene==2.1
 imgkit==1.0.1
-iso8601==0.1.12
-isort==4.3.20
-itsdangerous==1.1.0
-Jinja2==2.10.1
-kombu==3.0.37
-lazy-object-proxy==1.4.1
-Mako==1.0.12
 MarkupSafe==1.0
-mccabe==0.6.1
 more-itertools==4.1.0
-nose==1.3.7
 numpy==1.15.2
-oauth2client==4.1.3
 opencv-python==3.4.3.18
 pandas==0.23.4
-pdfkit==0.6.1
 Pillow==5.3.0
-pluggy==0.6.0
-promise==2.2.1
+pdfkit==0.6.1
 psycopg2-binary==2.7.4
 py==1.5.3
-pyasn1==0.4.5
-pyasn1-modules==0.2.5
-pycodestyle==2.3.1
-pyflakes==1.6.0
-PyJWT==1.6.4
-pylint==2.3.1
 pytest==3.5.0
 python-dateutil==2.7.0
-python-editor==1.0.3
-python-engineio==3.8.1
-python-socketio==4.1.0
-pytz==2019.1
+PyJWT==1.6.4
 redis==2.10.3
-requests==2.22.0
-rsa==4.0
-Rx==1.6.1
-singledispatch==3.4.0.3
-six==1.12.0
+nose==1.3.7
+python-editor==1.0.3
 SQLAlchemy==1.2.6
-SQLAlchemy-Utils==0.33.2
 tox==3.0.0
-typed-ast==1.4.0
-typing==3.6.4
-uritemplate==3.0.0
-urllib3==1.25.3
-validators==0.12.4
+SQLAlchemy-Utils==0.33.2
 virtualenv==15.2.0
-WebOb==1.8.5
-Werkzeug==0.15.4
-wrapt==1.11.1
+Flask-Testing==0.7.1
+typing==3.6.4
+flake8==3.5.0
+coveralls
+validators==0.12.4

utilities/utility.py

@@ -89,7 +89,6 @@ class QuestionType(enum.Enum):
     missingitem = "missing_items"
 
 
-
 class StatusType(enum.Enum):
     read = "read"
     unread = "unread"