-
Notifications
You must be signed in to change notification settings - Fork 29
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Alarm subscription server support 1st part: (#71)
1. Start alarm subscription server, initialize the path, related registrations 2. Alarm subscription server basic resp api support for get, list, add, and delete
- Loading branch information
1 parent
60c2282
commit 3a24a17
Showing
11 changed files
with
935 additions
and
3 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,210 @@ | ||
| /* | ||
| Copyright 2023 Red Hat Inc. | ||
| 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 server | ||
|
|
||
| import ( | ||
| "log/slog" | ||
| "net/http" | ||
|
|
||
| "github.com/gorilla/mux" | ||
| "github.com/spf13/cobra" | ||
|
|
||
| "github.com/openshift-kni/oran-o2ims/internal" | ||
| "github.com/openshift-kni/oran-o2ims/internal/exit" | ||
| "github.com/openshift-kni/oran-o2ims/internal/logging" | ||
| "github.com/openshift-kni/oran-o2ims/internal/network" | ||
| "github.com/openshift-kni/oran-o2ims/internal/service" | ||
| ) | ||
|
|
||
| // Server creates and returns the `start alarm-subscription-server` command. | ||
| func AlarmSubscriptionServer() *cobra.Command { | ||
| c := NewAlarmSubscriptionServer() | ||
| result := &cobra.Command{ | ||
| Use: "alarm-subscription-server", | ||
| Short: "Starts the alarm Subscription Server", | ||
| Args: cobra.NoArgs, | ||
| RunE: c.run, | ||
| } | ||
| flags := result.Flags() | ||
|
|
||
| // no need for now | ||
| //authentication.AddFlags(flags) | ||
| //authorization.AddFlags(flags) | ||
|
|
||
| network.AddListenerFlags(flags, network.APIListener, network.APIAddress) | ||
| _ = flags.String( | ||
| cloudIDFlagName, | ||
| "", | ||
| "O-Cloud identifier.", | ||
| ) | ||
| _ = flags.StringArray( | ||
| extensionsFlagName, | ||
| []string{}, | ||
| "Extension to add to alarm subscriptions.", | ||
| ) | ||
| return result | ||
| } | ||
|
|
||
| // alarmSubscriptionServerCommand contains the data and logic needed to run the `start | ||
| // alarm-subscription-server` command. | ||
| type AlarmSubscriptionServerCommand struct { | ||
| } | ||
|
|
||
| // NewAlarmSubscriptionServer creates a new runner that knows how to execute the `start | ||
| // alarm-subscription-server` command. | ||
| func NewAlarmSubscriptionServer() *AlarmSubscriptionServerCommand { | ||
| return &AlarmSubscriptionServerCommand{} | ||
| } | ||
|
|
||
| // run executes the `start alarm-subscription-server` command. | ||
| func (c *AlarmSubscriptionServerCommand) run(cmd *cobra.Command, argv []string) error { | ||
| // Get the context: | ||
| ctx := cmd.Context() | ||
|
|
||
| // Get the dependencies from the context: | ||
| logger := internal.LoggerFromContext(ctx) | ||
|
|
||
| // Get the flags: | ||
| flags := cmd.Flags() | ||
|
|
||
| // Get the cloud identifier: | ||
| cloudID, err := flags.GetString(cloudIDFlagName) | ||
| if err != nil { | ||
| logger.Error( | ||
| "Failed to get cloud identifier flag", | ||
| "flag", cloudIDFlagName, | ||
| "error", err.Error(), | ||
| ) | ||
| return exit.Error(1) | ||
| } | ||
| if cloudID == "" { | ||
| logger.Error( | ||
| "Cloud identifier is empty", | ||
| "flag", cloudIDFlagName, | ||
| ) | ||
| return exit.Error(1) | ||
| } | ||
| logger.Info( | ||
| "Cloud identifier", | ||
| "value", cloudID, | ||
| ) | ||
|
|
||
| // Get the backend details: | ||
| extensions, err := flags.GetStringArray(extensionsFlagName) | ||
| if err != nil { | ||
| logger.Error( | ||
| "Failed to extension flag", | ||
| "flag", extensionsFlagName, | ||
| "error", err.Error(), | ||
| ) | ||
| return exit.Error(1) | ||
| } | ||
| logger.Info( | ||
| "alarm subscription extensions details", | ||
| slog.Any("extensions", extensions), | ||
| ) | ||
|
|
||
| // Create the logging wrapper: | ||
| loggingWrapper, err := logging.NewTransportWrapper(). | ||
| SetLogger(logger). | ||
| SetFlags(flags). | ||
| Build() | ||
| if err != nil { | ||
| logger.Error( | ||
| "Failed to create transport wrapper", | ||
| "error", err.Error(), | ||
| ) | ||
| return exit.Error(1) | ||
| } | ||
|
|
||
| // Create the router: | ||
| router := mux.NewRouter() | ||
| router.NotFoundHandler = http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { | ||
| service.SendError(w, http.StatusNotFound, "Not found") | ||
| }) | ||
| router.MethodNotAllowedHandler = http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { | ||
| service.SendError(w, http.StatusMethodNotAllowed, "Method not allowed") | ||
| }) | ||
| //router.Use(authenticationWrapper, authorizationWrapper) | ||
|
|
||
| // Create the handler: | ||
| handler, err := service.NewAlarmSubscriptionHandler(). | ||
| SetLogger(logger). | ||
| SetLoggingWrapper(loggingWrapper). | ||
| SetCloudID(cloudID). | ||
| SetExtensions(extensions...). | ||
| Build() | ||
| if err != nil { | ||
| logger.Error( | ||
| "Failed to create handler", | ||
| "error", err, | ||
| ) | ||
| return exit.Error(1) | ||
| } | ||
|
|
||
| // Create the routes: | ||
| adapter, err := service.NewAdapter(). | ||
| SetLogger(logger). | ||
| SetPathVariables("alarmSubscriptionID"). | ||
| SetHandler(handler). | ||
| Build() | ||
| if err != nil { | ||
| logger.Error( | ||
| "Failed to create adapter", | ||
| "error", err, | ||
| ) | ||
| return exit.Error(1) | ||
| } | ||
| router.Handle( | ||
| "/o2ims-infrastructureMonitoring/{version}/alarmSubscriptions", | ||
| adapter, | ||
| ).Methods(http.MethodGet, http.MethodPost) | ||
|
|
||
| router.Handle( | ||
| "/o2ims-infrastructureMonitoring/{version}/alarmSubscriptions/{alarmSubscriptionID}", | ||
| adapter, | ||
| ).Methods(http.MethodGet, http.MethodDelete) | ||
|
|
||
| // Start the API server: | ||
| apiListener, err := network.NewListener(). | ||
| SetLogger(logger). | ||
| SetFlags(flags, network.APIListener). | ||
| Build() | ||
| if err != nil { | ||
| logger.Error( | ||
| "Failed to to create API listener", | ||
| slog.String("error", err.Error()), | ||
| ) | ||
| return exit.Error(1) | ||
| } | ||
| logger.Info( | ||
| "API listening", | ||
| slog.String("address", apiListener.Addr().String()), | ||
| ) | ||
| apiServer := http.Server{ | ||
| Addr: apiListener.Addr().String(), | ||
| Handler: router, | ||
| } | ||
| err = apiServer.Serve(apiListener) | ||
| if err != nil { | ||
| logger.Error( | ||
| "API server finished with error", | ||
| slog.String("error", err.Error()), | ||
| ) | ||
| return exit.Error(1) | ||
| } | ||
|
|
||
| return nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.