feat: add assignees and reviewers to pull_request_x table

backend/core/models/domainlayer/code/pull_request_assignees.go

@@ -0,0 +1,35 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements.  See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You under the Apache License, Version 2.0
+(the "License"); you may not use this file except in compliance with
+the License.  You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package code
+
+import (
+	"github.com/apache/incubator-devlake/core/models/common"
+)
+
+type PullRequestAssignee struct {
+	PullRequestId string `json:"id" gorm:"primaryKey;type:varchar(255);comment:This key is generated based on details from the original plugin"` // format: <Plugin>:<Entity>:<PK0>:<PK1>
+	AssigneeId    int    `gorm:"primaryKey"`
+	Name          string `gorm:"type:varchar(255)"`
+	UserName      string `gorm:"type:varchar(255)"`
+
+	common.NoPKModel
+}
+
+func (PullRequestAssignee) TableName() string {
+	return "pull_request_assignees"
+}

backend/core/models/domainlayer/code/pull_request_reviewers.go

@@ -0,0 +1,35 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements.  See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You under the Apache License, Version 2.0
+(the "License"); you may not use this file except in compliance with
+the License.  You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package code
+
+import (
+	"github.com/apache/incubator-devlake/core/models/common"
+)
+
+type PullRequestReviewer struct {
+	PullRequestId string `json:"id" gorm:"primaryKey;type:varchar(255);comment:This key is generated based on details from the original plugin"` // format: <Plugin>:<Entity>:<PK0>:<PK1>
+	ReviewerId    int    `gorm:"primaryKey"`
+	Name          string `gorm:"type:varchar(255)"`
+	UserName      string `gorm:"type:varchar(255)"`
+
+	common.NoPKModel
+}
+
+func (PullRequestReviewer) TableName() string {
+	return "pull_request_reviewers"
+}

backend/core/models/domainlayer/domaininfo/domaininfo.go

@@ -39,6 +39,8 @@ func GetDomainTablesInfo() []dal.Tabler {
 		&code.PullRequestComment{},
 		&code.PullRequestCommit{},
 		&code.PullRequestLabel{},
+		&code.PullRequestReviewer{},
+		&code.PullRequestAssignee{},
 		&code.Ref{},
 		&code.CommitsDiff{},
 		&code.RefCommit{},

backend/core/models/migrationscripts/20240531_add_pr_assignees_and_reviewers.go

@@ -0,0 +1,43 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements.  See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You under the Apache License, Version 2.0
+(the "License"); you may not use this file except in compliance with
+the License.  You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package migrationscripts
+
+import (
+	"github.com/apache/incubator-devlake/core/context"
+	"github.com/apache/incubator-devlake/core/errors"
+	"github.com/apache/incubator-devlake/core/models/migrationscripts/archived"
+	"github.com/apache/incubator-devlake/helpers/migrationhelper"
+)
+
+type addPrAssigneeAndReviewer struct{}
+
+func (u *addPrAssigneeAndReviewer) Up(basicRes context.BasicRes) errors.Error {
+	return migrationhelper.AutoMigrateTables(
+		basicRes,
+		&archived.PullRequestAssignee{},
+		&archived.PullRequestReviewer{},
+	)
+}
+
+func (*addPrAssigneeAndReviewer) Version() uint64 {
+	return 20250531000041
+}
+
+func (*addPrAssigneeAndReviewer) Name() string {
+	return "add pull_request_reviewers and pull_request_assignees tables"
+}

backend/core/models/migrationscripts/archived/pull_request_assignees.go

@@ -0,0 +1,31 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements.  See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You under the Apache License, Version 2.0
+(the "License"); you may not use this file except in compliance with
+the License.  You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package archived
+
+type PullRequestAssignee struct {
+	PullRequestId string `json:"id" gorm:"primaryKey;type:varchar(255);comment:This key is generated based on details from the original plugin"` // format: <Plugin>:<Entity>:<PK0>:<PK1>
+	AssigneeId    int    `gorm:"primaryKey"`
+	Name          string `gorm:"type:varchar(255)"`
+	UserName      string `gorm:"type:varchar(255)"`
+
+	NoPKModel
+}
+
+func (PullRequestAssignee) TableName() string {
+	return "pull_request_assignees"
+}

backend/core/models/migrationscripts/archived/pull_request_reviewers.go

@@ -0,0 +1,31 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements.  See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You under the Apache License, Version 2.0
+(the "License"); you may not use this file except in compliance with
+the License.  You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package archived
+
+type PullRequestReviewer struct {
+	PullRequestId string `json:"id" gorm:"primaryKey;type:varchar(255);comment:This key is generated based on details from the original plugin"` // format: <Plugin>:<Entity>:<PK0>:<PK1>
+	ReviewerId    int    `gorm:"primaryKey"`
+	Name          string `gorm:"type:varchar(255)"`
+	UserName      string `gorm:"type:varchar(255)"`
+
+	NoPKModel
+}
+
+func (PullRequestReviewer) TableName() string {
+	return "pull_request_reviewers"
+}

backend/core/models/migrationscripts/register.go

@@ -119,5 +119,6 @@ func All() []plugin.MigrationScript {
 		new(updatePluginOptionInProjectMetricSetting),
 		new(modifyCicdDeploymentCommitsRepoUrlLength),
 		new(modifyCicdPipelineCommitsRepoUrlLength),
+		new(addPrAssigneeAndReviewer),
 	}
 }

backend/plugins/gitlab/e2e/mr_commits_test.go

@@ -48,6 +48,8 @@ func TestGitlabMrCommitDataFlow(t *testing.T) {
 	// verify extraction
 	dataflowTester.FlushTabler(&models.GitlabMergeRequest{})
 	dataflowTester.FlushTabler(&models.GitlabMrLabel{})
+	dataflowTester.FlushTabler(&models.GitlabAssignee{})
+	dataflowTester.FlushTabler(&models.GitlabReviewer{})
 	dataflowTester.Subtask(tasks.ExtractApiMergeRequestsMeta, taskData)
 	dataflowTester.VerifyTable(
 		models.GitlabMergeRequest{},

backend/plugins/gitlab/impl/impl.go

@@ -98,6 +98,7 @@ func (p Gitlab) GetTablesInfo() []dal.Tabler {
 		&models.GitlabProject{},
 		&models.GitlabProjectCommit{},
 		&models.GitlabReviewer{},
+		&models.GitlabAssignee{},
 		&models.GitlabTag{},
 		&models.GitlabIssueAssignee{},
 		&models.GitlabScopeConfig{},

backend/plugins/gitlab/models/assignee.go

@@ -0,0 +1,39 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements.  See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You under the Apache License, Version 2.0
+(the "License"); you may not use this file except in compliance with
+the License.  You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package models
+
+import (
+	"github.com/apache/incubator-devlake/core/models/common"
+)
+
+type GitlabAssignee struct {
+	ConnectionId   uint64 `gorm:"primaryKey"`
+	AssigneeId     int    `gorm:"primaryKey"`
+	MergeRequestId int    `gorm:"index"`
+	ProjectId      int    `gorm:"index"`
+	Name           string `gorm:"type:varchar(255)"`
+	Username       string `gorm:"type:varchar(255)"`
+	State          string `gorm:"type:varchar(255)"`
+	AvatarUrl      string `gorm:"type:varchar(255)"`
+	WebUrl         string `gorm:"type:varchar(255)"`
+	common.NoPKModel
+}
+
+func (GitlabAssignee) TableName() string {
+	return "_tool_gitlab_assignees"
+}

backend/plugins/gitlab/models/migrationscripts/20240531_add_mr_assignees.go

@@ -0,0 +1,53 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements.  See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You under the Apache License, Version 2.0
+(the "License"); you may not use this file except in compliance with
+the License.  You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package migrationscripts
+
+import (
+	"github.com/apache/incubator-devlake/core/context"
+	"github.com/apache/incubator-devlake/core/errors"
+	"github.com/apache/incubator-devlake/helpers/migrationhelper"
+	"github.com/apache/incubator-devlake/plugins/gitlab/models/migrationscripts/archived"
+)
+
+type addGitlabAssignee struct{}
+
+func (*addGitlabAssignee) Up(baseRes context.BasicRes) errors.Error {
+	err := baseRes.GetDal().DropTables(archived.GitlabAssignee{})
+	if err != nil {
+		return err
+	}
+
+	err = migrationhelper.AutoMigrateTables(
+		baseRes,
+		&archived.GitlabAssignee{},
+		&archived.GitlabReviewer{},
+	)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (*addGitlabAssignee) Version() uint64 {
+	return 20240531110339
+}
+
+func (*addGitlabAssignee) Name() string {
+	return "add _tool_gitlab_assignees table"
+}

backend/plugins/gitlab/models/migrationscripts/archived/assignee.go

@@ -0,0 +1,39 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements.  See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You under the Apache License, Version 2.0
+(the "License"); you may not use this file except in compliance with
+the License.  You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package archived
+
+import (
+	"github.com/apache/incubator-devlake/core/models/migrationscripts/archived"
+)
+
+type GitlabAssignee struct {
+	ConnectionId   uint64 `gorm:"primaryKey"`
+	AssigneeId     int    `gorm:"primaryKey"`
+	MergeRequestId int    `gorm:"index"`
+	ProjectId      int    `gorm:"index"`
+	Name           string `gorm:"type:varchar(255)"`
+	Username       string `gorm:"type:varchar(255)"`
+	State          string `gorm:"type:varchar(255)"`
+	AvatarUrl      string `gorm:"type:varchar(255)"`
+	WebUrl         string `gorm:"type:varchar(255)"`
+	archived.NoPKModel
+}
+
+func (GitlabAssignee) TableName() string {
+	return "_tool_gitlab_assignees"
+}

backend/plugins/gitlab/models/migrationscripts/archived/reviewer.go

@@ -22,9 +22,8 @@ import (
 )
 
 type GitlabReviewer struct {
-	ConnectionId uint64 `gorm:"primaryKey"`
-
-	GitlabId       int    `gorm:"primaryKey"`
+	ConnectionId   uint64 `gorm:"primaryKey"`
+	ReviewerId     int    `gorm:"primaryKey"`
 	MergeRequestId int    `gorm:"index"`
 	ProjectId      int    `gorm:"index"`
 	Name           string `gorm:"type:varchar(255)"`

backend/plugins/gitlab/models/migrationscripts/register.go

@@ -48,5 +48,6 @@ func All() []plugin.MigrationScript {
 		new(addTimeToGitlabPipelineProject),
 		new(modifyDeploymentCommitTitle),
 		new(addWebUrlToGitlabPipelineProject),
+		new(addGitlabAssignee),
 	}
 }

backend/plugins/gitlab/models/reviewer.go

@@ -22,9 +22,8 @@ import (
 )
 
 type GitlabReviewer struct {
-	ConnectionId uint64 `gorm:"primaryKey"`
-
-	GitlabId       int    `gorm:"primaryKey"`
+	ConnectionId   uint64 `gorm:"primaryKey"`
+	ReviewerId     int    `gorm:"primaryKey"`
 	MergeRequestId int    `gorm:"index"`
 	ProjectId      int    `gorm:"index"`
 	Name           string `gorm:"type:varchar(255)"`