feat: new active projects api for export tool

backend/__init__.py

@@ -216,6 +216,7 @@ def add_api_endpoints(app):
         ProjectsQueriesPriorityAreasAPI,
         ProjectsQueriesFeaturedAPI,
         ProjectQueriesSimilarProjectsAPI,
+        ProjectQueriesActiveProjectsAPI,
     )
     from backend.api.projects.activities import (
         ProjectsActivitiesAPI,
@@ -428,6 +429,10 @@ def add_api_endpoints(app):
         ProjectQueriesSimilarProjectsAPI,
         format_url("projects/queries/<int:project_id>/similar-projects/"),
     )
+    api.add_resource(
+        ProjectQueriesActiveProjectsAPI,
+        format_url("projects/queries/active/"),
+    )
 
     # Projects' addtional resources
     api.add_resource(

backend/api/projects/resources.py

@@ -1164,3 +1164,39 @@ def get(self, project_id):
             project_id, authenticated_user_id, preferred_locale, limit
         )
         return projects_dto.to_primitive(), 200
+
+
+class ProjectQueriesActiveProjectsAPI(Resource):
+    @token_auth.login_required(optional=True)
+    def get(self):
+        """
+        Get active projects
+        ---
+        tags:
+            - projects
+        produces:
+            - application/json
+        parameters:
+            - in: header
+              name: Authorization
+              description: Base64 encoded session token
+              required: false
+              type: string
+              default: Token sessionTokenHere==
+            - name: interval
+              in: path
+              description: Time interval to get active project
+              required: false
+              type: integer
+              default: 24
+        responses:
+            200:
+                description: Active projects geojson
+            404:
+                description: Project not found or project is not published
+            500:
+                description: Internal Server Error
+        """
+        interval = int(request.args.get("interval", 24))
+        projects_dto = ProjectService.get_active_projects(interval)
+        return projects_dto, 200

backend/services/project_service.py

@@ -1,6 +1,8 @@
 import threading
 from cachetools import TTLCache, cached
 from flask import current_app
+import geojson
+from datetime import datetime, timedelta
 
 from backend.exceptions import NotFound
 from backend.models.dtos.mapping_dto import TaskDTOs
@@ -615,3 +617,37 @@ def send_email_on_project_progress(project_id):
                     project_completion,
                 ),
             ).start()
+
+    @staticmethod
+    def get_active_projects(interval):
+        action_date = datetime.now() - timedelta(hours=interval)
+        result = (
+            TaskHistory.query.with_entities(TaskHistory.project_id)
+            .distinct()
+            .filter(TaskHistory.action_date >= action_date)
+            .all()
+        )
+        project_ids = [row.project_id for row in result]
+        projects = (
+            Project.query.with_entities(
+                Project.id,
+                Project.mapping_types,
+                Project.geometry.ST_AsGeoJSON().label("geometry"),
+            )
+            .filter(
+                Project.status == ProjectStatus.PUBLISHED.value,
+                Project.id.in_(project_ids),
+            )
+            .all()
+        )
+        features = []
+        for project in projects:
+            properties = {
+                "project_id": project.id,
+                "mapping_types": project.mapping_types,
+            }
+            feature = geojson.Feature(
+                geometry=geojson.loads(project.geometry), properties=properties
+            )
+            features.append(feature)
+        return geojson.FeatureCollection(features)