Paginate runs on BE

apps/api/lib/buildel_web/controllers/organizations/pipelines/runs/run_controller.ex

@@ -14,18 +14,33 @@ defmodule BuildelWeb.OrganizationPipelineRunController do
   plug(:fetch_current_user)
   plug(:require_authenticated_user)
 
-  def index(conn, %{"organization_id" => organization_id, "pipeline_id" => pipeline_id}) do
+  defparams :index do
+    required(:page, :integer)
+    required(:per_page, :integer)
+  end
+
+  @default_params %{
+    "page" => 0,
+    "per_page" => 10
+  }
+
+  def index(conn, %{"organization_id" => organization_id, "pipeline_id" => pipeline_id} = params) do
+    params = Map.merge(@default_params, params)
     user = conn.assigns.current_user
 
-    with {:ok, organization} <- Organizations.get_user_organization(user, organization_id),
+    with {:ok, params} <- validate(:index, params),
+         {:ok, organization} <- Organizations.get_user_organization(user, organization_id),
          {:ok, %Pipeline{} = pipeline} <-
            Pipelines.get_organization_pipeline(organization, pipeline_id),
          runs <- Pipelines.list_pipeline_runs(pipeline) do
-      render(conn, :index, runs: runs)
+      render(conn, :index, runs: runs, pagination_params: params)
     end
   end
 
-  def show(conn, %{"organization_id" => organization_id, "pipeline_id" => pipeline_id, "id" => id}) do
+  def show(
+        conn,
+        %{"organization_id" => organization_id, "pipeline_id" => pipeline_id, "id" => id}
+      ) do
     user = conn.assigns.current_user
 
     with {:ok, organization} <- Organizations.get_user_organization(user, organization_id),

apps/api/lib/buildel_web/controllers/organizations/pipelines/runs/run_json.ex

@@ -1,8 +1,18 @@
 defmodule BuildelWeb.OrganizationPipelineRunJSON do
   alias Buildel.Pipelines.Run
 
-  def index(%{runs: runs}) do
-    %{data: for(run <- runs, do: data(run))}
+  def index(%{runs: runs, pagination_params: pagination_params}) do
+    %{
+      data:
+        for(run <- runs, do: data(run))
+        |> Enum.drop(pagination_params.page * pagination_params.per_page)
+        |> Enum.take(pagination_params.per_page),
+      meta: %{
+        total: Enum.count(runs),
+        page: pagination_params.page,
+        per_page: pagination_params.per_page
+      }
+    }
   end
 
   def show(%{run: run}) do