Kolpack-Software-Consulting/LeafWeb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Beginning to configure SshClient for docker instance

Browse Source
This commit is contained in:
James Kolpack
2022-09-20 09:37:27 -04:00
parent 398a0e807c
commit e06d5d5b66
3 changed files with 26 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Core/Remote/PiscalSshClient.cs
+18 -10
View File
@@ -1,3 +1,4 @@
//#define DOCKER_PISCAL
using System;
using System.Collections.Generic;
using System.Data.Common;
@@ -13,9 +14,15 @@ namespace LeafWeb.Core.Remote
{
public class PiscalSshClient : IPiscalClient
{
private const string BaseDirectory = "./LeafWeb";
private const string RemoteScriptPath = BaseDirectory + "/piscal_manager.sh";
#if DOCKER_PISCAL
private const string RunDirectory = ".";
private const string PiscalManagerScriptPath = "/srv/piscal_manager.sh";
#else
private const string RunDirectory = "./LeafWeb";
private const string PiscalManagerScriptPath = RunDirectory + "/piscal_manager.sh";
#endif
private readonly string _host;
private readonly int _port;
private readonly PasswordConnectionInfo _connectionInfo;
private const string StatusComplete = "complete";
@@ -34,9 +41,10 @@ namespace LeafWeb.Core.Remote
var conn = new DbConnectionStringBuilder {ConnectionString = connectionString};
_host = conn["host"] as string;
_port = int.Parse(conn.ContainsKey("port") ? conn["port"] as string : "22"); // default 22
var username = conn["username"] as string;
var password = conn["password"] as string;
_connectionInfo = new PasswordConnectionInfo(_host, username, password);
_connectionInfo = new PasswordConnectionInfo(_host, _port, username, password);
_connectRetryPolicy = Policy
.Handle<SshConnectionException>()
@@ -88,15 +96,15 @@ namespace LeafWeb.Core.Remote
using (var sshClient = GetSshClient())
{
Connect(leafInput, sshClient);
sshClient.RunCommand($"mkdir {BaseDirectory}/{leafInput.PiscalDirectoryName}");
sshClient.RunCommand($"mkdir {BaseDirectory}/{leafInput.PiscalDirectoryName}/input");
sshClient.RunCommand($"mkdir {RunDirectory}/{leafInput.PiscalDirectoryName}");
sshClient.RunCommand($"mkdir {RunDirectory}/{leafInput.PiscalDirectoryName}/input");
Disconnect(leafInput, sshClient);
}
// copy files
using (var scp = GetScpClient())
foreach (var file in leafInput.InputFiles)
{
var inputPath = $"{BaseDirectory}/{leafInput.PiscalDirectoryName}/input/{file.Filename}";
var inputPath = $"{RunDirectory}/{leafInput.PiscalDirectoryName}/input/{file.Filename}";
using (var stream = new MemoryStream(file.Contents))
{
_logger.Debug("Copying " + inputPath);
@@ -120,7 +128,7 @@ namespace LeafWeb.Core.Remote
using (var ssh = GetSshClient())
{
Connect(leafInput, ssh);
var commandText = $"{RemoteScriptPath} -d {leafInput.PiscalDirectoryName} -p {leafInput.PhotosyntheticType} -s";
var commandText = $"{PiscalManagerScriptPath} -d {leafInput.PiscalDirectoryName} -p {leafInput.PhotosyntheticType} -s";
if (leafInput.SuppressStorageCopy)
commandText += " -t";
@@ -166,7 +174,7 @@ namespace LeafWeb.Core.Remote
using (var ssh = GetSshClient())
{
Connect(leafInput, ssh);
var commandText = $"{RemoteScriptPath} -d {leafInput.PiscalDirectoryName}";
var commandText = $"{PiscalManagerScriptPath} -d {leafInput.PiscalDirectoryName}";
var command = ssh.CreateCommand(commandText);
command.Execute();
Disconnect(leafInput, ssh);
@@ -227,7 +235,7 @@ namespace LeafWeb.Core.Remote
using (var ssh = GetSshClient())
{
Connect(leafInput, ssh);
var commandText = $"{RemoteScriptPath} -d {leafInput.PiscalDirectoryName} -k";
var commandText = $"{PiscalManagerScriptPath} -d {leafInput.PiscalDirectoryName} -k";
var command = ssh.CreateCommand(commandText);
command.Execute();
Disconnect(leafInput, ssh);
@@ -242,7 +250,7 @@ namespace LeafWeb.Core.Remote
using (var ssh = GetSshClient())
{
Connect(leafInput, ssh);
var commandText = $"{RemoteScriptPath} -d {leafInput.PiscalDirectoryName} -c";
var commandText = $"{PiscalManagerScriptPath} -d {leafInput.PiscalDirectoryName} -c";
var command = ssh.CreateCommand(commandText);
command.Execute();
Disconnect(leafInput, ssh);