mirror of
https://github.com/hrfee/jfa-go.git
synced 2024-12-22 17:10:10 +00:00
ombi: fix password reset on default route
the ombi password wasn't being changed w/ password resets initiated through the admin page (and probably by other routes, too), as the code was considering a HTTP 204 from Jellyfin as a failure, causing it to skip anything with Ombi. Also added a little check for Ombi-imported accounts that probably won't help with anything, but whatever.
This commit is contained in:
parent
4864c6c53c
commit
cf94fdb2f0
15
api-ombi.go
15
api-ombi.go
@ -132,3 +132,18 @@ func (app *appContext) DeleteOmbiProfile(gc *gin.Context) {
|
|||||||
app.storage.SetProfileKey(profileName, profile)
|
app.storage.SetProfileKey(profileName, profile)
|
||||||
respondBool(204, true, gc)
|
respondBool(204, true, gc)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (app *appContext) applyOmbiProfile(user map[string]interface{}, profile map[string]interface{}) (status int, err error) {
|
||||||
|
for k, v := range profile {
|
||||||
|
switch v.(type) {
|
||||||
|
case map[string]interface{}, []interface{}:
|
||||||
|
user[k] = v
|
||||||
|
default:
|
||||||
|
if v != user[k] {
|
||||||
|
user[k] = v
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
status, err = app.ombi.ModifyUser(user)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
37
api-users.go
37
api-users.go
@ -377,16 +377,34 @@ func (app *appContext) newUser(req newUserDTO, confirmed bool) (f errorFunc, suc
|
|||||||
if profile.Ombi != nil && len(profile.Ombi) != 0 {
|
if profile.Ombi != nil && len(profile.Ombi) != 0 {
|
||||||
template := profile.Ombi
|
template := profile.Ombi
|
||||||
errors, code, err := app.ombi.NewUser(req.Username, req.Password, req.Email, template)
|
errors, code, err := app.ombi.NewUser(req.Username, req.Password, req.Email, template)
|
||||||
|
accountExists := false
|
||||||
|
var ombiUser map[string]interface{}
|
||||||
if err != nil || code != 200 {
|
if err != nil || code != 200 {
|
||||||
|
// Check if on the off chance, Ombi's user importer has already added the account.
|
||||||
|
ombiUser, status, err = app.getOmbiImportedUser(req.Username)
|
||||||
|
if status == 200 && err == nil {
|
||||||
|
app.info.Println("Found existing Ombi user, applying changes")
|
||||||
|
accountExists = true
|
||||||
|
template["password"] = req.Password
|
||||||
|
status, err = app.applyOmbiProfile(ombiUser, template)
|
||||||
|
if status != 200 || err != nil {
|
||||||
|
app.err.Printf("Failed to modify existing Ombi user (%d): %v\n", status, err)
|
||||||
|
}
|
||||||
|
} else {
|
||||||
app.info.Printf("Failed to create Ombi user (%d): %s", code, err)
|
app.info.Printf("Failed to create Ombi user (%d): %s", code, err)
|
||||||
app.debug.Printf("Errors reported by Ombi: %s", strings.Join(errors, ", "))
|
app.debug.Printf("Errors reported by Ombi: %s", strings.Join(errors, ", "))
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
app.info.Println("Created Ombi user")
|
ombiUser, status, err = app.getOmbiUser(id)
|
||||||
if discordVerified || telegramVerified {
|
|
||||||
ombiUser, status, err := app.getOmbiUser(id)
|
|
||||||
if status != 200 || err != nil {
|
if status != 200 || err != nil {
|
||||||
app.err.Printf("Failed to get Ombi user (%d): %v", status, err)
|
app.err.Printf("Failed to get Ombi user (%d): %v", status, err)
|
||||||
} else {
|
} else {
|
||||||
|
app.info.Println("Created Ombi user")
|
||||||
|
accountExists = true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if accountExists {
|
||||||
|
if discordVerified || telegramVerified {
|
||||||
dID := ""
|
dID := ""
|
||||||
tUser := ""
|
tUser := ""
|
||||||
if discordVerified {
|
if discordVerified {
|
||||||
@ -403,7 +421,6 @@ func (app *appContext) newUser(req newUserDTO, confirmed bool) (f errorFunc, suc
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
} else {
|
} else {
|
||||||
app.debug.Printf("Skipping Ombi: Profile \"%s\" was empty", invite.Profile)
|
app.debug.Printf("Skipping Ombi: Profile \"%s\" was empty", invite.Profile)
|
||||||
}
|
}
|
||||||
@ -1214,17 +1231,7 @@ func (app *appContext) ApplySettings(gc *gin.Context) {
|
|||||||
// newUser["userName"] = user["userName"]
|
// newUser["userName"] = user["userName"]
|
||||||
// newUser["alias"] = user["alias"]
|
// newUser["alias"] = user["alias"]
|
||||||
// newUser["emailAddress"] = user["emailAddress"]
|
// newUser["emailAddress"] = user["emailAddress"]
|
||||||
for k, v := range ombi {
|
status, err = app.applyOmbiProfile(user, ombi)
|
||||||
switch v.(type) {
|
|
||||||
case map[string]interface{}, []interface{}:
|
|
||||||
user[k] = v
|
|
||||||
default:
|
|
||||||
if v != user[k] {
|
|
||||||
user[k] = v
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
status, err = app.ombi.ModifyUser(user)
|
|
||||||
if status != 200 || err != nil {
|
if status != 200 || err != nil {
|
||||||
errorString += fmt.Sprintf("Apply %d: %v ", status, err)
|
errorString += fmt.Sprintf("Apply %d: %v ", status, err)
|
||||||
}
|
}
|
||||||
|
2
api.go
2
api.go
@ -182,7 +182,7 @@ func (app *appContext) ResetSetPassword(gc *gin.Context) {
|
|||||||
}
|
}
|
||||||
if app.config.Section("ombi").Key("enabled").MustBool(false) {
|
if app.config.Section("ombi").Key("enabled").MustBool(false) {
|
||||||
// Silently fail for changing ombi passwords
|
// Silently fail for changing ombi passwords
|
||||||
if status != 200 || err != nil {
|
if (status != 200 && status != 204) || err != nil {
|
||||||
app.err.Printf("Failed to get user \"%s\" from jellyfin/emby (%d): %v", username, status, err)
|
app.err.Printf("Failed to get user \"%s\" from jellyfin/emby (%d): %v", username, status, err)
|
||||||
respondBool(200, true, gc)
|
respondBool(200, true, gc)
|
||||||
return
|
return
|
||||||
|
Loading…
Reference in New Issue
Block a user