package com.mongodb.internal.connection;
import com.mongodb.MongoNamespace;
import com.mongodb.ReadPreference;
import com.mongodb.async.SingleResultCallback;
import com.mongodb.connection.ClusterConnectionMode;
import com.mongodb.connection.SplittablePayload;
import com.mongodb.session.SessionContext;
import org.bson.BsonDocument;
import org.bson.FieldNameValidator;
import org.bson.codecs.Decoder;
import static com.mongodb.assertions.Assertions.isTrueArgument;
import static com.mongodb.assertions.Assertions.notNull;
import static com.mongodb.internal.connection.ProtocolHelper.getMessageSettings;
class CommandProtocolImpl<T> implements CommandProtocol<T> {
private final MongoNamespace namespace;
private final BsonDocument command;
private final SplittablePayload payload;
private final ReadPreference readPreference;
private final FieldNameValidator commandFieldNameValidator;
private final FieldNameValidator payloadFieldNameValidator;
private final Decoder<T> commandResultDecoder;
private final boolean responseExpected;
private final ClusterConnectionMode clusterConnectionMode;
private SessionContext sessionContext;
CommandProtocolImpl(final String database, final BsonDocument command, final FieldNameValidator commandFieldNameValidator,
final ReadPreference readPreference, final Decoder<T> commandResultDecoder) {
this(database, command, commandFieldNameValidator, readPreference, commandResultDecoder, true, null, null,
ClusterConnectionMode.MULTIPLE);
}
CommandProtocolImpl(final String database, final BsonDocument command, final FieldNameValidator commandFieldNameValidator,
final ReadPreference readPreference, final Decoder<T> commandResultDecoder, final boolean responseExpected,
final SplittablePayload payload, final FieldNameValidator payloadFieldNameValidator,
final ClusterConnectionMode clusterConnectionMode) {
notNull("database", database);
this.namespace = new MongoNamespace(notNull("database", database), MongoNamespace.COMMAND_COLLECTION_NAME);
this.command = notNull("command", command);
this.commandFieldNameValidator = notNull("commandFieldNameValidator", commandFieldNameValidator);
this.readPreference = readPreference;
this.commandResultDecoder = notNull("commandResultDecoder", commandResultDecoder);
this.responseExpected = responseExpected;
this.payload = payload;
this.payloadFieldNameValidator = payloadFieldNameValidator;
this.clusterConnectionMode = notNull("clusterConnectionMode", clusterConnectionMode);
isTrueArgument("payloadFieldNameValidator cannot be null if there is a payload.",
payload == null || payloadFieldNameValidator != null);
}
@Override
public T execute(final InternalConnection connection) {
return connection.sendAndReceive(getCommandMessage(connection), commandResultDecoder, sessionContext);
}
@Override
public void executeAsync(final InternalConnection connection, final SingleResultCallback<T> callback) {
try {
connection.sendAndReceiveAsync(getCommandMessage(connection), commandResultDecoder, sessionContext,
new SingleResultCallback<T>() {
@Override
public void onResult(final T result, final Throwable t) {
if (t != null) {
callback.onResult(null, t);
} else {
callback.onResult(result, null);
}
}
});
} catch (Throwable t) {
callback.onResult(null, t);
}
}
@Override
public CommandProtocolImpl<T> sessionContext(final SessionContext sessionContext) {
this.sessionContext = sessionContext;
return this;
}
private CommandMessage getCommandMessage(final InternalConnection connection) {
return new CommandMessage(namespace, command, commandFieldNameValidator, readPreference,
getMessageSettings(connection.getDescription()), responseExpected, payload,
payloadFieldNameValidator, clusterConnectionMode);
}
}