Merge branch 'feature/output_dropdown' into fix_build_fe

2024-05-31 16:25:43 -03:00 · 2024-05-31 16:25:43 -03:00 · 1fa3a6a379
commit 1fa3a6a379
parent 513046caba 0b584fe731
55 changed files with 890 additions and 498 deletions
--- a/src/backend/base/langflow/alembic/versions/631faacf5da2_add_webhook_columns.py
+++ b/src/backend/base/langflow/alembic/versions/631faacf5da2_add_webhook_columns.py
@ -0,0 +1,45 @@
+"""Add webhook columns
+
+Revision ID: 631faacf5da2
+Revises: 1c79524817ed
+Create Date: 2024-04-22 15:14:43.454784
+
+"""
+
+from typing import Sequence, Union
+
+import sqlalchemy as sa
+from alembic import op
+from sqlalchemy.engine.reflection import Inspector
+
+# revision identifiers, used by Alembic.
+revision: str = "631faacf5da2"
+down_revision: Union[str, None] = "1c79524817ed"
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    conn = op.get_bind()
+    inspector = Inspector.from_engine(conn)  # type: ignore
+    table_names = inspector.get_table_names()
+    # ### commands auto generated by Alembic - please adjust! ###
+    column_names = [column["name"] for column in inspector.get_columns("flow")]
+    with op.batch_alter_table("flow", schema=None) as batch_op:
+        if "flow" in table_names and "webhook" not in column_names:
+            batch_op.add_column(sa.Column("webhook", sa.Boolean(), nullable=True))
+
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    conn = op.get_bind()
+    inspector = Inspector.from_engine(conn)  # type: ignore
+    table_names = inspector.get_table_names()
+    # ### commands auto generated by Alembic - please adjust! ###
+    column_names = [column["name"] for column in inspector.get_columns("flow")]
+    with op.batch_alter_table("flow", schema=None) as batch_op:
+        if "flow" in table_names and "webhook" in column_names:
+            batch_op.drop_column("webhook")
+
+    # ### end Alembic commands ###
--- a/src/backend/base/langflow/api/v1/endpoints.py
+++ b/src/backend/base/langflow/api/v1/endpoints.py
@ -3,7 +3,7 @@ from typing import TYPE_CHECKING, Annotated, List, Optional, Union
 from uuid import UUID

 import sqlalchemy as sa
-from fastapi import APIRouter, Body, Depends, HTTPException, UploadFile, status
+from fastapi import APIRouter, BackgroundTasks, Body, Depends, HTTPException, Request, UploadFile, status
 from loguru import logger
 from sqlmodel import Session, select

@ -22,11 +22,14 @@ from langflow.api.v1.schemas import (
 from langflow.custom import CustomComponent
 from langflow.custom.utils import build_custom_component_template
 from langflow.graph.graph.base import Graph
+from langflow.graph.schema import RunOutputs
+from langflow.helpers.flow import get_flow_by_id_or_endpoint_name
 from langflow.processing.process import process_tweaks, run_graph_internal
 from langflow.schema.graph import Tweaks
 from langflow.services.auth.utils import api_key_security, get_current_active_user
 from langflow.services.cache.utils import save_uploaded_file
 from langflow.services.database.models.flow import Flow
+from langflow.services.database.models.flow.utils import get_all_webhook_components_in_flow, get_flow_by_id
 from langflow.services.database.models.user.model import User
 from langflow.services.deps import get_session, get_session_service, get_settings_service, get_task_service
 from langflow.services.session.service import SessionService
@ -53,10 +56,75 @@ async def get_all(
        raise HTTPException(status_code=500, detail=str(exc)) from exc


+async def simple_run_flow(
+    db: Session,
+    flow: Flow,
+    input_request: SimplifiedAPIRequest,
+    session_service: SessionService,
+    stream: bool = False,
+    api_key_user: Optional[User] = None,
+):
+    try:
+        task_result: List[RunOutputs] = []
+        artifacts = {}
+        user_id = api_key_user.id if api_key_user else None
+        flow_id_str = str(flow.id)
+        if input_request.session_id:
+            session_data = await session_service.load_session(input_request.session_id, flow_id=flow_id_str)
+            graph, artifacts = session_data if session_data else (None, None)
+            if graph is None:
+                raise ValueError(f"Session {input_request.session_id} not found")
+        else:
+            if flow.data is None:
+                raise ValueError(f"Flow {flow_id_str} has no data")
+            graph_data = flow.data
+            graph_data = process_tweaks(graph_data, input_request.tweaks or {})
+            graph = Graph.from_payload(graph_data, flow_id=flow_id_str, user_id=str(user_id))
+        inputs = [
+            InputValueRequest(components=[], input_value=input_request.input_value, type=input_request.input_type)
+        ]
+        # outputs is a list of all components that should return output
+        # we need to get them by checking their type
+        # if the output type is debug, we return all outputs
+        # if the output type is any, we return all outputs that are either chat or text
+        # if the output type is chat or text, we return only the outputs that match the type
+        if input_request.output_component:
+            outputs = [input_request.output_component]
+        else:
+            outputs = [
+                vertex.id
+                for vertex in graph.vertices
+                if input_request.output_type == "debug"
+                or (
+                    vertex.is_output
+                    and (input_request.output_type == "any" or input_request.output_type in vertex.id.lower())
+                )
+            ]
+        task_result, session_id = await run_graph_internal(
+            graph=graph,
+            flow_id=flow_id_str,
+            session_id=input_request.session_id,
+            inputs=inputs,
+            outputs=outputs,
+            artifacts=artifacts,
+            session_service=session_service,
+            stream=stream,
+        )
+
+        return RunResponse(outputs=task_result, session_id=session_id)
+
+    except sa.exc.StatementError as exc:
+        # StatementError('(builtins.ValueError) badly formed hexadecimal UUID string')
+        if "badly formed hexadecimal UUID string" in str(exc):
+            logger.error(f"Flow ID {flow_id_str} is not a valid UUID")
+            # This means the Flow ID is not a valid UUID which means it can't find the flow
+            raise ValueError(str(exc)) from exc
+
+
@router.post("/run/{flow_id_or_name}", response_model=RunResponse, response_model_exclude_none=True)
 async def simplified_run_flow(
    db: Annotated[Session, Depends(get_session)],
-    flow_id_or_name: str,
+    flow: Annotated[Flow, Depends(get_flow_by_id_or_endpoint_name)],
    input_request: SimplifiedAPIRequest = SimplifiedAPIRequest(),
    stream: bool = False,
    api_key_user: User = Depends(api_key_security),
@ -67,7 +135,7 @@ async def simplified_run_flow(

    ### Parameters:
    - `db` (Session): Database session for executing queries.
-    - `flow_id` (str): Unique identifier of the flow to be executed.
+    - `flow_id_or_name` (str): ID or endpoint name of the flow to run.
    - `input_request` (SimplifiedAPIRequest): Request object containing input values, types, output selection, tweaks, and session ID.
    - `api_key_user` (User): User object derived from the provided API key, used for authentication.
    - `session_service` (SessionService): Service for managing flow sessions, essential for session reuse and caching.
@ -110,89 +178,21 @@ async def simplified_run_flow(

    This endpoint provides a powerful interface for executing flows with enhanced flexibility and efficiency, supporting a wide range of applications by allowing for dynamic input and output configuration along with performance optimizations through session management and caching.
    """
-    session_id = input_request.session_id
-    endpoint_name = None
-    flow_id_str = None
    try:
-        try:
-            flow_id = UUID(flow_id_or_name)
-
-        except ValueError:
-            endpoint_name = flow_id_or_name
-            flow = db.exec(
-                select(Flow).where(Flow.endpoint_name == endpoint_name).where(Flow.user_id == api_key_user.id)
-            ).first()
-            if flow is None:
-                raise ValueError(f"Flow with endpoint name {endpoint_name} not found")
-            flow_id = flow.id
-
-        flow_id_str = str(flow_id)
-        artifacts = {}
-        if input_request.session_id:
-            session_data = await session_service.load_session(input_request.session_id, flow_id=flow_id_str)
-            graph, artifacts = session_data if session_data else (None, None)
-            if graph is None:
-                raise ValueError(f"Session {input_request.session_id} not found")
-        else:
-            # Get the flow that matches the flow_id and belongs to the user
-            # flow = session.query(Flow).filter(Flow.id == flow_id).filter(Flow.user_id == api_key_user.id).first()
-            flow = db.exec(select(Flow).where(Flow.id == flow_id_str).where(Flow.user_id == api_key_user.id)).first()
-            if flow is None:
-                raise ValueError(f"Flow {flow_id_str} not found")
-
-            if flow.data is None:
-                raise ValueError(f"Flow {flow_id_str} has no data")
-            graph_data = flow.data
-
-            graph_data = process_tweaks(graph_data, input_request.tweaks or {}, stream=stream)
-            graph = Graph.from_payload(graph_data, flow_id=flow_id_str, user_id=str(api_key_user.id))
-        inputs = [
-            InputValueRequest(components=[], input_value=input_request.input_value, type=input_request.input_type)
-        ]
-        # outputs is a list of all components that should return output
-        # we need to get them by checking their type
-        # if the output type is debug, we return all outputs
-        # if the output type is any, we return all outputs that are either chat or text
-        # if the output type is chat or text, we return only the outputs that match the type
-        if input_request.output_component:
-            outputs = [input_request.output_component]
-        else:
-            outputs = [
-                vertex.id
-                for vertex in graph.vertices
-                if input_request.output_type == "debug"
-                or (
-                    vertex.is_output
-                    and (input_request.output_type == "any" or input_request.output_type in vertex.id.lower())
-                )
-            ]
-        task_result, session_id = await run_graph_internal(
-            graph=graph,
-            flow_id=flow_id_str,
-            session_id=input_request.session_id,
-            inputs=inputs,
-            outputs=outputs,
-            artifacts=artifacts,
+        return await simple_run_flow(
+            db=db,
+            flow=flow,
+            input_request=input_request,
            session_service=session_service,
            stream=stream,
+            api_key_user=api_key_user,
        )

-        return RunResponse(outputs=task_result, session_id=session_id)
-    except sa.exc.StatementError as exc:
-        # StatementError('(builtins.ValueError) badly formed hexadecimal UUID string')
-        if "badly formed hexadecimal UUID string" in str(exc):
-            logger.error(f"Flow ID {flow_id_str} is not a valid UUID")
-            # This means the Flow ID is not a valid UUID which means it can't find the flow
-            raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail=str(exc)) from exc
    except ValueError as exc:
-        if flow_id_str and f"Flow {flow_id_str} not found" in str(exc):
-            logger.error(f"Flow {flow_id_str} not found")
-            raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail=str(exc)) from exc
-        elif endpoint_name and f"Flow with endpoint name {endpoint_name} not found" in str(exc):
-            logger.error(f"Flow with endpoint name {endpoint_name} not found")
-            raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail=str(exc)) from exc
-        elif session_id and f"Session {session_id} not found" in str(exc):
-            logger.error(f"Session {session_id} not found")
+        if "badly formed hexadecimal UUID string" in str(exc):
+            # This means the Flow ID is not a valid UUID which means it can't find the flow
+            raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail=str(exc)) from exc
+        if "not found" in str(exc):
            raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail=str(exc)) from exc
        else:
            logger.exception(exc)
@ -202,6 +202,68 @@ async def simplified_run_flow(
        raise HTTPException(status_code=status.HTTP_500_INTERNAL_SERVER_ERROR, detail=str(exc)) from exc


+@router.post("/webhook/{flow_id}", response_model=dict, status_code=HTTPStatus.ACCEPTED)
+async def webhook_run_flow(
+    db: Annotated[Session, Depends(get_session)],
+    flow: Annotated[Flow, Depends(get_flow_by_id)],
+    request: Request,
+    background_tasks: BackgroundTasks,
+    session_service: SessionService = Depends(get_session_service),
+):
+    """
+    Run a flow using a webhook request.
+
+    Args:
+        db (Session): The database session.
+        request (Request): The incoming HTTP request.
+        background_tasks (BackgroundTasks): The background tasks manager.
+        session_service (SessionService, optional): The session service. Defaults to Depends(get_session_service).
+        flow (Flow, optional): The flow to be executed. Defaults to Depends(get_flow_by_id).
+
+    Returns:
+        dict: A dictionary containing the status of the task.
+
+    Raises:
+        HTTPException: If the flow is not found or if there is an error processing the request.
+    """
+    try:
+        logger.debug("Received webhook request")
+        data = await request.body()
+        if not data:
+            logger.error("Request body is empty")
+            raise ValueError(
+                "Request body is empty. You should provide a JSON payload containing the flow ID.",
+            )
+
+        # get all webhook components in the flow
+        webhook_components = get_all_webhook_components_in_flow(flow.data)
+        tweaks = {}
+        data_dict = await request.json()
+        for component in webhook_components:
+            tweaks[component["id"]] = {"data": data.decode() if isinstance(data, bytes) else data}
+        input_request = SimplifiedAPIRequest(
+            input_value=data_dict.get("input_value", ""),
+            input_type=data_dict.get("input_type", "chat"),
+            output_type=data_dict.get("output_type", "chat"),
+            tweaks=tweaks,
+            session_id=data_dict.get("session_id"),
+        )
+        logger.debug("Starting background task")
+        background_tasks.add_task(
+            simple_run_flow,
+            db=db,
+            flow=flow,
+            input_request=input_request,
+            session_service=session_service,
+        )
+        return {"message": "Task started in the background", "status": "in progress"}
+    except Exception as exc:
+        if "Flow ID is required" in str(exc) or "Request body is empty" in str(exc):
+            raise HTTPException(status_code=400, detail=str(exc)) from exc
+        logger.exception(exc)
+        raise HTTPException(status_code=500, detail=str(exc)) from exc
+
+
@router.post("/run/advanced/{flow_id}", response_model=RunResponse, response_model_exclude_none=True)
 async def experimental_run_flow(
    session: Annotated[Session, Depends(get_session)],
--- a/src/backend/base/langflow/api/v1/flows.py
+++ b/src/backend/base/langflow/api/v1/flows.py
@ -13,6 +13,7 @@ from langflow.api.v1.schemas import FlowListCreate, FlowListIds, FlowListRead
 from langflow.initial_setup.setup import STARTER_FOLDER_NAME
 from langflow.services.auth.utils import get_current_active_user
 from langflow.services.database.models.flow import Flow, FlowCreate, FlowRead, FlowUpdate
+from langflow.services.database.models.flow.utils import get_webhook_component_in_flow
 from langflow.services.database.models.folder.constants import DEFAULT_FOLDER_NAME
 from langflow.services.database.models.folder.model import Folder
 from langflow.services.database.models.user.model import User
@ -150,6 +151,8 @@ def update_flow(
        for key, value in flow_data.items():
            if value is not None:
                setattr(db_flow, key, value)
+        webhook_component = get_webhook_component_in_flow(db_flow.data)
+        db_flow.webhook = webhook_component is not None
        db_flow.updated_at = datetime.now(timezone.utc)
        if db_flow.folder_id is None:
            default_folder = session.exec(select(Folder).where(Folder.name == DEFAULT_FOLDER_NAME)).first()
--- a/src/backend/base/langflow/api/v1/folders.py
+++ b/src/backend/base/langflow/api/v1/folders.py
@ -1,5 +1,4 @@
 from typing import List
-from uuid import UUID

 import orjson
 from fastapi import APIRouter, Depends, File, HTTPException, Response, UploadFile, status
@ -88,7 +87,7 @@ def read_folders(
 def read_folder(
    *,
    session: Session = Depends(get_session),
-    folder_id: UUID,
+    folder_id: str,
    current_user: User = Depends(get_current_active_user),
 ):
    try:
@ -106,7 +105,7 @@ def read_folder(
 def update_folder(
    *,
    session: Session = Depends(get_session),
-    folder_id: UUID,
+    folder_id: str,
    folder: FolderUpdate,  # Assuming FolderUpdate is a Pydantic model defining updatable fields
    current_user: User = Depends(get_current_active_user),
 ):
@ -155,7 +154,7 @@ def update_folder(
 def delete_folder(
    *,
    session: Session = Depends(get_session),
-    folder_id: UUID,
+    folder_id: str,
    current_user: User = Depends(get_current_active_user),
 ):
    try:
@ -177,7 +176,7 @@ def delete_folder(
 async def download_file(
    *,
    session: Session = Depends(get_session),
-    folder_id: UUID,
+    folder_id: str,
    current_user: User = Depends(get_current_active_user),
 ):
    """Download all flows from folder."""
--- a/src/backend/base/langflow/components/data/Webhook.py
+++ b/src/backend/base/langflow/components/data/Webhook.py
@ -0,0 +1,39 @@
+import json
+import uuid
+from typing import Any, Optional
+
+from langflow.custom import CustomComponent
+from langflow.schema.dotdict import dotdict
+from langflow.schema.schema import Record
+
+
+class WebhookComponent(CustomComponent):
+    display_name = "Webhook Input"
+    description = "Defines a webhook input for the flow."
+
+    def update_build_config(self, build_config: dotdict, field_value: Any, field_name: str | None = None):
+        if field_name == "webhook_id":
+            build_config["webhook_id"]["value"] = uuid.uuid4().hex
+        return build_config
+
+    def build_config(self):
+        return {
+            "data": {
+                "display_name": "Data",
+                "info": "Use this field to quickly test the webhook component by providing a JSON payload.",
+                "multiline": True,
+            }
+        }
+
+    def build(self, data: Optional[str] = "") -> Record:
+        message = ""
+        try:
+            body = json.loads(data or "{}")
+        except json.JSONDecodeError:
+            body = {"payload": data}
+            message = f"Invalid JSON payload. Please check the format.\n\n{data}"
+        record = Record(data=body)
+        if not message:
+            message = json.dumps(body, indent=2)
+        self.status = message
+        return record
--- a/src/backend/base/langflow/components/data/init.py
+++ b/src/backend/base/langflow/components/data/init.py
@ -1,7 +1,8 @@
 from .APIRequest import APIRequest
 from .Directory import DirectoryComponent
 from .File import FileComponent
+from .Webhook import WebhookComponent

 from .URL import URLComponent

-__all__ = ["APIRequest", "DirectoryComponent", "FileComponent", "URLComponent"]
+__all__ = ["APIRequest", "DirectoryComponent", "FileComponent", "URLComponent", "WebhookComponent"]
--- a/src/backend/base/langflow/components/vectorsearch/UpstashSearch.py
+++ b/src/backend/base/langflow/components/vectorsearch/UpstashSearch.py
@ -0,0 +1,79 @@
+from typing import List, Optional
+
+from langchain_core.embeddings import Embeddings
+
+from langflow.components.vectorstores.base.model import LCVectorStoreComponent
+from langflow.components.vectorstores.Upstash import UpstashVectorStoreComponent
+from langflow.field_typing import Text
+from langflow.schema import Record
+
+
+class UpstashSearchComponent(UpstashVectorStoreComponent, LCVectorStoreComponent):
+    """
+    A custom component for implementing a Vector Store using Upstash.
+    """
+
+    display_name: str = "Upstash Search"
+    description: str = "Search an Upstash Vector Store for similar documents."
+
+    def build_config(self):
+        """
+        Builds the configuration for the component.
+
+        Returns:
+        - dict: A dictionary containing the configuration options for the component.
+        """
+        return {
+            "search_type": {
+                "display_name": "Search Type",
+                "options": ["Similarity", "MMR"],
+            },
+            "input_value": {"display_name": "Input"},
+            "inputs": {"display_name": "Input", "input_types": ["Document", "Record"]},
+            "embedding": {
+                "display_name": "Embedding",
+                "input_types": ["Embeddings"],
+                "info": "To use Upstash's embeddings, don't provide an embedding.",
+            },
+            "index_url": {
+                "display_name": "Index URL",
+                "info": "The URL of the Upstash index.",
+            },
+            "index_token": {
+                "display_name": "Index Token",
+                "info": "The token for the Upstash index.",
+            },
+            "number_of_results": {
+                "display_name": "Number of Results",
+                "info": "Number of results to return.",
+                "advanced": True,
+            },
+            "text_key": {
+                "display_name": "Text Key",
+                "info": "The key in the record to use as text.",
+                "advanced": True,
+            },
+        }
+
+    def build(  # type: ignore[override]
+        self,
+        input_value: Text,
+        search_type: str,
+        text_key: str = "text",
+        index_url: Optional[str] = None,
+        index_token: Optional[str] = None,
+        embedding: Optional[Embeddings] = None,
+        number_of_results: int = 4,
+    ) -> List[Record]:
+        vector_store = super().build(
+            embedding=embedding,
+            text_key=text_key,
+            index_url=index_url,
+            index_token=index_token,
+        )
+        if not vector_store:
+            raise ValueError("Failed to load the Upstash Vector Store.")
+
+        return self.search_with_vector_store(
+            input_value=input_value, search_type=search_type, vector_store=vector_store, k=number_of_results
+        )
--- a/src/backend/base/langflow/components/vectorstores/Upstash.py
+++ b/src/backend/base/langflow/components/vectorstores/Upstash.py
@ -0,0 +1,89 @@
+from typing import List, Optional, Union
+
+from langchain_community.vectorstores.upstash import UpstashVectorStore
+from langchain_core.embeddings import Embeddings
+from langchain_core.retrievers import BaseRetriever
+from langchain_core.vectorstores import VectorStore
+
+from langflow.custom import CustomComponent
+from langflow.schema.schema import Record
+
+
+class UpstashVectorStoreComponent(CustomComponent):
+    """
+    A custom component for implementing a Vector Store using Upstash.
+    """
+
+    display_name: str = "Upstash"
+    description: str = "Create and Utilize an Upstash Vector Store"
+
+    def build_config(self):
+        """
+        Builds the configuration for the component.
+
+        Returns:
+        - dict: A dictionary containing the configuration options for the component.
+        """
+        return {
+            "inputs": {"display_name": "Input", "input_types": ["Document", "Record"]},
+            "embedding": {
+                "display_name": "Embedding",
+                "input_types": ["Embeddings"],
+                "info": "To use Upstash's embeddings, don't provide an embedding.",
+            },
+            "index_url": {
+                "display_name": "Index URL",
+                "info": "The URL of the Upstash index.",
+            },
+            "index_token": {
+                "display_name": "Index Token",
+                "info": "The token for the Upstash index.",
+            },
+            "text_key": {
+                "display_name": "Text Key",
+                "info": "The key in the record to use as text.",
+                "advanced": True,
+            },
+        }
+
+    def build(
+        self,
+        inputs: Optional[List[Record]] = None,
+        text_key: str = "text",
+        index_url: Optional[str] = None,
+        index_token: Optional[str] = None,
+        embedding: Optional[Embeddings] = None,
+    ) -> Union[VectorStore, BaseRetriever]:
+        documents = []
+        for _input in inputs or []:
+            if isinstance(_input, Record):
+                documents.append(_input.to_lc_document())
+            else:
+                documents.append(_input)
+
+        use_upstash_embedding = embedding is None
+        if not documents:
+            upstash_vs = UpstashVectorStore(
+                embedding=embedding or use_upstash_embedding,
+                text_key=text_key,
+                index_url=index_url,
+                index_token=index_token,
+            )
+        else:
+            if use_upstash_embedding:
+                upstash_vs = UpstashVectorStore(
+                    embedding=use_upstash_embedding,
+                    text_key=text_key,
+                    index_url=index_url,
+                    index_token=index_token,
+                )
+                upstash_vs.add_documents(documents)
+            elif embedding:
+                upstash_vs = UpstashVectorStore.from_documents(
+                    documents=documents,  # type: ignore
+                    embedding=embedding,
+                    text_key=text_key,
+                    index_url=index_url,
+                    index_token=index_token,
+                )
+        return upstash_vs
--- a/src/backend/base/langflow/custom/utils.py
+++ b/src/backend/base/langflow/custom/utils.py
@ -164,6 +164,11 @@ def add_new_custom_field(
    if field_type == "bool" and field_value is None:
        field_value = False

+    if field_type == "SecretStr":
+        field_config["password"] = True
+        field_config["load_from_db"] = True
+        field_config["input_types"] = ["Text"]
+
    # If options is a list, then it's a dropdown
    # If options is None, then it's a list of strings
    is_list = isinstance(field_config.get("options"), list)
--- a/src/backend/base/langflow/graph/graph/base.py
+++ b/src/backend/base/langflow/graph/graph/base.py
@ -20,6 +20,7 @@ from langflow.schema.schema import INPUT_FIELD_NAME, InputType
 from langflow.services.cache.utils import CacheMiss
 from langflow.services.chat.service import ChatService
 from langflow.services.deps import get_chat_service
+from langflow.services.monitor.utils import log_transaction

 if TYPE_CHECKING:
    from langflow.graph.schema import ResultData
@ -763,9 +764,11 @@ class Graph:
            next_runnable_vertices, top_level_vertices = await self.get_next_and_top_level_vertices(
                lock, set_cache_coro, vertex
            )
+            log_transaction(vertex, status="success")
            return next_runnable_vertices, top_level_vertices, result_dict, params, valid, artifacts, vertex
        except Exception as exc:
            logger.exception(f"Error building vertex: {exc}")
+            log_transaction(vertex, status="failure", error=str(exc))
            raise exc

    async def get_next_and_top_level_vertices(
--- a/src/backend/base/langflow/graph/vertex/base.py
+++ b/src/backend/base/langflow/graph/vertex/base.py
@ -703,7 +703,8 @@ class Vertex:

            self._finalize_build()

-        return await self.get_requester_result(requester)
+        result = await self.get_requester_result(requester)
+        return result

    async def get_requester_result(self, requester: Optional["Vertex"]):
        # If the requester is None, this means that
--- a/src/backend/base/langflow/helpers/flow.py
+++ b/src/backend/base/langflow/helpers/flow.py
@ -1,13 +1,14 @@
 from typing import TYPE_CHECKING, Any, Awaitable, Callable, List, Optional, Tuple, Type, Union, cast
 from uuid import UUID

+from fastapi import Depends, HTTPException
 from pydantic.v1 import BaseModel, Field, create_model
-from sqlmodel import select
+from sqlmodel import Session, select

 from langflow.graph.schema import RunOutputs
 from langflow.schema.schema import INPUT_FIELD_NAME, Record
-from langflow.services.database.models.flow.model import Flow
-from langflow.services.deps import session_scope
+from langflow.services.database.models.flow import Flow
+from langflow.services.deps import get_session, session_scope

 if TYPE_CHECKING:
    from langflow.graph.graph.base import Graph
@ -235,3 +236,22 @@ def get_arg_names(inputs: List["Vertex"]) -> List[dict[str, str]]:
        {"component_name": input_.display_name, "arg_name": input_.display_name.lower().replace(" ", "_")}
        for input_ in inputs
    ]
+
+
+def get_flow_by_id_or_endpoint_name(
+    flow_id_or_name: str, db: Session = Depends(get_session), user_id: Optional[UUID] = None
+) -> Flow:
+    endpoint_name = None
+    try:
+        flow_id = UUID(flow_id_or_name)
+        flow = db.get(Flow, flow_id)
+    except ValueError:
+        endpoint_name = flow_id_or_name
+        stmt = select(Flow).where(Flow.name == endpoint_name)
+        if user_id:
+            stmt = stmt.where(Flow.user_id == user_id)
+        flow = db.exec(stmt).first()
+    if flow is None:
+        raise HTTPException(status_code=404, detail=f"Flow identifier {flow_id_or_name} not found")
+
+    return flow
--- a/src/backend/base/langflow/main.py
+++ b/src/backend/base/langflow/main.py
@ -14,7 +14,11 @@ from rich import print as rprint
 from starlette.middleware.base import BaseHTTPMiddleware

 from langflow.api import router
-from langflow.initial_setup.setup import create_or_update_starter_projects, initialize_super_user_if_needed, load_flows_from_directory
+from langflow.initial_setup.setup import (
+    create_or_update_starter_projects,
+    initialize_super_user_if_needed,
+    load_flows_from_directory,
+)
 from langflow.interface.utils import setup_llm_caching
 from langflow.services.plugins.langfuse_plugin import LangfuseInstance
 from langflow.services.utils import initialize_services, teardown_services
@ -33,20 +37,13 @@ class JavaScriptMIMETypeMiddleware(BaseHTTPMiddleware):
        return response


-def get_lifespan(fix_migration=False, socketio_server=None):
-    try:
-        from langflow.version import __version__  # type: ignore
-    except ImportError:
-        from importlib.metadata import version
-
-        __version__ = version("langflow-base")
-
+def get_lifespan(fix_migration=False, socketio_server=None, version=None):
    @asynccontextmanager
    async def lifespan(app: FastAPI):
        nest_asyncio.apply()
        # Startup message
-        if __version__:
-            rprint(f"[bold green]Starting Langflow v{__version__}...[/bold green]")
+        if version:
+            rprint(f"[bold green]Starting Langflow v{version}...[/bold green]")
        else:
            rprint("[bold green]Starting Langflow...[/bold green]")
        try:
@ -70,11 +67,17 @@ def get_lifespan(fix_migration=False, socketio_server=None):

 def create_app():
    """Create the FastAPI app and include the router."""
+    try:
+        from langflow.version import __version__  # type: ignore
+    except ImportError:
+        from importlib.metadata import version
+
+        __version__ = version("langflow-base")

    configure()
    socketio_server = socketio.AsyncServer(async_mode="asgi", cors_allowed_origins="*", logger=True)
-    lifespan = get_lifespan(socketio_server=socketio_server)
-    app = FastAPI(lifespan=lifespan)
+    lifespan = get_lifespan(socketio_server=socketio_server, version=__version__)
+    app = FastAPI(lifespan=lifespan, title="Langflow", version=__version__)
    origins = ["*"]

    app.add_middleware(
--- a/src/backend/base/langflow/services/database/models/flow/model.py
+++ b/src/backend/base/langflow/services/database/models/flow/model.py
@ -28,6 +28,7 @@ class FlowBase(SQLModel):
    data: Optional[Dict] = Field(default=None, nullable=True)
    is_component: Optional[bool] = Field(default=False, nullable=True)
    updated_at: Optional[datetime] = Field(default_factory=lambda: datetime.now(timezone.utc), nullable=True)
+    webhook: Optional[bool] = Field(default=False, nullable=True, description="Can be used on the webhook endpoint")
    folder_id: Optional[UUID] = Field(default=None, nullable=True)
    endpoint_name: Optional[str] = Field(default=None, nullable=True, index=True)

@ -114,10 +115,15 @@ class FlowBase(SQLModel):

    # updated_at can be serialized to JSON
    @field_serializer("updated_at")
-    def serialize_dt(self, dt: datetime, _info):
-        if dt is None:
-            return None
-        return dt.isoformat()
+    def serialize_datetime(value):
+        if isinstance(value, datetime):
+            # I'm getting 2024-05-29T17:57:17.631346
+            # and I want 2024-05-29T17:57:17-05:00
+            value = value.replace(microsecond=0)
+            if value.tzinfo is None:
+                value = value.replace(tzinfo=timezone.utc)
+            return value.isoformat()
+        return value

    @field_validator("updated_at", mode="before")
    def validate_dt(cls, v):
--- a/src/backend/base/langflow/services/database/models/flow/utils.py
+++ b/src/backend/base/langflow/services/database/models/flow/utils.py
@ -0,0 +1,33 @@
+from typing import Optional
+
+from fastapi import Depends
+from sqlmodel import Session
+
+from langflow.services.deps import get_session
+
+from .model import Flow
+
+
+def get_flow_by_id(session: Session = Depends(get_session), flow_id: Optional[str] = None) -> Flow | None:
+    """Get flow by id."""
+
+    if flow_id is None:
+        raise ValueError("Flow id is required.")
+
+    return session.get(Flow, flow_id)
+
+
+def get_webhook_component_in_flow(flow_data: dict):
+    """Get webhook component in flow data."""
+
+    for node in flow_data.get("nodes", []):
+        if "Webhook" in node.get("id"):
+            return node
+    return None
+
+
+def get_all_webhook_components_in_flow(flow_data: dict | None):
+    """Get all webhook components in flow data."""
+    if not flow_data:
+        return []
+    return [node for node in flow_data.get("nodes", []) if "Webhook" in node.get("id")]
--- a/src/backend/base/langflow/services/monitor/utils.py
+++ b/src/backend/base/langflow/services/monitor/utils.py
@ -8,6 +8,7 @@ from langflow.services.deps import get_monitor_service

 if TYPE_CHECKING:
    from langflow.api.v1.schemas import ResultDataResponse
+    from langflow.graph.vertex.base import Vertex


 INDEX_KEY = "index"
@ -165,3 +166,35 @@ async def log_vertex_build(
        monitor_service.add_row(table_name="vertex_builds", data=row)
    except Exception as e:
        logger.exception(f"Error logging vertex build: {e}")
+
+
+def build_clean_params(target: "Vertex") -> dict:
+    """
+    Cleans the parameters of the target vertex.
+    """
+    # Removes all keys that the values aren't python types like str, int, bool, etc.
+    params = {
+        key: value for key, value in target.params.items() if isinstance(value, (str, int, bool, float, list, dict))
+    }
+    # if it is a list we need to check if the contents are python types
+    for key, value in params.items():
+        if isinstance(value, list):
+            params[key] = [item for item in value if isinstance(item, (str, int, bool, float, list, dict))]
+    return params
+
+
+def log_transaction(vertex: "Vertex", status, error=None):
+    try:
+        monitor_service = get_monitor_service()
+        clean_params = build_clean_params(vertex)
+        data = {
+            "vertex_id": vertex.id,
+            "inputs": clean_params,
+            "output": str(vertex.result),
+            "timestamp": monitor_service.get_timestamp(),
+            "status": status,
+            "error": error,
+        }
+        monitor_service.add_row(table_name="transactions", data=data)
+    except Exception as e:
+        logger.error(f"Error logging transaction: {e}")
--- a/src/backend/base/langflow/services/settings/constants.py
+++ b/src/backend/base/langflow/services/settings/constants.py
@ -17,6 +17,8 @@ VARIABLES_TO_GET_FROM_ENVIRONMENT = [
    "PINECONE_API_KEY",
    "SEARCHAPI_API_KEY",
    "SERPAPI_API_KEY",
+    "UPSTASH_VECTOR_REST_URL",
+    "UPSTASH_VECTOR_REST_TOKEN",
    "VECTARA_CUSTOMER_ID",
    "VECTARA_CORPUS_ID",
    "VECTARA_API_KEY",
--- a/src/backend/base/poetry.lock
+++ b/src/backend/base/poetry.lock
@ -1224,18 +1224,18 @@ extended-testing = ["aiosqlite (>=0.19.0,<0.20.0)", "aleph-alpha-client (>=2.15.

 [[package]]
 name = "langchain-core"
-version = "0.2.1"
+version = "0.2.3"
 description = "Building applications with LLMs through composability"
 optional = false
 python-versions = "<4.0,>=3.8.1"
 files = [
-    {file = "langchain_core-0.2.1-py3-none-any.whl", hash = "sha256:3521e1e573988c47399fca9739270c5d34f8ecec147253ad829eb9ff288f76d5"},
-    {file = "langchain_core-0.2.1.tar.gz", hash = "sha256:49383126168d934559a543ce812c485048d9e6ac9b6798fbf3d4a72b6bba5b0c"},
+    {file = "langchain_core-0.2.3-py3-none-any.whl", hash = "sha256:22189b5a3a30bfd65eb995f95e627f7c2c3acb322feb89f5f5f2fb7df21833a7"},
+    {file = "langchain_core-0.2.3.tar.gz", hash = "sha256:fbc75a64b9c0b7655d96ca57a707df1e6c09efc1539c36adbd73260612549810"},
 ]

 [package.dependencies]
 jsonpatch = ">=1.33,<2.0"
-langsmith = ">=0.1.0,<0.2.0"
+langsmith = ">=0.1.65,<0.2.0"
 packaging = ">=23.2,<24.0"
 pydantic = ">=1,<3"
 PyYAML = ">=5.3"
@ -1281,13 +1281,13 @@ extended-testing = ["beautifulsoup4 (>=4.12.3,<5.0.0)", "lxml (>=4.9.3,<6.0)"]

 [[package]]
 name = "langchainhub"
-version = "0.1.16"
+version = "0.1.17"
 description = "The LangChain Hub API client"
 optional = false
 python-versions = "<4.0,>=3.8.1"
 files = [
-    {file = "langchainhub-0.1.16-py3-none-any.whl", hash = "sha256:a4379a1879cc6b441b8d02cc65e28a54f160fba61c9d1d4b0eddc3a276dff99a"},
-    {file = "langchainhub-0.1.16.tar.gz", hash = "sha256:9f11e68fddb575e70ef4b28800eedbd9eeb180ba508def04f7153ea5b246b6fc"},
+    {file = "langchainhub-0.1.17-py3-none-any.whl", hash = "sha256:4c609b3948252c71670f0d98f73413b515cfd2f6701a7b40ce959203e6133e04"},
+    {file = "langchainhub-0.1.17.tar.gz", hash = "sha256:af7df0cb1cebc7a6e0864e8632ae48ecad39ed96568f699c78657b9d04e50b46"},
 ]

 [package.dependencies]
@ -1296,13 +1296,13 @@ types-requests = ">=2.31.0.2,<3.0.0.0"

 [[package]]
 name = "langsmith"
-version = "0.1.63"
+version = "0.1.67"
 description = "Client library to connect to the LangSmith LLM Tracing and Evaluation Platform."
 optional = false
 python-versions = "<4.0,>=3.8.1"
 files = [
-    {file = "langsmith-0.1.63-py3-none-any.whl", hash = "sha256:7810afdf5e3f3b472fc581a29371fb96cd843dde2149e048d1b9610325159d1e"},
-    {file = "langsmith-0.1.63.tar.gz", hash = "sha256:a609405b52f6f54df442a142cbf19ab38662d54e532f96028b4c546434d4afdf"},
+    {file = "langsmith-0.1.67-py3-none-any.whl", hash = "sha256:7eb2e1c1b375925ff47700ed8071e10c15e942e9d1d634b4a449a9060364071a"},
+    {file = "langsmith-0.1.67.tar.gz", hash = "sha256:149558669a2ac4f21471cd964e61072687bba23b7c1ccb51f190a8f59b595b39"},
 ]

 [package.dependencies]
@ -2466,13 +2466,13 @@ files = [

 [[package]]
 name = "requests"
-version = "2.32.2"
+version = "2.32.3"
 description = "Python HTTP for Humans."
 optional = false
 python-versions = ">=3.8"
 files = [
-    {file = "requests-2.32.2-py3-none-any.whl", hash = "sha256:fc06670dd0ed212426dfeb94fc1b983d917c4f9847c863f313c9dfaaffb7c23c"},
-    {file = "requests-2.32.2.tar.gz", hash = "sha256:dd951ff5ecf3e3b3aa26b40703ba77495dab41da839ae72ef3c8e5d8e2433289"},
+    {file = "requests-2.32.3-py3-none-any.whl", hash = "sha256:70761cfe03c773ceb22aa2f671b4757976145175cdfca038c02654d061d6dcc6"},
+    {file = "requests-2.32.3.tar.gz", hash = "sha256:55365417734eb18255590a9ff9eb97e9e1da868d4ccd6402399eaf68af20a760"},
 ]

 [package.dependencies]
--- a/src/backend/base/pyproject.toml
+++ b/src/backend/base/pyproject.toml
@ -1,6 +1,6 @@
 [tool.poetry]
 name = "langflow-base"
-version = "0.0.53"
+version = "0.0.54"
 description = "A Python package with a built-in web application"
 authors = ["Langflow <contact@langflow.org>"]
 maintainers = [
--- a/src/frontend/src/components/accordionComponent/composite/folderAccordionComponent/index.tsx
+++ b/src/frontend/src/components/accordionComponent/composite/folderAccordionComponent/index.tsx
@ -15,7 +15,7 @@ export default function FolderAccordionComponent({
  options,
 }: AccordionComponentType): JSX.Element {
  const [value, setValue] = useState(
-    open.length === 0 ? "" : getOpenAccordion(),
+    open.length === 0 ? "" : getOpenAccordion()
  );

  function getOpenAccordion(): string {
--- a/src/frontend/src/components/cardComponent/components/dragCardComponent/index.tsx
+++ b/src/frontend/src/components/cardComponent/components/dragCardComponent/index.tsx
@ -1,7 +1,6 @@
 import { storeComponent } from "../../../../types/store";
 import { cn } from "../../../../utils/utils";
 import ForwardedIconComponent from "../../../genericIconComponent";
-import ShadTooltip from "../../../shadTooltipComponent";
 import { Card, CardHeader, CardTitle } from "../../../ui/card";

 export default function DragCardComponent({ data }: { data: storeComponent }) {
@ -11,7 +10,7 @@ export default function DragCardComponent({ data }: { data: storeComponent }) {
        draggable
        //TODO check color schema
        className={cn(
-          "group relative flex flex-col justify-between overflow-hidden transition-all hover:bg-muted/50 hover:shadow-md hover:dark:bg-[#ffffff10]",
+          "group relative flex flex-col justify-between overflow-hidden transition-all hover:bg-muted/50 hover:shadow-md hover:dark:bg-[#ffffff10]"
        )}
      >
        <div>
@ -23,7 +22,7 @@ export default function DragCardComponent({ data }: { data: storeComponent }) {
                    "visible flex-shrink-0",
                    data.is_component
                      ? "mx-0.5 h-6 w-6 text-component-icon"
-                      : "h-7 w-7 flex-shrink-0 text-flow-icon",
+                      : "h-7 w-7 flex-shrink-0 text-flow-icon"
                  )}
                  name={data.is_component ? "ToyBrick" : "Group"}
                />
--- a/src/frontend/src/components/codeAreaComponent/index.tsx
+++ b/src/frontend/src/components/codeAreaComponent/index.tsx
@ -18,7 +18,7 @@ export default function CodeAreaComponent({
  setOpen,
 }: CodeAreaComponentType) {
  const [myValue, setMyValue] = useState(
-    typeof value == "string" ? value : JSON.stringify(value),
+    typeof value == "string" ? value : JSON.stringify(value)
  );
  useEffect(() => {
    if (disabled && myValue !== "") {
--- a/src/frontend/src/components/dropdownComponent/index.tsx
+++ b/src/frontend/src/components/dropdownComponent/index.tsx
@ -59,7 +59,7 @@ export default function Dropdown({
                      ? "dropdown-component-outline"
                      : "dropdown-component-false-outline",
                    "w-full justify-between font-normal",
-                    editNode ? "input-edit-node" : "py-2",
+                    editNode ? "input-edit-node" : "py-2"
                  )}
                >
                  <span data-testid={`value-dropdown-` + id}>
@ -107,7 +107,7 @@ export default function Dropdown({
                          name="Check"
                          className={cn(
                            "ml-auto h-4 w-4 text-primary",
-                            value === option ? "opacity-100" : "opacity-0",
+                            value === option ? "opacity-100" : "opacity-0"
                          )}
                        />
                      </CommandItem>
--- a/src/frontend/src/components/genericIconComponent/index.tsx
+++ b/src/frontend/src/components/genericIconComponent/index.tsx
@ -18,7 +18,7 @@ export const ForwardedIconComponent = memo(
        strokeWidth,
        id = "",
      }: IconComponentProps,
-      ref,
+      ref
    ) => {
      const [showFallback, setShowFallback] = useState(false);

@ -65,8 +65,8 @@ export const ForwardedIconComponent = memo(
          />
        </Suspense>
      );
-    },
-  ),
+    }
+  )
 );

 export default ForwardedIconComponent;
--- a/src/frontend/src/components/headerComponent/components/menuBar/index.tsx
+++ b/src/frontend/src/components/headerComponent/components/menuBar/index.tsx
@ -132,7 +132,7 @@ export const MenuBar = ({}: {}): JSX.Element => {
                      title: UPLOAD_ERROR_ALERT,
                      list: [error],
                    });
-                  },
+                  }
                );
              }}
            >
@ -214,7 +214,7 @@ export const MenuBar = ({}: {}): JSX.Element => {
              name={isBuilding || saveLoading ? "Loader2" : "CheckCircle2"}
              className={cn(
                "h-4 w-4",
-                isBuilding || saveLoading ? "animate-spin" : "animate-wiggle",
+                isBuilding || saveLoading ? "animate-spin" : "animate-wiggle"
              )}
            />
            {printByBuildStatus()}
--- a/src/frontend/src/components/horizontalScrollFadeComponent/index.tsx
+++ b/src/frontend/src/components/horizontalScrollFadeComponent/index.tsx
@ -32,11 +32,11 @@ export default function HorizontalScrollFadeComponent({

      fadeContainerRef.current.classList.toggle(
        "fade-left",
-        isScrollable && !atStart,
+        isScrollable && !atStart
      );
      fadeContainerRef.current.classList.toggle(
        "fade-right",
-        isScrollable && !atEnd,
+        isScrollable && !atEnd
      );
    };

--- a/src/frontend/src/components/inputFileComponent/index.tsx
+++ b/src/frontend/src/components/inputFileComponent/index.tsx
@ -104,8 +104,8 @@ export default function InputFileComponent({
            editNode
              ? "input-edit-node input-dialog text-muted-foreground"
              : disabled
-                ? "input-disable input-dialog primary-input"
-                : "input-dialog primary-input text-muted-foreground"
+              ? "input-disable input-dialog primary-input"
+              : "input-dialog primary-input text-muted-foreground"
          }
        >
          {myValue !== "" ? myValue : "No file"}
--- a/src/frontend/src/components/inputGlobalComponent/index.tsx
+++ b/src/frontend/src/components/inputGlobalComponent/index.tsx
@ -19,15 +19,15 @@ export default function InputGlobalComponent({
  editNode = false,
 }: InputGlobalComponentType): JSX.Element {
  const globalVariablesEntries = useGlobalVariablesStore(
-    (state) => state.globalVariablesEntries,
+    (state) => state.globalVariablesEntries
  );

  const getVariableId = useGlobalVariablesStore((state) => state.getVariableId);
  const unavaliableFields = useGlobalVariablesStore(
-    (state) => state.unavaliableFields,
+    (state) => state.unavaliableFields
  );
  const removeGlobalVariable = useGlobalVariablesStore(
-    (state) => state.removeGlobalVariable,
+    (state) => state.removeGlobalVariable
  );
  const setErrorData = useAlertStore((state) => state.setErrorData);

@ -130,7 +130,7 @@ export default function InputGlobalComponent({
            <ForwardedIconComponent
              name="Trash2"
              className={cn(
-                "h-4 w-4 text-primary opacity-0 hover:text-status-red group-hover:opacity-100",
+                "h-4 w-4 text-primary opacity-0 hover:text-status-red group-hover:opacity-100"
              )}
              aria-hidden="true"
            />
--- a/src/frontend/src/components/recordsOutputComponent/index.tsx
+++ b/src/frontend/src/components/recordsOutputComponent/index.tsx
@ -2,8 +2,8 @@ import { ColDef, ColGroupDef } from "ag-grid-community";
 import "ag-grid-community/styles/ag-grid.css"; // Mandatory CSS required by the grid
 import "ag-grid-community/styles/ag-theme-balham.css"; // Optional Theme applied to the grid
 import { FlowPoolObjectType } from "../../types/chat";
-import TableComponent from "../tableComponent";
 import { extractColumnsFromRows } from "../../utils/utils";
+import TableComponent from "../tableComponent";

 function RecordsOutputComponent({
  flowPool,
--- a/src/frontend/src/components/sidebarComponent/components/sideBarButtons/index.tsx
+++ b/src/frontend/src/components/sidebarComponent/components/sideBarButtons/index.tsx
@ -21,7 +21,7 @@ const SideBarButtonsComponent = ({ items }: SideBarButtonsComponentProps) => {
            data-testid={`sidebar-nav-${item.title}`}
            className={cn(
              buttonVariants({ variant: "ghost" }),
-              "!w-[200px] cursor-pointer justify-start gap-2 border border-transparent hover:border-border hover:bg-transparent",
+              "!w-[200px] cursor-pointer justify-start gap-2 border border-transparent hover:border-border hover:bg-transparent"
            )}
          >
            {item.title}
--- a/src/frontend/src/components/tableAutoCellRender/index.tsx
+++ b/src/frontend/src/components/tableAutoCellRender/index.tsx
@ -5,7 +5,6 @@ import DateReader from "../dateReaderComponent";
 import NumberReader from "../numberReader";
 import ObjectRender from "../objectRender";
 import StringReader from "../stringReaderComponent";
-import { Label } from "../ui/label";
 import { Badge } from "../ui/badge";

 export default function TableAutoCellRender({
@ -35,7 +34,7 @@ export default function TableAutoCellRender({
              variant="outline"
              size="sq"
              className={cn(
-                "min-w-min bg-success-background text-success-foreground hover:bg-success-background",
+                "min-w-min bg-success-background text-success-foreground hover:bg-success-background"
              )}
            >
              {value}
--- a/src/frontend/src/components/tagsSelectorComponent/index.tsx
+++ b/src/frontend/src/components/tagsSelectorComponent/index.tsx
@ -48,7 +48,7 @@ export function TagsSelector({
              className={cn(
                selectedTags.some((category) => category === tag.name)
                  ? "min-w-min bg-beta-foreground text-background hover:bg-beta-foreground"
-                  : "",
+                  : ""
              )}
            >
              {tag.name}
--- a/src/frontend/src/components/ui/alert.tsx
+++ b/src/frontend/src/components/ui/alert.tsx
@ -1,5 +1,5 @@
-import * as React from "react";
 import { cva, type VariantProps } from "class-variance-authority";
+import * as React from "react";
 import { cn } from "../../utils/utils";

 const alertVariants = cva(
@ -15,7 +15,7 @@ const alertVariants = cva(
    defaultVariants: {
      variant: "default",
    },
-  },
+  }
 );

 const Alert = React.forwardRef<
@ -55,4 +55,4 @@ const AlertDescription = React.forwardRef<
 ));
 AlertDescription.displayName = "AlertDescription";

-export { Alert, AlertTitle, AlertDescription };
+export { Alert, AlertDescription, AlertTitle };
--- a/src/frontend/src/components/ui/checkbox.tsx
+++ b/src/frontend/src/components/ui/checkbox.tsx
@ -13,7 +13,7 @@ const Checkbox = React.forwardRef<
    ref={ref}
    className={cn(
      "peer h-4 w-4 shrink-0 rounded-sm border border-primary ring-offset-background focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-ring focus-visible:ring-offset-2 disabled:cursor-not-allowed disabled:opacity-50 data-[state=checked]:bg-primary data-[state=checked]:text-primary-foreground",
-      className,
+      className
    )}
    {...props}
  >
@ -37,7 +37,7 @@ const CheckBoxDiv = ({
    className={cn(
      className,
      "peer h-4 w-4 shrink-0 rounded-sm border border-primary ring-offset-background focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-ring focus-visible:ring-offset-2 disabled:cursor-not-allowed disabled:opacity-50",
-      checked ? "bg-primary text-primary-foreground" : "",
+      checked ? "bg-primary text-primary-foreground" : ""
    )}
  >
    {checked && (
--- a/src/frontend/src/components/ui/custom-accordion.tsx
+++ b/src/frontend/src/components/ui/custom-accordion.tsx
@ -24,7 +24,7 @@ const AccordionTrigger = React.forwardRef<
      <div
        className={cn(
          " flex flex-1 cursor-pointer items-center justify-between border-[1px] py-2 text-sm font-medium data-[state=closed]:rounded-md data-[state=open]:rounded-t-md data-[state=open]:border-b-0 data-[state=open]:bg-muted [&[data-state=open]>svg]:rotate-180",
-          className,
+          className
        )}
      >
        {children}
@ -43,7 +43,7 @@ const AccordionContent = React.forwardRef<
    ref={ref}
    className={cn(
      "data-[state=closed]:animate-accordion-up data-[state=open]:animate-accordion-down overflow-hidden border-[1px] text-sm data-[state=open]:rounded-b-md data-[state=open]:border-t-0 data-[state=open]:bg-muted",
-      className,
+      className
    )}
    {...props}
  >
--- a/src/frontend/src/components/ui/form.tsx
+++ b/src/frontend/src/components/ui/form.tsx
@ -16,18 +16,18 @@ const Form = FormProvider;

 type FormFieldContextValue<
  TFieldValues extends FieldValues = FieldValues,
-  TName extends FieldPath<TFieldValues> = FieldPath<TFieldValues>,
+  TName extends FieldPath<TFieldValues> = FieldPath<TFieldValues>
 > = {
  name: TName;
 };

 const FormFieldContext = React.createContext<FormFieldContextValue>(
-  {} as FormFieldContextValue,
+  {} as FormFieldContextValue
 );

 const FormField = <
  TFieldValues extends FieldValues = FieldValues,
-  TName extends FieldPath<TFieldValues> = FieldPath<TFieldValues>,
+  TName extends FieldPath<TFieldValues> = FieldPath<TFieldValues>
 >({
  ...props
 }: ControllerProps<TFieldValues, TName>) => {
@ -66,7 +66,7 @@ type FormItemContextValue = {
 };

 const FormItemContext = React.createContext<FormItemContextValue>(
-  {} as FormItemContextValue,
+  {} as FormItemContextValue
 );

 const FormItem = React.forwardRef<
--- a/src/frontend/src/constants/constants.ts
+++ b/src/frontend/src/constants/constants.ts
@ -606,84 +606,6 @@ export const CONTROL_NEW_USER = {

 export const tabsCode = [];

-export function tabsArray(codes: string[], method: number) {
-  if (!method) return;
-  if (method === 0) {
-    return [
-      {
-        name: "cURL",
-        mode: "bash",
-        image: "https://curl.se/logo/curl-symbol-transparent.png",
-        language: "sh",
-        code: codes[0],
-      },
-      {
-        name: "Python API",
-        mode: "python",
-        image:
-          "https://images.squarespace-cdn.com/content/v1/5df3d8c5d2be5962e4f87890/1628015119369-OY4TV3XJJ53ECO0W2OLQ/Python+API+Training+Logo.png?format=1000w",
-        language: "py",
-        code: codes[1],
-      },
-      {
-        name: "Python Code",
-        mode: "python",
-        image: "https://cdn-icons-png.flaticon.com/512/5968/5968350.png",
-        language: "py",
-        code: codes[2],
-      },
-      {
-        name: "Chat Widget HTML",
-        description:
-          "Insert this code anywhere in your &lt;body&gt; tag. To use with react and other libs, check our <a class='link-color' href='https://langflow.org/guidelines/widget'>documentation</a>.",
-        mode: "html",
-        image: "https://cdn-icons-png.flaticon.com/512/5968/5968350.png",
-        language: "py",
-        code: codes[3],
-      },
-    ];
-  }
-  return [
-    {
-      name: "cURL",
-      mode: "bash",
-      image: "https://curl.se/logo/curl-symbol-transparent.png",
-      language: "sh",
-      code: codes[0],
-    },
-    {
-      name: "Python API",
-      mode: "python",
-      image:
-        "https://images.squarespace-cdn.com/content/v1/5df3d8c5d2be5962e4f87890/1628015119369-OY4TV3XJJ53ECO0W2OLQ/Python+API+Training+Logo.png?format=1000w",
-      language: "py",
-      code: codes[1],
-    },
-    {
-      name: "Python Code",
-      mode: "python",
-      language: "py",
-      image: "https://cdn-icons-png.flaticon.com/512/5968/5968350.png",
-      code: codes[2],
-    },
-    {
-      name: "Chat Widget HTML",
-      description:
-        "Insert this code anywhere in your &lt;body&gt; tag. To use with react and other libs, check our <a class='link-color' href='https://langflow.org/guidelines/widget'>documentation</a>.",
-      mode: "html",
-      image: "https://cdn-icons-png.flaticon.com/512/5968/5968350.png",
-      language: "py",
-      code: codes[3],
-    },
-    {
-      name: "Tweaks",
-      mode: "python",
-      image: "https://cdn-icons-png.flaticon.com/512/5968/5968350.png",
-      language: "py",
-      code: codes[4],
-    },
-  ];
-}
 export const FETCH_ERROR_MESSAGE = "Couldn't establish a connection.";
 export const FETCH_ERROR_DESCRIPION =
  "Check if everything is working properly and try again.";
--- a/src/frontend/src/customNodes/genericNode/components/parameterComponent/constants.ts
+++ b/src/frontend/src/customNodes/genericNode/components/parameterComponent/constants.ts
@ -0,0 +1 @@
+export const TEXT_FIELD_TYPES: string[] = ["str", "SecretStr"];
--- a/src/frontend/src/customNodes/genericNode/components/parameterComponent/index.tsx
+++ b/src/frontend/src/customNodes/genericNode/components/parameterComponent/index.tsx
@ -43,6 +43,7 @@ import useHandleNodeClass from "../../../hooks/use-handle-node-class";
 import useHandleRefreshButtonPress from "../../../hooks/use-handle-refresh-buttons";
 import HandleTooltips from "../HandleTooltipComponent";
 import OutputComponent from "../OutputComponent";
+import { TEXT_FIELD_TYPES } from "./constants";

 export default function ParameterComponent({
  left,
@ -80,7 +81,7 @@ export default function ParameterComponent({
    debouncedHandleUpdateValues,
    setNode,
    isLoading,
-    setIsLoading,
+    setIsLoading
  );

  const { handleNodeClass: handleNodeClassHook } = useHandleNodeClass(
@ -88,7 +89,7 @@ export default function ParameterComponent({
    name,
    takeSnapshot,
    setNode,
-    updateNodeInternals,
+    updateNodeInternals
  );

  const { handleRefreshButtonPress: handleRefreshButtonPressHook } =
@ -97,7 +98,7 @@ export default function ParameterComponent({
  let disabled =
    edges.some(
      (edge) =>
-        edge.targetHandle === scapedJSONStringfy(proxy ? { ...id, proxy } : id),
+        edge.targetHandle === scapedJSONStringfy(proxy ? { ...id, proxy } : id)
    ) ?? false;

  const handleRefreshButtonPress = async (name, data) => {
@ -108,7 +109,7 @@ export default function ParameterComponent({

  const handleOnNewValue = async (
    newValue: string | string[] | boolean | Object[],
-    skipSnapshot: boolean | undefined = false,
+    skipSnapshot: boolean | undefined = false
  ): Promise<void> => {
    handleOnNewValueHook(newValue, skipSnapshot);
  };
@ -190,14 +191,14 @@ export default function ParameterComponent({
              className={classNames(
                left ? "my-12 -ml-0.5 " : " my-12 -mr-0.5 ",
                "h-3 w-3 rounded-full border-2 bg-background",
-                !showNode ? "mt-0" : "",
+                !showNode ? "mt-0" : ""
              )}
              style={{
                borderColor: color ?? nodeColors.unknown,
              }}
              onClick={() => {
                setFilterEdge(
-                  groupByFamily(myData, tooltipTitle!, left, nodes!),
+                  groupByFamily(myData, tooltipTitle!, left, nodes!)
                );
              }}
            ></Handle>
@ -282,12 +283,12 @@ export default function ParameterComponent({
                  }
                  className={classNames(
                    left ? "-ml-0.5" : "-mr-0.5",
-                    "h-3 w-3 rounded-full border-2 bg-background",
+                    "h-3 w-3 rounded-full border-2 bg-background"
                  )}
                  style={{ borderColor: color ?? nodeColors.unknown }}
                  onClick={() => {
                    setFilterEdge(
-                      groupByFamily(myData, tooltipTitle!, left, nodes!),
+                      groupByFamily(myData, tooltipTitle!, left, nodes!)
                    );
                  }}
                />
@ -299,7 +300,7 @@ export default function ParameterComponent({
        <Case
          condition={
            left === true &&
-            type === "str" &&
+            TEXT_FIELD_TYPES.includes(type ?? "") &&
            !data.node?.template[name]?.options
          }
        >
@ -345,8 +346,7 @@ export default function ParameterComponent({
                      name={name}
                      data={data}
                      button_text={
-                        data.node?.template[name]?.refresh_button_text ??
-                        "Refresh"
+                        data.node?.template[name].refresh_button_text
                      }
                      className="extra-side-bar-buttons mt-1"
                      handleUpdateValues={handleRefreshButtonPress}
@ -394,8 +394,7 @@ export default function ParameterComponent({
                      name={name}
                      data={data}
                      button_text={
-                        data.node?.template[name]?.refresh_button_text ??
-                        "Refresh"
+                        data.node?.template[name].refresh_button_text
                      }
                      className="extra-side-bar-buttons ml-2 mt-1"
                      handleUpdateValues={handleRefreshButtonPress}
--- a/src/frontend/src/customNodes/genericNode/components/tooltipRenderComponent/index.tsx
+++ b/src/frontend/src/customNodes/genericNode/components/tooltipRenderComponent/index.tsx
@ -24,7 +24,7 @@ const TooltipRenderComponent = ({ item, index, left }) => {
      <span
        key={index}
        className={classNames(
-          index > 0 ? "mt-2 flex items-center" : "mt-3 flex items-center",
+          index > 0 ? "mt-2 flex items-center" : "mt-3 flex items-center"
        )}
      >
        <div
--- a/src/frontend/src/customNodes/hooks/use-fetch-data-on-mount.tsx
+++ b/src/frontend/src/customNodes/hooks/use-fetch-data-on-mount.tsx
@ -8,7 +8,7 @@ const useFetchDataOnMount = (
  name,
  handleUpdateValues,
  setNode,
-  setIsLoading,
+  setIsLoading
 ) => {
  const setErrorData = useAlertStore((state) => state.setErrorData);

--- a/src/frontend/src/customNodes/hooks/use-handle-new-value.tsx
+++ b/src/frontend/src/customNodes/hooks/use-handle-new-value.tsx
@ -9,8 +9,7 @@ const useHandleOnNewValue = (
  handleUpdateValues,
  debouncedHandleUpdateValues,
  setNode,
-  isLoading,
-  setIsLoading,
+  setIsLoading
 ) => {
  const setErrorData = useAlertStore((state) => state.setErrorData);

--- a/src/frontend/src/customNodes/hooks/use-handle-node-class.tsx
+++ b/src/frontend/src/customNodes/hooks/use-handle-node-class.tsx
@ -5,7 +5,7 @@ const useHandleNodeClass = (
  name,
  takeSnapshot,
  setNode,
-  updateNodeInternals,
+  updateNodeInternals
 ) => {
  const handleNodeClass = (newNodeClass, code) => {
    if (!data.node) return;
--- a/src/frontend/src/modals/apiModal/utils/get-curl-code.tsx
+++ b/src/frontend/src/modals/apiModal/utils/get-curl-code.tsx
@ -4,7 +4,7 @@
 * @param {boolean} isAuth - If the API is authenticated
 * @returns {string} - The curl code
 */
-export default function getCurlCode(
+export function getCurlRunCode(
  flowId: string,
  isAuth: boolean,
  tweaksBuildedObject,
@ -13,9 +13,9 @@ export default function getCurlCode(
  const tweaksObject = tweaksBuildedObject[0];
  // show the endpoint name in the curl command if it exists
  return `curl -X POST \\
-    ${window.location.protocol}//${window.location.host}/api/v1/run/${
+    "${window.location.protocol}//${window.location.host}/api/v1/run/${
    endpointName || flowId
-  }?stream=false \\
+  }?stream=false" \\
    -H 'Content-Type: application/json'\\${
      !isAuth ? `\n  -H 'x-api-key: <your api key>'\\` : ""
    }
@ -25,3 +25,24 @@ export default function getCurlCode(
    "tweaks": ${JSON.stringify(tweaksObject, null, 2)}}'
    `;
 }
+
+/**
+ * Generates a cURL command for making a POST request to a webhook endpoint.
+ *
+ * @param {Object} options - The options for generating the cURL command.
+ * @param {string} options.flowId - The ID of the flow.
+ * @param {boolean} options.isAuth - Indicates whether authentication is required.
+ * @param {string} options.endpointName - The name of the webhook endpoint.
+ * @returns {string} The cURL command.
+ */
+export function getCurlWebhookCode(flowId, isAuth, endpointName?: string) {
+  return `curl -X POST \\
+  "${window.location.protocol}//${window.location.host}/api/v1/webhook/${
+    endpointName || flowId
+  }" \\
+  -H 'Content-Type: application/json'\\${
+    !isAuth ? `\n  -H 'x-api-key: <your api key>'\\` : ""
+  }
+  -d '{"any": "data"}'
+  `;
+}
--- a/src/frontend/src/modals/apiModal/utils/tabs-array.tsx
+++ b/src/frontend/src/modals/apiModal/utils/tabs-array.tsx
@ -1,43 +1,11 @@
-export default function tabsArray(codes: string[], method: number) {
-  if (!method) return;
-  if (method === 0) {
-    return [
-      {
-        name: "cURL",
-        mode: "bash",
-        image: "https://curl.se/logo/curl-symbol-transparent.png",
-        language: "sh",
-        code: codes[0],
-      },
-      {
-        name: "Python API",
-        mode: "python",
-        image:
-          "https://images.squarespace-cdn.com/content/v1/5df3d8c5d2be5962e4f87890/1628015119369-OY4TV3XJJ53ECO0W2OLQ/Python+API+Training+Logo.png?format=1000w",
-        language: "py",
-        code: codes[1],
-      },
-      {
-        name: "Python Code",
-        mode: "python",
-        image: "https://cdn-icons-png.flaticon.com/512/5968/5968350.png",
-        language: "py",
-        code: codes[2],
-      },
-      {
-        name: "Chat Widget HTML",
-        description:
-          "Insert this code anywhere in your &lt;body&gt; tag. To use with react and other libs, check our <a class='link-color' href='https://langflow.org/guidelines/widget'>documentation</a>.",
-        mode: "html",
-        image: "https://cdn-icons-png.flaticon.com/512/5968/5968350.png",
-        language: "py",
-        code: codes[3],
-      },
-    ];
-  }
-  return [
+export function createTabsArray(
+  codes,
+  includeWebhookCurl = false,
+  includeTweaks = false
+) {
+  const tabs = [
    {
-      name: "cURL",
+      name: "Run cURL",
      mode: "bash",
      image: "https://curl.se/logo/curl-symbol-transparent.png",
      language: "sh",
@ -49,14 +17,14 @@ export default function tabsArray(codes: string[], method: number) {
      image:
        "https://images.squarespace-cdn.com/content/v1/5df3d8c5d2be5962e4f87890/1628015119369-OY4TV3XJJ53ECO0W2OLQ/Python+API+Training+Logo.png?format=1000w",
      language: "py",
-      code: codes[1],
+      code: codes[2],
    },
    {
      name: "Python Code",
      mode: "python",
-      language: "py",
      image: "https://cdn-icons-png.flaticon.com/512/5968/5968350.png",
-      code: codes[2],
+      language: "py",
+      code: codes[3],
    },
    {
      name: "Chat Widget HTML",
@ -64,15 +32,30 @@ export default function tabsArray(codes: string[], method: number) {
        "Insert this code anywhere in your &lt;body&gt; tag. To use with react and other libs, check our <a class='link-color' href='https://langflow.org/guidelines/widget'>documentation</a>.",
      mode: "html",
      image: "https://cdn-icons-png.flaticon.com/512/5968/5968350.png",
-      language: "py",
-      code: codes[3],
+      language: "html",
+      code: codes[4],
    },
-    {
+  ];
+
+  if (includeWebhookCurl) {
+    tabs.splice(1, 0, {
+      name: "Webhook cURL",
+      mode: "bash",
+      image: "https://curl.se/logo/curl-symbol-transparent.png",
+      language: "sh",
+      code: codes[1],
+    });
+  }
+
+  if (includeTweaks) {
+    tabs.push({
      name: "Tweaks",
      mode: "python",
      image: "https://cdn-icons-png.flaticon.com/512/5968/5968350.png",
      language: "py",
-      code: codes[4],
-    },
-  ];
+      code: codes[5],
+    });
+  }
+
+  return tabs;
 }
--- a/src/frontend/src/modals/apiModal/views/index.tsx
+++ b/src/frontend/src/modals/apiModal/views/index.tsx
@ -18,13 +18,13 @@ import { buildContent } from "../utils/build-content";
 import { buildTweaks } from "../utils/build-tweaks";
 import { checkCanBuildTweakObject } from "../utils/check-can-build-tweak-object";
 import { getChangesType } from "../utils/get-changes-types";
-import getCurlCode from "../utils/get-curl-code";
+import { getCurlRunCode, getCurlWebhookCode } from "../utils/get-curl-code";
 import { getNodesWithDefaultValue } from "../utils/get-nodes-with-default-value";
 import getPythonApiCode from "../utils/get-python-api-code";
 import getPythonCode from "../utils/get-python-code";
 import { getValue } from "../utils/get-value";
 import getWidgetCode from "../utils/get-widget-code";
-import tabsArray from "../utils/tabs-array";
+import { createTabsArray } from "../utils/tabs-array";

 const ApiModal = forwardRef(
  (
@ -47,23 +47,33 @@ const ApiModal = forwardRef(
    const [open, setOpen] = useState(false);
    const [activeTab, setActiveTab] = useState("0");
    const pythonApiCode = getPythonApiCode(flow?.id, autoLogin, tweak);
-    const curl_code = getCurlCode(
+    const curl_run_code = getCurlRunCode(
      flow?.id,
      autoLogin,
      tweak,
      flow?.endpoint_name
    );
+    const curl_webhook_code = getCurlWebhookCode(
+      flow?.id,
+      autoLogin,
+      flow?.endpoint_name
+    );
    const pythonCode = getPythonCode(flow?.name, tweak);
    const widgetCode = getWidgetCode(flow?.id, flow?.name, autoLogin);
+    console.log("flow", flow);
+    const includeWebhook = flow.webhook;
    const tweaksCode = buildTweaks(flow);
    const codesArray = [
-      curl_code,
+      curl_run_code,
+      curl_webhook_code,
      pythonApiCode,
      pythonCode,
      widgetCode,
      pythonCode,
    ];
-    const [tabs, setTabs] = useState(tabsArray(codesArray, 0));
+    const [tabs, setTabs] = useState(
+      createTabsArray(codesArray, includeWebhook)
+    );

    const canShowTweaks =
      flow &&
@ -93,9 +103,9 @@ const ApiModal = forwardRef(

      if (Object.keys(tweaksCode).length > 0) {
        setActiveTab("0");
-        setTabs(tabsArray(codesArray, 1));
+        setTabs(createTabsArray(codesArray, includeWebhook, true));
      } else {
-        setTabs(tabsArray(codesArray, 1));
+        setTabs(createTabsArray(codesArray, includeWebhook, true));
      }
    }, [flow["data"]!["nodes"], open]);

@ -166,7 +176,7 @@ const ApiModal = forwardRef(

    const addCodes = (cloneTweak) => {
      const pythonApiCode = getPythonApiCode(flow?.id, autoLogin, cloneTweak);
-      const curl_code = getCurlCode(
+      const curl_code = getCurlRunCode(
        flow?.id,
        autoLogin,
        cloneTweak,
--- a/src/frontend/src/types/flow/index.ts
+++ b/src/frontend/src/types/flow/index.ts
@ -19,6 +19,7 @@ export type FlowType = {
  icon?: string;
  icon_bg_color?: string;
  folder_id?: string;
+  webhook?: boolean;
 };

 export type NodeType = {
				`@ -0,0 +1 @@`
				`export const TEXT_FIELD_TYPES: string[] = ["str", "SecretStr"];`