summaryrefslogtreecommitdiff
path: root/internal/server/repository
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2024-05-19 13:16:28 +0300
committerPaul Buetow <paul@buetow.org>2024-05-19 13:16:28 +0300
commitc06422b0727a4c6520d715e4be9a49a612afacfb (patch)
tree95565f8ac555f04b87bc2cb4482984d8cc649615 /internal/server/repository
parent3e55b77c042c8436f93347f26cdd3196c1cb7f25 (diff)
initial equality test for the entries
Diffstat (limited to 'internal/server/repository')
-rw-r--r--internal/server/repository/repository.go20
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))
}