# -*-c-*-
#
# $Id: 31MQCONNX-v5,v 33.1 2009/07/02 21:10:03 biersma Exp $
#
# (c) 1999-2009 Morgan Stanley & Co. Incorporated
# See ..../src/LICENSE for terms of distribution.
#

#ifdef MQCNO_NONE

MQHCONN
MQCONNX(Name,ConnectOpts,CompCode,Reason)
        MQCHAR48 Name
        MQCNO    ConnectOpts
        MQLONG   CompCode = NO_INIT
        MQLONG   Reason = NO_INIT

    PREINIT:
#ifdef MQCNO_VERSION_2
        MQCD ClientConnOpts  = { MQCD_CLIENT_CONN_DEFAULT };
#endif
#ifdef MQCNO_VERSION_4
        MQSCO SSLConfigOpts  = { MQSCO_DEFAULT };
#endif
#ifdef MQCNO_VERSION_5
        MQCSP SecurityParms = { MQCSP_DEFAULT };
#endif
    CODE:
#ifdef MQCNO_VERSION_2
        /*
           If the ClientConn hash entry is present in the ConnectOpts,
           we need to build an MQCD data structure manually
           and refer to it from the MQCON data structure.
        */
        if (hv_exists((HV*)SvRV(ST(1)),"ClientConn",10)) {
            SV     **cvp, **elem;
            HV      *options;
            int      FieldSize;
            STRLEN   StringLength;
            char    *String;

          /* warn("Using ClientConn options to set MQCD"); */
          ConnectOpts.ClientConnOffset = 0;
          ConnectOpts.ClientConnPtr = &ClientConnOpts;
          if (ConnectOpts.Version < MQCNO_VERSION_2)
              ConnectOpts.Version = MQCNO_VERSION_2; /* But see below */
          cvp = hv_fetch((HV*)SvRV(ST(1)),"ClientConn",10, FALSE);
          if ( !SvROK(*cvp) || ( SvROK(*cvp) &&
                                 SvTYPE(SvRV(*cvp)) != SVt_PVHV ) ) {
              warn("Invalid data for ClientConn, not a HASH reference\n");
              XSRETURN_EMPTY;
          }
          options = (HV*)SvRV(*cvp);

          /* ChannelName */
          elem = hv_fetch(options, "ChannelName", 11, FALSE);
          if (elem) {
              FieldSize = sizeof(ClientConnOpts.ChannelName);
              String = SvPV(*elem, StringLength);
              strncpy(ClientConnOpts.ChannelName,
                      String,
                      StringLength > FieldSize ? FieldSize : StringLength);
          }

          /* Version */
          elem = hv_fetch(options, "Version", 7, FALSE);
          if (elem) {
              ClientConnOpts.Version = SvIV(*elem);
          }

          /* TransportType */
          /* We support the string "TCP", or any numerical constant */
          elem = hv_fetch(options, "TransportType", 13, FALSE);
          if (elem) {
              String = SvPV(*elem, StringLength);
              if (StringLength && ! strcmp(String, "TCP")) {
                  ClientConnOpts.TransportType = MQXPT_TCP;
              } else {            /* Fall back on numerical code */
                  ClientConnOpts.TransportType = SvIV(*elem);
              }
          }

          /* ModeName */
          elem = hv_fetch(options, "ModeName", 8, FALSE);
          if (elem) {
              FieldSize = sizeof(ClientConnOpts.ModeName);
              String = SvPV(*elem, StringLength);
              strncpy(ClientConnOpts.ModeName,
                      String,
                      StringLength > FieldSize ? FieldSize : StringLength);
          }

          /* TpName */
          elem = hv_fetch(options, "TpName", 6, FALSE);
          if (elem) {
              FieldSize = sizeof(ClientConnOpts.TpName);
              String = SvPV(*elem, StringLength);
              strncpy(ClientConnOpts.TpName,
                      String,
                      StringLength > FieldSize ? FieldSize : StringLength);
          }

          /* SecurityExit */
          elem = hv_fetch(options, "SecurityExit", 12, FALSE);
          if (elem) {
              FieldSize = sizeof(ClientConnOpts.SecurityExit);
              String = SvPV(*elem, StringLength);
              strncpy(ClientConnOpts.SecurityExit,
                      String,
                      StringLength > FieldSize ? FieldSize : StringLength);
          }

          /* SendExit */
          elem = hv_fetch(options, "SendExit", 8, FALSE);
          if (elem) {
              FieldSize = sizeof(ClientConnOpts.SendExit);
              String = SvPV(*elem, StringLength);
              strncpy(ClientConnOpts.SendExit,
                      String,
                      StringLength > FieldSize ? FieldSize : StringLength);
          }

          /* ReceiveExit */
          elem = hv_fetch(options, "ReceiveExit", 11, FALSE);
          if (elem) {
              FieldSize = sizeof(ClientConnOpts.ReceiveExit);
              String = SvPV(*elem, StringLength);
              strncpy(ClientConnOpts.ReceiveExit,
                      String,
                      StringLength > FieldSize ? FieldSize : StringLength);
          }

          /* MaxMsgLength */
          elem = hv_fetch(options, "MaxMsgLength", 12, FALSE);
          if (elem) {
              ClientConnOpts.MaxMsgLength = SvIV(*elem);
          }

          /* SecurityUserData */
          elem = hv_fetch(options, "SecurityUserData", 16, FALSE);
          if (elem) {
              FieldSize = sizeof(ClientConnOpts.SecurityUserData);
              String = SvPV(*elem, StringLength);
              strncpy(ClientConnOpts.SecurityUserData,
                      String,
                      StringLength > FieldSize ? FieldSize : StringLength);
          }

          /* SendUserData */
          elem = hv_fetch(options, "SendUserData", 12, FALSE);
          if (elem) {
              FieldSize = sizeof(ClientConnOpts.SendUserData);
              String = SvPV(*elem, StringLength);
              strncpy(ClientConnOpts.SendUserData,
                      String,
                      StringLength > FieldSize ? FieldSize : StringLength);
          }

          /* ReceiveUserData */
          elem = hv_fetch(options, "ReceiveUserData", 15, FALSE);
          if (elem) {
              FieldSize = sizeof(ClientConnOpts.ReceiveUserData);
              String = SvPV(*elem, StringLength);
              strncpy(ClientConnOpts.ReceiveUserData,
                      String,
                      StringLength > FieldSize ? FieldSize : StringLength);
          }

          /* UserIdentifier */
          elem = hv_fetch(options, "UserIdentifier", 14, FALSE);
          if (elem) {
              FieldSize = sizeof(ClientConnOpts.UserIdentifier);
              String = SvPV(*elem, StringLength);
              strncpy(ClientConnOpts.UserIdentifier,
                      String,
                      StringLength > FieldSize ? FieldSize : StringLength);
          }

          /* Password */
          elem = hv_fetch(options, "Password", 8, FALSE);
          if (elem) {
              FieldSize = sizeof(ClientConnOpts.Password);
              String = SvPV(*elem, StringLength);
              strncpy(ClientConnOpts.Password,
                      String,
                      StringLength > FieldSize ? FieldSize : StringLength);
          }

          /* ConnectionName */
          elem = hv_fetch(options, "ConnectionName", 14, FALSE);
          if (elem) {
              FieldSize = sizeof(ClientConnOpts.ConnectionName);
              String = SvPV(*elem, StringLength);
              strncpy(ClientConnOpts.ConnectionName,
                      String,
                      StringLength > FieldSize ? FieldSize : StringLength);
          }

          /* HeartbeatInterval */
          elem = hv_fetch(options, "HeartbeatInterval", 17, FALSE);
          if (elem) {
              ClientConnOpts.HeartbeatInterval = SvIV(*elem);
          }
#endif /* MQCNO_VERSION_2 */
#ifdef MQCNO_VERSION_4 /* Includes MQCNO_VERSION_2 */
          /* Version 4 (WMQ 5.3) options: SSLCipherSpec and
           * KeepAliveInterval. (Contributed by Brian Bumpass)
           */
          /* SSLCipherSpec */
          elem = hv_fetch(options, "SSLCipherSpec", 13, FALSE);
          if (elem) {
              if (ConnectOpts.Version < MQCNO_VERSION_4)
                  ConnectOpts.Version = MQCNO_VERSION_4;
              FieldSize = sizeof(ClientConnOpts.SSLCipherSpec);
              String = SvPV(*elem, StringLength);
              strncpy(ClientConnOpts.SSLCipherSpec,
                      String,
                      StringLength > FieldSize ? FieldSize : StringLength);
          }

          /* KeepAliveInterval */
          elem = hv_fetch(options, "KeepAliveInterval", 17, FALSE);
          if (elem) {
              ConnectOpts.Version = MQCNO_VERSION_4;
              ClientConnOpts.KeepAliveInterval = SvIV(*elem);
          }
#endif /* MQCNO_VERSION_4 */
#ifdef MQCNO_VERSION_2
        } else {
            /* warn("ClientConn options not present"); */
        }
#endif /* MQCNO_VERSION_2 */
#ifdef MQCNO_VERSION_4
        /*
           SSLConfig represents the hash entry for ConnectOpts
           (Contributed by Brian Bumpass)
        */
        if (hv_exists((HV*)SvRV(ST(1)),"SSLConfig",9)) {
            SV     **cvp, **elem;
            HV      *options;
            int      FieldSize;
            STRLEN   StringLength;
            char    *String;

            /* warn("Using SSLConfig options to set MQSCO"); */
            ConnectOpts.SSLConfigOffset = 0;
            ConnectOpts.SSLConfigPtr = &SSLConfigOpts;
            if (ConnectOpts.Version < MQCNO_VERSION_4)
                ConnectOpts.Version = MQCNO_VERSION_4;
            cvp = hv_fetch((HV*)SvRV(ST(1)),"SSLConfig",9, FALSE);
            if ( !SvROK(*cvp) || ( SvROK(*cvp) &&
                                   SvTYPE(SvRV(*cvp)) != SVt_PVHV ) ) {
                warn("Invalid data for SSLConfig, not a HASH reference\n");
                XSRETURN_EMPTY;
            }
            options = (HV*)SvRV(*cvp);

            /* Version */
            elem = hv_fetch(options, "Version", 7, FALSE);
            if (elem) {
                SSLConfigOpts.Version = SvIV(*elem);
            }

            /* KeyRepository */
            elem = hv_fetch(options, "KeyRepository", 13, FALSE);
            if (elem) {
                FieldSize = sizeof(SSLConfigOpts.KeyRepository);
                String = SvPV(*elem, StringLength);
                strncpy(SSLConfigOpts.KeyRepository,
                        String,
                        StringLength > FieldSize ? FieldSize : StringLength);
            }
        } else {
            /* warn("SSLConfig options not present"); */
        }
#endif /* MQCNO_VERSION_4 */
#ifdef MQCNO_VERSION_5
        /*
         * SecurityParms represents the hash entry for ConnectOpts
         * (Contributed by Duke Nguyen)
        */
        if (hv_exists((HV*)SvRV(ST(1)), "SecurityParms", 13)) {
            SV     **cvp, **elem;
            HV      *options;
            STRLEN   UserLength;
            STRLEN   PassLength;
            char    *user;
            char    *pass;

            /* warn("Using SecurityParms options to set MQCSP"); */
            ConnectOpts.SecurityParmsOffset = 0;
            ConnectOpts.SecurityParmsPtr = &SecurityParms;
            if (ConnectOpts.Version < MQCNO_VERSION_5)
                ConnectOpts.Version = MQCNO_VERSION_5;
            cvp = hv_fetch((HV*)SvRV(ST(1)),"SecurityParms", 13, FALSE);
            if ( !SvROK(*cvp) || ( SvROK(*cvp) &&
                                   SvTYPE(SvRV(*cvp)) != SVt_PVHV ) ) {
                warn("Invalid data for SecurityParms, not a HASH reference\n");
                XSRETURN_EMPTY;
            }
            options = (HV*)SvRV(*cvp);

            /* Version */
            elem = hv_fetch(options, "Version", 7, FALSE);
            if (elem) {
                SecurityParms.Version = SvIV(*elem);
            }

            /* AuthenticationType */
            elem = hv_fetch(options, "AuthenticationType", 18, FALSE);
            if (elem) {
                SecurityParms.AuthenticationType = SvIV(*elem);
            }

            /* CSPUserId */
            elem = hv_fetch(options, "CSPUserId", 9, FALSE);
            if (elem) {
                user = SvPV(*elem, UserLength);
                SecurityParms.CSPUserIdPtr = user;
                SecurityParms.CSPUserIdOffset = 0;
                SecurityParms.CSPUserIdLength = strlen(user);
            }
            /* CSPPassword */
            elem = hv_fetch(options, "CSPPassword", 11, FALSE);
            if (elem) {
                pass = SvPV(*elem, PassLength);
                SecurityParms.CSPPasswordPtr = pass;
                SecurityParms.CSPPasswordOffset = 0;
                SecurityParms.CSPPasswordLength = strlen(pass);
            }
        } else {
            /* warn("SecurityParms options not present"); */
        }
#endif /* MQCNO_VERSION_5 */
        MQCONNX(Name,&ConnectOpts,&RETVAL,&CompCode,&Reason);
    OUTPUT:
        ConnectOpts
        RETVAL
        CompCode
        Reason

#endif /* MQCNO_NONE */