|
@@ -75,7 +75,7 @@ func createEgress(w http.ResponseWriter, r *http.Request) {
|
|
logic.ReturnErrorResponse(w, r, logic.FormatError(errors.New("invalid egress request"), "badrequest"))
|
|
logic.ReturnErrorResponse(w, r, logic.FormatError(errors.New("invalid egress request"), "badrequest"))
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- err = e.Create(db.WithContext(context.TODO()))
|
|
|
|
|
|
+ err = e.Create(db.WithContext(r.Context()))
|
|
if err != nil {
|
|
if err != nil {
|
|
logic.ReturnErrorResponse(
|
|
logic.ReturnErrorResponse(
|
|
w,
|
|
w,
|
|
@@ -105,7 +105,7 @@ func listEgress(w http.ResponseWriter, r *http.Request) {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
e := schema.Egress{Network: network}
|
|
e := schema.Egress{Network: network}
|
|
- list, err := e.ListByNetwork(db.WithContext(context.TODO()))
|
|
|
|
|
|
+ list, err := e.ListByNetwork(db.WithContext(r.Context()))
|
|
if err != nil {
|
|
if err != nil {
|
|
logic.ReturnErrorResponse(
|
|
logic.ReturnErrorResponse(
|
|
w,
|
|
w,
|
|
@@ -148,7 +148,7 @@ func updateEgress(w http.ResponseWriter, r *http.Request) {
|
|
}
|
|
}
|
|
|
|
|
|
e := schema.Egress{ID: req.ID}
|
|
e := schema.Egress{ID: req.ID}
|
|
- err = e.Get(db.WithContext(context.TODO()))
|
|
|
|
|
|
+ err = e.Get(db.WithContext(r.Context()))
|
|
if err != nil {
|
|
if err != nil {
|
|
logic.ReturnErrorResponse(w, r, logic.FormatError(err, "badrequest"))
|
|
logic.ReturnErrorResponse(w, r, logic.FormatError(err, "badrequest"))
|
|
return
|
|
return
|
|
@@ -213,7 +213,7 @@ func deleteEgress(w http.ResponseWriter, r *http.Request) {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
e := schema.Egress{ID: id}
|
|
e := schema.Egress{ID: id}
|
|
- err := e.Delete(db.WithContext(context.TODO()))
|
|
|
|
|
|
+ err := e.Delete(db.WithContext(r.Context()))
|
|
if err != nil {
|
|
if err != nil {
|
|
logic.ReturnErrorResponse(w, r, logic.FormatError(err, "internal"))
|
|
logic.ReturnErrorResponse(w, r, logic.FormatError(err, "internal"))
|
|
return
|
|
return
|