ini

.gitattributes copy

@@ -0,0 +1,35 @@
+*.7z filter=lfs diff=lfs merge=lfs -text
+*.arrow filter=lfs diff=lfs merge=lfs -text
+*.bin filter=lfs diff=lfs merge=lfs -text
+*.bz2 filter=lfs diff=lfs merge=lfs -text
+*.ckpt filter=lfs diff=lfs merge=lfs -text
+*.ftz filter=lfs diff=lfs merge=lfs -text
+*.gz filter=lfs diff=lfs merge=lfs -text
+*.h5 filter=lfs diff=lfs merge=lfs -text
+*.joblib filter=lfs diff=lfs merge=lfs -text
+*.lfs.* filter=lfs diff=lfs merge=lfs -text
+*.mlmodel filter=lfs diff=lfs merge=lfs -text
+*.model filter=lfs diff=lfs merge=lfs -text
+*.msgpack filter=lfs diff=lfs merge=lfs -text
+*.npy filter=lfs diff=lfs merge=lfs -text
+*.npz filter=lfs diff=lfs merge=lfs -text
+*.onnx filter=lfs diff=lfs merge=lfs -text
+*.ot filter=lfs diff=lfs merge=lfs -text
+*.parquet filter=lfs diff=lfs merge=lfs -text
+*.pb filter=lfs diff=lfs merge=lfs -text
+*.pickle filter=lfs diff=lfs merge=lfs -text
+*.pkl filter=lfs diff=lfs merge=lfs -text
+*.pt filter=lfs diff=lfs merge=lfs -text
+*.pth filter=lfs diff=lfs merge=lfs -text
+*.rar filter=lfs diff=lfs merge=lfs -text
+*.safetensors filter=lfs diff=lfs merge=lfs -text
+saved_model/**/* filter=lfs diff=lfs merge=lfs -text
+*.tar.* filter=lfs diff=lfs merge=lfs -text
+*.tar filter=lfs diff=lfs merge=lfs -text
+*.tflite filter=lfs diff=lfs merge=lfs -text
+*.tgz filter=lfs diff=lfs merge=lfs -text
+*.wasm filter=lfs diff=lfs merge=lfs -text
+*.xz filter=lfs diff=lfs merge=lfs -text
+*.zip filter=lfs diff=lfs merge=lfs -text
+*.zst filter=lfs diff=lfs merge=lfs -text
+*tfevents* filter=lfs diff=lfs merge=lfs -text

Dockerfile

@@ -0,0 +1,13 @@
+FROM python:3.9
+
+WORKDIR /
+
+# Copy requirements.txt and install dependencies
+COPY ./requirements.txt /requirements.txt
+RUN pip install --no-cache-dir --upgrade -r /requirements.txt
+
+# Copy the rest of the application files
+COPY . .
+
+# Run the application
+CMD ["uvicorn", "app:app", "--host", "0.0.0.0", "--port", "7860"]

Drive_API.pickle

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:39f1df70fd5fc1ab84982447bb71d5501ce5d18ca9e5e7ea3db807b894b129d9
+size 968

README copy.md

@@ -0,0 +1,10 @@
+---
+title: Repetitive Backend
+emoji: 📈
+colorFrom: red
+colorTo: red
+sdk: docker
+pinned: false
+---
+
+Check out the configuration reference at https://huggingface.co/docs/hub/spaces-config-reference

api_connection/apiConnection.py

@@ -0,0 +1,63 @@
+import pickle
+import os
+import datetime
+from google_auth_oauthlib.flow import Flow, InstalledAppFlow
+from googleapiclient.discovery import build
+from googleapiclient.http import MediaFileUpload, MediaIoBaseDownload
+from google.auth.transport.requests import Request
+
+
+def token_file_exists(prefix="token_"):
+    files = os.listdir()
+    for file in files:
+        if file.startswith(prefix):
+            return True
+
+    return False
+
+def Create_Service(client_secret_file, api_name, api_version, *scopes):
+    CLIENT_SECRET_FILE = client_secret_file
+    API_SERVICE_NAME = api_name
+    API_VERSION = api_version
+    SCOPES = [scope for scope in scopes[0]]
+
+    cred = None
+    pickle_file = f'token_{API_SERVICE_NAME}_{API_VERSION}.pickle'
+
+    if os.path.exists(pickle_file):
+        with open(pickle_file, 'rb') as token:
+            cred = pickle.load(token)
+
+    if not cred or not cred.valid:
+        if cred and cred.expired and cred.refresh_token:
+            cred.refresh(Request())
+        else:
+            flow = InstalledAppFlow.from_client_secrets_file(CLIENT_SECRET_FILE, SCOPES)
+            cred = flow.run_local_server()
+
+        with open(pickle_file, 'wb') as token:
+            pickle.dump(cred, token)
+
+    try:
+        service = build(API_SERVICE_NAME, API_VERSION, credentials=cred)
+        return service
+    except Exception as e:
+        print('Unable to connect.')
+        print(e)
+        return None
+
+def convert_to_RFC_datetime(year=1900, month=1, day=1, hour=0, minute=0):
+    dt = datetime.datetime(year, month, day, hour, minute, 0).isoformat() + 'Z'
+    return dt
+
+import os
+def removeAccount():
+    directory = os.getcwd()
+    files = os.listdir(directory)
+    for file in files:
+        if "token" in file:
+            try:
+                os.remove(os.path.join(directory, file))
+                print(f"File '{file}' deleted successfully.")
+            except Exception as e:
+                print(f"Error deleting file '{file}': {e}")

app.py

@@ -0,0 +1,250 @@
+from fastapi import FastAPI
+import uvicorn
+from fastapi.middleware.cors import CORSMiddleware
+from fastapi import FastAPI, File, UploadFile, HTTPException
+from fastapi.responses import JSONResponse
+from typing import Annotated
+import os
+import shutil
+from typing import List
+from pydantic import BaseModel
+from api_connection.apiConnection import Create_Service
+from comparator.report import (
+    AddReport,
+    CheckFolders,
+    DeleteReport,
+)
+import json
+import asyncio
+from concurrent.futures import ThreadPoolExecutor
+from api_connection.apiConnection import token_file_exists
+from comparator.summerized import AddSummary, DeleteSummary, Get_All_Reports
+
+from api_connection.apiConnection import removeAccount
+import uuid
+from comparator.text_summerizer.summerize2 import Summerized_Text
+from comparator.extract.extract import extract_text_from_pdf
+
+from comparator.compareSummerized import compareText
+
+from token_operation.driveToken import Delete_Drive_Token, Create_Drive_Token
+from token_operation.tokenOperation import Create_Token_Drive, Delete_Token_File, Expire_Token_File
+
+from pydantic import BaseModel
+class AccountInfo(BaseModel):
+    oldName: str
+    newName: str
+
+
+"""
+Folder Path in drive would be:
+    Fake/reports
+    Fake/summerized
+    
+"""
+
+class IDRequest(BaseModel):
+    ids: List[str]
+
+global API_VERSION, CLIENT_FILE_NAME, API_DRIVE, SCOPES 
+CLIENT_FILE_NAME = "./client_secret.json"
+API_DRIVE = "drive"
+API_VERSION = "v3"
+SCOPES = ["https://www.googleapis.com/auth/drive"]
+
+app = FastAPI(docs_url="/api/docs", openapi_url="/api/openapi.json")
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+class AccountCheck(BaseModel):
+    name: str
+
+@app.post("/api/isLogin")
+async def is_login(request: AccountCheck):
+    try:
+        global services
+        services, name = Create_Token_Drive(request.name)
+        if services:
+            return {"message": "Successfully logged in", "data": name, "status":"success"}
+        else:
+            return {"message": "Failed to login", "data": False, "status":"failed"}
+    except Exception as e:
+        print(f"An error occurred: {e}")
+        return {"message": "Failed to login", "data": False, "status":"failed"}
+    
+@app.get("/api/check-working")
+def check_working():
+    return {"message": "Message working Successfully",  "status":"success"}
+
+async def process_file(file):
+    try:
+        summerized_id = str(uuid.uuid4())
+        file_contents = await file.read()
+        directory = "./delete"
+        os.makedirs(directory, exist_ok=True) 
+        path = os.path.join(directory, file.filename) 
+        path = f"./delete/{file.filename}"
+        with open(path, "wb") as f:
+            f.write(file_contents)
+        text = extract_text_from_pdf(path)
+        summary = Summerized_Text(text)
+        report_id = AddReport(services, summerized_id, path)
+        AddSummary(
+            services,
+            {
+                "id": summerized_id,
+                "project": "",
+                "summary": summary,
+                "drive": f"https://drive.google.com/file/d/{report_id}/view?usp=sharing",
+                "year": "2023",
+                "category": ["wanna check"],
+            },
+        )
+        os.remove(path)
+        return {
+            "message": f"Successfully added Report and Summary for {file.filename}",
+            "data": {
+                "id": summerized_id,
+                "compare": "",
+                "title": "",
+                "summary": summary,
+                "drive": f"https://drive.google.com/file/d/{report_id}/view?usp=sharing",
+                "year": "2023",
+                "category": ["wanna check"],
+            },
+            "success": True,
+        }
+    except Exception as e:
+        return {
+            "message": f"Error processing {file.filename}: {str(e)}",
+            "status": "failed",
+        }
+
+@app.post("/api/upload")
+async def upload_files(files: List[UploadFile] = File(...)):
+    try:
+        loop = asyncio.get_event_loop()
+        with ThreadPoolExecutor() as pool:
+            responses = await asyncio.gather(*[loop.run_in_executor(pool, process_file, file) for file in files])
+        print("Uploaded Successfully")
+        return {"data": [await response for response in responses], "status": "success"}
+    except Exception as e:
+        print(f"An error occurred: {str(e)}")
+        return {"message": "Failed to Upload files", "data": False, "status": "failed"}
+    
+
+@app.post("/api/delete")
+async def delete_files(request: IDRequest):
+    try:
+        for report_name in request.ids:
+            DeleteSummary(services, report_name)
+            DeleteReport(services, report_name)
+            try:
+                directory = "."
+                for filename in os.listdir(directory):
+                    if filename.startswith("data-"):
+                        file_path = "./" + filename
+                        os.remove(file_path)
+            except Exception as e:
+                print(f"An error occurred: {str(e)}")
+        return {"message": "Successfully Deleted Summary and Report", "success": True}
+    except Exception as e:
+        print(f"An error occurred: {str(e)}")
+        return {"message": "Failed to login", "data": False, "status":"failed"}
+
+
+
+@app.post("/api/logout")
+async def delete_account(request: AccountInfo):
+    try:
+        Delete_Token_File(request.oldName)
+        global services  
+        services, name = Create_Token_Drive(request.newName)
+        return {"message": "Successfully Deleted Account", "data": name, "success": True}
+    except Exception as e:
+        print(f"An error occurred: {str(e)}")
+        return {"message": "Failed to login", "data": False, "status":"failed"}
+
+
+@app.get("/api/getReports")
+async def get_reports():
+    try:
+        data = Get_All_Reports(services)
+        if len(data) == 0:
+            return {"data": None, "status": "failed" }
+        try:
+            directory = "."
+            for filename in os.listdir(directory):
+                if filename.startswith("data-"):
+                    file_path = "./" + filename
+                    os.remove(file_path)
+        except Exception as e:
+            print(f"An error occurred: {str(e)}")
+        return {"data": data, "success": True}
+    except Exception as e:
+        print(f"An error occurred: {str(e)}")
+        return {"message": "Failed to login", "data": False, "status":"failed"}
+
+
+
+@app.post("/api/compare")
+async def compare(file: UploadFile = File(...)):
+    try:
+        CheckFolders(services)
+        summerized_id = str(uuid.uuid4())
+        file_contents = await file.read()
+        path = f"./delete/{file.filename}"
+        with open(path, "wb") as f:
+            f.write(file_contents)
+        text = extract_text_from_pdf(path)
+        summary = Summerized_Text(text)
+        path = f"./delete/{file.filename}"
+        with open(path, "wb") as f:
+            f.write(file_contents)
+        data = compareText(services, summary)
+        try:
+            directory = "."
+            for filename in os.listdir(directory):
+                if filename.startswith("data-"):
+                    file_path = "./" + filename
+                    os.remove(file_path)
+                if filename.startswith("delete"):
+                    file_path = path
+                    os.remove(file_path)
+        except Exception as e:
+            print(f"An error occurred: {str(e)}")
+        return {"summary": summary, "data": data, "success": True}
+    except Exception as e:
+        print(f"An error occurred: {str(e)}")
+        return {"message": "Failed to login", "data": False, "status":"failed"}
+
+@app.get("/api/Check-Expired")
+async def checkExpired():
+    try:
+        Expire_Token_File()
+        return {"message": "Successfully Expired", "status": "success"}
+    except Exception as e:
+        print(f"An error occurred: {str(e)}")
+        return {"message": "Failed to Check Expired Tokens", "data": False, "status":"failed"}
+
+
+@app.post("/api/New-Drive")
+async def NewDrive():
+    try:
+        Delete_Drive_Token()
+        Create_Drive_Token()
+        return {"message": "Successfully Created a new drive", "status": "success"}
+    except Exception as e:
+        print(f"An error occurred: {str(e)}")
+        return {"message": "Failed to login", "data": False, "status":"failed"}
+
+
+if __name__ == "__main__":
+    global services
+    Create_Drive_Token()
+    uvicorn.run(app, host="0.0.0.0", port=8000)
+

client_secret.json

@@ -0,0 +1,11 @@
+{
+  "\u0069\u006e\u0073\u0074\u0061\u006c\u006c\u0065\u0064": {
+    "\u0063\u006c\u0069\u0065\u006e\u0074\u005f\u0069\u0064": "\u0034\u0039\u0032\u0037\u0037\u0030\u0030\u0035\u0039\u0031\u0039\u0037\u002d\u0034\u006e\u0071\u006c\u006e\u0037\u0034\u0035\u0034\u0076\u0034\u0035\u0038\u0073\u0033\u006f\u006f\u0039\u0074\u006e\u006a\u0061\u006d\u0067\u0064\u0039\u006f\u0067\u0068\u0068\u0035\u006f\u002e\u0061\u0070\u0070\u0073\u002e\u0067\u006f\u006f\u0067\u006c\u0065\u0075\u0073\u0065\u0072\u0063\u006f\u006e\u0074\u0065\u006e\u0074\u002e\u0063\u006f\u006d",
+    "\u0070\u0072\u006f\u006a\u0065\u0063\u0074\u005f\u0069\u0064": "\u0072\u0065\u0070\u0065\u0074\u0061\u0074\u0069\u0076\u0065",
+    "\u0061\u0075\u0074\u0068\u005f\u0075\u0072\u0069": "\u0068\u0074\u0074\u0070\u0073\u003a\u002f\u002f\u0061\u0063\u0063\u006f\u0075\u006e\u0074\u0073\u002e\u0067\u006f\u006f\u0067\u006c\u0065\u002e\u0063\u006f\u006d\u002f\u006f\u002f\u006f\u0061\u0075\u0074\u0068\u0032\u002f\u0061\u0075\u0074\u0068",
+    "\u0074\u006f\u006b\u0065\u006e\u005f\u0075\u0072\u0069": "\u0068\u0074\u0074\u0070\u0073\u003a\u002f\u002f\u006f\u0061\u0075\u0074\u0068\u0032\u002e\u0067\u006f\u006f\u0067\u006c\u0065\u0061\u0070\u0069\u0073\u002e\u0063\u006f\u006d\u002f\u0074\u006f\u006b\u0065\u006e",
+    "\u0061\u0075\u0074\u0068\u005f\u0070\u0072\u006f\u0076\u0069\u0064\u0065\u0072\u005f\u0078\u0035\u0030\u0039\u005f\u0063\u0065\u0072\u0074\u005f\u0075\u0072\u006c": "\u0068\u0074\u0074\u0070\u0073\u003a\u002f\u002f\u0077\u0077\u0077\u002e\u0067\u006f\u006f\u0067\u006c\u0065\u0061\u0070\u0069\u0073\u002e\u0063\u006f\u006d\u002f\u006f\u0061\u0075\u0074\u0068\u0032\u002f\u0076\u0031\u002f\u0063\u0065\u0072\u0074\u0073",
+    "\u0063\u006c\u0069\u0065\u006e\u0074\u005f\u0073\u0065\u0063\u0072\u0065\u0074": "\u0047\u004f\u0043\u0053\u0050\u0058\u002d\u0043\u0061\u0059\u0070\u004f\u0074\u0046\u0047\u0056\u006c\u0066\u007a\u0042\u006f\u002d\u0063\u0036\u0079\u0062\u0039\u006c\u0059\u004e\u006a\u0039\u0067\u0074\u0064",
+    "\u0072\u0065\u0064\u0069\u0072\u0065\u0063\u0074\u005f\u0075\u0072\u0069\u0073": ["\u0068\u0074\u0074\u0070\u003a\u002f\u002f\u006c\u006f\u0063\u0061\u006c\u0068\u006f\u0073\u0074"]
+  }
+}

comparator/compareSummerized.py

@@ -0,0 +1,58 @@
+from googleapiclient.http import MediaFileUpload, MediaIoBaseUpload
+import json
+import os
+from io import BytesIO
+import time
+import io
+from comparator.report import checkRespectiveFolder
+from comparator.compare_model.compare import compare
+def get_compare_value(report):
+    return report["compare"]
+
+def compareText(service, summary):
+    try:
+        fake_folder_id = checkRespectiveFolder(service)
+        result_folder_id = checkRespectiveFolder(
+            service, path=fake_folder_id, Folder_Name="Result"
+        )
+        response = (
+            service.files()
+            .list(
+                q="name contains 'data-'",
+                spaces="drive",
+                fields="files(id, name)",
+            )
+            .execute()
+        )
+        list_all_files = response.get("files", [])
+        all_reports = []
+
+        for list_files in list_all_files:
+            if list_files["name"].startswith("data-"):
+                latest_file_id = str(list_files["id"])
+
+                existing_data = (
+                    service.files().get_media(fileId=latest_file_id).execute()
+                )
+                existing_details = json.loads(existing_data.decode("utf-8"))
+                file_name = list_files["name"]
+
+                for json_data in existing_details:
+                    print(summary)
+                    value = compare(summary, json_data["summary"])
+                    all_reports.append(
+                        {
+                            "id": json_data["id"],
+                            "year": json_data["year"],
+                            "drive": json_data["drive"],
+                            "summary": json_data["summary"],
+                            "category": json_data["category"],
+                            "title": "",
+                            "compare": value,
+                        }
+                    )
+        sorted_reports = sorted(all_reports, key=get_compare_value, reverse=True)
+        return sorted_reports
+
+    except Exception as e:
+        print(f"An error occurred: {str(e)}")

comparator/compare_model/compare.py

@@ -0,0 +1,42 @@
+from transformers import AutoTokenizer, AutoModel
+import torch
+import torch.nn.functional as F
+
+
+def mean_pooling(model_output, attention_mask):
+    token_embeddings = model_output[
+        0
+    ] 
+    input_mask_expanded = (
+        attention_mask.unsqueeze(-1).expand(token_embeddings.size()).float()
+    )
+    return torch.sum(token_embeddings * input_mask_expanded, 1) / torch.clamp(
+        input_mask_expanded.sum(1), min=1e-9
+    )
+
+def cosine_similarity(u, v):
+    return F.cosine_similarity(u, v, dim=1)
+
+
+def compare(text1, text2):
+
+    sentences = [text1, text2]
+
+    tokenizer = AutoTokenizer.from_pretrained("dmlls/all-mpnet-base-v2-negation")
+    model = AutoModel.from_pretrained("dmlls/all-mpnet-base-v2-negation")
+
+    encoded_input = tokenizer(
+        sentences, padding=True, truncation=True, return_tensors="pt"
+    )
+
+    with torch.no_grad():
+        model_output = model(**encoded_input)
+
+    sentence_embeddings = mean_pooling(model_output, encoded_input["attention_mask"])
+
+    sentence_embeddings = F.normalize(sentence_embeddings, p=2, dim=1)
+
+    similarity_score = cosine_similarity(
+        sentence_embeddings[0].unsqueeze(0), sentence_embeddings[1].unsqueeze(0)
+    )
+    return similarity_score.item()

comparator/compare_model/compare2.py

@@ -0,0 +1,25 @@
+from sentence_transformers import SentenceTransformer
+
+# sentences = [
+#     "I like rainy days because they make me feel relaxed.",
+#     "I don't like rainy days because they don't make me feel relaxed."
+# ]
+
+# model = SentenceTransformer('dmlls/all-mpnet-base-v2-negation')
+# embeddings = model.encode(sentences)
+# from sklearn.metrics.pairwise import cosine_similarity
+
+# similarity_score = cosine_similarity([embeddings[0]], [embeddings[1]])[0][0]
+# similarity = (similarity_score + 1) / 2 
+
+# print("Similarity:", similarity)
+
+def checkSimilarity(text1, text2):
+    model = SentenceTransformer('dmlls/all-mpnet-base-v2-negation')
+    embeddings = model.encode([text1, text2])
+    from sklearn.metrics.pairwise import cosine_similarity
+
+    similarity_score = cosine_similarity([embeddings[0]], [embeddings[1]])[0][0]
+    similarity = (similarity_score + 1) / 2 
+
+    return similarity

comparator/extract/extract.py

@@ -0,0 +1,58 @@
+import PyPDF2
+from PIL import Image
+import pytesseract
+import io
+import sys
+
+
+# def extract_text(file_path, output_file_path):
+#     text = ""
+#     try:
+#         if file_path.lower().endswith(".pdf"):
+#             text = extract_text_from_pdf(file_path)
+#         else:
+#             print("Unsupported file format")
+
+#         with open(output_file_path, "w") as output_file:
+#             print("Run output")
+#             for line in text.splitlines():
+#                 print(line)
+#             output_file.write(text)
+#         print(f"Extracted text saved to {output_file_path}")
+
+#     except Exception as e:
+#         print("An error occurred:", e)
+
+
+# def extract_text_from_image(file_path):
+#     image_path = file_path
+#     img = Image.open(image_path)
+#     text = pytesseract.image_to_string(img)
+#     print(text[:-1])
+
+
+import PyPDF2
+
+def extract_text_from_pdf(pdf_file_path):
+    extracted_text = ""
+    try:
+        with open(pdf_file_path, "rb") as file:
+            pdf_reader = PyPDF2.PdfReader(file)
+            num_pages = len(pdf_reader.pages)
+            for i in range(num_pages):
+                page = pdf_reader.pages[i]
+                page_text = page.extract_text()
+                if "ABSTRACT" in page_text:
+                    extracted_text += page_text + "\n"
+                    break
+        return extracted_text
+    except Exception as e:
+        print("An error occurred:", e)
+        return None
+
+# if __name__ == "__main__":
+#     import PyPDF2
+
+#     file_path = "./report.pdf"
+#     output_file_path = "./extracted_text.txt"
+#     extract_text_from_pdf(file_path, output_file_path)

comparator/report.py

@@ -0,0 +1,128 @@
+from googleapiclient.http import MediaFileUpload, MediaIoBaseUpload
+import json
+import os
+from io import BytesIO
+import time
+import io
+
+file_metadata = {
+    "name": "Fake",
+    "mimeType": "application/vnd.google-apps.folder",
+}
+file_result = {
+    "name": "Result",
+    "mimeType": "application/vnd.google-apps.folder",
+}
+file_report = {
+    "name": "Report",
+    "mimeType": "application/vnd.google-apps.folder",
+}
+
+
+def checkFake(service, path="root", Folder_Name="Fake"):
+    resource = service.files()
+    result = resource.list(
+        q=f"mimeType = 'application/vnd.google-apps.folder' and '{path}' in parents",
+        fields="nextPageToken, files(id, name)",
+    ).execute()
+    list_folders = result.get("files")
+    fake_folder_id = None
+    result_folder_id = None
+    report_folder_id = None
+
+    for folder in list_folders:
+        if folder["name"] == Folder_Name:
+            fake_folder_id = folder["id"]
+            break
+
+    if not fake_folder_id:
+        fake_folder = service.files().create(body=file_metadata, fields="id").execute()
+        fake_folder_id = fake_folder["id"]
+        result_folder = (
+            service.files()
+            .create(
+                body={
+                    "name": "Result",
+                    "mimeType": "application/vnd.google-apps.folder",
+                    "parents": [fake_folder_id],
+                    "type": "anyone",
+                    "role": "reader",
+                },
+                fields="id",
+            )
+            .execute()
+        )
+        result_folder_id = result_folder["id"]
+
+        report_folder = (
+            service.files()
+            .create(
+                body={
+                    "name": "Report",
+                    "mimeType": "application/vnd.google-apps.folder",
+                    "parents": [fake_folder_id],
+                },
+                fields="id",
+            )
+            .execute()
+        )
+        report_folder_id = report_folder["id"]
+
+    return fake_folder_id, result_folder_id, report_folder_id
+
+
+def checkRespectiveFolder(service, path="root", Folder_Name="Fake"):
+    resource = service.files()
+    result = resource.list(
+        q=f"mimeType = 'application/vnd.google-apps.folder' and '{path}' in parents",
+        fields="nextPageToken, files(id, name)",
+    ).execute()
+    list_folders = result.get("files")
+    fake_folder_id = None
+    for folder in list_folders:
+        if folder["name"] == Folder_Name:
+            fake_folder_id = folder["id"]
+            break
+    return fake_folder_id
+
+
+def CheckFolders(service):
+    fake_folder_id = checkFake(service)
+    return "Folders created or already existed."
+
+def AddReport(service, fileName, file):
+    fake_folder_id = checkRespectiveFolder(service)
+    report_folder_id = checkRespectiveFolder(
+        service, path=fake_folder_id, Folder_Name="Report"
+    )
+
+    file_metadata = {"name": fileName, "parents": [report_folder_id]}
+    media = MediaFileUpload(file, mimetype="application/pdf")
+    newFile = (
+        service.files()
+        .create(body=file_metadata, media_body=media, fields="id")
+        .execute()
+    )
+    return newFile.get("id")
+
+def DeleteReport(service, fileName):
+    fake_folder_id = checkRespectiveFolder(service)
+    report_folder_id = checkRespectiveFolder(
+        service, path=fake_folder_id, Folder_Name="Report"
+    )
+    response = (
+        service.files()
+        .list(
+            q="mimeType='application/pdf' and '" + report_folder_id + "' in parents",
+            spaces="drive",
+            fields="files(id, name)",
+            pageToken=None,
+        )
+        .execute()
+    )
+    for i in response["files"]:
+        if i["name"] == fileName:
+            file_id = i["id"]
+            service.files().delete(fileId=file_id).execute()
+            break
+

comparator/summerized.py

@@ -0,0 +1,165 @@
+from googleapiclient.http import MediaFileUpload, MediaIoBaseUpload
+import json
+import os
+from io import BytesIO
+import time
+import io
+from comparator.report import checkRespectiveFolder
+
+
+def DeleteSummary(service, fileID):
+    try:
+        fake_folder_id = checkRespectiveFolder(service)
+        result_folder_id = checkRespectiveFolder(
+            service, path=fake_folder_id, Folder_Name="Result"
+        )
+        response = (
+            service.files()
+            .list(
+                q="name contains 'data-'",
+                spaces="drive",
+                fields="files(id, name)",
+            )
+            .execute()
+        )
+        list_all_files = response.get("files", [])
+
+        for list_files in list_all_files:
+            if list_files["name"].startswith("data-"):
+                latest_file_id = list_files["id"]
+
+                existing_data = (
+                    service.files().get_media(fileId=latest_file_id).execute()
+                )
+                existing_details = json.loads(existing_data.decode("utf-8"))
+
+                updated_data = [
+                    data for data in existing_details if data["id"] != fileID
+                ]
+
+                with open(list_files["name"], "w", encoding="utf-8") as json_file:
+                    json.dump(updated_data, json_file, ensure_ascii=False)
+
+                media = MediaFileUpload(list_files["name"], mimetype="application/json")
+
+                service.files().update(
+                    fileId=latest_file_id, media_body=media
+                ).execute()
+                return
+        return
+    except Exception as e:
+        print(f"An error occurred: {str(e)}")
+
+
+def AddSummary(service, details):
+    try:
+        fake_folder_id = checkRespectiveFolder(service)
+        result_folder_id = checkRespectiveFolder(
+            service, path=fake_folder_id, Folder_Name="Result"
+        )
+        response = (
+            service.files()
+            .list(
+                q="name contains 'data-'",
+                spaces="drive",
+                fields="files(id, name)",
+            )
+            .execute()
+        )
+        list_all_files = response.get("files", [])  
+
+        is_selected = False
+        file_name = ""
+
+        for list_files in list_all_files:
+            if list_files["name"].startswith("data-"):
+                latest_file_id = str(list_files["id"])
+
+                existing_data = service.files().get_media(fileId=latest_file_id).execute()
+
+                if existing_data:  
+                    existing_details = json.loads(existing_data.decode("utf-8"))
+
+                    with open(list_files["name"], "w", encoding="utf-8") as json_file:
+                        json.dump(existing_details, json_file, ensure_ascii=False)
+
+                    if len(existing_details) < 100:
+                        is_selected = True
+                        file_name = list_files["name"]
+
+                        with open(file_name, "r", encoding="utf-8") as json_file:
+                            existing_data = json.load(json_file)
+
+                        existing_data.append(details)
+
+                        with open(file_name, "w", encoding="utf-8") as json_file:
+                            json.dump(existing_data, json_file)
+
+                        json_file.close()
+
+                        file_metadata = {"name": file_name, "parents": [result_folder_id]}
+                        media = MediaFileUpload(file_name, mimetype="application/json")
+
+                        service.files().update(fileId=latest_file_id, media_body=media).execute()
+
+                        return
+            else:
+                break
+
+        if not is_selected:
+            existing_details = [details]
+            file_name = f"data-{len(list_all_files)}.json"
+            json_data = json.dumps(existing_details)
+            with open(file_name, "w") as f:
+                f.write(json_data)
+            file_metadata = {"name": file_name, "parents": [result_folder_id]}
+            media = MediaFileUpload(
+                file_name, mimetype="application/json", resumable=True
+            )
+            service.files().create(
+                body=file_metadata, media_body=media, fields="id"
+            ).execute()
+            return
+
+    except Exception as e:
+        print(f"An error occurred here: {str(e)}")
+        
+def Get_All_Reports(service):
+    try:
+        fake_folder_id = checkRespectiveFolder(service)
+        result_folder_id = checkRespectiveFolder(
+            service, path=fake_folder_id, Folder_Name="Result"
+        )
+        response = (
+            service.files()
+            .list(
+                q="name contains 'data-'",
+                spaces="drive",
+                fields="files(id, name)",
+            )
+            .execute()
+        )
+        list_all_files = response["files"]
+        all_reports = []
+        
+        for list_files in list_all_files:
+            if list_files["name"].startswith("data-"):
+                latest_file_id = str(list_files["id"])
+
+                existing_data = (
+                    service.files().get_media(fileId=latest_file_id).execute()
+                )
+                existing_details = json.loads(existing_data.decode("utf-8"))
+                file_name = list_files["name"]
+
+                with open(file_name, "w", encoding="utf-8") as json_file:
+                    json.dump(existing_details, json_file, ensure_ascii=False)
+
+                with open(file_name, "r", encoding="utf-8") as json_file:
+                    existing_data = json.load(json_file)
+
+                all_reports.extend(existing_details)
+        return all_reports
+
+    except Exception as e:
+        print(f"An error occurred: {str(e)}")

comparator/text_summerizer/summerize2.py

@@ -0,0 +1,27 @@
+from transformers import pipeline
+
+summarizer = pipeline("summarization", model="facebook/bart-large-cnn")
+
+ARTICLE = """Parkinson’s disease (PD) is one of the long-term regressive disorders of the central nervous
+system that mainly affects the nervous system in humans due to which there is the recurrent
+occurrence of falls which might even lead to death or put them in a serious situation. For
+solving this issue,  we have proposed an idea that detects patient fall and reports to the
+caretaker or family member utilizing message/call/Alarm thereby avoiding deaths. Our
+work focuses on developing and apply the wearable fall -detection system for Parkinson’s
+disease long -suffers formed on a Wi -Fi module. Patient falls were precisely traced on the
+outcome of an accelerometer, oximeter, and pressure sensors which were sent to the cloud
+via NodeMCU -ESP32. Furthermore, Node MCU ESP32 is planned for attaining smooth
+communicat ion between the fall detection device and the system for obtaining and
+processing the data anytime and anywhere until we have a Wi -Fi connection. In
+consequence, the cloud will perform the calculations based on SVM which is the Support
+Vector Machine. In t urn, it sends the fall detection outcomes to the MIT application. This
+WFDS turns out to be the best among the existing models in terms of fall detection
+sensitivity, specificity, and accuracy. The fall of direction in PD can be performed
+accurately based on the fall detection algorithm at the receiver end. The preliminary
+outcomes show that the wearable fall -detection system attains eighty -. eight percent
+accuracy in identifying the patient’s fall."""
+
+def Summerized_Text(text):
+    text = text.strip()
+    a = summarizer(text, max_length=130, min_length=30, do_sample=False)
+    return a[0]['summary_text']

repetitive-project-backend

@@ -0,0 +1 @@
+Subproject commit 02e651a414b44be04759eb6cb0336417e3dcb782

requirements.txt

@@ -0,0 +1,15 @@
+fastapi==0.70.0
+uvicorn==0.15.0
+google-auth==2.29.0
+google-auth-oauthlib==1.2.0
+google-api-python-client==2.125.0
+transformers==4.39.3
+tensorflow==2.13.1
+torch==2.2.2
+torchvision==0.17.2
+torchaudio==2.2.2
+PyPDF2==3.0.1
+pytesseract==0.3.10
+sentence-transformers==2.6.1
+python-multipart
+asyncio

token_json.json

@@ -0,0 +1 @@
+{"01d63f7d-ec01-4ab9-a4c2-865039408b18": {"token_name": "01d63f7d-ec01-4ab9-a4c2-865039408b18", "token_file_id": "12C8dbqBSg-tgMFLzPHiUBtmc0ZNmWI9N", "expires_at": "2024-04-21T06:37:55Z"}, "91030212-6d4b-4a3a-b07c-7a9af8eb4b3f": {"token_name": "91030212-6d4b-4a3a-b07c-7a9af8eb4b3f", "token_file_id": "1dWn--JJA4CNjANuBguBUucwW5bFVc4VR", "expires_at": "2024-04-21T06:38:19Z"}, "a033f0d9-c4d4-41a4-8345-cd1f51666e11": {"token_name": "a033f0d9-c4d4-41a4-8345-cd1f51666e11", "token_file_id": "1ybgR3Pyo5IGkeY7fylqi6bwZiJBLCWO-", "expires_at": "2024-04-21T07:01:15Z"}, "c578af4e-a61d-4ebc-925a-9eca1656fecf": {"token_name": "c578af4e-a61d-4ebc-925a-9eca1656fecf", "token_file_id": "1f3Nf_jyhFGF2hChWr3aATvwBh49Nfgxq", "expires_at": "2024-04-21T07:01:43Z"}, "e6e7141c-850f-41de-9cf7-8db123ea48b5": {"token_name": "e6e7141c-850f-41de-9cf7-8db123ea48b5", "token_file_id": "1FVKdEeN6onZA7ppJys5VL7ozXCw_CaGu", "expires_at": "2024-04-21T16:21:48Z"}, "a394423a-b49a-45f1-8d96-eed459d2a0ce": {"token_name": "a394423a-b49a-45f1-8d96-eed459d2a0ce", "token_file_id": "1IgXKi83S540F-ihq_5OWKLSmdp1xxwMu", "expires_at": "2024-04-21T16:34:09Z"}, "e8ebc7f1-12eb-461e-83c3-69e55d4fea8a": {"token_name": "e8ebc7f1-12eb-461e-83c3-69e55d4fea8a", "token_file_id": "1bGb8kdKr4EKjlLEMQcs_2F4HaNNtJkw6", "expires_at": "2024-04-21T16:34:38Z"}, "a375311a-0779-4199-9f9c-e8b7a665994c": {"token_name": "a375311a-0779-4199-9f9c-e8b7a665994c", "token_file_id": "1jBmcxhAOTrqvarFQ8zeNDmGI80noSDhv", "expires_at": "2024-04-21T17:48:42Z"}, "95b533d6-1d5c-4852-945f-578130d939b6": {"token_name": "95b533d6-1d5c-4852-945f-578130d939b6", "token_file_id": "19q-zGO5uBAtAknF-pvFTyqp03nT1eV6p", "expires_at": "2024-04-22T19:02:29Z"}, "96779b9b-4dbb-4136-a263-b5bf3f06f5cd": {"token_name": "96779b9b-4dbb-4136-a263-b5bf3f06f5cd", "token_file_id": "1t_HU7LuO2XtrQk_GSCgC0ZdyHwLCk-Lm", "expires_at": "2024-04-23T05:54:21Z"}, "7debcd64-c89b-44a7-ae74-da3af4201d33": {"token_name": "7debcd64-c89b-44a7-ae74-da3af4201d33", "token_file_id": "18EZlC41-hz1eNy_EtImVXz2mOYPrE9fH", "expires_at": "2024-04-23T22:19:22Z"}}

token_operation/client_secret.json

@@ -0,0 +1,11 @@
+{
+  "\u0069\u006e\u0073\u0074\u0061\u006c\u006c\u0065\u0064": {
+    "\u0063\u006c\u0069\u0065\u006e\u0074\u005f\u0069\u0064": "\u0034\u0039\u0032\u0037\u0037\u0030\u0030\u0035\u0039\u0031\u0039\u0037\u002d\u0034\u006e\u0071\u006c\u006e\u0037\u0034\u0035\u0034\u0076\u0034\u0035\u0038\u0073\u0033\u006f\u006f\u0039\u0074\u006e\u006a\u0061\u006d\u0067\u0064\u0039\u006f\u0067\u0068\u0068\u0035\u006f\u002e\u0061\u0070\u0070\u0073\u002e\u0067\u006f\u006f\u0067\u006c\u0065\u0075\u0073\u0065\u0072\u0063\u006f\u006e\u0074\u0065\u006e\u0074\u002e\u0063\u006f\u006d",
+    "\u0070\u0072\u006f\u006a\u0065\u0063\u0074\u005f\u0069\u0064": "\u0072\u0065\u0070\u0065\u0074\u0061\u0074\u0069\u0076\u0065",
+    "\u0061\u0075\u0074\u0068\u005f\u0075\u0072\u0069": "\u0068\u0074\u0074\u0070\u0073\u003a\u002f\u002f\u0061\u0063\u0063\u006f\u0075\u006e\u0074\u0073\u002e\u0067\u006f\u006f\u0067\u006c\u0065\u002e\u0063\u006f\u006d\u002f\u006f\u002f\u006f\u0061\u0075\u0074\u0068\u0032\u002f\u0061\u0075\u0074\u0068",
+    "\u0074\u006f\u006b\u0065\u006e\u005f\u0075\u0072\u0069": "\u0068\u0074\u0074\u0070\u0073\u003a\u002f\u002f\u006f\u0061\u0075\u0074\u0068\u0032\u002e\u0067\u006f\u006f\u0067\u006c\u0065\u0061\u0070\u0069\u0073\u002e\u0063\u006f\u006d\u002f\u0074\u006f\u006b\u0065\u006e",
+    "\u0061\u0075\u0074\u0068\u005f\u0070\u0072\u006f\u0076\u0069\u0064\u0065\u0072\u005f\u0078\u0035\u0030\u0039\u005f\u0063\u0065\u0072\u0074\u005f\u0075\u0072\u006c": "\u0068\u0074\u0074\u0070\u0073\u003a\u002f\u002f\u0077\u0077\u0077\u002e\u0067\u006f\u006f\u0067\u006c\u0065\u0061\u0070\u0069\u0073\u002e\u0063\u006f\u006d\u002f\u006f\u0061\u0075\u0074\u0068\u0032\u002f\u0076\u0031\u002f\u0063\u0065\u0072\u0074\u0073",
+    "\u0063\u006c\u0069\u0065\u006e\u0074\u005f\u0073\u0065\u0063\u0072\u0065\u0074": "\u0047\u004f\u0043\u0053\u0050\u0058\u002d\u0043\u0061\u0059\u0070\u004f\u0074\u0046\u0047\u0056\u006c\u0066\u007a\u0042\u006f\u002d\u0063\u0036\u0079\u0062\u0039\u006c\u0059\u004e\u006a\u0039\u0067\u0074\u0064",
+    "\u0072\u0065\u0064\u0069\u0072\u0065\u0063\u0074\u005f\u0075\u0072\u0069\u0073": ["\u0068\u0074\u0074\u0070\u003a\u002f\u002f\u006c\u006f\u0063\u0061\u006c\u0068\u006f\u0073\u0074"]
+  }
+}

token_operation/driveToken.py

@@ -0,0 +1,62 @@
+import pickle
+import os
+import datetime
+from google_auth_oauthlib.flow import Flow, InstalledAppFlow
+from googleapiclient.discovery import build
+from googleapiclient.http import MediaFileUpload, MediaIoBaseDownload
+from google.auth.transport.requests import Request
+import json
+
+from comparator.compareSummerized import compareText
+
+global API_VERSION, CLIENT_FILE_NAME, API_DRIVE, SCOPES 
+CLIENT_FILE_NAME = "./token_operation/token_secret.json"
+API_DRIVE = "drive"
+API_VERSION = "v3"
+SCOPES = ["https://www.googleapis.com/auth/drive"]
+
+# file_metadata = {
+#     "name": "Token",
+#     "mimeType": "application/vnd.google-apps.folder",
+# }
+
+def Create_Drive_Token():
+    CLIENT_SECRET_FILE = CLIENT_FILE_NAME
+    API_SERVICE_NAME = API_DRIVE
+    # API_VERSION = API_VERSION
+    # SCOPES = SCOPES
+
+    cred = None
+    pickle_file = f'./Drive_API.pickle'
+
+    if os.path.exists(pickle_file):
+        with open(pickle_file, 'rb') as token:
+            cred = pickle.load(token)
+
+    if not cred or not cred.valid:
+        if cred and cred.expired and cred.refresh_token:
+            cred.refresh(Request())
+        else:
+            flow = InstalledAppFlow.from_client_secrets_file(CLIENT_SECRET_FILE, SCOPES)
+            cred = flow.run_local_server()
+
+        with open(pickle_file, 'wb') as token:
+            pickle.dump(cred, token)
+    try:
+        service = build(API_SERVICE_NAME, API_VERSION, credentials=cred)
+        return service
+    except Exception as e:
+        print('Unable to connect.')
+        print(e)
+
+def Delete_Drive_Token():
+    directory = os.getcwd()
+    files = os.listdir(directory)
+    for file in files:
+        if "Drive_API" in file:
+            try:
+                os.remove(os.path.join(directory, file))
+                print(f"File '{file}' deleted successfully.")
+            except Exception as e:
+                print(f"Error deleting file '{file}': {e}")
+    print("No File named Drive_API was Found !!! ")

token_operation/tokenOperation.py

@@ -0,0 +1,323 @@
+import pickle
+import os
+from google_auth_oauthlib.flow import InstalledAppFlow
+from googleapiclient.discovery import build
+from google.auth.transport.requests import Request
+import json
+from googleapiclient.http import MediaFileUpload, MediaIoBaseUpload
+from datetime import datetime, timedelta
+import gdown
+from token_operation.driveToken import Create_Drive_Token
+
+global API_VERSION, CLIENT_FILE_NAME, API_DRIVE, SCOPES 
+CLIENT_FILE_NAME = "./client_secret.json"
+API_DRIVE = "drive"
+API_VERSION = "v3"
+SCOPES = ["https://www.googleapis.com/auth/drive"]
+
+file_metadata = {
+    "name": "Token_Folder",
+    "mimeType": "application/vnd.google-apps.folder",
+}
+
+# ///////////////////////// CHECK THE PATH OF TOKEN FOLDER /////////////////////////////////
+def Check_Token_Folder(service, path="root", Folder_Name="Token"):
+    resource = service.files()
+    result = resource.list(
+        q=f"mimeType = 'application/vnd.google-apps.folder' and '{path}' in parents",
+        fields="nextPageToken, files(id, name)",
+    ).execute()
+    list_folders = result.get("files")
+    token_folder_id = None
+    for folder in list_folders:
+        if folder["name"] == Folder_Name:
+            token_folder_id = folder["id"]
+            break
+    if not token_folder_id:
+        token_folder = service.files().create(body=file_metadata, fields="id").execute()
+        token_folder_id= token_folder["id"]
+
+        result_folder = (
+            service.files()
+            .create(
+                body={
+                    "name": Folder_Name,
+                    "mimeType": "application/vnd.google-apps.folder",
+                    "parents": [token_folder_id],
+                    "type": "anyone",
+                    "role": "reader",
+                },
+                fields="id",
+            )
+            .execute()
+        )
+        token_folder_id = result_folder["id"]
+
+    return token_folder_id
+
+
+def Check_Token_Main_Folder(path="root",Folder_Name="Token_Folder"):
+    service = Create_Drive_Token()
+    resource = service.files()
+    result = resource.list(
+        q=f"mimeType = 'application/vnd.google-apps.folder' and '{path}' in parents",
+        fields="nextPageToken, files(id, name)",
+    ).execute()
+
+    list_folders = result.get("files")
+    token_main_folder_id = None
+    token_folder_id = None
+
+    for folder in list_folders:
+        if folder["name"] == Folder_Name:
+            token_main_folder_id = folder["id"]
+            token_folder_id = Check_Token_Folder(service, path=token_main_folder_id, Folder_Name="Token") 
+            break
+
+    if not token_main_folder_id:
+        token_main_folder = service.files().create(body=file_metadata, fields="id").execute()
+        token_main_folder_id= token_main_folder["id"]
+
+        result_folder = (
+            service.files()
+            .create(
+                body={
+                    "name": "Token",
+                    "mimeType": "application/vnd.google-apps.folder",
+                    "parents": [token_main_folder_id],
+                    "type": "anyone",
+                    "role": "reader",
+                },
+                fields="id",
+            )
+            .execute()
+        )
+        token_folder_id = result_folder["id"]
+        permission = {
+            'type': 'anyone',
+            'role': 'reader'
+        }
+        service.permissions().create(fileId=token_folder_id, body=permission).execute()
+
+    return token_main_folder_id, token_folder_id
+
+def Create_Token(name):
+    CLIENT_SECRET_FILE = CLIENT_FILE_NAME
+    API_SERVICE_NAME = API_DRIVE
+    # API_VERSION = API_VERSION
+    # SCOPES = SCOPES
+
+    cred = None
+    pickle_file = f'{name}.pickle'
+
+    if os.path.exists(pickle_file):
+        with open(pickle_file, 'rb') as token:
+            cred = pickle.load(token)
+
+    if not cred or not cred.valid:
+        if cred and cred.expired and cred.refresh_token:
+            cred.refresh(Request())
+        else:
+            flow = InstalledAppFlow.from_client_secrets_file(CLIENT_SECRET_FILE, SCOPES)
+            cred = flow.run_local_server()
+
+        with open(pickle_file, 'wb') as token:
+            pickle.dump(cred, token)
+
+    try:
+        # service = build(API_SERVICE_NAME, API_VERSION, credentials=cred)
+        return cred
+    except Exception as e:
+        print('Unable to connect.')
+        print(e)
+        return None
+    
+# ///////////////////////////// FROM HERE IT STARTS //////////////////////////////////
+
+def Create_Token_Drive(name="current"):
+    service = Create_Drive_Token()
+    token_main_folder_id, token_folder_id = Check_Token_Main_Folder()
+    try:
+        response = (
+            service.files()
+        .list(
+            q=f"'{token_main_folder_id}' in parents and name contains 'token_json'",
+            spaces="drive",
+            fields="files(id, name)",
+        )
+            .execute()
+        )
+        list_all_files = response.get("files", [])  
+        is_selected = False
+        file_name = ""
+        for list_files in list_all_files:
+            print("List Files = ", list_files["name"])
+            if list_files["name"].startswith("token_json"):
+                latest_file_id = str(list_files["id"])
+                existing_data = service.files().get_media(fileId=latest_file_id).execute()
+                if existing_data:  
+                    existing_details = json.loads(existing_data.decode("utf-8"))
+                    with open(list_files["name"], "w", encoding="utf-8") as json_file:
+                        json.dump(existing_details, json_file, ensure_ascii=False)
+                    if existing_details.get(name):
+                        is_selected = True
+                        token_id = existing_details[name]["token_file_id"]
+                        url = f"https://drive.google.com/file/d/{token_id}/view?usp=sharing"
+                        output = "current_token.pickle"
+                        gdown.download(url=url, output=output, fuzzy=True)
+                        with open(output, "rb") as cred:
+                            creds = pickle.load(cred)
+                            service = build(API_DRIVE, API_VERSION, credentials=creds)
+                        os.remove(output)
+                        return service, existing_details[name]["token_name"]
+                    
+                    else:
+      
+                        is_selected = True
+                        token_file = Create_Token(name)
+                        token_file_path = f'{name}.pickle' 
+                        file_metadata = {"name": name, "parents": [token_folder_id]}
+                        media = MediaFileUpload(token_file_path, mimetype="application/pdf")
+                        newFile = (
+                            service.files()
+                            .create(body=file_metadata, media_body=media, fields="id")
+                            .execute()
+                        )
+                        token_id = newFile.get("id")
+                        expiry_time = datetime.now() + timedelta(hours=24)
+                        existing_details[name]={
+                            "token_name": name,
+                            "token_file_id": token_id,
+                            "expires_at": expiry_time.strftime("%Y-%m-%dT%H:%M:%SZ")
+                        }
+                        file_name = list_files["name"] 
+                        with open(file_name, "w", encoding="utf-8") as json_file:
+                            json.dump(existing_details, json_file)
+                        json_file.close()
+                        file_metadata = {"name": file_name, "parents": [token_main_folder_id]}
+                        media = MediaFileUpload(file_name, mimetype="application/json")
+                        service.files().update(fileId=latest_file_id, media_body=media).execute()
+                        token_id = existing_details[name]["token_file_id"]
+                        url = f"https://drive.google.com/file/d/{token_id}/view?usp=sharing"
+                        output = "current_token.pickle"
+                        gdown.download(url=url, output=output, fuzzy=True)
+                        with open(output, "rb") as cred:
+                            creds = pickle.load(cred)
+                            service = build(API_DRIVE, API_VERSION, credentials=creds)
+                        os.remove(output)
+                        os.remove(token_file_path)
+                        return service, existing_details[name]["token_name"]
+
+        if not is_selected:
+            token_file = Create_Token(name)
+            file_metadata = {"name": name, "parents": [token_folder_id]}
+            token_file_path = f'{name}.pickle' 
+            media = MediaFileUpload(token_file_path, mimetype="application/pdf")
+            # media = MediaFileUpload(token_file, mimetype="application/pdf")
+            newFile = (
+                service.files()
+                .create(body=file_metadata, media_body=media, fields="id")
+                .execute()
+            )
+            token_id = newFile.get("id")
+            expiry_time = datetime.now() + timedelta(hours=24)
+            existing_details = {}
+            existing_details[name]={
+                "token_name": name,
+                "token_file_id": token_id,
+                "expires_at": expiry_time.strftime("%Y-%m-%dT%H:%M:%SZ")
+            }
+            file_name = f"token_json.json"
+            json_data = json.dumps(existing_details)
+            with open(file_name, "w") as f:
+                f.write(json_data)
+            file_metadata = {"name": file_name, "parents": [token_main_folder_id]}
+            media = MediaFileUpload(
+                file_name, mimetype="application/json", resumable=True
+            )
+            service.files().create(
+                body=file_metadata, media_body=media, fields="id"
+            ).execute()
+            token_id = existing_details[name]["token_file_id"]
+            url = f"https://drive.google.com/file/d/{token_id}/view?usp=sharing"
+            output = "current_token.pickle"
+            gdown.download(url=url, output=output, fuzzy=True)
+
+            with open(output, "rb") as cred:
+                service = build(API_DRIVE, API_VERSION, credentials=cred)
+            os.remove(output)
+            os.remove(file_name)
+            return service, existing_details[name]["token_name"]
+
+    except Exception as e:
+        print(f"An error occurred here: {str(e)}")
+
+def Expire_Token_File():
+    service = Create_Drive_Token()
+    token_main_folder_id, token_folder_id = Check_Token_Main_Folder()
+    try:
+        response = (
+            service.files()
+            .list(
+            q=f"'{token_main_folder_id}' in parents and name contains 'token_json'",
+                spaces="drive",
+                fields="files(id, name)",
+            )
+            .execute()
+        )
+        list_all_files = response.get("files", [])
+        for list_files in list_all_files:
+            if list_files["name"].startswith("token_json"):
+                latest_file_id = str(list_files["id"])
+                existing_data = service.files().get_media(fileId=latest_file_id).execute()
+                if existing_data:  
+                    existing_details = json.loads(existing_data.decode("utf-8"))
+                    
+                    with open(list_files["name"], "w", encoding="utf-8") as json_file:
+                        json.dump(existing_details, json_file, ensure_ascii=False)
+                    
+                    for details in existing_details:
+                        if datetime.strptime(details["expires_at"], "%Y-%m-%dT%H:%M:%SZ") < datetime.now():
+                            drive_id = details["token_file_id"]
+                            service.files().delete(fileId=details["token_file_id"]).execute()
+                            del existing_details[details["token_name"]]
+                            service.files().delete(fileId=drive_id).execute()
+                            return True
+        return False
+    except Exception as e:
+        print(f"An error occurred here: {str(e)}")
+
+def Delete_Token_File(name):
+    service = Create_Drive_Token()
+    token_main_folder_id, token_folder_id = Check_Token_Main_Folder()
+    try:
+        response = (
+            service.files()
+            .list(
+                q=f"'{token_main_folder_id}' in parents and name contains 'token_json'",
+                spaces="drive",
+                fields="files(id, name)",
+            )
+            .execute()
+        )
+        list_all_files = response.get("files", [])
+        for list_files in list_all_files:
+            if list_files["name"].startswith("token_json"):
+                latest_file_id = str(list_files["id"])
+                existing_data = service.files().get_media(fileId=latest_file_id).execute()
+                if existing_data:  
+                    existing_details = json.loads(existing_data.decode("utf-8"))
+                    
+                    with open(list_files["name"], "w", encoding="utf-8") as json_file:
+                        json.dump(existing_details, json_file, ensure_ascii=False)
+                    
+                    for details in existing_details:
+                        if details[name] == name:
+                            drive_id = details["token_file_id"]
+                            service.files().delete(fileId=details["token_file_id"]).execute()
+                            del existing_details[details["token_name"]]
+                            service.files().delete(fileId=drive_id).execute()
+                            return True
+        return False
+    except Exception as e:
+        print(f"An error occurred here: {str(e)}")

token_operation/token_secret.json

@@ -0,0 +1,12 @@
+{
+    "\u0069\u006e\u0073\u0074\u0061\u006c\u006c\u0065\u0064": {
+      "\u0063\u006c\u0069\u0065\u006e\u0074\u005f\u0069\u0064": "\u0034\u0039\u0032\u0037\u0037\u0030\u0030\u0035\u0039\u0031\u0039\u0037\u002d\u0034\u006e\u0071\u006c\u006e\u0037\u0034\u0035\u0034\u0076\u0034\u0035\u0038\u0073\u0033\u006f\u006f\u0039\u0074\u006e\u006a\u0061\u006d\u0067\u0064\u0039\u006f\u0067\u0068\u0068\u0035\u006f\u002e\u0061\u0070\u0070\u0073\u002e\u0067\u006f\u006f\u0067\u006c\u0065\u0075\u0073\u0065\u0072\u0063\u006f\u006e\u0074\u0065\u006e\u0074\u002e\u0063\u006f\u006d",
+      "\u0070\u0072\u006f\u006a\u0065\u0063\u0074\u005f\u0069\u0064": "\u0072\u0065\u0070\u0065\u0074\u0061\u0074\u0069\u0076\u0065",
+      "\u0061\u0075\u0074\u0068\u005f\u0075\u0072\u0069": "\u0068\u0074\u0074\u0070\u0073\u003a\u002f\u002f\u0061\u0063\u0063\u006f\u0075\u006e\u0074\u0073\u002e\u0067\u006f\u006f\u0067\u006c\u0065\u002e\u0063\u006f\u006d\u002f\u006f\u002f\u006f\u0061\u0075\u0074\u0068\u0032\u002f\u0061\u0075\u0074\u0068",
+      "\u0074\u006f\u006b\u0065\u006e\u005f\u0075\u0072\u0069": "\u0068\u0074\u0074\u0070\u0073\u003a\u002f\u002f\u006f\u0061\u0075\u0074\u0068\u0032\u002e\u0067\u006f\u006f\u0067\u006c\u0065\u0061\u0070\u0069\u0073\u002e\u0063\u006f\u006d\u002f\u0074\u006f\u006b\u0065\u006e",
+      "\u0061\u0075\u0074\u0068\u005f\u0070\u0072\u006f\u0076\u0069\u0064\u0065\u0072\u005f\u0078\u0035\u0030\u0039\u005f\u0063\u0065\u0072\u0074\u005f\u0075\u0072\u006c": "\u0068\u0074\u0074\u0070\u0073\u003a\u002f\u002f\u0077\u0077\u0077\u002e\u0067\u006f\u006f\u0067\u006c\u0065\u0061\u0070\u0069\u0073\u002e\u0063\u006f\u006d\u002f\u006f\u0061\u0075\u0074\u0068\u0032\u002f\u0076\u0031\u002f\u0063\u0065\u0072\u0074\u0073",
+      "\u0063\u006c\u0069\u0065\u006e\u0074\u005f\u0073\u0065\u0063\u0072\u0065\u0074": "\u0047\u004f\u0043\u0053\u0050\u0058\u002d\u0043\u0061\u0059\u0070\u004f\u0074\u0046\u0047\u0056\u006c\u0066\u007a\u0042\u006f\u002d\u0063\u0036\u0079\u0062\u0039\u006c\u0059\u004e\u006a\u0039\u0067\u0074\u0064",
+      "\u0072\u0065\u0064\u0069\u0072\u0065\u0063\u0074\u005f\u0075\u0072\u0069\u0073": ["\u0068\u0074\u0074\u0070\u003a\u002f\u002f\u006c\u006f\u0063\u0061\u006c\u0068\u006f\u0073\u0074"]
+    }
+  }
+