Simplify timestamp comparisons

This commit is contained in:
Philipp Wolfer 2025-05-01 12:27:24 +02:00
parent 389c7c6ec1
commit c305b6c7e3
No known key found for this signature in database
GPG key ID: 8FDF744D4919943B
7 changed files with 14 additions and 14 deletions

View file

@ -117,7 +117,7 @@ out:
listens := make(models.ListensList, 0, perPage) listens := make(models.ListensList, 0, perPage)
for _, track := range result.Tracks { for _, track := range result.Tracks {
listen := track.AsListen() listen := track.AsListen()
if listen.ListenedAt.Unix() > oldestTimestamp.Unix() { if listen.ListenedAt.After(oldestTimestamp) {
listens = append(listens, listen) listens = append(listens, listen)
} else { } else {
break break
@ -186,7 +186,7 @@ out:
loves := make(models.LovesList, 0, perPage) loves := make(models.LovesList, 0, perPage)
for _, track := range result.Tracks { for _, track := range result.Tracks {
love := track.AsLove() love := track.AsLove()
if love.Created.Unix() > oldestTimestamp.Unix() { if love.Created.After(oldestTimestamp) {
loves = append(loves, love) loves = append(loves, love)
} else { } else {
totalCount -= 1 totalCount -= 1

View file

@ -84,7 +84,7 @@ out:
for _, fwListen := range result.Results { for _, fwListen := range result.Results {
listen := fwListen.AsListen() listen := fwListen.AsListen()
if listen.ListenedAt.Unix() > oldestTimestamp.Unix() { if listen.ListenedAt.After(oldestTimestamp) {
p.Elapsed += 1 p.Elapsed += 1
listens = append(listens, listen) listens = append(listens, listen)
} else { } else {
@ -135,7 +135,7 @@ out:
for _, favorite := range result.Results { for _, favorite := range result.Results {
love := favorite.AsLove() love := favorite.AsLove()
if love.Created.Unix() > oldestTimestamp.Unix() { if love.Created.After(oldestTimestamp) {
p.Elapsed += 1 p.Elapsed += 1
loves = append(loves, love) loves = append(loves, love)
} else { } else {

View file

@ -246,7 +246,7 @@ out:
} }
love := feedback.AsLove() love := feedback.AsLove()
if love.Created.Unix() > oldestTimestamp.Unix() { if love.Created.After(oldestTimestamp) {
loves = append(loves, love) loves = append(loves, love)
p.Elapsed += 1 p.Elapsed += 1
} else { } else {

View file

@ -139,7 +139,7 @@ func (b *SpotifyApiBackend) ExportListens(oldestTimestamp time.Time, results cha
for _, listen := range result.Items { for _, listen := range result.Items {
l := listen.AsListen() l := listen.AsListen()
if l.ListenedAt.Unix() > oldestTimestamp.Unix() { if l.ListenedAt.After(oldestTimestamp) {
listens = append(listens, l) listens = append(listens, l)
} else { } else {
// result contains listens older then oldestTimestamp // result contains listens older then oldestTimestamp
@ -195,7 +195,7 @@ out:
loves := make(models.LovesList, 0, perPage) loves := make(models.LovesList, 0, perPage)
for _, track := range result.Items { for _, track := range result.Items {
love := track.AsLove() love := track.AsLove()
if love.Created.Unix() > oldestTimestamp.Unix() { if love.Created.After(oldestTimestamp) {
loves = append(loves, love) loves = append(loves, love)
} else { } else {
continue continue

View file

@ -90,7 +90,7 @@ func (b *SubsonicApiBackend) filterSongs(songs []*subsonic.Child, oldestTimestam
loves := make(models.LovesList, 0, len(songs)) loves := make(models.LovesList, 0, len(songs))
for _, song := range songs { for _, song := range songs {
love := SongAsLove(*song, b.client.User) love := SongAsLove(*song, b.client.User)
if love.Created.Unix() > oldestTimestamp.Unix() { if love.Created.After(oldestTimestamp) {
loves = append(loves, love) loves = append(loves, love)
} }
} }

View file

@ -123,7 +123,7 @@ func (c *TransferCmd[E, I, R]) Transfer(exp backends.ExportProcessor[R], imp bac
resultChan := make(chan models.ImportResult) resultChan := make(chan models.ImportResult)
go imp.Process(exportChan, resultChan, importProgress) go imp.Process(exportChan, resultChan, importProgress)
result := <-resultChan result := <-resultChan
if result.LastTimestamp.Unix() < timestamp.Unix() { if timestamp.After(result.LastTimestamp) {
result.LastTimestamp = timestamp result.LastTimestamp = timestamp
} }
wg.Wait() wg.Wait()
@ -180,7 +180,7 @@ func (c *TransferCmd[E, I, R]) timestamp() (time.Time, error) {
} }
func (c *TransferCmd[E, I, R]) updateTimestamp(result models.ImportResult, oldTimestamp time.Time) error { func (c *TransferCmd[E, I, R]) updateTimestamp(result models.ImportResult, oldTimestamp time.Time) error {
if result.LastTimestamp.Unix() < oldTimestamp.Unix() { if oldTimestamp.After(result.LastTimestamp) {
result.LastTimestamp = oldTimestamp result.LastTimestamp = oldTimestamp
} }
printTimestamp("Latest timestamp: %v (%v)", result.LastTimestamp) printTimestamp("Latest timestamp: %v (%v)", result.LastTimestamp)

View file

@ -121,7 +121,7 @@ type ListensList []Listen
func (l ListensList) NewerThan(t time.Time) ListensList { func (l ListensList) NewerThan(t time.Time) ListensList {
result := make(ListensList, 0, len(l)) result := make(ListensList, 0, len(l))
for _, item := range l { for _, item := range l {
if item.ListenedAt.Unix() > t.Unix() { if item.ListenedAt.After(t) {
result = append(result, item) result = append(result, item)
} }
} }
@ -133,7 +133,7 @@ func (l ListensList) Len() int {
} }
func (l ListensList) Less(i, j int) bool { func (l ListensList) Less(i, j int) bool {
return l[i].ListenedAt.Unix() < l[j].ListenedAt.Unix() return l[j].ListenedAt.After(l[i].ListenedAt)
} }
func (l ListensList) Swap(i, j int) { func (l ListensList) Swap(i, j int) {
@ -147,7 +147,7 @@ func (l LovesList) Len() int {
} }
func (l LovesList) Less(i, j int) bool { func (l LovesList) Less(i, j int) bool {
return l[i].Created.Unix() < l[j].Created.Unix() return l[j].Created.After(l[i].Created)
} }
func (l LovesList) Swap(i, j int) { func (l LovesList) Swap(i, j int) {
@ -190,7 +190,7 @@ type ImportResult struct {
// Sets LastTimestamp to newTime, if newTime is newer than LastTimestamp // Sets LastTimestamp to newTime, if newTime is newer than LastTimestamp
func (i *ImportResult) UpdateTimestamp(newTime time.Time) { func (i *ImportResult) UpdateTimestamp(newTime time.Time) {
if newTime.Unix() > i.LastTimestamp.Unix() { if newTime.After(i.LastTimestamp) {
i.LastTimestamp = newTime i.LastTimestamp = newTime
} }
} }