2016-10-29 05:40:15 +00:00
using System ;
using System.Collections.Generic ;
2017-10-04 18:51:26 +00:00
using System.Diagnostics ;
2016-10-29 05:40:15 +00:00
using System.IO ;
using System.Linq ;
using System.Text ;
using MediaBrowser.Model.IO ;
using MediaBrowser.Model.Logging ;
2017-03-10 19:51:29 +00:00
using MediaBrowser.Model.System ;
2016-10-29 05:40:15 +00:00
2017-08-16 06:43:41 +00:00
namespace Emby.Server.Implementations.IO
2016-10-29 05:40:15 +00:00
{
/// <summary>
/// Class ManagedFileSystem
/// </summary>
public class ManagedFileSystem : IFileSystem
{
protected ILogger Logger ;
private readonly bool _supportsAsyncFileStreams ;
private char [ ] _invalidFileNameChars ;
private readonly List < IShortcutHandler > _shortcutHandlers = new List < IShortcutHandler > ( ) ;
2017-03-10 19:51:29 +00:00
private bool EnableFileSystemRequestConcat ;
2016-10-29 05:40:15 +00:00
2017-01-23 21:51:23 +00:00
private string _tempPath ;
2017-04-02 00:36:06 +00:00
private SharpCifsFileSystem _sharpCifsFileSystem ;
2017-10-04 18:51:26 +00:00
private IEnvironmentInfo _environmentInfo ;
2017-04-02 00:36:06 +00:00
2017-03-10 19:51:29 +00:00
public ManagedFileSystem ( ILogger logger , IEnvironmentInfo environmentInfo , string tempPath )
2016-10-29 05:40:15 +00:00
{
Logger = logger ;
2017-03-10 19:51:29 +00:00
_supportsAsyncFileStreams = true ;
2017-01-23 21:51:23 +00:00
_tempPath = tempPath ;
2017-10-04 18:51:26 +00:00
_environmentInfo = environmentInfo ;
2017-03-18 23:37:29 +00:00
// On Linux, this needs to be true or symbolic links are ignored
EnableFileSystemRequestConcat = environmentInfo . OperatingSystem ! = MediaBrowser . Model . System . OperatingSystem . Windows & &
environmentInfo . OperatingSystem ! = MediaBrowser . Model . System . OperatingSystem . OSX ;
2017-03-10 19:51:29 +00:00
SetInvalidFileNameChars ( environmentInfo . OperatingSystem = = MediaBrowser . Model . System . OperatingSystem . Windows ) ;
2017-04-02 00:36:06 +00:00
_sharpCifsFileSystem = new SharpCifsFileSystem ( environmentInfo . OperatingSystem ) ;
2016-10-29 05:40:15 +00:00
}
public void AddShortcutHandler ( IShortcutHandler handler )
{
_shortcutHandlers . Add ( handler ) ;
}
protected void SetInvalidFileNameChars ( bool enableManagedInvalidFileNameChars )
{
if ( enableManagedInvalidFileNameChars )
{
_invalidFileNameChars = Path . GetInvalidFileNameChars ( ) ;
}
else
{
// GetInvalidFileNameChars is less restrictive in Linux/Mac than Windows, this mimic Windows behavior for mono under Linux/Mac.
_invalidFileNameChars = new char [ 41 ] { ' \ x00 ' , ' \ x01 ' , ' \ x02 ' , ' \ x03 ' , ' \ x04 ' , ' \ x05 ' , ' \ x06 ' , ' \ x07 ' ,
' \ x08 ' , ' \ x09 ' , ' \ x0A ' , ' \ x0B ' , ' \ x0C ' , ' \ x0D ' , ' \ x0E ' , ' \ x0F ' , ' \ x10 ' , ' \ x11 ' , ' \ x12 ' ,
' \ x13 ' , ' \ x14 ' , ' \ x15 ' , ' \ x16 ' , ' \ x17 ' , ' \ x18 ' , ' \ x19 ' , ' \ x1A ' , ' \ x1B ' , ' \ x1C ' , ' \ x1D ' ,
' \ x1E ' , ' \ x1F ' , ' \ x22 ' , ' \ x3C ' , ' \ x3E ' , ' \ x7C ' , ':' , '*' , '?' , '\\' , '/' } ;
}
}
public char DirectorySeparatorChar
{
get
{
return Path . DirectorySeparatorChar ;
}
}
public string GetFullPath ( string path )
{
return Path . GetFullPath ( path ) ;
}
/// <summary>
/// Determines whether the specified filename is shortcut.
/// </summary>
/// <param name="filename">The filename.</param>
/// <returns><c>true</c> if the specified filename is shortcut; otherwise, <c>false</c>.</returns>
/// <exception cref="System.ArgumentNullException">filename</exception>
public virtual bool IsShortcut ( string filename )
{
if ( string . IsNullOrEmpty ( filename ) )
{
throw new ArgumentNullException ( "filename" ) ;
}
var extension = Path . GetExtension ( filename ) ;
return _shortcutHandlers . Any ( i = > string . Equals ( extension , i . Extension , StringComparison . OrdinalIgnoreCase ) ) ;
}
/// <summary>
/// Resolves the shortcut.
/// </summary>
/// <param name="filename">The filename.</param>
/// <returns>System.String.</returns>
/// <exception cref="System.ArgumentNullException">filename</exception>
public virtual string ResolveShortcut ( string filename )
{
if ( string . IsNullOrEmpty ( filename ) )
{
throw new ArgumentNullException ( "filename" ) ;
}
var extension = Path . GetExtension ( filename ) ;
var handler = _shortcutHandlers . FirstOrDefault ( i = > string . Equals ( extension , i . Extension , StringComparison . OrdinalIgnoreCase ) ) ;
if ( handler ! = null )
{
return handler . Resolve ( filename ) ;
}
return null ;
}
/// <summary>
/// Creates the shortcut.
/// </summary>
/// <param name="shortcutPath">The shortcut path.</param>
/// <param name="target">The target.</param>
/// <exception cref="System.ArgumentNullException">
/// shortcutPath
/// or
/// target
/// </exception>
public void CreateShortcut ( string shortcutPath , string target )
{
if ( string . IsNullOrEmpty ( shortcutPath ) )
{
throw new ArgumentNullException ( "shortcutPath" ) ;
}
if ( string . IsNullOrEmpty ( target ) )
{
throw new ArgumentNullException ( "target" ) ;
}
var extension = Path . GetExtension ( shortcutPath ) ;
var handler = _shortcutHandlers . FirstOrDefault ( i = > string . Equals ( extension , i . Extension , StringComparison . OrdinalIgnoreCase ) ) ;
if ( handler ! = null )
{
handler . Create ( shortcutPath , target ) ;
}
else
{
throw new NotImplementedException ( ) ;
}
}
/// <summary>
/// Returns a <see cref="FileSystemMetadata"/> object for the specified file or directory path.
/// </summary>
/// <param name="path">A path to a file or directory.</param>
/// <returns>A <see cref="FileSystemMetadata"/> object.</returns>
/// <remarks>If the specified path points to a directory, the returned <see cref="FileSystemMetadata"/> object's
/// <see cref="FileSystemMetadata.IsDirectory"/> property will be set to true and all other properties will reflect the properties of the directory.</remarks>
public FileSystemMetadata GetFileSystemInfo ( string path )
{
if ( string . IsNullOrEmpty ( path ) )
{
throw new ArgumentNullException ( "path" ) ;
}
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . GetFileSystemInfo ( path ) ;
}
2016-10-29 05:40:15 +00:00
// Take a guess to try and avoid two file system hits, but we'll double-check by calling Exists
if ( Path . HasExtension ( path ) )
{
var fileInfo = new FileInfo ( path ) ;
if ( fileInfo . Exists )
{
return GetFileSystemMetadata ( fileInfo ) ;
}
return GetFileSystemMetadata ( new DirectoryInfo ( path ) ) ;
}
else
{
var fileInfo = new DirectoryInfo ( path ) ;
if ( fileInfo . Exists )
{
return GetFileSystemMetadata ( fileInfo ) ;
}
return GetFileSystemMetadata ( new FileInfo ( path ) ) ;
}
}
/// <summary>
/// Returns a <see cref="FileSystemMetadata"/> object for the specified file path.
/// </summary>
/// <param name="path">A path to a file.</param>
/// <returns>A <see cref="FileSystemMetadata"/> object.</returns>
/// <remarks><para>If the specified path points to a directory, the returned <see cref="FileSystemMetadata"/> object's
/// <see cref="FileSystemMetadata.IsDirectory"/> property and the <see cref="FileSystemMetadata.Exists"/> property will both be set to false.</para>
/// <para>For automatic handling of files <b>and</b> directories, use <see cref="GetFileSystemInfo"/>.</para></remarks>
public FileSystemMetadata GetFileInfo ( string path )
{
if ( string . IsNullOrEmpty ( path ) )
{
throw new ArgumentNullException ( "path" ) ;
}
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . GetFileInfo ( path ) ;
}
2016-10-29 05:40:15 +00:00
var fileInfo = new FileInfo ( path ) ;
return GetFileSystemMetadata ( fileInfo ) ;
}
/// <summary>
/// Returns a <see cref="FileSystemMetadata"/> object for the specified directory path.
/// </summary>
/// <param name="path">A path to a directory.</param>
/// <returns>A <see cref="FileSystemMetadata"/> object.</returns>
/// <remarks><para>If the specified path points to a file, the returned <see cref="FileSystemMetadata"/> object's
/// <see cref="FileSystemMetadata.IsDirectory"/> property will be set to true and the <see cref="FileSystemMetadata.Exists"/> property will be set to false.</para>
/// <para>For automatic handling of files <b>and</b> directories, use <see cref="GetFileSystemInfo"/>.</para></remarks>
public FileSystemMetadata GetDirectoryInfo ( string path )
{
if ( string . IsNullOrEmpty ( path ) )
{
throw new ArgumentNullException ( "path" ) ;
}
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . GetDirectoryInfo ( path ) ;
}
2016-10-29 05:40:15 +00:00
var fileInfo = new DirectoryInfo ( path ) ;
return GetFileSystemMetadata ( fileInfo ) ;
}
private FileSystemMetadata GetFileSystemMetadata ( FileSystemInfo info )
{
var result = new FileSystemMetadata ( ) ;
result . Exists = info . Exists ;
result . FullName = info . FullName ;
result . Extension = info . Extension ;
result . Name = info . Name ;
if ( result . Exists )
{
var attributes = info . Attributes ;
result . IsDirectory = info is DirectoryInfo | | ( attributes & FileAttributes . Directory ) = = FileAttributes . Directory ;
result . IsHidden = ( attributes & FileAttributes . Hidden ) = = FileAttributes . Hidden ;
result . IsReadOnly = ( attributes & FileAttributes . ReadOnly ) = = FileAttributes . ReadOnly ;
var fileInfo = info as FileInfo ;
if ( fileInfo ! = null )
{
result . Length = fileInfo . Length ;
result . DirectoryName = fileInfo . DirectoryName ;
}
result . CreationTimeUtc = GetCreationTimeUtc ( info ) ;
result . LastWriteTimeUtc = GetLastWriteTimeUtc ( info ) ;
}
else
{
result . IsDirectory = info is DirectoryInfo ;
}
return result ;
}
/// <summary>
/// The space char
/// </summary>
private const char SpaceChar = ' ' ;
/// <summary>
/// Takes a filename and removes invalid characters
/// </summary>
/// <param name="filename">The filename.</param>
/// <returns>System.String.</returns>
/// <exception cref="System.ArgumentNullException">filename</exception>
public string GetValidFilename ( string filename )
{
if ( string . IsNullOrEmpty ( filename ) )
{
throw new ArgumentNullException ( "filename" ) ;
}
var builder = new StringBuilder ( filename ) ;
foreach ( var c in _invalidFileNameChars )
{
builder = builder . Replace ( c , SpaceChar ) ;
}
return builder . ToString ( ) ;
}
/// <summary>
/// Gets the creation time UTC.
/// </summary>
/// <param name="info">The info.</param>
/// <returns>DateTime.</returns>
public DateTime GetCreationTimeUtc ( FileSystemInfo info )
{
// This could throw an error on some file systems that have dates out of range
try
{
return info . CreationTimeUtc ;
}
catch ( Exception ex )
{
Logger . ErrorException ( "Error determining CreationTimeUtc for {0}" , ex , info . FullName ) ;
return DateTime . MinValue ;
}
}
/// <summary>
/// Gets the creation time UTC.
/// </summary>
/// <param name="path">The path.</param>
/// <returns>DateTime.</returns>
public DateTime GetCreationTimeUtc ( string path )
{
return GetCreationTimeUtc ( GetFileSystemInfo ( path ) ) ;
}
public DateTime GetCreationTimeUtc ( FileSystemMetadata info )
{
return info . CreationTimeUtc ;
}
public DateTime GetLastWriteTimeUtc ( FileSystemMetadata info )
{
return info . LastWriteTimeUtc ;
}
/// <summary>
/// Gets the creation time UTC.
/// </summary>
/// <param name="info">The info.</param>
/// <returns>DateTime.</returns>
public DateTime GetLastWriteTimeUtc ( FileSystemInfo info )
{
// This could throw an error on some file systems that have dates out of range
try
{
return info . LastWriteTimeUtc ;
}
catch ( Exception ex )
{
Logger . ErrorException ( "Error determining LastAccessTimeUtc for {0}" , ex , info . FullName ) ;
return DateTime . MinValue ;
}
}
/// <summary>
/// Gets the last write time UTC.
/// </summary>
/// <param name="path">The path.</param>
/// <returns>DateTime.</returns>
public DateTime GetLastWriteTimeUtc ( string path )
{
return GetLastWriteTimeUtc ( GetFileSystemInfo ( path ) ) ;
}
/// <summary>
/// Gets the file stream.
/// </summary>
/// <param name="path">The path.</param>
/// <param name="mode">The mode.</param>
/// <param name="access">The access.</param>
/// <param name="share">The share.</param>
/// <param name="isAsync">if set to <c>true</c> [is asynchronous].</param>
/// <returns>FileStream.</returns>
public Stream GetFileStream ( string path , FileOpenMode mode , FileAccessMode access , FileShareMode share , bool isAsync = false )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . GetFileStream ( path , mode , access , share ) ;
}
2016-10-29 05:40:15 +00:00
if ( _supportsAsyncFileStreams & & isAsync )
{
2017-05-09 18:51:26 +00:00
return GetFileStream ( path , mode , access , share , FileOpenOptions . Asynchronous ) ;
2016-10-29 05:40:15 +00:00
}
2017-05-09 18:51:26 +00:00
return GetFileStream ( path , mode , access , share , FileOpenOptions . None ) ;
}
public Stream GetFileStream ( string path , FileOpenMode mode , FileAccessMode access , FileShareMode share , FileOpenOptions fileOpenOptions )
{
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . GetFileStream ( path , mode , access , share ) ;
}
var defaultBufferSize = 4096 ;
return new FileStream ( path , GetFileMode ( mode ) , GetFileAccess ( access ) , GetFileShare ( share ) , defaultBufferSize , GetFileOptions ( fileOpenOptions ) ) ;
}
private FileOptions GetFileOptions ( FileOpenOptions mode )
{
var val = ( int ) mode ;
return ( FileOptions ) val ;
2016-10-29 05:40:15 +00:00
}
private FileMode GetFileMode ( FileOpenMode mode )
{
switch ( mode )
{
2017-04-02 00:36:06 +00:00
//case FileOpenMode.Append:
// return FileMode.Append;
2016-10-29 05:40:15 +00:00
case FileOpenMode . Create :
return FileMode . Create ;
case FileOpenMode . CreateNew :
return FileMode . CreateNew ;
case FileOpenMode . Open :
return FileMode . Open ;
case FileOpenMode . OpenOrCreate :
return FileMode . OpenOrCreate ;
2017-04-02 00:36:06 +00:00
//case FileOpenMode.Truncate:
// return FileMode.Truncate;
2016-10-29 05:40:15 +00:00
default :
throw new Exception ( "Unrecognized FileOpenMode" ) ;
}
}
private FileAccess GetFileAccess ( FileAccessMode mode )
{
2016-11-27 19:36:56 +00:00
switch ( mode )
{
2017-04-02 00:36:06 +00:00
//case FileAccessMode.ReadWrite:
// return FileAccess.ReadWrite;
2016-11-27 19:36:56 +00:00
case FileAccessMode . Write :
return FileAccess . Write ;
case FileAccessMode . Read :
return FileAccess . Read ;
default :
throw new Exception ( "Unrecognized FileAccessMode" ) ;
}
2016-10-29 05:40:15 +00:00
}
private FileShare GetFileShare ( FileShareMode mode )
{
2016-11-27 19:36:56 +00:00
switch ( mode )
{
case FileShareMode . ReadWrite :
return FileShare . ReadWrite ;
case FileShareMode . Write :
return FileShare . Write ;
case FileShareMode . Read :
return FileShare . Read ;
case FileShareMode . None :
return FileShare . None ;
default :
throw new Exception ( "Unrecognized FileShareMode" ) ;
}
2016-10-29 05:40:15 +00:00
}
public void SetHidden ( string path , bool isHidden )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
_sharpCifsFileSystem . SetHidden ( path , isHidden ) ;
return ;
}
2016-10-29 05:40:15 +00:00
var info = GetFileInfo ( path ) ;
if ( info . Exists & & info . IsHidden ! = isHidden )
{
if ( isHidden )
{
2016-10-31 04:28:23 +00:00
File . SetAttributes ( path , File . GetAttributes ( path ) | FileAttributes . Hidden ) ;
2016-10-29 05:40:15 +00:00
}
else
{
2016-10-31 04:28:23 +00:00
FileAttributes attributes = File . GetAttributes ( path ) ;
attributes = RemoveAttribute ( attributes , FileAttributes . Hidden ) ;
File . SetAttributes ( path , attributes ) ;
2016-10-29 05:40:15 +00:00
}
}
}
2016-11-09 17:24:57 +00:00
public void SetReadOnly ( string path , bool isReadOnly )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
_sharpCifsFileSystem . SetReadOnly ( path , isReadOnly ) ;
return ;
}
2016-11-09 17:24:57 +00:00
var info = GetFileInfo ( path ) ;
if ( info . Exists & & info . IsReadOnly ! = isReadOnly )
{
if ( isReadOnly )
{
File . SetAttributes ( path , File . GetAttributes ( path ) | FileAttributes . ReadOnly ) ;
}
else
{
FileAttributes attributes = File . GetAttributes ( path ) ;
attributes = RemoveAttribute ( attributes , FileAttributes . ReadOnly ) ;
File . SetAttributes ( path , attributes ) ;
}
}
}
2017-05-12 04:54:19 +00:00
public void SetAttributes ( string path , bool isHidden , bool isReadOnly )
{
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
_sharpCifsFileSystem . SetAttributes ( path , isHidden , isReadOnly ) ;
return ;
}
var info = GetFileInfo ( path ) ;
if ( ! info . Exists )
{
return ;
}
if ( info . IsReadOnly = = isReadOnly & & info . IsHidden = = isHidden )
{
return ;
}
var attributes = File . GetAttributes ( path ) ;
if ( isReadOnly )
{
attributes = attributes | FileAttributes . ReadOnly ;
}
else
{
attributes = RemoveAttribute ( attributes , FileAttributes . ReadOnly ) ;
}
if ( isHidden )
{
attributes = attributes | FileAttributes . Hidden ;
}
else
{
attributes = RemoveAttribute ( attributes , FileAttributes . Hidden ) ;
}
File . SetAttributes ( path , attributes ) ;
}
2016-10-29 05:40:15 +00:00
private static FileAttributes RemoveAttribute ( FileAttributes attributes , FileAttributes attributesToRemove )
{
return attributes & ~ attributesToRemove ;
}
/// <summary>
/// Swaps the files.
/// </summary>
/// <param name="file1">The file1.</param>
/// <param name="file2">The file2.</param>
public void SwapFiles ( string file1 , string file2 )
{
if ( string . IsNullOrEmpty ( file1 ) )
{
throw new ArgumentNullException ( "file1" ) ;
}
if ( string . IsNullOrEmpty ( file2 ) )
{
throw new ArgumentNullException ( "file2" ) ;
}
2017-01-23 21:51:23 +00:00
var temp1 = Path . Combine ( _tempPath , Guid . NewGuid ( ) . ToString ( "N" ) ) ;
2016-10-29 05:40:15 +00:00
// Copying over will fail against hidden files
2016-12-27 07:25:51 +00:00
SetHidden ( file1 , false ) ;
SetHidden ( file2 , false ) ;
2016-10-29 05:40:15 +00:00
2017-01-23 21:51:23 +00:00
Directory . CreateDirectory ( _tempPath ) ;
2016-10-29 05:40:15 +00:00
CopyFile ( file1 , temp1 , true ) ;
2016-12-17 20:52:05 +00:00
CopyFile ( file2 , file1 , true ) ;
2016-10-29 05:40:15 +00:00
CopyFile ( temp1 , file2 , true ) ;
}
2017-04-02 04:45:57 +00:00
private char GetDirectorySeparatorChar ( string path )
2017-04-02 04:08:07 +00:00
{
2017-04-02 04:45:57 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
2017-04-02 04:08:07 +00:00
{
2017-04-02 04:45:57 +00:00
return _sharpCifsFileSystem . GetDirectorySeparatorChar ( path ) ;
2017-04-02 04:08:07 +00:00
}
2017-04-02 04:45:57 +00:00
return Path . DirectorySeparatorChar ;
2017-04-02 04:08:07 +00:00
}
2016-10-29 05:40:15 +00:00
public bool ContainsSubPath ( string parentPath , string path )
{
if ( string . IsNullOrEmpty ( parentPath ) )
{
throw new ArgumentNullException ( "parentPath" ) ;
}
if ( string . IsNullOrEmpty ( path ) )
{
throw new ArgumentNullException ( "path" ) ;
}
2017-04-02 04:45:57 +00:00
var separatorChar = GetDirectorySeparatorChar ( parentPath ) ;
2017-04-02 04:08:07 +00:00
return path . IndexOf ( parentPath . TrimEnd ( separatorChar ) + separatorChar , StringComparison . OrdinalIgnoreCase ) ! = - 1 ;
2016-10-29 05:40:15 +00:00
}
public bool IsRootPath ( string path )
{
if ( string . IsNullOrEmpty ( path ) )
{
throw new ArgumentNullException ( "path" ) ;
}
2017-05-04 18:14:45 +00:00
var parent = GetDirectoryName ( path ) ;
2016-10-29 05:40:15 +00:00
if ( ! string . IsNullOrEmpty ( parent ) )
{
return false ;
}
return true ;
}
2017-05-04 18:14:45 +00:00
public string GetDirectoryName ( string path )
{
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . GetDirectoryName ( path ) ;
}
return Path . GetDirectoryName ( path ) ;
}
2016-10-29 05:40:15 +00:00
public string NormalizePath ( string path )
{
if ( string . IsNullOrEmpty ( path ) )
{
throw new ArgumentNullException ( "path" ) ;
}
2017-05-04 18:14:45 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . NormalizePath ( path ) ;
}
2016-10-29 05:40:15 +00:00
if ( path . EndsWith ( ":\\" , StringComparison . OrdinalIgnoreCase ) )
{
return path ;
}
2017-04-02 04:45:57 +00:00
return path . TrimEnd ( GetDirectorySeparatorChar ( path ) ) ;
2016-10-29 05:40:15 +00:00
}
2017-05-04 18:14:45 +00:00
public bool AreEqual ( string path1 , string path2 )
{
if ( path1 = = null & & path2 = = null )
{
return true ;
}
if ( path1 = = null | | path2 = = null )
{
return false ;
}
return string . Equals ( NormalizePath ( path1 ) , NormalizePath ( path2 ) , StringComparison . OrdinalIgnoreCase ) ;
}
2016-10-29 05:40:15 +00:00
public string GetFileNameWithoutExtension ( FileSystemMetadata info )
{
if ( info . IsDirectory )
{
return info . Name ;
}
return Path . GetFileNameWithoutExtension ( info . FullName ) ;
}
public string GetFileNameWithoutExtension ( string path )
{
return Path . GetFileNameWithoutExtension ( path ) ;
}
public bool IsPathFile ( string path )
{
if ( string . IsNullOrWhiteSpace ( path ) )
{
throw new ArgumentNullException ( "path" ) ;
}
// Cannot use Path.IsPathRooted because it returns false under mono when using windows-based paths, e.g. C:\\
2017-05-04 18:14:45 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return true ;
}
2016-10-29 05:40:15 +00:00
if ( path . IndexOf ( "://" , StringComparison . OrdinalIgnoreCase ) ! = - 1 & &
! path . StartsWith ( "file://" , StringComparison . OrdinalIgnoreCase ) )
{
return false ;
}
2017-05-04 18:14:45 +00:00
2016-10-29 05:40:15 +00:00
return true ;
//return Path.IsPathRooted(path);
}
public void DeleteFile ( string path )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
_sharpCifsFileSystem . DeleteFile ( path ) ;
return ;
}
2017-05-12 04:54:19 +00:00
SetAttributes ( path , false , false ) ;
2016-10-29 05:40:15 +00:00
File . Delete ( path ) ;
}
public void DeleteDirectory ( string path , bool recursive )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
_sharpCifsFileSystem . DeleteDirectory ( path , recursive ) ;
return ;
}
2016-10-29 05:40:15 +00:00
Directory . Delete ( path , recursive ) ;
}
public void CreateDirectory ( string path )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
_sharpCifsFileSystem . CreateDirectory ( path ) ;
return ;
}
2016-10-29 05:40:15 +00:00
Directory . CreateDirectory ( path ) ;
}
2016-11-01 03:07:45 +00:00
public List < FileSystemMetadata > GetDrives ( )
{
// Only include drives in the ready state or this method could end up being very slow, waiting for drives to timeout
return DriveInfo . GetDrives ( ) . Where ( d = > d . IsReady ) . Select ( d = > new FileSystemMetadata
{
Name = GetName ( d ) ,
FullName = d . RootDirectory . FullName ,
IsDirectory = true
} ) . ToList ( ) ;
}
private string GetName ( DriveInfo drive )
{
return drive . Name ;
}
2016-10-29 05:40:15 +00:00
public IEnumerable < FileSystemMetadata > GetDirectories ( string path , bool recursive = false )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . GetDirectories ( path , recursive ) ;
}
2016-10-29 05:40:15 +00:00
var searchOption = recursive ? SearchOption . AllDirectories : SearchOption . TopDirectoryOnly ;
2017-03-29 06:26:48 +00:00
return ToMetadata ( new DirectoryInfo ( path ) . EnumerateDirectories ( "*" , searchOption ) ) ;
2016-10-29 05:40:15 +00:00
}
public IEnumerable < FileSystemMetadata > GetFiles ( string path , bool recursive = false )
2017-03-29 06:26:48 +00:00
{
2017-03-30 17:56:32 +00:00
return GetFiles ( path , null , false , recursive ) ;
2017-03-29 06:26:48 +00:00
}
public IEnumerable < FileSystemMetadata > GetFiles ( string path , string [ ] extensions , bool enableCaseSensitiveExtensions , bool recursive = false )
2016-10-29 05:40:15 +00:00
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . GetFiles ( path , extensions , enableCaseSensitiveExtensions , recursive ) ;
}
2016-10-29 05:40:15 +00:00
var searchOption = recursive ? SearchOption . AllDirectories : SearchOption . TopDirectoryOnly ;
2017-03-29 06:26:48 +00:00
// On linux and osx the search pattern is case sensitive
// If we're OK with case-sensitivity, and we're only filtering for one extension, then use the native method
if ( enableCaseSensitiveExtensions & & extensions ! = null & & extensions . Length = = 1 )
{
return ToMetadata ( new DirectoryInfo ( path ) . EnumerateFiles ( "*" + extensions [ 0 ] , searchOption ) ) ;
}
var files = new DirectoryInfo ( path ) . EnumerateFiles ( "*" , searchOption ) ;
if ( extensions ! = null & & extensions . Length > 0 )
{
files = files . Where ( i = >
{
var ext = i . Extension ;
if ( ext = = null )
{
return false ;
}
return extensions . Contains ( ext , StringComparer . OrdinalIgnoreCase ) ;
} ) ;
}
return ToMetadata ( files ) ;
2016-10-29 05:40:15 +00:00
}
public IEnumerable < FileSystemMetadata > GetFileSystemEntries ( string path , bool recursive = false )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . GetFileSystemEntries ( path , recursive ) ;
}
2016-10-29 05:40:15 +00:00
var directoryInfo = new DirectoryInfo ( path ) ;
var searchOption = recursive ? SearchOption . AllDirectories : SearchOption . TopDirectoryOnly ;
if ( EnableFileSystemRequestConcat )
{
2017-03-29 06:26:48 +00:00
return ToMetadata ( directoryInfo . EnumerateDirectories ( "*" , searchOption ) )
. Concat ( ToMetadata ( directoryInfo . EnumerateFiles ( "*" , searchOption ) ) ) ;
2016-10-29 05:40:15 +00:00
}
2017-03-29 06:26:48 +00:00
return ToMetadata ( directoryInfo . EnumerateFileSystemInfos ( "*" , searchOption ) ) ;
2016-10-29 05:40:15 +00:00
}
2017-03-29 06:26:48 +00:00
private IEnumerable < FileSystemMetadata > ToMetadata ( IEnumerable < FileSystemInfo > infos )
2016-10-29 05:40:15 +00:00
{
2017-01-23 21:51:23 +00:00
return infos . Select ( GetFileSystemMetadata ) ;
2016-10-29 05:40:15 +00:00
}
2016-11-04 08:43:59 +00:00
public string [ ] ReadAllLines ( string path )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . ReadAllLines ( path ) ;
}
2016-11-04 08:43:59 +00:00
return File . ReadAllLines ( path ) ;
}
public void WriteAllLines ( string path , IEnumerable < string > lines )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
_sharpCifsFileSystem . WriteAllLines ( path , lines ) ;
return ;
}
2016-11-04 08:43:59 +00:00
File . WriteAllLines ( path , lines ) ;
}
2016-10-29 05:40:15 +00:00
public Stream OpenRead ( string path )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . OpenRead ( path ) ;
}
2016-10-29 05:40:15 +00:00
return File . OpenRead ( path ) ;
}
public void CopyFile ( string source , string target , bool overwrite )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( source ) )
{
_sharpCifsFileSystem . CopyFile ( source , target , overwrite ) ;
return ;
}
2016-10-29 05:40:15 +00:00
File . Copy ( source , target , overwrite ) ;
}
public void MoveFile ( string source , string target )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( source ) )
{
_sharpCifsFileSystem . MoveFile ( source , target ) ;
return ;
}
2016-10-29 05:40:15 +00:00
File . Move ( source , target ) ;
}
public void MoveDirectory ( string source , string target )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( source ) )
{
_sharpCifsFileSystem . MoveDirectory ( source , target ) ;
return ;
}
2016-10-29 05:40:15 +00:00
Directory . Move ( source , target ) ;
}
public bool DirectoryExists ( string path )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . DirectoryExists ( path ) ;
}
2016-10-29 05:40:15 +00:00
return Directory . Exists ( path ) ;
}
public bool FileExists ( string path )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . FileExists ( path ) ;
}
2016-10-29 05:40:15 +00:00
return File . Exists ( path ) ;
}
public string ReadAllText ( string path )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . ReadAllText ( path ) ;
}
2016-10-29 05:40:15 +00:00
return File . ReadAllText ( path ) ;
}
public byte [ ] ReadAllBytes ( string path )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . ReadAllBytes ( path ) ;
}
2016-10-29 05:40:15 +00:00
return File . ReadAllBytes ( path ) ;
}
public void WriteAllText ( string path , string text , Encoding encoding )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
_sharpCifsFileSystem . WriteAllText ( path , text , encoding ) ;
return ;
}
2016-10-29 05:40:15 +00:00
File . WriteAllText ( path , text , encoding ) ;
}
public void WriteAllText ( string path , string text )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
_sharpCifsFileSystem . WriteAllText ( path , text ) ;
return ;
}
2016-10-29 05:40:15 +00:00
File . WriteAllText ( path , text ) ;
}
public void WriteAllBytes ( string path , byte [ ] bytes )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
_sharpCifsFileSystem . WriteAllBytes ( path , bytes ) ;
return ;
}
2016-10-29 05:40:15 +00:00
File . WriteAllBytes ( path , bytes ) ;
}
public string ReadAllText ( string path , Encoding encoding )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . ReadAllText ( path , encoding ) ;
}
2016-10-29 05:40:15 +00:00
return File . ReadAllText ( path , encoding ) ;
}
public IEnumerable < string > GetDirectoryPaths ( string path , bool recursive = false )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . GetDirectoryPaths ( path , recursive ) ;
}
2016-10-29 05:40:15 +00:00
var searchOption = recursive ? SearchOption . AllDirectories : SearchOption . TopDirectoryOnly ;
return Directory . EnumerateDirectories ( path , "*" , searchOption ) ;
}
public IEnumerable < string > GetFilePaths ( string path , bool recursive = false )
2017-03-30 17:56:32 +00:00
{
return GetFilePaths ( path , null , false , recursive ) ;
}
public IEnumerable < string > GetFilePaths ( string path , string [ ] extensions , bool enableCaseSensitiveExtensions , bool recursive = false )
2016-10-29 05:40:15 +00:00
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . GetFilePaths ( path , extensions , enableCaseSensitiveExtensions , recursive ) ;
}
2016-10-29 05:40:15 +00:00
var searchOption = recursive ? SearchOption . AllDirectories : SearchOption . TopDirectoryOnly ;
2017-03-30 17:56:32 +00:00
// On linux and osx the search pattern is case sensitive
// If we're OK with case-sensitivity, and we're only filtering for one extension, then use the native method
if ( enableCaseSensitiveExtensions & & extensions ! = null & & extensions . Length = = 1 )
{
return Directory . EnumerateFiles ( path , "*" + extensions [ 0 ] , searchOption ) ;
}
var files = Directory . EnumerateFiles ( path , "*" , searchOption ) ;
if ( extensions ! = null & & extensions . Length > 0 )
{
files = files . Where ( i = >
{
var ext = Path . GetExtension ( i ) ;
if ( ext = = null )
{
return false ;
}
return extensions . Contains ( ext , StringComparer . OrdinalIgnoreCase ) ;
} ) ;
}
return files ;
2016-10-29 05:40:15 +00:00
}
public IEnumerable < string > GetFileSystemEntryPaths ( string path , bool recursive = false )
{
2017-04-02 00:36:06 +00:00
if ( _sharpCifsFileSystem . IsEnabledForPath ( path ) )
{
return _sharpCifsFileSystem . GetFileSystemEntryPaths ( path , recursive ) ;
}
2016-10-29 05:40:15 +00:00
var searchOption = recursive ? SearchOption . AllDirectories : SearchOption . TopDirectoryOnly ;
return Directory . EnumerateFileSystemEntries ( path , "*" , searchOption ) ;
}
2016-11-11 07:24:36 +00:00
public virtual void SetExecutable ( string path )
{
2017-10-04 18:51:26 +00:00
if ( _environmentInfo . OperatingSystem = = MediaBrowser . Model . System . OperatingSystem . OSX )
{
RunProcess ( "chmod" , "+x \"" + path + "\"" , GetDirectoryName ( path ) ) ;
}
}
2017-03-29 06:26:48 +00:00
2017-10-04 18:51:26 +00:00
private void RunProcess ( string path , string args , string workingDirectory )
{
using ( var process = Process . Start ( new ProcessStartInfo
{
Arguments = args ,
FileName = path ,
CreateNoWindow = true ,
WorkingDirectory = workingDirectory ,
WindowStyle = ProcessWindowStyle . Normal
} ) )
{
process . WaitForExit ( ) ;
}
2016-11-11 07:24:36 +00:00
}
2016-10-29 05:40:15 +00:00
}
}