1diff --git a/config.example.scfg b/config.example.scfg
2index 3961e51ddb60a7deb021ad48db74525d2eae913e..9de249b5a5f90bf9c59566794da9333add87a06d 100644
3--- a/config.example.scfg
4+++ b/config.example.scfg
5@@ -1,4 +1,9 @@
6+# for tcp biding
7+# listen-addr tcp://localhost:8080
8+listen-addr unix://var/run/cerrado.sock
9+
10 root-readme /srv/git/README.md
11+
12 scan /srv/git/ {
13 public true
14 }
15diff --git a/main.go b/main.go
16index eedff5eb6a12149528573530facbba8b740bd578..18b73ff0fd202e715f3f6721bdc26d36fcebee0a 100644
17--- a/main.go
18+++ b/main.go
19@@ -4,7 +4,6 @@ import (
20 "context"
21 "flag"
22 "log/slog"
23- "net/http"
24 "os"
25 "os/signal"
26 "time"
27@@ -16,7 +15,6 @@ "git.gabrielgio.me/cerrado/pkg/worker"
28 )
29
30 func main() {
31-
32 ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt, os.Kill)
33 defer stop()
34 if err := run(ctx); err != nil {
35@@ -27,7 +25,7 @@ }
36
37 func run(ctx context.Context) error {
38 var (
39- configPath = flag.String("config", "config.example.scfg", "File path for the configuration file")
40+ configPath = flag.String("config", "/etc/cerrado.scfg", "File path for the configuration file")
41 )
42
43 flag.Parse()
44@@ -46,7 +44,7 @@ if err != nil {
45 return err
46 }
47
48- serverTask := worker.NewServerTask(&http.Server{Handler: handler, Addr: "0.0.0.0:8080"})
49+ serverTask := worker.NewServerTask(configRepo.GetListenAddr(), handler)
50
51 pool := worker.NewTaskPool()
52 pool.AddTask("http-server", 5*time.Second, serverTask)
53diff --git a/pkg/config/config.go b/pkg/config/config.go
54index 3e539f7091a7b2b1e39ee96b7bd54136d052fd2b..0e85b5abb5231e21caf6a1a3db5c6168709cc10b 100644
55--- a/pkg/config/config.go
56+++ b/pkg/config/config.go
57@@ -32,6 +32,7 @@ // fields needs to be exported to cmp to work
58 configuration struct {
59 Scan *scan
60 RootReadme string
61+ ListenAddr string
62 Repositories []*GitRepositoryConfiguration
63 }
64
65@@ -49,6 +50,7 @@ // This holds all the function necessary to ask for configuration
66 // information.
67 ConfigurationRepository struct {
68 rootReadme string
69+ listenAddr string
70 repositories []*GitRepositoryConfiguration
71 }
72 )
73@@ -66,6 +68,7 @@ }
74
75 repo := &ConfigurationRepository{
76 rootReadme: config.RootReadme,
77+ listenAddr: config.ListenAddr,
78 repositories: config.Repositories,
79 }
80
81@@ -83,6 +86,10 @@
82 // GetRootReadme returns root read path
83 func (c *ConfigurationRepository) GetRootReadme() string {
84 return c.rootReadme
85+}
86+
87+func (c *ConfigurationRepository) GetListenAddr() string {
88+ return c.listenAddr
89 }
90
91 // GetByName returns configuration of repository for a given name.
92@@ -157,6 +164,11 @@ if err != nil {
93 return nil, err
94 }
95
96+ err = setListenAddr(block, &config.ListenAddr)
97+ if err != nil {
98+ return nil, err
99+ }
100+
101 err = setRepositories(block, &config.Repositories)
102 if err != nil {
103 return nil, err
104@@ -215,6 +227,7 @@ func defaultConfiguration() *configuration {
105 return &configuration{
106 Scan: defaultScan(),
107 RootReadme: "",
108+ ListenAddr: "http//0.0.0.0:8080",
109 Repositories: make([]*GitRepositoryConfiguration, 0),
110 }
111 }
112@@ -239,6 +252,11 @@
113 func setRootReadme(block scfg.Block, readme *string) error {
114 scanDir := block.Get("root-readme")
115 return setString(scanDir, readme)
116+}
117+
118+func setListenAddr(block scfg.Block, listenAddr *string) error {
119+ scanDir := block.Get("listen-addr")
120+ return setString(scanDir, listenAddr)
121 }
122
123 func setScan(block scfg.Block, scan *scan) error {
124diff --git a/pkg/worker/http.go b/pkg/worker/http.go
125index 973775e14ea0374073c0c59af15a908bdf1254e0..c4f99504bf9d8968e05cd4f27e8375af9cad7909 100644
126--- a/pkg/worker/http.go
127+++ b/pkg/worker/http.go
128@@ -2,24 +2,41 @@ package worker
129
130 import (
131 "context"
132+ "errors"
133+ "net"
134 "net/http"
135+ "net/url"
136+)
137+
138+var (
139+ UnsupportedSchemeErr = errors.New("Ivalid schema, only tcp and unix supported")
140 )
141
142 type ServerTask struct {
143- server *http.Server
144+ addr string
145+ handler http.Handler
146 }
147
148-func NewServerTask(server *http.Server) *ServerTask {
149+func NewServerTask(addr string, handler http.Handler) *ServerTask {
150 return &ServerTask{
151- server: server,
152+ addr: addr,
153+ handler: handler,
154 }
155 }
156
157-func (self *ServerTask) Start(ctx context.Context) error {
158+func (s *ServerTask) Start(ctx context.Context) error {
159 done := make(chan error)
160+
161+ listen, err := getListen(s.addr)
162+ if err != nil {
163+ return err
164+ }
165+ server := &http.Server{
166+ Handler: s.handler,
167+ }
168
169 go func() {
170- done <- self.server.ListenAndServe()
171+ done <- server.Serve(listen)
172 }()
173
174 select {
175@@ -33,6 +50,26 @@ // in case of context canceled it will manually trigger the server to
176 // shutdown, and return its error, which is most cases, but not limited, is
177 // context.Canceled.
178 case <-ctx.Done():
179- return self.server.Shutdown(ctx)
180+ return server.Shutdown(ctx)
181+ }
182+}
183+
184+func getListen(addr string) (net.Listener, error) {
185+ u, err := url.Parse(addr)
186+ if err != nil {
187+ return nil, err
188+ }
189+
190+ switch u.Scheme {
191+ case "tcp":
192+ return net.Listen(u.Scheme, u.Host)
193+ case "unix":
194+ host, err := url.JoinPath("/", u.Host, u.Path)
195+ if err != nil {
196+ return nil, err
197+ }
198+ return net.Listen(u.Scheme, host)
199+ default:
200+ return nil, UnsupportedSchemeErr
201 }
202 }