webarchive/entity/result.go

package entity

import (
	"sync"

	"github.com/vmihailenco/msgpack/v5"
)

type ResultsRO []Result

type Result struct {
	Format Format
	Err    error
	Files  []File
}

type Results struct {
	mu      sync.RWMutex
	results []Result
}

func (r *Results) RO() ResultsRO {
	r.mu.Lock()
	defer r.mu.Unlock()

	return r.results
}

func (r *Results) MarshalMsgpack() ([]byte, error) {
	return msgpack.Marshal(r.results)
}

func (r *Results) UnmarshalMsgpack(b []byte) error {
	return msgpack.Unmarshal(b, &r.results)
}

func (r *Results) Add(result Result) {
	r.mu.Lock()
	r.results = append(r.results, result)
	r.mu.Unlock()
}

func (r *Results) Results() []Result {
	r.mu.RLock()
	defer r.mu.RUnlock()

	return r.results
}