mirror/mxpv-podsync
1
0
Fork 0
mirror of https://github.com/mxpv/podsync.git synced 2024-05-11 05:55:04 +00:00
Code Issues Releases Activity

Fix timestamp serialization

Browse Source
This commit is contained in:
Maksym Pavlenko
2019-04-06 12:13:50 -07:00
parent 51367f6e9b
commit 1fd2d80cb8
2 changed files with 17 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
pkg/storage/dynamo.go
View File

@@ -148,8 +148,15 @@ func (d Dynamo) GetFeed(hashID string) (*model.Feed, error) {
var feed model.Feed
if err := attr.UnmarshalMap(getOutput.Item, &feed); err != nil {
logger.WithError(err).Error("failed to unmarshal feed item")
return nil, err
// TODO: remove this
delete(getOutput.Item, "UpdatedAt")
delete(getOutput.Item, "PubDate")
err = attr.UnmarshalMap(getOutput.Item, &feed)
if err != nil {
logger.WithError(err).Error("failed to unmarshal feed item")
return nil, err
}
}
// Check if we need to update LastAccess field (no more than once per hour)
@@ -193,8 +200,8 @@ func (d Dynamo) GetFeed(hashID string) (*model.Feed, error) {
func (d Dynamo) UpdateFeed(feed *model.Feed) error {
var (
pubDate = strconv.FormatInt(feed.PubDate.Unix(), 10)
updatedAt = strconv.FormatInt(feed.LastAccess.Unix(), 10)
pubDate = feed.PubDate.Unix()
updatedAt = feed.LastAccess.Unix()
)
update := expr.

6
pkg/storage/dynamo_test.go
View File

@@ -35,8 +35,14 @@ func TestDynamo_UpdateFeed(t *testing.T) {
err := client.SaveFeed(feed)
assert.NoError(t, err)
_, err = client.GetFeed(feed.HashID)
assert.NoError(t, err, "can't read feed after save")
err = client.UpdateFeed(feed)
assert.NoError(t, err)
_, err = client.GetFeed(feed.HashID)
assert.NoError(t, err, "can't read feed after update")
}
// docker run -it --rm -p 8000:8000 amazon/dynamodb-local