fix(ap): lock db and return error in createFollow
This commit is contained in:
@@ -313,6 +313,9 @@ func (r *SqlFollowersRepository) Update(actorIRI string, inbox string, sharedInb
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (r *SqlFollowersRepository) createFollow(actor, inbox, sharedInbox, request, name, username, image string, requestObject []byte, approved bool) error {
|
func (r *SqlFollowersRepository) createFollow(actor, inbox, sharedInbox, request, name, username, image string, requestObject []byte, approved bool) error {
|
||||||
|
r.datastore.DbLock.Lock()
|
||||||
|
defer r.datastore.DbLock.Unlock()
|
||||||
|
|
||||||
tx, err := r.datastore.DB.Begin()
|
tx, err := r.datastore.DB.Begin()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return errors.Wrap(err, "error beginning transaction")
|
return errors.Wrap(err, "error beginning transaction")
|
||||||
@@ -340,7 +343,7 @@ func (r *SqlFollowersRepository) createFollow(actor, inbox, sharedInbox, request
|
|||||||
Request: request,
|
Request: request,
|
||||||
RequestObject: requestObject,
|
RequestObject: requestObject,
|
||||||
}); err != nil {
|
}); err != nil {
|
||||||
log.Errorln("error creating new federation follow: ", err)
|
return errors.Wrap(err, "error creating new federation follow")
|
||||||
}
|
}
|
||||||
|
|
||||||
return tx.Commit()
|
return tx.Commit()
|
||||||
|
|||||||
Reference in New Issue
Block a user