feat: optimize dropdown filtering and output resolution

misc: remove commented out code

feat: add refresh button and sort flows by updated_at date from most to least recent

ruff (flow.py imports)

improve fn contracts in runflow and improve flow id retrieval logic based on graph exec context

add dynamic outputs and optimize db lookups

add flow cache and db query for getting a single flow by id or name

cache run outputs and add refresh context to build config

misc

misc

use ids for flow retrieval

misc

fix missing flow_id bug

add unit and integration tests

add input field flag to persist hidden fields at runtime

move unit tests and change input and output display names

chore: update component index

fix: fix tool mode when flow has multiple inputs by dynamically creating resolvers

chore: update component index

ruff (run_flow and tests)

add resolvers to outputs map for non tool mode runtime

fix tests (current flow excluded in db fetch)

mypy (helpers/flow.py)

chore: update component index

remove unused code and clean up comments

fix: persist user messages in chat-based flows via session injection

chore: update component index

empty string fallback for sessionid in chat.py

chore: update component index

chore: update component index

cache invalidation with timestamps

misc

add cache invalidation

chore: update component index

chore: update comp idx

ruff (run_flow.py)

change session_id input type to MessageTextInput

chore: update component index

chore: update component index

chore: update component index

chore: update component index

sync starter projects with main

chore: update component index

Author: HzaRashid

src/backend/base/langflow/helpers/flow.py

@@ -6,7 +6,8 @@
 from fastapi import HTTPException
 from lfx.log.logger import logger
 from pydantic.v1 import BaseModel, Field, create_model
-from sqlmodel import select
+from sqlalchemy.orm import aliased
+from sqlmodel import asc, desc, select
 
 from langflow.schema.schema import INPUT_FIELD_NAME
 from langflow.services.database.models.flow.model import Flow, FlowRead
@@ -19,14 +20,17 @@
     from lfx.graph.schema import RunOutputs
     from lfx.graph.vertex.base import Vertex
 
-    from langflow.schema.data import Data
+from langflow.schema.data import Data
 
 INPUT_TYPE_MAP = {
     "ChatInput": {"type_hint": "Optional[str]", "default": '""'},
     "TextInput": {"type_hint": "Optional[str]", "default": '""'},
     "JSONInput": {"type_hint": "Optional[dict]", "default": "{}"},
 }
-
+SORT_DISPATCHER = {
+    "asc": asc,
+    "desc": desc,
+    }
 
 async def list_flows(*, user_id: str | None = None) -> list[Data]:
     if not user_id:
@@ -44,6 +48,122 @@ async def list_flows(*, user_id: str | None = None) -> list[Data]:
         raise ValueError(msg) from e
 
 
+async def list_flows_by_flow_folder(
+    *,
+    user_id: str | None = None,
+    flow_id: str | None = None,
+    order_params: dict | None = {"column": "updated_at", "direction": "desc"} # noqa: B006
+    ) -> list[Data]:
+    if not user_id:
+        msg = "Session is invalid"
+        raise ValueError(msg)
+    if not flow_id:
+        msg = "Flow ID is required"
+        raise ValueError(msg)
+    try:
+        async with session_scope() as session:
+            uuid_user_id = UUID(user_id) if isinstance(user_id, str) else user_id
+            uuid_flow_id = UUID(flow_id) if isinstance(flow_id, str) else flow_id
+            # get all flows belonging to the specified user
+            # and inside the same folder as the specified flow
+            flow_ = aliased(Flow) # flow table alias, used to retrieve the folder
+            stmt = (select(Flow.id, Flow.name, Flow.updated_at)
+                .join(flow_, Flow.folder_id == flow_.folder_id)
+                .where(flow_.id == uuid_flow_id)
+                .where(flow_.user_id == uuid_user_id)
+                .where(Flow.user_id == uuid_user_id)
+                .where(Flow.id != uuid_flow_id)
+                )
+            # sort flows by the specified column and direction
+            if order_params is not None:
+                sort_col = getattr(Flow, order_params.get("column", "updated_at"), Flow.updated_at)
+                sort_dir = SORT_DISPATCHER.get(order_params.get("direction", "desc"), desc)
+                stmt = stmt.order_by(sort_dir(sort_col))
+
+            flows = (await session.exec(stmt)).all()
+            return [Data(data=dict(flow._mapping)) for flow in flows] # noqa: SLF001
+    except Exception as e:
+        msg = f"Error listing flows: {e}"
+        raise ValueError(msg) from e
+
+
+async def list_flows_by_folder_id(
+    *,
+    user_id: str | None = None,
+    folder_id: str | None = None,
+    order_params: dict | None = {"column": "updated_at", "direction": "desc"} # noqa: B006
+    ) -> list[Data]:
+    if not user_id:
+        msg = "Session is invalid"
+        raise ValueError(msg)
+    if not folder_id:
+        msg = "Folder ID is required"
+        raise ValueError(msg)
+
+    try:
+        async with session_scope() as session:
+            uuid_user_id = UUID(user_id) if isinstance(user_id, str) else user_id
+            uuid_folder_id = UUID(folder_id) if isinstance(folder_id, str) else folder_id
+            stmt = (select(Flow.id, Flow.name, Flow.updated_at)
+                .where(Flow.user_id == uuid_user_id)
+                .where(Flow.folder_id == uuid_folder_id)
+                )
+            if order_params is not None:
+                sort_col = getattr(Flow, order_params.get("column", "updated_at"), Flow.updated_at)
+                sort_dir = SORT_DISPATCHER.get(order_params.get("direction", "desc"), desc)
+                stmt = stmt.order_by(sort_dir(sort_col))
+
+            flows = (await session.exec(stmt)).all()
+            return [Data(data=dict(flow._mapping)) for flow in flows] # noqa: SLF001
+    except Exception as e:
+        msg = f"Error listing flows: {e}"
+        raise ValueError(msg) from e
+
+
+async def get_flow_by_id_or_name(
+    *,
+    user_id: str | None = None,
+    flow_id: str | None = None,
+    flow_name: str | None = None,
+    ) -> Data | None:
+    if not user_id:
+        msg = "Session is invalid"
+        raise ValueError(msg)
+    if not (flow_id or flow_name):
+        msg = "Flow ID or Flow Name is required"
+        raise ValueError(msg)
+
+    # set user provided flow id or flow name.
+    # if both are provided, flow_id is used.
+    attr, val = None, None
+    if flow_name:
+        attr = "name"
+        val = flow_name
+    if flow_id:
+        attr = "id"
+        val = flow_id
+    if not (attr and val):
+        msg = "Flow id or Name is required"
+        raise ValueError(msg)
+    try:
+        async with session_scope() as session:
+            uuid_user_id = UUID(user_id) if isinstance(user_id, str) else user_id # type: ignore[assignment]
+            uuid_flow_id_or_name = val # type: ignore[assignment]
+            if isinstance(val, str) and attr == "id":
+                uuid_flow_id_or_name = UUID(val) # type: ignore[assignment]
+            stmt = (
+                select(Flow)
+                .where(Flow.user_id == uuid_user_id)
+                .where(getattr(Flow, attr) == uuid_flow_id_or_name)
+                )
+            flow = (await session.exec(stmt)).first()
+            return flow.to_data() if flow else None
+
+    except Exception as e:
+        msg = f"Error getting flow by id: {e}"
+        raise ValueError(msg) from e
+
+
 async def load_flow(
     user_id: str, flow_id: str | None = None, flow_name: str | None = None, tweaks: dict | None = None
 ) -> Graph:

src/backend/base/langflow/services/database/models/flow/model.py

@@ -203,6 +203,7 @@ def to_data(self):
             "name": serialized.pop("name"),
             "description": serialized.pop("description"),
             "updated_at": serialized.pop("updated_at"),
+            "folder_id": serialized.pop("folder_id"),
         }
         return Data(data=data)