Add initial setup tests

tests/test_initial_setup.py

@@ -0,0 +1,84 @@
+from itertools import chain
+
+import pytest
+from sqlalchemy import func
+from sqlmodel import select
+
+from langflow.graph.graph.base import Graph
+from langflow.graph.schema import ResultData
+from langflow.initial_setup.setup import (
+    STARTER_FOLDER_NAME,
+    create_or_update_starter_projects,
+    get_project_data,
+    load_starter_projects,
+)
+from langflow.services.database.models.flow.model import Flow
+from langflow.services.deps import session_scope
+
+
+def test_load_starter_projects():
+    projects = load_starter_projects()
+    assert isinstance(projects, list)
+    assert all(isinstance(project, dict) for project in projects)
+
+
+def test_get_project_data():
+    projects = load_starter_projects()
+    for project in projects:
+        data = get_project_data(project)
+        assert all(d is not None for d in data)
+
+
+def test_create_or_update_starter_projects(client):
+    with session_scope() as session:
+        # Run the function to create or update projects
+        create_or_update_starter_projects()
+
+        # Get the number of projects returned by load_starter_projects
+        num_projects = len(load_starter_projects())
+
+        # Get the number of projects in the database
+        num_db_projects = session.exec(
+            select(func.count(Flow.id)).where(Flow.folder == STARTER_FOLDER_NAME)
+        ).one()
+
+        # Check that the number of projects in the database is the same as the number of projects returned by load_starter_projects
+        assert num_db_projects == num_projects
+
+
+@pytest.mark.asyncio
+async def test_starter_project_can_run_successfully(client):
+    with session_scope() as session:
+        # Run the function to create or update projects
+        create_or_update_starter_projects()
+
+        # Get the number of projects returned by load_starter_projects
+        num_projects = len(load_starter_projects())
+
+        # Get the number of projects in the database
+        num_db_projects = session.exec(
+            select(func.count(Flow.id)).where(Flow.folder == STARTER_FOLDER_NAME)
+        ).one()
+
+        # Check that the number of projects in the database is the same as the number of projects returned by load_starter_projects
+        assert num_db_projects == num_projects
+
+        # Get all the starter projects
+        projects = session.exec(
+            select(Flow).where(Flow.folder == STARTER_FOLDER_NAME)
+        ).all()
+
+        graphs: list[Graph] = [
+            (project.name, Graph.from_payload(project.data, flow_id=project.id))
+            for project in projects
+        ]
+        assert len(graphs) == len(projects)
+    for name, graph in graphs:
+        outputs = await graph.run(
+            inputs={},
+            outputs=[],
+            session_id="test",
+        )
+        assert all(
+            isinstance(output, ResultData) for output in chain.from_iterable(outputs)
+        ), f"Project {name} error: {outputs}"