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

added object storage

parent 8f3e88cb
No related branches found
No related tags found
1 merge request!2added file to separate client function from the server
package main package main
import ( import (
"context"
"fmt" "fmt"
"gopkg.in/yaml.v3" "gopkg.in/yaml.v3"
"log"
"net" "net"
command_line "node/command-line"
ObjectStorage "node/object-storage" ObjectStorage "node/object-storage"
ProcessConnection "node/process-connection" ProcessConnection "node/process-connection"
. "node/types" . "node/types"
...@@ -34,8 +37,6 @@ func listenForConnections(serverConfig Config, objectStorage Blob, addressToList ...@@ -34,8 +37,6 @@ func listenForConnections(serverConfig Config, objectStorage Blob, addressToList
fmt.Println("Server is ready to accept connections") fmt.Println("Server is ready to accept connections")
fmt.Println("listening on ", completeAddress) fmt.Println("listening on ", completeAddress)
ServerReady = true
var mu sync.Mutex var mu sync.Mutex
for { for {
// Listening for connections // Listening for connections
...@@ -49,6 +50,7 @@ func listenForConnections(serverConfig Config, objectStorage Blob, addressToList ...@@ -49,6 +50,7 @@ func listenForConnections(serverConfig Config, objectStorage Blob, addressToList
} }
func main() { func main() {
ctx := context.Background()
argsLen := len(os.Args) argsLen := len(os.Args)
isThereEnoughArgs := argsLen <= 1 isThereEnoughArgs := argsLen <= 1
if isThereEnoughArgs { if isThereEnoughArgs {
...@@ -87,10 +89,24 @@ func main() { ...@@ -87,10 +89,24 @@ func main() {
} }
azureCreds := ObjectStorage.InitAzureCredentials("hepiadistributedsystems") azureCreds := ObjectStorage.InitAzureCredentials("hepiadistributedsystems")
blobName := "blockchain" + "-" + "database" + "" + strconv.Itoa(serverConfig.ID) blobName := "blob-number-" + strconv.Itoa(serverConfig.ID)
objectStorage := ObjectStorage.InitializeBlobFromObjectStorageCreds(blobName, azureCreds) objectStorage := ObjectStorage.InitializeBlobFromObjectStorageCreds(blobName, azureCreds)
addressToListenOn := "0.0.0.0" addressToListenOn := "0.0.0.0"
go listenForConnections(serverConfig, objectStorage, addressToListenOn, amIRoot) go listenForConnections(serverConfig, objectStorage, addressToListenOn, amIRoot)
userInputLoop(serverConfig, true) command_line.UserInputLoop(serverConfig, true, objectStorage)
_, err = objectStorage.BlockBlobClient.Delete(ctx, nil)
if err != nil {
fmt.Println("Error while deleting the blob", err)
fmt.Println("This previous error is normal if the blob was already deleted or wasn't created")
}
// Delete the container
fmt.Println("Deleting the container " + objectStorage.BlobName)
_, err = objectStorage.ContainerClient.Delete(ctx, nil)
if err != nil {
log.Fatalf("Failure: %+v", err)
}
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment