- Add Oauth authentication

- Add internal Swagger UI
- Add cors

README.md

@@ -52,6 +52,11 @@ Click on `file-system-service-windows-{version}-windows-amd64.zip`
 file-system-service --generate-signature
 ```
 
+## Swagger
+- [Fichiers de définitions json](./swagger/swagger.json)
+- [Fichiers de définitions yaml](./swagger/swagger.yaml)
+- [Swagger UI accessible ici](http://localhost:3000/swagger)
+
 ## API Reference
 
 #### Check Validity

actions/main.go

@@ -1,15 +1,31 @@
 package actions
 
 import (
-	"filesystem_service/auth"
+	"filesystem_service/auth/credentials"
+	"filesystem_service/auth/roles"
 	"filesystem_service/flags"
 )
 
 func Exec() bool {
 	fl := flags.GetFlags()
 
-	if fl.IsGenerateSignature() {
-		auth.GenerateSignatureTokenAction()
+	if fl.IsShowRoles() {
+		roles.ShowRoles()
+		return true
+	}
+
+	if fl.IsUpdateCredentials() {
+		credentials.UpdateCredentials(fl.GetClientId(), fl.GetRole())
+		return true
+	}
+
+	if fl.IsShowUserRole() {
+		roles.GetUserRole(fl.GetClientId())
+		return true
+	}
+
+	if fl.IsGenerateCredentials() {
+		credentials.GenerateCredentials(fl.GetRole())
 		return true
 	}
 

arrays/main.go

@@ -21,3 +21,19 @@ func Filter[T any](ts []T, f func(T) bool) []T {
 func Generate[T any](length int) []T {
 	return make([]T, length)
 }
+
+func Keys[T any](arr []T) (keys []int) {
+	for i, _ := range arr {
+		keys = append(keys, i)
+	}
+	return
+}
+
+func IsIn[T comparable](v T, a []T) bool {
+	for _, val := range a {
+		if v == val {
+			return true
+		}
+	}
+	return false
+}

auth/credentials/createNewToken.go

@@ -0,0 +1,19 @@
+package credentials
+
+import (
+	"filesystem_service/arrays"
+	"filesystem_service/integer"
+	"strings"
+)
+
+func CreateNewToken(availableCharacters string, charNumber int) string {
+	return strings.Join(
+		arrays.Map[string, string](
+			arrays.Generate[string](charNumber),
+			func(t string) string {
+				return strings.Split(availableCharacters, "")[integer.RandomBetween(0, len(availableCharacters)-1)]
+			},
+		),
+		"",
+	)
+}

auth/credentials/generateClientId.go

@@ -0,0 +1,7 @@
+package credentials
+
+import "fmt"
+
+func GenerateClientId() string {
+	return fmt.Sprintf("fs_service_i@%v", CreateNewToken(AvailableCharacters, 15))
+}

auth/credentials/generateClientSecret.go

@@ -0,0 +1,7 @@
+package credentials
+
+import "fmt"
+
+func GenerateClientSecret() string {
+	return fmt.Sprintf("fs_service_s@%v", CreateNewToken(AvailableCharacters, 15))
+}

auth/credentials/generateCredentials.go

@@ -0,0 +1,48 @@
+package credentials
+
+import (
+	"filesystem_service/auth/roles"
+	"filesystem_service/database"
+	"fmt"
+)
+
+func GenerateCredentials(role string) {
+	db, err := database.Init()
+	defer db.Close()
+	if err != nil {
+		fmt.Printf("Une erreur est survenue lors de l'initialisation de la base de donnée.\n")
+		fmt.Printf(err.Error() + "\n")
+		return
+	}
+
+	roleId := roles.GetRoleIdFromName(db, role)
+
+	if roleId != -1 {
+		fmt.Printf("Generation du client_id ...\n")
+		fmt.Printf("Generation du client_secret ...\n")
+		clientId := GenerateClientId()
+		clientSecret := GenerateClientSecret()
+
+		if _, err = db.Exec(`UPDATE credentials 
+			SET active = FALSE 
+		WHERE active = TRUE;`); err != nil {
+			fmt.Printf("\nUne erreur est survenue lors de la création du token de signature.\n")
+			fmt.Printf(err.Error() + "\n")
+			return
+		}
+
+		if _, err = db.Exec(`INSERT INTO credentials (
+			client_id, 
+			client_secret, 
+			role, 
+			active
+		) VALUES (?, ?, ?, TRUE);`, clientId, clientSecret, roleId); err != nil {
+			fmt.Printf("\nUne erreur est survenue lors de la création du token de signature.\n")
+			fmt.Printf(err.Error() + "\n")
+			return
+		}
+
+		fmt.Printf("\nVous devrez les saisir dans le système d'exploitation web.\n")
+		fmt.Printf("\n=> client_id: %v\n=> client_secret: %v\n", clientId, clientSecret)
+	}
+}

auth/credentials/main.go

@@ -0,0 +1,3 @@
+package credentials
+
+var AvailableCharacters = "aAbBcCdDeEfFgGhHiIjJkKlLmMnNoOpPqQrRsStTuUvVwWxXyYzZ0123456789"

auth/credentials/updateCredentials.go

@@ -0,0 +1,40 @@
+package credentials
+
+import (
+	"filesystem_service/auth/roles"
+	"filesystem_service/database"
+	"fmt"
+)
+
+func UpdateCredentials(clientId string, newRole string) {
+	if clientId == "" {
+		fmt.Printf("Vous devez renseigner le client_id.\n")
+		return
+	}
+
+	if newRole == "" {
+		fmt.Printf("Vous devez renseigner votre nouveau rôle.\n")
+		return
+	}
+
+	db, err := database.Init()
+	defer db.Close()
+	if err != nil {
+		fmt.Printf("Une erreur est survenue lors de l'initialisation de la base de donnée.\n")
+		fmt.Printf(err.Error() + "\n")
+		return
+	}
+
+	newRoleId := roles.GetRoleIdFromName(db, newRole)
+
+	if _, err = db.Exec(
+		`UPDATE credentials SET role = ? WHERE client_id = ?;`,
+		newRoleId, clientId,
+	); err != nil {
+		fmt.Printf("Une erreur est survenue lors de laa modification de votre rôle.\n")
+		fmt.Printf(err.Error() + "\n")
+		return
+	}
+
+	fmt.Printf("Votre rôle à bien été modifié.\n")
+}