Compare commits
4 Commits
Author | SHA1 | Date | |
---|---|---|---|
|
225a4ab531 | ||
|
7cd579a86f | ||
|
ca9dd538e3 | ||
|
52032b5676 |
13
README.md
Normal file
13
README.md
Normal file
@ -0,0 +1,13 @@
|
|||||||
|
# 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
|
@ -36,7 +36,7 @@ func main() {
|
|||||||
===== Init all Write here =====
|
===== Init all Write here =====
|
||||||
*/
|
*/
|
||||||
// Creation of the HelloRule
|
// 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)
|
protocolRepository.AddWriter(&helloRule)
|
||||||
|
|
||||||
// Creation of the SendOkRule
|
// Creation of the SendOkRule
|
||||||
@ -87,10 +87,6 @@ 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() // TODO : -> pourquoi ne pas partir dans un thread ici.
|
server.Run()
|
||||||
|
|
||||||
//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)
|
|
||||||
}
|
}
|
||||||
|
@ -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("connection ok")
|
print("Connecté au FFE")
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Printf("Error while accepting client : %s\n", err)
|
fmt.Printf("Error while accepting client : %s\n", err)
|
||||||
|
@ -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)
|
||||||
|
|
||||||
|
@ -36,10 +36,3 @@ 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")
|
|
||||||
}
|
|
||||||
|
|
||||||
*/
|
|
||||||
|
@ -36,10 +36,3 @@ 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")
|
|
||||||
}
|
|
||||||
|
|
||||||
*/
|
|
||||||
|
@ -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
|
||||||
}
|
}
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
{
|
{
|
||||||
"multicastNetworkInterface" : "wlp1s0",
|
"multicastNetworkInterface" : "tun0",
|
||||||
"multicastAddress" : "224.66.66.1:15502",
|
"multicastAddress" : "224.66.66.1:15502",
|
||||||
"multicastSecond" : 30,
|
"multicastSecond" : 30,
|
||||||
"domain" : "lightcontainerSB01",
|
"domain" : "lightcontainerSB01",
|
||||||
|
Loading…
Reference in New Issue
Block a user