mirror of
https://github.com/AdguardTeam/AdGuardHome.git
synced 2024-12-16 03:45:45 +03:00
94 lines
2.0 KiB
Go
94 lines
2.0 KiB
Go
|
package filtering
|
||
|
|
||
|
import (
|
||
|
"encoding/json"
|
||
|
"net/http"
|
||
|
|
||
|
"github.com/AdguardTeam/AdGuardHome/internal/aghhttp"
|
||
|
"github.com/AdguardTeam/golibs/log"
|
||
|
)
|
||
|
|
||
|
// TODO(d.kolyshev): Use [rewrite.Item] instead.
|
||
|
type rewriteEntryJSON struct {
|
||
|
Domain string `json:"domain"`
|
||
|
Answer string `json:"answer"`
|
||
|
}
|
||
|
|
||
|
func (d *DNSFilter) handleRewriteList(w http.ResponseWriter, r *http.Request) {
|
||
|
arr := []*rewriteEntryJSON{}
|
||
|
|
||
|
d.confLock.Lock()
|
||
|
for _, ent := range d.Config.Rewrites {
|
||
|
jsent := rewriteEntryJSON{
|
||
|
Domain: ent.Domain,
|
||
|
Answer: ent.Answer,
|
||
|
}
|
||
|
arr = append(arr, &jsent)
|
||
|
}
|
||
|
d.confLock.Unlock()
|
||
|
|
||
|
_ = aghhttp.WriteJSONResponse(w, r, arr)
|
||
|
}
|
||
|
|
||
|
func (d *DNSFilter) handleRewriteAdd(w http.ResponseWriter, r *http.Request) {
|
||
|
rwJSON := rewriteEntryJSON{}
|
||
|
err := json.NewDecoder(r.Body).Decode(&rwJSON)
|
||
|
if err != nil {
|
||
|
aghhttp.Error(r, w, http.StatusBadRequest, "json.Decode: %s", err)
|
||
|
|
||
|
return
|
||
|
}
|
||
|
|
||
|
rw := &LegacyRewrite{
|
||
|
Domain: rwJSON.Domain,
|
||
|
Answer: rwJSON.Answer,
|
||
|
}
|
||
|
|
||
|
err = rw.normalize()
|
||
|
if err != nil {
|
||
|
// Shouldn't happen currently, since normalize only returns a non-nil
|
||
|
// error when a rewrite is nil, but be change-proof.
|
||
|
aghhttp.Error(r, w, http.StatusBadRequest, "normalizing: %s", err)
|
||
|
|
||
|
return
|
||
|
}
|
||
|
|
||
|
d.confLock.Lock()
|
||
|
d.Config.Rewrites = append(d.Config.Rewrites, rw)
|
||
|
d.confLock.Unlock()
|
||
|
log.Debug("rewrite: added element: %s -> %s [%d]", rw.Domain, rw.Answer, len(d.Config.Rewrites))
|
||
|
|
||
|
d.Config.ConfigModified()
|
||
|
}
|
||
|
|
||
|
func (d *DNSFilter) handleRewriteDelete(w http.ResponseWriter, r *http.Request) {
|
||
|
jsent := rewriteEntryJSON{}
|
||
|
err := json.NewDecoder(r.Body).Decode(&jsent)
|
||
|
if err != nil {
|
||
|
aghhttp.Error(r, w, http.StatusBadRequest, "json.Decode: %s", err)
|
||
|
|
||
|
return
|
||
|
}
|
||
|
|
||
|
entDel := &LegacyRewrite{
|
||
|
Domain: jsent.Domain,
|
||
|
Answer: jsent.Answer,
|
||
|
}
|
||
|
arr := []*LegacyRewrite{}
|
||
|
|
||
|
d.confLock.Lock()
|
||
|
for _, ent := range d.Config.Rewrites {
|
||
|
if ent.equal(entDel) {
|
||
|
log.Debug("rewrite: removed element: %s -> %s", ent.Domain, ent.Answer)
|
||
|
|
||
|
continue
|
||
|
}
|
||
|
|
||
|
arr = append(arr, ent)
|
||
|
}
|
||
|
d.Config.Rewrites = arr
|
||
|
d.confLock.Unlock()
|
||
|
|
||
|
d.Config.ConfigModified()
|
||
|
}
|