Feature/tag projects endpoint (#630)

* feat: add social endpoint for browsing projects, users, and tags

* chore: add review comments for socials controller and helpers refactor (pagination, schema counts)

* fix(migrations):prevent accidental drop of project_database table and ensure downgrade restores it properly

* refactor: move Followers import to top of file

* feat: Add TagProjectsView endpoint with pagination

* fix :update tags detail and modified /tags/{id}/following with pagination

Author: CHRISTOPHERKADOGO

api_docs.yml

@@ -4217,6 +4217,41 @@ paths:
           description: "Bad request"
         500:
           description: "Internal Server Error"
+          
+  "/tags/{tag_id}/projects":
+    get:
+      tags:
+        - tags
+      consumes:
+        - application/json
+      produces:
+        - application/json
+      parameters:
+        - in: header
+          name: Authorization
+          required: true
+          description: "Bearer [token]"
+        - in: path
+          name: tag_id
+          required: true
+          type: string
+        - in: query
+          name: page
+          type: integer
+          description: Page number
+        - in: query
+          name: per_page
+          type: integer
+          description: Number of items per page
+      responses:
+        200:
+          description: "Success"
+        404:
+          description: "Tag not found"
+        400:
+          description: "Bad request"
+        500:
+          description: "Internal Server Error"
 
   "/socials":
     get:

app/controllers/__init__.py

@@ -30,6 +30,6 @@
 from .system_status import SystemSummaryView
 from .project_users import ProjectUsersView, ProjectUsersTransferView, ProjectUsersHandleInviteView, ProjectFollowingView
 from .activity_feed import ActivityFeedView
-from .tags import TagsView, TagsDetailView, TagFollowingView
+from .tags import TagsView, TagsDetailView, TagFollowingView,TagProjectsView
 from .generic_search import GenericSearchView
 from .socials import SocialView

app/controllers/tags.py

@@ -1,11 +1,16 @@
 
 import json
+from app.models.project import Project
+from app.models.user import User
+from app.schemas.project import ProjectSchema
 from app.schemas.project_users import UserIndexSchema
 from app.schemas.tags import TagSchema, TagsDetailSchema
+from app.schemas.user import UserSchema
 from flask_restful import Resource, request
 from flask_jwt_extended import jwt_required, get_jwt_identity
-from app.models.tags import Tag, TagFollowers
+from app.models.tags import ProjectTag, Tag, TagFollowers
 from app.helpers.decorators import admin_required
+from app.models import db
 
 
 class TagsView(Resource):
@@ -64,7 +69,7 @@ class TagsDetailView(Resource):
 
     @jwt_required
     def get(self, tag_id):
-        tag_schema = TagsDetailSchema()
+        tag_schema = TagSchema()
 
         tag = Tag.get_by_id(tag_id)
 
@@ -122,22 +127,82 @@ def post(self, tag_id):
             message=f'You are now following tag with id {tag_id}'
         ), 201
 
-    @ jwt_required
+    @jwt_required
     def get(self, tag_id):
+        page = request.args.get('page', 1, type=int)
+        per_page = request.args.get('per_page', 10, type=int)
+        
+        if per_page > 100:
+            per_page = 100
+        
+        if page < 1:
+            page = 1
+        
         tag = Tag.get_by_id(tag_id)
-        follower_schema = UserIndexSchema(many=True)
-
-        followers = tag.followers
-        users_data, errors = follower_schema.dumps(followers)
-
-        if errors:
-            return dict(status='fail', message=errors), 400
-
-        return dict(
-            status='success',
-            data=dict(followers=json.loads(users_data))
-        ), 200
-
+        
+        if not tag:
+            return dict(status='fail', message=f'Tag with id {tag_id} not found'), 404
+        
+        try:
+            query = db.session.query(User).join(
+                    TagFollowers, User.id == TagFollowers.user_id
+                ).filter(
+                    TagFollowers.tag_id == tag_id
+                ).order_by(TagFollowers.date_created.desc())
+                            
+            total_followers_count = query.count()
+    
+            paginated_result = query.paginate(
+                page=page,
+                per_page=per_page,
+                error_out=False
+            )
+            
+            follower_schema = UserSchema(many=True)
+            schema_result = follower_schema.dump(paginated_result.items)
+
+            if hasattr(schema_result, 'data'):
+                followers_data = schema_result.data
+            else:
+                followers_data = schema_result
+          
+            if followers_data is None:
+                followers_data = []
+            elif not isinstance(followers_data, list):
+                try:
+                    followers_data = list(followers_data)
+                except:
+                    followers_data = []
+            
+            pagination = {
+                'total': paginated_result.total,
+                'pages': paginated_result.pages,
+                'page': paginated_result.page,
+                'per_page': paginated_result.per_page,
+                'next': paginated_result.next_num,
+                'prev': paginated_result.prev_num,
+                'has_next': paginated_result.has_next,
+                'has_prev': paginated_result.has_prev
+            }
+            
+            tag_info = dict(
+                id=str(tag.id),
+                name=tag.name,
+                followers_count=total_followers_count
+            )
+            
+            return dict(
+                status='success',
+                data=dict(
+                    tag=tag_info,
+                    followers=followers_data,
+                    pagination=pagination
+                )
+            ), 200
+            
+        except Exception as e:
+            return dict(status='fail', message='Internal Server Error'), 500
+        
     @ jwt_required
     def delete(self, tag_id):
         current_user_id = get_jwt_identity()
@@ -160,3 +225,85 @@ def delete(self, tag_id):
             status='success',
             message=f'You are nolonger following tag with id {tag_id}'
         ), 201
+
+
+
+
+class TagProjectsView(Resource):
+    @jwt_required
+    def get(self, tag_id):
+       
+        page = request.args.get('page', 1, type=int)
+        per_page = request.args.get('per_page', 10, type=int)
+
+        if per_page > 100:
+            per_page = 100
+
+        if page < 1:
+            page = 1
+
+        tag = Tag.get_by_id(tag_id)
+        tag_schema = TagSchema()
+        tag_data = tag_schema.dump(tag)
+            
+        
+        if not tag:
+            return dict(status='fail', message=f'Tag with id {tag_id} not found'), 404
+
+        try:
+            query = db.session.query(Project).join(
+                ProjectTag, Project.id == ProjectTag.project_id
+            ).filter(
+                ProjectTag.tag_id == tag_id
+            ).order_by(Project.date_created.desc())
+            total_projects_count = query.count()
+            
+            paginated_result = query.paginate(
+                page=page, 
+                per_page=per_page, 
+                error_out=False
+            )
+
+            project_schema = ProjectSchema(many=True)
+            schema_result = project_schema.dump(paginated_result.items)
+
+            if hasattr(schema_result, 'data'):
+                projects_data = schema_result.data
+            else:
+                projects_data = schema_result
+                
+            if projects_data is None:
+                projects_data = []
+            elif not isinstance(projects_data, list):
+                try:
+                    projects_data = list(projects_data)
+                except:
+                    projects_data = []
+            
+            pagination = {
+                'total': paginated_result.total,
+                'pages': paginated_result.pages,
+                'page': paginated_result.page,
+                'per_page': paginated_result.per_page,
+                'next': paginated_result.next_num,
+                'prev': paginated_result.prev_num,
+                'has_next': paginated_result.has_next,
+                'has_prev': paginated_result.has_prev
+            }
+                
+            tag_info = dict(
+                id=str(tag.id),
+                name=tag.name,
+                projects_count=total_projects_count
+            )
+            return dict(
+                status='success',
+                data=dict(
+                    tag=tag_info,
+                    projects=projects_data,
+                    pagination=pagination
+                    )
+                ), 200
+                
+        except Exception as e:      
+            return dict(status='fail', message='Internal Server Error'), 500

app/routes/__init__.py

@@ -15,7 +15,7 @@
     BillingInvoiceView, BillingInvoiceNotificationView, SystemSummaryView, CreditDetailView, ProjectUsersView, ProjectUsersTransferView, AppReviseView,
     ProjectUsersHandleInviteView, ClusterProjectsView, ProjectDisableView, ProjectEnableView, AppRedeployView, AppDisableView, AppEnableView,
     TagsView, TagsDetailView, TagFollowingView, GenericSearchView, MLProjectAppsView, ProjectMigrationView,
-    UserDisableView, UserEnableView, AppDockerWebhookListenerView, UserFollowersView, UserFollowView, ProjectFollowingView, ActivityFeedView, SendInactiveUserMailReminder,GoogleOAuthView)
+    UserDisableView, UserEnableView, AppDockerWebhookListenerView, UserFollowersView, UserFollowView, ProjectFollowingView, ActivityFeedView, SendInactiveUserMailReminder,GoogleOAuthView,TagProjectsView)
 from app.controllers.app import AppRevisionsView
 from app.controllers.app_domain import AppDomainView, AppDomainDetailView
 from app.controllers.billing_invoice import BillingInvoiceDetailView
@@ -164,6 +164,8 @@
 api.add_resource(TagsView, '/tags')
 api.add_resource(TagsDetailView, '/tags/<string:tag_id>')
 api.add_resource(TagFollowingView, '/tags/<string:tag_id>/following')
+# Add this route to get projects by tag
+api.add_resource(TagProjectsView, '/tags/<string:tag_id>/projects')
 
 # App routes
 api.add_resource(AppsView, '/apps')

app/schemas/project.py

@@ -103,13 +103,14 @@ def get_supports_ml(self, obj):
 
     def get_tags_count(self, obj):
         return ProjectTag.count(project_id=obj.id)
-    
+      
     def get_pinned_status(self, obj):
         project_user = ProjectUser.query.filter_by(
             project_id=obj.id,
         ).first()
         return project_user.pinned if project_user else False
 
 
+
 class ProjectMigrationSchema(Schema):
     new_cluster_id = fields.String(required=True)

migrations/versions/64081c5f2989_.py

@@ -17,7 +17,7 @@
 
 
 def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
+
     op.add_column('project', sa.Column(
         'updated_at', sa.DateTime(), nullable=True))
     op.add_column('project_tag', sa.Column(