diff options
| author | Paul Buetow <paul@buetow.org> | 2024-05-19 13:16:28 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2024-05-19 13:16:28 +0300 |
| commit | c06422b0727a4c6520d715e4be9a49a612afacfb (patch) | |
| tree | 95565f8ac555f04b87bc2cb4482984d8cc649615 /internal/server/repository | |
| parent | 3e55b77c042c8436f93347f26cdd3196c1cb7f25 (diff) | |
initial equality test for the entries
Diffstat (limited to 'internal/server/repository')
| -rw-r--r-- | internal/server/repository/repository.go | 20 |
1 files changed, 14 insertions, 6 deletions
diff --git a/internal/server/repository/repository.go b/internal/server/repository/repository.go index f83175f..2c6b132 100644 --- a/internal/server/repository/repository.go +++ b/internal/server/repository/repository.go @@ -2,11 +2,13 @@ package repository import ( "encoding/json" + "fmt" "log" "os" "path/filepath" "strings" "sync" + "time" "codeberg.org/snonux/gos/internal/types" ) @@ -95,16 +97,22 @@ func (r Repository) HasEntry(pair EntryPair) bool { return true } -func (r Repository) Merge(newEntry types.Entry) { +func (r Repository) entryPath(entry types.Entry) string { + return fmt.Sprintf("%s/%s/%s.json", r.dataDir, time.Now().Format("2006"), entry.ID) +} + +func (r Repository) Merge(newEntry types.Entry) error { r.mu.Lock() defer r.mu.Unlock() - oldEntry, ok := r.entries[newEntry.ID] + entry, ok := r.entries[newEntry.ID] if !ok { - r.entries[newEntry.ID] = types.NewEntryFromCopy(newEntry) - return + entry = types.NewEntryFromCopy(newEntry) } - r.entries[newEntry.ID] = oldEntry.Updated(newEntry) - panic("Not yet implemented: shoud write entry also to disk") + entry, _ = entry.Update(newEntry) + r.entries[newEntry.ID] = entry + + // TODO: Only save to file when actually changed + return entry.SaveFile(r.entryPath(entry)) } |
