Tools/ManagedExtensions/ManagementExtensions/Remote/Providers/HttpChannelProvider.cs

   1 // Copyright 2003-2004 DigitalCraftsmen - http://www.digitalcraftsmen.com.br/
   2 //
   3 // Licensed under the Apache License, Version 2.0 (the "License");
   4 // you may not use this file except in compliance with the License.
   5 // You may obtain a copy of the License at
   6 //
   7 //     http://www.apache.org/licenses/LICENSE-2.0
   8 //
   9 // Unless required by applicable law or agreed to in writing, software
  10 // distributed under the License is distributed on an "AS IS" BASIS,
  11 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12 // See the License for the specific language governing permissions and
  13 // limitations under the License.
  14
  15 namespace Castle.ManagementExtensions.Remote.Providers
  16 {
  17         using System;
  18         using System.Collections.Specialized;
  19
  20         using System.Runtime.Remoting;
  21         using System.Runtime.Remoting.Channels;
  22         using System.Runtime.Remoting.Channels.Http;
  23
  24         using Castle.ManagementExtensions.Remote.Server;
  25         using Castle.ManagementExtensions.Remote.Client;
  26
  27         /// <summary>
  28         /// Summary description for HttpChannelProvider.
  29         /// </summary>
  30         public class HttpChannelProvider : AbstractServerProvider
  31         {
  32                 public HttpChannelProvider()
  33                 {
  34                 }
  35
  36                 protected override bool AcceptsChannel(String channel)
  37                 {
  38                         return "http".EndsWith(channel);
  39                 }
  40
  41                 protected override bool AcceptsFormatter(String formatter)
  42                 {
  43                         return "binary".EndsWith(formatter) || "soap".EndsWith(formatter);
  44                 }
  45
  46                 #region MProvider Members
  47
  48                 public override MConnector Connect(String url, System.Collections.Specialized.NameValueCollection properties)
  49                 {
  50                         String[] parts = StripUrl(url);
  51
  52                         String formatter = parts[2];
  53                         String objectUri = parts[3];
  54                         String objectUrl = null;
  55
  56                         HttpClientChannel channel = new HttpClientChannel();
  57
  58                         try
  59                         {
  60                                 ChannelServices.RegisterChannel( channel );
  61                         }
  62                         catch(RemotingException)
  63                         {
  64                                 // Already registered
  65                         }
  66
  67                         objectUrl = String.Format("{0}://{1}:{2}/{3}",
  68                                 "http", GetHost(properties), GetPort(properties), objectUri);
  69
  70                         object ret = RemotingServices.Connect( typeof(MServer), objectUrl, null );
  71
  72                         return new MConnector( (MServer) ret, channel );
  73                 }
  74
  75                 #endregion
  76
  77                 #region MServerProvider Members
  78
  79                 public override MConnectorServer CreateServer(String url, NameValueCollection properties, MServer server)
  80                 {
  81                         String[] parts = StripUrl(url);
  82                         String formatter = parts[2];
  83                         String objectUri = parts[3];
  84
  85                         HttpChannel channel = CreateChannel(formatter, properties, true);
  86
  87                         MConnectorServer connServer = null;
  88
  89                         if (server != null)
  90                         {
  91                                 connServer = new MConnectorServer(server, objectUri);
  92                         }
  93                         else
  94                         {
  95                                 connServer = new MConnectorServer(objectUri);
  96                         }
  97
  98                         //connServer.Channel = channel;
  99
 100                         return connServer;
 101                 }
 102
 103                 #endregion
 104
 105                 private HttpChannel CreateChannel(String formatter, NameValueCollection properties, bool createAsServer)
 106                 {
 107                         HttpChannel httpChannel = null;
 108
 109                         int portNum = GetPort(properties);
 110
 111                         bool alreadyRegistered = false;
 112
 113                         foreach(IChannel channel in ChannelServices.RegisteredChannels)
 114                         {
 115                                 if (channel.ChannelName.Equals("http"))
 116                                 {
 117                                         HttpChannel item = (HttpChannel) channel;
 118                                         ChannelDataStore dataStore = (ChannelDataStore) item.ChannelData;
 119                                         // TODO: Check if is the same channel as the url specify
 120
 121                                         httpChannel = item;
 122
 123                                         alreadyRegistered = true;
 124                                         break;
 125                                 }
 126                         }
 127
 128                         if (!alreadyRegistered)
 129                         {
 130                                 if (createAsServer)
 131                                 {
 132                                         httpChannel = new HttpChannel(portNum);
 133                                 }
 134                                 else
 135                                 {
 136                                         httpChannel = new HttpChannel();
 137                                 }
 138
 139                                 ChannelServices.RegisterChannel( httpChannel );
 140                         }
 141
 142                         return httpChannel;
 143                 }
 144         }
 145 }