Added CreationTime and LastModified to blob metadata (#33)

Author: dtymakhov

Directory.Build.props

@@ -13,8 +13,8 @@
         <PackageLicenseExpression>MIT</PackageLicenseExpression>
         <PackageReadmeFile>README.md</PackageReadmeFile>
         <Product>Managed Code - Storage</Product>
-        <Version>2.0.6</Version>
-        <PackageVersion>2.0.6</PackageVersion>
+        <Version>2.0.7</Version>
+        <PackageVersion>2.0.7</PackageVersion>
     </PropertyGroup>
     <PropertyGroup Condition="'$(GITHUB_ACTIONS)' == 'true'">
         <ContinuousIntegrationBuild>true</ContinuousIntegrationBuild>

ManagedCode.Storage.Aws/AWSStorage.cs

@@ -70,9 +70,12 @@ public override async IAsyncEnumerable<BlobMetadata> GetBlobMetadataListAsync(st
 
                 yield return new BlobMetadata
                 {
+                    Name = entry.Key,
                     FullName = entry.Key,
-                    Name = Path.GetFileName(entry.Key),
+                    Container = StorageOptions.Bucket,
                     Uri = new Uri($"https://s3.amazonaws.com/{StorageOptions.Bucket}/{entry.Key}"),
+                    LastModified = objectMetaResponse.LastModified,
+                    CreationTime = objectMetaResponse.LastModified,
                     MimeType = objectMetaResponse.Headers.ContentType,
                     Length = objectMetaResponse.Headers.ContentLength
                 };
@@ -135,7 +138,7 @@ protected override async Task<Result<BlobMetadata>> UploadInternalAsync(Stream s
             InputStream = stream,
             AutoCloseStream = false,
             ContentType = options.MimeType,
-            ServerSideEncryptionMethod = null
+            ServerSideEncryptionMethod = null,
         };
 
         try
@@ -162,11 +165,13 @@ protected override async Task<Result<LocalFile>> DownloadInternalAsync(LocalFile
 
             localFile.BlobMetadata = new BlobMetadata
             {
-                Name = options.FullPath,
+                Name = options.FileName,
+                Container = StorageOptions.Bucket,
                 Uri = new Uri($"https://s3.amazonaws.com/{StorageOptions.Bucket}/{options.FullPath}"),
+                LastModified = response.LastModified,
+                CreationTime = response.LastModified,
                 MimeType = response.Headers.ContentType,
-                Length = response.Headers.ContentLength,
-                Container = StorageOptions.Bucket
+                Length = response.Headers.ContentLength
             };
 
             await localFile.CopyFromStreamAsync(await StorageClient.GetObjectStreamAsync(StorageOptions.Bucket, options.FullPath, null,
@@ -249,8 +254,11 @@ protected override async Task<Result<BlobMetadata>> GetBlobMetadataInternalAsync
 
             var metadata = new BlobMetadata
             {
-                Name = options.FullPath,
+                Name = options.FileName,
+                Container = StorageOptions.Bucket,
                 Uri = new Uri($"https://s3.amazonaws.com/{StorageOptions.Bucket}/{options.FullPath}"),
+                LastModified = objectMetaResponse.LastModified,
+                CreationTime = objectMetaResponse.LastModified,
                 MimeType = objectMetaResponse.Headers.ContentType,
                 Length = objectMetaResponse.Headers.ContentLength
             };

ManagedCode.Storage.Azure/AzureStorage.cs

@@ -269,6 +269,8 @@ protected override async Task<Result<BlobMetadata>> GetBlobMetadataInternalAsync
                 Uri = blobClient.Uri,
                 Container = blobClient.BlobContainerName,
                 Length = properties.Value.ContentLength,
+                CreationTime = properties.Value.CreatedOn,
+                LastModified = properties.Value.LastModified,
                 Metadata = properties.Value.Metadata.ToDictionary(k => k.Key, v => v.Value),
                 MimeType = properties.Value.ContentType
             });

ManagedCode.Storage.AzureDataLake/AzureDataLakeStorage.cs

@@ -233,6 +233,8 @@ protected override async Task<Result<BlobMetadata>> GetBlobMetadataInternalAsync
                 Uri = fileClient.Uri,
                 Container = fileClient.FileSystemName,
                 Length = properties.Value.ContentLength,
+                CreationTime = properties.Value.CreatedOn,
+                LastModified = properties.Value.LastModified,
                 Metadata = properties.Value.Metadata.ToDictionary(k => k.Key, v => v.Value),
                 MimeType = properties.Value.ContentType
             });

ManagedCode.Storage.Core/Models/BlobMetadata.cs

@@ -9,6 +9,8 @@ public class BlobMetadata
     public string Name { get; set; } = null!;
     public Uri? Uri { get; set; }
     public Dictionary<string, string>? Metadata { get; set; }
+    public DateTimeOffset LastModified { get; set; }
+    public DateTimeOffset CreationTime { get; set; }
     public string? Container { get; set; }
     public string? MimeType { get; set; }
     public long Length { get; set; }

ManagedCode.Storage.FileSystem/FileSystemStorage.cs

@@ -166,6 +166,8 @@ protected override async Task<Result<BlobMetadata>> GetBlobMetadataInternalAsync
             Name = fileInfo.Name,
             Uri = new Uri(Path.Combine(_path, filePath)),
             MimeType = MimeHelper.GetMimeType(fileInfo.Extension),
+            CreationTime = fileInfo.CreationTimeUtc,
+            LastModified = fileInfo.LastWriteTimeUtc,
             Length = fileInfo.Length
         };
 

ManagedCode.Storage.Gcp/GCPStorage.cs

@@ -57,15 +57,17 @@ public override IAsyncEnumerable<BlobMetadata> GetBlobMetadataListAsync(string?
 
     {
         return StorageClient.ListObjectsAsync(StorageOptions.BucketOptions.Bucket, directory,
-                new ListObjectsOptions { Projection = Projection.Full })
+                new ListObjectsOptions {Projection = Projection.Full})
             .Select(
                 x => new BlobMetadata
                 {
                     Name = x.Name,
                     Uri = string.IsNullOrEmpty(x.MediaLink) ? null : new Uri(x.MediaLink),
                     Container = x.Bucket,
+                    CreationTime = x.TimeCreated!.Value,
+                    LastModified = x.Updated!.Value,
                     MimeType = x.ContentType,
-                    Length = (long)(x.Size ?? 0)
+                    Length = (long) (x.Size ?? 0)
                 }
             );
     }
@@ -111,7 +113,7 @@ protected override async Task<Result> DeleteDirectoryInternalAsync(string direct
         {
             await EnsureContainerExist();
             var blobs = StorageClient.ListObjectsAsync(StorageOptions.BucketOptions.Bucket, string.Empty,
-                    new ListObjectsOptions { Projection = Projection.Full })
+                    new ListObjectsOptions {Projection = Projection.Full})
                 .Select(x => x);
 
             await foreach (var blob in blobs.WithCancellation(cancellationToken))
@@ -135,6 +137,7 @@ protected override async Task<Result<BlobMetadata>> UploadInternalAsync(Stream s
         try
         {
             await EnsureContainerExist();
+
             await StorageClient.UploadObjectAsync(StorageOptions.BucketOptions.Bucket, options.FullPath, options.MimeType, stream, null,
                 cancellationToken);
 
@@ -218,8 +221,10 @@ protected override async Task<Result<BlobMetadata>> GetBlobMetadataInternalAsync
                 Name = obj.Name,
                 Uri = string.IsNullOrEmpty(obj.MediaLink) ? null : new Uri(obj.MediaLink),
                 Container = obj.Bucket,
+                CreationTime = obj.TimeCreated!.Value,
+                LastModified = obj.Updated!.Value,
                 MimeType = obj.ContentType,
-                Length = (long)(obj.Size ?? 0)
+                Length = (long) (obj.Size ?? 0)
             });
         }
         catch (Exception ex)