add campaign api

Author: rubybui

mind_matter_api/api/campaigns.py

@@ -0,0 +1,28 @@
+from flask import jsonify, request, current_app
+from marshmallow import ValidationError
+
+from mind_matter_api.services.campaigns import CampaignsService
+from mind_matter_api.utils.decorators import require_auth, require_owner
+from mind_matter_api.utils.auth import is_user_owner, is_user_admin
+import logging
+
+logging.basicConfig(level=logging.DEBUG)
+
+def init_campaigns_routes(app):
+    campaign_service: CampaignsService = app.campaigns_service
+
+    @app.route('/campaigns', methods=['GET'])
+    @require_auth
+    def get_campaigns(user_id):
+        return campaign_service.get_campaigns(user_id)   
+    
+    @app.route('/campaigns/<int:campaign_id>/survey-responses-count', methods=['GET'])
+    @require_auth
+    def get_survey_responses_count(campaign_id):
+        return campaign_service.get_survey_responses_count(campaign_id)
+    
+    @app.route('/campaigns/<int:campaign_id>/participation', methods=['GET'])
+    @require_auth
+    def get_campaign_participation(campaign_id):
+        return campaign_service.get_campaign_participation(campaign_id)
+    

mind_matter_api/api/emergency_contacts.py

@@ -9,14 +9,14 @@
 logging.basicConfig(level=logging.DEBUG)
 
 def init_emergency_contacts_routes(app):
-    svc: EmergencyContactsService = app.emergency_contacts_service
+    emergency_contact_service: EmergencyContactsService = app.emergency_contacts_service
 
     @app.route('/emergency-contacts', methods=['GET'])
     @require_auth
     def get_emergency_contacts(user_id):
         """Get all emergency contacts for the current user"""
         try:
-            emergency_contacts = svc.get_emergency_contacts(user_id)
+            emergency_contacts = emergency_contact_service.get_emergency_contacts(user_id)
             return jsonify(EmergencyContactSchema(many=True).dump(emergency_contacts)), 200
         except Exception as e:
             app.logger.error(f"Error retrieving emergency contacts: {str(e)}")
@@ -38,7 +38,7 @@ def create_emergency_contact(user_id):
             contact_data = EmergencyContactSchema().dump(validated_data)
 
             # Create the emergency contact
-            new_contact = svc.create_emergency_contacts(user_id, contact_data)
+            new_contact = emergency_contact_service.create_emergency_contacts(user_id, contact_data)
 
             return jsonify(EmergencyContactSchema().dump(new_contact)), 201
         except ValidationError as err:
@@ -54,7 +54,7 @@ def update_emergency_contact(user_id, contact_id):
         """Update an existing emergency contact"""
         try:
             # First check if the contact exists
-            contact = svc.emergency_contacts_repository.get_by_id(contact_id)
+            contact = emergency_contact_service.emergency_contacts_repository.get_by_id(contact_id)
             if not contact:
                 return jsonify({'error': 'Emergency contact not found'}), 404
 
@@ -68,7 +68,7 @@ def update_emergency_contact(user_id, contact_id):
             # Validate the data
             data = EmergencyContactSchema().load(request_data, partial=True)
             # Update the contact
-            updated = svc.update_emergency_contacts(contact_id, data)
+            updated = emergency_contact_service.update_emergency_contacts(contact_id, data)
             return jsonify(EmergencyContactSchema().dump(updated)), 200
         except ValidationError as err:
             app.logger.error(f"Validation error: {err.messages}")
@@ -83,15 +83,15 @@ def delete_emergency_contact(user_id, contact_id):
         """Delete an emergency contact"""
         try:
             # First check if the contact exists
-            contact = svc.emergency_contacts_repository.get_by_id(contact_id)
+            contact = emergency_contact_service.emergency_contacts_repository.get_by_id(contact_id)
             if not contact:
                 return jsonify({'error': 'Emergency contact not found'}), 404
 
             # Then check ownership
             if not is_user_owner(user_id, contact) and not is_user_admin(user_id):
                 return jsonify({'error': 'Permission denied'}), 403
 
-            svc.delete_emergency_contacts(contact_id)
+            emergency_contact_service.delete_emergency_contacts(contact_id)
             return '', 204
         except Exception as e:
             app.logger.error(f"Error deleting emergency contact: {str(e)}")

mind_matter_api/repositories/campaigns.py

@@ -1,6 +1,6 @@
 from typing import Any, Dict, List, Optional
-from mind_matter_api.models.campaigns import Campaign
-from mind_matter_api.repositories.type import Repository
+from mind_matter_api.models.campaigns import Campaign, CampaignParticipation
+from mind_matter_api.repositories.types import Repository
 from mind_matter_api.models import db   
 
 class CampaignRepository(Repository):
@@ -36,4 +36,10 @@ def delete(self, resource_id: Any) -> None:
         if not campaign:
             raise ValueError("Resource not found")
         self.session.delete(campaign)
-        self.session.commit()
+        self.session.commit()
+
+    def get_survey_responses_count(self, campaign_id: str) -> int:
+        return self.session.query(Campaign).filter(Campaign.campaign_id == campaign_id).count()
+
+    def get_campaign_participation(self, campaign_id: str) -> CampaignParticipation:
+        return self.session.query(CampaignParticipation).filter(CampaignParticipation.campaign_id == campaign_id).all()

mind_matter_api/services/campaigns.py

@@ -1,5 +1,5 @@
 from mind_matter_api.services.types import BaseService
-from mind_matter_api.models.campaigns import Campaigns
+from mind_matter_api.models.campaigns import Campaigns, CampaignParticipation
 from mind_matter_api.repositories.campaigns import CampaignsRepository
 
 class CampaignsService(BaseService):
@@ -10,6 +10,14 @@ def get_campaigns(self, user_id: str) -> Campaigns:
         campaigns = self.campaigns_repository.get(user_id)
         return campaigns
 
+    def get_survey_responses_count(self, campaign_id: str) -> int:
+        survey_responses_count = self.campaigns_repository.get_survey_responses_count(campaign_id)
+        return survey_responses_count
+    
+    def get_campaign_participation(self, campaign_id: str) -> CampaignParticipation:
+        campaign_participation = self.campaigns_repository.get_campaign_participation(campaign_id)
+        return campaign_participation
+    
     def create_campaigns(self, user_data: Campaigns) -> Campaigns:
         new_campaigns = Campaigns(**user_data)
         created_campaigns = self.campaigns_repository.create(new_campaigns)