222

schangxiang@126.com

2025-06-13 6a8393408d8cefcea02b7a598967de8dc1e565c2

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
'use strict';
 
const Aspect = require('./operation').Aspect;
const defineAspects = require('./operation').defineAspects;
const handleCallback = require('../utils').handleCallback;
const CursorState = require('../core/cursor').CursorState;
const OperationBase = require('./operation').OperationBase;
const push = Array.prototype.push;
 
class ToArrayOperation extends OperationBase {
  constructor(cursor) {
    super();
 
    this.cursor = cursor;
  }
 
  execute(callback) {
    const cursor = this.cursor;
    const items = [];
 
    // Reset cursor
    cursor.rewind();
    cursor.s.state = CursorState.INIT;
 
    // Fetch all the documents
    const fetchDocs = () => {
      cursor._next((err, doc) => {
        if (err) {
          return cursor._endSession
            ? cursor._endSession(() => handleCallback(callback, err))
            : handleCallback(callback, err);
        }
 
        if (doc == null) {
          return cursor.close({ skipKillCursors: true }, () =>
            handleCallback(callback, null, items)
          );
        }
 
        // Add doc to items
        items.push(doc);
 
        // Get all buffered objects
        if (cursor.bufferedCount() > 0) {
          let docs = cursor.readBufferedDocuments(cursor.bufferedCount());
 
          // Transform the doc if transform method added
          if (cursor.s.transforms && typeof cursor.s.transforms.doc === 'function') {
            docs = docs.map(cursor.s.transforms.doc);
          }
 
          push.apply(items, docs);
        }
 
        // Attempt a fetch
        fetchDocs();
      });
    };
 
    fetchDocs();
  }
}
 
defineAspects(ToArrayOperation, Aspect.SKIP_SESSION);
 
module.exports = ToArrayOperation;