trying to syncronize files between two folder using microsoft sync frame work
below code is i am using. using timer to syncronise files at particular interval of time.
class
FileSyncProviderSample
{
// static SyncId sourceID;
//static SyncId destID;
public
static
void Main(string[]
args)
{
string[] arg =
new
string[2];
arg[0] =
@"C:\Projects\TestFolder\F1";
arg[1] =
@"C:\Projects\TestFolder\F2";
// arg[1] = @"\\199.63.39.76\Scanner Test Cases\F2";
if (arg.Length < 2 ||
string.IsNullOrEmpty(arg[0]) ||
string.IsNullOrEmpty(arg[1]) ||
!
Directory.Exists(arg[0]) || !Directory.Exists(arg[1]))
{
Console.WriteLine(
"Usage: FileSyncSample [valid directory path 1] [valid directory path 2]");
Console.ReadLine();
return;
}
string replica1RootPath = arg[0];
string replica2RootPath = arg[1];
System.Timers.
Timer objTimer;
try
{
// Set options for the synchronization operation
//WatchDirectory(replica1RootPath, replica2RootPath);
objTimer =
new System.Timers.Timer(1000);
objTimer.Elapsed +=
new System.Timers.ElapsedEventHandler(objTimer_Elapsed);
objTimer.Interval = 10000;
objTimer.Enabled =
true;
//WatchDirectory(@"C:\Projects\TestFolder\F1", @"C:\Projects\TestFolder\F2");
Console.WriteLine("Press
the Enter key to exit the program.");
Console.ReadLine();
}
catch (Exception
e)
{
Console.WriteLine("\nException
from File Synchronization Provider:\n" + e.ToString());
Console.ReadLine();
}
}
private
static
void WatchDirectory(string
replica1RootPath, string replica2RootPath)
{
FileSyncOptions options =
FileSyncOptions.ExplicitDetectChanges |
FileSyncOptions.RecycleDeletedFiles |
FileSyncOptions
.RecyclePreviousFileOnUpdates |
FileSyncOptions
.RecycleConflictLoserFiles;
FileSyncScopeFilter filter =
new
FileSyncScopeFilter();
filter.FileNameExcludes.Add(
"*.lnk");
// Exclude all *.lnk files
filter.FileNameExcludes.Add(
"filesync.metadata");
// Explicitly detect changes on both replicas upfront, to avoid two change
// detection passes for the two-way synchronization
DetectChangesOnFileSystemReplica(
replica1RootPath, filter, options);
DetectChangesOnFileSystemReplica(
replica2RootPath, filter, options);
// Synchronization in both directions
SyncFileSystemReplicasOneWay(replica1RootPath, replica2RootPath,
null, options);
SyncFileSystemReplicasOneWay(replica2RootPath, replica1RootPath,
null, options);
}
static
void objTimer_Elapsed(object
sender, System.Timers.ElapsedEventArgs e)
{
WatchDirectory(
@"C:\Projects\TestFolder\F1",
@"C:\Projects\TestFolder\F2");
}
public
static
void DetectChangesOnFileSystemReplica(
string replicaRootPath,
FileSyncScopeFilter filter,
FileSyncOptions options)
{
FileSyncProvider provider =
null;
try
{
provider =
new
FileSyncProvider(
new System.Guid(),replicaRootPath,
filter, options);
provider.DetectChanges();
}
catch (Exception
ex)
{
Console.WriteLine(ex.Message);
}
finally
{
// Release resources
if (provider !=
null)
provider.Dispose();
}
}
public
static
void SyncFileSystemReplicasOneWay(
string sourceReplicaRootPath,
string destinationReplicaRootPath,
FileSyncScopeFilter filter,
FileSyncOptions options)
{
FileSyncProvider sourceProvider =
null;
FileSyncProvider destinationProvider =
null;
try
{
sourceProvider = new
FileSyncProvider(sourceReplicaRootPath, filter, options);
destinationProvider =
new
FileSyncProvider(
destinationReplicaRootPath, filter, options);
destinationProvider.AppliedChange +=
new
EventHandler<AppliedChangeEventArgs>(OnAppliedChange);
destinationProvider.SkippedChange +=
new
EventHandler<SkippedChangeEventArgs>(OnSkippedChange);
SyncOrchestrator agent =
new
SyncOrchestrator();
agent.LocalProvider = sourceProvider;
agent.RemoteProvider = destinationProvider;
agent.Direction =
SyncDirectionOrder.Upload;// Upload; // Sync
source to destination
Console.WriteLine("Synchronizing
changes to replica: " +
destinationProvider.RootDirectoryPath);
//Console.ReadLine();
agent.Synchronize();
}
catch (Exception
ex)
{
}
finally
{
// Release resources
if (sourceProvider !=
null) { sourceProvider.Dispose(); sourceProvider =
null; }
if (destinationProvider !=
null) { destinationProvider.Dispose(); destinationProvider =
null; }
}
}
public
static
void OnAppliedChange(object
sender, AppliedChangeEventArgs args)
{
switch (args.ChangeType)
{
case
ChangeType.Create:
Console.WriteLine("--
Applied CREATE for file " + args.NewFilePath);
break;
case
ChangeType.Delete:
Console.WriteLine("--
Applied DELETE for file " + args.OldFilePath);
break;
case
ChangeType.Update:
Console.WriteLine("--
Applied OVERWRITE for file " + args.OldFilePath);
break;
case
ChangeType.Rename:
Console.WriteLine("--
Applied RENAME for file " + args.OldFilePath +
" as " + args.NewFilePath);
break;
}
Console.ReadLine();
}
public
static
void OnSkippedChange(object
sender, SkippedChangeEventArgs args)
{
Console.WriteLine("--
Skipped applying " + args.ChangeType.ToString().ToUpper()
+
" for " + (!string.IsNullOrEmpty(args.CurrentFilePath)
?
args.CurrentFilePath : args.NewFilePath) +
" due to error");
if (args.Exception !=
null)
Console.WriteLine("
[" + args.Exception.Message +
"]");
Console.ReadLine();
}
}
}
