Merge pull request #7 from anyproto/fix-publish-list

fix publish list
anyproto · Jan 20, 2025 · d8659e0 · d8659e0
2 parents 32fd845 + 1dcc7c6
commit d8659e0
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/publish/publishrepo/publishrepo.go b/publish/publishrepo/publishrepo.go
@@ -223,11 +223,11 @@ func (p *publishRepo) ListPublishes(ctx context.Context, identity string) ([]dom
 	var publishes []domain.ObjectWithPublish
 	for cur.Next(ctx) {
 		var publish domain.ObjectWithPublish
-		if err = cur.Decode(&publish.Publish); err != nil {
+		if err = cur.Decode(&publish.Object); err != nil {
 			return nil, err
 		}
 		if publish.ActivePublishId != nil {
-			publish.Publish = &domain.Publish{}
+			_ = p.publishColl.FindOne(ctx, bson.D{{"_id", *publish.ActivePublishId}}).Decode(&publish.Publish)
 		}
 		publishes = append(publishes, publish)
 	}

diff --git a/publish/publishrepo/publishrepo_test.go b/publish/publishrepo/publishrepo_test.go
@@ -99,6 +99,12 @@ func TestPublishRepo_ObjectPublishStatus(t *testing.T) {
 		require.NotNil(t, publishObj.Publish)
 		assert.Equal(t, domain.PublishStatusPublished, publishObj.Publish.Status)
 		assert.Equal(t, int64(123), publishObj.Publish.Size)
+
+		list, err := fx.ListPublishes(ctx, obj.Identity)
+		require.NoError(t, err)
+		require.Len(t, list, 1)
+		require.NotNil(t, list[0].Publish)
+		assert.Equal(t, domain.PublishStatusPublished, list[0].Publish.Status)
 	})
 }