db_getter.go

package getter

import (
	"errors"
	"github.com/goharbor/harbor/src/common/dao"
)

// DBGetter is responsible for retrieving DB log data
type DBGetter struct {
}

// NewDBGetter is constructor of DBGetter
func NewDBGetter() *DBGetter {
	return &DBGetter{}
}

// Retrieve implements @Interface.Retrieve
func (dbg *DBGetter) Retrieve(logID string) ([]byte, error) {
	if len(logID) == 0 {
		return nil, errors.New("empty log identify")
	}

	jobLog, err := dao.GetJobLog(logID)
	if err != nil {
		return nil, err
	}

	return []byte(jobLog.Content), nil
}