diff --git a/app/server.go b/app/server.go index da67640cdcf8453bc82feb261fcb523ad9701356..46c95ec242710291557d03a465eca4b7011633fb 100644 --- a/app/server.go +++ b/app/server.go @@ -1,9 +1,12 @@ package main import ( + "context" "fmt" "gopkg.in/yaml.v3" + "log" "net" + command_line "node/command-line" ObjectStorage "node/object-storage" ProcessConnection "node/process-connection" . "node/types" @@ -34,8 +37,6 @@ func listenForConnections(serverConfig Config, objectStorage Blob, addressToList fmt.Println("Server is ready to accept connections") fmt.Println("listening on ", completeAddress) - ServerReady = true - var mu sync.Mutex for { // Listening for connections @@ -49,6 +50,7 @@ func listenForConnections(serverConfig Config, objectStorage Blob, addressToList } func main() { + ctx := context.Background() argsLen := len(os.Args) isThereEnoughArgs := argsLen <= 1 if isThereEnoughArgs { @@ -87,10 +89,24 @@ func main() { } azureCreds := ObjectStorage.InitAzureCredentials("hepiadistributedsystems") - blobName := "blockchain" + "-" + "database" + "" + strconv.Itoa(serverConfig.ID) + blobName := "blob-number-" + strconv.Itoa(serverConfig.ID) objectStorage := ObjectStorage.InitializeBlobFromObjectStorageCreds(blobName, azureCreds) addressToListenOn := "0.0.0.0" 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) + } }