feat: add offset and limit pagination to tasks output endpoint #3057

api-docs.yml

@@ -2429,6 +2429,19 @@ paths:
       - $ref: '#/parameters/project_id'
       - $ref: '#/parameters/task_id'
     get:
+      parameters:
+        - name: limit
+          in: query
+          required: false
+          type: integer
+          description: Maximum number of items to return. Use 0 to return all available items
+          x-example: 1000
+        - name: offset
+          in: query
+          required: false
+          type: integer
+          description: Number of items to skip before starting to collect the result set. Defaults to 0.
+          x-example: 0
       tags:
         - project
       summary: Get task output

api/projects/tasks.go

@@ -3,15 +3,16 @@ package projects
 import (
 	"bytes"
 	"errors"
+	"net/http"
+	"strconv"
+	"time"
+
 	"github.com/gorilla/context"
 	"github.com/semaphoreui/semaphore/api/helpers"
 	"github.com/semaphoreui/semaphore/db"
 	"github.com/semaphoreui/semaphore/services/tasks"
 	"github.com/semaphoreui/semaphore/util"
 	log "github.com/sirupsen/logrus"
-	"net/http"
-	"strconv"
-	"time"
 )
 
 // AddTask inserts a task into the database and returns a header or returns error
@@ -145,8 +146,20 @@ func GetTaskOutput(w http.ResponseWriter, r *http.Request) {
 	task := context.Get(r, "task").(db.Task)
 	project := context.Get(r, "project").(db.Project)
 
+	limitStr := r.URL.Query().Get("limit")
+	limit, err := strconv.Atoi(limitStr)
+	if err != nil {
+		limit = 0
+	}
+
+	offsetStr := r.URL.Query().Get("offset")
+	offset, err := strconv.Atoi(offsetStr)
+	if err != nil {
+		offset = 0
+	}
+
 	var output []db.TaskOutput
-	output, err := helpers.Store(r).GetTaskOutputs(project.ID, task.ID, db.RetrieveQueryParams{})
+	output, err = helpers.Store(r).GetTaskOutputs(project.ID, task.ID, db.RetrieveQueryParams{Offset: offset, Count: limit})
 
 	if err != nil {
 		util.LogErrorF(err, log.Fields{"error": "Bad request. Cannot get task output from database"})