Skip to content

Commit b3e5ac2

Browse files
jsmurphyrstam
authored andcommitted
Change ClusterTime to return BsonTimestamp instead of BsonDocument
1 parent bc2560c commit b3e5ac2

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

src/MongoDB.Driver.Core/ChangeStreamDocument.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ public ChangeStreamDocument(
5151
/// <value>
5252
/// The cluster time.
5353
/// </value>
54-
public BsonDocument ClusterTime => GetValue<BsonDocument>(nameof(ClusterTime), null);
54+
public BsonTimestamp ClusterTime => GetValue<BsonTimestamp>(nameof(ClusterTime), null);
5555

5656
/// <summary>
5757
/// Gets the namespace of the collection.

src/MongoDB.Driver.Core/ChangeStreamDocumentSerializer.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ public ChangeStreamDocumentSerializer(
4040
{
4141
_documentSerializer = Ensure.IsNotNull(documentSerializer, nameof(documentSerializer));
4242

43-
RegisterMember("ClusterTime", "clusterTime", BsonDocumentSerializer.Instance);
43+
RegisterMember("ClusterTime", "clusterTime", BsonTimestampSerializer.Instance);
4444
RegisterMember("CollectionNamespace", "ns", ChangeStreamDocumentCollectionNamespaceSerializer.Instance);
4545
RegisterMember("DocumentKey", "documentKey", BsonDocumentSerializer.Instance);
4646
RegisterMember("FullDocument", "fullDocument", _documentSerializer);

tests/MongoDB.Driver.Core.Tests/ChangeStreamDocumentSerializerTests.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ public void constructor_should_initialize_instance()
3737

3838
result._documentSerializer().Should().BeSameAs(documentSerializer);
3939
result._memberSerializationInfo().Count.Should().Be(7);
40-
AssertRegisteredMember(result, "ClusterTime", "clusterTime", BsonDocumentSerializer.Instance);
40+
AssertRegisteredMember(result, "ClusterTime", "clusterTime", BsonTimestampSerializer.Instance);
4141
AssertRegisteredMember(result, "CollectionNamespace", "ns", ChangeStreamDocumentCollectionNamespaceSerializer.Instance);
4242
AssertRegisteredMember(result, "DocumentKey", "documentKey", BsonDocumentSerializer.Instance);
4343
AssertRegisteredMember(result, "FullDocument", "fullDocument", documentSerializer);

tests/MongoDB.Driver.Core.Tests/ChangeStreamDocumentTests.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ public void BackingDocument_should_return_expected_result()
7575
[Fact]
7676
public void ClusterTime_should_return_expected_result()
7777
{
78-
var value = new BsonDocument("x", 1234);
78+
var value = new BsonTimestamp(DateTime.Now.Ticks);
7979
var backingDocument = new BsonDocument { { "other", 1 }, { "clusterTime", value } };
8080
var subject = CreateSubject(backingDocument: backingDocument);
8181

0 commit comments

Comments
 (0)