constants.js 7.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170
  1. "use strict";
  2. Object.defineProperty(exports, "__esModule", { value: true });
  3. exports.END = exports.CHANGE = exports.INIT = exports.MORE = exports.RESPONSE = exports.SERVER_HEARTBEAT_FAILED = exports.SERVER_HEARTBEAT_SUCCEEDED = exports.SERVER_HEARTBEAT_STARTED = exports.COMMAND_FAILED = exports.COMMAND_SUCCEEDED = exports.COMMAND_STARTED = exports.CLUSTER_TIME_RECEIVED = exports.CONNECTION_CHECKED_IN = exports.CONNECTION_CHECKED_OUT = exports.CONNECTION_CHECK_OUT_FAILED = exports.CONNECTION_CHECK_OUT_STARTED = exports.CONNECTION_CLOSED = exports.CONNECTION_READY = exports.CONNECTION_CREATED = exports.CONNECTION_POOL_READY = exports.CONNECTION_POOL_CLEARED = exports.CONNECTION_POOL_CLOSED = exports.CONNECTION_POOL_CREATED = exports.WAITING_FOR_SUITABLE_SERVER = exports.SERVER_SELECTION_SUCCEEDED = exports.SERVER_SELECTION_FAILED = exports.SERVER_SELECTION_STARTED = exports.TOPOLOGY_DESCRIPTION_CHANGED = exports.TOPOLOGY_CLOSED = exports.TOPOLOGY_OPENING = exports.SERVER_DESCRIPTION_CHANGED = exports.SERVER_CLOSED = exports.SERVER_OPENING = exports.DESCRIPTION_RECEIVED = exports.UNPINNED = exports.PINNED = exports.MESSAGE = exports.ENDED = exports.CLOSED = exports.CONNECT = exports.OPEN = exports.CLOSE = exports.TIMEOUT = exports.ERROR = exports.SYSTEM_JS_COLLECTION = exports.SYSTEM_COMMAND_COLLECTION = exports.SYSTEM_USER_COLLECTION = exports.SYSTEM_PROFILE_COLLECTION = exports.SYSTEM_INDEX_COLLECTION = exports.SYSTEM_NAMESPACE_COLLECTION = void 0;
  4. exports.kDecoratedKeys = exports.kDecorateResult = exports.LEGACY_HELLO_COMMAND_CAMEL_CASE = exports.LEGACY_HELLO_COMMAND = exports.MONGO_CLIENT_EVENTS = exports.LOCAL_SERVER_EVENTS = exports.SERVER_RELAY_EVENTS = exports.APM_EVENTS = exports.TOPOLOGY_EVENTS = exports.CMAP_EVENTS = exports.HEARTBEAT_EVENTS = exports.RESUME_TOKEN_CHANGED = void 0;
  5. exports.SYSTEM_NAMESPACE_COLLECTION = 'system.namespaces';
  6. exports.SYSTEM_INDEX_COLLECTION = 'system.indexes';
  7. exports.SYSTEM_PROFILE_COLLECTION = 'system.profile';
  8. exports.SYSTEM_USER_COLLECTION = 'system.users';
  9. exports.SYSTEM_COMMAND_COLLECTION = '$cmd';
  10. exports.SYSTEM_JS_COLLECTION = 'system.js';
  11. // events
  12. exports.ERROR = 'error';
  13. exports.TIMEOUT = 'timeout';
  14. exports.CLOSE = 'close';
  15. exports.OPEN = 'open';
  16. exports.CONNECT = 'connect';
  17. exports.CLOSED = 'closed';
  18. exports.ENDED = 'ended';
  19. exports.MESSAGE = 'message';
  20. exports.PINNED = 'pinned';
  21. exports.UNPINNED = 'unpinned';
  22. exports.DESCRIPTION_RECEIVED = 'descriptionReceived';
  23. /** @internal */
  24. exports.SERVER_OPENING = 'serverOpening';
  25. /** @internal */
  26. exports.SERVER_CLOSED = 'serverClosed';
  27. /** @internal */
  28. exports.SERVER_DESCRIPTION_CHANGED = 'serverDescriptionChanged';
  29. /** @internal */
  30. exports.TOPOLOGY_OPENING = 'topologyOpening';
  31. /** @internal */
  32. exports.TOPOLOGY_CLOSED = 'topologyClosed';
  33. /** @internal */
  34. exports.TOPOLOGY_DESCRIPTION_CHANGED = 'topologyDescriptionChanged';
  35. /** @internal */
  36. exports.SERVER_SELECTION_STARTED = 'serverSelectionStarted';
  37. /** @internal */
  38. exports.SERVER_SELECTION_FAILED = 'serverSelectionFailed';
  39. /** @internal */
  40. exports.SERVER_SELECTION_SUCCEEDED = 'serverSelectionSucceeded';
  41. /** @internal */
  42. exports.WAITING_FOR_SUITABLE_SERVER = 'waitingForSuitableServer';
  43. /** @internal */
  44. exports.CONNECTION_POOL_CREATED = 'connectionPoolCreated';
  45. /** @internal */
  46. exports.CONNECTION_POOL_CLOSED = 'connectionPoolClosed';
  47. /** @internal */
  48. exports.CONNECTION_POOL_CLEARED = 'connectionPoolCleared';
  49. /** @internal */
  50. exports.CONNECTION_POOL_READY = 'connectionPoolReady';
  51. /** @internal */
  52. exports.CONNECTION_CREATED = 'connectionCreated';
  53. /** @internal */
  54. exports.CONNECTION_READY = 'connectionReady';
  55. /** @internal */
  56. exports.CONNECTION_CLOSED = 'connectionClosed';
  57. /** @internal */
  58. exports.CONNECTION_CHECK_OUT_STARTED = 'connectionCheckOutStarted';
  59. /** @internal */
  60. exports.CONNECTION_CHECK_OUT_FAILED = 'connectionCheckOutFailed';
  61. /** @internal */
  62. exports.CONNECTION_CHECKED_OUT = 'connectionCheckedOut';
  63. /** @internal */
  64. exports.CONNECTION_CHECKED_IN = 'connectionCheckedIn';
  65. exports.CLUSTER_TIME_RECEIVED = 'clusterTimeReceived';
  66. /** @internal */
  67. exports.COMMAND_STARTED = 'commandStarted';
  68. /** @internal */
  69. exports.COMMAND_SUCCEEDED = 'commandSucceeded';
  70. /** @internal */
  71. exports.COMMAND_FAILED = 'commandFailed';
  72. /** @internal */
  73. exports.SERVER_HEARTBEAT_STARTED = 'serverHeartbeatStarted';
  74. /** @internal */
  75. exports.SERVER_HEARTBEAT_SUCCEEDED = 'serverHeartbeatSucceeded';
  76. /** @internal */
  77. exports.SERVER_HEARTBEAT_FAILED = 'serverHeartbeatFailed';
  78. exports.RESPONSE = 'response';
  79. exports.MORE = 'more';
  80. exports.INIT = 'init';
  81. exports.CHANGE = 'change';
  82. exports.END = 'end';
  83. exports.RESUME_TOKEN_CHANGED = 'resumeTokenChanged';
  84. /** @public */
  85. exports.HEARTBEAT_EVENTS = Object.freeze([
  86. exports.SERVER_HEARTBEAT_STARTED,
  87. exports.SERVER_HEARTBEAT_SUCCEEDED,
  88. exports.SERVER_HEARTBEAT_FAILED
  89. ]);
  90. /** @public */
  91. exports.CMAP_EVENTS = Object.freeze([
  92. exports.CONNECTION_POOL_CREATED,
  93. exports.CONNECTION_POOL_READY,
  94. exports.CONNECTION_POOL_CLEARED,
  95. exports.CONNECTION_POOL_CLOSED,
  96. exports.CONNECTION_CREATED,
  97. exports.CONNECTION_READY,
  98. exports.CONNECTION_CLOSED,
  99. exports.CONNECTION_CHECK_OUT_STARTED,
  100. exports.CONNECTION_CHECK_OUT_FAILED,
  101. exports.CONNECTION_CHECKED_OUT,
  102. exports.CONNECTION_CHECKED_IN
  103. ]);
  104. /** @public */
  105. exports.TOPOLOGY_EVENTS = Object.freeze([
  106. exports.SERVER_OPENING,
  107. exports.SERVER_CLOSED,
  108. exports.SERVER_DESCRIPTION_CHANGED,
  109. exports.TOPOLOGY_OPENING,
  110. exports.TOPOLOGY_CLOSED,
  111. exports.TOPOLOGY_DESCRIPTION_CHANGED,
  112. exports.ERROR,
  113. exports.TIMEOUT,
  114. exports.CLOSE
  115. ]);
  116. /** @public */
  117. exports.APM_EVENTS = Object.freeze([
  118. exports.COMMAND_STARTED,
  119. exports.COMMAND_SUCCEEDED,
  120. exports.COMMAND_FAILED
  121. ]);
  122. /**
  123. * All events that we relay to the `Topology`
  124. * @internal
  125. */
  126. exports.SERVER_RELAY_EVENTS = Object.freeze([
  127. exports.SERVER_HEARTBEAT_STARTED,
  128. exports.SERVER_HEARTBEAT_SUCCEEDED,
  129. exports.SERVER_HEARTBEAT_FAILED,
  130. exports.COMMAND_STARTED,
  131. exports.COMMAND_SUCCEEDED,
  132. exports.COMMAND_FAILED,
  133. ...exports.CMAP_EVENTS
  134. ]);
  135. /**
  136. * All events we listen to from `Server` instances, but do not forward to the client
  137. * @internal
  138. */
  139. exports.LOCAL_SERVER_EVENTS = Object.freeze([
  140. exports.CONNECT,
  141. exports.DESCRIPTION_RECEIVED,
  142. exports.CLOSED,
  143. exports.ENDED
  144. ]);
  145. /** @public */
  146. exports.MONGO_CLIENT_EVENTS = Object.freeze([
  147. ...exports.CMAP_EVENTS,
  148. ...exports.APM_EVENTS,
  149. ...exports.TOPOLOGY_EVENTS,
  150. ...exports.HEARTBEAT_EVENTS
  151. ]);
  152. /**
  153. * @internal
  154. * The legacy hello command that was deprecated in MongoDB 5.0.
  155. */
  156. exports.LEGACY_HELLO_COMMAND = 'ismaster';
  157. /**
  158. * @internal
  159. * The legacy hello command that was deprecated in MongoDB 5.0.
  160. */
  161. exports.LEGACY_HELLO_COMMAND_CAMEL_CASE = 'isMaster';
  162. // Typescript errors if we index objects with `Symbol.for(...)`, so
  163. // to avoid TS errors we pull them out into variables. Then we can type
  164. // the objects (and class) that we expect to see them on and prevent TS
  165. // errors.
  166. /** @internal */
  167. exports.kDecorateResult = Symbol.for('@@mdb.decorateDecryptionResult');
  168. /** @internal */
  169. exports.kDecoratedKeys = Symbol.for('@@mdb.decryptedKeys');
  170. //# sourceMappingURL=constants.js.map