Edgegallery MEP是依据ETSI MEC 003 1和011 2标准实现的MEP开源方案

/* * Copyright 2020-2021 Huawei Technologies Co., Ltd. * * Licensed 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 mp1 import ( "bytes" "context" "crypto/tls" "encoding/json" "errors" "fmt" "github.com/beevik/ntp" "github.com/ghodss/yaml" "io" "io/ioutil" "math/rand" "mepserver/common/config" "mepserver/common/extif/dataplane" "mepserver/common/extif/dataplane/none" "mepserver/common/models" "mepserver/mp1/plans" "net/http" "net/http/httptest" "net/url" "os" "strconv" "testing" "time" "github.com/agiledragon/gomonkey" "github.com/apache/servicecomb-service-center/pkg/log" baseutil "github.com/apache/servicecomb-service-center/pkg/util" _ "github.com/apache/servicecomb-service-center/server" _ "github.com/apache/servicecomb-service-center/server/bootstrap" pb "github.com/apache/servicecomb-service-center/server/core/proto" scerr "github.com/apache/servicecomb-service-center/server/error" "github.com/apache/servicecomb-service-center/server/plugin/pkg/registry" "github.com/apache/servicecomb-service-center/server/plugin/pkg/registry/buildin" srv "github.com/apache/servicecomb-service-center/server/service" svcutil "github.com/apache/servicecomb-service-center/server/service/util" uuid "github.com/satori/go.uuid" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/mock" "reflect" "mepserver/common/extif/backend" "mepserver/common/extif/dns" ntpc "mepserver/common/extif/ntp" "mepserver/common/util" ) type mockHttpWriter struct { mock.Mock response []byte } //============================= dns ============================================ const defaultAppInstanceId = "5abe4782-2c70-4e47-9a4e-0ee3a1a0fd1f" const dnsRuleId = "7d71e54e-81f3-47bb-a2fc-b565a326d794" const trafficRuleId = "8ft68t22-81f3-47bb-a2fc-56996er4tf37" const panicFormatString = "Panic: %v" const getDnsRulesUrlFormat = "/mep/mec_app_support/v1/applications/%s/dns_rules" const getDnsRuleUrlFormat = "/mep/mec_app_support/v1/applications/%s/dns_rules/%s" const appInstanceQueryFormat = ":appInstanceId=%s&;" const appIdAndDnsRuleIdQueryFormat = ":appInstanceId=%s&;:dnsRuleId=%s&;" const appIdAndTrafficRuleIdQueryFormat = ":appInstanceId=%s&;:trafficRuleId=%s&;" const appInstanceIdHeader = "X-AppinstanceID" const responseStatusHeader = "X-Response-Status" const responseCheckFor200 = "Response status code must be 200" const responseCheckFor400 = "Response status code must be 404" const errorWriteRespErr = "Write Response Error" const exampleDomainName = "www.example.com" const defaultTTL = 30 const maxIPVal = 255 const ipAddFormatter = "%d.%d.%d.%d" const writeObjectFormat = "{\"dnsRuleId\":\"7d71e54e-81f3-47bb-a2fc-b565a326d794\",\"domainName\":\"www.example.com\"," + "\"ipAddressType\":\"IP_V4\",\"ipAddress\":\"%s\",\"ttl\":30,\"state\":\"%s\"}\n" const writeTrafficObjectFormat = "{\"trafficRuleId\":\"" + trafficRuleId + "\",\"filterType\":\"FLOW\",\"priority\":5," + "\"trafficFilter\":null,\"action\":\"DROP\",\"dstInterface\":null,\"state\":\"%s\"}\n" const writeTrafficPutObjectFormat = "{\"trafficRuleId\":\"" + trafficRuleId + "\",\"filterType\":\"FLOW\"," + "\"priority\":5," + "\"trafficFilter\":[],\"action\":\"DROP\",\"dstInterface\":null,\"state\":\"%s\"}\n" const writeCurTimetFormat = "{\"seconds\":1623770544,\"nanoSeconds\":468538768," + "\"timeSourceStatus\":\"TRACEABLE\"}" const writeCurTimeNonSynct = "{\"seconds\":1623770544,\"nanoSeconds\":468538768," + "\"timeSourceStatus\":\"NONTRACEABLE\"}" const writeCaps = "{\"timeStamp\":{\"seconds\":1623770544,\"nanoSeconds\":468538768},\"ntpServers\"" + ":[{\"ntpServerAddrType\":\"DNS_NAME\",\"ntpServerAddr\":\"mep-ntp\",\"minPollingInterval\":4,\"maxPollingInterval\":17," + "\"localPriority\":1,\"authenticationOption\":\"NONE\",\"authenticationKeyNum\":0}]}" const writeTransport = "{\"id\":\"8eb442b7cdfc11eba09314feb5b475da\",\"name\":\"REST\",\"description\":\"REST API\"," + "\"type\":\"REST_HTTP\",\"protocol\":\"HTTP\",\"version\":\"2.0\",\"endpoint\":{\"uris\":null,\"addresses\":null," + "\"alternative\":null},\"security\":{\"oAuth2Info\":{\"grantTypes\":[\"OAUTH2_CLIENT_CREDENTIALS\"]," + "\"tokenEndpoint\":\"/mep/token\"}}}" const writeCurTimeFormatVal = "{\"seconds\":%s,\"nanoSeconds\":%s," + "\"timeSourceStatus\":\"TRACEABLE\"}" const defCapabilityId = "16384563dca094183778a41ea7701d15" const svcCatHref = "serCategory/href" const svcCatResponse = "/example/catalogue1" const svcCatName = "serCategory/name" const svcCatId = "serCategory/id" const svcCatVersion = "serCategory/version" //===========================Services============================================== const postSubscribeUrl = "/mec_service_mgmt/v1/applications/%s/services" const getSubscribeUrl = "/mec_service_mgmt/v1/applications/%s/services" const getOrDelOneSubscribeOrSveUrl = "/mec_service_mgmt/v1/applications/%s/services/%s" const responseCheckFor201 = "Response status code must be 201" const responseCheckFor204 = "Response status code must be 204" const subtype1 = "SerAvailabilityNotificationSubscription" const subtype2 = "AppTerminationNotificationSubscription" const errorSubtypeMissMatch = "Subscription type mismatch" const postAppTerminologiesUrl = "/mec_app_support/v1/applications/%s/services" const getAppTerminologiesUrl = "/mec_app_support/v1/applications/%s/services" const getOneAppTerminologiesUrl = "/mec_app_support/v1/applications/%s/services/%s" const delOneAppTerminologiesUrl = "/mec_app_support/v1/applications/%s/services/%s" const appIdAndServiceIdQueryFormat = ":appInstanceId=%s&;:serviceId=%s&;" const sampleServiceId = "f7e898d1c9ea9edd7496c761ddc92718" const sampleInstanceId = "f7e898d1c9ea9edd7496c761ddc92718" const serviceDiscoverUrlFormat = "/mep/mec_service_mgmt/v1/applications/%s/services" const serNameQueryFormat = ":appInstanceId=%s&;ser_name=%s&;" const getAllTrafficRuleUrl = "/mec_app_support/v1/applications/%s/traffic_rules" const getOneTrafficRuleUrl = "/mec_app_support/v1/applications/%s/traffic_rules/%s" const heartBeatUrl = "/mep/mec_service_mgmt/v1/applications/%s/services/%s/liveness" const formatIntBase = 10 const secString = "timestamp/seconds" const nanosecString = "timestamp/nanoseconds" const getTiming = "/mec_app_support/v1/applications/timing/%s" const getCurrentTIme = "currentTime" const getCaps = "timing_caps" const getTransport = "transports" const confirm_ready = "/mec_app_support/v1/applications/%s/confirm_ready" const confirm_termination = "/mec_app_support/v1/applications/%s/confirm_termination" //=====================================COMMON==================================================================== const restApi = "REST API" const tokenEndPoint = "/mecSerMgmtApi/security/TokenEndPoint" const href = "/example/catalogue1" const callBack = "https://%d.%d.%d.%d:%d/example/catalogue1" const parseFail = "Parsing configuration file error" //=======================================END====================================================================== // Generate test IP, instead of hard coding them var exampleIPAddress = fmt.Sprintf(ipAddFormatter, rand.Intn(maxIPVal), rand.Intn(maxIPVal), rand.Intn(maxIPVal), rand.Intn(maxIPVal)) var callBackRef = fmt.Sprintf(callBack, 192, 0, 2, 1, 8080) func (m *mockHttpWriter) Header() http.Header { // Get the argument inputs args := m.Called() // retrieve the configured value we provided at the input and return it back return args.Get(0).(http.Header) } func (m *mockHttpWriter) Write(respons