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
|
package server
import (
"context"
"gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16/internal/module/modserver"
"gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16/internal/module/modshared"
"gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16/internal/module/notifications/rpc"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
)
type gitPushPublisherFunc func(ctx context.Context, e *modserver.Project) error
func newServer(gitPushPublisher gitPushPublisherFunc) *server {
return &server{
gitPushPublisher: gitPushPublisher,
}
}
type server struct {
rpc.UnimplementedNotificationsServer
gitPushPublisher gitPushPublisherFunc
}
func (s *server) GitPushEvent(ctx context.Context, req *rpc.GitPushEventRequest) (*rpc.GitPushEventResponse, error) {
err := s.gitPushPublisher(ctx, &modserver.Project{
Id: req.Project.Id,
FullPath: req.Project.FullPath,
})
if err != nil {
rpcApi := modserver.RpcApiFromContext(ctx)
rpcApi.HandleProcessingError(rpcApi.Log(), modshared.NoAgentId, "failed to publish received git push event", err)
return nil, status.Errorf(codes.Unavailable, "Failed to publish received git push event: %v", err)
}
return &rpc.GitPushEventResponse{}, nil
}
|
