From 5779a6eaa12c3f9f81e109007c939dc353c45575 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=87=A1=E7=BE=8A=E7=BE=8A?= Date: Tue, 10 Sep 2019 13:13:42 +0800 Subject: [PATCH] add third-part endpoint as sync event type --- api/api_routers/version2/v2Routers.go | 2 +- db/gateway_db_test.go | 223 +------------------------- util/license/no_license.go | 1 + 3 files changed, 3 insertions(+), 223 deletions(-) diff --git a/api/api_routers/version2/v2Routers.go b/api/api_routers/version2/v2Routers.go index c2020a6ef..0ab8d9f89 100644 --- a/api/api_routers/version2/v2Routers.go +++ b/api/api_routers/version2/v2Routers.go @@ -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) diff --git a/db/gateway_db_test.go b/db/gateway_db_test.go index aa014feb5..8381967f0 100644 --- a/db/gateway_db_test.go +++ b/db/gateway_db_test.go @@ -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 { diff --git a/util/license/no_license.go b/util/license/no_license.go index a95cf38b6..bdbb1f746 100644 --- a/util/license/no_license.go +++ b/util/license/no_license.go @@ -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"`