/* Copyright (c) Cloud Software Group, Inc.
*
* Redistribution and use in source and binary forms,
* with or without modification, are permitted provided
* that the following conditions are met:
*
* * Redistributions of source code must retain the above
* copyright notice, this list of conditions and the
* following disclaimer.
* * Redistributions in binary form must reproduce the above
* copyright notice, this list of conditions and the
* following disclaimer in the documentation and/or other
* materials provided with the distribution.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND
* CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES,
* INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
* MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR
* CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
* BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
* WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
* NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
*/
using System;
using System.Collections.Generic;
using System.Xml;
using XenAdmin.Network;
using XenAPI;
using XenAdmin.Core;
namespace XenAdmin.Actions
{
///
/// Used for scanning for CSLG servers
///
public abstract class SrCslgScanAction : AsyncAction
{
private readonly string _hostname;
private readonly string _username;
private readonly string _passwordSecret;
protected SrCslgScanAction(IXenConnection connection, string hostname, string username, string passwordSecret)
: base(connection, string.Format(Messages.ACTION_SR_SCAN_NAME_CSLG, hostname), string.Format(Messages.ACTION_SR_SCAN_NAME_CSLG, hostname), true)
{
_hostname = hostname ?? throw new ArgumentNullException(nameof(hostname));
_username = username ?? throw new ArgumentNullException(nameof(username));
_passwordSecret = passwordSecret;
ApiMethodsToRoleCheck.AddRange(
"SR.async_probe",
"Secret.create",
"Secret.get_by_uuid",
"Secret.get_uuid",
"Secret.destroy");
}
protected void RunProbe(Dictionary dconf)
{
// CA-40132 create a new secret based on the secret that was passed in to the constructor. This is required so that the
// server doesn't associate the secret with a particular SR and then delete it when the SR is detached.
string newPasswordSecret = Secret.CreateSecret(Session, _passwordSecret);
dconf["password_secret"] = newPasswordSecret;
try
{
RelatedTask = SR.async_probe(Session, Helpers.GetCoordinator(Connection).opaque_ref, dconf, SR.SRTypes.cslg.ToString(), new Dictionary());
PollToCompletion();
}
finally
{
// now destroy the secret.
if (!string.IsNullOrEmpty(newPasswordSecret))
{
string newSecretRef = Secret.get_by_uuid(Session, newPasswordSecret);
Secret.destroy(Session, newSecretRef);
}
}
}
protected Dictionary GetAuthenticationDeviceConfig()
{
return new Dictionary
{
{ "target", _hostname },
{ "username", _username },
{ "password_secret", _passwordSecret }
};
}
protected string GetXmlNodeInnerText(XmlNode node, string xPath)
{
Util.ThrowIfParameterNull(node, "node");
Util.ThrowIfStringParameterNullOrEmpty(xPath, "xPath");
XmlNodeList nodes = node.SelectNodes(xPath);
if (nodes == null || nodes.Count == 0)
{
throw new InvalidOperationException(string.Format(Messages.CANNOT_FIND_NODE, xPath));
}
return nodes[0].InnerText;
}
protected List GetXmlChildNodeInnerTexts(XmlNode node, string xPath)
{
Util.ThrowIfParameterNull(node, "node");
Util.ThrowIfStringParameterNullOrEmpty(xPath, "xPath");
List output = new List();
XmlNodeList nodes = node.SelectNodes(xPath);
if (nodes == null)
{
throw new InvalidOperationException(string.Format(Messages.CANNOT_FIND_NODE, xPath));
}
foreach (XmlNode n in nodes)
{
output.Add(n.InnerText);
}
return output;
}
}
}