Loading go-apps/meep-vis/api/swagger.yaml +5 −5 Original line number Diff line number Diff line Loading @@ -30,7 +30,7 @@ paths: /queries/uu_unicast_provisioning_info: get: tags: - 'unsupported' - 'v2xi' summary: 'Used to query provisioning information for V2X communication over Uu unicast.' description: 'Used to query provisioning information for V2X communication over Uu unicast.' operationId: prov_info_uu_unicastGET Loading Loading @@ -163,7 +163,7 @@ paths: /publish_v2x_message: post: tags: - 'unsupported' - 'v2xi' summary: 'Used to publish a V2X message.' description: 'Used to publish a V2X message.' operationId: v2x_messagePOST Loading Loading @@ -299,7 +299,7 @@ paths: get: tags: - 'unsupported' - 'v2xi' summary: 'Retrieve information about this subscription.' description: 'Retrieve information about this subscription.' operationId: individualSubscriptionGET Loading Loading @@ -330,7 +330,7 @@ paths: put: tags: - 'unsupported' - 'v2xi' summary: 'Used to update the existing subscription.' description: 'Used to update the existing subscription.' operationId: individualSubscriptionPUT Loading Loading @@ -379,7 +379,7 @@ paths: $ref: '#/components/responses/429' delete: tags: - 'unsupported' - 'v2xi' summary: 'Used to cancel the existing subscription.' description: 'Used to cancel the existing subscription.' operationId: individualSubscriptionDELETE Loading go-apps/meep-vis/server/api_unsupported.go +0 −24 Original line number Diff line number Diff line Loading @@ -27,18 +27,6 @@ import ( "net/http" ) func IndividualSubscriptionDELETE(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func IndividualSubscriptionGET(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func IndividualSubscriptionPUT(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func ProvInfoGET(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } Loading @@ -46,15 +34,3 @@ func ProvInfoGET(w http.ResponseWriter, r *http.Request) { func ProvInfoUuMbmsGET(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func ProvInfoUuUnicastGET(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func SubGET(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func V2xMessagePOST(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } go-apps/meep-vis/server/api_v2xi.go +24 −0 Original line number Diff line number Diff line Loading @@ -38,3 +38,27 @@ func PredictedQosPOST(w http.ResponseWriter, r *http.Request) { func SubPOST(w http.ResponseWriter, r *http.Request) { subscriptionsPost(w, r) } func IndividualSubscriptionDELETE(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func IndividualSubscriptionGET(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func IndividualSubscriptionPUT(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func ProvInfoUuUnicastGET(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func SubGET(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func V2xMessagePOST(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } go-apps/meep-vis/server/subscriptionCommon.go +5 −5 Original line number Diff line number Diff line Loading @@ -24,9 +24,9 @@ package server type SubscriptionCommon struct { Links *Links `json:"_links,omitempty"` // URI selected by the service consumer, to receive notifications on the subscribed RNIS information. This shall be included in the request and response. CallbackReference string `json:"callbackReference,omitempty"` FilterCriteria *V2xMsgSubscriptionFilterCriteria `json:"filterCriteria"` WebsockNotifConfig *WebsockNotifConfig `json:"websockNotifConfig,omitempty"` ExpiryDeadline *TimeStamp `json:"expiryDeadline,omitempty"` SubscriptionType string `json:"subscriptionType"` Loading go-apps/meep-vis/server/vis.go +2 −2 Original line number Diff line number Diff line Loading @@ -758,7 +758,7 @@ func subscriptionsPost(w http.ResponseWriter, r *http.Request) { self.Href = hostUrl.String() + basePath + "subscriptions/" + subsIdStr link.Self = self var jsonResponse []byte var jsonResponse string switch subscriptionType { case V2X_MSG: Loading Loading @@ -815,7 +815,7 @@ func subscriptionsPost(w http.ResponseWriter, r *http.Request) { _ = rc.JSONSetEntry(baseKey+"subscriptions:"+subsIdStr, ".", convertV2xMsgSubscriptionToJson(&v2xSubscription)) jsonResponse, _ = json.Marshal(v2xSubscription) jsonResponse = convertV2xMsgSubscriptionToJson(&v2xSubscription) default: log.Error("Unsupported subscriptionType") Loading Loading
go-apps/meep-vis/api/swagger.yaml +5 −5 Original line number Diff line number Diff line Loading @@ -30,7 +30,7 @@ paths: /queries/uu_unicast_provisioning_info: get: tags: - 'unsupported' - 'v2xi' summary: 'Used to query provisioning information for V2X communication over Uu unicast.' description: 'Used to query provisioning information for V2X communication over Uu unicast.' operationId: prov_info_uu_unicastGET Loading Loading @@ -163,7 +163,7 @@ paths: /publish_v2x_message: post: tags: - 'unsupported' - 'v2xi' summary: 'Used to publish a V2X message.' description: 'Used to publish a V2X message.' operationId: v2x_messagePOST Loading Loading @@ -299,7 +299,7 @@ paths: get: tags: - 'unsupported' - 'v2xi' summary: 'Retrieve information about this subscription.' description: 'Retrieve information about this subscription.' operationId: individualSubscriptionGET Loading Loading @@ -330,7 +330,7 @@ paths: put: tags: - 'unsupported' - 'v2xi' summary: 'Used to update the existing subscription.' description: 'Used to update the existing subscription.' operationId: individualSubscriptionPUT Loading Loading @@ -379,7 +379,7 @@ paths: $ref: '#/components/responses/429' delete: tags: - 'unsupported' - 'v2xi' summary: 'Used to cancel the existing subscription.' description: 'Used to cancel the existing subscription.' operationId: individualSubscriptionDELETE Loading
go-apps/meep-vis/server/api_unsupported.go +0 −24 Original line number Diff line number Diff line Loading @@ -27,18 +27,6 @@ import ( "net/http" ) func IndividualSubscriptionDELETE(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func IndividualSubscriptionGET(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func IndividualSubscriptionPUT(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func ProvInfoGET(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } Loading @@ -46,15 +34,3 @@ func ProvInfoGET(w http.ResponseWriter, r *http.Request) { func ProvInfoUuMbmsGET(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func ProvInfoUuUnicastGET(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func SubGET(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func V2xMessagePOST(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) }
go-apps/meep-vis/server/api_v2xi.go +24 −0 Original line number Diff line number Diff line Loading @@ -38,3 +38,27 @@ func PredictedQosPOST(w http.ResponseWriter, r *http.Request) { func SubPOST(w http.ResponseWriter, r *http.Request) { subscriptionsPost(w, r) } func IndividualSubscriptionDELETE(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func IndividualSubscriptionGET(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func IndividualSubscriptionPUT(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func ProvInfoUuUnicastGET(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func SubGET(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) } func V2xMessagePOST(w http.ResponseWriter, r *http.Request) { notImplemented(w, r) }
go-apps/meep-vis/server/subscriptionCommon.go +5 −5 Original line number Diff line number Diff line Loading @@ -24,9 +24,9 @@ package server type SubscriptionCommon struct { Links *Links `json:"_links,omitempty"` // URI selected by the service consumer, to receive notifications on the subscribed RNIS information. This shall be included in the request and response. CallbackReference string `json:"callbackReference,omitempty"` FilterCriteria *V2xMsgSubscriptionFilterCriteria `json:"filterCriteria"` WebsockNotifConfig *WebsockNotifConfig `json:"websockNotifConfig,omitempty"` ExpiryDeadline *TimeStamp `json:"expiryDeadline,omitempty"` SubscriptionType string `json:"subscriptionType"` Loading
go-apps/meep-vis/server/vis.go +2 −2 Original line number Diff line number Diff line Loading @@ -758,7 +758,7 @@ func subscriptionsPost(w http.ResponseWriter, r *http.Request) { self.Href = hostUrl.String() + basePath + "subscriptions/" + subsIdStr link.Self = self var jsonResponse []byte var jsonResponse string switch subscriptionType { case V2X_MSG: Loading Loading @@ -815,7 +815,7 @@ func subscriptionsPost(w http.ResponseWriter, r *http.Request) { _ = rc.JSONSetEntry(baseKey+"subscriptions:"+subsIdStr, ".", convertV2xMsgSubscriptionToJson(&v2xSubscription)) jsonResponse, _ = json.Marshal(v2xSubscription) jsonResponse = convertV2xMsgSubscriptionToJson(&v2xSubscription) default: log.Error("Unsupported subscriptionType") Loading