| | |
| | | * CDDL HEADER END |
| | | * |
| | | * |
| | | * Copyright 2013 ForgeRock AS |
| | | * Portions Copyright 2013-2014 ForgeRock AS |
| | | */ |
| | | package org.opends.server.protocols.http; |
| | | |
| | |
| | | import org.opends.server.protocols.ldap.SearchRequestProtocolOp; |
| | | import org.opends.server.protocols.ldap.UnbindRequestProtocolOp; |
| | | import org.opends.server.types.AuthenticationInfo; |
| | | import org.opends.server.types.ByteString; |
| | | import org.forgerock.opendj.ldap.ByteString; |
| | | import org.opends.server.types.DebugLogLevel; |
| | | import org.opends.server.types.DisconnectReason; |
| | | import org.opends.server.types.Operation; |
| | |
| | | final int messageID = nextMessageID.getAndIncrement(); |
| | | AddOperationBasis operation = |
| | | new AddOperationBasis(clientConnection, messageID, messageID, |
| | | to(request.getControls()), to(valueOf(request.getName())), |
| | | to(request.getControls()), valueOf(request.getName()), |
| | | to(request.getAllAttributes())); |
| | | |
| | | return enqueueOperation(operation, resultHandler); |
| | |
| | | byte[] password = ((SimpleBindRequest) request).getPassword(); |
| | | BindOperationBasis operation = |
| | | new BindOperationBasis(clientConnection, messageID, messageID, |
| | | to(request.getControls()), "3", to(userName), ByteString |
| | | .wrap(password)); |
| | | to(request.getControls()), "3", ByteString.valueOf(userName), |
| | | ByteString.wrap(password)); |
| | | |
| | | return enqueueOperation(operation, resultHandler); |
| | | } |
| | |
| | | final int messageID = nextMessageID.getAndIncrement(); |
| | | CompareOperationBasis operation = |
| | | new CompareOperationBasis(clientConnection, messageID, messageID, |
| | | to(request.getControls()), to(valueOf(request.getName())), |
| | | to(request.getControls()), valueOf(request.getName()), |
| | | request.getAttributeDescription().getAttributeType().getOID(), |
| | | to(request.getAssertionValue())); |
| | | request.getAssertionValue()); |
| | | |
| | | return enqueueOperation(operation, resultHandler); |
| | | } |
| | |
| | | final int messageID = nextMessageID.getAndIncrement(); |
| | | DeleteOperationBasis operation = |
| | | new DeleteOperationBasis(clientConnection, messageID, messageID, |
| | | to(request.getControls()), to(valueOf(request.getName()))); |
| | | to(request.getControls()), valueOf(request.getName())); |
| | | |
| | | return enqueueOperation(operation, resultHandler); |
| | | } |
| | |
| | | ExtendedOperationBasis operation = |
| | | new ExtendedOperationBasis(this.clientConnection, messageID, messageID, |
| | | to(request.getControls()), request.getOID(), |
| | | to(request.getValue())); |
| | | request.getValue()); |
| | | |
| | | return enqueueOperation(operation, resultHandler); |
| | | } |
| | |
| | | final int messageID = nextMessageID.getAndIncrement(); |
| | | SearchOperationBasis operation = |
| | | new SearchOperationBasis(clientConnection, messageID, messageID, |
| | | to(request.getControls()), to(valueOf(request.getName())), |
| | | to(request.getControls()), valueOf(request.getName()), |
| | | to(request.getScope()), to(request.getDereferenceAliasesPolicy()), |
| | | request.getSizeLimit(), request.getTimeLimit(), |
| | | request.isTypesOnly(), to(request.getFilter()), |