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
|
package main
import (
"context"
"fmt"
"io"
"os"
"path/filepath"
"gitlab.com/gitlab-org/gitaly/v16/internal/git/smudge"
"gitlab.com/gitlab-org/gitaly/v16/internal/helper/env"
gitalylog "gitlab.com/gitlab-org/gitaly/v16/internal/log"
"gitlab.com/gitlab-org/labkit/log"
"gitlab.com/gitlab-org/labkit/tracing"
)
func requireStdin(msg string) {
var out string
stat, err := os.Stdin.Stat()
if err != nil {
out = fmt.Sprintf("Cannot read from STDIN. %s (%s)", msg, err)
} else if (stat.Mode() & os.ModeCharDevice) != 0 {
out = fmt.Sprintf("Cannot read from STDIN. %s", msg)
}
if len(out) > 0 {
fmt.Println(out)
os.Exit(1)
}
}
func main() {
requireStdin("This command should be run by the Git 'smudge' filter")
closer, err := initLogging(os.Environ())
if err != nil {
fmt.Fprintf(os.Stderr, "error initializing log file for gitaly-lfs-smudge: %v", err)
}
defer closer.Close()
if err := run(os.Environ(), os.Stdout, os.Stdin); err != nil {
log.WithError(err).Error(err)
os.Exit(1)
}
}
func initLogging(environment []string) (io.Closer, error) {
path := env.ExtractValue(environment, gitalylog.GitalyLogDirEnvKey)
if path == "" {
return log.Initialize(log.WithWriter(io.Discard))
}
filepath := filepath.Join(path, "gitaly_lfs_smudge.log")
return log.Initialize(
log.WithFormatter("json"),
log.WithLogLevel("info"),
log.WithOutputName(filepath),
)
}
func run(environment []string, out io.Writer, in io.Reader) error {
// Since the environment is sanitized at the moment, we're only
// using this to extract the correlation ID. The finished() call
// to clean up the tracing will be a NOP here.
ctx, finished := tracing.ExtractFromEnv(context.Background())
defer finished()
cfg, err := smudge.ConfigFromEnvironment(environment)
if err != nil {
return fmt.Errorf("loading configuration: %w", err)
}
switch cfg.DriverType {
case smudge.DriverTypeFilter:
if err := filter(ctx, cfg, out, in); err != nil {
return fmt.Errorf("running smudge filter: %w", err)
}
return nil
case smudge.DriverTypeProcess:
if err := process(ctx, cfg, out, in); err != nil {
return fmt.Errorf("running smudge process: %w", err)
}
return nil
default:
return fmt.Errorf("unknown driver type: %v", cfg.DriverType)
}
}
|
