102 lines
3.6 KiB
C#
102 lines
3.6 KiB
C#
//******************************************************************************//
|
|
// FileWatcher.cs
|
|
// 12/4/2023
|
|
//
|
|
// RAYTHEON PROPRIETARY: THIS DOCUMENT CONTAINS DATA OR INFORMATION
|
|
// PROPRIETARY TO RAYTHEON COMPANY AND IS RESTRICTED TO USE ONLY BY PERSONS
|
|
// AUTHORIZED BY RAYTHEON COMPANY IN WRITING TO USE IT. DISCLOSURE TO
|
|
// UNAUTHORIZED PERSONS WOULD LIKELY CAUSE SUBSTANTIAL COMPETITIVE HARM TO
|
|
// RAYTHEON COMPANY'S BUSINESS POSITION. NEITHER SAID DOCUMENT NOR ITS
|
|
// CONTENTS SHALL BE FURNISHED OR DISCLOSED TO OR COPIED OR USED BY PERSONS
|
|
// OUTSIDE RAYTHEON COMPANY WITHOUT THE EXPRESS WRITTEN APPROVAL OF RAYTHEON
|
|
// COMPANY.
|
|
//
|
|
// THIS PROPRIETARY NOTICE IS NOT APPLICABLE IF DELIVERED TO THE U.S. GOVERNMENT
|
|
//
|
|
// UNPUBLISHED WORK - COPYRIGHT RAYTHEON COMPANY.
|
|
//
|
|
// WARNING: THIS DOCUMENT CONTAINS TECHNICAL DATA AND / OR TECHNOLOGY WHOSE
|
|
// EXPORT OR DISCLOSURE TO NON-U.S. PERSONS, WHEREVER LOCATED, IS RESTRICTED
|
|
// BY THE INTERNATIONAL TRAFFIC IN ARMS REGULATIONS (ITAR) (22 C.F.R. SECTION
|
|
// 120-130) OR THE EXPORT ADMINISTRATION REGULATIONS (EAR) (15 C.F.R. SECTION
|
|
// 730-774). THIS DOCUMENT CANNOT BE EXPORTED (E.G., PROVIDED TO A SUPPLIER
|
|
// OUTSIDE OF THE UNITED STATES) OR DISCLOSED TO A NON-U.S. PERSON, WHEREVER
|
|
// LOCATED, UNTIL A FINAL JURISDICTION AND CLASSIFICATION DETERMINATION HAS
|
|
// BEEN COMPLETED AND APPROVED BY RAYTHEON, AND ANY REQUIRED U.S. GOVERNMENT
|
|
// APPROVALS HAVE BEEN OBTAINED. VIOLATIONS ARE SUBJECT TO SEVERE CRIMINAL
|
|
// PENALTIES.
|
|
//
|
|
// DOD 5220.22-M, INDUSTRIAL SECURITY MANUAL, CHAPTER 5, SECTION 1 THROUGH 9 :
|
|
// FOR CLASSIFIED DOCUMENTS FOLLOW THE PROCEDURES IN OR DOD 5200.1-R,
|
|
// INFORMATION SECURITY PROGRAM, CHAPTER 6. FOR UNCLASSIFIED, LIMITED DOCUMENTS
|
|
// DESTROY BY ANY METHOD THAT WILL PREVENT DISCLOSURE OF CONTENTS OR
|
|
// RECONSTRUCTION OF THE DOCUMENT.
|
|
// POC: Alex Kravchenko (1118268)
|
|
//******************************************************************************//
|
|
using Raytheon.LogDashboard.Model;
|
|
using System;
|
|
using System.IO;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace Raytheon.LogDashboard.Helpers
|
|
{
|
|
public class FileWatcher
|
|
{
|
|
private CancellationTokenSource cancellationToken;
|
|
|
|
public string FilePath { get; set; }
|
|
|
|
public long Position { get; set; }
|
|
|
|
public LogTemplate Template { get; set; }
|
|
|
|
public ImportLogFile ImportLogFile { get; set; }
|
|
|
|
public event EventHandler<FileWatcher> FileChanged;
|
|
|
|
/// <summary>
|
|
/// starts watching the file for changes with hard-coded one sec interval
|
|
/// </summary>
|
|
public void StartWatch()
|
|
{
|
|
cancellationToken = new CancellationTokenSource();
|
|
|
|
Task.Run(() =>
|
|
{
|
|
while(true)
|
|
{
|
|
if(cancellationToken.Token.IsCancellationRequested)
|
|
{
|
|
return;
|
|
}
|
|
|
|
long currentLength;
|
|
using(FileStream stream = File.Open(FilePath, FileMode.Open, FileAccess.Read, FileShare.ReadWrite))
|
|
{
|
|
currentLength = stream.Length;
|
|
}
|
|
|
|
if(currentLength > Position)
|
|
{
|
|
OnFileChanged(this);
|
|
}
|
|
|
|
Position = currentLength;
|
|
Thread.Sleep(1000);
|
|
}
|
|
});
|
|
}
|
|
|
|
public void StopWatch()
|
|
{
|
|
cancellationToken.Cancel();
|
|
}
|
|
|
|
protected virtual void OnFileChanged(FileWatcher fileWatcher)
|
|
{
|
|
FileChanged?.Invoke(this, fileWatcher);
|
|
}
|
|
}
|
|
}
|