2 /* -----------------------------------------------------------------------
3 * <copyright file="PithosWorkflow.cs" company="GRNet">
5 * Copyright 2011-2012 GRNET S.A. All rights reserved.
7 * Redistribution and use in source and binary forms, with or
8 * without modification, are permitted provided that the following
11 * 1. Redistributions of source code must retain the above
12 * copyright notice, this list of conditions and the following
15 * 2. Redistributions in binary form must reproduce the above
16 * copyright notice, this list of conditions and the following
17 * disclaimer in the documentation and/or other materials
18 * provided with the distribution.
21 * THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS
22 * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
23 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
24 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
25 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
26 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
27 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
28 * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
29 * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
30 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
31 * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
32 * POSSIBILITY OF SUCH DAMAGE.
34 * The views and conclusions contained in the software and
35 * documentation are those of the authors and should not be
36 * interpreted as representing official policies, either expressed
37 * or implied, of GRNET S.A.
39 * -----------------------------------------------------------------------
43 using System.Collections.Generic;
44 using System.ComponentModel.Composition;
46 using System.Runtime.InteropServices;
48 using System.Threading;
49 using System.Threading.Tasks;
50 using Pithos.Interfaces;
52 using System.Diagnostics;
57 [Export(typeof(IPithosWorkflow))]
58 public class PithosWorkflow:IPithosWorkflow
61 public IPithosSettings Settings { get; set; }
64 public IStatusKeeper StatusKeeper { get; set; }
66 public FileStatus SetFileStatus(string path, FileStatus status)
68 Debug.Assert(!path.Contains(FolderConstants.CacheFolder));
69 Debug.Assert(!path.EndsWith(".ignore",StringComparison.InvariantCultureIgnoreCase));
71 if (String.IsNullOrWhiteSpace(path))
72 throw new ArgumentNullException("path", "The path parameter must not be emtpy");
74 var oldStatus=StatusKeeper.GetFileStatus(path);
76 if (oldStatus == status)
81 case FileStatus.Unchanged :
83 case FileStatus.Created:
84 if (status == FileStatus.Modified)
87 case FileStatus.Modified:
88 case FileStatus.Renamed:
89 if (status == FileStatus.Created)
93 StatusKeeper.SetFileStatus(path, status);
97 public void ClearFileStatus(string path)
99 if (String.IsNullOrWhiteSpace(path))
100 throw new ArgumentNullException("path", "The path parameter must not be emtpy");
102 StatusKeeper.ClearFileStatus(path.ToLower());
106 public Task<FileStream> OpenStreamWithWaiting(string path)
108 if (String.IsNullOrWhiteSpace(path))
109 throw new ArgumentNullException("path","The path parameter must not be emtpy");
111 if (!File.Exists(path))
112 throw new FileNotFoundException("The specified file or path does not exist", path);
114 return new Task<FileStream>(() =>
121 var stream=File.OpenRead(path);