up

.env.example

@@ -1,7 +1,9 @@
 SERVICE_GEOLOCATION_URL=
-SERVICE_AIGVDET_URL=
 SERVICE_REPORT_URL=
 SERVICE_TIMESTAMP_URL=
+SERVICE_AIGVDET_URL=
+
+TOKEN_HF=
 
 MONGO_DATABASE_CONNECTION_STRING=
 
@@ -11,4 +13,7 @@ JWT_REFRESH_TOKEN_SECRET_KEY=
 JWT_REFRESH_TOKEN_EXPIRED_IN=
 JWT_REFRESH_TOKEN_EXTENDED_EXPIRED_IN=
 
-SAVE_DATA_PATH=
+SAVE_DATA_PATH=
+
+SPREADSHEET_ID =
+SERVICE_ACCOUNT_FILE =

.gitignore

@@ -200,4 +200,5 @@ google_application_credentials.json
 query_dataset
 video_cache.json
 processed_readme.md
-reports
+reports
+credentials.json

app/config.py

@@ -6,6 +6,8 @@ class Settings(BaseSettings):
     SERVICE_REPORT_URL: str
     SERVICE_TIMESTAMP_URL: str
 
+    TOKEN_HF: str
+
     MONGO_DATABASE_CONNECTION_STRING: str
 
     JWT_ACCESS_TOKEN_SECRET_KEY: str
@@ -16,6 +18,9 @@ class Settings(BaseSettings):
 
     SAVE_DATA_PATH: str = "reports"
 
+    SPREADSHEET_ID: str
+    SERVICE_ACCOUNT_FILE: str
+
     class Config:
         env_file = ".env"
 

app/face_check/service.py

@@ -14,7 +14,8 @@ class AIService:
                 files_payload = [("files", (name, content, ctype)) for name, content, ctype in file_bytes]
                 files_payload.append(("files", (meta_bytes[0], meta_bytes[1], meta_bytes[2])))
 
-                resp = await client.post("/g3/predict", files=files_payload)
+                headers = {"Authorization": f"Bearer {settings.TOKEN_HF}"}
+                resp = await client.post("/g3/predict", files=files_payload, headers=headers)
                 resp.raise_for_status()
                 await SseView.send_sse_message(client_id, {
                     "status_service": "completed",
@@ -42,7 +43,8 @@ class AIService:
                 files_payload = [("files", (name, content, ctype)) for name, content, ctype in file_bytes]
                 files_payload.append(("metadata_file", (meta_bytes[0], meta_bytes[1], meta_bytes[2])))
 
-                resp = await client.post("/analyze/", files=files_payload)
+                headers = {"Authorization": f"Bearer {settings.TOKEN_HF}"}
+                resp = await client.post("/analyze/", files=files_payload, headers=headers)
                 resp.raise_for_status()
                 await SseView.send_sse_message(client_id, {
                     "status_service": "completed",
@@ -74,7 +76,8 @@ class AIService:
                     ("file", (name, content, ctype))
                 ]
 
-                resp = await client.post("/predict", files=files_payload)
+                headers = {"Authorization": f"Bearer {settings.TOKEN_HF}"}
+                resp = await client.post("/predict", files=files_payload, headers=headers)
                 resp.raise_for_status()
                 await SseView.send_sse_message(client_id, {
                     "status_service": "completed",
@@ -95,7 +98,9 @@ class AIService:
     async def call_Report(client_id: str, data):
         try:
             async with httpx.AsyncClient(base_url=settings.SERVICE_REPORT_URL, timeout=10000) as client:
-                resp = await client.post("/v1/report", json=data)
+
+                headers = {"Authorization": f"Bearer {settings.TOKEN_HF}"}
+                resp = await client.post("/v1/report", json=data, headers=headers)
                 resp.raise_for_status()
                 return resp.json()
             await SseView.send_sse_message(client_id, {

app/main.py

@@ -2,6 +2,7 @@ from fastapi import FastAPI
 from .auth.routers import AuthRouters
 from .face_check.routers import FaceCheckRouters
 from .sse.routers import SseRouters
+from .survey.routers import SurveyRouters
 from .mongo import init_db
 from contextlib import asynccontextmanager
 from fastapi.middleware.cors import CORSMiddleware
@@ -29,3 +30,4 @@ app.add_middleware(
 app.include_router(AuthRouters)
 app.include_router(FaceCheckRouters)
 app.include_router(SseRouters)
+app.include_router(SurveyRouters)

app/survey/routers.py

@@ -0,0 +1,13 @@
+from fastapi import APIRouter
+from .view import SurveyView
+from .schemas import SurveyPayload
+
+SurveyRouters = APIRouter(
+    prefix="/v1/survey",
+    tags=["survey"]
+)
+
+survey_view = SurveyView()
+@SurveyRouters.post("", name="survey")
+async def survey(payload: SurveyPayload):
+    return await survey_view.update(payload)

app/survey/schemas.py

@@ -0,0 +1,21 @@
+from pydantic import BaseModel
+
+
+class SurveyPayload(BaseModel):
+    q0: str
+    q1: str
+    q2: str
+    q3: str
+    q4: str
+    q5: str
+    q6: str
+    q7: str
+    q8: str
+    q9: str
+    q10: str
+    q11: str
+    q12: str
+    q13: str
+    q14: str
+    q15: str
+    q16: str

app/survey/view.py

@@ -0,0 +1,73 @@
+
+from fastapi.params import Header
+from app.config import settings
+from google.oauth2 import service_account
+from googleapiclient.discovery import build
+from .schemas import SurveyPayload
+
+HEADER_RANGE = "Sheet1!A1:Q1"
+DATA_RANGE = "Sheet1!A2:Q"
+HEADER_VALUES = [
+                 "How accurate was the conclusion?", 
+                 "Did the algorithm correctly classify this content?", 
+                 "Were the provided links relevant?", 
+                 "Was the technical analysis understandable?",
+                 "Did the report contain any hallucinations (made-up facts)?",
+                 "Did the app clearly identify the main people, organizations, or sources involved in the news item?",
+                 "How accurate did the app's assessment of the credibility of the \"Who\" (e.g., source, expert, witness) seem to you?",
+                 "Did the app correctly identify the central claim or action of the news story?",
+                 "How well did the app's verification evidence address the specific details of the \"What\"?",
+                 "Did the app clearly show when the original event/information was first published or occurred?",
+                 "How useful was the time context (e.g., date, timeline of events) in helping you determine the news' authenticity?",
+                 "Was the location of the event (\"Where\") specified and verified by the app's output?",
+                 "Did the app provide sufficient evidence (e.g., images, maps, source addresses) to confirm the \"Where\" of the event?",
+                 "How well did the app explain the motive or purpose behind the original claim (e.g., persuasion, profit, error)?",
+                 "Did the \"Why\" section help you understand if the news was designed to be misleading or biased?",
+                 "What is your profession?",
+                 "Help us improve. If the verification failed, what did we miss?"
+                ]
+
+class SurveyView:
+    def __init__(self):
+        self.service = self.get_service()
+    
+    def get_service(self):
+        creds = service_account.Credentials.from_service_account_file(
+            settings.SERVICE_ACCOUNT_FILE,
+            scopes=["https://www.googleapis.com/auth/spreadsheets"]
+        )
+        return build("sheets", "v4", credentials=creds)
+
+    def ensure_header(self):
+        values_api = self.service.spreadsheets().values()
+        header_result = values_api.get(
+            spreadsheetId=settings.SPREADSHEET_ID,
+            range=HEADER_RANGE
+        ).execute()
+        header_values = header_result.get("values", [])
+        current = [cell.strip() for cell in header_values[0]] if header_values else []
+        padded = (current + ["" for _ in range(len(HEADER_VALUES))])[: len(HEADER_VALUES)]
+        if padded != HEADER_VALUES:
+            values_api.update(
+                spreadsheetId=settings.SPREADSHEET_ID,
+                range=HEADER_RANGE,
+                valueInputOption="RAW",
+                body={"values": [HEADER_VALUES]},
+            ).execute()
+
+    async def update(self, payload: SurveyPayload):
+        try:
+            self.ensure_header()
+            body = {"values": [[payload.q0, payload.q1, payload.q2, payload.q3, payload.q4, payload.q5, payload.q6,
+                                payload.q7, payload.q8, payload.q9, payload.q10, payload.q11, payload.q12,
+                                payload.q13, payload.q14, payload.q15, payload.q16]]}
+            result = self.service.spreadsheets().values().append(
+                spreadsheetId=settings.SPREADSHEET_ID,
+                range=DATA_RANGE,
+                valueInputOption="RAW",
+                insertDataOption="INSERT_ROWS",
+                body=body,
+            ).execute()
+            return result
+        except Exception as e:
+            return {"error": str(e)}

requirements.txt

@@ -2,33 +2,49 @@ annotated-types==0.7.0
 anyio==4.10.0
 bcrypt==4.3.0
 beanie==2.0.0
+cachetools==6.2.2
 certifi==2025.8.3
 cffi==2.0.0
+charset-normalizer==3.4.4
 click==8.2.1
 cryptography==45.0.7
 dnspython==2.8.0
 ecdsa==0.19.1
 email-validator==2.3.0
 fastapi==0.116.1
+google-api-core==2.28.1
+google-api-python-client==2.187.0
+google-auth==2.41.1
+google-auth-httplib2==0.2.1
+google-auth-oauthlib==1.2.3
+googleapis-common-protos==1.72.0
 h11==0.16.0
 httpcore==1.0.9
+httplib2==0.31.0
 httptools==0.6.4
 httpx==0.28.1
 idna==3.10
 lazy-model==0.3.0
 motor==3.7.1
+oauthlib==3.3.1
 passlib==1.7.4
+proto-plus==1.26.1
+protobuf==6.33.2
 pyasn1==0.6.1
+pyasn1_modules==0.4.2
 pycparser==2.23
 pydantic==2.11.9
 pydantic-settings==2.10.1
 pydantic_core==2.33.2
 PyJWT==2.10.1
 pymongo==4.15.0
+pyparsing==3.2.5
 python-dotenv==1.1.1
 python-jose==3.5.0
 python-multipart==0.0.20
 PyYAML==6.0.2
+requests==2.32.5
+requests-oauthlib==2.0.0
 rsa==4.9.1
 six==1.17.0
 sniffio==1.3.1
@@ -36,6 +52,8 @@ sse-starlette==3.0.2
 starlette==0.47.3
 typing-inspection==0.4.1
 typing_extensions==4.15.0
+uritemplate==4.2.0
+urllib3==2.6.1
 uvicorn==0.35.0
 uvloop==0.21.0
 watchfiles==1.1.0