path: root/state/state.go

// SPDX-License-Identifier: ISC
// Copyright © 2021 siddharth <s@ricketyspace.net>

package state

// Contains the result of processing a Feed.
type FeedResult struct {
	FeedId string // Feed's identifier
	Err    error  // Set on error
}

// Contains the result of processing an Entry.
type EntryResult struct {
	EntryId string // Entry's identifier
	Err     error  // Set on error
}

type ProcessState struct {
	YDLPath string
	DumpDir string
	// Channel for Feed.Process goroutines to communicate to the
	// caller about the number of entries that are being
	// downloaded for a feed.
	FeedResultChan chan FeedResult
	// Number of feeds that are being processed.
	FeedsProcessing int
}

func NewProcessState() *ProcessState {
	ps := new(ProcessState)
	ps.FeedResultChan = make(chan FeedResult)
	return ps
}