diff options
| author | Paul Buetow <paul@buetow.org> | 2024-09-18 01:04:26 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2024-09-18 01:04:26 +0300 |
| commit | 5263e61d5667009e7a7ac13014cec73ccbd0e20a (patch) | |
| tree | 64187b679f0b0da34840c3d77d5bde441cea3fb0 /internal/server/repository | |
| parent | 279ee9e1026f74f923766286b767d4df3901b82f (diff) | |
some stuff
Diffstat (limited to 'internal/server/repository')
| -rw-r--r-- | internal/server/repository/pending.go | 9 | ||||
| -rw-r--r-- | internal/server/repository/repository.go | 5 |
2 files changed, 13 insertions, 1 deletions
diff --git a/internal/server/repository/pending.go b/internal/server/repository/pending.go index 2245f30..a1fd7a7 100644 --- a/internal/server/repository/pending.go +++ b/internal/server/repository/pending.go @@ -13,6 +13,15 @@ func newPending() pending { return pending{make(map[types.PlatformName]pendingEntries)} } +// Returns number of pending entries for the platform +// func (p pending) num(platform types.PlatformName) int { +// pe, ok := p.platforms[platform] +// if !ok { +// return 0 +// } +// return len(pe) +// } + func (p pending) add(platform types.PlatformName, id types.EntryID) { pe, ok := p.platforms[platform] if !ok { diff --git a/internal/server/repository/repository.go b/internal/server/repository/repository.go index 77f23ec..d277884 100644 --- a/internal/server/repository/repository.go +++ b/internal/server/repository/repository.go @@ -33,8 +33,10 @@ type entryPair struct { } // Holds all entries in the database / stores them to the disks.. +// TODO: Keep track of how many posts were made this week already. type Repository struct { - pending + pending pending + stats stats conf server.ServerConfig entries map[types.EntryID]types.Entry mu *sync.Mutex @@ -55,6 +57,7 @@ func newRepository(conf server.ServerConfig, fs fs) Repository { var loaded bool return Repository{ pending: newPending(), // TODO: Make use of the pending for the selection algoritmh for the next post + stats: newStats(), // TODO: Make use of this. conf: conf, entries: make(map[types.EntryID]types.Entry), mu: &sync.Mutex{}, |
