From e8e6cbff6f2ced2e572127cf0a3780d553b2d40a Mon Sep 17 00:00:00 2001
From: Xavier Perret <xa.perret@outlook.com>
Date: Mon, 17 Oct 2022 19:50:48 +0200
Subject: [PATCH] function to add transactions works !
---
app/object-storage/object-storage.go | 67 ++++++++++++++--------------
1 file changed, 34 insertions(+), 33 deletions(-)
diff --git a/app/object-storage/object-storage.go b/app/object-storage/object-storage.go
index d664f5f..a8cad14 100644
--- a/app/object-storage/object-storage.go
+++ b/app/object-storage/object-storage.go
@@ -2,7 +2,6 @@ package object_storage
import (
"bufio"
- "bytes"
"context"
"encoding/json"
"fmt"
@@ -126,8 +125,8 @@ func InitializeObjectStorage(baseObjectStorageName string, azureCreds AzureCrede
}
func TestObjectStorage() {
+ ctx := context.Background()
// url := "https://hepiadistributedsystems.blob.core.windows.net/" //replace <StorageAccountName> with your Azure storage account name
-
azureCreds := InitAzureCredentials("hepiadistributedsystems")
blobName := "quickstartblob" + "-" + randomString()
objectStorage := InitializeObjectStorage(blobName, azureCreds)
@@ -145,45 +144,47 @@ func TestObjectStorage() {
Receiver: "1",
Amount: "1000",
}
- db = addTransactionToBlobStorage(t1, db)
- db = addTransactionToBlobStorage(t2, db)
+ db = addTransactionToBlobStorage(t1, db, objectStorage)
+ db = addTransactionToBlobStorage(t2, db, objectStorage)
// List the blobs in the container
- fmt.Println("Listing the blobs in the container:")
+ /*
+ fmt.Println("Listing the blobs in the container:")
- pager := containerClient.ListBlobsFlat(nil)
+ pager := containerClient.ListBlobsFlat(nil)
- for pager.NextPage(ctx) {
- resp := pager.PageResponse()
+ for pager.NextPage(ctx) {
+ resp := pager.PageResponse()
- for _, v := range resp.ContainerListBlobFlatSegmentResult.Segment.BlobItems {
- fmt.Println(*v.Name)
+ for _, v := range resp.ContainerListBlobFlatSegmentResult.Segment.BlobItems {
+ fmt.Println(*v.Name)
+ }
}
- }
- if err = pager.Err(); err != nil {
- log.Fatalf("Failure to list blobs: %+v", err)
- }
+ if err = pager.Err(); err != nil {
+ log.Fatalf("Failure to list blobs: %+v", err)
+ }
- // Download the blob
- get, err := blobClient.Download(ctx, nil)
- if err != nil {
- log.Fatal(err)
- }
+ // Download the blob
+ get, err := blobClient.Download(ctx, nil)
+ if err != nil {
+ log.Fatal(err)
+ }
- downloadedData := &bytes.Buffer{}
- reader := get.Body(azblob.RetryReaderOptions{})
- _, err = downloadedData.ReadFrom(reader)
- if err != nil {
- log.Fatal(err)
- }
- err = reader.Close()
- if err != nil {
- log.Fatal(err)
- }
+ downloadedData := &bytes.Buffer{}
+ reader := get.Body(azblob.RetryReaderOptions{})
+ _, err = downloadedData.ReadFrom(reader)
+ if err != nil {
+ log.Fatal(err)
+ }
+ err = reader.Close()
+ if err != nil {
+ log.Fatal(err)
+ }
- fmt.Println(downloadedData.String())
+ fmt.Println(downloadedData.String())
+ */
fmt.Printf("Press enter key to delete the blob fils, example container, and exit the application.\n")
bufio.NewReader(os.Stdin).ReadBytes('\n')
fmt.Printf("Cleaning up.\n")
@@ -191,14 +192,14 @@ func TestObjectStorage() {
// Delete the blob
fmt.Printf("Deleting the blob " + blobName + "\n")
- _, err = blobClient.Delete(ctx, nil)
+ _, err := objectStorage.BlockBlobClient.Delete(ctx, nil)
if err != nil {
log.Fatalf("Failure: %+v", err)
}
// Delete the container
- fmt.Printf("Deleting the blob " + containerName + "\n")
- _, err = containerClient.Delete(ctx, nil)
+ fmt.Printf("Deleting the blob " + objectStorage.ContainerName + "\n")
+ _, err = objectStorage.ContainerClient.Delete(ctx, nil)
if err != nil {
log.Fatalf("Failure: %+v", err)
--
GitLab