chore: add cursor envelope endpoint

Author: vishalg0wda

cmd/server/main.go

@@ -44,6 +44,7 @@ func main() {
 	r.HandleFunc("/pagination/limitoffset/deep_outputs/page", pagination.HandleLimitOffsetDeepOutputsPage).Methods(http.MethodGet, http.MethodPut)
 	r.HandleFunc("/pagination/limitoffset/offset", pagination.HandleLimitOffsetOffset).Methods(http.MethodGet, http.MethodPut)
 	r.HandleFunc("/pagination/cursor", pagination.HandleCursor).Methods(http.MethodGet, http.MethodPut)
+	r.HandleFunc("/pagination/cursor/response_envelope", pagination.HandleCursorResponseEnvelope).Methods(http.MethodGet, http.MethodPut)
 	r.HandleFunc("/pagination/url", pagination.HandleURL).Methods(http.MethodGet)
 	r.HandleFunc("/pagination/cursor_non_numeric", pagination.HandleNonNumericCursor).Methods(http.MethodGet)
 	r.HandleFunc("/retries", retries.HandleRetries).Methods(http.MethodGet, http.MethodPost)

internal/pagination/service.go

@@ -123,21 +123,62 @@ func HandleCursor(w http.ResponseWriter, r *http.Request) {
 	}
 
 	cursor := getValue(queryCursor, hasBody, pagination.Cursor)
+	resultArray := make([]interface{}, 0)
 
+	for i := cursor + 1; i < total && len(resultArray) < 15; i++ {
+		resultArray = append(resultArray, i)
+	}
+
+	w.Header().Set("Content-Type", "application/json")
 	res := PaginationResponse{
 		NumPages:    0,
-		ResultArray: make([]interface{}, 0),
+		ResultArray: resultArray,
 	}
 
-	for i := cursor + 1; i < total && len(res.ResultArray) < 15; i++ {
-		res.ResultArray = append(res.ResultArray, i)
+	err := json.NewEncoder(w).Encode(res)
+	if err != nil {
+		w.WriteHeader(500)
+	}
+
+}
+
+func HandleCursorResponseEnvelope(w http.ResponseWriter, r *http.Request) {
+	queryCursor := r.FormValue("cursor")
+
+	var pagination CursorRequest
+	hasBody := true
+	if err := json.NewDecoder(r.Body).Decode(&pagination); err != nil {
+		hasBody = false
+	}
+
+	cursor := getValue(queryCursor, hasBody, pagination.Cursor)
+	resultArray := make([]interface{}, 0)
+
+	for i := cursor + 1; i < total && len(resultArray) < 15; i++ {
+		resultArray = append(resultArray, i)
 	}
 
 	w.Header().Set("Content-Type", "application/json")
+	var lastItem *string
+	if len(resultArray) > 0 {
+		idx := strconv.Itoa(resultArray[len(resultArray)-1].(int))
+		lastItem = &idx
+	} else {
+		lastItem = nil
+	}
+
+	res := PaginationResponseDeep{
+		PageInfo: PageInfo{
+			Next: lastItem,
+		},
+		ResultArray: resultArray,
+	}
+
 	err := json.NewEncoder(w).Encode(res)
 	if err != nil {
 		w.WriteHeader(500)
 	}
+
 }
 
 func HandleURL(w http.ResponseWriter, r *http.Request) {