README.md

@@ -1,13 +0,0 @@
-# StorBackEnd
-
-## Configuration du projet
-
-### Version de GO
-* Télécharger et installer GO 1.17 et Goland de JetBrains
-* Si l'installation de GO n'a pas créé le dossier Go, créer un dossier Go et un dossier src à l'intérieur
-* Cloner le projet dans Go > src
-
-### Démarrer le projet
-* resources > AppConfig.json -> fichier de configuration
-* Modifier storagePath pour indiquer où le SBE va stocker les fichiers
-* Modifier l'interface réseau dans multicastNetworkInterface. Lorsque le programme démarre, il montre une liste des interfaces réseau disponibles. Copier-coller l'interface voulue dans le JSON et redémarrer

cmd/main.go

@@ -36,7 +36,7 @@ func main() {
 	===== Init all Write here =====
 	*/
 	// Creation of the HelloRule
-	helloRule := writers.CreateHelloRule("^HELLO ([A-Za-z0-9.]{5,20}) ([0-9]{1,5})\r\n$")
+	helloRule := writers.CreateHelloRule("^HELLO ([A-Za-z0-9]{5,20}) ([0-9]{1,5})\r\n$")
 	protocolRepository.AddWriter(&helloRule)
 
 	// Creation of the SendOkRule
@@ -87,6 +87,10 @@ func main() {
 	requestManager := managers.RequestManager{Repository: protocolRepository}
 
 	server := network.ServerUnicast{Network: "tcp", Port: appConfig.UnicastPort, ReqManager: &requestManager}
-	server.Run()
+	server.Run() // TODO : -> pourquoi ne pas partir dans un thread ici.
 
+	//reader := bufio.NewReader(os.Stdin) TODO ne pas oublier ici de mettre en place un point de sortie pour le programme.
+	//fmt.Print("Type Enter to quite: ")
+	//cmd, _ := reader.ReadString('\n')
+	//println(cmd)
 }

pkg/network/ServerUnicast.go

@@ -23,7 +23,7 @@ func (server ServerUnicast) Run() {
 
 	// Attente connexion du FileFrontEnd
 	con, err := listen.Accept()
-	print("Connecté au FFE")
+	print("connection ok")
 
 	if err != nil {
 		fmt.Printf("Error while accepting client : %s\n", err)

pkg/protocol/rules/readers/SendFileRule.go

@@ -43,7 +43,7 @@ func (rule SendFileRule) GetCmd() string {
 
 // Execute the Rule with a string command.
 func (rule SendFileRule) Execute(data string) (*protocol.ProtocolWriterResult, func(reader *bufio.Reader) *protocol.ProtocolWriterResult) {
-
+	println(0)
 	if rule.Match(data) { // TODO : cloture this command.
 		values := rule.matcher.Parse(data)
 

pkg/protocol/rules/writers/EraseOkRule.go

@@ -36,3 +36,10 @@ func (rule EraseOkRule) Execute(argsData ...string) *protocol.ProtocolWriterResu
 		Cmd: buildedCmd,
 	}
 }
+
+/*
+func onWrite(writer *bufio.Writer) {
+	println("Ecriture du fichier sur le réseau")
+}
+
+*/

pkg/protocol/rules/writers/SendErrorRule.go

@@ -36,3 +36,10 @@ func (rule SendErrorRule) Execute(argsData ...string) *protocol.ProtocolWriterRe
 		Cmd: buildedCmd,
 	}
 }
+
+/*
+func onWrite(writer *bufio.Writer) {
+	println("Ecriture du fichier sur le réseau")
+}
+
+*/

pkg/utils/SHA.go

@@ -45,7 +45,7 @@ func HashFileCompare(filePath string, fingerprint string) (bool, error) {
 	if err != nil {
 		return false, err
 	}
-
+	println("OKOK ", fileFingerprint, fingerprint)
 	if strings.Compare(fileFingerprint, fingerprint) == 0 {
 		return true, nil
 	}

resources/AppConfig.json

@@ -1,5 +1,5 @@
 {
-  "multicastNetworkInterface" : "tun0",
+  "multicastNetworkInterface" : "wlp1s0",
   "multicastAddress" : "224.66.66.1:15502",
   "multicastSecond" : 30,
   "domain" : "lightcontainerSB01",