mirror of https://github.com/mongodb/mongo
27 lines
1.0 KiB
JavaScript
27 lines
1.0 KiB
JavaScript
/**
|
|
* Writer class for executing commands and notifying completion.
|
|
* Executes a sequence of commands and signals test completion via the Connector.
|
|
*/
|
|
import {Connector} from "jstests/libs/util/change_stream/change_stream_connector.js";
|
|
|
|
class Writer {
|
|
/**
|
|
* Execute all commands in the configuration and notify completion.
|
|
* @param {Mongo} conn - MongoDB connection.
|
|
* @param {string} controlDbName - Name of the control database for test coordination.
|
|
* @param {string} notificationCollName - Name of the notification collection for test completion.
|
|
* @param {Object} config - Configuration object containing:
|
|
* - commands: Array of command objects to execute
|
|
* - instanceName: Name of the test instance
|
|
*/
|
|
static run(conn, controlDbName, notificationCollName, config) {
|
|
for (const cmd of config.commands) {
|
|
cmd.execute(conn);
|
|
}
|
|
|
|
Connector.notifyDone(conn, controlDbName, notificationCollName, config.instanceName);
|
|
}
|
|
}
|
|
|
|
export {Writer};
|