init

.devcontainer/devcontainer.json

@@ -0,0 +1,33 @@
+{
+  "name": "Python 3",
+  // Or use a Dockerfile or Docker Compose file. More info: https://containers.dev/guide/dockerfile
+  "image": "mcr.microsoft.com/devcontainers/python:1-3.11-bullseye",
+  "customizations": {
+    "codespaces": {
+      "openFiles": [
+        "README.md",
+        "main.py"
+      ]
+    },
+    "vscode": {
+      "settings": {},
+      "extensions": [
+        "ms-python.python",
+        "ms-python.vscode-pylance"
+      ]
+    }
+  },
+  "updateContentCommand": "[ -f packages.txt ] && sudo apt update && sudo apt upgrade -y && sudo xargs apt install -y <packages.txt; [ -f requirements.txt ] && pip3 install --user -r requirements.txt; pip3 install --user streamlit; echo '✅ Packages installed and Requirements met'",
+  "postAttachCommand": {
+    "server": "streamlit run main.py --server.enableCORS false --server.enableXsrfProtection false"
+  },
+  "portsAttributes": {
+    "8501": {
+      "label": "Application",
+      "onAutoForward": "openPreview"
+    }
+  },
+  "forwardPorts": [
+    8501
+  ]
+}

.env

@@ -0,0 +1,9 @@
+OPENAI_API_KEY="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"
+LANGCHAIN_TRACING_V2=true
+LANGCHAIN_ENDPOINT="https://api.smith.langchain.com"
+LANGCHAIN_API_KEY="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"
+LANGCHAIN_PROJECT="langchain_udemy_k"
+INDEX_NAME="langchain_udemy_k-index"
+PINECONE_API_KEY="37d0996a-8a8a-4792-b29b-f2f78e7f1df2"
+HF_TOKEN="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"
+GROQ_API_KEY="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"

.gitignore

@@ -0,0 +1 @@
+.vercel

Pipfile

@@ -0,0 +1,20 @@
+[[source]]
+url = "https://pypi.org/simple"
+verify_ssl = true
+name = "pypi"
+
+[packages]
+python-dotenv = "*"
+langchain = "*"
+langchain_openai = "*"
+pinecone-client = "*"
+langchain-pinecone = "*"
+langchain-google-firestore = "*"
+firebase-admin = "*"
+streamlit = "*"
+langchain-community = "*"
+
+[dev-packages]
+
+[requires]
+python_version = "3.11"

agent/retrive_agent.py

@@ -0,0 +1,97 @@
+from dotenv import load_dotenv
+from typing import Any, Dict, List
+
+load_dotenv()
+from langchain_openai import ChatOpenAI
+from langchain.prompts.prompt import PromptTemplate
+from langchain_core.tools import Tool
+from langchain.agents import (
+    create_react_agent,
+    AgentExecutor,
+)
+from langchain import hub
+from tools.retrive import retrieve_berita, retrieve_umkm, retrieve_wisata, get_current_time, retrieve_wikipedia_info
+
+
+def run_llm(query: str, chat_history: List[Dict[str, Any]] = []) -> str:
+    llm = ChatOpenAI(
+        temperature=0,
+        model_name="gpt-4o-mini",
+    )
+    template = """
+Anda adalah asisten yang memiliki akses ke beberapa alat untuk mengambil informasi terbaru di Surabaya. Berdasarkan pertanyaan berikut, gunakan alat yang sesuai untuk memberikan jawaban yang paling akurat dan terkini.
+
+
+Jika pertanyaan pengguna menyebutkan "hari ini", "waktu sekarang", atau "sekarang", gunakan alat Get Current Time untuk mendapatkan waktu saat ini. Ganti kata tersebut dengan waktu yang diperoleh untuk memberikan jawaban yang lebih spesifik.
+
+Jika pertanyaan pengguna mengandung kata "terdekat", "dekat sini", atau "di sekitar", gunakan alat Get User Location Name untuk mengambil nama lokasi pengguna saat ini. Ganti kata "terdekat" dengan nama lokasi yang dihasilkan agar jawaban lebih relevan.
+
+Setiap kali Anda mengambil data menggunakan alat **Retrieve Berita**, **Retrieve UMKM**, atau **Retrieve Wisata**, pastikan untuk menyertakan **metadata ID dari Firebase** sebagai bagian dari jawaban. Metadata ini dapat digunakan sebagai tautan yang mengarahkan pengguna ke halaman terkait. Format tautan adalah sebagai berikut:
+
+- Untuk berita: `https://firebaseapp.com/berita/id`
+- Untuk UMKM: `https://firebaseapp.com/umkm/id`
+- Untuk wisata: `https://firebaseapp.com/wisata/id`
+
+Pertanyaan Pengguna: {query}
+
+Anda dapat memilih di antara alat berikut:
+1. **Get Current Time** - Untuk mengetahui waktu saat ini dalam format YYYY-MM-DD HH:MM:SS.
+2. **Retrieve Berita** - Untuk mengambil artikel berita terbaru atau informasi terkait peristiwa terkini di Surabaya.
+3. **Retrieve UMKM** - Untuk mendapatkan informasi tentang UMKM, terutama yang terkait makanan lokal dan rekomendasi tempat usaha mikro di Surabaya.
+4. **Retrieve Wisata** - Untuk memberikan detail tentang tempat wisata, atraksi, dan rekomendasi destinasi di Surabaya.
+5. **Wikipedia Search** - Untuk mendapatkan informasi umum dari Wikipedia yang terkait dengan topik atau orang terkenal di luar cakupan lokal.
+
+
+**Instruksi**:
+1. Periksa apakah pertanyaan memerlukan informasi waktu saat ini. Jika ya, gunakan **Get Current Time** terlebih dahulu.
+2. Ganti kata "hari ini" dalam pertanyaan dengan waktu yang diperoleh dari alat **Get Current Time**.
+3. Gunakan alat yang paling sesuai dengan pertanyaan setelah mengganti waktu (jika diperlukan).
+4. Untuk setiap hasil dari **Retrieve Berita**, **Retrieve UMKM**, atau **Retrieve Wisata**, sertakan metadata ID sebagai tautan dalam format di atas, sehingga pengguna dapat membuka halaman terkait.
+5. Berikan jawaban yang akurat, singkat, dan relevan berdasarkan informasi yang ditemukan dari alat tersebut.
+
+Mulai menjawab sekarang:
+"""
+    prompt_template = PromptTemplate(
+        template=template, input_variables=["query"]
+    )
+    tools_for_agent = [
+        Tool(
+            name="Retrieve Berita",
+            func=retrieve_berita,
+            description="Mengambil artikel berita terbaru dan konten yang relevan dengan pertanyaan pengguna, memastikan jawaban yang diberikan selalu terbaru dan informatif mengenai peristiwa terkini."
+        ),
+        Tool(
+            name="Retrieve UMKM",
+            func=retrieve_umkm,
+            description="Mengambil informasi tentang UMKM (usaha mikro, kecil, dan menengah), khususnya yang berkaitan dengan makanan, berdasarkan pertanyaan spesifik, berguna untuk memberikan detail tentang bisnis lokal, kewirausahaan, dan rekomendasi makanan lokal."
+        ),
+        Tool(
+            name="Retrieve Wisata",
+            func=retrieve_wisata,
+            description="Mengambil informasi terkait pariwisata, termasuk tempat wisata seperti pantai, laut, mall, dan atraksi lainnya, serta tips perjalanan, berdasarkan pertanyaan pengguna untuk meningkatkan rekomendasi yang berhubungan dengan pariwisata."
+        ),
+        Tool(
+            name="Get Current Time",
+            func=get_current_time,
+            description="Mengembalikan waktu saat ini dalam format yang mudah dibaca (YYYY-MM-DD HH:MM:SS), membantu untuk menjawab pertanyaan yang memerlukan konteks waktu saat ini."
+        ),
+        Tool(
+            name="Wikipedia Search",
+            func=retrieve_wikipedia_info,
+            description="Mengambil informasi dari Wikipedia mengenai topik umum atau tokoh terkenal. Cocok digunakan untuk menjawab pertanyaan tentang subjek di luar cakupan lokal."
+        ),
+    ]
+
+    react_prompt = hub.pull("hwchase17/react-chat")
+    agent = create_react_agent(llm=llm, tools=tools_for_agent, prompt=react_prompt)
+    agent_executor = AgentExecutor(agent=agent, tools=tools_for_agent, verbose=True)
+
+    result = agent_executor.invoke(
+        input={
+            "input": prompt_template.format(query=query),
+            "chat_history": chat_history  # Include an empty chat history
+        }
+    )
+    
+    return result["output"]
+

api/api_mage_x.py

@@ -0,0 +1,155 @@
+from fastapi import FastAPI, HTTPException, File, UploadFile
+from pydantic import BaseModel
+from firebase_admin import credentials, firestore
+from langchain_google_firestore import FirestoreChatMessageHistory
+from langchain.memory import ConversationBufferWindowMemory
+from langchain.schema import HumanMessage, AIMessage
+from dotenv import load_dotenv
+from google.oauth2 import service_account
+from googleapiclient.discovery import build
+from googleapiclient.http import MediaFileUpload
+from fastapi.middleware.cors import CORSMiddleware
+import uuid
+import os
+import tempfile
+import firebase_admin
+from agent.retrive_agent import run_llm
+
+# Load environment variables
+load_dotenv()
+
+# Initialize FastAPI
+app = FastAPI()
+
+# Add CORS Middleware
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],  # Gantilah "*" dengan URL spesifik jika perlu
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+
+# Initialize Firebase
+PROJECT_ID = "recommendation-system-mage"
+COLLECTION_NAME = "data_user"
+if not firebase_admin._apps:
+    cred = credentials.Certificate("../recommendation-system-mage-firebase-adminsdk-ds1lw-1ac94ba6dd.json")
+    firebase_admin.initialize_app(cred)
+client = firestore.client()
+
+# Initialize Google Drive API
+SERVICE_ACCOUNT_FILE = '../mage-442005-26c159b79c30.json'
+FOLDER_ID = '1SUjdlLkt58srCwSffDMAoZJKpzPCWszn'
+creds = service_account.Credentials.from_service_account_file(SERVICE_ACCOUNT_FILE)
+drive_service = build('drive', 'v3', credentials=creds)
+
+# Define data models
+class ChatRequest(BaseModel):
+    user_id: str
+    prompt: str
+
+class NewSessionRequest(BaseModel):
+    user_id: str
+
+# Endpoint to check if API is running
+@app.get("/")
+async def check():
+    return "API redi bolo!"
+
+# Endpoint to initialize a new chat session
+@app.post("/initialize_session")
+def initialize_session(request: NewSessionRequest):
+    user_doc_ref = client.collection(COLLECTION_NAME).document(request.user_id)
+    user_doc = user_doc_ref.get()
+
+    if not user_doc.exists:
+        raise HTTPException(status_code=404, detail="User ID not found in Firebase.")
+    
+    # Create new session
+    session_id = str(uuid.uuid4())
+    user_doc_ref.set({"last_session_id": session_id}, merge=True)
+    user_doc_ref.collection("message_history").document(session_id).set({})
+
+    return {"session_id": session_id}
+
+# Endpoint to handle chat requests
+@app.post("/chat")
+def chat(request: ChatRequest):
+    user_doc_ref = client.collection(COLLECTION_NAME).document(request.user_id)
+    user_doc = user_doc_ref.get()
+
+    if not user_doc.exists:
+        raise HTTPException(status_code=404, detail="User ID not found in Firebase.")
+    
+    # Corrected session ID retrieval
+    session_id = user_doc.get("last_session_id") if user_doc.exists and "last_session_id" in user_doc.to_dict() else str(uuid.uuid4())
+    user_doc_ref.set({"last_session_id": session_id}, merge=True)
+    
+    # Initialize chat history and memory
+    chat_history = FirestoreChatMessageHistory(
+        session_id=session_id,
+        collection=f"{COLLECTION_NAME}/{request.user_id}/message_history",
+        client=client,
+    )
+    memory = ConversationBufferWindowMemory(k=5, chat_memory=chat_history)
+    
+    # Generate response
+    generated_response = run_llm(query=request.prompt, chat_history=memory.chat_memory.messages)
+    generated_response = generated_response.replace("```", "").strip()
+    memory.save_context({"input": request.prompt}, {"output": generated_response})
+    
+    return {"response": generated_response, "session_id": session_id}
+
+# Endpoint to get chat history for a session
+@app.get("/chat_history/{user_id}/{session_id}")
+def get_chat_history(user_id: str, session_id: str):
+    chat_history = FirestoreChatMessageHistory(
+        session_id=session_id,
+        collection=f"{COLLECTION_NAME}/{user_id}/message_history",
+        client=client,
+    )
+    messages = [{"role": "user" if isinstance(msg, HumanMessage) else "assistant", "content": msg.content} for msg in chat_history.messages]
+    return {"chat_history": messages}
+
+# Fungsi untuk mengunggah file ke Google Drive
+def upload_to_drive(file_path: str, folder_id: str) -> str:
+    file_name = os.path.basename(file_path)
+    file_metadata = {
+        'name': file_name,
+        'parents': [folder_id]
+    }
+    media = MediaFileUpload(file_path, resumable=True)
+    uploaded_file = drive_service.files().create(
+        body=file_metadata, media_body=media, fields='id'
+    ).execute()
+
+    # Mengatur izin agar file dapat diakses secara publik
+    permission = {'type': 'anyone', 'role': 'reader'}
+    drive_service.permissions().create(fileId=uploaded_file['id'], body=permission).execute()
+
+    # Menghasilkan tautan publik
+    public_url = f"https://drive.google.com/uc?export=view&id={uploaded_file['id']}"
+    return public_url
+
+# Endpoint to upload a file to Google Drive
+@app.post("/upload/")
+async def upload_file(file: UploadFile = File(...)):
+    try:
+        # Membuat nama file sementara yang unik
+        unique_filename = f"{uuid.uuid4()}_{file.filename}"
+        file_path = os.path.join(tempfile.gettempdir(), unique_filename)
+
+        # Simpan file yang diunggah ke file sistem lokal
+        with open(file_path, "wb") as buffer:
+            buffer.write(await file.read())
+
+        # Unggah file ke Google Drive
+        public_link = upload_to_drive(file_path, FOLDER_ID)
+
+        # Hapus file lokal setelah diunggah
+        os.remove(file_path)
+
+        return {"message": "File uploaded successfully", "link": public_link}
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))

app/main.py

@@ -0,0 +1,154 @@
+import streamlit as st
+from firebase_admin import credentials, firestore
+from langchain_google_firestore import FirestoreChatMessageHistory
+from langchain.memory import ConversationBufferWindowMemory
+from langchain.schema import HumanMessage, AIMessage
+from dotenv import load_dotenv
+import firebase_admin
+import uuid
+from agent.retrive_agent import run_llm
+
+
+
+load_dotenv()
+
+
+PROJECT_ID = "recommendation-system-mage"
+COLLECTION_NAME = "data_user"
+
+if not firebase_admin._apps:
+    cred = credentials.Certificate("../recommendation-system-mage-firebase-adminsdk-ds1lw-1ac94ba6dd.json")
+    firebase_admin.initialize_app(cred)
+
+client = firestore.client()
+
+# Streamlit UI
+st.title(" Chat SITY")
+
+# Login and User ID settings
+st.sidebar.header("Login")
+user_id = st.sidebar.text_input("Enter User ID", value="")
+
+# Initialize session state variables if they are not present
+if "user_prompt_history" not in st.session_state:
+    st.session_state["user_prompt_history"] = []
+
+if "chat_answers_history" not in st.session_state:
+    st.session_state["chat_answers_history"] = []
+
+if "session_id" not in st.session_state:
+    st.session_state.session_id = ""
+
+if "current_user" not in st.session_state:
+    st.session_state.current_user = ""
+
+# Check if the user exists in Firebase
+if user_id:
+    # If the user has changed, reset the session state
+    if st.session_state.current_user != user_id:
+        st.session_state.current_user = user_id
+        st.session_state.user_prompt_history = []
+        st.session_state.chat_answers_history = []
+        st.session_state.session_id = ""
+
+    user_doc_ref = client.collection(COLLECTION_NAME).document(user_id)
+    user_doc = user_doc_ref.get()
+    if not user_doc.exists:
+        st.sidebar.error("Login failed: User ID not found in Firebase.")
+    else:
+        # Setup session and history if User ID is provided
+
+        # Initialize Session ID and store in Firebase if new session
+        if not st.session_state.session_id:
+            session_id = str(uuid.uuid4())
+            st.session_state.session_id = session_id
+            user_doc_ref.set({"last_session_id": session_id}, merge=True)
+            user_doc_ref.collection("message_history").document(session_id).set({})
+            st.sidebar.success(f"New session created: {session_id}")
+
+        if st.sidebar.button("New Chat"):
+            session_id = str(uuid.uuid4())
+            st.session_state.session_id = session_id
+            user_doc_ref.set({"last_session_id": session_id}, merge=True)
+            user_doc_ref.collection("message_history").document(session_id).set({})
+            st.session_state.user_prompt_history = []
+            st.session_state.chat_answers_history = []
+            st.sidebar.success(f"New session created: {session_id}")
+
+        sessions_collection_ref = user_doc_ref.collection("message_history").list_documents()
+        session_ids = [session.id for session in sessions_collection_ref]
+
+        st.sidebar.subheader("Session History")
+        selected_session_id = st.sidebar.selectbox("Select a session", session_ids, index=session_ids.index(st.session_state.session_id) if session_ids else -1)
+
+        # Load chat history when a new session is selected
+        if selected_session_id and selected_session_id != st.session_state.session_id:
+            st.session_state.session_id = selected_session_id
+
+            # Load the chat history for the selected session
+            chat_history = FirestoreChatMessageHistory(
+                session_id=st.session_state.session_id,
+                collection=f"{COLLECTION_NAME}/{user_id}/message_history",
+                client=client,
+            )
+
+            # Load chat messages into session state variables
+            st.session_state["user_prompt_history"] = []
+            st.session_state["chat_answers_history"] = []
+
+            for msg in chat_history.messages:
+                if isinstance(msg, HumanMessage):
+                    st.session_state["user_prompt_history"].append(msg.content)
+                elif isinstance(msg, AIMessage):
+                    st.session_state["chat_answers_history"].append(msg.content)
+
+        # Display the loaded chat history
+        if st.session_state.get("user_prompt_history") and st.session_state.get("chat_answers_history"):
+            for user_prompt, answer in zip(st.session_state["user_prompt_history"], st.session_state["chat_answers_history"]):
+                st.chat_message("user").write(user_prompt)
+                st.chat_message("assistant").write(answer)
+            
+
+
+
+        # Initialize Firestore Chat Message History in user's subcollection
+        chat_history = FirestoreChatMessageHistory(
+            session_id=st.session_state.session_id,
+            collection=f"{COLLECTION_NAME}/{user_id}/message_history",
+            client=client,
+        )
+
+        # Initialize memory to store messages specific to the current user and session
+        memory = ConversationBufferWindowMemory(
+            k=5,
+            chat_memory=chat_history
+        )
+
+        # Chatbot UI - Input and Chat Messages
+        if prompt := st.chat_input("Enter your prompt here..."):
+            with st.spinner("Generating response..."):
+                # Use Firebase history in RAG query specific to the current session
+                generated_response = run_llm(query=prompt, chat_history=memory.chat_memory.messages)
+                generated_response = generated_response.replace("```", "").strip()
+                memory.save_context(
+                    {"input": prompt},
+                    {"output": generated_response}
+                )
+
+                # Update session state
+                st.session_state["user_prompt_history"].append(prompt)
+                st.session_state["chat_answers_history"].append(generated_response)
+
+                # Display the updated chat history
+                st.chat_message("user").write(prompt)
+                st.chat_message("assistant").write(generated_response)
+        else:
+            if len(st.session_state["user_prompt_history"]) == 0 and len(st.session_state["chat_answers_history"]) == 0:
+                col1, col2, col3 = st.columns([1, 2, 1])  # Membagi halaman menjadi 3 bagian, dengan bagian tengah lebih besar
+                with col2:
+                    st.write("#")
+                    st.write("#")
+                    st.write("### Ada yang bisa saya bantu?")
+
+else:
+    st.sidebar.warning("Please enter your User ID to proceed.")

app/ui.py

@@ -0,0 +1,67 @@
+# streamlit_ui.py
+
+import streamlit as st
+import requests
+
+# Backend URL
+API_BASE_URL = "http://127.0.0.1:8000/"
+
+st.title("Chat SITY - API Client")
+
+# User ID Input for Login
+st.sidebar.header("Login")
+user_id = st.sidebar.text_input("Enter User ID", value="")
+
+# Initialize session state variables if they are not present
+if "user_prompt_history" not in st.session_state:
+    st.session_state["user_prompt_history"] = []
+
+if "chat_answers_history" not in st.session_state:
+    st.session_state["chat_answers_history"] = []
+
+if "session_id" not in st.session_state:
+    st.session_state.session_id = ""
+
+if user_id:
+    # Start a new session if not already initialized
+    if not st.session_state.session_id:
+        response = requests.post(f"{API_BASE_URL}/initialize_session", json={"user_id": user_id})
+        if response.status_code == 200:
+            st.session_state.session_id = response.json()["session_id"]
+            st.sidebar.success(f"New session created: {st.session_state.session_id}")
+        else:
+            st.sidebar.error("Login failed: User ID not found in Firebase.")
+    
+    # New Chat Button
+    if st.sidebar.button("New Chat"):
+        response = requests.post(f"{API_BASE_URL}/initialize_session", json={"user_id": user_id})
+        if response.status_code == 200:
+            st.session_state.session_id = response.json()["session_id"]
+            st.session_state.user_prompt_history = []
+            st.session_state.chat_answers_history = []
+            st.sidebar.success(f"New session created: {st.session_state.session_id}")
+    
+    # Chat History Retrieval
+    if st.session_state.session_id:
+        history_response = requests.get(f"{API_BASE_URL}/chat_history/{user_id}/{st.session_state.session_id}")
+        if history_response.status_code == 200:
+            chat_history = history_response.json()["chat_history"]
+            st.session_state.user_prompt_history = [msg["content"] for msg in chat_history if msg["role"] == "user"]
+            st.session_state.chat_answers_history = [msg["content"] for msg in chat_history if msg["role"] == "assistant"]
+        
+        # Display chat history
+        for user_prompt, answer in zip(st.session_state["user_prompt_history"], st.session_state["chat_answers_history"]):
+            st.chat_message("user").write(user_prompt)
+            st.chat_message("assistant").write(answer)
+
+        # Chat Input
+        if prompt := st.chat_input("Enter your prompt here..."):
+            response = requests.post(f"{API_BASE_URL}/chat", json={"user_id": user_id, "prompt": prompt})
+            if response.status_code == 200:
+                generated_response = response.json()["response"]
+                st.session_state["user_prompt_history"].append(prompt)
+                st.session_state["chat_answers_history"].append(generated_response)
+                st.chat_message("user").write(prompt)
+                st.chat_message("assistant").write(generated_response)
+else:
+    st.sidebar.warning("Please enter your User ID to proceed.")

mage-442005-26c159b79c30.json

@@ -0,0 +1,13 @@
+{
+  "type": "service_account",
+  "project_id": "mage-442005",
+  "private_key_id": "26c159b79c307e8ccd6534080c0195703f04e559",
+  "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQDFbt+8scgZcYdZ\nPx3MsQPvTL7A1LOE2IEErsZP1bXQ/PQA/9c/6K9Ga//Fd61x+ZOnEjZaRdrKh4e7\nNywHxytuJ4LeOyqiiXF5RptOcjRVXWg2I6svytoo5MKQcZ5mTVMnVfUYq/YaX7LY\n0xvgSPS0FJUeTgLt8ncDJMrfsoHrn41+2fLUr6aVzwBTN5Xa+PKSUpUXltR0JXr2\nN0Bb3lCq2Y+/jV8g3Rlz6pYrtuouJadmtXo1/dz7dZuJ2m87+RaZ3n6yx+3nCxmz\nwD4B2P4y/dglvKEYEp7YG99mSQOOtGKsZ6d4FGx74waelfQTOgMyTT4UISt9jKVz\nuS6X8QMJAgMBAAECggEAFGE+jS7Y1e+HJipCvDdljZUhd6w9H7BtmPslk2YfD4Sc\n92FxabJuLVnGnC6fY818dVmG7MibLh7RXvzx+ZeQnx1K//+hhgekA/3K2E0no8wx\njq0d5aAN5vy+LMTdsfe3Zq8TzskpbU2Fm6YnEX7Wa6RYRDmPSdqmeFea7X5ytMyj\n5eV7Vg0T0nIpN8seKecUbgRdbUbqMcZU0tgK4Oxdj03sa+JJJ2r3SIE9g1vtfHG2\nd42mfUI44GHsD7kiXSLQBGgqzOTGxYk4sQa9eeZPDNKXr8UPwypt9ahXYJY/LDyj\nAH+PgyIEdYFhv6UAZXE6u8MlxCPj5pkUGgASCoV9BQKBgQD2VBmjWdTpO/nKh8u9\neK4X07h/j/zd0fq7jJMma5G+nDDemcEOxEe+YFHHB7PHg3MN8a4SeBPxyCvO1wUQ\nSkRqfxFJOzWhgzK1ESPxy5zA1dQ5jUSub6AMvBmuTvy/zHPtd1b3nO1KIFUv8RVB\nu6PBuLClMjhiA2FRV0f6NpOf7wKBgQDNL1DR0ylhOV19xYFXTf/9oYwQ2dGcZHcD\nooW5jotepIg768KC7feavx03j7s0Nhl097E83tjY0v0KIRjgni6hdnxB4HwscI92\nmcbtKrOh8Un+K5tsYvZx3Wgi5y1lFEMitPy0v8+fGjUNUgK4Oonf9PsHyTYsCWbA\naVSOiPcUhwKBgFiwNvrlYQ8IlQsikWyKgsP5argi83w6GfhkyKZQnIzwV3gOC8Bx\nUxNsQoVSdJwk68vddDsaGLQ4ye0S5bPTyYY+cc7YDps0TZF7tmFcWffkBSEjh9L2\nRb3QC78CmWXFCwg4q4tDaPwDYCh+uJSOJoudH5ya1EoVxXgv4K5p8ATpAoGAWhiB\nq3DGRbuzsqtL7PMCCfOqliee48Y1gDIX9++AgRFMBMu0AFvPknKCuMfzEq0Cppqw\nh6Luot6aX51C2DZ9EUb+rsqMm9LdG93QPIm4kM5riCDLwV7/CeaHeHP8OdsY05+X\nKyLiXuFaFDxDl3OU4PMoWzXeBJ4oMSrPBztbCvcCgYEA4qSxCTQYlOCL6uA6ts2U\nwiPbh5y/iY7gq0AnBF6POzBdqKGtFUlabARkCsNYdstYiRbkwCctcQzbX0VYe0zD\ndg7kl/LXbqkvdQHrg7T+pthcAD1Yt9cd3CRkWGVxdPD0IVBjTTDeY/PLjcuTFZJ4\nLr3NXBGKUDrVbByjhUqwPj4=\n-----END PRIVATE KEY-----\n",
+  "client_email": "drive-service-account@mage-442005.iam.gserviceaccount.com",
+  "client_id": "117806948028026927979",
+  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
+  "token_uri": "https://oauth2.googleapis.com/token",
+  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
+  "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/drive-service-account%40mage-442005.iam.gserviceaccount.com",
+  "universe_domain": "googleapis.com"
+}

recommendation-system-mage-firebase-adminsdk-ds1lw-1ac94ba6dd.json

@@ -0,0 +1,13 @@
+{
+  "type": "service_account",
+  "project_id": "recommendation-system-mage",
+  "private_key_id": "1ac94ba6dd33936ea62020b6d5054c3271c0c607",
+  "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvAIBADANBgkqhkiG9w0BAQEFAASCBKYwggSiAgEAAoIBAQCSl+7Qkoh8uNcY\nTQWAoEKyDvXI44rxyCaC9RoM6QJgBrZUBbOjQVePirzTTC3Kk5NtsgdaTPNpjx25\nFn4CF2aHeyOeVhdn1yrdA80FFjOrd3JMSt7barDmhg3VDoRz0dmNM21rTjGYa5wx\nsPpExQw68aEYwyJhRN8EmPdK+I/N19X7D+x/9cVi8pjI+EQvAo0xlz6T2Wchy3pr\ndWkk0E6tD/opR7pyHbaPjOkAAP4A9Uj7ZJhNjTa1SFjoaOY/MOznOoV8QcL6NjMo\nILYLblE4RM8lAOQwpVbzfuDj5u4KLUWxaYUpASIWiz73qaXG4Wg1pCXWqvPIwr9n\nT9YL7wXbAgMBAAECggEAFCC9XzEHgYyFqCYHL+KRVc59C/DGRq1zMD8ELSqfM10o\nkr/Xqv5RTfnANIj8rph1wTWVEd6H+4H1lFDUy2e4IbkUKmzquMzP61nWwDCMtqnn\nbTdIgzsSgAx/ALaGFDsHkn4xs26gm6uG3kHNEz01ETDVLEe6xD1HG+P+7HHVmO8p\nD251I9KYjZp0+ocXMDcpzy9zWKsZLOx7m7rv38PXcfCd3C+UMQ9CIwlJ52shjvrD\n/QiSVHQHr9xx+QOK1N9h1oClrQ6bx6Tr6iXtSDZAZyRnUl5LBXxVSLUjfndp/yyq\nBdRau93LItqxcFqu5da3wIyRe3eZv9dZLNVYzTK2cQKBgQDHYsMJdvuzY4FDaKdw\nvGH2vQQ6vo2PgpdRwJv37bv/QX4i2iLGUUtyUnzw8vaUguk8hH3h6YZ1YTxVVcmo\nrnX9KqoP0riqvu7wDySG95MQ72aD8SAbqPg2UDx5PNxmRNJtxbrGNuS2jh1OAbIe\nb1cE7QIGWJUMYTm4DMInL35GcQKBgQC8N7qkS/CD0T2uggpO+soQ4GOpEAufZ9ny\nETyZUqBRIiP9fluFzF8R+YMML+PSSCQPiu2AYRX8WWflNFOnyGYx0Cbodo+LBE8O\nNWVnuuxfzzJZEFsh1pk0lFcJ/qrQadRJk0e+acR7yZU8R1ejF/BrEjq1luQRqtfg\nC8brQedvCwKBgFrmJbDM89dGyAmpTpzQ5YCNj74QXY1Nphr5SqHvWkP24cCV3kC3\nk0PdY2Sd/9iZDigu5wz1X/1nhRAKelNSpivzJXDtSo9dWKVM4gQ+HmgcHIqOhWrW\nz8JDNi63lmtxeNXezVXMdNzdUXLcxw2lCPEP9FpcTCdGs/+6oVEoD9OhAoGAf6s1\nmNhB7sfxlPt0TppikgwCzdyqZZgmB8KVXlLjl+UWkI4zOpCkNCcRMyUQ3cQ9YaWU\n8C3qod9rT9esnvSaDVPp8GjreRqVHUgu3qu2Rk7fEfa8Ojm8diPg3lC2QORoMPgM\nBCbuNiFIbzjdQy2r0JTu6dnOHgXKpJiYd1+ewn0CgYAXBtFkoiYPn94XDBDxgcdB\nbSxW0Pr4fK9pn3JiU/vvyS29xXkmLLtwZS7ZJ/mhuUNskwYnxqqE5A1Ybji087kX\nfM55KjIBsiRtypID0vO97ZZOZH/3yZAvQxtZ6BU4Gu0J6gPifxJuaGuOOwMpeNZr\nmyqiY3wZOdLXOpHybcorDg==\n-----END PRIVATE KEY-----\n",
+  "client_email": "firebase-adminsdk-ds1lw@recommendation-system-mage.iam.gserviceaccount.com",
+  "client_id": "112738464264180377678",
+  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
+  "token_uri": "https://oauth2.googleapis.com/token",
+  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
+  "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-ds1lw%40recommendation-system-mage.iam.gserviceaccount.com",
+  "universe_domain": "googleapis.com"
+}

tools/retrive.py

@@ -0,0 +1,73 @@
+from typing import List, Dict, Any
+from langchain_pinecone import PineconeVectorStore
+from langchain_openai import OpenAIEmbeddings
+from pinecone import Pinecone
+import json
+from datetime import datetime
+from langchain_community.tools import WikipediaQueryRun
+from langchain_community.utilities import WikipediaAPIWrapper
+
+# Initialize Pinecone client
+pc = Pinecone(api_key="pcsk_6vVrG6_2ZUYuJwQcrKefGPodrfDuYAXB4AKD2ZENoXF7qmAahuSAYWijPTaBhkkb8DoB4M")
+index = "mage-x-embeddings-all"
+index = pc.Index(index)
+docsearch = PineconeVectorStore(index=index, embedding=OpenAIEmbeddings())
+
+# Initialize Wikipedia API Wrapper and Tool
+api_wrapper_wiki = WikipediaAPIWrapper(top_k_results=1, doc_content_chars_max=1000)
+wiki = WikipediaQueryRun(api_wrapper=api_wrapper_wiki)
+
+def retrieve_wisata(query: str) -> str:
+    """
+    Mengambil teks dan metadata yang relevan dari vector store UMKM berdasarkan query yang diberikan.
+    """
+    search_results = docsearch.similarity_search(query, filter={'collection_type': 'data_wisata'})
+    retrieved_texts = []
+    for result in search_results:
+        text = result.page_content
+        metadata = result.metadata.get("firebase_id", "")
+        retrieved_texts.append({"content": text, "metadata": metadata})
+    return json.dumps(retrieved_texts, indent=2)
+
+def retrieve_berita(query: str) -> str:
+    """
+    Mengambil teks dan metadata yang relevan dari vector store UMKM berdasarkan query yang diberikan.
+    """
+    search_results = docsearch.similarity_search(query, filter={'collection_type': 'data_berita'})
+    retrieved_texts = []
+    for result in search_results:
+        text = result.page_content
+        metadata = result.metadata.get("firebase_id", "")
+        retrieved_texts.append({"content": text, "metadata": metadata})
+    return json.dumps(retrieved_texts, indent=2)
+
+def retrieve_umkm(query: str) -> str:
+    """
+    Mengambil teks dan metadata yang relevan dari vector store UMKM berdasarkan query yang diberikan.
+    """
+    search_results = docsearch.similarity_search(query, filter={'collection_type': 'data_umkm'})
+    retrieved_texts = []
+    for result in search_results:
+        text = result.page_content
+        metadata = result.metadata.get("firebase_id", "")
+        retrieved_texts.append({"content": text, "metadata": metadata})
+    return json.dumps(retrieved_texts, indent=2)
+
+def retrieve_wikipedia_info(query: str) -> str:
+    """
+    Mengambil informasi dari Wikipedia berdasarkan query yang diberikan.
+    """
+    result = wiki.run(query)  # Menggunakan WikipediaQueryRun untuk menjalankan pencarian
+    return result if result else "Tidak ditemukan hasil di Wikipedia."
+
+def get_current_time(*args, **kwargs) -> str:
+    """
+    Mengembalikan waktu saat ini dalam format yang mudah dibaca.
+    """
+    current_time = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+    return current_time
+
+# Contoh penggunaan fungsi baru
+# print(retrieve_umkm("Produk UMKM terbaik?"))
+# print(retrieve_berita("Berita ekonomi terbaru?"))
+# print(retrieve_wisata("Tempat wisata terpopuler?"))

vercel.json

@@ -0,0 +1,24 @@
+{
+  "version": 2,
+  "builds": [
+    {
+      "src": "api_mage_x.py",
+      "use": "@vercel/python",
+      "config": {
+        "maxLambdaSize": "50mb",
+        "pythonVersion": "3.11"
+      }
+    }
+  ],
+  "routes": [
+    {
+      "src": "/(.*)",
+      "dest": "api_mage_x.py"
+    }
+  ],
+  "env": {
+    "PROJECT_ID": "recommendation-system-mage",
+    "COLLECTION_NAME": "data_user",
+    "GOOGLE_APPLICATION_CREDENTIALS": "./recommendation-system-mage-firebase-adminsdk-ds1lw-1ac94ba6dd.json"
+  }
+}