mcs/class/System.Web.Services/System.Web.Services.Protocols/SoapExtension.cs

   1 // \r
   2 // System.Web.Services.Protocols.SoapExtension.cs\r
   3 //\r
   4 // Author:\r
   5 //   Tim Coleman (tim@timcoleman.com)\r
   6 //\r
   7 // Copyright (C) Tim Coleman, 2002\r
   8 //\r
   9 \r
  10 using System.IO;\r
  11 using System.Collections;\r
  12 using System.Web.Services.Configuration;\r
  13 \r
  14 namespace System.Web.Services.Protocols {\r
  15         public abstract class SoapExtension {\r
  16 \r
  17                 #region Fields\r
  18 \r
  19                 Stream stream;\r
  20 \r
  21                 #endregion\r
  22 \r
  23                 #region Constructors\r
  24 \r
  25                 protected SoapExtension ()\r
  26                 {\r
  27                 }\r
  28 \r
  29                 #endregion // Constructors\r
  30 \r
  31                 #region Methods\r
  32 \r
  33                 public virtual Stream ChainStream (Stream stream)\r
  34                 {\r
  35                         return stream;\r
  36                 }\r
  37 \r
  38                 public abstract object GetInitializer (Type serviceType);\r
  39                 public abstract object GetInitializer (LogicalMethodInfo methodInfo, SoapExtensionAttribute attribute);\r
  40                 public abstract void Initialize (object initializer);\r
  41                 public abstract void ProcessMessage (SoapMessage message);\r
  42 \r
  43 \r
  44                 static ArrayList[] globalExtensions;\r
  45 \r
  46                 internal static SoapExtension[] CreateExtensionChain (SoapExtensionRuntimeConfig[] extensionConfigs)\r
  47                 {\r
  48                         if (extensionConfigs == null) return null;\r
  49                         SoapExtension[] res = new SoapExtension [extensionConfigs.Length];\r
  50                         CreateExtensionChain (extensionConfigs, res, 0);\r
  51                         return res;\r
  52                 }\r
  53 \r
  54                 internal static SoapExtension[] CreateExtensionChain (SoapExtensionRuntimeConfig[] hiPrioExts, SoapExtensionRuntimeConfig[] medPrioExts, SoapExtensionRuntimeConfig[] lowPrioExts)\r
  55                 {\r
  56                         int len = 0;\r
  57                         if (hiPrioExts != null) len += hiPrioExts.Length;\r
  58                         if (medPrioExts != null) len += medPrioExts.Length;\r
  59                         if (lowPrioExts != null) len += lowPrioExts.Length;\r
  60                         if (len == 0) return null;\r
  61 \r
  62                         SoapExtension[] res = new SoapExtension [len];\r
  63                         int pos = 0;\r
  64                         if (hiPrioExts != null) pos = CreateExtensionChain (hiPrioExts, res, pos);\r
  65                         if (medPrioExts != null) pos = CreateExtensionChain (medPrioExts, res, pos);\r
  66                         if (lowPrioExts != null) pos = CreateExtensionChain (lowPrioExts, res, pos);\r
  67                         return res;\r
  68                 }\r
  69 \r
  70                 static int CreateExtensionChain (SoapExtensionRuntimeConfig[] extensionConfigs, SoapExtension[] destArray, int pos)\r
  71                 {\r
  72                         for (int n=0; n<extensionConfigs.Length; n++)\r
  73                         {\r
  74                                 SoapExtensionRuntimeConfig econf = extensionConfigs [n];\r
  75                                 SoapExtension ext = (SoapExtension) Activator.CreateInstance (econf.Type);\r
  76                                 ext.Initialize (econf.InitializationInfo);\r
  77                                 destArray [pos++] = ext;\r
  78                         }\r
  79                         return pos;\r
  80                 }\r
  81 \r
  82                 static void InitializeGlobalExtensions ()\r
  83                 {\r
  84                         globalExtensions = new ArrayList[2];\r
  85                         \r
  86                         ArrayList exts = WSConfig.Instance.ExtensionTypes;\r
  87                         if (exts == null) return;\r
  88 \r
  89                         foreach (WSExtensionConfig econf in exts)\r
  90                         {\r
  91                                 if (globalExtensions [(int)econf.Group] == null) globalExtensions [(int)econf.Group] = new ArrayList ();\r
  92                                 ArrayList destList = globalExtensions [(int) econf.Group];\r
  93                                 bool added = false;\r
  94                                 for (int n=0; n<destList.Count && !added; n++)\r
  95                                         if (((WSExtensionConfig)destList [n]).Priority > econf.Priority) {\r
  96                                                 destList.Insert (n, econf);\r
  97                                                 added = true;\r
  98                                         }\r
  99                                 if (!added) destList.Add (econf);\r
 100                         }\r
 101                 }\r
 102 \r
 103                 internal static SoapExtensionRuntimeConfig[][] GetTypeExtensions (Type serviceType)\r
 104                 {\r
 105                         if (globalExtensions == null) InitializeGlobalExtensions();\r
 106                         \r
 107                         SoapExtensionRuntimeConfig[][] exts = new SoapExtensionRuntimeConfig[2][];\r
 108 \r
 109                         for (int group = 0; group < 2; group++)\r
 110                         {\r
 111                                 ArrayList globList = globalExtensions[group];\r
 112                                 if (globList == null) continue;\r
 113                                 exts [group] = new SoapExtensionRuntimeConfig [globList.Count];\r
 114                                 for (int n=0; n<globList.Count; n++)\r
 115                                 {\r
 116                                         WSExtensionConfig econf = (WSExtensionConfig) globList [n];\r
 117                                         SoapExtensionRuntimeConfig typeconf = new SoapExtensionRuntimeConfig ();\r
 118                                         typeconf.Type = econf.Type;\r
 119                                         SoapExtension ext = (SoapExtension) Activator.CreateInstance (econf.Type);\r
 120                                         typeconf.InitializationInfo = ext.GetInitializer (serviceType);\r
 121                                         exts [group][n] = typeconf;\r
 122                                 }\r
 123                         }\r
 124                         return exts;\r
 125                 }\r
 126 \r
 127                 internal static SoapExtensionRuntimeConfig[] GetMethodExtensions (LogicalMethodInfo method)\r
 128                 {\r
 129                         object[] ats = method.GetCustomAttributes (typeof (SoapExtensionAttribute));\r
 130                         SoapExtensionRuntimeConfig[] exts = new SoapExtensionRuntimeConfig [ats.Length];\r
 131                         int[] priorities = new int[ats.Length];\r
 132 \r
 133                         for (int n=0; n<ats.Length; n++)\r
 134                         {\r
 135                                 SoapExtensionAttribute at = (SoapExtensionAttribute) ats[n];\r
 136                                 SoapExtensionRuntimeConfig econf = new SoapExtensionRuntimeConfig ();\r
 137                                 econf.Type = at.ExtensionType;\r
 138                                 priorities [n] = at.Priority;\r
 139                                 SoapExtension ext = (SoapExtension) Activator.CreateInstance (econf.Type);\r
 140                                 econf.InitializationInfo = ext.GetInitializer (method, at);\r
 141                                 exts [n] = econf;\r
 142                         }\r
 143                         Array.Sort (priorities, exts);\r
 144                         return exts;\r
 145                 }\r
 146 \r
 147                 internal static Stream ExecuteChainStream (SoapExtension[] extensions, Stream stream)\r
 148                 {\r
 149                         if (extensions == null) return stream;\r
 150 \r
 151                         Stream newStream = stream;\r
 152                         foreach (SoapExtension ext in extensions)\r
 153                                 newStream = ext.ChainStream (newStream);\r
 154                         return newStream;\r
 155                 }\r
 156 \r
 157                 internal static void ExecuteProcessMessage(SoapExtension[] extensions, SoapMessage message, bool inverseOrder)\r
 158                 {\r
 159                         if (extensions == null) return;\r
 160 \r
 161                         if (inverseOrder)\r
 162                         {\r
 163                                 for (int n = extensions.Length-1; n >= 0; n--)\r
 164                                         extensions[n].ProcessMessage (message);\r
 165                         }\r
 166                         else\r
 167                         {\r
 168                                 for (int n = 0; n < extensions.Length; n++)\r
 169                                         extensions[n].ProcessMessage (message);\r
 170                         }\r
 171                 }
 172 \r
 173                 #endregion // Methods\r
 174         }\r
 175 \r
 176         internal class SoapExtensionRuntimeConfig\r
 177         {\r
 178                 public Type Type;\r
 179                 public int Priority;\r
 180                 public object InitializationInfo;\r
 181         }\r
 182 }