upadates

Author: Curiouspaul1

core/api/user/views.py

@@ -123,6 +123,21 @@ def view_cards(current_user):
         many=True
     )
 
+
+@user.post('/app_token')
+@login_required
+def add_app_token(current_user):
+    payload = request.get_json(force=True)
+    if 'app_token' not in payload:
+        return error_response(
+            400,
+            'Missing required field "app_token"'
+        )
+    with db.session() as sess:
+        current_user.mobile_app_registration_token = payload['app_token']
+        sess.commit()
+    return gen_response(200, 'Added token successfully!')
+
 # @user.get('/<uid>')
 # def check_uid(uid):
 #     """ checks if uid exists """

migrations/versions/2025-12-17__42f4aaaab1a1.py

@@ -0,0 +1,31 @@
+"""empty message
+
+Revision ID: 42f4aaaab1a1
+Revises: b8ec34f70d9c
+Create Date: 2025-12-17 12:44:08.160967
+
+"""
+from alembic import op
+import sqlalchemy as sa
+from sqlalchemy.dialects import postgresql
+
+# revision identifiers, used by Alembic.
+revision = '42f4aaaab1a1'
+down_revision = 'b8ec34f70d9c'
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    with op.batch_alter_table('user', schema=None) as batch_op:
+        batch_op.add_column(
+            sa.Column('mobile_app_registration_token', sa.String(), nullable=True)
+        )
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+
+    with op.batch_alter_table('user', schema=None) as batch_op:
+        batch_op.drop_column('mobile_app_registration_token')

models/user_models.py

@@ -116,6 +116,7 @@ class User(TimestampMixin, db.Model):
     address = db.Column(db.String(500))
     sign_up_date = db.Column(db.Date, default=datetime.utcnow())
     profile_picture = db.Column(db.String())
+    mobile_app_registration_token = db.Column(db.String())
     artisan_profile = db.relationship(
         'Artisan',
         backref='user_profile',

tasks/events.py

@@ -16,6 +16,11 @@
 redis_pass = os.getenv('REDIS_PASS')
 redis_port = os.getenv('REDIS_PORT', 6378)
 
+IMPORTANT_NOTIFICATIONS = [
+    'approve_booking_details',
+    'job_completed',
+]
+
 
 def exp_backoff_task(retries, retry_backoff):
     def deco(fn):