// TestFileIO.cpp
//------------------------------------------------------------------------------

// Includes
//------------------------------------------------------------------------------
#include "TestFramework/TestGroup.h"

// Core
#include "Core/Containers/UniquePtr.h"
#if defined( __WINDOWS__ )
    #include "Core/Env/WindowsHeader.h"
#endif
#include "Core/FileIO/FileIO.h"
#include "Core/FileIO/FileStream.h"
#include "Core/Math/Random.h"
#include "Core/Process/Process.h"
#include "Core/Process/Thread.h"
#include "Core/Strings/AStackString.h"
#include "Core/Tracing/Tracing.h"

// system
#include <string.h>
#if defined( __LINUX__ )
    #include <unistd.h>
#endif

//------------------------------------------------------------------------------
TEST_GROUP( TestFileIO, TestGroupTest )
{
public:
    // Helpers
    mutable Random m_Random;
    void GenerateTempFileName( AString & tmpFileName ) const;
};

//------------------------------------------------------------------------------
TEST_CASE( TestFileIO, FileExists )
{
    // generate a process unique file path
    AStackString path;
    GenerateTempFileName( path );

    // File
    {
        // ensure doesn't exist
        FileIO::FileDelete( path.Get() ); // delete in case left over from previous test run
        TEST_ASSERT( FileIO::FileExists( path.Get() ) == false );

        // create it
        FileStream f;
        TEST_ASSERT( f.Open( path.Get(), FileStream::WRITE_ONLY ) == true );
        f.Close();

        // ensure exists
        TEST_ASSERT( FileIO::FileExists( path.Get() ) == true );

        // clean up
        TEST_ASSERT( FileIO::FileDelete( path.Get() ) == true );
        TEST_ASSERT( FileIO::FileExists( path.Get() ) == false );
    }

    // Folder
    {
        // Create a directory
        AStackString dirPath( path );
        dirPath += "_dir";
        FileIO::DirectoryCreate( dirPath );
        TEST_ASSERT( FileIO::DirectoryExists( dirPath ) );

        // Ensure FileExists returns false if passed the directory path
        TEST_ASSERT( FileIO::FileExists( dirPath.Get() ) == false );
    }
}

//------------------------------------------------------------------------------
TEST_CASE( TestFileIO, FileDelete )
{
    // generate a process unique file path
    AStackString path;
    GenerateTempFileName( path );

    // create it
    FileStream f;
    TEST_ASSERT( f.Open( path.Get(), FileStream::WRITE_ONLY ) == true );
    f.Close();

    // ensure exists
    TEST_ASSERT( FileIO::FileExists( path.Get() ) == true );

    // delete
    TEST_ASSERT( FileIO::FileDelete( path.Get() ) == true );
    TEST_ASSERT( FileIO::FileExists( path.Get() ) == false );
}

//------------------------------------------------------------------------------
TEST_CASE( TestFileIO, FileCopy )
{
    // generate a process unique file path
    AStackString path;
    GenerateTempFileName( path );

    // generate copy file name
    AStackString pathCopy( path );
    pathCopy += ".copy";

    // make sure nothing is left from previous runs
    FileIO::FileDelete( path.Get() );
    FileIO::FileDelete( pathCopy.Get() );
    TEST_ASSERT( FileIO::FileExists( path.Get() ) == false );
    TEST_ASSERT( FileIO::FileExists( pathCopy.Get() ) == false );

    // create it
    FileStream f;
    TEST_ASSERT( f.Open( path.Get(), FileStream::WRITE_ONLY ) == true );
    f.Close();

    // copy it
    TEST_ASSERT( FileIO::FileCopy( path.Get(), pathCopy.Get() ) );
    TEST_ASSERT( FileIO::FileExists( pathCopy.Get() ) == true );

    // ensure attributes are transferred properly
    FileIO::FileInfo sourceInfo;
    TEST_ASSERT( FileIO::GetFileInfo( path, sourceInfo ) == true );
    FileIO::FileInfo destInfo;
    TEST_ASSERT( FileIO::GetFileInfo( pathCopy, destInfo ) == true );
    TEST_ASSERT( destInfo.m_Attributes == sourceInfo.m_Attributes );

    // copy without overwrite allowed should fail
    const bool allowOverwrite = false;
    TEST_ASSERT( FileIO::FileCopy( path.Get(), pathCopy.Get(), allowOverwrite ) == false );

    // cleanup
    VERIFY( FileIO::FileDelete( path.Get() ) );
    VERIFY( FileIO::FileDelete( pathCopy.Get() ) );
}

//------------------------------------------------------------------------------
TEST_CASE( TestFileIO, FileCopySymlink )
{
#if defined( __WINDOWS__ ) || defined( __APPLE__ )
    // Not tested on Windows/MacOS as symlinks are directly supported
    // by the file copy API.  Also on Windows, it would make unit
    // tests require administrator privileges.
#elif defined( __LINUX__ )
    AStackString symlinkTarget( "symlink" );

    // generate a process unique file path
    AStackString path;
    GenerateTempFileName( path );

    // generate copy file name
    AStackString pathCopy( path );
    pathCopy += ".copy";

    // make sure nothing is left from previous runs
    FileIO::FileDelete( path.Get() );
    FileIO::FileDelete( pathCopy.Get() );
    TEST_ASSERT( FileIO::FileExists( path.Get() ) == false );
    TEST_ASSERT( FileIO::FileExists( pathCopy.Get() ) == false );

    // create it
    TEST_ASSERT( symlink( symlinkTarget.Get(), path.Get() ) == 0 );

    // copy it
    TEST_ASSERT( FileIO::FileCopy( path.Get(), pathCopy.Get() ) );
    TEST_ASSERT( FileIO::FileExists( pathCopy.Get() ) == true );

    // validate link
    AStackString linkPath;
    ssize_t length = readlink( pathCopy.Get(), linkPath.Get(), linkPath.GetReserved() );
    TEST_ASSERT( length == symlinkTarget.GetLength() );
    linkPath.SetLength( length );
    TEST_ASSERT( linkPath == symlinkTarget );

    // ensure attributes are transferred properly
    FileIO::FileInfo sourceInfo;
    TEST_ASSERT( FileIO::GetFileInfo( path, sourceInfo ) == true );
    FileIO::FileInfo destInfo;
    TEST_ASSERT( FileIO::GetFileInfo( pathCopy, destInfo ) == true );
    TEST_ASSERT( destInfo.m_Attributes == sourceInfo.m_Attributes );

    // copy without overwrite allowed should fail
    const bool allowOverwrite = false;
    TEST_ASSERT( FileIO::FileCopy( path.Get(), pathCopy.Get(), allowOverwrite ) == false );

    // cleanup
    VERIFY( FileIO::FileDelete( path.Get() ) );
    VERIFY( FileIO::FileDelete( pathCopy.Get() ) );
#else
    #error Unknown platform
#endif
}

//------------------------------------------------------------------------------
TEST_CASE( TestFileIO, FileMove )
{
    // generate a process unique file path
    AStackString path;
    GenerateTempFileName( path );

    // generate copy file name
    AStackString pathCopy( path );
    pathCopy += ".copy";

    // make sure nothing is left from previous runs
    FileIO::FileDelete( path.Get() );
    FileIO::FileDelete( pathCopy.Get() );

    // create it
    FileStream f;
    TEST_ASSERT( f.Open( path.Get(), FileStream::WRITE_ONLY ) == true );
    f.Close();

    // move it
    TEST_ASSERT( FileIO::FileMove( path, pathCopy ) );
    TEST_ASSERT( FileIO::FileExists( path.Get() ) == false );
    TEST_ASSERT( FileIO::FileExists( pathCopy.Get() ) == true );

    // cleanup
    VERIFY( FileIO::FileDelete( pathCopy.Get() ) );
}

//------------------------------------------------------------------------------
TEST_CASE( TestFileIO, ReadOnly )
{
    // generate a process unique file path
    AStackString path;
    GenerateTempFileName( path );

    // create it
    FileStream f;
    TEST_ASSERT( f.Open( path.Get(), FileStream::WRITE_ONLY ) == true );
    f.Close();

    // should not be read only
    TEST_ASSERT( FileIO::GetReadOnly( path ) == false );

    // set readonly
    TEST_ASSERT( FileIO::SetReadOnly( path.Get(), true ) == true );

    // should be read only
    TEST_ASSERT( FileIO::GetReadOnly( path ) == true );

    // delete should fail
    TEST_ASSERT( FileIO::FileDelete( path.Get() ) == false );

    // clean up
    TEST_ASSERT( FileIO::SetReadOnly( path.Get(), false ) == true );
    TEST_ASSERT( FileIO::GetReadOnly( path ) == false );
    TEST_ASSERT( FileIO::FileDelete( path.Get() ) == true );
}

//------------------------------------------------------------------------------
TEST_CASE( TestFileIO, FileTime )
{
    // generate a process unique file path
    AStackString path;
    GenerateTempFileName( path );

    // create it
    FileStream f;
    TEST_ASSERT( f.Open( path.Get(), FileStream::WRITE_ONLY ) == true );
    f.Close();

    // get last write time
    const uint64_t oldTime = FileIO::GetFileLastWriteTime( path );
    TEST_ASSERT( oldTime != 0 );

    // Modify the file until the filetime changes. This can be surprisingly
    // long on OSX due to poor HFS+ filetime granularity
    uint64_t newTime = 0;
    for ( ;; )
    {
        Thread::Sleep( 10 );

        // modify file
        FileStream f2;
        TEST_ASSERT( f.Open( path.Get(), FileStream::WRITE_ONLY ) == true );
        f.Write( (uint32_t)0 );
        f.Close();

        // get new last write time
        newTime = FileIO::GetFileLastWriteTime( path );
        if ( newTime > oldTime )
        {
            break;
        }
    }

    // manually set time back
    TEST_ASSERT( FileIO::SetFileLastWriteTime( path, oldTime ) == true );
    const uint64_t timeNow = FileIO::GetFileLastWriteTime( path );
    TEST_ASSERT( timeNow == oldTime );
}

//------------------------------------------------------------------------------
TEST_CASE( TestFileIO, LongPaths )
{
    //
    // Ensure long paths are correctly handled by various functions
    //

#if defined( __WINDOWS__ )
    // On Windows, long path support must be enabled via a registry key
    // Only if this is enabled can we expect our test to pass
    if ( FileIO::IsWindowsLongPathSupportEnabled() == false )
    {
        return;
    }
#endif

    // Constants used to build long paths
    AString a( 255 );
    AString b( 255 );
    for ( size_t i = 0; i < 255; ++i )
    {
        a += 'a';
        b += 'B';
    }

    // We'll operate in the tmp dir under a long sub folder (256 chars long)
    AStackString tmpPath1;
    AStackString tmpPath2;
    {
        VERIFY( FileIO::GetTempDir( tmpPath1 ) );
        tmpPath1 += "CoreTest_TestFileIO";
        tmpPath2.Format( "%s/%s", tmpPath1.Get(), a.Get() );
        TEST_ASSERT( tmpPath2.GetLength() > 260 );
    }

    // Create some file paths to work with
    AStackString filePathA;
    AStackString filePathB;
    AStackString subDir1;
    AStackString subDir2;
    AStackString filePathC;
    {
        // long file name A
        filePathA.Format( "%s/%s", tmpPath2.Get(), b.Get() );
        TEST_ASSERT( filePathA.GetLength() == ( tmpPath2.GetLength() + 1 + 255 ) );

        // long file name B
        filePathB = filePathA;
        filePathB.Trim( 0, 5 );
        filePathB += ".copy";
        TEST_ASSERT( filePathB.GetLength() == ( filePathA.GetLength() ) );

        // long subdir 1
        subDir1.Format( "%s/%s", tmpPath2.Get(), a.Get() );
        TEST_ASSERT( subDir1.GetLength() == ( tmpPath2.GetLength() + 1 + 255 ) );

        // long file name C
        filePathC.Format( "%s/%s", subDir1.Get(), b.Get() );
        TEST_ASSERT( filePathC.GetLength() == ( subDir1.GetLength() + 1 + 255 ) );

        // long subdir 2
        subDir2 = subDir1.Get();
        subDir2.Trim( 0, 2 );
        subDir2 += ".2";
        TEST_ASSERT( subDir2.GetLength() == subDir1.GetLength() );
    }

    // Cleanup anything left over from previous runs
    {
        FileIO::FileDelete( filePathA.Get() );
        FileIO::FileDelete( filePathB.Get() );
        FileIO::FileDelete( filePathC.Get() );
        FileIO::DirectoryDelete( subDir1 );
        FileIO::DirectoryDelete( subDir2 );
        FileIO::DirectoryDelete( tmpPath2 );
        FileIO::DirectoryDelete( tmpPath1 );
    }

    // EnsurePathExists (tmp)
    TEST_ASSERT( FileIO::EnsurePathExists( tmpPath2 ) );

    // Create a file (A)
    {
        FileStream f;
        TEST_ASSERT( f.Open( filePathA.Get(), FileStream::WRITE_ONLY ) );
    }

    // FileExists (A)
    TEST_ASSERT( FileIO::FileExists( filePathA.Get() ) );

    // Get/SetFileLastWriteTime
    {
        const uint64_t time = FileIO::GetFileLastWriteTime( filePathA );
        ASSERT( time != 0 );
        FileIO::SetFileLastWriteTime( filePathA, time );
    }

    // SetFileLastWriteTimeToNow
    TEST_ASSERT( FileIO::SetFileLastWriteTimeToNow( filePathA ) );

    // Get/SetReadOnly
    {
        TEST_ASSERT( FileIO::GetReadOnly( filePathA ) == false );
        TEST_ASSERT( FileIO::SetReadOnly( filePathA.Get(), true ) );
        TEST_ASSERT( FileIO::SetReadOnly( filePathA.Get(), false ) );
    }

    // EnsurePathExistsForFile (C) (subdir 1)
    TEST_ASSERT( FileIO::EnsurePathExistsForFile( filePathC ) );

    // FileCopy (A -> C)
    TEST_ASSERT( FileIO::FileCopy( filePathA.Get(), filePathC.Get() ) );

    // FileMove (C -> B)
    TEST_ASSERT( FileIO::FileExists( filePathC.Get() ) );
    TEST_ASSERT( FileIO::FileExists( filePathB.Get() ) == false );
    TEST_ASSERT( FileIO::FileMove( filePathC, filePathB ) );

    // DirectoryCreate (2)
    TEST_ASSERT( FileIO::DirectoryCreate( subDir2 ) );

    // DirectoryExists (2)
    TEST_ASSERT( FileIO::DirectoryExists( subDir2 ) );

    // GetFiles
    {
        StackArray<AString> files;
        TEST_ASSERT( FileIO::GetFiles( tmpPath1, AStackString( "*" ), true, &files ) );
        TEST_ASSERT( files.GetSize() == 2 );
        files.Sort();
        TEST_ASSERT( files[ 0 ].EndsWith( filePathB.FindLast( '/' ) + 1 ) );
        TEST_ASSERT( files[ 1 ].EndsWith( filePathA.FindLast( '/' ) + 1 ) );
    }

    // Get/SetCurrentDir
    {
        AStackString original;
        TEST_ASSERT( FileIO::GetCurrentDir( original ) );
        TEST_ASSERT( FileIO::SetCurrentDir( tmpPath2 ) );
        TEST_ASSERT( FileIO::SetCurrentDir( original ) );
    }

    // FileDelete
    TEST_ASSERT( FileIO::FileDelete( filePathA.Get() ) );
    TEST_ASSERT( FileIO::FileDelete( filePathB.Get() ) );

    // DirectoryDelete
    TEST_ASSERT( FileIO::DirectoryDelete( subDir1 ) );
    TEST_ASSERT( FileIO::DirectoryDelete( subDir2 ) );
    TEST_ASSERT( FileIO::DirectoryDelete( tmpPath2 ) );
    TEST_ASSERT( FileIO::DirectoryDelete( tmpPath1 ) );
}

// GenerateTempFileName
//------------------------------------------------------------------------------
void TestFileIO::GenerateTempFileName( AString & tmpFileName ) const
{
    // get system temp folder
    VERIFY( FileIO::GetTempDir( tmpFileName ) );

    // add process unique identifier
    AStackString buffer;
    buffer.Format( "TestFileIO.%u.%u", Process::GetCurrentId(), m_Random.GetRand() );
    tmpFileName += buffer;
}

//------------------------------------------------------------------------------
#if defined( __WINDOWS__ )
TEST_CASE( TestFileIO, NormalizeWindowsPathCasing )
{
    #define CHECK_NORMALIZATION( badPath, expectedPath ) \
            do \
            { \
                AStackString normalizedPath; \
                TEST_ASSERT( FileIO::NormalizeWindowsPathCasing( AStackString( badPath ), normalizedPath ) ); \
                TEST_ASSERT( normalizedPath == expectedPath ); \
            } while ( false )

    // Out test needs to rely on some generally available directory.
    // While technically Windows can be installed on different drives or folders
    // it's reasonable for our test to not support that.
    TEST_ASSERT( FileIO::DirectoryExists( AStackString( "C:\\Windows" ) ) );

    // Folder parts get the actual case of folders on disk
    CHECK_NORMALIZATION( "C:\\WINDOWS", "C:\\Windows" );
    CHECK_NORMALIZATION( "C:\\windows\\sySTem32", "C:\\Windows\\System32" );

    // Drive letters are upper-case
    CHECK_NORMALIZATION( "c:\\Windows", "C:\\Windows" );
    CHECK_NORMALIZATION( "c:\\Windows", "C:\\Windows" );

    // Drive only
    CHECK_NORMALIZATION( "C:\\", "C:\\" );
    CHECK_NORMALIZATION( "c:\\", "C:\\" );

    // Paths that partially exist have the parts that exist fixed up
    // but the parts that don't left alone
    CHECK_NORMALIZATION( "c:\\winDOWs\\FolderThatDoesNotExist", "C:\\Windows\\FolderThatDoesNotExist" );

    #undef CHECK_NORMALIZATION
}
#endif

//------------------------------------------------------------------------------
TEST_CASE( TestFileIO, CreateOrOpenReadWrite )
{
    // generate a process unique file path
    AStackString path;
    GenerateTempFileName( path );

    // Make sure file does not exist (handle potential previous failed runs)
    FileIO::FileDelete( path.Get() );
    TEST_ASSERT( FileIO::FileExists( path.Get() ) == false );

    // Ensure file is created when it doesn't exist
    uint64_t fileSize = 0;
    {
        FileStream f;
        TEST_ASSERT( f.Open( path.Get(), FileStream::FileMode::OPEN_OR_CREATE_READ_WRITE ) );

        // Write some content
        TEST_ASSERT( f.Write( path ) );
        fileSize = f.GetFileSize();
        TEST_ASSERT( fileSize >= path.GetLength() ); // String length plus content
        TEST_ASSERT( fileSize == f.Tell() );

        // Read it back
        AStackString pathCopy;
        TEST_ASSERT( f.Seek( 0 ) );
        TEST_ASSERT( f.Read( pathCopy ) );
        TEST_ASSERT( path == pathCopy );
    }

    // Ensure file is opened in read write mode if it does exist
    {
        FileStream f;
        TEST_ASSERT( f.Open( path.Get(), FileStream::FileMode::OPEN_OR_CREATE_READ_WRITE ) );

        // File should not be truncated (previous content should exist)
        TEST_ASSERT( f.GetFileSize() == fileSize );

        // File pointer should be at start of file
        TEST_ASSERT( f.Tell() == 0 );

        // Read content
        AStackString pathCopy;
        TEST_ASSERT( f.Read( pathCopy ) );
        TEST_ASSERT( path == pathCopy );

        // Write new content, extending file
        const uint32_t value = 0xF00DF00D;
        TEST_ASSERT( f.Write( value ) );
        TEST_ASSERT( f.GetFileSize() == ( fileSize + sizeof( value ) ) );

        // Read back new content
        uint32_t valueCopy = 0;
        TEST_ASSERT( f.Seek( 0 ) );
        TEST_ASSERT( f.Read( pathCopy ) );
        TEST_ASSERT( f.Read( valueCopy ) );
        TEST_ASSERT( pathCopy == path );
        TEST_ASSERT( valueCopy == value );

        // Seek back and truncate file
        TEST_ASSERT( f.Seek( 0 ) );
        TEST_ASSERT( f.Write( value ) );
        TEST_ASSERT( f.Truncate() );
        TEST_ASSERT( f.Tell() == sizeof( uint32_t ) );
        TEST_ASSERT( f.GetFileSize() == sizeof( uint32_t ) );

        // Read back truncated content
        TEST_ASSERT( f.Seek( 0 ) );
        TEST_ASSERT( f.Seek( valueCopy ) );
        TEST_ASSERT( valueCopy == value );
    }

    FileIO::FileDelete( path.Get() );
}

//------------------------------------------------------------------------------
TEST_CASE( TestFileIO, CreateOrOpenReadWritePerf )
{
    // generate a process unique file path
    AStackString path;
    GenerateTempFileName( path );

    // Allocate a buffer. Each iteration will write a different subset of this
    // causing the file to be truncated or grow on each iteration
    const uint32_t maxDataLen = ( 16 * 1024 * 1024 );
    UniquePtr<uint8_t, FreeDeletor> data( static_cast<uint8_t *>( ALLOC( maxDataLen ) ) );
    memset( data.Get(), 0, maxDataLen );

    // Repeat operation several times to get performance info
    const size_t numRepeats = 8;

    // Truncate on open
    float t1 = 0.0f;
    {
        Random r( 0x5EED5EED );
        const Timer t;
        for ( size_t i = 0; i < numRepeats; ++i )
        {
            const uint32_t dataLen = r.GetRandIndex( maxDataLen );
            FileStream f;
            TEST_ASSERT( f.Open( path.Get(), FileStream::WRITE_ONLY ) );
            TEST_ASSERT( f.Tell() == 0 );
            TEST_ASSERT( f.WriteBuffer( data.Get(), dataLen ) == dataLen );
        }
        t1 = t.GetElapsed();
    }

    // Truncate when done
    float t2 = 0.0f;
    {
        Random r( 0x5EED5EED );
        const Timer t;
        for ( size_t i = 0; i < numRepeats; ++i )
        {
            const uint32_t dataLen = r.GetRandIndex( maxDataLen );
            FileStream f;
            TEST_ASSERT( f.Open( path.Get(), FileStream::OPEN_OR_CREATE_READ_WRITE ) );
            TEST_ASSERT( f.Tell() == 0 );
            TEST_ASSERT( f.WriteBuffer( data.Get(), dataLen ) == dataLen );
            TEST_ASSERT( f.Truncate() );
        }
        t2 = t.GetElapsed();
    }

    FileIO::FileDelete( path.Get() );

    OUTPUT( " Truncate on Open : %2.5f s\n", static_cast<double>( t1 ) );
    OUTPUT( " Truncate on Close: %2.5f s\n", static_cast<double>( t2 ) );
}

//------------------------------------------------------------------------------
