Skip to content
Snippets Groups Projects
Commit 4a622378 authored by Xavier Perret's avatar Xavier Perret
Browse files

removed useless exit from app

parent 75285a0b
Branches
No related tags found
1 merge request!2added file to separate client function from the server
...@@ -42,28 +42,32 @@ func FakeTransaction(transactionToFake Transaction, fakeTransaction Transaction, ...@@ -42,28 +42,32 @@ func FakeTransaction(transactionToFake Transaction, fakeTransaction Transaction,
func ReadDatabaseFromBlobStorage(blob Blob) Database { func ReadDatabaseFromBlobStorage(blob Blob) Database {
ctx := context.Background() ctx := context.Background()
var database Database
// Download the blob // Download the blob
get, err := blob.BlockBlobClient.Download(ctx, nil) get, err := blob.BlockBlobClient.Download(ctx, nil)
if err != nil { if err != nil {
log.Fatal(err) log.Println(err)
return database
} }
downloadedData := &bytes.Buffer{} downloadedData := &bytes.Buffer{}
reader := get.Body(azblob.RetryReaderOptions{}) reader := get.Body(azblob.RetryReaderOptions{})
_, err = downloadedData.ReadFrom(reader) _, err = downloadedData.ReadFrom(reader)
if err != nil { if err != nil {
log.Fatal(err) log.Println(err)
return database
} }
err = reader.Close() err = reader.Close()
if err != nil { if err != nil {
log.Fatal(err) log.Println(err)
return database
} }
var database Database
err = json.Unmarshal(downloadedData.Bytes(), &database) err = json.Unmarshal(downloadedData.Bytes(), &database)
if err != nil { if err != nil {
log.Fatal(err) log.Println(err)
return database
} }
fmt.Println(downloadedData.String()) fmt.Println(downloadedData.String())
...@@ -75,23 +79,23 @@ func readGivenBlobFromContainer(blob Blob, data any) any { ...@@ -75,23 +79,23 @@ func readGivenBlobFromContainer(blob Blob, data any) any {
ctx := context.Background() ctx := context.Background()
get, err := blob.BlockBlobClient.Download(ctx, nil) get, err := blob.BlockBlobClient.Download(ctx, nil)
if err != nil { if err != nil {
log.Fatal(err) log.Println(err)
} }
downloadedData := &bytes.Buffer{} downloadedData := &bytes.Buffer{}
reader := get.Body(azblob.RetryReaderOptions{}) reader := get.Body(azblob.RetryReaderOptions{})
_, err = downloadedData.ReadFrom(reader) _, err = downloadedData.ReadFrom(reader)
if err != nil { if err != nil {
log.Fatal(err) log.Println(err)
} }
err = reader.Close() err = reader.Close()
if err != nil { if err != nil {
log.Fatal(err) log.Println(err)
} }
err = json.Unmarshal(downloadedData.Bytes(), &data) err = json.Unmarshal(downloadedData.Bytes(), &data)
if err != nil { if err != nil {
log.Fatal(err) log.Println(err)
} }
fmt.Println(downloadedData.String()) fmt.Println(downloadedData.String())
...@@ -106,7 +110,7 @@ func WriteDatabaseToBlobStorage(database Database, blob Blob) { ...@@ -106,7 +110,7 @@ func WriteDatabaseToBlobStorage(database Database, blob Blob) {
_, err = blob.BlockBlobClient.UploadBufferToBlockBlob(ctx, data, azblob.HighLevelUploadToBlockBlobOption{}) _, err = blob.BlockBlobClient.UploadBufferToBlockBlob(ctx, data, azblob.HighLevelUploadToBlockBlobOption{})
if err != nil { if err != nil {
log.Fatalf("Failure to upload to blob: %+v", err) log.Printf("Failure to upload to blob: %+v", err)
} }
} }
...@@ -118,7 +122,7 @@ func writeGivenDataToBlob(blob Blob, data any) { ...@@ -118,7 +122,7 @@ func writeGivenDataToBlob(blob Blob, data any) {
_, err = blob.BlockBlobClient.UploadBufferToBlockBlob(ctx, dataBytes, azblob.HighLevelUploadToBlockBlobOption{}) _, err = blob.BlockBlobClient.UploadBufferToBlockBlob(ctx, dataBytes, azblob.HighLevelUploadToBlockBlobOption{})
if err != nil { if err != nil {
log.Fatalf("Failure to upload to blob: %+v", err) log.Printf("Failure to upload to blob: %+v", err)
} }
} }
...@@ -137,12 +141,12 @@ func InitAzureCredentials(storageAccountName string) AzureCredentials { ...@@ -137,12 +141,12 @@ func InitAzureCredentials(storageAccountName string) AzureCredentials {
// Create a default request pipeline using your storage account name and account key. // Create a default request pipeline using your storage account name and account key.
credential, err := azidentity.NewDefaultAzureCredential(nil) credential, err := azidentity.NewDefaultAzureCredential(nil)
if err != nil { if err != nil {
log.Fatal("Invalid credentials with error: " + err.Error()) log.Println("Invalid credentials with error: " + err.Error())
} }
serviceClient, err := azblob.NewServiceClient(url, credential, nil) serviceClient, err := azblob.NewServiceClient(url, credential, nil)
if err != nil { if err != nil {
log.Fatal("Invalid credentials with error: " + err.Error()) log.Println("Invalid credentials with error: " + err.Error())
} }
newAzureCredentials := AzureCredentials{ newAzureCredentials := AzureCredentials{
...@@ -212,7 +216,7 @@ func ListBlobs(blob Blob) { ...@@ -212,7 +216,7 @@ func ListBlobs(blob Blob) {
} }
if err := pager.Err(); err != nil { if err := pager.Err(); err != nil {
log.Fatalf("Failure to list blobs: %+v", err) log.Printf("Failure to list blobs: %+v", err)
} }
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment