Compare commits

..

No commits in common. "master" and "maximilien" have entirely different histories.

7 changed files with 22 additions and 17 deletions

View File

@ -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

View File

@ -87,6 +87,10 @@ func main() {
requestManager := managers.RequestManager{Repository: protocolRepository} requestManager := managers.RequestManager{Repository: protocolRepository}
server := network.ServerUnicast{Network: "tcp", Port: appConfig.UnicastPort, ReqManager: &requestManager} 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)
} }

View File

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

View File

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

View File

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

View File

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

View File

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