| 130 | } |
| 131 | |
| 132 | export class UnifiedMongoClient extends MongoClient { |
| 133 | commandEvents: CommandEvent[] = []; |
| 134 | cmapEvents: CmapEvent[] = []; |
| 135 | sdamEvents: SdamEvent[] = []; |
| 136 | failPoints: Document[] = []; |
| 137 | logCollector?: { buffer: LogMessage[]; write: (log: Log) => void }; |
| 138 | |
| 139 | ignoredEvents: string[]; |
| 140 | observeSensitiveCommands: boolean; |
| 141 | observedCommandEvents: (class="st">'commandStarted' | class="st">'commandSucceeded' | class="st">'commandFailed')[]; |
| 142 | observedCmapEvents: ( |
| 143 | | class="st">'connectionPoolCreated' |
| 144 | | class="st">'connectionPoolClosed' |
| 145 | | class="st">'connectionPoolReady' |
| 146 | | class="st">'connectionPoolCleared' |
| 147 | | class="st">'connectionCreated' |
| 148 | | class="st">'connectionReady' |
| 149 | | class="st">'connectionClosed' |
| 150 | | class="st">'connectionCheckOutStarted' |
| 151 | | class="st">'connectionCheckOutFailed' |
| 152 | | class="st">'connectionCheckedOut' |
| 153 | | class="st">'connectionCheckedIn' |
| 154 | )[]; |
| 155 | observedSdamEvents: ( |
| 156 | | class="st">'serverDescriptionChanged' |
| 157 | | class="st">'serverHeartbeatStarted' |
| 158 | | class="st">'serverHeartbeatFailed' |
| 159 | | class="st">'serverHeartbeatSucceeded' |
| 160 | | class="st">'serverOpened' |
| 161 | | class="st">'serverClosed' |
| 162 | | class="st">'topologyOpened' |
| 163 | | class="st">'topologyClosed' |
| 164 | | class="st">'topologyDescriptionChangedEvent' |
| 165 | )[]; |
| 166 | observedEventEmitter = new EventEmitter(); |
| 167 | _credentials: MongoCredentials | null; |
| 168 | |
| 169 | static COMMAND_EVENT_NAME_LOOKUP = { |
| 170 | commandStartedEvent: class="st">'commandStarted', |
| 171 | commandSucceededEvent: class="st">'commandSucceeded', |
| 172 | commandFailedEvent: class="st">'commandFailed' |
| 173 | } as const; |
| 174 | |
| 175 | static CMAP_EVENT_NAME_LOOKUP = { |
| 176 | poolCreatedEvent: class="st">'connectionPoolCreated', |
| 177 | poolClosedEvent: class="st">'connectionPoolClosed', |
| 178 | poolReadyEvent: class="st">'connectionPoolReady', |
| 179 | poolClearedEvent: class="st">'connectionPoolCleared', |
| 180 | connectionCreatedEvent: class="st">'connectionCreated', |
| 181 | connectionReadyEvent: class="st">'connectionReady', |
| 182 | connectionClosedEvent: class="st">'connectionClosed', |
| 183 | connectionCheckOutStartedEvent: class="st">'connectionCheckOutStarted', |
| 184 | connectionCheckOutFailedEvent: class="st">'connectionCheckOutFailed', |
| 185 | connectionCheckedOutEvent: class="st">'connectionCheckedOut', |
| 186 | connectionCheckedInEvent: class="st">'connectionCheckedIn' |
| 187 | } as const; |
| 188 | |
| 189 | static SDAM_EVENT_NAME_LOOKUP = { |
nothing calls this directly
no test coverage detected