TAO/orbsvcs/DevGuideExamples/Security/ParticipatingApp/MessengerClient.cpp

   1 /* -*- C++ -*-  */
   2
   3 #include "orbsvcs/SecurityC.h"
   4 #include "MessengerC.h"
   5 #include "ace/Get_Opt.h"
   6
   7 #if 0
   8 The servers service configuration file
   9 for this example is:
  10 ---------------------------------------
  11 # server.conf
  12 dynamic SSLIOP_Factory Service_Object *
  13   TAO_SSLIOP:_make_TAO_SSLIOP_Protocol_Factory()
  14   "-SSLNoProtection \
  15    -SSLAuthenticate SERVER_AND_CLIENT \
  16    -SSLPrivateKey PEM:server_key.pem \
  17    -SSLCertificate PEM:server_cert.pem"
  18
  19 static Resource_Factory "-ORBProtocolFactory SSLIOP_Factory"
  20 ---------------------------------------
  21
  22 The clients service configuration file
  23 for this example is:
  24 ---------------------------------------
  25 # client.conf
  26 dynamic SSLIOP_Factory Service_Object *
  27   TAO_SSLIOP:_make_TAO_SSLIOP_Protocol_Factory()
  28   "-SSLNoProtection  \
  29    -SSLAuthenticate SERVER \
  30    -SSLPrivateKey PEM:client_key.pem  \
  31    -SSLCertificate PEM:client_cert.pem"
  32
  33 static Resource_Factory "-ORBProtocolFactory SSLIOP_Factory"
  34 ---------------------------------------
  35 #endif
  36
  37 const ACE_TCHAR *ior = ACE_TEXT ("file://Messenger.ior");
  38
  39 int
  40 parse_args (int argc, ACE_TCHAR *argv[])
  41 {
  42   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("k:"));
  43   int c;
  44
  45   while ((c = get_opts ()) != -1)
  46     switch (c)
  47       {
  48       case 'k':
  49         ior = get_opts.opt_arg ();
  50         break;
  51
  52       case '?':
  53       default:
  54         ACE_ERROR_RETURN ((LM_ERROR,
  55                            "usage:  %s "
  56                            "-k <ior> "
  57                            "\n",
  58                            argv [0]),
  59                           -1);
  60       }
  61   // Indicates successful parsing of the command line
  62   return 0;
  63 }
  64
  65 int
  66 ACE_TMAIN (int argc, ACE_TCHAR *argv[])
  67 {
  68   try {
  69
  70     CORBA::ORB_var orb =
  71       CORBA::ORB_init( argc, argv );
  72
  73       if (parse_args (argc, argv) != 0)
  74         return 1;
  75
  76     CORBA::Object_var obj =
  77       orb->string_to_object( ior );
  78
  79     Messenger_var messenger =
  80       Messenger::_narrow( obj.in() );
  81
  82     CORBA::String_var message =
  83       CORBA::string_dup( "Terminating messenger service!" );
  84
  85     messenger->send_message( "Chief of Security",
  86                              "New Directive",
  87                              message.inout() );
  88
  89     messenger->shutdown("Chief of Security");
  90
  91     Security::QOP qop =
  92       Security::SecQOPIntegrityAndConfidentiality;
  93
  94     CORBA::Any want_protection;
  95     want_protection <<= qop;
  96
  97     CORBA::Policy_var policy =
  98       orb->create_policy (Security::SecQOPPolicy,
  99                           want_protection);
 100
 101     Security::EstablishTrust establish_trust;
 102     establish_trust.trust_in_client = 0;
 103     establish_trust.trust_in_target = 1;
 104
 105     CORBA::Any want_trust;
 106     want_trust <<= establish_trust;
 107
 108     CORBA::Policy_var policy2 =
 109       orb->create_policy (Security::SecEstablishTrustPolicy,
 110                           want_trust);
 111
 112
 113     CORBA::PolicyList policy_list (2);
 114     policy_list.length (1);
 115     policy_list[0] =
 116       CORBA::Policy::_duplicate (policy.in ());
 117     policy_list.length (2);
 118     policy_list[1] =
 119       CORBA::Policy::_duplicate (policy2.in ());
 120
 121
 122     CORBA::Object_var object =
 123       obj->_set_policy_overrides (policy_list,
 124                                   CORBA::SET_OVERRIDE);
 125
 126     Messenger_var messenger2 =
 127       Messenger::_narrow( object.in() );
 128
 129     message =
 130       CORBA::string_dup( "Terminating messenger service!" );
 131
 132     messenger2->send_message( "Chief of Security",
 133                              "New Directive",
 134                              message.inout() );
 135
 136     messenger2->shutdown("Chief of Security");
 137
 138     orb->destroy();
 139   }
 140   catch(const CORBA::Exception& ex)
 141   {
 142     ex._tao_print_exception("Client: main block");
 143     return 1;
 144   }
 145
 146   return 0;
 147 }