recent posts service added

main.py

@@ -3,7 +3,7 @@ from typing import Annotated
 import os
 from fastapi.middleware.cors import CORSMiddleware
 from dotenv import load_dotenv
-from utils.GetTopAndRecentQuestions import return_top_question
+from utils.GetTopAndRecentQuestions import return_top_question, return_recent_posts
 
 load_dotenv()
 
@@ -33,3 +33,15 @@ def get_top_questions_(limit: int = 5, Authorization: Annotated[list[str] | None
     except Exception as e:
         # return a success message
         raise HTTPException(status_code=400, detail=str(e))
+
+
+@app.get("/get_recent_posts", status_code=status.HTTP_200_OK)
+def get_recent_posts_(limit: int = 5, strategy: str = 'recent',
+                      Authorization: Annotated[list[str] | None, Header()] = None):
+    if Authorization is None or Authorization[0] != "Bearer {}".format(token):
+        raise HTTPException(status_code=401, detail="Unauthorised.")
+    try:
+        return {'data': return_recent_posts(limit, strategy)}
+    except Exception as e:
+        # return a success message
+        raise HTTPException(status_code=400, detail=str(e))

utils/GetTopAndRecentQuestions.py

@@ -134,4 +134,43 @@ def return_top_question(limit=5):
 
     return message
 
-# print(return_top_question())
+
+def return_recent_posts(limit=5, strategy='recent'):
+    import os
+    import requests
+    import json
+
+    HASURA_URL = os.environ['HASURA_URL']
+    HASURA_ADMIN_SECRET = os.environ['HASURA_ADMIN_SECRET']
+
+    url = HASURA_URL
+    body = """query homeFeedQuery($strategy: Strategy, $limit: Int){
+feed(strategy: $strategy, limit: $limit) {
+hits {
+link
+title
+date
+author
+        }
+    }
+}"""
+    variables = {'strategy': strategy, 'limit': limit}
+    response = requests.post(url=url, json={'query': body, 'variables': variables}, headers={
+        'x-hasura-admin-secret': HASURA_ADMIN_SECRET})
+
+    message = 'These are the recent Articles/Posts on the platform/twimbit website: \n'
+
+    if response.status_code == 200:
+        data = json.loads(response.content)
+        posts = data.get('data').get('feed').get('hits')
+
+        for key, post in enumerate(posts):
+            title = post.get('title')
+            link = post.get('link')
+            date = post.get('date')
+            authors = ','.join(post.get('author'))
+            message += 'Post/Article {}:- \n\tPost/Article Title:- {}\n\tPost/Article Link/URL:- {}\n\tPost/Article Publish Date:- {}\n\tPost/Article Author:- {}\n'.format(
+                key + 1, title, link, date, authors)
+
+    return message
+