66 lines
1.7 KiB
Go
66 lines
1.7 KiB
Go
|
package cmd
|
||
|
|
|
||
|
|
import (
|
||
|
|
"errors"
|
||
|
|
"os"
|
||
|
|
"strconv"
|
||
|
|
|
||
|
|
"github.com/filebrowser/filebrowser/v2/users"
|
||
|
|
"github.com/spf13/cobra"
|
||
|
|
)
|
||
|
|
|
||
|
|
func init() {
|
||
|
|
usersCmd.AddCommand(usersImportCmd)
|
||
|
|
usersImportCmd.Flags().Bool("overwrite", false, "overwrite users with the same id/username combo")
|
||
|
|
}
|
||
|
|
|
||
|
|
var usersImportCmd = &cobra.Command{
|
||
|
|
Use: "import <filename>",
|
||
|
|
Short: "Import users from a file.",
|
||
|
|
Args: jsonYamlArg,
|
||
|
|
Run: python(func(cmd *cobra.Command, args []string, d pythonData) {
|
||
|
|
fd, err := os.Open(args[0])
|
||
|
|
checkErr(err)
|
||
|
|
defer fd.Close()
|
||
|
|
|
||
|
|
list := []*users.User{}
|
||
|
|
err = unmarshal(args[0], &list)
|
||
|
|
checkErr(err)
|
||
|
|
|
||
|
|
for _, user := range list {
|
||
|
|
err = user.Clean("")
|
||
|
|
checkErr(err)
|
||
|
|
}
|
||
|
|
|
||
|
|
overwrite := mustGetBool(cmd, "overwrite")
|
||
|
|
|
||
|
|
for _, user := range list {
|
||
|
|
old, err := d.store.Users.Get("", user.ID)
|
||
|
|
|
||
|
|
// User exists in DB.
|
||
|
|
if err == nil {
|
||
|
|
if !overwrite {
|
||
|
|
checkErr(errors.New("user " + strconv.Itoa(int(user.ID)) + " is already registred"))
|
||
|
|
}
|
||
|
|
|
||
|
|
// If the usernames mismatch, check if there is another one in the DB
|
||
|
|
// with the new username. If there is, print an error and cancel the
|
||
|
|
// operation
|
||
|
|
if user.Username != old.Username {
|
||
|
|
conflictuous, err := d.store.Users.Get("", user.Username)
|
||
|
|
if err == nil {
|
||
|
|
checkErr(usernameConflictError(user.Username, conflictuous.ID, user.ID))
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
err = d.store.Users.Save(user)
|
||
|
|
checkErr(err)
|
||
|
|
}
|
||
|
|
}, pythonConfig{}),
|
||
|
|
}
|
||
|
|
|
||
|
|
func usernameConflictError(username string, original, new uint) error {
|
||
|
|
return errors.New("can't import user with ID " + strconv.Itoa(int(new)) + " and username \"" + username + "\" because the username is already registred with the user " + strconv.Itoa(int(original)))
|
||
|
|
}
|