refactor: notification module

This commit is contained in:
Jacky 2025-02-25 19:06:39 +08:00
parent 34fa4eb204
commit ab46d1de7e
No known key found for this signature in database
GPG key ID: 215C21B10DF38B4D
41 changed files with 3989 additions and 2411 deletions

View file

@ -66,14 +66,14 @@ func syncDisable(name string) {
SetHeader("X-Node-Secret", node.Token).
Post(fmt.Sprintf("/api/streams/%s/disable", name))
if err != nil {
notification.Error("Disable Remote Stream Error", err.Error())
notification.Error("Disable Remote Stream Error", err.Error(), nil)
return
}
if resp.StatusCode() != http.StatusOK {
notification.Error("Disable Remote Stream Error", NewSyncResult(node.Name, name, resp).String())
notification.Error("Disable Remote Stream Error", "Disable stream %{name} from %{node} failed", NewSyncResult(node.Name, name, resp))
return
}
notification.Success("Disable Remote Stream Success", NewSyncResult(node.Name, name, resp).String())
notification.Success("Disable Remote Stream Success", "Disable stream %{name} from %{node} successfully", NewSyncResult(node.Name, name, resp))
}()
}