xenadmin/XenServerHealthCheck/XenServerHealthCheckConfigProvider.cs
CitrixChris 1d003da4c7
CP-39720: Enable auth tokens (#3002)
* CP-39720 adds a auth token to updates.xml download and chc.msi download if it exists in the registry keys

Signed-off-by: Christophe25 <christopher.lancaste1@citrix.com>

* CP-39720 adds definition of GetInternalStageAuthToken() to XenServerHealthCheckConfigProvider.cs

Signed-off-by: Christophe25 <christopher.lancaste1@citrix.com>

* CP-39720 updates token name to be more consistent

Signed-off-by: Christophe25 <christopher.lancaste1@citrix.com>

* CP-39720 updates token name in missed request

Signed-off-by: Christophe25 <christopher.lancaste1@citrix.com>

* CP-39720 reads token name from registry

Signed-off-by: Christophe25 <christopher.lancaste1@citrix.com>
2022-05-10 12:22:28 +01:00

209 lines
7.5 KiB
C#

/* Copyright (c) Citrix Systems, Inc.
* All rights reserved.
*
* 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.Configuration;
using System.IO;
using System.Net;
using XenAdmin;
using XenAdmin.Actions;
using XenCenterLib;
using XenAdmin.Model;
using XenAdmin.Network;
using XenAdmin.ServerDBs;
using XenAPI;
namespace XenServerHealthCheck
{
public class XenServerHealthCheckConfigProvider : IXenAdminConfigProvider
{
private static readonly log4net.ILog log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
public Func<List<Role>, IXenConnection, string, AsyncAction.SudoElevationResult> ElevatedSessionDelegate => GetElevatedSession;
public int ConnectionTimeout => Properties.Settings.Default.ConnectionTimeout;
public Session CreateActionSession(Session session, IXenConnection connection)
{
return SessionFactory.DuplicateSession(session, connection, ConnectionTimeout);
}
public bool Exiting => false;
public bool ForcedExiting => false;
public string XenCenterUUID => "";
public bool DontSudo => false;
public bool ShowHiddenVMs => false;
public string GetXenCenterMetadata(bool isForXenCenter)
{
var metadataString = Properties.Settings.Default.XenCenterMetadata;
return metadataString.Replace(HealthCheckSettings.REPORT_TIME_PLACEHOLDER, DateTime.UtcNow.ToString("u"));
}
public string GetCustomUpdatesXmlLocation()
{
return string.Empty;
}
public string GetInternalStageAuthToken()
{
return string.Empty;
}
public string GetInternalStageAuthTokenName()
{
return string.Empty;
}
public int GetProxyTimeout(bool timeout)
{
return timeout ? Properties.Settings.Default.HttpTimeout : 0;
}
public IWebProxy GetProxyFromSettings(IXenConnection connection)
{
return GetProxyFromSettings(connection, true);
}
public IWebProxy GetProxyFromSettings(IXenConnection connection, bool isForXenServer)
{
try
{
if (connection != null && connection.Session != null && connection.Session.opaque_ref == "dummy")
return new XenServerHealthCheckSimulatorWebProxy(DbProxy.proxys[connection]);
switch ((HTTPHelper.ProxyStyle)Properties.Settings.Default.ProxySetting)
{
case HTTPHelper.ProxyStyle.SpecifiedProxy:
if (isForXenServer && Properties.Settings.Default.BypassProxyForServers)
return null;
string address = string.Format("http://{0}:{1}",
Properties.Settings.Default.ProxyAddress,
Properties.Settings.Default.ProxyPort);
if (Properties.Settings.Default.ProvideProxyAuthentication)
{
string username = "";
try
{
string protectedUsername = Properties.Settings.Default.ProxyUsername;
if (!string.IsNullOrEmpty(protectedUsername))
username = EncryptionUtils.Unprotect(protectedUsername);
}
catch (Exception e)
{
log.Warn("Could not unprotect internet proxy username.", e);
}
string password = "";
try
{
string protectedPassword = Properties.Settings.Default.ProxyPassword;
if (!string.IsNullOrEmpty(protectedPassword))
password = EncryptionUtils.Unprotect(protectedPassword);
}
catch (Exception e)
{
log.Warn("Could not unprotect internet proxy password.", e);
}
return new WebProxy(address, false, null, new NetworkCredential(username, password));
}
else
return new WebProxy(address, false);
case HTTPHelper.ProxyStyle.SystemProxy:
return WebRequest.GetSystemWebProxy();
default:
return null;
}
}
catch (ConfigurationErrorsException e)
{
log.Error("Error parsing 'ProxySetting' from settings - settings file deemed corrupt", e);
Environment.Exit(1);
}
return null;
}
public void ShowObject(string newVMRef)
{
}
public void HideObject(string newVMRef)
{
}
public bool ObjectIsHidden(string opaqueRef)
{
return false;
}
public string GetLogFile()
{
return "";
}
public void UpdateServerHistory(string hostnameWithPort)
{
}
public void SaveSettingsIfRequired()
{
}
private static AsyncAction.SudoElevationResult GetElevatedSession(List<Role> roles, IXenConnection connection, string actionTitle)
{
return new AsyncAction.SudoElevationResult(string.Empty, string.Empty, null);
}
}
internal class XenServerHealthCheckSimulatorWebProxy : SimulatorWebProxy
{
public XenServerHealthCheckSimulatorWebProxy(DbProxy proxy) : base(proxy)
{
}
public override Stream GetStream(Uri uri)
{
return new SimulatorWebStream(uri, this);
}
}
}