Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 1 addition & 2 deletions .github/workflows/keyfactor-release-workflow.yml
Original file line number Diff line number Diff line change
Expand Up @@ -11,10 +11,9 @@ on:

jobs:
call-starter-workflow:
uses: keyfactor/actions/.github/workflows/starter.yml@v3
uses: keyfactor/actions/.github/workflows/starter.yml@v5
secrets:
token: ${{ secrets.V2BUILDTOKEN}}
APPROVE_README_PUSH: ${{ secrets.APPROVE_README_PUSH}}
gpg_key: ${{ secrets.KF_GPG_PRIVATE_KEY }}
gpg_pass: ${{ secrets.KF_GPG_PASSPHRASE }}
scan_token: ${{ secrets.SAST_TOKEN }}
2 changes: 2 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
# v2.0.1
- Added PAM resolution support
# v2.0.0
- .Net 6 and .Net 8 Support and Documentation Updates
# v1.0.0
Expand Down
3 changes: 1 addition & 2 deletions Kemp.sln
Original file line number Diff line number Diff line change
@@ -1,5 +1,4 @@

Microsoft Visual Studio Solution File, Format Version 12.00
Microsoft Visual Studio Solution File, Format Version 12.00
# Visual Studio Version 17
VisualStudioVersion = 17.11.35222.181
MinimumVisualStudioVersion = 10.0.40219.1
Expand Down
255 changes: 131 additions & 124 deletions Kemp/Jobs/Inventory.cs
Original file line number Diff line number Diff line change
@@ -1,126 +1,133 @@
using System;
using System.IO;
using System.Linq;
using System.Xml.Serialization;
using Keyfactor.Extensions.Orchestrator.Kemp.Client;
using Keyfactor.Extensions.Orchestrator.Kemp.Client.Models;
using Keyfactor.Logging;
using Keyfactor.Orchestrators.Common.Enums;
using Keyfactor.Orchestrators.Extensions;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;

namespace Keyfactor.Extensions.Orchestrator.Kemp.Jobs
{
public class Inventory : IInventoryJobExtension
{
private readonly ILogger<Inventory> _logger;

public Inventory(ILogger<Inventory> logger)
{
_logger = logger;
}

public string ExtensionName => "Kemp";

public JobResult ProcessJob(InventoryJobConfiguration jobConfiguration,
SubmitInventoryUpdate submitInventoryUpdate)
{
try
{
_logger.MethodEntry();
return PerformInventory(jobConfiguration, submitInventoryUpdate);
}
catch (Exception e)
{
_logger.LogError($"Error occured in Inventory.ProcessJob: {LogHandler.FlattenException(e)}");
throw;
}
}

private JobResult PerformInventory(InventoryJobConfiguration config, SubmitInventoryUpdate submitInventory)
{
try
{
_logger.MethodEntry(LogLevel.Debug);
_logger.LogTrace($"Inventory Config {JsonConvert.SerializeObject(config)}");
_logger.LogTrace(
$"Client Machine: {config.CertificateStoreDetails.ClientMachine} ApiKey: {config.ServerPassword}");

var client = new KempClient(config);

var certificatesResult = client.GetCertificates().Result;
var intermediateCertificates = client.GetIntermediateCertificates().Result;

//Debug Write Certificate List Response from Palo Alto
var listWriter = new StringWriter();
var listSerializer = new XmlSerializer(typeof(CertListResponse));
listSerializer.Serialize(listWriter, certificatesResult);
_logger.LogTrace($"Certificate List Result {listWriter}");

//Debug Write Intermediate Certificate List Response from Palo Alto
var intListWriter = new StringWriter();
var intListSerializer = new XmlSerializer(typeof(CertListResponse));
intListSerializer.Serialize(intListWriter, intermediateCertificates);
_logger.LogTrace($"Intermediate List Result {intListWriter}");

var inventoryItems = (from cert in certificatesResult?.Success?.Data?.Certs
let certPem = client.GetCertificate(cert.Name).Result
select BuildInventoryItem(cert.Name, certPem.Success.Data.Certificate, true)).ToList();
inventoryItems.AddRange(from cert in intermediateCertificates?.Success?.Data?.Certs
let certPem = client.GetIntermediateCertificate(cert.Name).Result
select BuildInventoryItem(cert.Name, certPem.Success.Data.Certificate, false));

_logger.LogTrace("Submitting Inventory To Keyfactor via submitInventory.Invoke");
submitInventory.Invoke(inventoryItems);
_logger.LogTrace("Submitted Inventory To Keyfactor via submitInventory.Invoke");

_logger.MethodExit(LogLevel.Debug);

_logger.LogTrace("Return Success");
return new JobResult
{
Result = OrchestratorJobStatusJobResult.Success,
JobHistoryId = config.JobHistoryId,
FailureMessage = ""
};
}
catch (Exception e)
using Keyfactor.Extensions.Orchestrator.Kemp.Client;
using Keyfactor.Extensions.Orchestrator.Kemp.Client.Models;
using Keyfactor.Logging;
using Keyfactor.Orchestrators.Common.Enums;
using Keyfactor.Orchestrators.Extensions;
using Keyfactor.Orchestrators.Extensions.Interfaces;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
Comment on lines +7 to +8
using System;
using System.IO;
using System.Linq;
using System.Xml.Linq;
using System.Xml.Serialization;
using static Org.BouncyCastle.Math.EC.ECCurve;
Comment on lines +12 to +14

namespace Keyfactor.Extensions.Orchestrator.Kemp.Jobs
{
public class Inventory : IInventoryJobExtension
{
public IPAMSecretResolver _resolver;
public string ExtensionName => "Kemp";
private ILogger _logger;

public Inventory(IPAMSecretResolver resolver)
{
_resolver = resolver;
}
Comment on lines +20 to +27

public JobResult ProcessJob(InventoryJobConfiguration jobConfiguration, SubmitInventoryUpdate submitInventoryUpdate)
{
_logger = LogHandler.GetClassLogger(this.GetType());
_logger.MethodEntry();

try
{
return new JobResult
{
Result = OrchestratorJobStatusJobResult.Failure,
JobHistoryId = config.JobHistoryId,
FailureMessage = LogHandler.FlattenException(e)
};
}
}

protected virtual CurrentInventoryItem BuildInventoryItem(string alias, string certPem, bool privateKey)
{
try
{
_logger.MethodEntry();
_logger.LogTrace($"Alias: {alias} Pem: {certPem} PrivateKey: {privateKey}");


var acsi = new CurrentInventoryItem
{
Alias = alias,
Certificates = new[] {certPem},
ItemStatus = OrchestratorInventoryItemStatus.Unknown,
PrivateKeyEntry = privateKey,
UseChainLevel = false
};

_logger.MethodExit();
return acsi;
}
catch (Exception e)
{
_logger.LogError($"Error Occurred in Inventory.BuildInventoryItem: {LogHandler.FlattenException(e)}");
throw;
}
}
}
string password = PAMUtilities.ResolvePAMField(_resolver, _logger, "Kemp ApiKey", jobConfiguration.ServerPassword);
jobConfiguration.ServerPassword = password;

return PerformInventory(jobConfiguration, submitInventoryUpdate);
}
catch (Exception e)
{
_logger.LogError($"Error occured in Inventory.ProcessJob: {LogHandler.FlattenException(e)}");
throw;
}
}

private JobResult PerformInventory(InventoryJobConfiguration config, SubmitInventoryUpdate submitInventory)
{
try
{
_logger.MethodEntry(LogLevel.Debug);

_logger.LogTrace(
$"Client Machine: {config.CertificateStoreDetails.ClientMachine} ApiKey: *********");

var client = new KempClient(config);

var certificatesResult = client.GetCertificates().Result;
var intermediateCertificates = client.GetIntermediateCertificates().Result;

//Debug Write Certificate List Response from Palo Alto
var listWriter = new StringWriter();
var listSerializer = new XmlSerializer(typeof(CertListResponse));
listSerializer.Serialize(listWriter, certificatesResult);
_logger.LogTrace($"Certificate List Result {listWriter}");

//Debug Write Intermediate Certificate List Response from Palo Alto
var intListWriter = new StringWriter();
var intListSerializer = new XmlSerializer(typeof(CertListResponse));
intListSerializer.Serialize(intListWriter, intermediateCertificates);
_logger.LogTrace($"Intermediate List Result {intListWriter}");

var inventoryItems = (from cert in certificatesResult?.Success?.Data?.Certs
let certPem = client.GetCertificate(cert.Name).Result
select BuildInventoryItem(cert.Name, certPem.Success.Data.Certificate, true)).ToList();
inventoryItems.AddRange(from cert in intermediateCertificates?.Success?.Data?.Certs
let certPem = client.GetIntermediateCertificate(cert.Name).Result
select BuildInventoryItem(cert.Name, certPem.Success.Data.Certificate, false));

_logger.LogTrace("Submitting Inventory To Keyfactor via submitInventory.Invoke");
submitInventory.Invoke(inventoryItems);
_logger.LogTrace("Submitted Inventory To Keyfactor via submitInventory.Invoke");

_logger.MethodExit(LogLevel.Debug);

_logger.LogTrace("Return Success");
return new JobResult
{
Result = OrchestratorJobStatusJobResult.Success,
JobHistoryId = config.JobHistoryId,
FailureMessage = ""
};
}
catch (Exception e)
{
return new JobResult
{
Result = OrchestratorJobStatusJobResult.Failure,
JobHistoryId = config.JobHistoryId,
FailureMessage = LogHandler.FlattenException(e)
};
}
}

protected virtual CurrentInventoryItem BuildInventoryItem(string alias, string certPem, bool privateKey)
{
try
{
_logger.MethodEntry();
_logger.LogTrace($"Alias: {alias} Pem: {certPem} PrivateKey: *******");


var acsi = new CurrentInventoryItem
{
Alias = alias,
Certificates = new[] {certPem},
ItemStatus = OrchestratorInventoryItemStatus.Unknown,
PrivateKeyEntry = privateKey,
UseChainLevel = false
};

_logger.MethodExit();
return acsi;
}
catch (Exception e)
{
_logger.LogError($"Error Occurred in Inventory.BuildInventoryItem: {LogHandler.FlattenException(e)}");
throw;
}
}
}
}
Loading
Loading