This is an automated email from the ASF dual-hosted git repository.
klesh pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-devlake.git
The following commit(s) were added to refs/heads/main by this push:
new dde0f41d refactor: remove e2e folder (#2414)
dde0f41d is described below
commit dde0f41d5e68b45d978ebaad1cdb053c721361e3
Author: abeizn <[email protected]>
AuthorDate: Tue Jul 5 17:42:25 2022 +0800
refactor: remove e2e folder (#2414)
---
e2e/README.md | 74 --------------------
e2e/config.go | 28 --------
e2e/database.go | 78 ----------------------
e2e/domain_board_issues_test.go | 56 ----------------
e2e/domain_board_sprints_test.go | 56 ----------------
e2e/domain_boards_test.go | 56 ----------------
e2e/domain_builds_test.go | 56 ----------------
e2e/domain_changelogs_test.go | 56 ----------------
e2e/domain_commits_test.go | 55 ---------------
e2e/domain_issue_asignee_history_test.go | 56 ----------------
e2e/domain_issue_sprints_history_test.go | 56 ----------------
e2e/domain_issue_status_history_test.go | 56 ----------------
e2e/domain_issues_test.go | 55 ---------------
e2e/domain_jobs_test.go | 56 ----------------
e2e/domain_notes_test.go | 56 ----------------
e2e/domain_prs_test.go | 56 ----------------
e2e/domain_repo_commits_test.go | 56 ----------------
e2e/domain_repos_test.go | 55 ---------------
e2e/domain_sprint_issues_test.go | 56 ----------------
e2e/domain_sprints_test.go | 56 ----------------
e2e/domain_users_test.go | 56 ----------------
e2e/domain_worklogs_test.go | 56 ----------------
e2e/github_commits_test.go | 55 ---------------
e2e/github_issue_comments_test.go | 55 ---------------
e2e/github_issue_events_test.go | 55 ---------------
e2e/github_issue_labels.go | 55 ---------------
e2e/github_issues_label_issue_test.go | 55 ---------------
e2e/github_issues_test.go | 55 ---------------
e2e/github_pull_request_comments_test.go | 55 ---------------
...ithub_pull_request_commit_pull_requests_test.go | 55 ---------------
e2e/github_pull_request_commits_test.go | 55 ---------------
e2e/github_pull_requests_test.go | 55 ---------------
e2e/github_repo_commits_test.go | 55 ---------------
e2e/github_repo_test.go | 55 ---------------
e2e/github_users_test.go | 56 ----------------
e2e/gitlab_commits_test.go | 56 ----------------
...ab_merge_request_commits_merge_requests_test.go | 56 ----------------
e2e/gitlab_merge_request_commits_test.go | 56 ----------------
e2e/gitlab_merge_request_notes_test.go | 56 ----------------
e2e/gitlab_mrs_test.go | 56 ----------------
e2e/gitlab_pipelines_test.go | 56 ----------------
e2e/gitlab_project_commits_test.go | 56 ----------------
e2e/gitlab_projects_test.go | 56 ----------------
e2e/gitlab_reviewers_test.go | 56 ----------------
e2e/gitlab_users_test.go | 56 ----------------
e2e/jenkins_builds_test.go | 56 ----------------
e2e/jenkins_jobs_test.go | 56 ----------------
e2e/jira_board_issues_test.go | 56 ----------------
e2e/jira_board_sprints_test.go | 56 ----------------
e2e/jira_boards_test.go | 56 ----------------
e2e/jira_changelog_items_test.go | 56 ----------------
e2e/jira_changelogs_test.go | 56 ----------------
e2e/jira_issues_test.go | 56 ----------------
e2e/jira_projects_test.go | 56 ----------------
e2e/jira_remote_links_test.go | 56 ----------------
e2e/jira_sprint_issues_test.go | 56 ----------------
e2e/jira_sprints_test.go | 56 ----------------
e2e/jira_users_test.go | 56 ----------------
e2e/jira_worklogs_test.go | 56 ----------------
59 files changed, 3301 deletions(-)
diff --git a/e2e/README.md b/e2e/README.md
deleted file mode 100644
index 96b58af7..00000000
--- a/e2e/README.md
+++ /dev/null
@@ -1,74 +0,0 @@
-## E2E Tests
-
-## Why?
-
-To ensure data integrity of the application, we need to make sure that the
result
-data matches what we expect to get from accessing a real API as if a real user
is
-using it. Previously, we relied on manual testing.
-
-Automated tests allow us to do this in a very convenient, low cost way
-that is easily repeatable.
-
-## What it does
-
-1. Automatically or Manually trigger all collection / enrichment / conversion
tasks
-2. Tests access all key data models from our DB to determine if the expected
number
-of rows were collected and processed or not.
-
-## How to run
-
-1. Collect all data normally for all repos.
-2. Wait until all jobs are done
-3. Then you can run tests with this command: `make real-e2e-test`
-
-## JSON samples to send to DevLake (POST /pipelines)
-
-### Jira
-
-{
- "name": "jira",
- "tasks": [[{
- "Plugin": "jira",
- "Options": {
- "connectionId": `<your_connection_id>`,
- "boardId": 8
- }
- }]]
-}
-
-### GitLab
-
-{
- "name": "gitlab",
- "tasks": [[{
- "Plugin": "gitlab",
- "Options": {
- "projectId": 8967944
- }
- }]]
-}
-
-### GitHub
-
-{
- "name": "github",
- "tasks": [[{
- "Plugin": "github",
- "Options": {
- "repo": "lake",
- "owner": "merico-dev"
- }
- }]]
-}
-
-### Jenkins
-
-{
- "name": "jenkins",
- "tasks": [[
- {
- "plugin": "jenkins",
- "options": {}
- }
- ]]
-}
\ No newline at end of file
diff --git a/e2e/config.go b/e2e/config.go
deleted file mode 100644
index 59002f7a..00000000
--- a/e2e/config.go
+++ /dev/null
@@ -1,28 +0,0 @@
-/*
-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 e2e
-
-import "github.com/spf13/viper"
-
-func LoadConfigFile() *viper.Viper {
- V := viper.New()
- V.SetConfigFile("../.env")
- _ = V.ReadInConfig()
- V.AutomaticEnv()
- return V
-}
diff --git a/e2e/database.go b/e2e/database.go
deleted file mode 100644
index c69db039..00000000
--- a/e2e/database.go
+++ /dev/null
@@ -1,78 +0,0 @@
-/*
-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 e2e
-
-import (
- "database/sql"
- "fmt"
- "log"
- "net/url"
- "strings"
-
- mysqlGorm "gorm.io/driver/mysql"
- postgresGorm "gorm.io/driver/postgres"
- "gorm.io/gorm"
-)
-
-func InitializeDb() (*sql.DB, error) {
- v := LoadConfigFile()
- dbUrl := v.GetString("DB_URL")
- u, err := url.Parse(dbUrl)
- if err != nil {
- return nil, err
- }
-
- var db *sql.DB
- switch strings.ToLower(u.Scheme) {
- case "mysql":
- dbUrl = fmt.Sprintf(("%s@tcp(%s)%s?%s"), u.User.String(),
u.Host, u.Path, u.RawQuery)
- db, err = sql.Open(u.Scheme, dbUrl)
- case "postgresql", "postgres", "pg":
- db, err = sql.Open(`pgx`, dbUrl)
- default:
- return nil, fmt.Errorf("invalid DB_URL:%s", dbUrl)
- }
- if err != nil {
- return nil, err
- }
- pingErr := db.Ping()
- if pingErr != nil {
- log.Fatal(pingErr)
- return nil, err
- }
- fmt.Println("Connected!")
- return db, nil
-}
-
-func InitializeGormDb() (*gorm.DB, error) {
- connectionString := "merico:merico@tcp(localhost:3306)/lake"
- db, err := gorm.Open(mysqlGorm.Open(connectionString))
- if err != nil {
- return nil, err
- }
- return db, nil
-}
-
-func InitializeGormDb2() (*gorm.DB, error) {
- connectionString := "merico:merico@tcp(localhost:3306)/lake"
- db, err := gorm.Open(postgresGorm.Open(connectionString))
- if err != nil {
- return nil, err
- }
- return db, nil
-}
diff --git a/e2e/domain_board_issues_test.go b/e2e/domain_board_issues_test.go
deleted file mode 100644
index 684506f5..00000000
--- a/e2e/domain_board_issues_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainBoardIssue struct {
- BoardId string `json:"board_id"`
-}
-
-func TestDomainBoardIssues(t *testing.T) {
- var domainBoardIssues []DomainBoardIssue
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT board_id FROM lake.issues i JOIN board_issues bi
ON i.id = bi.issue_id WHERE resolution_date < '2021-10-25 17:00:58.000';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var domainBoardIssue DomainBoardIssue
- if err := rows.Scan(&domainBoardIssue.BoardId); err != nil {
- panic(err)
- }
- domainBoardIssues = append(domainBoardIssues, domainBoardIssue)
- }
- assert.Equal(t, 2687, len(domainBoardIssues))
-}
diff --git a/e2e/domain_board_sprints_test.go b/e2e/domain_board_sprints_test.go
deleted file mode 100644
index 723fe1dc..00000000
--- a/e2e/domain_board_sprints_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainBoardSprint struct {
- BoardId string `json:"board_id"`
-}
-
-func TestDomainBoardSprints(t *testing.T) {
- var domainBoardSprints []DomainBoardSprint
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT bs.board_id FROM lake.board_sprints bs JOIN
sprints s ON bs.sprint_id = s.id WHERE ended_date < '2022-01-14 14:10:00.000';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var domainBoardSprint DomainBoardSprint
- if err := rows.Scan(&domainBoardSprint.BoardId); err != nil {
- panic(err)
- }
- domainBoardSprints = append(domainBoardSprints,
domainBoardSprint)
- }
- assert.Equal(t, 61, len(domainBoardSprints))
-}
diff --git a/e2e/domain_boards_test.go b/e2e/domain_boards_test.go
deleted file mode 100644
index 22e2b4cd..00000000
--- a/e2e/domain_boards_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainBoard struct {
- Id string
-}
-
-func TestDomainBoards(t *testing.T) {
- var domainBoards []DomainBoard
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT id FROM lake.builds WHERE started_date <
'2021-04-09 09:49:07.000';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var domainBoard DomainBoard
- if err := rows.Scan(&domainBoard.Id); err != nil {
- panic(err)
- }
- domainBoards = append(domainBoards, domainBoard)
- }
- assert.Equal(t, 2904, len(domainBoards))
-}
diff --git a/e2e/domain_builds_test.go b/e2e/domain_builds_test.go
deleted file mode 100644
index f6177fad..00000000
--- a/e2e/domain_builds_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainBuild struct {
- Id string
-}
-
-func TestDomainBuilds(t *testing.T) {
- var domainBuilds []DomainBuild
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT id FROM lake.builds WHERE started_date <
'2021-05-14 15:06:50.000';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var domainBuild DomainBuild
- if err := rows.Scan(&domainBuild.Id); err != nil {
- panic(err)
- }
- domainBuilds = append(domainBuilds, domainBuild)
- }
- assert.Equal(t, 4266, len(domainBuilds))
-}
diff --git a/e2e/domain_changelogs_test.go b/e2e/domain_changelogs_test.go
deleted file mode 100644
index e3dec350..00000000
--- a/e2e/domain_changelogs_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainChangelog struct {
- Id string
-}
-
-func TestDomainChangelogs(t *testing.T) {
- var domainChangelogs []DomainChangelog
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT id FROM lake.changelogs WHERE created_date <
'2020-06-20 06:18:24.880';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var domainChangelog DomainChangelog
- if err := rows.Scan(&domainChangelog.Id); err != nil {
- panic(err)
- }
- domainChangelogs = append(domainChangelogs, domainChangelog)
- }
- assert.Equal(t, 1742, len(domainChangelogs))
-}
diff --git a/e2e/domain_commits_test.go b/e2e/domain_commits_test.go
deleted file mode 100644
index e76ae650..00000000
--- a/e2e/domain_commits_test.go
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainCommit struct {
- Sha string `json:"sha"`
-}
-
-func TestDomainCommits(t *testing.T) {
- var commits []DomainCommit
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- rows, err := db.Query("SELECT sha FROM commits WHERE authored_date <
'2021-11-24 19:22:29.000'")
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var commit DomainCommit
- if err := rows.Scan(&commit.Sha); err != nil {
- panic(err)
- }
- commits = append(commits, commit)
- }
- assert.Equal(t, 19829, len(commits))
-}
diff --git a/e2e/domain_issue_asignee_history_test.go
b/e2e/domain_issue_asignee_history_test.go
deleted file mode 100644
index c3f2b1db..00000000
--- a/e2e/domain_issue_asignee_history_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainIssueAssigneeHistory struct {
- IssueId string `json:"issue_id"`
-}
-
-func TestDomainIssueAssigneeHistorys(t *testing.T) {
- var domainBoardSprints []DomainIssueAssigneeHistory
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT issue_id FROM lake.issue_assignee_history WHERE
start_date < '2022-06-12 00:44:34.880';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var domainBoardSprint DomainIssueAssigneeHistory
- if err := rows.Scan(&domainBoardSprint.IssueId); err != nil {
- panic(err)
- }
- domainBoardSprints = append(domainBoardSprints,
domainBoardSprint)
- }
- assert.Equal(t, 2591, len(domainBoardSprints))
-}
diff --git a/e2e/domain_issue_sprints_history_test.go
b/e2e/domain_issue_sprints_history_test.go
deleted file mode 100644
index 741e22d4..00000000
--- a/e2e/domain_issue_sprints_history_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainIssueStatusHistory struct {
- IssueId string `json:"issue_id"`
-}
-
-func TestDomainIssueStatusHistorys(t *testing.T) {
- var domainBoardSprints []DomainIssueStatusHistory
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT issue_id FROM lake.issue_sprints_history WHERE
start_date < '2020-06-17 07:29:24.052';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var domainBoardSprint DomainIssueStatusHistory
- if err := rows.Scan(&domainBoardSprint.IssueId); err != nil {
- panic(err)
- }
- domainBoardSprints = append(domainBoardSprints,
domainBoardSprint)
- }
- assert.Equal(t, 8, len(domainBoardSprints))
-}
diff --git a/e2e/domain_issue_status_history_test.go
b/e2e/domain_issue_status_history_test.go
deleted file mode 100644
index a164d700..00000000
--- a/e2e/domain_issue_status_history_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainIssueSprintHistory struct {
- SprintId string `json:"sprint_id"`
-}
-
-func TestDomainIssueSprintHistorys(t *testing.T) {
- var domainBoardSprints []DomainIssueSprintHistory
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT sprint_id FROM lake.issue_sprints_history WHERE
start_date < '2020-06-17 07:29:24.052';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var domainBoardSprint DomainIssueSprintHistory
- if err := rows.Scan(&domainBoardSprint.SprintId); err != nil {
- panic(err)
- }
- domainBoardSprints = append(domainBoardSprints,
domainBoardSprint)
- }
- assert.Equal(t, 8, len(domainBoardSprints))
-}
diff --git a/e2e/domain_issues_test.go b/e2e/domain_issues_test.go
deleted file mode 100644
index c7bed558..00000000
--- a/e2e/domain_issues_test.go
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainIssue struct {
- Id string
-}
-
-func TestDomainIssues(t *testing.T) {
- var issues []DomainIssue
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- rows, err := db.Query("SELECT id FROM lake.issues WHERE resolution_date
< '2021-10-25 17:00:58.000';")
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var issue DomainIssue
- if err := rows.Scan(&issue.Id); err != nil {
- panic(err)
- }
- issues = append(issues, issue)
- }
- assert.Equal(t, 2847, len(issues))
-}
diff --git a/e2e/domain_jobs_test.go b/e2e/domain_jobs_test.go
deleted file mode 100644
index 174a2328..00000000
--- a/e2e/domain_jobs_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainJob struct {
- Id string
-}
-
-func TestDomainJobs(t *testing.T) {
- var domainJobs []DomainJob
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT id FROM jobs;"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var domainJob DomainJob
- if err := rows.Scan(&domainJob.Id); err != nil {
- panic(err)
- }
- domainJobs = append(domainJobs, domainJob)
- }
- assert.Equal(t, true, len(domainJobs) > 0)
-}
diff --git a/e2e/domain_notes_test.go b/e2e/domain_notes_test.go
deleted file mode 100644
index bcab0077..00000000
--- a/e2e/domain_notes_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainNote struct {
- Id string
-}
-
-func TestDomainNotes(t *testing.T) {
- var domainNotes []DomainNote
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT id FROM lake.notes WHERE created_date <
'2019-10-24 02:23:43.000';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var domainNote DomainNote
- if err := rows.Scan(&domainNote.Id); err != nil {
- panic(err)
- }
- domainNotes = append(domainNotes, domainNote)
- }
- assert.Equal(t, 4352, len(domainNotes))
-}
diff --git a/e2e/domain_prs_test.go b/e2e/domain_prs_test.go
deleted file mode 100644
index 49f01ac0..00000000
--- a/e2e/domain_prs_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainPullRequest struct {
- Id string
-}
-
-func TestDomainPullRequests(t *testing.T) {
- var domainPullRequests []DomainPullRequest
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT id FROM pull_requests WHERE created_date <
'2020-07-27 01:26:13.465';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var domainPullRequest DomainPullRequest
- if err := rows.Scan(&domainPullRequest.Id); err != nil {
- panic(err)
- }
- domainPullRequests = append(domainPullRequests,
domainPullRequest)
- }
- assert.Equal(t, 6, len(domainPullRequests))
-}
diff --git a/e2e/domain_repo_commits_test.go b/e2e/domain_repo_commits_test.go
deleted file mode 100644
index 62f51a45..00000000
--- a/e2e/domain_repo_commits_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainPullRequestCommit struct {
- CommitSha string `json:"commit_sha"`
-}
-
-func TestDomainPullRequestCommits(t *testing.T) {
- var domainPullRequestCommits []DomainPullRequestCommit
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT commit_sha FROM lake.repo_commits rc JOIN commits
c ON c.sha = rc.commit_sha where authored_date < '2019-04-21 10:12:19.000';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var domainPullRequestCommit DomainPullRequestCommit
- if err := rows.Scan(&domainPullRequestCommit.CommitSha); err !=
nil {
- panic(err)
- }
- domainPullRequestCommits = append(domainPullRequestCommits,
domainPullRequestCommit)
- }
- assert.Equal(t, 1617, len(domainPullRequestCommits))
-}
diff --git a/e2e/domain_repos_test.go b/e2e/domain_repos_test.go
deleted file mode 100644
index 1679e97a..00000000
--- a/e2e/domain_repos_test.go
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainRepo struct {
- Id string
-}
-
-func TestDomainRepos(t *testing.T) {
- var repos []DomainRepo
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- rows, err := db.Query("SELECT id FROM repos")
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var repo DomainRepo
- if err := rows.Scan(&repo.Id); err != nil {
- panic(err)
- }
- repos = append(repos, repo)
- }
- assert.Equal(t, true, len(repos) > 0)
-}
diff --git a/e2e/domain_sprint_issues_test.go b/e2e/domain_sprint_issues_test.go
deleted file mode 100644
index 227d05ed..00000000
--- a/e2e/domain_sprint_issues_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainSprintIssue struct {
- IssueId string `json:"issue_id"`
-}
-
-func TestDomainSprintIssues(t *testing.T) {
- var domainSprintIssues []DomainSprintIssue
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT issue_id FROM lake.sprint_issues si JOIN
lake.issues i ON si.issue_id = i.id where created_date < '2020-06-20
06:18:24.880';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var domainSprintIssue DomainSprintIssue
- if err := rows.Scan(&domainSprintIssue.IssueId); err != nil {
- panic(err)
- }
- domainSprintIssues = append(domainSprintIssues,
domainSprintIssue)
- }
- assert.Equal(t, 999, len(domainSprintIssues))
-}
diff --git a/e2e/domain_sprints_test.go b/e2e/domain_sprints_test.go
deleted file mode 100644
index 67e100af..00000000
--- a/e2e/domain_sprints_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainSprint struct {
- Id string
-}
-
-func TestDomainSprints(t *testing.T) {
- var domainSprints []DomainSprint
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT id FROM lake.sprints where started_date <
'2020-07-27 01:26:13.465';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var domainSprint DomainSprint
- if err := rows.Scan(&domainSprint.Id); err != nil {
- panic(err)
- }
- domainSprints = append(domainSprints, domainSprint)
- }
- assert.Equal(t, 4, len(domainSprints))
-}
diff --git a/e2e/domain_users_test.go b/e2e/domain_users_test.go
deleted file mode 100644
index 58d02372..00000000
--- a/e2e/domain_users_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainUser struct {
- Id string
-}
-
-func TestDomainUsers(t *testing.T) {
- var users []DomainUser
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT id FROM users"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var user DomainUser
- if err := rows.Scan(&user.Id); err != nil {
- panic(err)
- }
- users = append(users, user)
- }
- assert.Equal(t, true, len(users) > 0)
-}
diff --git a/e2e/domain_worklogs_test.go b/e2e/domain_worklogs_test.go
deleted file mode 100644
index 44ff3b6d..00000000
--- a/e2e/domain_worklogs_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type DomainWorklog struct {
- AuthorId string `json:"author_id"`
-}
-
-func TestDomainWorklogs(t *testing.T) {
- var domainWorklogs []DomainWorklog
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT author_id FROM lake.worklogs w JOIN lake.issues i
ON w.issue_id = i.id where started_date < '2020-06-20 06:18:24.880';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var domainWorklog DomainWorklog
- if err := rows.Scan(&domainWorklog.AuthorId); err != nil {
- panic(err)
- }
- domainWorklogs = append(domainWorklogs, domainWorklog)
- }
- assert.Equal(t, 987, len(domainWorklogs))
-}
diff --git a/e2e/github_commits_test.go b/e2e/github_commits_test.go
deleted file mode 100644
index 388e4ea7..00000000
--- a/e2e/github_commits_test.go
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type GithubCommit struct {
- Sha string `json:"sha"`
-}
-
-func TestGitHubCommits(t *testing.T) {
- var commits []GithubCommit
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- rows, err := db.Query("SELECT sha FROM github_commits where
authored_date < '2021-11-24 19:22:29.000'")
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var commit GithubCommit
- if err := rows.Scan(&commit.Sha); err != nil {
- panic(err)
- }
- commits = append(commits, commit)
- }
- assert.Equal(t, 874, len(commits))
-}
diff --git a/e2e/github_issue_comments_test.go
b/e2e/github_issue_comments_test.go
deleted file mode 100644
index e625475d..00000000
--- a/e2e/github_issue_comments_test.go
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type GithubIssueComment struct {
- GithubId int `json:"github_id"`
-}
-
-func TestGitHubIssueComments(t *testing.T) {
- var issueComments []GithubIssueComment
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- rows, err := db.Query("SELECT github_id FROM github_issue_comments
where github_created_at < '2021-12-25 04:40:11.000'")
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var issueComment GithubIssueComment
- if err := rows.Scan(&issueComment.GithubId); err != nil {
- panic(err)
- }
- issueComments = append(issueComments, issueComment)
- }
- assert.Equal(t, 781, len(issueComments))
-}
diff --git a/e2e/github_issue_events_test.go b/e2e/github_issue_events_test.go
deleted file mode 100644
index cb8202a7..00000000
--- a/e2e/github_issue_events_test.go
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type GithubIssueEvent struct {
- GithubId int `json:"github_id"`
-}
-
-func TestGitHubIssueEvents(t *testing.T) {
- var issueEvents []GithubIssueEvent
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- rows, err := db.Query("SELECT github_id FROM github_issue_events where
github_created_at < '2021-12-25 04:40:11.000'")
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var issueEvent GithubIssueEvent
- if err := rows.Scan(&issueEvent.GithubId); err != nil {
- panic(err)
- }
- issueEvents = append(issueEvents, issueEvent)
- }
- assert.Equal(t, 3899, len(issueEvents))
-}
diff --git a/e2e/github_issue_labels.go b/e2e/github_issue_labels.go
deleted file mode 100644
index e96f705f..00000000
--- a/e2e/github_issue_labels.go
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type GithubIssueLabels struct {
- GithubId int `json:"github_id"`
-}
-
-func TestGithubIssueLabelss(t *testing.T) {
- var issues []GithubIssueLabels
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- rows, err := db.Query("SELECT github_id FROM lake.github_issue_labels")
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var issue GithubIssueLabels
- if err := rows.Scan(&issue.GithubId); err != nil {
- panic(err)
- }
- issues = append(issues, issue)
- }
- assert.Equal(t, true, len(issues) > 0)
-}
diff --git a/e2e/github_issues_label_issue_test.go
b/e2e/github_issues_label_issue_test.go
deleted file mode 100644
index 709c9714..00000000
--- a/e2e/github_issues_label_issue_test.go
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type GithubIssueLabelIssue struct {
- GithubId int `json:"github_id"`
-}
-
-func TestGithubIssueLabelIssues(t *testing.T) {
- var issues []GithubIssueLabelIssue
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- rows, err := db.Query("SELECT github_id FROM lake.github_issues gi JOIN
lake.github_issue_label_issues gili ON gili.issue_id = gi.github_id where
github_created_at < '2021-11-24 19:22:29.000';")
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var issue GithubIssueLabelIssue
- if err := rows.Scan(&issue.GithubId); err != nil {
- panic(err)
- }
- issues = append(issues, issue)
- }
- assert.Equal(t, 561, len(issues))
-}
diff --git a/e2e/github_issues_test.go b/e2e/github_issues_test.go
deleted file mode 100644
index 5972ff24..00000000
--- a/e2e/github_issues_test.go
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type GithubIssue struct {
- GithubId int `json:"github_id"`
-}
-
-func TestGithubIssues(t *testing.T) {
- var issues []GithubIssue
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- rows, err := db.Query("SELECT github_id FROM github_issues where
github_created_at < '2021-12-25 04:40:11.000'")
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var issue GithubIssue
- if err := rows.Scan(&issue.GithubId); err != nil {
- panic(err)
- }
- issues = append(issues, issue)
- }
- assert.Equal(t, 490, len(issues))
-}
diff --git a/e2e/github_pull_request_comments_test.go
b/e2e/github_pull_request_comments_test.go
deleted file mode 100644
index 53d329a3..00000000
--- a/e2e/github_pull_request_comments_test.go
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type GithubPullRequestComment struct {
- GithubId int `json:"github_id"`
-}
-
-func TestGithubPullRequestComments(t *testing.T) {
- var PullRequestComments []GithubPullRequestComment
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- rows, err := db.Query("SELECT github_id FROM
github_pull_request_comments where github_created_at < '2021-12-25
04:40:11.000'")
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var PullRequestComment GithubPullRequestComment
- if err := rows.Scan(&PullRequestComment.GithubId); err != nil {
- panic(err)
- }
- PullRequestComments = append(PullRequestComments,
PullRequestComment)
- }
- assert.Equal(t, 401, len(PullRequestComments))
-}
diff --git a/e2e/github_pull_request_commit_pull_requests_test.go
b/e2e/github_pull_request_commit_pull_requests_test.go
deleted file mode 100644
index c51beca7..00000000
--- a/e2e/github_pull_request_commit_pull_requests_test.go
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type GithubPRJoin struct {
- GithubId int `json:"github_id"`
-}
-
-func TestGithubPRJoins(t *testing.T) {
- var issues []GithubPRJoin
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- rows, err := db.Query("SELECT github_id FROM lake.github_pull_requests
pr JOIN github_pull_request_commit_pull_requests prj ON prj.pull_request_id =
pr.github_id where github_created_at < '2021-12-25 04:40:11.000';")
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var issue GithubPRJoin
- if err := rows.Scan(&issue.GithubId); err != nil {
- panic(err)
- }
- issues = append(issues, issue)
- }
- assert.Equal(t, 1705, len(issues))
-}
diff --git a/e2e/github_pull_request_commits_test.go
b/e2e/github_pull_request_commits_test.go
deleted file mode 100644
index 066680eb..00000000
--- a/e2e/github_pull_request_commits_test.go
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type GithubPullRequestCommit struct {
- CommitSha string `json:"commit_sha"`
-}
-
-func TestGithubPullRequestCommits(t *testing.T) {
- var PullRequestCommits []GithubPullRequestCommit
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- rows, err := db.Query("SELECT sha FROM github_pull_request_commits
where authored_date < '2021-12-25 04:40:11.000'")
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var PullRequestCommit GithubPullRequestCommit
- if err := rows.Scan(&PullRequestCommit.CommitSha); err != nil {
- panic(err)
- }
- PullRequestCommits = append(PullRequestCommits,
PullRequestCommit)
- }
- assert.Equal(t, 1505, len(PullRequestCommits))
-}
diff --git a/e2e/github_pull_requests_test.go b/e2e/github_pull_requests_test.go
deleted file mode 100644
index 26485588..00000000
--- a/e2e/github_pull_requests_test.go
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type GithubPullRequest struct {
- GithubId int `json:"github_id"`
-}
-
-func TestGithubPullRequests(t *testing.T) {
- var pullRequests []GithubPullRequest
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- rows, err := db.Query("SELECT github_id FROM github_pull_requests where
github_created_at < '2021-12-25 04:40:11.000'")
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var pullRequest GithubPullRequest
- if err := rows.Scan(&pullRequest.GithubId); err != nil {
- panic(err)
- }
- pullRequests = append(pullRequests, pullRequest)
- }
- assert.Equal(t, 512, len(pullRequests))
-}
diff --git a/e2e/github_repo_commits_test.go b/e2e/github_repo_commits_test.go
deleted file mode 100644
index 0bf04ce8..00000000
--- a/e2e/github_repo_commits_test.go
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type GithubRepoCommits struct {
- GithubId string `json:"github_id"`
-}
-
-func TestGitHubGithubRepoCommitss(t *testing.T) {
- var repos []GithubRepoCommits
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- rows, err := db.Query("Select author_id from github_commits gc JOIN
github_repo_commits grc ON grc.commit_sha = gc.sha where authored_date <
'2021-12-25 04:40:11.000';")
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var repo GithubRepoCommits
- if err := rows.Scan(&repo.GithubId); err != nil {
- panic(err)
- }
- repos = append(repos, repo)
- }
- assert.Equal(t, 1093, len(repos))
-}
diff --git a/e2e/github_repo_test.go b/e2e/github_repo_test.go
deleted file mode 100644
index 1de9609b..00000000
--- a/e2e/github_repo_test.go
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type GithubRepo struct {
- GithubId string `json:"github_id"`
-}
-
-func TestGitHubRepos(t *testing.T) {
- var repos []GithubRepo
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- rows, err := db.Query("SELECT github_id FROM github_repos")
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var repo GithubRepo
- if err := rows.Scan(&repo.GithubId); err != nil {
- panic(err)
- }
- repos = append(repos, repo)
- }
- assert.Equal(t, 1, len(repos))
-}
diff --git a/e2e/github_users_test.go b/e2e/github_users_test.go
deleted file mode 100644
index 3e82104d..00000000
--- a/e2e/github_users_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type GithubUser struct {
- Id int
-}
-
-func TestGithubUsers(t *testing.T) {
- var users []GithubUser
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT id FROM github_users"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var user GithubUser
- if err := rows.Scan(&user.Id); err != nil {
- panic(err)
- }
- users = append(users, user)
- }
- assert.Equal(t, true, len(users) > 0)
-}
diff --git a/e2e/gitlab_commits_test.go b/e2e/gitlab_commits_test.go
deleted file mode 100644
index 260aecef..00000000
--- a/e2e/gitlab_commits_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type Commit struct {
- Sha string
-}
-
-func TestGitLabCommits(t *testing.T) {
- var commits []Commit
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT sha FROM gitlab_commits where authored_date <
'2019-06-25 02:41:42.000'"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var commit Commit
- if err := rows.Scan(&commit.Sha); err != nil {
- panic(err)
- }
- commits = append(commits, commit)
- }
- assert.Equal(t, 2817, len(commits))
-}
diff --git a/e2e/gitlab_merge_request_commits_merge_requests_test.go
b/e2e/gitlab_merge_request_commits_merge_requests_test.go
deleted file mode 100644
index 4c753ee0..00000000
--- a/e2e/gitlab_merge_request_commits_merge_requests_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type MergeRequestCommitsJoin struct {
- GitlabId string `json:"gitlab_id"`
-}
-
-func TestGitLabMergeRequestCommitsJoins(t *testing.T) {
- var mergeRequestCommitJoins []MergeRequestCommitsJoin
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "Select gitlab_id from _tool_gitlab_merge_requests mr
JOIN gitlab_merge_request_commit_merge_requests mrj ON mrj.merge_request_id =
mr.gitlab_id where gitlab_created_at < '2019-04-25 04:40:11.000';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var mergeRequestCommitJoin MergeRequestCommitsJoin
- if err := rows.Scan(&mergeRequestCommitJoin.GitlabId); err !=
nil {
- panic(err)
- }
- mergeRequestCommitJoins = append(mergeRequestCommitJoins,
mergeRequestCommitJoin)
- }
- assert.Equal(t, 1957, len(mergeRequestCommitJoins))
-}
diff --git a/e2e/gitlab_merge_request_commits_test.go
b/e2e/gitlab_merge_request_commits_test.go
deleted file mode 100644
index a5589579..00000000
--- a/e2e/gitlab_merge_request_commits_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type MergeRequestCommit struct {
- CommitId string `json:"commit_id"`
-}
-
-func TestGitLabMergeRequestCommits(t *testing.T) {
- var mergeRequestCommits []MergeRequestCommit
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT commit_id FROM _tool_gitlab_merge_request_commits
where authored_date < '2019-06-25 02:41:42.000'"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var mergeRequestCommit MergeRequestCommit
- if err := rows.Scan(&mergeRequestCommit.CommitId); err != nil {
- panic(err)
- }
- mergeRequestCommits = append(mergeRequestCommits,
mergeRequestCommit)
- }
- assert.Equal(t, 2496, len(mergeRequestCommits))
-}
diff --git a/e2e/gitlab_merge_request_notes_test.go
b/e2e/gitlab_merge_request_notes_test.go
deleted file mode 100644
index 660c9beb..00000000
--- a/e2e/gitlab_merge_request_notes_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type MergeRequestNote struct {
- GitlabId int `json:"gitlab_id"`
-}
-
-func TestGitLabMergeRequestNotes(t *testing.T) {
- var mergeRequestNotes []MergeRequestNote
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT gitlab_id FROM gitlab_merge_request_notes where
gitlab_created_at < '2019-06-25 02:41:42.000'"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var mergeRequestNote MergeRequestNote
- if err := rows.Scan(&mergeRequestNote.GitlabId); err != nil {
- panic(err)
- }
- mergeRequestNotes = append(mergeRequestNotes, mergeRequestNote)
- }
- assert.Equal(t, 2835, len(mergeRequestNotes))
-}
diff --git a/e2e/gitlab_mrs_test.go b/e2e/gitlab_mrs_test.go
deleted file mode 100644
index 421c7a78..00000000
--- a/e2e/gitlab_mrs_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type Mr struct {
- iid int
-}
-
-func TestGitLabMrs(t *testing.T) {
- var mrs []Mr
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT iid FROM _tool_gitlab_merge_requests where
gitlab_created_at < '2019-06-25 02:41:42.000'"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var mr Mr
- if err := rows.Scan(&mr.iid); err != nil {
- panic(err)
- }
- mrs = append(mrs, mr)
- }
- assert.Equal(t, 589, len(mrs))
-}
diff --git a/e2e/gitlab_pipelines_test.go b/e2e/gitlab_pipelines_test.go
deleted file mode 100644
index c112ef06..00000000
--- a/e2e/gitlab_pipelines_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type Pipeline struct {
- GitlabId string `json:"gitlab_id"`
-}
-
-func TestGitLabPipelines(t *testing.T) {
- var pipelines []Pipeline
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT gitlab_id FROM gitlab_pipelines where
gitlab_created_at < '2019-06-25 02:41:42.000'"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var pipeline Pipeline
- if err := rows.Scan(&pipeline.GitlabId); err != nil {
- panic(err)
- }
- pipelines = append(pipelines, pipeline)
- }
- assert.Equal(t, 1333, len(pipelines))
-}
diff --git a/e2e/gitlab_project_commits_test.go
b/e2e/gitlab_project_commits_test.go
deleted file mode 100644
index 4378c84a..00000000
--- a/e2e/gitlab_project_commits_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type GitlabProjectCommit struct {
- Sha string
-}
-
-func TestGitlabProjectCommits(t *testing.T) {
- var commits []GitlabProjectCommit
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "Select sha from gitlab_commits co JOIN
gitlab_project_commits coj ON co.sha = coj.commit_sha where authored_date <
'2019-04-25 04:40:11.000';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var commit GitlabProjectCommit
- if err := rows.Scan(&commit.Sha); err != nil {
- panic(err)
- }
- commits = append(commits, commit)
- }
- assert.Equal(t, 1659, len(commits))
-}
diff --git a/e2e/gitlab_projects_test.go b/e2e/gitlab_projects_test.go
deleted file mode 100644
index 79250c10..00000000
--- a/e2e/gitlab_projects_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type Project struct {
- GitlabId int `json:"gitlab_id"`
-}
-
-func TestGitLabProjects(t *testing.T) {
- var projects []Project
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT gitlab_id FROM gitlab_projects"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var project Project
- if err := rows.Scan(&project.GitlabId); err != nil {
- panic(err)
- }
- projects = append(projects, project)
- }
- assert.Equal(t, 1, len(projects))
-}
diff --git a/e2e/gitlab_reviewers_test.go b/e2e/gitlab_reviewers_test.go
deleted file mode 100644
index e16b6425..00000000
--- a/e2e/gitlab_reviewers_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type Reviewer struct {
- GitlabId int `json:"gitlab_id"`
-}
-
-func TestGitLabReviewers(t *testing.T) {
- var reviewers []Reviewer
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT gitlab_id FROM gitlab_reviewers"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var reviewer Reviewer
- if err := rows.Scan(&reviewer.GitlabId); err != nil {
- panic(err)
- }
- reviewers = append(reviewers, reviewer)
- }
- assert.Equal(t, true, len(reviewers) > 0)
-}
diff --git a/e2e/gitlab_users_test.go b/e2e/gitlab_users_test.go
deleted file mode 100644
index 72afa89b..00000000
--- a/e2e/gitlab_users_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type User struct {
- Email string
-}
-
-func TestGitLabUsers(t *testing.T) {
- var users []User
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT email FROM gitlab_users"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var user User
- if err := rows.Scan(&user.Email); err != nil {
- panic(err)
- }
- users = append(users, user)
- }
- assert.Equal(t, true, len(users) > 0)
-}
diff --git a/e2e/jenkins_builds_test.go b/e2e/jenkins_builds_test.go
deleted file mode 100644
index a6399aa2..00000000
--- a/e2e/jenkins_builds_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type JenkinsBuild struct {
- Id int
-}
-
-func TestJenkinsBuilds(t *testing.T) {
- var jenkinsBuilds []JenkinsBuild
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT id FROM jenkins_builds where start_time <
'2021-01-27 08:34:34.000';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var jenkinsBuild JenkinsBuild
- if err := rows.Scan(&jenkinsBuild.Id); err != nil {
- panic(err)
- }
- jenkinsBuilds = append(jenkinsBuilds, jenkinsBuild)
- }
- assert.Equal(t, 972, len(jenkinsBuilds))
-}
diff --git a/e2e/jenkins_jobs_test.go b/e2e/jenkins_jobs_test.go
deleted file mode 100644
index 42042cb8..00000000
--- a/e2e/jenkins_jobs_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type JenkinsJob struct {
- Id int
-}
-
-func TestJenkinsJobs(t *testing.T) {
- var jenkinsJobs []JenkinsJob
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT id FROM jenkins_jobs;"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var jenkinsJob JenkinsJob
- if err := rows.Scan(&jenkinsJob.Id); err != nil {
- panic(err)
- }
- jenkinsJobs = append(jenkinsJobs, jenkinsJob)
- }
- assert.Equal(t, true, len(jenkinsJobs) > 0)
-}
diff --git a/e2e/jira_board_issues_test.go b/e2e/jira_board_issues_test.go
deleted file mode 100644
index 9c92c80a..00000000
--- a/e2e/jira_board_issues_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type JiraBoardIssue struct {
- BoardIssueId int `json:"board_id"`
-}
-
-func TestJiraBoardIssues(t *testing.T) {
- var jiraBoardIssues []JiraBoardIssue
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT board_id FROM lake.jira_issues ji JOIN
jira_board_issues jbi ON ji.issue_id = jbi.issue_id where resolution_date <
'2020-10-15 08:59:51.304';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var jiraBoardIssue JiraBoardIssue
- if err := rows.Scan(&jiraBoardIssue.BoardIssueId); err != nil {
- panic(err)
- }
- jiraBoardIssues = append(jiraBoardIssues, jiraBoardIssue)
- }
- assert.Equal(t, 894, len(jiraBoardIssues))
-}
diff --git a/e2e/jira_board_sprints_test.go b/e2e/jira_board_sprints_test.go
deleted file mode 100644
index ded28b00..00000000
--- a/e2e/jira_board_sprints_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type JiraBoardSprint struct {
- BoardId int `json:"board_id"`
-}
-
-func TestJiraBoardSprints(t *testing.T) {
- var jiraBoardSprints []JiraBoardSprint
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT board_id FROM lake.jira_sprints js JOIN
jira_board_sprints jbs ON jbs.sprint_id = js.sprint_id WHERE start_date <
'2020-12-27 01:22:00.000';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var jiraBoardSprint JiraBoardSprint
- if err := rows.Scan(&jiraBoardSprint.BoardId); err != nil {
- panic(err)
- }
- jiraBoardSprints = append(jiraBoardSprints, jiraBoardSprint)
- }
- assert.Equal(t, 13, len(jiraBoardSprints))
-}
diff --git a/e2e/jira_boards_test.go b/e2e/jira_boards_test.go
deleted file mode 100644
index c02bcc77..00000000
--- a/e2e/jira_boards_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type JiraBoard struct {
- BoardId int `json:"board_id"`
-}
-
-func TestJiraBoards(t *testing.T) {
- var jiraBoards []JiraBoard
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT board_id FROM jira_boards;"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var jiraBoard JiraBoard
- if err := rows.Scan(&jiraBoard.BoardId); err != nil {
- panic(err)
- }
- jiraBoards = append(jiraBoards, jiraBoard)
- }
- assert.Equal(t, 1, len(jiraBoards))
-}
diff --git a/e2e/jira_changelog_items_test.go b/e2e/jira_changelog_items_test.go
deleted file mode 100644
index ae26585a..00000000
--- a/e2e/jira_changelog_items_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type JiraChangelogItem struct {
- ChangelogId int `json:"changelog_id"`
-}
-
-func TestJiraChangelogItems(t *testing.T) {
- var jiraChangelogItems []JiraChangelogItem
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT jc.changelog_id FROM lake.jira_changelogs jc JOIN
jira_changelog_items jci ON jci.changelog_id = jc.changelog_id where created <
'2020-07-05 00:17:32.778';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var jiraChangelogItem JiraChangelogItem
- if err := rows.Scan(&jiraChangelogItem.ChangelogId); err != nil
{
- panic(err)
- }
- jiraChangelogItems = append(jiraChangelogItems,
jiraChangelogItem)
- }
- assert.Equal(t, 4293, len(jiraChangelogItems))
-}
diff --git a/e2e/jira_changelogs_test.go b/e2e/jira_changelogs_test.go
deleted file mode 100644
index 15d519b2..00000000
--- a/e2e/jira_changelogs_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type JiraChangelog struct {
- ChangelogId int `json:"changelog_id"`
-}
-
-func TestJiraChangelogs(t *testing.T) {
- var jiraChangelogs []JiraChangelog
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT changelog_id FROM jira_changelogs where created <
'2020-07-05 00:17:32.778';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var jiraChangelog JiraChangelog
- if err := rows.Scan(&jiraChangelog.ChangelogId); err != nil {
- panic(err)
- }
- jiraChangelogs = append(jiraChangelogs, jiraChangelog)
- }
- assert.Equal(t, 3494, len(jiraChangelogs))
-}
diff --git a/e2e/jira_issues_test.go b/e2e/jira_issues_test.go
deleted file mode 100644
index 547ac337..00000000
--- a/e2e/jira_issues_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type JiraIssue struct {
- IssueId int `json:"issue_id"`
-}
-
-func TestJiraIssues(t *testing.T) {
- var jiraIssues []JiraIssue
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT issue_id FROM lake.jira_issues ji where
resolution_date < '2020-06-23 10:21:23.562';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var jiraIssue JiraIssue
- if err := rows.Scan(&jiraIssue.IssueId); err != nil {
- panic(err)
- }
- jiraIssues = append(jiraIssues, jiraIssue)
- }
- assert.Equal(t, 130, len(jiraIssues))
-}
diff --git a/e2e/jira_projects_test.go b/e2e/jira_projects_test.go
deleted file mode 100644
index dea1c0f9..00000000
--- a/e2e/jira_projects_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type JiraProject struct {
- Id int
-}
-
-func TestJiraProjects(t *testing.T) {
- var jiraProjects []JiraProject
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT id FROM jira_projects;"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var jiraProject JiraProject
- if err := rows.Scan(&jiraProject.Id); err != nil {
- panic(err)
- }
- jiraProjects = append(jiraProjects, jiraProject)
- }
- assert.Equal(t, true, len(jiraProjects) > 0)
-}
diff --git a/e2e/jira_remote_links_test.go b/e2e/jira_remote_links_test.go
deleted file mode 100644
index 42d000ac..00000000
--- a/e2e/jira_remote_links_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type JiraRemoteLink struct {
- RemotelinkId string `json:"remotelink_id"`
-}
-
-func TestJiraRemoteLinks(t *testing.T) {
- var jiraRemoteLinks []JiraRemoteLink
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT remotelink_id FROM lake.jira_remotelinks rl JOIN
jira_issues ji ON ji.issue_id = rl.issue_id where resolution_date < '2020-06-19
06:31:18.495';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var jiraRemoteLink JiraRemoteLink
- if err := rows.Scan(&jiraRemoteLink.RemotelinkId); err != nil {
- panic(err)
- }
- jiraRemoteLinks = append(jiraRemoteLinks, jiraRemoteLink)
- }
- assert.Equal(t, 43, len(jiraRemoteLinks))
-}
diff --git a/e2e/jira_sprint_issues_test.go b/e2e/jira_sprint_issues_test.go
deleted file mode 100644
index 0e196346..00000000
--- a/e2e/jira_sprint_issues_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type JiraSprintIssue struct {
- IssueId int `json:"issue_id"`
-}
-
-func TestJiraSprintIssues(t *testing.T) {
- var jiraSprintIssues []JiraSprintIssue
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT si.issue_id FROM lake.jira_sprint_issues si JOIN
jira_issues ji ON ji.issue_id = si.issue_id where resolution_date < '2020-06-19
06:31:18.495';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var jiraSprintIssue JiraSprintIssue
- if err := rows.Scan(&jiraSprintIssue.IssueId); err != nil {
- panic(err)
- }
- jiraSprintIssues = append(jiraSprintIssues, jiraSprintIssue)
- }
- assert.Equal(t, 78, len(jiraSprintIssues))
-}
diff --git a/e2e/jira_sprints_test.go b/e2e/jira_sprints_test.go
deleted file mode 100644
index 00a7d2e5..00000000
--- a/e2e/jira_sprints_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type JiraSprint struct {
- SprintId int `json:"sprint_id"`
-}
-
-func TestJiraSprints(t *testing.T) {
- var jiraSprints []JiraSprint
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT sprint_id FROM jira_sprints where start_date <
'2020-12-09 01:15:11.205';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var jiraSprint JiraSprint
- if err := rows.Scan(&jiraSprint.SprintId); err != nil {
- panic(err)
- }
- jiraSprints = append(jiraSprints, jiraSprint)
- }
- assert.Equal(t, 12, len(jiraSprints))
-}
diff --git a/e2e/jira_users_test.go b/e2e/jira_users_test.go
deleted file mode 100644
index c8b9399f..00000000
--- a/e2e/jira_users_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type JiraUser struct {
- Email string
-}
-
-func TestJiraUsers(t *testing.T) {
- var jiraUsers []JiraUser
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT email FROM jira_users;"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var jiraUser JiraUser
- if err := rows.Scan(&jiraUser.Email); err != nil {
- panic(err)
- }
- jiraUsers = append(jiraUsers, jiraUser)
- }
- assert.Equal(t, true, len(jiraUsers) > 0)
-}
diff --git a/e2e/jira_worklogs_test.go b/e2e/jira_worklogs_test.go
deleted file mode 100644
index 5b39ac35..00000000
--- a/e2e/jira_worklogs_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
-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 e2e
-
-import (
- "fmt"
- "log"
- "testing"
-
- "github.com/stretchr/testify/assert"
-)
-
-// This test should only run once main_test is complete and ready
-
-type JiraWorklog struct {
- TimeSpent string `json:"time_spent"`
-}
-
-func TestJiraWorklogs(t *testing.T) {
- var jiraWorklogs []JiraWorklog
- db, err := InitializeDb()
- assert.Nil(t, err)
- if err != nil {
- log.Fatal(err)
- }
- sqlCommand := "SELECT time_spent FROM lake.jira_issues ji JOIN
jira_worklogs jw ON ji.issue_id = jw.issue_id where resolution_date <
'2020-06-19 06:31:18.495';"
- rows, err := db.Query(sqlCommand)
- if err != nil {
- fmt.Println("ERROR: ", err)
- }
- assert.Nil(t, err)
- defer rows.Close()
- for rows.Next() {
- var jiraWorklog JiraWorklog
- if err := rows.Scan(&jiraWorklog.TimeSpent); err != nil {
- panic(err)
- }
- jiraWorklogs = append(jiraWorklogs, jiraWorklog)
- }
- assert.Equal(t, 41, len(jiraWorklogs))
-}
