1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
package hook
import (
"context"
"gitlab.com/gitlab-org/gitaly/v16/internal/git"
"gitlab.com/gitlab-org/gitaly/v16/internal/transaction/txinfo"
"gitlab.com/gitlab-org/gitaly/v16/internal/transaction/voting"
)
func isPrimary(payload git.HooksPayload) bool {
if payload.Transaction == nil {
return true
}
return payload.Transaction.Primary
}
// transactionHandler is a callback invoked on a transaction if it exists.
type transactionHandler func(ctx context.Context, tx txinfo.Transaction) error
// runWithTransaction runs the given function if the payload identifies a transaction. No error
// is returned if no transaction exists. If a transaction exists and the function is executed on it,
// then its error will ber returned directly.
func (m *GitLabHookManager) runWithTransaction(ctx context.Context, payload git.HooksPayload, handler transactionHandler) error {
if payload.Transaction == nil {
return nil
}
if err := handler(ctx, *payload.Transaction); err != nil {
return err
}
return nil
}
func (m *GitLabHookManager) voteOnTransaction(
ctx context.Context,
vote voting.Vote,
phase voting.Phase,
payload git.HooksPayload,
) error {
return m.runWithTransaction(ctx, payload, func(ctx context.Context, tx txinfo.Transaction) error {
return m.txManager.Vote(ctx, tx, vote, phase)
})
}
func (m *GitLabHookManager) stopTransaction(ctx context.Context, payload git.HooksPayload) error {
return m.runWithTransaction(ctx, payload, func(ctx context.Context, tx txinfo.Transaction) error {
return m.txManager.Stop(ctx, tx)
})
}
|
