test/Rainbond
1
0
Fork 0
mirror of https://gitee.com/rainbond/Rainbond.git synced 2024-11-30 02:38:17 +08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

add third-part endpoint as sync event type

Browse Source
This commit is contained in:
凡羊羊 2019-09-10 13:13:42 +08:00 committed by glyasai
parent 49284182bd
commit 5779a6eaa1
3 changed files with 3 additions and 223 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
api/api_routers/version2/v2Routers.go
View File

@ -226,7 +226,7 @@ func (v2 *V2) serviceRouter() chi.Router {
r.Get("/deploy-info", controller.GetServiceDeployInfo)
// third-party service
r.Post("/endpoints", middleware.WrapEL(controller.GetManager().Endpoints, dbmodel.TargetTypeService, "add-thirdpart-service", dbmodel.ASYNEVENTTYPE))
r.Post("/endpoints", middleware.WrapEL(controller.GetManager().Endpoints, dbmodel.TargetTypeService, "add-thirdpart-service", dbmodel.SYNEVENTTYPE))
r.Put("/endpoints", middleware.WrapEL(controller.GetManager().Endpoints, dbmodel.TargetTypeService, "update-thirdpart-service", dbmodel.SYNEVENTTYPE))
r.Delete("/endpoints", middleware.WrapEL(controller.GetManager().Endpoints, dbmodel.TargetTypeService, "delete-thirdpart-service", dbmodel.SYNEVENTTYPE))
r.Get("/endpoints", controller.GetManager().Endpoints)

223
db/gateway_db_test.go
View File

@ -21,236 +21,15 @@ package db
import (
"context"
"fmt"
"github.com/testcontainers/testcontainers-go"
"testing"
"time"
dbconfig "github.com/goodrain/rainbond/db/config"
"github.com/goodrain/rainbond/db/model"
"github.com/goodrain/rainbond/util"
"github.com/testcontainers/testcontainers-go"
)
func TestIPPortImpl_UpdateModel(t *testing.T) {
// if err := CreateManager(dbconfig.Config{
// DBType: "sqlite3",
// }); err != nil {
// t.Fatal(err)
// }
// tx := GetManager().Begin()
// tx.Delete(model.IPPort{})
// tx.Commit()
// ipport := &model.IPPort{
// UUID: util.NewUUID(),
// IP: "127.0.0.1",
// Port: 8888,
// }
// if err := GetManager().IPPortDao().AddModel(ipport); err != nil {
// t.Fatal(err)
// }
// ipport.Port = 9999
// err := GetManager().IPPortDao().UpdateModel(ipport)
// if err != nil {
// t.Fatal(err)
// }
}
func TestIPPortImpl_DeleteIPPortByIPAndPort(t *testing.T) {
// if err := CreateManager(dbconfig.Config{
// DBType: "sqlite3",
// }); err != nil {
// t.Fatal(err)
// }
// tx := GetManager().Begin()
// tx.Delete(model.IPPort{})
// tx.Commit()
// ipport := &model.IPPort{
// UUID: util.NewUUID(),
// IP: "127.0.0.1",
// Port: 8888,
// }
// if err := GetManager().IPPortDao().AddModel(ipport); err != nil {
// t.Fatal(err)
// }
// if err := GetManager().IPPortDao().DeleteByIPAndPort(ipport.IP, ipport.Port); err != nil {
// t.Fatal(err)
// }
// ipPort, err := GetManager().IPPortDao().GetIPPortByIPAndPort(ipport.IP, ipport.Port)
// if err != nil {
// t.Fatal(err)
// }
// if ipPort != nil {
// t.Errorf("Expected nil for ipPort, but return %v", ipPort)
// }
}
func TestIPPortImpl_GetIPByPort(t *testing.T) {
// if err := CreateManager(dbconfig.Config{
// DBType: "sqlite3",
// }); err != nil {
// t.Fatal(err)
// }
// tx := GetManager().Begin()
// tx.Delete(model.IPPort{})
// tx.Commit()
// ipport := &model.IPPort{
// UUID: util.NewUUID(),
// IP: "127.0.0.1",
// Port: 8888,
// }
// if err := GetManager().IPPortDao().AddModel(ipport); err != nil {
// t.Fatal(err)
// }
// ports, err := GetManager().IPPortDao().GetIPByPort(8888)
// if err != nil {
// t.Fatal(err)
// }
// if len(ports) != 1 {
// t.Fatalf("Expected 1 for length of ports, but returned %d)", len(ports))
// }
}
func TestIPPortImpl_GetIPPortByIPAndPort(t *testing.T) {
// if err := CreateManager(dbconfig.Config{
// DBType: "sqlite3",
// }); err != nil {
// t.Fatal(err)
// }
// tx := GetManager().Begin()
// tx.Delete(model.IPPort{})
// tx.Commit()
// ipport := &model.IPPort{
// UUID: util.NewUUID(),
// IP: "127.0.0.1",
// Port: 8888,
// }
// if err := GetManager().IPPortDao().AddModel(ipport); err != nil {
// t.Fatal(err)
// }
// ipPort, err := GetManager().IPPortDao().GetIPPortByIPAndPort(ipport.IP, ipport.Port)
// if err != nil {
// t.Fatal(err)
// }
// if ipPort.IP != ipport.IP {
// t.Errorf("Expected %s for ip, but retruned %s", ipport.IP, ipPort.IP)
// }
// if ipPort.Port != ipport.Port {
// t.Errorf("Expected %d for port, but retruned %d", ipport.Port, ipPort.Port)
// }
}
func TestIPPoolImpl_AddModel(t *testing.T) {
// if err := CreateManager(dbconfig.Config{
// DBType: "sqlite3",
// }); err != nil {
// t.Fatal(err)
// }
// tx := GetManager().Begin()
// tx.Delete(model.IPPool{})
// tx.Commit()
// ippool := &model.IPPool{
// EID: util.NewUUID(),
// CIDR: "192.168.11.11/24",
// }
// if err := GetManager().IPPoolDao().AddModel(ippool); err != nil {
// t.Fatal(err)
// }
// pool, err := GetManager().IPPoolDao().GetIPPoolByEID(ippool.EID)
// if err != nil {
// t.Fatal(err)
// }
// if pool == nil {
// t.Errorf("Expected %v for pool, but returned nil", pool)
// }
// if pool.CIDR != ippool.CIDR {
// t.Errorf("Expected %v for CIDR, but returned %s", ippool.CIDR, pool.CIDR)
// }
}
func TestIPPoolImpl_UpdateModel(t *testing.T) {
// if err := CreateManager(dbconfig.Config{
// DBType: "sqlite3",
// }); err != nil {
// t.Fatal(err)
// }
// tx := GetManager().Begin()
// tx.Delete(model.IPPool{})
// tx.Commit()
// ippool := &model.IPPool{
// EID: util.NewUUID(),
// CIDR: "192.168.11.11/24",
// }
// if err := GetManager().IPPoolDao().AddModel(ippool); err != nil {
// t.Fatal(err)
// }
// ippool.CIDR = "192.168.22.22/24"
// if err := GetManager().IPPoolDao().UpdateModel(ippool); err != nil {
// t.Fatal(err)
// }
// if ippool.CIDR != "192.168.22.22/24" {
// t.Errorf("Expected %s for CIDR, but returned %s", "192.168.22.22/24", ippool.CIDR)
// }
}
func TestHTTPRuleImpl_ListByServiceID(t *testing.T) {
// if err := CreateManager(dbconfig.Config{
// DBType: "sqlite3",
// }); err != nil {
// t.Fatal(err)
// }
// tx := GetManager().Begin()
// tx.Delete(model.HTTPRule{})
// tx.Commit()
// rules, err := GetManager().HTTPRuleDao().ListByServiceID("")
// if err != nil {
// t.Fatal(err)
// }
// if len(rules) != 0 {
// t.Errorf("Expected 0 for len(rules), but returned %v", len(rules))
// }
// serviceID := util.NewUUID()
// rules = []*model.HTTPRule{
// {
// UUID: util.NewUUID(),
// ServiceID: serviceID,
// },
// {
// UUID: util.NewUUID(),
// ServiceID: serviceID,
// },
// {
// UUID: util.NewUUID(),
// ServiceID: serviceID,
// },
// }
// for _, rule := range rules {
// err := GetManager().HTTPRuleDao().AddModel(rule)
// if err != nil {
// t.Fatal(err)
// }
// }
// rules, err = GetManager().HTTPRuleDao().ListByServiceID(serviceID)
// if err != nil {
// t.Fatal(err)
// }
// if len(rules) != 3 {
// t.Errorf("Expected 3 for len(rules), but returned %v", len(rules))
// }
}
func TestGwRuleConfig(t *testing.T) {
dbm, err := CreateTestManager()
if err != nil {

1
util/license/no_license.go
View File

@ -22,6 +22,7 @@ package license
// LicInfo license information
type LicInfo struct {
LicKey string `json:"license_key"`
Code string `json:"code"`
Company string `json:"company"`
Node int64 `json:"node"`