Skip to content

Commit e2080e8

Browse files
Create and commit xorm session
1 parent d3eb84f commit e2080e8

File tree

1 file changed

+30
-2
lines changed

1 file changed

+30
-2
lines changed

models/repo_collaboration.go

Lines changed: 30 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,21 @@ func (repo *Repository) addCollaborator(e Engine, u *User) error {
4848

4949
// AddCollaborator adds new collaboration to a repository with default access mode.
5050
func (repo *Repository) AddCollaborator(u *User) error {
51-
return repo.addCollaborator(x, u)
51+
sess := x.NewSession()
52+
defer sess.Close()
53+
if err = sess.Begin(); err != nil {
54+
return err
55+
}
56+
57+
if err = repo.addCollaborator(sess, u); err != nil {
58+
return err
59+
}
60+
61+
if err = sess.Commit(); err != nil {
62+
return err
63+
}
64+
65+
return nil
5266
}
5367

5468
func (repo *Repository) getCollaborations(e Engine) ([]*Collaboration, error) {
@@ -132,7 +146,21 @@ func (repo *Repository) changeCollaborationAccessMode(e Engine, uid int64, mode
132146

133147
// ChangeCollaborationAccessMode sets new access mode for the collaboration.
134148
func (repo *Repository) ChangeCollaborationAccessMode(uid int64, mode AccessMode) error {
135-
return repo.changeCollaborationAccessMode(x, uid, mode)
149+
sess := x.NewSession()
150+
defer sess.Close()
151+
if err = sess.Begin(); err != nil {
152+
return err
153+
}
154+
155+
if err = repo.changeCollaborationAccessMode(sess, uid, mode); err != nil {
156+
return err
157+
}
158+
159+
if err = sess.Commit(); err != nil {
160+
return err
161+
}
162+
163+
return nil
136164
}
137165

138166
// DeleteCollaboration removes collaboration relation between the user and repository.

0 commit comments

Comments
 (0)