Fix refactored API compatibility problem

upload/metadata/metaData.go

@@ -92,11 +92,11 @@ func NewMetaDataFromLocalVHD(vhdPath string) (*MetaData, error) {
 // MetaData associated with the blob it returns nil value for MetaData
 //
 func NewMetadataFromBlob(blobClient storage.BlobStorageClient, containerName, blobName string) (*MetaData, error) {
-	allMetadata, err := blobClient.GetBlobMetadata(containerName, blobName)
-	if err != nil {
+	blob := blobClient.GetContainerReference(containerName).GetBlobReference(blobName)
+	if err := blob.GetMetadata(nil); err != nil {
 		return nil, fmt.Errorf("NewMetadataFromBlob, failed to fetch blob metadata: %v", err)
 	}
-	m, ok := allMetadata[metaDataKey]
+	m, ok := blob.Metadata[metaDataKey]
 	if !ok {
 		return nil, nil
 	}

upload/upload.go

@@ -1,6 +1,7 @@
 package upload
 
 import (
+	"bytes"
 	"errors"
 	"fmt"
 	"io"
@@ -86,13 +87,13 @@ L:
 			//
 			req := &concurrent.Request{
 				Work: func() error {
-					err := cxt.BlobServiceClient.PutPage(cxt.ContainerName,
-						cxt.BlobName,
-						dataWithRange.Range.Start,
-						dataWithRange.Range.End,
-						storage.PageWriteTypeUpdate,
-						dataWithRange.Data,
-						nil)
+					container := cxt.BlobServiceClient.GetContainerReference(cxt.ContainerName)
+					blob := container.GetBlobReference(cxt.BlobName)
+
+					err := blob.WriteRange(storage.BlobRange{
+						Start: uint64(dataWithRange.Range.Start),
+						End:   uint64(dataWithRange.Range.End),
+					}, bytes.NewReader(dataWithRange.Data), nil)
 					if err == nil {
 						uploadProgress.ReportBytesProcessedCount(dataWithRange.Range.Length())
 					}