Synnefo » Pithos MS Client

using System;

using System.Collections.Generic;

using System.IO;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using NUnit.Framework;

using Pithos.Core.Agents;

using Pithos.Network;

namespace Pithos.Core.Test

{

    [TestFixture]

    class NetworkAgentTest

    {

        [Test]

        public void TestUpload()

        {

            var agent = new NetworkAgent();

            var account = "890329@vho.grnet.gr";

            var apiKey = "24989dce4e0fcb072f8cb60c8922be19";

            var client = new CloudFilesClient(account,apiKey)

                             {

                                 AuthenticationUrl = @"https://pithos.dev.grnet.gr",

                                 UsePithos = true

                             };

            var accountInfo=client.Authenticate();

            var fileName = "012345.dump";

            var filePath = Path.Combine(@"e:\pithos\", fileName);

            var random = new Random();

            var buffer = new byte[4096];

            random.NextBytes(buffer);

            if (File.Exists(filePath))

                File.Delete(filePath);

            using (var stream = File.OpenWrite(filePath))

            {

                for (var i = 0; i < 2* 1024;i++ )

                    stream.Write(buffer, 0, buffer.Length);

            }

            client.DeleteObject(null, FolderConstants.PithosContainer, fileName);

            var task = Signature.CalculateTreeHashAsync(filePath, accountInfo.BlockSize, accountInfo.BlockHash);

            var tasks=agent.UploadWithHashMap(accountInfo,account,"pithos",new FileInfo(filePath),fileName,task);

            Task.Factory.Iterate(tasks).Wait();

            var newHash = client.GetHashMap(null, FolderConstants.PithosContainer, fileName).Result;

            var treeHash = task.Result;

            Assert.AreEqual(treeHash.TopHash, newHash.TopHash);

            Assert.AreEqual(treeHash.Hashes, newHash.Hashes);

        }

        [Test]

        public void TestDownload()

        {

            var fileAgent = new FileAgent {FragmentsPath = @"e:\pithos\Fragments"};

            var agent = new NetworkAgent();

            var account = "890329@vho.grnet.gr";

            var apiKey = "24989dce4e0fcb072f8cb60c8922be19";

            var client = new CloudFilesClient(account,apiKey)

            {

                AuthenticationUrl = @"https://pithos.dev.grnet.gr",

                UsePithos = true

            };

            var accountInfo=client.Authenticate();

            var fileName = @"AccessDatabaseEngine_x64.exe";

            var filePath = Path.Combine(@"e:\pithos\", fileName);

            if (File.Exists(filePath))

                File.Delete(filePath);

            var newHash = client.GetHashMap(null, FolderConstants.PithosContainer, fileName).Result;

            agent.DownloadWithBlocks(client, account, FolderConstants.PithosContainer, new Uri(fileName, UriKind.Relative), filePath, newHash)

                .Wait();

            Assert.IsTrue(File.Exists(filePath));

            var treeHash = Signature.CalculateTreeHashAsync(filePath, accountInfo.BlockSize, accountInfo.BlockHash).Result;

            Assert.AreEqual(treeHash.TopHash, newHash.TopHash);

            Assert.AreEqual(treeHash.Hashes, newHash.Hashes);

        }

    }

}