1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using Tango.Core.DI;
using Tango.FSE.BL;
using Tango.FSE.Common;
using Tango.FSE.Common.Connection;
using Tango.FSE.Common.HotFolder;
using Tango.FSE.Common.Notifications;
using Tango.FSE.Common.RemoteJobUpload;
using Tango.PPC.Shared.RemoteJobUpload;
using Tango.Settings;
namespace Tango.FSE.UI.HotFolder
{
[TangoCreateWhenRegistered]
public class DefaultHotFolderService : FSEExtendedObject, IHotFolderService
{
private Thread _watchThread;
public bool Enabled { get; set; }
public string HotFolderPath { get; set; }
[TangoInject]
private IRemoteJobUploadProvider RemoteJobUploadProvider { get; set; }
private IMachineProvider MachineProvider { get; set; }
[TangoInject]
private INotificationProvider NotificationProvider { get; set; }
public DefaultHotFolderService(IMachineProvider machineProvider)
{
MachineProvider = machineProvider;
var settings = SettingsManager.Default.GetOrCreate<FSESettings>();
Enabled = settings.EnableHotFolder;
if (Enabled)
{
String defaultPath = Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData),
"Twine", "Tango", "Hot Folder", BuildProvider.Build.ToDescription());
HotFolderPath = settings.HotFolderPath.IsNotNullOrEmpty() ? settings.HotFolderPath : defaultPath;
MachineProvider.MachineConnected += MachineProvider_MachineConnected;
}
}
private void MachineProvider_MachineConnected(object sender, MachineConnectedEventArgs e)
{
if (MachineProvider.ConnectionType.IsRemote())
{
try
{
if (!Directory.Exists(HotFolderPath))
{
Directory.CreateDirectory(HotFolderPath);
}
_watchThread = new Thread(WatchThreadLoop);
_watchThread.IsBackground = true;
_watchThread.Start();
}
catch (Exception ex)
{
LogManager.Log(ex, $"Error initializing hot folder at '{HotFolderPath}'.");
NotificationProvider.PushSnackbarItem(MessageType.Error, "Hot Folder", true, "Error initializing hot folder");
}
}
}
private void WatchThreadLoop()
{
while (MachineProvider.IsConnected)
{
try
{
Thread.Sleep(5000);
if (MachineProvider.IsConnected && Directory.Exists(HotFolderPath))
{
foreach (var file in Directory.GetFiles(HotFolderPath))
{
if (!MachineProvider.IsConnected) return;
bool upload = false;
String extension = Path.GetExtension(file).ToLower();
String fileName = Path.GetFileName(file);
if (extension == ".csv") upload = true;
if (upload)
{
LogManager.Log($"Found new hot folder item '{fileName}'. Uploading...");
var snackItem = NotificationProvider.PushProgressSnackbar("Hot Folder", $"Uploading '{fileName}' from to machine '{MachineProvider.Machine.SerialNumber}'...");
try
{
RemoteJobUploadProvider.UploadJob(file, RemoteJobUploadType.CSV).GetAwaiter().GetResult();
LogManager.Log($"Success uploading hot folder item '{fileName}'.");
snackItem.ProgressCompleted($"'{fileName}' uploaded successfully.");
try
{
File.Delete(file);
}
catch (Exception ex)
{
LogManager.Log(ex, $"Error deleting file '{fileName}' after upload from hot folder.");
NotificationProvider.PushSnackbarItem(MessageType.Error, "Hot Folder", true, $"$Error deleting '{fileName}' from hot folder.");
}
}
catch (Exception ex)
{
LogManager.Log(ex, $"Error uploading hot folder item '{fileName}'.");
snackItem.ProgressFailed($"'{fileName}' upload failed.");
}
}
}
}
}
catch (Exception ex)
{
LogManager.Log(ex, "Error occurred on hot folder service watch loop.");
}
}
}
}
}
|
