Protect changing in parallel using HTTP 412 precondition failed
This commit is contained in:
parent
90d896e1cc
commit
4dc8be7bd3
|
|
@ -116,11 +116,47 @@ func main() {
|
||||||
Priority: 999, // execute as latest as possible to allow users to provide their own route
|
Priority: 999, // execute as latest as possible to allow users to provide their own route
|
||||||
})
|
})
|
||||||
|
|
||||||
|
app.OnRecordViewRequest().BindFunc(addLastModified)
|
||||||
|
|
||||||
|
app.OnRecordUpdateRequest().BindFunc(ifUnmodifiedSince)
|
||||||
|
|
||||||
|
app.OnRecordDeleteRequest().BindFunc(ifUnmodifiedSince)
|
||||||
|
|
||||||
if err := app.Start(); err != nil {
|
if err := app.Start(); err != nil {
|
||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func addLastModified(e *core.RecordRequestEvent) error {
|
||||||
|
updated := e.Record.GetString("updated")
|
||||||
|
|
||||||
|
if updated != "" {
|
||||||
|
e.Response.Header().Add("Last-Modified", updated)
|
||||||
|
}
|
||||||
|
|
||||||
|
return e.Next()
|
||||||
|
}
|
||||||
|
|
||||||
|
func ifUnmodifiedSince(e *core.RecordRequestEvent) error {
|
||||||
|
updated := e.Record.GetString("updated")
|
||||||
|
|
||||||
|
if updated != "" {
|
||||||
|
header := e.Request.Header.Get("If-Unmodified-Since")
|
||||||
|
|
||||||
|
if header == "" || header != updated {
|
||||||
|
e.Response.Header().Add("Last-Modified", updated)
|
||||||
|
|
||||||
|
if header == "" {
|
||||||
|
return e.Error(http.StatusPreconditionRequired, "Header If-Unmodified-Since is required", nil)
|
||||||
|
} else if header != updated {
|
||||||
|
return e.Error(http.StatusPreconditionFailed, "Record was modified after retrieval", nil)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return e.Next()
|
||||||
|
}
|
||||||
|
|
||||||
// the default pb_public dir location is relative to the executable
|
// the default pb_public dir location is relative to the executable
|
||||||
func defaultPublicDir() string {
|
func defaultPublicDir() string {
|
||||||
if osutils.IsProbablyGoRun() {
|
if osutils.IsProbablyGoRun() {
|
||||||
|
|
|
||||||
|
|
@ -278,7 +278,11 @@
|
||||||
if (isNew) {
|
if (isNew) {
|
||||||
result = await ApiClient.collection(collection.id).create(data);
|
result = await ApiClient.collection(collection.id).create(data);
|
||||||
} else {
|
} else {
|
||||||
result = await ApiClient.collection(collection.id).update(record.id, data);
|
result = await ApiClient.collection(collection.id).update(record.id, data, {
|
||||||
|
headers: {
|
||||||
|
"If-Unmodified-Since": record.updated,
|
||||||
|
},
|
||||||
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
addSuccessToast(isNew ? "Successfully created record." : "Successfully updated record.");
|
addSuccessToast(isNew ? "Successfully created record." : "Successfully updated record.");
|
||||||
|
|
@ -318,7 +322,11 @@
|
||||||
|
|
||||||
confirm(`Do you really want to delete the selected record?`, () => {
|
confirm(`Do you really want to delete the selected record?`, () => {
|
||||||
return ApiClient.collection(original.collectionId)
|
return ApiClient.collection(original.collectionId)
|
||||||
.delete(original.id)
|
.delete(original.id, {
|
||||||
|
headers: {
|
||||||
|
"If-Unmodified-Since": record.updated,
|
||||||
|
},
|
||||||
|
})
|
||||||
.then(() => {
|
.then(() => {
|
||||||
forceHide();
|
forceHide();
|
||||||
addSuccessToast("Successfully deleted record.");
|
addSuccessToast("Successfully deleted record.");
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue