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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
package hook
import (
"bytes"
"fmt"
"io"
"strings"
"testing"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"gitlab.com/gitlab-org/gitaly/v14/internal/git"
"gitlab.com/gitlab-org/gitaly/v14/internal/git/gittest"
"gitlab.com/gitlab-org/gitaly/v14/internal/helper/text"
"gitlab.com/gitlab-org/gitaly/v14/internal/metadata/featureflag"
"gitlab.com/gitlab-org/gitaly/v14/internal/testhelper"
"gitlab.com/gitlab-org/gitaly/v14/internal/testhelper/testcfg"
"gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"
"google.golang.org/grpc/codes"
)
func TestUpdateInvalidArgument(t *testing.T) {
cfg := testcfg.Build(t)
serverSocketPath := runHooksServer(t, cfg, nil)
client, conn := newHooksClient(t, serverSocketPath)
t.Cleanup(func() { conn.Close() })
ctx := testhelper.Context(t)
stream, err := client.UpdateHook(ctx, &gitalypb.UpdateHookRequest{})
require.NoError(t, err)
_, err = stream.Recv()
testhelper.RequireGrpcCode(t, err, codes.InvalidArgument)
}
func TestUpdate_CustomHooks(t *testing.T) {
ctx := testhelper.Context(t)
cfg, repo, repoPath, client := setupHookService(ctx, t)
hooksPayload, err := git.NewHooksPayload(
cfg,
repo,
nil,
&git.ReceiveHooksPayload{
UserID: "key-123",
Username: "username",
Protocol: "web",
},
git.UpdateHook,
featureflag.RawFromContext(ctx),
).Env()
require.NoError(t, err)
envVars := []string{
hooksPayload,
}
req := gitalypb.UpdateHookRequest{
Repository: repo,
Ref: []byte("master"),
OldValue: strings.Repeat("a", 40),
NewValue: strings.Repeat("b", 40),
EnvironmentVariables: envVars,
}
errorMsg := "error123"
gittest.WriteCustomHook(t, repoPath, "update", []byte(fmt.Sprintf(`#!/bin/bash
echo %s 1>&2
exit 1
`, errorMsg)))
stream, err := client.UpdateHook(ctx, &req)
require.NoError(t, err)
var status int32
var stderr, stdout bytes.Buffer
for {
resp, err := stream.Recv()
if err == io.EOF {
break
}
require.NoError(t, err, "when receiving stream")
stderr.Write(resp.GetStderr())
stdout.Write(resp.GetStdout())
status = resp.GetExitStatus().GetValue()
}
assert.Equal(t, int32(1), status)
assert.Equal(t, errorMsg, text.ChompBytes(stderr.Bytes()), "hook stderr")
assert.Equal(t, "", text.ChompBytes(stdout.Bytes()), "hook stdout")
}
|
