File Storage

FileStorage Api host you can download from the link here

FileStorage docker link here

POST http://localhost:11580/api/v1/filestorage/upload

Content-Type: multipart/form-data; boundary=----WebKitFormBoundaryDr2CUabwjQoYpMwU

POST http://localhost:11580/api/v1/filestorage/savebytes

  {"Id": "9E6A55B6B4563E652A23BE9D623CA5055C356940",  "Bytes": "Qk22EhMAAAAAAD" "Close": true}

GET http://localhost:11580/api/v1/filestorage/stream?id=

GET http://localhost:11580/api/v1/filestorage/exists?id=

GET http://localhost:11580/api/v1/filestorage/external?id=

GET http://localhost:11580/api/v1/filestorage/count?id=

GET http://localhost:11580/api/v1/filestorage/size?id=

Service registry config

{
      "id": "IFileStorageRestService",
      "host": "http://localhost:11580/"
},
{
      "id": "IFolderStorageRestService",
      "host": "http://localhost:11580/"
},

{ "id": "TcpFolderStorageService",
      "Address": "127.0.0.1",
      "Port": "11581"
},
{ 
	"id": "ITcpFileStorageService",
      "Address": "127.0.0.1",
      "Port": "11581"
}

Example use api rest lib

 /// <summary>
/// Example use Service registry http call
/// </summary>
private static void ExampleRestFile()
{
    var serviceRegistryFactory = new ServiceRegistryFactory();
    var service =
        serviceRegistryFactory.CreateTcp<IFileStorageRestService, FileStorageRestService>();
    var storageName = "test2";
    var fileName = $"1.txt";
    var sessionId = Guid.NewGuid().ToString();
    var fileId = service.GetIdByExternal(fileName);
    if (service.Exists(fileId, storageName))
    {
        service.Delete(fileId, storageName);
    }

    using (var stream = new FileStream(fileName, FileMode.Open))
    {
        service.SaveBytes(fileId, storageName, stream, sessionId);
    }
}

/// <summary>
/// Example use Service registry tcp socket call
/// </summary>
private static void ExampleTcpFile()
{
    var serviceRegistryFactory = new ServiceRegistryFactory();
    var service =
        serviceRegistryFactory.CreateTcp<ITcpFileStorageService, TcpFileStorageService>("ITcpFileStorageService");
    var storageName = "test2";
    var fileName = $"1.txt";
    var sessionId = Guid.NewGuid().ToString();
    if (service.IsExists(fileName, storageName))
    {
        service.Delete(fileName, storageName);
    }

    using (var stream = new FileStream(fileName, FileMode.Open))
    {
        service.Write(fileName, storageName, stream, sessionId);
    }
}
/// <summary>
/// Example use Service registry tcp socket call. Store files into folder
/// </summary>
private static void ExampleTcpFolder()
{
    var serviceRegistryFactory = new ServiceRegistryFactory();
    var service =
        serviceRegistryFactory.CreateTcp<ITcpFolderStorageService, TcpFolderStorageService>();
    var storageName = "test2";
    var fileName = $"1.txt";
    var folder = "folderName";
    var sessionId = Guid.NewGuid().ToString();
    if (service.IsExists(folder,fileName, storageName))
    {
        service.Delete(folder, fileName, storageName);
    }

    using (var stream = new FileStream(fileName, FileMode.Open))
    {
        service.Write(folder, fileName, storageName, stream, sessionId);
    }
}

How use FS.Core


public void Save(Stream stream, string id)
{
    // where id is md5 or sha1
    var factory = new FileStorageFactory(new FileStorageSettings(), new FileStorageVirtual());
    var localStorage = factory.Create(name);

    localStorage.Save(localMemory, id);
}

FileStorageSettings read configuration from file: filestorage.json


{
  "RootDirectory": "c:\\FileStorage",
  "IsMainNode": false,
  "ElemenetsCount": 6,
  "TreeDepth": 3
}