aboutsummaryrefslogtreecommitdiffstats
path: root/storage/filesystem/config.go
blob: 4b479371b453edb8a8e1b9525735c32130e9bf29 (plain) (blame)
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
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
package filesystem

import (
	"os"

	"gopkg.in/src-d/go-git.v4/config"
	gitconfig "gopkg.in/src-d/go-git.v4/formats/config"
	"gopkg.in/src-d/go-git.v4/storage/filesystem/internal/dotgit"
)

const (
	remoteSection = "remote"
	fetchKey      = "fetch"
	urlKey        = "url"
)

type ConfigStorage struct {
	dir *dotgit.DotGit
}

func (c *ConfigStorage) Config() (*config.Config, error) {
	cfg := config.NewConfig()

	ini, err := c.unmarshal()
	if err != nil {
		return nil, err
	}

	sect := ini.Section(remoteSection)
	for _, s := range sect.Subsections {
		r := c.unmarshalRemote(s)
		cfg.Remotes[r.Name] = r
	}

	return cfg, nil
}

func (c *ConfigStorage) unmarshal() (*gitconfig.Config, error) {
	cfg := gitconfig.New()

	f, err := c.dir.Config()
	if err != nil {
		if os.IsNotExist(err) {
			return cfg, nil
		}

		return nil, err
	}

	defer f.Close()

	d := gitconfig.NewDecoder(f)
	if err := d.Decode(cfg); err != nil {
		return nil, err
	}

	return cfg, nil
}

func (c *ConfigStorage) unmarshalRemote(s *gitconfig.Subsection) *config.RemoteConfig {
	fetch := []config.RefSpec{}
	for _, f := range s.Options.GetAll(fetchKey) {
		rs := config.RefSpec(f)
		if rs.IsValid() {
			fetch = append(fetch, rs)
		}
	}

	return &config.RemoteConfig{
		Name:  s.Name,
		URL:   s.Option(urlKey),
		Fetch: fetch,
	}
}

func (c *ConfigStorage) SetConfig(cfg *config.Config) error {
	if err := cfg.Validate(); err != nil {
		return err
	}

	ini, err := c.unmarshal()
	if err != nil {
		return err
	}

	s := ini.Section(remoteSection)
	s.Subsections = make(gitconfig.Subsections, len(cfg.Remotes))

	var i int
	for _, r := range cfg.Remotes {
		s.Subsections[i] = c.marshalRemote(r)
		i++
	}

	return c.marshal(ini)
}

func (c *ConfigStorage) marshal(ini *gitconfig.Config) error {
	f, err := c.dir.ConfigWriter()
	if err != nil {
		return err
	}

	defer f.Close()

	e := gitconfig.NewEncoder(f)
	return e.Encode(ini)
}

func (c *ConfigStorage) marshalRemote(r *config.RemoteConfig) *gitconfig.Subsection {
	s := &gitconfig.Subsection{Name: r.Name}
	s.AddOption(urlKey, r.URL)
	for _, rs := range r.Fetch {
		s.AddOption(fetchKey, rs.String())
	}

	return s
}