Synnefo » Pithos MS Client

using System;

using System.Collections.Concurrent;

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.Interfaces;

using Pithos.Network;

namespace Pithos.Core.Test

{

    [TestFixture]

    class NetworkAgentTest

    {

        [Test]

        public async 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 treeHash = await Signature.CalculateTreeHashAsync(filePath, accountInfo.BlockSize, accountInfo.BlockHash, 2);

            var cloudFile = new ObjectInfo {Account = account, Container = "pithos"};

            var fileInfo = new FileInfo(filePath);

            agent.UploadWithHashMap(accountInfo,cloudFile,fileInfo,fileName,treeHash);

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

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

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

        }

        [Test]

        public void TestDownload()

        {

            var agent = new NetworkAgent();

            var account = "";

            var apiKey = "";

            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 cloudFile = new ObjectInfo {Account = account, Container = FolderConstants.PithosContainer};

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

            agent.DownloadWithBlocks(accountInfo, client, cloudFile, new Uri(fileName, UriKind.Relative), filePath, newHash)

                .Wait();

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

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

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

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

        }

    }

}