Avoid emitting errors on duplicate Stadia requests
This commit is contained in:
parent
cfe166c0f2
commit
e93c88003e
1 changed files with 4 additions and 3 deletions
|
|
@ -68,12 +68,13 @@ func restyMiddleware(rclient *resty.Client, response *resty.Response) error {
|
||||||
CreatedAt: time.Now(),
|
CreatedAt: time.Now(),
|
||||||
Request: u,
|
Request: u,
|
||||||
Response: string(resp_bytes),
|
Response: string(resp_bytes),
|
||||||
}).RETURNING(table.APIRequest.AllColumns)
|
}).ON_CONFLICT(table.APIRequest.Request).DO_NOTHING().
|
||||||
data, err := db.ExecuteOne[model.APIRequest](ctx, statement)
|
RETURNING(table.APIRequest.AllColumns)
|
||||||
|
_, err = db.ExecuteOne[model.APIRequest](ctx, statement)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Error().Err(err).Msg("failed to insert stadia request")
|
log.Error().Err(err).Msg("failed to insert stadia request")
|
||||||
} else {
|
} else {
|
||||||
log.Debug().Int64("id", data.ID).Msg("Created stadia request cache entry")
|
log.Debug().Msg("Created stadia request cache entry")
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue