TransportProtocol (Maverick Legacy - Client Assembly 1.7.61 API)

java.lang.Object
- com.maverick.ssh.ExecutorOperationSupport<Ssh2Context>
- - com.maverick.ssh2.TransportProtocol

All Implemented Interfaces:

SshMessageReader, AbstractClientTransport
```
public class TransportProtocol
extends ExecutorOperationSupport<Ssh2Context>
implements SshMessageReader, AbstractClientTransport
```
Main implementation of the SSH Transport Protocol. The transport is designed to run over a provider such as a Socket or StreamConnection. To use first create an instance of the protocol and set its parameters and when ready start the protocol using startTransportProtocol supplying a TransportProvider instance. This example uses the SocketProvider example implementation demonstrated in TransportProvider Help File.
```
 TransportProtocol transport = new TransportProtocol();
 transport.ignoreHostKeyVerification(true);
 transport.startTransportProtocol(new SocketProvider("titan", 22));
 
```
Host key verification is recommended and a callback interface is provided by HostKeyVerifcation. To force verification use setHostKeyVerification() before starting the protocol. This is required by default but can be ignored with ignoreHostKeyVerification(boolean ignore).

Additional cipher, message authentication and compression components can be supported by providing a custom TransportContext. The default context provides all the required components of the protocol but others can be added by creating an instance and adding the various implementations to the component factories.
```
 TransportContext context = new TransportContext();
 context.supportedCiphers().add("blowfish-cbc", "com.mycrypt.Blowfish");
 
 TransportProtocol transport = new TransportProtocol(
                TransportProtocol.CLIENT_MODE, context);
 
```
The context can also be used to specify the preferred methods of encryption for the connection which you may want to use should you add a new method to the context.
```
 context.setPreferredCipherCS("blowfish-cbc");
 
```
Author:

Lee David Painter

See Also:

TransportProvider

Field Summary

Fields
Modifier and Type	Field and Description
`static int`	`AUTH_CANCELLED_BY_USER` Disconnect reason: Authentication was cancelled
`static int`	`BY_APPLICATION` Disconnect reason: The application disconnected
`static String`	`CHARSET_ENCODING` Character set encoding.
`static int`	`COMPRESSION_ERROR` Disconnect reason: A compression error occurred
`static int`	`CONNECTED` Protocol state: The transport protocol is connected and services can be started or may already be active.
`static int`	`CONNECTION_LOST` Disconnect reason: The connection was lost
`static int`	`DISCONNECTED` Protocol state: The transport protocol has disconnected.
`static int`	`HOST_KEY_NOT_VERIFIABLE` Disconnect reason: The host key supplied could not be verified
`static int`	`HOST_NOT_ALLOWED` Disconnect reason: The host is not allowed
`static int`	`ILLEGAL_USER_NAME` Disconnect reason: The user's name is illegal
`static int`	`KEY_EXCHANGE_FAILED` Disconnect reason: Key exchange failed
`static int`	`MAC_ERROR` Disconnect reason: An error occurred verifying the MAC
`static int`	`NEGOTIATING_PROTOCOL` Protocol state: Negotation of the protocol version
`static int`	`NO_MORE_AUTH_METHODS_AVAILABLE` Disconnect reason: No more authentication methods are available
`static int`	`PERFORMING_KEYEXCHANGE` Protocol state: The protocol is performing key exchange
`static int`	`PROTOCOL_ERROR` Disconnect reason: A protocol error occurred
`static int`	`PROTOCOL_VERSION_NOT_SUPPORTED` Disconnect reason: The protocol version is not supported
`static int`	`RESERVED` Disconnect reason: Reserved
`static int`	`SERVICE_NOT_AVAILABLE` Disconnect reason: The requested service is not available
`static int`	`TOO_MANY_CONNECTIONS` Disconnect reason: Too many connections, try later

Constructor Summary

Constructors
Constructor and Description

TransportProtocol(boolean buffered, boolean managedSecurity)
Create a default transport protocol instance in CLIENT_MODE.

Constructors
Constructor and Description
`TransportProtocol(boolean buffered, boolean managedSecurity)` Create a default transport protocol instance in CLIENT_MODE.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`addListener(TransportProtocolListener listener)`
`void`	`debug(org.slf4j.Logger log, String msg, Object... args)`
`void`	`debug(String msg, Object... args)`
`void`	`disconnect(int reason, String disconnectReason)` Disconnect from the remote host.
`void`	`error(org.slf4j.Logger log, String msg, Exception e)`
`Ssh2Client`	`getClient()` Get the SshClient instance that created this transport.
`Ssh2Context`	`getContext()`
`ExecutorService`	`getExecutorService()`
`String`	`getHost()`
`String`	`getHostname()`
`String`	`getIdent()`
`boolean`	`getIgnoreHostKeyifEmpty()`
`SshKeyExchangeClient`	`getKeyExchange()`
`String`	`getKnownHostName()`
`Throwable`	`getLastError()` Returns the last error detected by the protocol.
`String[]`	`getLocalCiphersCS()`
`String[]`	`getLocalCiphersSC()`
`String[]`	`getLocalCompressionsCS()`
`String[]`	`getLocalCompressionsSC()`
`String[]`	`getLocalKeyExchanges()`
`String[]`	`getLocalMacsCS()`
`String[]`	`getLocalMacsSC()`
`String[]`	`getLocalPublicKeys()`
`protected String`	`getName()`
`SshTransport`	`getProvider()`
`String[]`	`getRemoteCiphersCS()`
`String[]`	`getRemoteCiphersSC()`
`String[]`	`getRemoteCompressionsCS()`
`String[]`	`getRemoteCompressionsSC()`
`String`	`getRemoteIdentification()` Get the identification string sent by the server during protocol negotiation
`String[]`	`getRemoteKeyExchanges()`
`String[]`	`getRemoteMacsCS()`
`String[]`	`getRemoteMacsSC()`
`String[]`	`getRemotePublicKeys()`
`byte[]`	`getSessionIdentifier()` Get the session identifier
`String`	`getUuid()`
`void`	`info(org.slf4j.Logger log, String msg, Object... args)`
`void`	`info(String msg, Object... args)`
`boolean`	`isConnected()` Returns the connected state
`byte[]`	`makeSshKey(char chr, int sizeRequired)`
`byte[]`	`nextMessage(long timeout)` Get the next message.
`boolean`	`processMessage(byte[] msg)` Process a message.
`void`	`sendMessage(byte[] msg, boolean isActivity)` Send a transport protocol message.
`void`	`setIgnoreHostKeyifEmpty(boolean ignoreHostKeyifEmpty)`
`void`	`startService(String servicename)` Request that the remote server starts a transport protocol service.
`void`	`startTransportProtocol(SshTransport provider, Ssh2Context context, String localIdentification, String remoteIdentification, Ssh2Client client)` Starts the protocol on the provider.

Methods inherited from class com.maverick.ssh.ExecutorOperationSupport
addOperationListener, addTask, cleanupOperations, clearQueue, endExecution, getOperationsCount, removeOperationListener, startExecution, startTask, taskAdded

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - CHARSET_ENCODING
```
public static String CHARSET_ENCODING
```
    Character set encoding. All input/output strings created by the API are created with this encoding. The default is "UTF-8" and it may be changed, the results however are unexpected.
  - NEGOTIATING_PROTOCOL
```
public static final int NEGOTIATING_PROTOCOL
```
    Protocol state: Negotation of the protocol version
    
    See Also:
    
    Constant Field Values
  - PERFORMING_KEYEXCHANGE
```
public static final int PERFORMING_KEYEXCHANGE
```
    Protocol state: The protocol is performing key exchange
    
    See Also:
    
    Constant Field Values
  - CONNECTED
```
public static final int CONNECTED
```
    Protocol state: The transport protocol is connected and services can be started or may already be active.
    
    See Also:
    
    Constant Field Values
  - DISCONNECTED
```
public static final int DISCONNECTED
```
    Protocol state: The transport protocol has disconnected.
    
    See Also:
    
    getLastError(), Constant Field Values
  - HOST_NOT_ALLOWED
```
public static final int HOST_NOT_ALLOWED
```
    Disconnect reason: The host is not allowed
    
    See Also:
    
    Constant Field Values
  - PROTOCOL_ERROR
```
public static final int PROTOCOL_ERROR
```
    Disconnect reason: A protocol error occurred
    
    See Also:
    
    Constant Field Values
  - KEY_EXCHANGE_FAILED
```
public static final int KEY_EXCHANGE_FAILED
```
    Disconnect reason: Key exchange failed
    
    See Also:
    
    Constant Field Values
  - RESERVED
```
public static final int RESERVED
```
    Disconnect reason: Reserved
    
    See Also:
    
    Constant Field Values
  - MAC_ERROR
```
public static final int MAC_ERROR
```
    Disconnect reason: An error occurred verifying the MAC
    
    See Also:
    
    Constant Field Values
  - COMPRESSION_ERROR
```
public static final int COMPRESSION_ERROR
```
    Disconnect reason: A compression error occurred
    
    See Also:
    
    Constant Field Values
  - SERVICE_NOT_AVAILABLE
```
public static final int SERVICE_NOT_AVAILABLE
```
    Disconnect reason: The requested service is not available
    
    See Also:
    
    Constant Field Values
  - PROTOCOL_VERSION_NOT_SUPPORTED
```
public static final int PROTOCOL_VERSION_NOT_SUPPORTED
```
    Disconnect reason: The protocol version is not supported
    
    See Also:
    
    Constant Field Values
  - HOST_KEY_NOT_VERIFIABLE
```
public static final int HOST_KEY_NOT_VERIFIABLE
```
    Disconnect reason: The host key supplied could not be verified
    
    See Also:
    
    Constant Field Values
  - CONNECTION_LOST
```
public static final int CONNECTION_LOST
```
    Disconnect reason: The connection was lost
    
    See Also:
    
    Constant Field Values
  - BY_APPLICATION
```
public static final int BY_APPLICATION
```
    Disconnect reason: The application disconnected
    
    See Also:
    
    Constant Field Values
  - TOO_MANY_CONNECTIONS
```
public static final int TOO_MANY_CONNECTIONS
```
    Disconnect reason: Too many connections, try later
    
    See Also:
    
    Constant Field Values
  - AUTH_CANCELLED_BY_USER
```
public static final int AUTH_CANCELLED_BY_USER
```
    Disconnect reason: Authentication was cancelled
    
    See Also:
    
    Constant Field Values
  - NO_MORE_AUTH_METHODS_AVAILABLE
```
public static final int NO_MORE_AUTH_METHODS_AVAILABLE
```
    Disconnect reason: No more authentication methods are available
    
    See Also:
    
    Constant Field Values
  - ILLEGAL_USER_NAME
```
public static final int ILLEGAL_USER_NAME
```
    Disconnect reason: The user's name is illegal
    
    See Also:
    
    Constant Field Values
- Constructor Detail
  - TransportProtocol
```
public TransportProtocol(boolean buffered,
                         boolean managedSecurity)
```
    Create a default transport protocol instance in CLIENT_MODE.
    
    Throws:
    
    IOException
- Method Detail
  - getProvider
```
public SshTransport getProvider()
```
  - addListener
```
public void addListener(TransportProtocolListener listener)
```
  - getClient
```
public Ssh2Client getClient()
```
    Get the SshClient instance that created this transport.
    
    Returns:
  - getName
```
protected String getName()
```
    Specified by:
    
    getName in class ExecutorOperationSupport<Ssh2Context>
  - isConnected
```
public boolean isConnected()
```
    Returns the connected state
    
    Specified by:
    
    isConnected in interface SshMessageReader
    
    Returns:
    
    true if the transport is connected, otherwise false
  - getLastError
```
public Throwable getLastError()
```
    Returns the last error detected by the protocol. If a disconnect occurs this may provide a reason.
    
    Returns:
    
    a last error detected by the transport protocol.
  - getContext
```
public Ssh2Context getContext()
```
    Specified by:
    
    getContext in interface AbstractClientTransport
    
    Specified by:
    
    getContext in class ExecutorOperationSupport<Ssh2Context>
  - getIgnoreHostKeyifEmpty
```
public boolean getIgnoreHostKeyifEmpty()
```
  - setIgnoreHostKeyifEmpty
```
public void setIgnoreHostKeyifEmpty(boolean ignoreHostKeyifEmpty)
```
  - getHostname
```
public String getHostname()
```
    Specified by:
    
    getHostname in interface SshMessageReader
  - startTransportProtocol
```
public void startTransportProtocol(SshTransport provider,
                                   Ssh2Context context,
                                   String localIdentification,
                                   String remoteIdentification,
                                   Ssh2Client client)
                            throws SshException
```
    Starts the protocol on the provider.
    
    Throws:
    
    SshException
  - getRemoteIdentification
```
public String getRemoteIdentification()
```
    Get the identification string sent by the server during protocol negotiation
    
    Returns:
    
    String
  - getSessionIdentifier
```
public byte[] getSessionIdentifier()
```
    Get the session identifier
    
    Returns:
    
    byte[]
  - disconnect
```
public void disconnect(int reason,
                       String disconnectReason)
```
    Disconnect from the remote host. No more messages can be sent after this method has been called.
    
    Specified by:
    
    disconnect in interface AbstractClientTransport
    
    Parameters:
    
    reason -
    
    disconnectReason - , description
    
    Throws:
    
    IOException
  - sendMessage
```
public void sendMessage(byte[] msg,
                        boolean isActivity)
                 throws SshException
```
    Send a transport protocol message. The format of the message should be:
    byte Message ID byte[] Payload
    Specified by:
    
    sendMessage in interface AbstractClientTransport
    
    Parameters:
    
    msgdata -
    
    Throws:
    
    IOException
    
    SshException
  - info
```
public void info(String msg,
                 Object... args)
```
  - debug
```
public void debug(String msg,
                  Object... args)
```
  - info
```
public void info(org.slf4j.Logger log,
                 String msg,
                 Object... args)
```
    Specified by:
    
    info in interface AbstractClientTransport
  - debug
```
public void debug(org.slf4j.Logger log,
                  String msg,
                  Object... args)
```
    Specified by:
    
    debug in interface AbstractClientTransport
  - error
```
public void error(org.slf4j.Logger log,
                  String msg,
                  Exception e)
```
    Specified by:
    
    error in interface AbstractClientTransport
  - nextMessage
```
public byte[] nextMessage(long timeout)
                   throws SshException
```
    Get the next message. The message returned will be the full message data so skipping the first 5 bytes is required before the message data can be read.
    
    Specified by:
    
    nextMessage in interface SshMessageReader
    
    Specified by:
    
    nextMessage in interface AbstractClientTransport
    
    Returns:
    
    a byte array containing all the message data
    
    Throws:
    
    IOException
    
    SshException
  - getKeyExchange
```
public SshKeyExchangeClient getKeyExchange()
```
  - getKnownHostName
```
public String getKnownHostName()
```
  - startService
```
public void startService(String servicename)
                  throws SshException
```
    Request that the remote server starts a transport protocol service. This is only available in CLIENT_MODE.
    
    Parameters:
    
    servicename -
    
    Throws:
    
    IOException
    
    SshException
  - processMessage
```
public boolean processMessage(byte[] msg)
                       throws SshException
```
    Process a message. This should be called when reading messages from outside of the transport protocol so that the transport protocol can parse its own messages.
    
    Parameters:
    
    msg -
    
    Returns:
    
    true if the message was processed by the transport and can be discarded, otherwise false.
    
    Throws:
    
    SshException
  - makeSshKey
```
public byte[] makeSshKey(char chr,
                         int sizeRequired)
                  throws IOException
```
    Throws:
    
    IOException
  - getExecutorService
```
public ExecutorService getExecutorService()
```
    Specified by:
    
    getExecutorService in interface SshMessageReader
  - getRemoteKeyExchanges
```
public String[] getRemoteKeyExchanges()
```
  - getRemotePublicKeys
```
public String[] getRemotePublicKeys()
```
  - getRemoteCiphersCS
```
public String[] getRemoteCiphersCS()
```
  - getRemoteCiphersSC
```
public String[] getRemoteCiphersSC()
```
  - getRemoteMacsCS
```
public String[] getRemoteMacsCS()
```
  - getRemoteMacsSC
```
public String[] getRemoteMacsSC()
```
  - getRemoteCompressionsCS
```
public String[] getRemoteCompressionsCS()
```
  - getRemoteCompressionsSC
```
public String[] getRemoteCompressionsSC()
```
  - getLocalKeyExchanges
```
public String[] getLocalKeyExchanges()
```
  - getLocalPublicKeys
```
public String[] getLocalPublicKeys()
```
  - getLocalCiphersCS
```
public String[] getLocalCiphersCS()
```
  - getLocalCiphersSC
```
public String[] getLocalCiphersSC()
```
  - getLocalMacsCS
```
public String[] getLocalMacsCS()
```
  - getLocalMacsSC
```
public String[] getLocalMacsSC()
```
  - getLocalCompressionsCS
```
public String[] getLocalCompressionsCS()
```
  - getLocalCompressionsSC
```
public String[] getLocalCompressionsSC()
```
  - getIdent
```
public String getIdent()
```
    Specified by:
    
    getIdent in interface SshMessageReader
    
    Specified by:
    
    getIdent in interface AbstractClientTransport
  - getHost
```
public String getHost()
```
    Specified by:
    
    getHost in interface AbstractClientTransport
  - getUuid
```
public String getUuid()
```
    Specified by:
    
    getUuid in interface SshMessageReader

Class TransportProtocol

Field Summary

Constructor Summary

Method Summary

Methods inherited from class com.maverick.ssh.ExecutorOperationSupport

Methods inherited from class java.lang.Object

Field Detail

CHARSET_ENCODING

NEGOTIATING_PROTOCOL

PERFORMING_KEYEXCHANGE

CONNECTED

DISCONNECTED

HOST_NOT_ALLOWED

PROTOCOL_ERROR

KEY_EXCHANGE_FAILED

RESERVED

MAC_ERROR

COMPRESSION_ERROR

SERVICE_NOT_AVAILABLE

PROTOCOL_VERSION_NOT_SUPPORTED

HOST_KEY_NOT_VERIFIABLE

CONNECTION_LOST

BY_APPLICATION

TOO_MANY_CONNECTIONS

AUTH_CANCELLED_BY_USER

NO_MORE_AUTH_METHODS_AVAILABLE

ILLEGAL_USER_NAME

Constructor Detail

TransportProtocol

Method Detail

getProvider

addListener

getClient

getName

isConnected

getLastError

getContext

getIgnoreHostKeyifEmpty

setIgnoreHostKeyifEmpty

getHostname

startTransportProtocol

getRemoteIdentification

getSessionIdentifier

disconnect

sendMessage

info

debug

info

debug

error

nextMessage

getKeyExchange

getKnownHostName

startService

processMessage

makeSshKey

getExecutorService

getRemoteKeyExchanges

getRemotePublicKeys

getRemoteCiphersCS

getRemoteCiphersSC

getRemoteMacsCS

getRemoteMacsSC

getRemoteCompressionsCS

getRemoteCompressionsSC

getLocalKeyExchanges

getLocalPublicKeys

getLocalCiphersCS

getLocalCiphersSC

getLocalMacsCS

getLocalMacsSC

getLocalCompressionsCS

getLocalCompressionsSC

getIdent

getHost

getUuid