1 files changed, 303 insertions, 0 deletions

diff --git a/src/wixext/MsmqDecompiler.cs b/src/wixext/MsmqDecompiler.cs
new file mode 100644
index 00000000..396fc49a
--- /dev/null
+++ b/src/wixext/MsmqDecompiler.cs
@@ -0,0 +1,303 @@
+// Copyright (c) .NET Foundation and contributors. All rights reserved. Licensed under the Microsoft Reciprocal License. See LICENSE.TXT file in the project root for full license information.
+
+namespace WixToolset.Extensions
+{
+    using System;
+    using System.Collections;
+    using System.Globalization;
+    using WixToolset.Data;
+    using WixToolset.Extensibility;
+    using Msmq = WixToolset.Extensions.Serialize.Msmq;
+    using Wix = WixToolset.Data.Serialize;
+
+    /// <summary>
+    /// The decompiler for the WiX Toolset MSMQ Extension.
+    /// </summary>
+    public sealed class MsmqDecompiler : DecompilerExtension
+    {
+        /// <summary>
+        /// Creates a decompiler for MSMQ Extension.
+        /// </summary>
+        public MsmqDecompiler()
+        {
+            this.TableDefinitions = MsmqExtensionData.GetExtensionTableDefinitions();
+        }
+
+        /// <summary>
+        /// Get the extensions library to be removed.
+        /// </summary>
+        /// <param name="tableDefinitions">Table definitions for library.</param>
+        /// <returns>Library to remove from decompiled output.</returns>
+        public override Library GetLibraryToRemove(TableDefinitionCollection tableDefinitions)
+        {
+            return MsmqExtensionData.GetExtensionLibrary(tableDefinitions);
+        }
+
+        /// <summary>
+        /// Decompiles an extension table.
+        /// </summary>
+        /// <param name="table">The table to decompile.</param>
+        public override void DecompileTable(Table table)
+        {
+            switch (table.Name)
+            {
+                case "MessageQueue":
+                    this.DecompileMessageQueueTable(table);
+                    break;
+                case "MessageQueueUserPermission":
+                    this.DecompileMessageQueueUserPermissionTable(table);
+                    break;
+                case "MessageQueueGroupPermission":
+                    this.DecompileMessageQueueGroupPermissionTable(table);
+                    break;
+                default:
+                    base.DecompileTable(table);
+                    break;
+            }
+        }
+
+        /// <summary>
+        /// Decompile the MessageQueue table.
+        /// </summary>
+        /// <param name="table">The table to decompile.</param>
+        private void DecompileMessageQueueTable(Table table)
+        {
+            foreach (Row row in table.Rows)
+            {
+                Msmq.MessageQueue queue = new Msmq.MessageQueue();
+
+                queue.Id = (string)row[0];
+
+                if (null != row[2])
+                {
+                    queue.BasePriority = (int)row[2];
+                }
+
+                if (null != row[3])
+                {
+                    queue.JournalQuota = (int)row[3];
+                }
+
+                queue.Label = (string)row[4];
+
+                if (null != row[5])
+                {
+                    queue.MulticastAddress = (string)row[5];
+                }
+
+                queue.PathName = (string)row[6];
+
+                if (null != row[7])
+                {
+                    switch ((MsmqCompiler.MqiMessageQueuePrivacyLevel)row[7])
+                    {
+                        case MsmqCompiler.MqiMessageQueuePrivacyLevel.None:
+                            queue.PrivLevel = Msmq.MessageQueue.PrivLevelType.none;
+                            break;
+                        case MsmqCompiler.MqiMessageQueuePrivacyLevel.Optional:
+                            queue.PrivLevel = Msmq.MessageQueue.PrivLevelType.optional;
+                            break;
+                        case MsmqCompiler.MqiMessageQueuePrivacyLevel.Body:
+                            queue.PrivLevel = Msmq.MessageQueue.PrivLevelType.body;
+                            break;
+                        default:
+                            break;
+                    }
+                }
+
+                if (null != row[8])
+                {
+                    queue.Quota = (int)row[8];
+                }
+
+                if (null != row[9])
+                {
+                    queue.ServiceTypeGuid = (string)row[9];
+                }
+
+                int attributes = (int)row[10];
+
+                if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueueAttributes.Authenticate))
+                {
+                    queue.Authenticate = Msmq.YesNoType.yes;
+                }
+
+                if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueueAttributes.Journal))
+                {
+                    queue.Journal = Msmq.YesNoType.yes;
+                }
+
+                if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueueAttributes.Transactional))
+                {
+                    queue.Transactional = Msmq.YesNoType.yes;
+                }
+
+                Wix.Component component = (Wix.Component)this.Core.GetIndexedElement("Component", (string)row[1]);
+                if (null != component)
+                {
+                    component.AddChild(queue);
+                }
+                else
+                {
+                    this.Core.OnMessage(WixWarnings.ExpectedForeignRow(row.SourceLineNumbers, table.Name, row.GetPrimaryKey(DecompilerConstants.PrimaryKeyDelimiter), "Component_", (string)row[1], "Component"));
+                }
+            }
+        }
+
+        /// <summary>
+        /// Decompile the MessageQueueUserPermission table.
+        /// </summary>
+        /// <param name="table">The table to decompile.</param>
+        private void DecompileMessageQueueUserPermissionTable(Table table)
+        {
+            foreach (Row row in table.Rows)
+            {
+                Msmq.MessageQueuePermission queuePermission = new Msmq.MessageQueuePermission();
+
+                queuePermission.Id = (string)row[0];
+
+                if (null != row[2])
+                {
+                    queuePermission.MessageQueue = (string)row[2];
+                }
+
+                queuePermission.User = (string)row[3];
+
+                DecompileMessageQueuePermissionAttributes(row, queuePermission);
+
+                Wix.Component component = (Wix.Component)this.Core.GetIndexedElement("Component", (string)row[1]);
+                if (null != component)
+                {
+                    component.AddChild(queuePermission);
+                }
+                else
+                {
+                    this.Core.OnMessage(WixWarnings.ExpectedForeignRow(row.SourceLineNumbers, table.Name, row.GetPrimaryKey(DecompilerConstants.PrimaryKeyDelimiter), "Component_", (string)row[1], "Component"));
+                }
+            }
+        }
+
+        /// <summary>
+        /// Decompile the MessageQueueGroupPermission table.
+        /// </summary>
+        /// <param name="table">The table to decompile.</param>
+        private void DecompileMessageQueueGroupPermissionTable(Table table)
+        {
+            foreach (Row row in table.Rows)
+            {
+                Msmq.MessageQueuePermission queuePermission = new Msmq.MessageQueuePermission();
+
+                queuePermission.Id = (string)row[0];
+
+                if (null != row[2])
+                {
+                    queuePermission.MessageQueue = (string)row[2];
+                }
+
+                queuePermission.Group = (string)row[3];
+
+                DecompileMessageQueuePermissionAttributes(row, queuePermission);
+
+                Wix.Component component = (Wix.Component)this.Core.GetIndexedElement("Component", (string)row[1]);
+                if (null != component)
+                {
+                    component.AddChild(queuePermission);
+                }
+                else
+                {
+                    this.Core.OnMessage(WixWarnings.ExpectedForeignRow(row.SourceLineNumbers, table.Name, row.GetPrimaryKey(DecompilerConstants.PrimaryKeyDelimiter), "Component_", (string)row[1], "Component"));
+                }
+            }
+        }
+
+        /// <summary>
+        /// Decompile row attributes for the MessageQueueUserPermission and MessageQueueGroupPermission tables.
+        /// </summary>
+        /// <param name="row">The row to decompile.</param>
+        /// <param name="table">Target element.</param>
+        private void DecompileMessageQueuePermissionAttributes(Row row, Msmq.MessageQueuePermission queuePermission)
+        {
+            int attributes = (int)row[4];
+
+            if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueuePermission.DeleteMessage))
+            {
+                queuePermission.DeleteMessage = Msmq.YesNoType.yes;
+            }
+
+            if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueuePermission.PeekMessage))
+            {
+                queuePermission.PeekMessage = Msmq.YesNoType.yes;
+            }
+
+            if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueuePermission.WriteMessage))
+            {
+                queuePermission.WriteMessage = Msmq.YesNoType.yes;
+            }
+
+            if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueuePermission.DeleteJournalMessage))
+            {
+                queuePermission.DeleteJournalMessage = Msmq.YesNoType.yes;
+            }
+
+            if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueuePermission.SetQueueProperties))
+            {
+                queuePermission.SetQueueProperties = Msmq.YesNoType.yes;
+            }
+
+            if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueuePermission.GetQueueProperties))
+            {
+                queuePermission.GetQueueProperties = Msmq.YesNoType.yes;
+            }
+
+            if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueuePermission.DeleteQueue))
+            {
+                queuePermission.DeleteQueue = Msmq.YesNoType.yes;
+            }
+
+            if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueuePermission.GetQueuePermissions))
+            {
+                queuePermission.GetQueuePermissions = Msmq.YesNoType.yes;
+            }
+
+            if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueuePermission.ChangeQueuePermissions))
+            {
+                queuePermission.ChangeQueuePermissions = Msmq.YesNoType.yes;
+            }
+
+            if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueuePermission.TakeQueueOwnership))
+            {
+                queuePermission.TakeQueueOwnership = Msmq.YesNoType.yes;
+            }
+
+            if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueuePermission.ReceiveMessage))
+            {
+                queuePermission.ReceiveMessage = Msmq.YesNoType.yes;
+            }
+
+            if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueuePermission.ReceiveJournalMessage))
+            {
+                queuePermission.ReceiveJournalMessage = Msmq.YesNoType.yes;
+            }
+
+            if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueuePermission.QueueGenericRead))
+            {
+                queuePermission.QueueGenericRead = Msmq.YesNoType.yes;
+            }
+
+            if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueuePermission.QueueGenericWrite))
+            {
+                queuePermission.QueueGenericWrite = Msmq.YesNoType.yes;
+            }
+
+            if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueuePermission.QueueGenericExecute))
+            {
+                queuePermission.QueueGenericExecute = Msmq.YesNoType.yes;
+            }
+
+            if (0 != (attributes & (int)MsmqCompiler.MqiMessageQueuePermission.QueueGenericAll))
+            {
+                queuePermission.QueueGenericAll = Msmq.YesNoType.yes;
+            }
+        }
+    }
+}