crawlab/core/controllers/result_v2.go

package controllers

import (
	models2 "github.com/crawlab-team/crawlab/core/models/models/v2"
	"github.com/crawlab-team/crawlab/core/models/service"
	"github.com/crawlab-team/crawlab/core/result"
	"github.com/crawlab-team/crawlab/core/utils"
	"github.com/crawlab-team/crawlab/db/generic"
	"github.com/gin-gonic/gin"
	"go.mongodb.org/mongo-driver/bson"
	"go.mongodb.org/mongo-driver/bson/primitive"
	mongo2 "go.mongodb.org/mongo-driver/mongo"
)

func GetResultList(c *gin.Context) {
	// data collection id
	dcId, err := primitive.ObjectIDFromHex(c.Param("id"))
	if err != nil {
		HandleErrorBadRequest(c, err)
		return
	}

	// data source id
	var dsId primitive.ObjectID
	dsIdStr := c.Query("data_source_id")
	if dsIdStr != "" {
		dsId, err = primitive.ObjectIDFromHex(dsIdStr)
		if err != nil {
			HandleErrorBadRequest(c, err)
			return
		}
	}

	// data collection
	dc, err := service.NewModelServiceV2[models2.DataCollectionV2]().GetById(dcId)
	if err != nil {
		HandleErrorInternalServerError(c, err)
		return
	}

	// data source
	ds, err := service.NewModelServiceV2[models2.DataSourceV2]().GetById(dsId)
	if err != nil {
		if err.Error() == mongo2.ErrNoDocuments.Error() {
			ds = &models2.DataSourceV2{}
		} else {
			HandleErrorInternalServerError(c, err)
			return
		}
	}

	// spider
	sq := bson.M{
		"col_id":         dc.Id,
		"data_source_id": ds.Id,
	}
	s, err := service.NewModelServiceV2[models2.SpiderV2]().GetOne(sq, nil)
	if err != nil {
		HandleErrorInternalServerError(c, err)
		return
	}

	// service
	svc, err := result.GetResultService(s.Id)
	if err != nil {
		HandleErrorInternalServerError(c, err)
		return
	}

	// params
	pagination := MustGetPagination(c)
	query := getResultListQuery(c)

	// get results
	data, err := svc.List(query, &generic.ListOptions{
		Sort:  []generic.ListSort{{"_id", generic.SortDirectionDesc}},
		Skip:  pagination.Size * (pagination.Page - 1),
		Limit: pagination.Size,
	})
	if err != nil {
		if err.Error() == mongo2.ErrNoDocuments.Error() {
			HandleSuccessWithListData(c, nil, 0)
			return
		}
		HandleErrorInternalServerError(c, err)
		return
	}

	// validate results
	if len(data) == 0 {
		HandleSuccessWithListData(c, nil, 0)
		return
	}

	// total count
	total, err := svc.Count(query)
	if err != nil {
		HandleErrorInternalServerError(c, err)
		return
	}

	// response
	HandleSuccessWithListData(c, data, total)
}

func getResultListQuery(c *gin.Context) (q generic.ListQuery) {
	f, err := GetFilter(c)
	if err != nil {
		return q
	}
	for _, cond := range f.Conditions {
		q = append(q, generic.ListQueryCondition{
			Key:   cond.Key,
			Op:    cond.Op,
			Value: utils.NormalizeObjectId(cond.Value),
		})
	}
	return q
}