aboutsummaryrefslogtreecommitdiff
path: root/internal/feed/cache.go
blob: 2d8f9aa4d483fe22f4b68fdfe6bee3846d4222ee (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
package feed

import (
	"bufio"
	"encoding/gob"
	"errors"
	"fmt"
	"os"
	"time"

	"github.com/nightlyone/lockfile"

	"github.com/Necoro/feed2imap-go/pkg/log"
)

type Version byte

const (
	currentVersion Version = 1
)

type CacheImpl interface {
	findItem(*Feed) CachedFeed
	Version() Version
	Info() string
	SpecificInfo(interface{}) string
	transformToCurrent() (CacheImpl, error)
}

type Cache struct {
	CacheImpl
	lock   lockfile.Lockfile
	locked bool
}

type CachedFeed interface {
	Checked(withFailure bool)
	Failures() int
	Last() time.Time
	ID() string
	filterItems(items []item, ignoreHash bool, alwaysNew bool) []item
	Commit()
}

func cacheForVersion(version Version) (CacheImpl, error) {
	switch version {
	case v1Version:
		return newV1Cache(), nil
	default:
		return nil, fmt.Errorf("unknown cache version '%d'", version)
	}
}

func lockName(fileName string) string {
	return fileName + ".lck"
}

func lock(fileName string) (lock lockfile.Lockfile, err error) {
	lockFile := lockName(fileName)
	log.Debugf("Handling lock file '%s'", lockFile)

	if lock, err = lockfile.New(lockFile); err != nil {
		err = fmt.Errorf("Creating lock file: %w", err)
		return
	}

	if err = lock.TryLock(); err != nil {
		err = fmt.Errorf("Locking: %w", err)
		return
	}

	return
}

func storeCache(cache Cache, fileName string) error {
	if cache.CacheImpl == nil {
		return fmt.Errorf("trying to store nil cache")
	}
	if cache.Version() != currentVersion {
		return fmt.Errorf("trying to store cache with unsupported version '%d' (current: '%d')", cache.Version(), currentVersion)
	}

	f, err := os.Create(fileName)
	if err != nil {
		return fmt.Errorf("trying to store cache to '%s': %w", fileName, err)
	}
	defer f.Close()

	writer := bufio.NewWriter(f)
	if err = writer.WriteByte(byte(currentVersion)); err != nil {
		return fmt.Errorf("writing to '%s': %w", fileName, err)
	}

	encoder := gob.NewEncoder(writer)
	if err = encoder.Encode(cache); err != nil {
		return fmt.Errorf("encoding cache: %w", err)
	}

	writer.Flush()
	log.Printf("Stored cache to '%s'.", fileName)

	if cache.locked {
		if err = cache.lock.Unlock(); err != nil {
			return fmt.Errorf("Unlocking cache: %w", err)
		}
	}
	return nil
}

func newCache() (Cache, error) {
	cache, err := cacheForVersion(currentVersion)
	if err != nil {
		return Cache{}, err
	}
	return Cache{
		CacheImpl: cache,
		locked:    false,
	}, nil
}

func LoadCache(fileName string) (Cache, error) {
	f, err := os.Open(fileName)
	if err != nil {
		if errors.Is(err, os.ErrNotExist) {
			// no cache there yet -- make new
			return newCache()
		}
		return Cache{}, fmt.Errorf("opening cache at '%s': %w", fileName, err)
	}
	defer f.Close()

	lock, err := lock(fileName)
	if err != nil {
		return Cache{}, err
	}

	log.Printf("Loading cache from '%s'", fileName)

	reader := bufio.NewReader(f)
	version, err := reader.ReadByte()
	if err != nil {
		return Cache{}, fmt.Errorf("reading from '%s': %w", fileName, err)
	}

	cache, err := cacheForVersion(Version(version))
	if err != nil {
		return Cache{}, err
	}

	decoder := gob.NewDecoder(reader)
	if err = decoder.Decode(cache); err != nil {
		return Cache{}, fmt.Errorf("decoding for version '%d' from '%s': %w", version, fileName, err)
	}

	if cache, err = cache.transformToCurrent(); err != nil {
		return Cache{}, fmt.Errorf("cannot transform from version %d to %d: %w", version, currentVersion, err)
	}

	log.Printf("Loaded cache (version %d), transformed to version %d.", version, currentVersion)

	return Cache{cache, lock, true}, nil
}