refactor(tibuild): move pkg/database to internal/database (#225)

Signed-off-by: wuhuizuo <[email protected]>

Signed-off-by: wuhuizuo <[email protected]>

Author: wuhuizuo

tibuild/api/api.go

@@ -11,8 +11,8 @@ import (
 	ginSwagger "github.com/swaggo/gin-swagger"
 
 	"github.com/PingCAP-QE/ee-apps/tibuild/internal/controller"
+	"github.com/PingCAP-QE/ee-apps/tibuild/internal/database"
 	"github.com/PingCAP-QE/ee-apps/tibuild/pkg/configs"
-	"github.com/PingCAP-QE/ee-apps/tibuild/pkg/database"
 	controllers "github.com/PingCAP-QE/ee-apps/tibuild/pkg/rest/controller"
 	"github.com/PingCAP-QE/ee-apps/tibuild/pkg/rest/service"
 	events "github.com/PingCAP-QE/ee-apps/tibuild/pkg/webhook/handler"

tibuild/cmd/tibuild/main.go

@@ -2,8 +2,8 @@ package main
 
 import (
 	"github.com/PingCAP-QE/ee-apps/tibuild/api"
+	"github.com/PingCAP-QE/ee-apps/tibuild/internal/database"
 	"github.com/PingCAP-QE/ee-apps/tibuild/pkg/configs"
-	"github.com/PingCAP-QE/ee-apps/tibuild/pkg/database"
 )
 
 func main() {

tibuild/internal/controller/params_available_for_pipeline.go

@@ -8,7 +8,7 @@ import (
 	"github.com/gin-gonic/gin/binding"
 	"github.com/rs/zerolog/log"
 
-	"github.com/PingCAP-QE/ee-apps/tibuild/pkg/database"
+	"github.com/PingCAP-QE/ee-apps/tibuild/internal/database"
 )
 
 type ParamsAvailableForPipelineStruct struct {

tibuild/internal/controller/pipeline_for_build_type.go

@@ -6,7 +6,7 @@ import (
 	"github.com/gin-gonic/gin"
 	"github.com/gin-gonic/gin/binding"
 
-	"github.com/PingCAP-QE/ee-apps/tibuild/pkg/database"
+	"github.com/PingCAP-QE/ee-apps/tibuild/internal/database"
 )
 
 type PipelineForBuildTypeStruct struct {

tibuild/internal/controller/pipeline_list_show.go

@@ -7,8 +7,8 @@ import (
 	"github.com/gin-gonic/gin/binding"
 	"github.com/rs/zerolog/log"
 
+	"github.com/PingCAP-QE/ee-apps/tibuild/internal/database"
 	"github.com/PingCAP-QE/ee-apps/tibuild/internal/entity"
-	"github.com/PingCAP-QE/ee-apps/tibuild/pkg/database"
 )
 
 type PipelinesListShowRequest struct {

tibuild/internal/controller/pipeline_trigger.go

@@ -11,10 +11,10 @@ import (
 	"github.com/gin-gonic/gin"
 	"github.com/rs/zerolog/log"
 
+	"github.com/PingCAP-QE/ee-apps/tibuild/internal/database"
 	"github.com/PingCAP-QE/ee-apps/tibuild/internal/entity"
 	"github.com/PingCAP-QE/ee-apps/tibuild/internal/service"
 	"github.com/PingCAP-QE/ee-apps/tibuild/pkg/configs"
-	"github.com/PingCAP-QE/ee-apps/tibuild/pkg/database"
 )
 
 const (

tibuild/internal/controller/request_result.go

@@ -6,8 +6,8 @@ import (
 	"github.com/gin-gonic/gin"
 	"github.com/gin-gonic/gin/binding"
 
+	"github.com/PingCAP-QE/ee-apps/tibuild/internal/database"
 	"github.com/PingCAP-QE/ee-apps/tibuild/internal/entity"
-	"github.com/PingCAP-QE/ee-apps/tibuild/pkg/database"
 )
 
 type RequestResultRequestStruct struct {

tibuild/internal/controller/request_rotation.go

@@ -6,8 +6,8 @@ import (
 	"github.com/gin-gonic/gin"
 	"github.com/gin-gonic/gin/binding"
 
+	"github.com/PingCAP-QE/ee-apps/tibuild/internal/database"
 	"github.com/PingCAP-QE/ee-apps/tibuild/internal/entity"
-	"github.com/PingCAP-QE/ee-apps/tibuild/pkg/database"
 )
 
 type RequestRotationRequestStruct struct {

tibuild/pkg/database/client_api.go tibuild/internal/database/client_api.go

@@ -10,8 +10,8 @@ import (
 
 	"github.com/bndr/gojenkins"
 
+	"github.com/PingCAP-QE/ee-apps/tibuild/internal/database"
 	"github.com/PingCAP-QE/ee-apps/tibuild/internal/entity"
-	"github.com/PingCAP-QE/ee-apps/tibuild/pkg/database"
 )
 
 func JobBuild(jenkins *gojenkins.Jenkins, ctx context.Context, jobname string, params map[string]string, pipeline_build_id int64) {

tibuild/pkg/database/mysql.go tibuild/internal/database/mysql.go

@@ -2,7 +2,6 @@ package service
 
 import (
 	"context"
-	"encoding/json"
 	"fmt"
 	"log/slog"
 	"strings"
@@ -39,19 +38,17 @@ type CloudEventClient struct {
 }
 
 func (s CloudEventClient) TriggerDevBuild(ctx context.Context, dev DevBuild) error {
-	bs, _ := json.Marshal(dev)
-	slog.InfoContext(ctx, "trigger dev build", "dev", string(bs))
 	event, err := newDevBuildCloudEvent(dev)
 	if err != nil {
 		return err
 	}
-	eventBytes, _ := event.MarshalJSON()
-	slog.InfoContext(ctx, "trigger dev build event", "event", string(eventBytes))
+
 	c := cloudevents.ContextWithTarget(ctx, s.endpoint)
 	if result := s.client.Send(c, *event); !protocol.IsACK(result) {
 		slog.ErrorContext(ctx, "failed to send", "reason", result)
 		return fmt.Errorf("failed to send ce:%w", result)
 	}
+
 	return nil
 }