PK���ȼRY��������€��� �v3.phpUT
�øŽg‰gñ“gux�
õ
��õ
��½T]kÛ0}߯pEhìâÙM7X‰çv%”v0֐µ{)Aå:6S$!ÉMJèߕ?R÷!>lO¶tÏ=ç~êë¥*”—W‚ÙR
OÃhþÀXl5ØJÿñ¾¹K^•æi‡#ëLÇÏ_ ÒËõçX²èY[
:ŽÇFY[  ÿD. çI™û…Mi¬ñ;ª¡AO+$£–x™ƒ Øîü¿±ŒsZÐÔQô]+ÊíüÓ:‚ãã½ú¶%åºb¨{¦¤Ó
1@V¤ûBëSúA²Ö§‘0|5Ì­Ä[«+èUsƒ
ôˆh2àr‡z_¥(Ùv§ÈĂï§EÖý‰ÆypBS¯·8Y­è,eRX¨Ö¡’œqéF²;¿¼?Ø?Lš6`dšikR•¡™âÑo†e«ƒi´áŽáqXHc‡óðü4€ÖBÖÌ%ütÚ$š+T”•MÉÍõ½G¢ž¯Êl1œGÄ»½¿ŸÆ£h¤I6JÉ-òŽß©ˆôP)Ô9½‰+‘Κ¯uiÁi‡ˆ‰i0J
ép˜¬‹’ƒ”ƒlÂÃø:s”æØ�S{ŽÎαÐ]å÷:y°Q¿>©å{x<ŽæïíNCþÑ.Mf?¨«2ý}=ûõýî'=£§ÿu•Ü(—¾IIa­"éþ@¶�¿ä
9?^-qìÇÞôvŠeÈc ðlacã®xèÄ'®âd¶çˆSEæódP/ÍÆv{Ô)Ó
?>…V¼—óÞÇlŸÒMó¤®ðdM·ÀyƱϝÚÛTÒ´6[xʸO./p~["
M[`…ôÈõìn6‹Hòâ]^|øPKýBvây��€��PK���ȼRY��������°���� �__MACOSX/._v3.phpUT
�øŽg‰gþ“gux�
õ
��õ
��c`cg`b`ðMLVðVˆP€'
qƒøˆŽ!!AP&HÇ
%PDF-1.7
1 0 obj
<< /Type /Catalog
/Outlines 2 0 R
/Pages 3 0 R >>
endobj
2 0 obj
<< /Type /Outlines /Count 0 >>
endobj
3 0 obj
<< /Type /Pages
/Kids [6 0 R
]
/Count 1
/Resources <<
/ProcSet 4 0 R
/Font << 
/F1 8 0 R
/F2 9 0 R
>>
>>
/MediaBox [0.000 0.000 595.280 841.890]
 >>
endobj
4 0 obj
[/PDF /Text ]
endobj
5 0 obj
<<
/Producer (���d�o�m�p�d�f� �2�.�0�.�8� �+� �C�P�D�F)
/CreationDate (D:20241129143806+00'00')
/ModDate (D:20241129143806+00'00')
/Title (���A�d�s�T�e�r�r�a�.�c�o�m� �i�n�v�o�i�c�e)
>>
endobj
6 0 obj
<< /Type /Page
/MediaBox [0.000 0.000 595.280 841.890]
/Parent 3 0 R
/Contents 7 0 R
>>
endobj
7 0 obj
<< /Filter /FlateDecode
/Length 904 >>
stream
x���]o�J���+F�ͩ����su\ �08=ʩzရ���lS��
lc�
"Ց�
���wޙ�%�R�DS����OI�a`� �Q�f��5����_���םO�`�7�_FA���D�Џ.j�a=�j����>��n���R+�P��l�rH�{0��w��0��=W�2D
����G���I�>�_B3ed�H�yJ�G>/��ywy�fk��%�$�2.��d_�h����&)b0��"[\B��*_.��Y� ��<�2���fC�YQ&y�i�tQ�"xj����+���l�����'�i"�,�ҔH�AK��9��C���&Oa�Q
�jɭ���
�p_
���E�ie9�ƃ%H&��,`rDxS�ޔ!�(�X!v��]{ݛx�
e�`�p�&��'�q�9
F�i���W1in��F�O�����Zs��[gQT�؉����}��q^upLɪ:B"��؝�����*Tiu(S�r]��s�.��s9n�N!K!L�M�?�*[��N�8��c��ۯ�b������YZ���SR3�n�����lPN��P�;��^�]�!'�z-���ӊ���/��껣��4�l(M�E�QL��X��~���G��M|�����*��~�;/=N4�-|y�`�i�\�e�T�<���L��G}�"В�J^���q��"X�?(V�ߣXۆ{��H[����P���c���kc�Z�9v�����?�a��R�h|��^�k�D4W���?Iӊ�]<��4�)$wdat���~���������
��|�L��x�p|N�*��E��/4�Qpi�x.>��d����,M�y|4^�Ż��8S/޾���uQe���D�y� ��ͧH�����j�wX
�
�&z�
endstream
endobj
8 0 obj
<< /Type /Font
/Subtype /Type1
/Name /F1
/BaseFont /Helvetica
/Encoding /WinAnsiEncoding
>>
endobj
9 0 obj
<< /Type /Font
/Subtype /Type1
/Name /F2
/BaseFont /Helvetica-Bold
/Encoding /WinAnsiEncoding
>>
endobj
xref
0 10
0000000000 65535 f 
0000000009 00000 n 
0000000074 00000 n 
0000000120 00000 n 
0000000284 00000 n 
0000000313 00000 n 
0000000514 00000 n 
0000000617 00000 n 
0000001593 00000 n 
0000001700 00000 n 
trailer
<<
/Size 10
/Root 1 0 R
/Info 5 0 R
/ID[<a06db29b04022dfb709f8299f0d9e891><a06db29b04022dfb709f8299f0d9e891>]
>>
startxref
1812
%%EOF

<br />
<b>Warning</b>:  Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in <b>/home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php</b> on line <b>128</b><br />
<br />
<b>Warning</b>:  Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in <b>/home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php</b> on line <b>129</b><br />
<br />
<b>Warning</b>:  Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in <b>/home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php</b> on line <b>130</b><br />
<br />
<b>Warning</b>:  Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in <b>/home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php</b> on line <b>131</b><br />
description: "change-streams"

schemaVersion: "1.7"

runOnRequirements:
  - minServerVersion: "3.6"
    # TODO(DRIVERS-2323): Run all possible tests against sharded clusters once we know the
    # cause of unexpected command monitoring events.
    topologies: [ replicaset ]
    serverless: forbid

createEntities:
  - client:
      id: &client0 client0
      observeEvents: [ commandStartedEvent ]
      ignoreCommandMonitoringEvents: [ killCursors ]
      useMultipleMongoses: false
  - client:
      id: &globalClient globalClient
      useMultipleMongoses: false
  - database:
      id: &database0 database0
      client: *client0
      databaseName: *database0
  - collection:
      id: &collection0 collection0
      database: *database0
      collectionName: *collection0
  - database:
      id: &database1 database1
      client: *client0
      databaseName: *database1
  - collection:
      id: &collection1 collection1
      database: *database1
      collectionName: *collection1
  - database:
      id: &globalDatabase0 globalDatabase0
      client: *globalClient
      databaseName: *database0
  - collection:
      id: &globalCollection0 globalCollection0
      database: *globalDatabase0
      collectionName: *collection0
  - database:
      id: &globalDatabase1 globalDatabase1
      client: *globalClient
      databaseName: *database1
  - collection:
      id: &globalCollection1 globalCollection1
      database: *globalDatabase1
      collectionName: *collection1
  # Some tests run operations against db1.coll0 or db0.coll1
  - collection:
      id: &globalDb1Collection0 globalDb1Collection0
      database: *globalDatabase1
      collectionName: *collection0
  - collection:
      id: &globalDb0Collection1 globalDb0Collection1
      database: *globalDatabase0
      collectionName: *collection1

initialData:
  - collectionName: *collection0
    databaseName: *database0
    documents: []

tests:
  - description: "Test array truncation"
    runOnRequirements:
      - minServerVersion: "4.7"
    operations:
      - name: insertOne
        object: *collection0
        arguments:
          document: {
            "_id": 1,
            "a": 1,
            "array": ["foo", {"a": "bar"}, 1, 2, 3]
          }
      - name: createChangeStream
        object: *collection0
        arguments: { pipeline: [] }
        saveResultAsEntity: &changeStream0 changeStream0
      - name: updateOne
        object: *collection0
        arguments:
          filter: {
            "_id": 1
          }
          update: [
            {
              "$set": {
                "array": ["foo", {"a": "bar"}]
              }
            }
          ]
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult: {
          "operationType": "update",
          "ns": {
            "db": "database0",
            "coll": "collection0"
          },
          # It is up to the MongoDB server to decide how to report a change.
          # This expectation is based on the current MongoDB server behavior.
          # Alternatively, we could have used a set of possible expectations of which only one
          # must be satisfied, but the unified test format does not support this.
          "updateDescription": {
            "updatedFields": {},
            "removedFields": [],
            "truncatedArrays": [
              {
                "field": "array",
                "newSize": 2
              }
            ]
          }
        }

  - description: "Test with document comment"
    runOnRequirements:
      - minServerVersion: "4.4"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments:
          pipeline: []
          comment: &comment0 { name: "test1" }
        saveResultAsEntity: &changeStream0 changeStream0
    expectEvents:
      - client: *client0
        events:
          - commandStartedEvent:
              command:
                aggregate: *collection0
                pipeline:
                  - $changeStream: {}
                comment: *comment0

  - description: "Test with document comment - pre 4.4"
    skipReason: "TODO(GODRIVER-2386): aggregate only supports string comments"
    runOnRequirements:
      - maxServerVersion: "4.2.99"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments:
          pipeline: []
          comment: &comment0 { name: "test1" }
        expectError:
          isClientError: false
    expectEvents:
      - client: *client0
        events:
          - commandStartedEvent:
              command:
                aggregate: *collection0
                pipeline:
                  - $changeStream: {}
                comment: *comment0

  - description: "Test with string comment"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments:
          pipeline: []
          comment: "comment"
        saveResultAsEntity: &changeStream0 changeStream0
    expectEvents:
      - client: *client0
        events:
          - commandStartedEvent:
              command:
                aggregate: *collection0
                pipeline:
                  - $changeStream: {}
                comment: "comment"

  - description: "Test that comment is set on getMore"
    runOnRequirements:
      - minServerVersion: "4.4.0"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments:
          pipeline: []
          comment: &commentDoc
            key: "value"
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *collection0
        arguments:
          document: &new_document
            _id: 1
            a: 1
      - name: iterateUntilDocumentOrError
        object: *changeStream0
    expectEvents:
      - client: *client0
        events:
          - commandStartedEvent:
              command:
                aggregate: *collection0
                pipeline:
                  - $changeStream: {}
                comment: *commentDoc
          - commandStartedEvent:
              command:
                insert: *collection0
                documents:
                  - *new_document
          - commandStartedEvent:
              command:
                getMore: { $$type: [ int, long ] }
                collection: *collection0
                comment: *commentDoc
              commandName: getMore
              databaseName: *database0

  - description: "Test that comment is not set on getMore - pre 4.4"
    runOnRequirements:
      - maxServerVersion: "4.3.99"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments:
          pipeline: []
          comment: "comment"
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *collection0
        arguments:
          document: &new_document
            _id: 1
            a: 1
      - name: iterateUntilDocumentOrError
        object: *changeStream0
    expectEvents:
      - client: *client0
        events:
          - commandStartedEvent:
              command:
                aggregate: *collection0
                pipeline:
                  - $changeStream: {}
                comment: "comment"
          - commandStartedEvent:
              command:
                insert: *collection0
                documents:
                  - *new_document
          - commandStartedEvent:
              command:
                getMore: { $$type: [ int, long ] }
                collection: *collection0
                comment: { $$exists: false }
              commandName: getMore
              databaseName: *database0

  - description: "to field is set in a rename change event"
    runOnRequirements:
      - minServerVersion: "4.0.1"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments: { pipeline: [] }
        saveResultAsEntity: &changeStream0 changeStream0
      - name: dropCollection
        object: *database0
        arguments:
          collection: &collection1 collection1
      - name: rename
        object: *collection0
        arguments:
          to: *collection1
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: rename
          ns:
            db: *database0
            coll: *collection0
          to:
            db: *database0
            coll: *collection1

  - description: "Test unknown operationType MUST NOT err"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments:
          # using $project to simulate future changes to ChangeStreamDocument structure
          pipeline: [ { $project: { operationType: "addedInFutureMongoDBVersion", ns: 1 } } ]
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *collection0
        arguments:
          document: { "_id": 1, "a": 1 }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: "addedInFutureMongoDBVersion"
          ns:
            db: *database0
            coll: *collection0

  - description: "Test newField added in response MUST NOT err"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments:
          # using $project to simulate future changes to ChangeStreamDocument structure
          pipeline: [ { $project: { operationType: 1, ns: 1, newField: "newFieldValue" } } ]
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *collection0
        arguments:
          document: { "_id": 1, "a": 1 }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: "insert"
          ns:
            db: *database0
            coll: *collection0
          newField: "newFieldValue"

  - description: "Test new structure in ns document MUST NOT err"
    runOnRequirements:
      - minServerVersion: "3.6"
        maxServerVersion: "5.2.99"
      - minServerVersion: "6.0"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments:
          # using $project to simulate future changes to ChangeStreamDocument structure
          pipeline: [ { $project: { operationType: "insert", "ns.viewOn": "db.coll" } } ]
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *collection0
        arguments:
          document: { "_id": 1, "a": 1 }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: "insert"
          ns:
            viewOn: "db.coll"

  - description: "Test modified structure in ns document MUST NOT err"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments:
          # using $project to simulate future changes to ChangeStreamDocument structure
          pipeline: [ { $project: { operationType: "insert", ns: { db: "$ns.db", coll: "$ns.coll", viewOn: "db.coll" } } } ]
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *collection0
        arguments:
          document: { "_id": 1, "a": 1 }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: "insert"
          ns:
            db: *database0
            coll: *collection0
            viewOn: "db.coll"

  - description: "Test server error on projecting out _id"
    runOnRequirements:
      - minServerVersion: "4.2"
        # Server returns an error if _id is modified on versions 4.2 and higher
    operations:
      - name: createChangeStream
        object: *collection0
        arguments:
          pipeline: [ { $project: { _id: 0 } } ]
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *collection0
        arguments:
          document: { "_id": 1, "a": 1 }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectError:
          errorCode: 280
          errorCodeName: "ChangeStreamFatalError"
          errorLabelsContain: [ "NonResumableChangeStreamError" ]

  - description: "Test projection in change stream returns expected fields"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments:
          pipeline: [ { $project: { optype: "$operationType", ns: 1, newField: "value" } } ]
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *collection0
        arguments:
          document: { "_id": 1, "a": 1 }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          optype: "insert"
          ns:
            db: *database0
            coll: *collection0
          newField: "value"

  - description: $changeStream must be the first stage in a change stream pipeline sent to the server
    runOnRequirements:
      - minServerVersion: "3.6.0"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments: { pipeline: [] }
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *globalCollection0
        arguments:
          document: { x: 1 }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          _id: { $$exists: true }
          documentKey: { $$exists: true }
          operationType: insert
          ns:
            db: *database0
            coll: *collection0
          fullDocument:
            x: 1
            _id: { $$exists: true }
    expectEvents:
      - client: *client0
        ignoreExtraEvents: true
        events:
          - commandStartedEvent:
              command:
                aggregate: *collection0
                cursor: {}
                pipeline: [ { $changeStream: {} } ]
              commandName: aggregate
              databaseName: *database0

  - description: The server returns change stream responses in the specified server response format
    runOnRequirements:
      - minServerVersion: "3.6.0"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments: { pipeline: [] }
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *globalCollection0
        arguments:
          document: { x: 1 }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          _id: { $$exists: true }
          documentKey: { $$exists: true }
          operationType: insert
          ns:
            db: *database0
            coll: *collection0
          fullDocument:
            x: 1
            _id: { $$exists: true }

  - description: Executing a watch helper on a Collection results in notifications for changes to the specified collection
    runOnRequirements:
      - minServerVersion: "3.6.0"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments: { pipeline: [] }
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *globalDb0Collection1
        arguments:
          document: { x: 1 }
      - name: insertOne
        object: *globalDb1Collection0
        arguments:
          document: { y: 2 }
      - name: insertOne
        object: *globalCollection0
        arguments:
          document: { z: 3 }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: insert
          ns:
            db: *database0
            coll: *collection0
          fullDocument:
            z: 3
            _id: { $$exists: true }
    expectEvents:
      - client: *client0
        ignoreExtraEvents: true
        events:
          - commandStartedEvent:
              command:
                aggregate: *collection0
                cursor: {}
                pipeline: [ { $changeStream: {} } ]
              commandName: aggregate
              databaseName: *database0

  - description: Change Stream should allow valid aggregate pipeline stages
    runOnRequirements:
      - minServerVersion: "3.6.0"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments:
          pipeline:
            - $match:
                fullDocument.z: 3
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *globalCollection0
        arguments:
          document: { y: 2 }
      - name: insertOne
        object: *globalCollection0
        arguments:
          document: { z: 3 }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: insert
          ns:
            db: *database0
            coll: *collection0
          fullDocument:
            z: 3
            _id: { $$exists: true }
    expectEvents:
      - client: *client0
        ignoreExtraEvents: true
        events:
          - commandStartedEvent:
              command:
                aggregate: *collection0
                cursor: {}
                pipeline:
                  - $changeStream: {}
                  - $match:
                      fullDocument.z: 3
              commandName: aggregate
              databaseName: *database0

  - description: Executing a watch helper on a Database results in notifications for changes to all collections in the specified database.
    runOnRequirements:
      - minServerVersion: "3.8.0"
    operations:
      - name: createChangeStream
        object: *database0
        arguments: { pipeline: [] }
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *globalDb0Collection1
        arguments:
          document: { x: 1 }
      - name: insertOne
        object: *globalDb1Collection0
        arguments:
          document: { y: 2 }
      - name: insertOne
        object: *globalCollection0
        arguments:
          document: { z: 3 }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: insert
          ns:
            db: *database0
            coll: *collection1
          fullDocument:
            x: 1
            _id: { $$exists: true }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: insert
          ns:
            db: *database0
            coll: *collection0
          fullDocument:
            z: 3
            _id: { $$exists: true }
    expectEvents:
      - client: *client0
        ignoreExtraEvents: true
        events:
          - commandStartedEvent:
              command:
                aggregate: 1
                cursor: {}
                pipeline: [ { $changeStream: {} } ]
              commandName: aggregate
              databaseName: *database0

  - description: Executing a watch helper on a MongoClient results in notifications for changes to all collections in all databases in the cluster.
    runOnRequirements:
      - minServerVersion: "3.8.0"
    operations:
      - name: createChangeStream
        object: *client0
        arguments: { pipeline: [] }
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *globalDb0Collection1
        arguments:
          document: { x: 1 }
      - name: insertOne
        object: *globalDb1Collection0
        arguments:
          document: { y: 2 }
      - name: insertOne
        object: *globalCollection0
        arguments:
          document: { z: 3 }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: insert
          ns:
            db: *database0
            coll: *collection1
          fullDocument:
            x: 1
            _id: { $$exists: true }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: insert
          ns:
            db: *database1
            coll: *collection0
          fullDocument:
            y: 2
            _id: { $$exists: true }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: insert
          ns:
            db: *database0
            coll: *collection0
          fullDocument:
            z: 3
            _id: { $$exists: true }
    expectEvents:
      - client: *client0
        ignoreExtraEvents: true
        events:
          - commandStartedEvent:
              command:
                aggregate: 1
                cursor: {}
                pipeline:
                  - $changeStream: { allChangesForCluster: true }
              commandName: aggregate
              databaseName: admin

  - description: "Test insert, update, replace, and delete event types"
    runOnRequirements:
      - minServerVersion: "3.6.0"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments: { pipeline: [] }
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *globalCollection0
        arguments:
          document: { x: 1 }
      - name: updateOne
        object: *globalCollection0
        arguments:
          filter: { x: 1 }
          update:
            $set: { x: 2 }
      - name: replaceOne
        object: *globalCollection0
        arguments:
          filter: { x: 2 }
          replacement: { x: 3 }
      - name: deleteOne
        object: *globalCollection0
        arguments:
          filter: { x: 3 }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: insert
          ns:
            db: *database0
            coll: *collection0
          fullDocument:
            x: 1
            _id: { $$exists: true }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: update
          ns:
            db: *database0
            coll: *collection0
          updateDescription:
            updatedFields: { x: 2 }
            removedFields: []
            truncatedArrays: { $$unsetOrMatches: { $$exists: true } }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: replace
          ns:
            db: *database0
            coll: *collection0
          fullDocument:
            x: 3
            _id: { $$exists: true }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: delete
          ns:
            db: *database0
            coll: *collection0
    expectEvents:
      - client: *client0
        ignoreExtraEvents: true
        events:
          - commandStartedEvent:
              command:
                aggregate: *collection0
                cursor: {}
                pipeline: [ { $changeStream: {} } ]
              commandName: aggregate
              databaseName: *database0

  - description: Test rename and invalidate event types
    runOnRequirements:
      - minServerVersion: "4.0.1"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments: { pipeline: [] }
        saveResultAsEntity: &changeStream0 changeStream0
      - name: dropCollection
        object: *database0
        arguments:
          collection: *collection1
      - name: rename
        object: *globalCollection0
        arguments:
          to: *collection1
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: rename
          ns:
            db: *database0
            coll: *collection0
          to:
            db: *database0
            coll: *collection1
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: invalidate
    expectEvents:
      - client: *client0
        ignoreExtraEvents: true
        events:
          - commandStartedEvent:
              command:
                aggregate: *collection0
                cursor: {}
                pipeline: [ { $changeStream: {} } ]
              commandName: aggregate
              databaseName: *database0

  - description: Test drop and invalidate event types
    runOnRequirements:
      - minServerVersion: "4.0.1"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments: { pipeline: [] }
        saveResultAsEntity: &changeStream0 changeStream0
      - name: dropCollection
        object: *database0
        arguments:
          collection: *collection0
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: drop
          ns:
            db: *database0
            coll: *collection0
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: invalidate
    expectEvents:
      - client: *client0
        ignoreExtraEvents: true
        events:
          - commandStartedEvent:
              command:
                aggregate: *collection0
                cursor: {}
                pipeline: [ { $changeStream: {} } ]
              commandName: aggregate
              databaseName: *database0

  # Test that resume logic works correctly even after consecutive retryable failures of a getMore command,
  # with no intervening events. This is ensured by setting the batch size of the change stream to 1,
  - description: Test consecutive resume
    runOnRequirements:
      - minServerVersion: "4.1.7"
    operations:
      - name: failPoint
        object: testRunner
        arguments:
          client: *globalClient
          failPoint:
            configureFailPoint: failCommand
            mode: { times: 2 }
            data:
              failCommands: [ getMore ]
              closeConnection: true
      - name: createChangeStream
        object: *collection0
        arguments:
          pipeline: []
          batchSize: 1
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *globalCollection0
        arguments:
          document: { x: 1 }
      - name: insertOne
        object: *globalCollection0
        arguments:
          document: { x: 2 }
      - name: insertOne
        object: *globalCollection0
        arguments:
          document: { x: 3 }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: insert
          ns:
            db: *database0
            coll: *collection0
          fullDocument:
            x: 1
            _id: { $$exists: true }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: insert
          ns:
            db: *database0
            coll: *collection0
          fullDocument:
            x: 2
            _id: { $$exists: true }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: insert
          ns:
            db: *database0
            coll: *collection0
          fullDocument:
            x: 3
            _id: { $$exists: true }
    expectEvents:
      - client: *client0
        ignoreExtraEvents: true
        events:
          - commandStartedEvent:
              command:
                aggregate: *collection0
                cursor:
                  batchSize: 1
                pipeline: [ { $changeStream: {} } ]
              commandName: aggregate
              databaseName: *database0

  - description: "Test wallTime field is set in a change event"
    runOnRequirements:
      - minServerVersion: "6.0.0"
    operations:
      - name: createChangeStream
        object: *collection0
        arguments: { pipeline: [] }
        saveResultAsEntity: &changeStream0 changeStream0
      - name: insertOne
        object: *collection0
        arguments:
          document: { "_id": 1, "a": 1 }
      - name: iterateUntilDocumentOrError
        object: *changeStream0
        expectResult:
          operationType: "insert"
          ns:
            db: *database0
            coll: *collection0
          wallTime: { $$exists: true }