camptocamp / terraboard / 308

Committed 18 Jan 2021 11:06AM UTC coverage: 13.818%. First build

Build # 308

Build Type

Pull #133

travis-ci

Committed by

web-flow

Commit Message

<a href="https://github.com/camptocamp/terraboard/commit/<a class=hub.com/camptocamp/terraboard/commit/<a class="double-link" href="https://git"><a class=hub.com/camptocamp/terraboard/commit/<a class="double-link" href="https://git"><a class=hub.com/camptocamp/terraboard/commit/<a class="double-link" href="https://git"><a class=hub.com/camptocamp/terraboard/commit/c7c09acefe918d08c009519f8d041da24b664dd1">c7c09acef">&lt;a href=&quot;https://github.com/camptocamp/terraboard/commit/</a><a class="double-link" href="https://github.com/camptocamp/terraboard/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/camptocamp/terraboard/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/camptocamp/terraboard/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/camptocamp/terraboard/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/camptocamp/terraboard/commit/c7c09acefe918d08c009519f8d041da24b664dd1">c7c09acef</a><a href="https://github.com/camptocamp/terraboard/commit/c7c09acefe918d08c009519f8d041da24b664dd1">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/camptocamp/terraboard/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/camptocamp/terraboard/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/camptocamp/terraboard/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/camptocamp/terraboard/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/camptocamp/terraboard/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/camptocamp/terraboard/commit/c7c09acefe918d08c009519f8d041da24b664dd1&quot;&gt;c7c09acef&lt;/a&gt;&lt;a href=&quot;https://github.com/camptocamp/terraboard/commit/c7c09acefe918d08c009519f8d041da24b664dd1&quot;&gt;&amp;quot;&amp;gt;&amp;amp;lt;a href=&amp;amp;quot;https://github.com/camptocamp/terraboard/commit/&amp;lt;/a&amp;gt;&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp... (continued)

Pull Request Pull Request #133: Fixed failing CI following recent changes introducing GitLab backend support

Run Details

8 of 8 new or added lines in 1 file covered. (100.0%)

207 of 1498 relevant lines covered (13.82%)

0.16 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/state/gitlab.go

package state

import (
        "bytes"
        "fmt"
        "net/url"
        "regexp"
        "strconv"

        "github.com/camptocamp/terraboard/config"
        "github.com/camptocamp/terraboard/pkg/client/gitlab"
        "github.com/hashicorp/terraform/states/statefile"
)

// Gitlab is a state provider type, leveraging GitLab
type Gitlab struct {
        Client gitlab.Client
}

// NewGitlab creates a new Gitlab object
func NewGitlab(c *config.Config) *Gitlab {
        return &Gitlab{
                Client: gitlab.NewClient(c.Gitlab.Address, c.Gitlab.Token),
        }
}

// GetLocks returns a map of locks by State path
func (g *Gitlab) GetLocks() (locks map[string]LockInfo, err error) {
        locks = make(map[string]LockInfo)
        var projects gitlab.Projects
        projects, err = g.Client.GetProjectsWithTerraformStates()
        if err != nil {
                return
        }

        for _, project := range projects {
                for _, state := range project.TerraformStates {
                        if state.Lock != nil {
                                locks[state.GlobalPath()] = LockInfo{
                                        ID:        "N/A",
                                        Operation: "N/A",
                                        Info:      "N/A",
                                        Who:       state.Lock.CreatedBy,
                                        Version:   "N/A",
                                        Created:   &state.Lock.CreatedAt,
                                        Path:      state.GlobalPath(),
                                }
                        }
                }
        }

        return
}

// GetStates returns a slice of all found workspaces
func (g *Gitlab) GetStates() (states []string, err error) {
        var projects gitlab.Projects
        projects, err = g.Client.GetProjectsWithTerraformStates()
        if err != nil {
                return
        }

        for _, project := range projects {
                for _, state := range project.TerraformStates {
                        states = append(states, state.GlobalPath())
                }
        }

        return
}

// GetVersions returns a slice of Version objects
func (g *Gitlab) GetVersions(state string) (versions []Version, err error) {
        var projects gitlab.Projects
        projects, err = g.Client.GetProjectsWithTerraformStates()
        if err != nil {
                return
        }

        // TODO: Highly unoptimized: whether implement a GraphQL query to fetch the correct project only
        // TODO: or cache the values locally
        for _, project := range projects {
                for _, s := range project.TerraformStates {
                        if state != s.GlobalPath() {
                                continue
                        }

                        for i := s.LatestVersion.Serial; i >= 0; i-- {
                                versions = append(versions, Version{
                                        ID: strconv.Itoa(i),
                                        // TODO: Fix/implement once https://gitlab.com/gitlab-org/gitlab/-/merge_requests/45851 will be released
                                        // somehow it seems to be working correctly though, not sure from which place it manages to find the correct date
                                        LastModified: s.LatestVersion.CreatedAt,
                                })
                        }
                }
        }

        return
}

// GetState retrieves a single state file from the GitLab API
func (g *Gitlab) GetState(path, version string) (sf *statefile.File, err error) {
        re := regexp.MustCompile(`^\[(.*)] (.*)$`)
        stateInfo := re.FindStringSubmatch(path)
        if len(stateInfo) != 3 {
                return nil, fmt.Errorf("invalid state path: %s", path)
        }

        var state []byte
        state, err = g.Client.GetState(url.PathEscape(stateInfo[1]), url.PathEscape(stateInfo[2]), version)
        if err != nil {
                return
        }

        // Parse the statefile
        sf, err = statefile.Read(bytes.NewReader(state))
        if sf == nil {
                return nil, fmt.Errorf("Unable to parse the statefile for workspace %s version %s", path, version)
        }

        return
}

1	package state
2
3	import (
4	"bytes"
5	"fmt"
6	"net/url"
7	"regexp"
8	"strconv"
9
10	"github.com/camptocamp/terraboard/config"
11	"github.com/camptocamp/terraboard/pkg/client/gitlab"
12	"github.com/hashicorp/terraform/states/statefile"
13	)
14
15	// Gitlab is a state provider type, leveraging GitLab
16	type Gitlab struct {
17	Client gitlab.Client
18	}
19
20	// NewGitlab creates a new Gitlab object
21	func NewGitlab(c config.Config) Gitlab {	×
22	return &Gitlab{	×
23	Client: gitlab.NewClient(c.Gitlab.Address, c.Gitlab.Token),	×
24	}	×
25	}	×
26
27	// GetLocks returns a map of locks by State path
28	func (g *Gitlab) GetLocks() (locks map[string]LockInfo, err error) {	×
29	locks = make(map[string]LockInfo)	×
30	var projects gitlab.Projects	×
31	projects, err = g.Client.GetProjectsWithTerraformStates()	×
32	if err != nil {	×
33	return	×
34	}	×
35
36	for _, project := range projects {	×
37	for _, state := range project.TerraformStates {	×
38	if state.Lock != nil {	×
39	locks[state.GlobalPath()] = LockInfo{	×
40	ID: "N/A",	×
41	Operation: "N/A",	×
42	Info: "N/A",	×
43	Who: state.Lock.CreatedBy,	×
44	Version: "N/A",	×
45	Created: &state.Lock.CreatedAt,	×
46	Path: state.GlobalPath(),	×
47	}	×
48	}	×
49	}
50	}
51
52	return	×
53	}
54
55	// GetStates returns a slice of all found workspaces
56	func (g *Gitlab) GetStates() (states []string, err error) {	×
57	var projects gitlab.Projects	×
58	projects, err = g.Client.GetProjectsWithTerraformStates()	×
59	if err != nil {	×
60	return	×
61	}	×
62
63	for _, project := range projects {	×
64	for _, state := range project.TerraformStates {	×
65	states = append(states, state.GlobalPath())	×
66	}	×
67	}
68
69	return	×
70	}
71
72	// GetVersions returns a slice of Version objects
73	func (g *Gitlab) GetVersions(state string) (versions []Version, err error) {	×
74	var projects gitlab.Projects	×
75	projects, err = g.Client.GetProjectsWithTerraformStates()	×
76	if err != nil {	×
77	return	×
78	}	×
79
80	// TODO: Highly unoptimized: whether implement a GraphQL query to fetch the correct project only
81	// TODO: or cache the values locally
82	for _, project := range projects {	×
83	for _, s := range project.TerraformStates {	×
84	if state != s.GlobalPath() {	×
85	continue	×
86	}
87
88	for i := s.LatestVersion.Serial; i >= 0; i-- {	×
89	versions = append(versions, Version{	×
90	ID: strconv.Itoa(i),	×
91	// TODO: Fix/implement once https://gitlab.com/gitlab-org/gitlab/-/merge_requests/45851 will be released	×
92	// somehow it seems to be working correctly though, not sure from which place it manages to find the correct date	×
93	LastModified: s.LatestVersion.CreatedAt,	×
94	})	×
95	}	×
96	}
97	}
98
99	return	×
100	}
101
102	// GetState retrieves a single state file from the GitLab API
103	func (g Gitlab) GetState(path, version string) (sf statefile.File, err error) {	×
104	re := regexp.MustCompile(`^\[(.)] (.)$`)	×
105	stateInfo := re.FindStringSubmatch(path)	×
106	if len(stateInfo) != 3 {	×
107	return nil, fmt.Errorf("invalid state path: %s", path)	×
108	}	×
109
110	var state []byte	×
111	state, err = g.Client.GetState(url.PathEscape(stateInfo[1]), url.PathEscape(stateInfo[2]), version)	×
112	if err != nil {	×
113	return	×
114	}	×
115
116	// Parse the statefile
117	sf, err = statefile.Read(bytes.NewReader(state))	×
118	if sf == nil {	×
119	return nil, fmt.Errorf("Unable to parse the statefile for workspace %s version %s", path, version)	×
120	}	×
121
122	return	×
123	}

camptocamp / terraboard / 308

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous