import_test.go

  1package gitlab
  2
  3import (
  4	"context"
  5	"fmt"
  6	"os"
  7	"testing"
  8	"time"
  9
 10	"github.com/stretchr/testify/require"
 11
 12	"github.com/git-bug/git-bug/bridge/core"
 13	"github.com/git-bug/git-bug/bridge/core/auth"
 14	"github.com/git-bug/git-bug/cache"
 15	"github.com/git-bug/git-bug/entities/bug"
 16	"github.com/git-bug/git-bug/entities/common"
 17	"github.com/git-bug/git-bug/entities/identity"
 18	"github.com/git-bug/git-bug/entity/dag"
 19	"github.com/git-bug/git-bug/repository"
 20	"github.com/git-bug/git-bug/util/interrupt"
 21)
 22
 23func TestGitlabImport(t *testing.T) {
 24	envToken := os.Getenv("GITLAB_API_TOKEN")
 25	if envToken == "" {
 26		t.Skip("Env var GITLAB_API_TOKEN missing")
 27	}
 28
 29	projectID := os.Getenv("GITLAB_PROJECT_ID")
 30	if projectID == "" {
 31		t.Skip("Env var GITLAB_PROJECT_ID missing")
 32	}
 33
 34	repo := repository.CreateGoGitTestRepo(t, false)
 35
 36	backend, err := cache.NewRepoCacheNoEvents(repo)
 37	require.NoError(t, err)
 38
 39	defer backend.Close()
 40	interrupt.RegisterCleaner(backend.Close)
 41
 42	author, err := identity.NewIdentity(repo, "Amine Hilaly", "hilalyamine@gmail.com")
 43	require.NoError(t, err)
 44
 45	tests := []struct {
 46		name string
 47		url  string
 48		bug  *bug.Snapshot
 49	}{
 50		{
 51			name: "simple issue",
 52			url:  "https://gitlab.com/git-bug/test/-/issues/1",
 53			bug: &bug.Snapshot{
 54				Operations: []dag.Operation{
 55					bug.NewCreateOp(author, 0, "simple issue", "initial comment", nil),
 56					bug.NewAddCommentOp(author, 0, "first comment", nil),
 57					bug.NewAddCommentOp(author, 0, "second comment", nil),
 58				},
 59			},
 60		},
 61		{
 62			name: "empty issue",
 63			url:  "https://gitlab.com/git-bug/test/-/issues/2",
 64			bug: &bug.Snapshot{
 65				Operations: []dag.Operation{
 66					bug.NewCreateOp(author, 0, "empty issue", "", nil),
 67				},
 68			},
 69		},
 70		{
 71			name: "complex issue",
 72			url:  "https://gitlab.com/git-bug/test/-/issues/3",
 73			bug: &bug.Snapshot{
 74				Operations: []dag.Operation{
 75					bug.NewCreateOp(author, 0, "complex issue", "initial comment", nil),
 76					bug.NewAddCommentOp(author, 0, "### header\n\n**bold**\n\n_italic_\n\n> with quote\n\n`inline code`\n\n```\nmultiline code\n```\n\n- bulleted\n- list\n\n1. numbered\n1. list\n\n- [ ] task\n- [x] list\n\n@git-bug mention\n\n#2 reference issue\n#3 auto-reference issue", nil),
 77					bug.NewSetTitleOp(author, 0, "complex issue edited", "complex issue"),
 78					bug.NewSetTitleOp(author, 0, "complex issue", "complex issue edited"),
 79					bug.NewSetStatusOp(author, 0, common.ClosedStatus),
 80					bug.NewSetStatusOp(author, 0, common.OpenStatus),
 81					bug.NewLabelChangeOperation(author, 0, []bug.Label{"bug"}, []bug.Label{}),
 82					bug.NewLabelChangeOperation(author, 0, []bug.Label{"critical"}, []bug.Label{}),
 83					bug.NewLabelChangeOperation(author, 0, []bug.Label{}, []bug.Label{"critical"}),
 84				},
 85			},
 86		},
 87		{
 88			name: "editions",
 89			url:  "https://gitlab.com/git-bug/test/-/issues/4",
 90			bug: &bug.Snapshot{
 91				Operations: []dag.Operation{
 92					bug.NewCreateOp(author, 0, "editions", "initial comment edited", nil),
 93					bug.NewAddCommentOp(author, 0, "first comment edited", nil),
 94				},
 95			},
 96		},
 97	}
 98
 99	login := "test-identity"
100	author.SetMetadata(metaKeyGitlabLogin, login)
101
102	token := auth.NewToken(target, envToken)
103	token.SetMetadata(auth.MetaKeyLogin, login)
104	token.SetMetadata(auth.MetaKeyBaseURL, defaultBaseURL)
105	err = auth.Store(repo, token)
106	require.NoError(t, err)
107
108	ctx := context.Background()
109
110	importer := &gitlabImporter{}
111	err = importer.Init(ctx, backend, core.Configuration{
112		confKeyProjectID:     projectID,
113		confKeyGitlabBaseUrl: defaultBaseURL,
114		confKeyDefaultLogin:  login,
115	})
116	require.NoError(t, err)
117
118	start := time.Now()
119
120	events, err := importer.ImportAll(ctx, backend, time.Time{})
121	require.NoError(t, err)
122
123	for result := range events {
124		require.NoError(t, result.Err)
125	}
126
127	fmt.Printf("test repository imported in %f seconds\n", time.Since(start).Seconds())
128
129	require.Len(t, backend.Bugs().AllIds(), len(tests))
130
131	for _, tt := range tests {
132		t.Run(tt.name, func(t *testing.T) {
133			b, err := backend.Bugs().ResolveBugCreateMetadata(metaKeyGitlabUrl, tt.url)
134			require.NoError(t, err)
135
136			ops := b.Snapshot().Operations
137			require.Len(t, tt.bug.Operations, len(ops))
138
139			for i, op := range tt.bug.Operations {
140
141				require.IsType(t, ops[i], op)
142				require.Equal(t, op.Author().Name(), ops[i].Author().Name())
143
144				switch op := op.(type) {
145				case *bug.CreateOperation:
146					require.Equal(t, op.Title, ops[i].(*bug.CreateOperation).Title)
147					require.Equal(t, op.Message, ops[i].(*bug.CreateOperation).Message)
148				case *bug.SetStatusOperation:
149					require.Equal(t, op.Status, ops[i].(*bug.SetStatusOperation).Status)
150				case *bug.SetTitleOperation:
151					require.Equal(t, op.Was, ops[i].(*bug.SetTitleOperation).Was)
152					require.Equal(t, op.Title, ops[i].(*bug.SetTitleOperation).Title)
153				case *bug.LabelChangeOperation:
154					require.ElementsMatch(t, op.Added, ops[i].(*bug.LabelChangeOperation).Added)
155					require.ElementsMatch(t, op.Removed, ops[i].(*bug.LabelChangeOperation).Removed)
156				case *bug.AddCommentOperation:
157					require.Equal(t, op.Message, ops[i].(*bug.AddCommentOperation).Message)
158				case *bug.EditCommentOperation:
159					require.Equal(t, op.Message, ops[i].(*bug.EditCommentOperation).Message)
160
161				default:
162					panic("unknown operation type")
163				}
164			}
165		})
166	}
167}