# ClientSocket.java

    /*
    ** Module   : ClientSocket.java
    ** Abstract : Implementation of OpenEdge.Net.ServerConnection.ClientSocket
    **            builtin class.
    **
    ** Copyright (c) 2019-2024, Golden Code Development Corporation.
    **
    ** -#- -I- --Date-- ---------------------------------------Description---------------------------------------
    ** 001 MP  20200528 Created the first version, by converting the legacy skeleton .cls file and using that
    **                  output.
    ** 002 MP  20200611 Add missing methods as stubs taken by converting the skeleton using FWD.
    **     CA  20210219 OO input parameter definitions for functions/procedures must not register with  ObjectOps
    **                  - TypeFactory.initInput will take care of this.
    ** 003 CA  20210221 Fixed 'qualified', 'extent' and 'returns' annotations at the legacy signature.
    **     ME  20210426 Fixed properties initial values (class not implemented, http client used instead).
    **     OM  20210917 Code maintenance.
    **     CA  20220513 Fixed legacy signature for 'writeData'.
    ** 004 CA  20230817 Removed ObjectOps.register, as this registration is handled by runtime.
    ** 005 ME  20230503 Reconvert skeleton, remove setter for connected, set connect params on ctor (#6410).
    ** 006 CA  20231113 The 'execute' method must be annotated with LegacySignature Type.Execute, and also can be
    **                  dropped if is a no-op.
    ** 007 GBB 20240610 Comments left to remind of setting client type.
    */

    /*
    ** This program is free software: you can redistribute it and/or modify
    ** it under the terms of the GNU Affero General Public License as
    ** published by the Free Software Foundation, either version 3 of the
    ** License, or (at your option) any later version.
    **
    ** This program is distributed in the hope that it will be useful,
    ** but WITHOUT ANY WARRANTY; without even the implied warranty of
    ** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    ** GNU Affero General Public License for more details.
    **
    ** You may find a copy of the GNU Affero GPL version 3 at the following
    ** location: https://www.gnu.org/licenses/agpl-3.0.en.html
    **
    ** Additional terms under GNU Affero GPL version 3 section 7:
    **
    **   Under Section 7 of the GNU Affero GPL version 3, the following additional
    **   terms apply to the works covered under the License.  These additional terms
    **   are non-permissive additional terms allowed under Section 7 of the GNU
    **   Affero GPL version 3 and may not be removed by you.
    **
    **   0. Attribution Requirement.
    **
    **     You must preserve all legal notices or author attributions in the covered
    **     work or Appropriate Legal Notices displayed by works containing the covered
    **     work.  You may not remove from the covered work any author or developer
    **     credit already included within the covered work.
    **
    **   1. No License To Use Trademarks.
    **
    **     This license does not grant any license or rights to use the trademarks
    **     Golden Code, FWD, any Golden Code or FWD logo, or any other trademarks
    **     of Golden Code Development Corporation. You are not authorized to use the
    **     name Golden Code, FWD, or the names of any author or contributor, for
    **     publicity purposes without written authorization.
    **
    **   2. No Misrepresentation of Affiliation.
    **
    **     You may not represent yourself as Golden Code Development Corporation or FWD.
    **
    **     You may not represent yourself for publicity purposes as associated with
    **     Golden Code Development Corporation, FWD, or any author or contributor to
    **     the covered work, without written authorization.
    **
    **   3. No Misrepresentation of Source or Origin.
    **
    **     You may not represent the covered work as solely your work.  All modified
    **     versions of the covered work must be marked in a reasonable way to make it
    **     clear that the modified work is not originating from Golden Code Development
    **     Corporation or FWD.  All modified versions must contain the notices of
    **     attribution required in this license.
    */

    package com.goldencode.p2j.oo.net.serverconnection;

    import com.goldencode.p2j.util.*;
    import com.goldencode.p2j.util.BlockManager.Action;
    import com.goldencode.p2j.util.BlockManager.Condition;
    import com.goldencode.p2j.oo.core.serverconnection.IserverConnection;
    import com.goldencode.p2j.oo.logging.ISupportLogging;
    import com.goldencode.p2j.oo.lang.*;
    import com.goldencode.p2j.oo.core.serverconnection.IconnectionParameters;
    import com.goldencode.p2j.oo.logging.IlogWriter;
    import com.goldencode.p2j.oo.lang._BaseObject_;
    import com.goldencode.p2j.oo.net.Uri;

    import static com.goldencode.p2j.report.ReportConstants.*;
    import static com.goldencode.p2j.util.BlockManager.*;
    import static com.goldencode.p2j.util.InternalEntry.Type;

    /**
     * Business logic (converted to Java from the 4GL source code
     * in OpenEdge/Net/ServerConnection/ClientSocket.cls).
     */
    @LegacyResource(resource = "OpenEdge.Net.ServerConnection.ClientSocket")
    @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
    public class ClientSocket
    extends BaseObject
    implements IserverConnection,
               ISupportLogging
    {
       @LegacySignature(type = Type.PROPERTY, name = "Connected")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private logical connected = TypeFactory.logical();

       @LegacySignature(type = Type.PROPERTY, name = "ConnectionParameters")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private object<? extends IconnectionParameters> connectionParameters = TypeFactory.object(IconnectionParameters.class);

       @LegacySignature(type = Type.PROPERTY, name = "DefaultReadTimeout")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private integer defaultReadTimeout = TypeFactory.integer();

       @LegacySignature(type = Type.PROPERTY, name = "KeepAlive")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private logical keepAlive = TypeFactory.logical(null);

       @LegacySignature(type = Type.PROPERTY, name = "LingerTime")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private integer lingerTime = TypeFactory.integer(-1L);

       @LegacySignature(type = Type.PROPERTY, name = "Logger")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private object<? extends IlogWriter> logger = TypeFactory.object(IlogWriter.class);

       @LegacySignature(type = Type.PROPERTY, name = "NoDelay")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private logical noDelay = TypeFactory.logical(null);

       @LegacySignature(type = Type.PROPERTY, name = "ReadBufferSize")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private integer readBufferSize = TypeFactory.integer();

       @LegacySignature(type = Type.PROPERTY, name = "ReceiveBufferSize")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private integer receiveBufferSize = TypeFactory.integer(null);

       @LegacySignature(type = Type.PROPERTY, name = "ReceiveTimeout")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private integer receiveTimeout = TypeFactory.integer(null);

       @LegacySignature(type = Type.PROPERTY, name = "ReuseAddress")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private logical reuseAddress = TypeFactory.logical(null);

       @LegacySignature(type = Type.PROPERTY, name = "RemoteHost")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private character remoteHost = TypeFactory.character();

       @LegacySignature(type = Type.PROPERTY, name = "RemotePort")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private integer remotePort = TypeFactory.integer();

       @LegacySignature(type = Type.PROPERTY, name = "LocalHost")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private character localHost = TypeFactory.character();

       @LegacySignature(type = Type.PROPERTY, name = "LocalPort")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private integer localPort = TypeFactory.integer();

       @LegacySignature(type = Type.PROPERTY, name = "SendBufferSize")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private integer sendBufferSize = TypeFactory.integer(null);

       @LegacySignature(type = Type.PROPERTY, name = "server")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private object<? extends _BaseObject_> server = TypeFactory.object(_BaseObject_.class);

       @LegacySignature(type = Type.PROPERTY, name = "SslServerName")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private character sslServerName = TypeFactory.character();

       @LegacySignature(type = Type.EVENT, name = "DataReceived", parameters =
       {
          @LegacyParameter(name = "p1", type = "OBJECT", qualified = "openedge.net.serverconnection.clientsocket", mode = "INPUT"),
          @LegacyParameter(name = "p2", type = "OBJECT", qualified = "openedge.net.serverconnection.socketreadeventargs", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private ClassEvent dataReceived = new ClassEvent(ClientSocket.this, "DataReceived", "dataReceived");

       @LegacySignature(type = Type.EVENT, name = "ReadTerminated", parameters =
       {
          @LegacyParameter(name = "p1", type = "OBJECT", qualified = "openedge.net.serverconnection.clientsocket", mode = "INPUT"),
          @LegacyParameter(name = "p2", type = "OBJECT", qualified = "openedge.net.serverconnection.socketreadeventargs", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private ClassEvent readTerminated = new ClassEvent(ClientSocket.this, "ReadTerminated", "readTerminated");

       @LegacySignature(type = Type.EVENT, name = "ReadTimeout", parameters =
       {
          @LegacyParameter(name = "p1", type = "OBJECT", qualified = "openedge.net.serverconnection.clientsocket", mode = "INPUT"),
          @LegacyParameter(name = "p2", type = "OBJECT", qualified = "openedge.net.serverconnection.socketreadeventargs", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private ClassEvent readTimeout = new ClassEvent(ClientSocket.this, "ReadTimeout", "readTimeout");

       /**
        * Execute method
        */
       @LegacySignature(type = Type.EXECUTE)
       public void __net_serverconnection_ClientSocket_execute__()
       {
          onBlockLevel(Condition.ERROR, Action.THROW);
       }

       @LegacySignature(returns = "LOGICAL", type = Type.GETTER, name = "Connected")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public logical getConnected()
       {
          return function(ClientSocket.class, this, "Connected", logical.class, new Block((Body) () ->
          {
             returnNormal(connected);
          }));
       }

       @LegacySignature(returns = "OBJECT", qualified = "OpenEdge.Core.ServerConnection.IConnectionParameters", type = Type.GETTER, name = "ConnectionParameters")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public object<? extends IconnectionParameters> getConnectionParameters()
       {
          return function(ClientSocket.class, this, "ConnectionParameters", object.class, new Block((Body) () ->
          {
             returnNormal(connectionParameters);
          }));
       }

       @LegacySignature(type = Type.SETTER, name = "ConnectionParameters", parameters =
       {
          @LegacyParameter(qualified = "OpenEdge.Core.ServerConnection.IConnectionParameters", name = "var", type = "OBJECT", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void setConnectionParameters(final object<? extends IconnectionParameters> _var)
       {
          object<? extends IconnectionParameters> var = TypeFactory.initInput(_var);

          internalProcedure(ClientSocket.class, this, "ConnectionParameters", new Block((Body) () ->
          {
             connectionParameters.assign(var);
          }));
       }

       @LegacySignature(returns = "CHARACTER", type = Type.GETTER, name = "LocalHost")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public character getLocalHost()
       {
          return function(ClientSocket.class, this, "LocalHost", character.class, new Block((Body) () ->
          {
             returnNormal(localHost);
          }));
       }

       @LegacySignature(returns = "INTEGER", type = Type.GETTER, name = "LocalPort")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public integer getLocalPort()
       {
          return function(ClientSocket.class, this, "LocalPort", integer.class, new Block((Body) () ->
          {
             returnNormal(localPort);
          }));
       }

       @LegacySignature(returns = "CHARACTER", type = Type.GETTER, name = "RemoteHost")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public character getRemoteHost()
       {
          return function(ClientSocket.class, this, "RemoteHost", character.class, new Block((Body) () ->
          {
             returnNormal(remoteHost);
          }));
       }

       @LegacySignature(returns = "INTEGER", type = Type.GETTER, name = "RemotePort")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public integer getRemotePort()
       {
          return function(ClientSocket.class, this, "RemotePort", integer.class, new Block((Body) () ->
          {
             returnNormal(remotePort);
          }));
       }

       @LegacySignature(returns = "INTEGER", type = Type.GETTER, name = "DefaultReadTimeout")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public integer getDefaultReadTimeout()
       {
          return function(ClientSocket.class, this, "DefaultReadTimeout", integer.class, new Block((Body) () ->
          {
             returnNormal(defaultReadTimeout);
          }));
       }

       @LegacySignature(type = Type.SETTER, name = "DefaultReadTimeout", parameters =
       {
          @LegacyParameter(name = "var", type = "INTEGER", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void setDefaultReadTimeout(final integer _var)
       {
          integer var = TypeFactory.initInput(_var);

          internalProcedure(ClientSocket.class, this, "DefaultReadTimeout", new Block((Body) () ->
          {
             defaultReadTimeout.assign(var);
          }));
       }

       @LegacySignature(returns = "LOGICAL", type = Type.GETTER, name = "KeepAlive")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public logical getKeepAlive()
       {
          return function(ClientSocket.class, this, "KeepAlive", logical.class, new Block((Body) () ->
          {
             returnNormal(keepAlive);
          }));
       }

       @LegacySignature(type = Type.SETTER, name = "KeepAlive", parameters =
       {
          @LegacyParameter(name = "var", type = "LOGICAL", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void setKeepAlive(final logical _var)
       {
          logical var = TypeFactory.initInput(_var);

          internalProcedure(ClientSocket.class, this, "KeepAlive", new Block((Body) () ->
          {
             keepAlive.assign(var);
          }));
       }

       @LegacySignature(returns = "INTEGER", type = Type.GETTER, name = "LingerTime")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public integer getLingerTime()
       {
          return function(ClientSocket.class, this, "LingerTime", integer.class, new Block((Body) () ->
          {
             returnNormal(lingerTime);
          }));
       }

       @LegacySignature(type = Type.SETTER, name = "LingerTime", parameters =
       {
          @LegacyParameter(name = "var", type = "INTEGER", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void setLingerTime(final integer _var)
       {
          integer var = TypeFactory.initInput(_var);

          internalProcedure(ClientSocket.class, this, "LingerTime", new Block((Body) () ->
          {
             lingerTime.assign(var);
          }));
       }

       @LegacySignature(returns = "OBJECT", qualified = "OpenEdge.Logging.ILogWriter", type = Type.GETTER, name = "Logger")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public object<? extends IlogWriter> getLogger()
       {
          return function(ClientSocket.class, this, "Logger", object.class, new Block((Body) () ->
          {
             returnNormal(logger);
          }));
       }

       @LegacySignature(type = Type.SETTER, name = "Logger", parameters =
       {
          @LegacyParameter(qualified = "OpenEdge.Logging.ILogWriter", name = "var", type = "OBJECT", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void setLogger(final object<? extends IlogWriter> _var)
       {
          object<? extends IlogWriter> var = TypeFactory.initInput(_var);

          internalProcedure(ClientSocket.class, this, "Logger", new Block((Body) () ->
          {
             logger.assign(var);
          }));
       }

       @LegacySignature(returns = "LOGICAL", type = Type.GETTER, name = "NoDelay")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public logical getNoDelay()
       {
          return function(ClientSocket.class, this, "NoDelay", logical.class, new Block((Body) () ->
          {
             returnNormal(noDelay);
          }));
       }

       @LegacySignature(type = Type.SETTER, name = "NoDelay", parameters =
       {
          @LegacyParameter(name = "var", type = "LOGICAL", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void setNoDelay(final logical _var)
       {
          logical var = TypeFactory.initInput(_var);

          internalProcedure(ClientSocket.class, this, "NoDelay", new Block((Body) () ->
          {
             noDelay.assign(var);
          }));
       }

       @LegacySignature(returns = "INTEGER", type = Type.GETTER, name = "ReadBufferSize")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public integer getReadBufferSize()
       {
          return function(ClientSocket.class, this, "ReadBufferSize", integer.class, new Block((Body) () ->
          {
             returnNormal(readBufferSize);
          }));
       }

       @LegacySignature(type = Type.SETTER, name = "ReadBufferSize", parameters =
       {
          @LegacyParameter(name = "var", type = "INTEGER", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void setReadBufferSize(final integer _var)
       {
          integer var = TypeFactory.initInput(_var);

          internalProcedure(ClientSocket.class, this, "ReadBufferSize", new Block((Body) () ->
          {
             readBufferSize.assign(var);
          }));
       }

       @LegacySignature(returns = "INTEGER", type = Type.GETTER, name = "ReceiveBufferSize")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public integer getReceiveBufferSize()
       {
          return function(ClientSocket.class, this, "ReceiveBufferSize", integer.class, new Block((Body) () ->
          {
             returnNormal(receiveBufferSize);
          }));
       }

       @LegacySignature(type = Type.SETTER, name = "ReceiveBufferSize", parameters =
       {
          @LegacyParameter(name = "var", type = "INTEGER", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void setReceiveBufferSize(final integer _var)
       {
          integer var = TypeFactory.initInput(_var);

          internalProcedure(ClientSocket.class, this, "ReceiveBufferSize", new Block((Body) () ->
          {
             receiveBufferSize.assign(var);
          }));
       }

       @LegacySignature(returns = "INTEGER", type = Type.GETTER, name = "ReceiveTimeout")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public integer getReceiveTimeout()
       {
          return function(ClientSocket.class, this, "ReceiveTimeout", integer.class, new Block((Body) () ->
          {
             returnNormal(receiveTimeout);
          }));
       }

       @LegacySignature(type = Type.SETTER, name = "ReceiveTimeout", parameters =
       {
          @LegacyParameter(name = "var", type = "INTEGER", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void setReceiveTimeout(final integer _var)
       {
          integer var = TypeFactory.initInput(_var);

          internalProcedure(ClientSocket.class, this, "ReceiveTimeout", new Block((Body) () ->
          {
             receiveTimeout.assign(var);
          }));
       }

       @LegacySignature(returns = "LOGICAL", type = Type.GETTER, name = "ReuseAddress")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public logical getReuseAddress()
       {
          return function(ClientSocket.class, this, "ReuseAddress", logical.class, new Block((Body) () ->
          {
             returnNormal(reuseAddress);
          }));
       }

       @LegacySignature(type = Type.SETTER, name = "ReuseAddress", parameters =
       {
          @LegacyParameter(name = "var", type = "LOGICAL", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void setReuseAddress(final logical _var)
       {
          logical var = TypeFactory.initInput(_var);

          internalProcedure(ClientSocket.class, this, "ReuseAddress", new Block((Body) () ->
          {
             reuseAddress.assign(var);
          }));
       }

       @LegacySignature(returns = "INTEGER", type = Type.GETTER, name = "SendBufferSize")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public integer getSendBufferSize()
       {
          return function(ClientSocket.class, this, "SendBufferSize", integer.class, new Block((Body) () ->
          {
             returnNormal(sendBufferSize);
          }));
       }

       @LegacySignature(type = Type.SETTER, name = "SendBufferSize", parameters =
       {
          @LegacyParameter(name = "var", type = "INTEGER", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void setSendBufferSize(final integer _var)
       {
          integer var = TypeFactory.initInput(_var);

          internalProcedure(ClientSocket.class, this, "SendBufferSize", new Block((Body) () ->
          {
             sendBufferSize.assign(var);
          }));
       }

       @LegacySignature(returns = "OBJECT", qualified = "Progress.Lang.Object", type = Type.GETTER, name = "server")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public object<? extends _BaseObject_> getServer()
       {
          return function(ClientSocket.class, this, "server", object.class, new Block((Body) () ->
          {
             returnNormal(server);
          }));
       }

       @LegacySignature(type = Type.SETTER, name = "server", parameters =
       {
          @LegacyParameter(qualified = "Progress.Lang.Object", name = "var", type = "OBJECT", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void setServer(final object<? extends _BaseObject_> _var)
       {
          object<? extends _BaseObject_> var = TypeFactory.initInput(_var);

          internalProcedure(ClientSocket.class, this, "server", new Block((Body) () ->
          {
             server.assign(var);
          }));
       }

       @LegacySignature(returns = "CHARACTER", type = Type.GETTER, name = "SslServerName")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public character getSslServerName()
       {
          return function(ClientSocket.class, this, "SslServerName", character.class, new Block((Body) () ->
          {
             returnNormal(sslServerName);
          }));
       }

       @LegacySignature(type = Type.CONSTRUCTOR)
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL | RT_LVL_FULL)
       public void __net_serverconnection_ClientSocket_constructor__()
       {
          internalProcedure(ClientSocket.class, this, "__net_serverconnection_ClientSocket_constructor__", new Block((Body) () ->
          {
             __lang_BaseObject_constructor__();
             readBufferSize.assign(8192);
          }));
       }

       @LegacySignature(type = Type.CONSTRUCTOR, parameters =
       {
          @LegacyParameter(name = "p1", type = "OBJECT", qualified = "openedge.net.serverconnection.clientsocketconnectionparameters", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void __net_serverconnection_ClientSocket_constructor__(final object<? extends ClientSocketConnectionParameters> _p1)
       {
          object<? extends ClientSocketConnectionParameters> p1 = TypeFactory.initInput(_p1);

          internalProcedure(ClientSocket.class, this, "__net_serverconnection_ClientSocket_constructor__", new Block((Body) () ->
          {
             __lang_BaseObject_constructor__();
             connectionParameters.assign(p1);
          }));
       }

       @LegacySignature(type = Type.METHOD, name = "Connect")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void connect()
       {
          internalProcedure(ClientSocket.class, this, "Connect", new Block((Body) () ->
          {
             // on implementation mark the appserver-agent session with
             // SessionUtils.setClientType(ClientType._.NETCLIENT");
             UnimplementedFeature.missing("ClientSocket:Connect3 METHOD");
          }));
       }

       @LegacySignature(type = Type.METHOD, name = "Connect", parameters =
       {
          @LegacyParameter(name = "p1", type = "OBJECT", qualified = "openedge.net.serverconnection.clientsocketconnectionparameters", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void connect(final object<? extends ClientSocketConnectionParameters> _p1)
       {
          object<? extends ClientSocketConnectionParameters> p1 = TypeFactory.initInput(_p1);

          internalProcedure(ClientSocket.class, this, "Connect", new Block((Body) () ->
          {
             // on implementation mark the appserver-agent session with
             // SessionUtils.setClientType(ClientType._.NETCLIENT");
             UnimplementedFeature.missing("ClientSocket:Connect2 METHOD");
          }));
       }

       @LegacySignature(type = Type.METHOD, name = "Connect", parameters =
       {
          @LegacyParameter(name = "p1", type = "OBJECT", qualified = "openedge.net.uri", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void connect_1(final object<? extends Uri> _p1)
       {
          object<? extends Uri> p1 = TypeFactory.initInput(_p1);

          internalProcedure(ClientSocket.class, this, "Connect", new Block((Body) () ->
          {
             // on implementation mark the appserver-agent session with
             // SessionUtils.setClientType(ClientType._.NETCLIENT");
             UnimplementedFeature.missing("ClientSocket:Connect METHOD");
          }));
       }

       @LegacySignature(type = Type.METHOD, name = "CreateServer")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void createServer()
       {
          internalProcedure(ClientSocket.class, this, "CreateServer", new Block((Body) () ->
          {
             UnimplementedFeature.missing("ClientSocket:CreateServer METHOD");
          }));
       }

       @LegacySignature(type = Type.METHOD, name = "DestroyServer")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void destroyServer()
       {
          internalProcedure(ClientSocket.class, this, "DestroyServer", new Block((Body) () ->
          {
             UnimplementedFeature.missing("ClientSocket:DestroyServer METHOD");
          }));
       }

       @LegacySignature(type = Type.METHOD, name = "Disconnect")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void disconnect()
       {
          internalProcedure(ClientSocket.class, this, "Disconnect", new Block((Body) () ->
          {
             UnimplementedFeature.missing("ClientSocket:Disconnect METHOD");
          }));
       }

       @LegacySignature(returns = "LOGICAL", type = Type.METHOD, name = "IsConnected")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       protected logical isConnected()
       {
          return function(ClientSocket.class, this, "IsConnected", logical.class, new Block((Body) () ->
          {
             UnimplementedFeature.missing("ClientSocket:IsConnected METHOD");
          }));
       }

       @LegacySignature(type = Type.METHOD, name = "OnDataReceived", parameters =
       {
          @LegacyParameter(name = "p1", type = "OBJECT", qualified = "openedge.net.serverconnection.socketreadeventargs", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       protected void onDataReceived(final object<? extends SocketReadEventArgs> _p1)
       {
          object<? extends SocketReadEventArgs> p1 = TypeFactory.initInput(_p1);

          internalProcedure(ClientSocket.class, this, "OnDataReceived", new Block((Body) () ->
          {
             UnimplementedFeature.missing("ClientSocket:OnDataReceived METHOD");
          }));
       }

       @LegacySignature(type = Type.METHOD, name = "OnReadTerminated", parameters =
       {
          @LegacyParameter(name = "p1", type = "OBJECT", qualified = "openedge.net.serverconnection.socketreadeventargs", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       protected void onReadTerminated(final object<? extends SocketReadEventArgs> _p1)
       {
          object<? extends SocketReadEventArgs> p1 = TypeFactory.initInput(_p1);

          internalProcedure(ClientSocket.class, this, "OnReadTerminated", new Block((Body) () ->
          {
             UnimplementedFeature.missing("ClientSocket:OnReadTerminated METHOD");
          }));
       }

       @LegacySignature(type = Type.METHOD, name = "OnReadTimeout", parameters =
       {
          @LegacyParameter(name = "p1", type = "OBJECT", qualified = "openedge.net.serverconnection.socketreadeventargs", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       protected void onReadTimeout(final object<? extends SocketReadEventArgs> _p1)
       {
          object<? extends SocketReadEventArgs> p1 = TypeFactory.initInput(_p1);

          internalProcedure(ClientSocket.class, this, "OnReadTimeout", new Block((Body) () ->
          {
             UnimplementedFeature.missing("ClientSocket:OnReadTimeout METHOD");
          }));
       }

       @LegacySignature(type = Type.METHOD, name = "ReadResponseHandler")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void readResponseHandler()
       {
          internalProcedure(ClientSocket.class, this, "ReadResponseHandler", new Block((Body) () ->
          {
             UnimplementedFeature.missing("ClientSocket:ReadResponseHandler METHOD");
          }));
       }

       @LegacySignature(type = Type.METHOD, name = "SetSocketOptions", parameters =
       {
          @LegacyParameter(name = "p1", type = "HANDLE", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void setSocketOptions(final handle _p1)
       {
          handle p1 = TypeFactory.initInput(_p1);

          internalProcedure(ClientSocket.class, this, "SetSocketOptions", new Block((Body) () ->
          {
             UnimplementedFeature.missing("ClientSocket:SetSocketOptions METHOD");
          }));
       }

       @LegacySignature(type = Type.METHOD, name = "WaitForResponse")
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void waitForResponse()
       {
          internalProcedure(ClientSocket.class, this, "WaitForResponse", new Block((Body) () ->
          {
             UnimplementedFeature.missing("ClientSocket:WaitForResponse METHOD");
          }));
       }

       @LegacySignature(type = Type.METHOD, name = "StartTls", parameters =
       {
          @LegacyParameter(name = "pCertificatSubjectName", type = "CHARACTER", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void startTls(final character _pCertificatSubjectName)
       {
          character pCertificatSubjectName = TypeFactory.initInput(_pCertificatSubjectName);

          internalProcedure(ClientSocket.class, this, "StartTls", new Block((Body) () ->
          {
             UnimplementedFeature.missing("ClientSocket:StartTls METHOD");
          }));
       }

       @LegacySignature(type = Type.METHOD, name = "WaitForResponse", parameters =
       {
          @LegacyParameter(name = "p1", type = "DECIMAL", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void waitForResponse(final decimal _p1)
       {
          decimal p1 = TypeFactory.initInput(_p1);

          internalProcedure(ClientSocket.class, this, "WaitForResponse", new Block((Body) () ->
          {
             UnimplementedFeature.missing("ClientSocket:WaitForResponse METHOD");
          }));
       }

       @LegacySignature(type = Type.METHOD, name = "WaitForResponseAsync", parameters =
       {
          @LegacyParameter(name = "p1", type = "DECIMAL", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void waitForResponseAsync(final decimal _p1)
       {
          decimal p1 = TypeFactory.initInput(_p1);

          internalProcedure(ClientSocket.class, this, "WaitForResponseAsync", new Block((Body) () ->
          {
             UnimplementedFeature.missing("ClientSocket:WaitForResponseAsync METHOD");
          }));
       }

       @LegacySignature(type = Type.METHOD, name = "WriteData", parameters =
       {
          @LegacyParameter(qualified = "OpenEdge.Core.Memptr", name = "p1", type = "OBJECT", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void writeData(final object<? extends com.goldencode.p2j.oo.core.Memptr> _p1)
       {
          object<? extends com.goldencode.p2j.oo.core.Memptr> p1 = TypeFactory.initInput(_p1);

          internalProcedure(ClientSocket.class, this, "WriteData", new Block((Body) () ->
          {
             UnimplementedFeature.missing("ClientSocket:WriteData METHOD");
          }));
       }

       @LegacySignature(type = Type.PUBLISH, name = "DataReceived", parameters =
       {
          @LegacyParameter(name = "p1", type = "OBJECT", qualified = "openedge.net.serverconnection.clientsocket", mode = "INPUT"),
          @LegacyParameter(name = "p2", type = "OBJECT", qualified = "openedge.net.serverconnection.socketreadeventargs", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private void publish_dataReceived(object p1, object p2)
       {
          dataReceived.publish(p1, p2);
       }

       @LegacySignature(type = Type.SUBSCRIBE, name = "DataReceived", parameters =
       {
          @LegacyParameter(name = "p1", type = "handle", mode = "INPUT"),
          @LegacyParameter(name = "p2", type = "character", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void subscribe_dataReceived(handle h, character procName)
       {
          dataReceived.subscribe(h, procName);
       }

       @LegacySignature(type = Type.SUBSCRIBE, name = "DataReceived", parameters =
       {
          @LegacyParameter(name = "p1", type = "object", mode = "INPUT", qualified = "progress.lang.object"),
          @LegacyParameter(name = "p2", type = "character", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void subscribe_dataReceived(object<? extends com.goldencode.p2j.oo.lang._BaseObject_> ref, character methName)
       {
          dataReceived.subscribe(ref, methName);
       }

       @LegacySignature(type = Type.UNSUBSCRIBE, name = "DataReceived", parameters =
       {
          @LegacyParameter(name = "p1", type = "handle", mode = "INPUT"),
          @LegacyParameter(name = "p2", type = "character", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void unsubscribe_dataReceived(handle h, character procName)
       {
          dataReceived.unsubscribe(h, procName);
       }

       @LegacySignature(type = Type.UNSUBSCRIBE, name = "DataReceived", parameters =
       {
          @LegacyParameter(name = "p1", type = "object", mode = "INPUT", qualified = "progress.lang.object"),
          @LegacyParameter(name = "p2", type = "character", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void unsubscribe_dataReceived(object<? extends com.goldencode.p2j.oo.lang._BaseObject_> ref, character methName)
       {
          dataReceived.unsubscribe(ref, methName);
       }

       @LegacySignature(type = Type.PUBLISH, name = "ReadTerminated", parameters =
       {
          @LegacyParameter(name = "p1", type = "OBJECT", qualified = "openedge.net.serverconnection.clientsocket", mode = "INPUT"),
          @LegacyParameter(name = "p2", type = "OBJECT", qualified = "openedge.net.serverconnection.socketreadeventargs", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private void publish_readTerminated(object p1_1, object p2_1)
       {
          readTerminated.publish(p1_1, p2_1);
       }

       @LegacySignature(type = Type.SUBSCRIBE, name = "ReadTerminated", parameters =
       {
          @LegacyParameter(name = "p1", type = "handle", mode = "INPUT"),
          @LegacyParameter(name = "p2", type = "character", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void subscribe_readTerminated(handle h, character procName)
       {
          readTerminated.subscribe(h, procName);
       }

       @LegacySignature(type = Type.SUBSCRIBE, name = "ReadTerminated", parameters =
       {
          @LegacyParameter(name = "p1", type = "object", mode = "INPUT", qualified = "progress.lang.object"),
          @LegacyParameter(name = "p2", type = "character", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void subscribe_readTerminated(object<? extends com.goldencode.p2j.oo.lang._BaseObject_> ref, character methName)
       {
          readTerminated.subscribe(ref, methName);
       }

       @LegacySignature(type = Type.UNSUBSCRIBE, name = "ReadTerminated", parameters =
       {
          @LegacyParameter(name = "p1", type = "handle", mode = "INPUT"),
          @LegacyParameter(name = "p2", type = "character", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void unsubscribe_readTerminated(handle h, character procName)
       {
          readTerminated.unsubscribe(h, procName);
       }

       @LegacySignature(type = Type.UNSUBSCRIBE, name = "ReadTerminated", parameters =
       {
          @LegacyParameter(name = "p1", type = "object", mode = "INPUT", qualified = "progress.lang.object"),
          @LegacyParameter(name = "p2", type = "character", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void unsubscribe_readTerminated(object<? extends com.goldencode.p2j.oo.lang._BaseObject_> ref, character methName)
       {
          readTerminated.unsubscribe(ref, methName);
       }

       @LegacySignature(type = Type.PUBLISH, name = "ReadTimeout", parameters =
       {
          @LegacyParameter(name = "p1", type = "OBJECT", qualified = "openedge.net.serverconnection.clientsocket", mode = "INPUT"),
          @LegacyParameter(name = "p2", type = "OBJECT", qualified = "openedge.net.serverconnection.socketreadeventargs", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       private void publish_readTimeout(object p1_2, object p2_2)
       {
          readTimeout.publish(p1_2, p2_2);
       }

       @LegacySignature(type = Type.SUBSCRIBE, name = "ReadTimeout", parameters =
       {
          @LegacyParameter(name = "p1", type = "handle", mode = "INPUT"),
          @LegacyParameter(name = "p2", type = "character", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void subscribe_readTimeout(handle h, character procName)
       {
          readTimeout.subscribe(h, procName);
       }

       @LegacySignature(type = Type.SUBSCRIBE, name = "ReadTimeout", parameters =
       {
          @LegacyParameter(name = "p1", type = "object", mode = "INPUT", qualified = "progress.lang.object"),
          @LegacyParameter(name = "p2", type = "character", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void subscribe_readTimeout(object<? extends com.goldencode.p2j.oo.lang._BaseObject_> ref, character methName)
       {
          readTimeout.subscribe(ref, methName);
       }

       @LegacySignature(type = Type.UNSUBSCRIBE, name = "ReadTimeout", parameters =
       {
          @LegacyParameter(name = "p1", type = "handle", mode = "INPUT"),
          @LegacyParameter(name = "p2", type = "character", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void unsubscribe_readTimeout(handle h, character procName)
       {
          readTimeout.unsubscribe(h, procName);
       }

       @LegacySignature(type = Type.UNSUBSCRIBE, name = "ReadTimeout", parameters =
       {
          @LegacyParameter(name = "p1", type = "object", mode = "INPUT", qualified = "progress.lang.object"),
          @LegacyParameter(name = "p2", type = "character", mode = "INPUT")
       })
       @LegacyResourceSupport(supportLvl = CVT_LVL_FULL|RT_LVL_STUB)
       public void unsubscribe_readTimeout(object<? extends com.goldencode.p2j.oo.lang._BaseObject_> ref, character methName)
       {
          readTimeout.unsubscribe(ref, methName);
       }
    }