-
Notifications
You must be signed in to change notification settings - Fork 1
/
action.go
98 lines (86 loc) · 2.83 KB
/
action.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
package start
import (
"fmt"
"net/http"
"os"
"os/signal"
"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
"github.com/Azure/azure-sdk-for-go/sdk/monitor/azquery"
"github.com/equinor/radix-log-api/api/controllers"
logscontroller "github.com/equinor/radix-log-api/api/controllers/logs"
"github.com/equinor/radix-log-api/api/middleware/authn"
"github.com/equinor/radix-log-api/api/router"
"github.com/equinor/radix-log-api/api/server"
"github.com/equinor/radix-log-api/pkg/radixapi/client/application"
logservice "github.com/equinor/radix-log-api/pkg/services/logs"
runtimeclient "github.com/go-openapi/runtime/client"
"github.com/go-openapi/strfmt"
"github.com/urfave/cli/v2"
)
func action(cliCtx *cli.Context) error {
router, err := buildRouter(cliCtx)
if err != nil {
return err
}
ctx, cancel := signal.NotifyContext(cliCtx.Context, os.Interrupt, os.Kill)
defer cancel()
return server.Run(ctx, router, buildServerConfig(cliCtx))
}
func buildRouter(cliCtx *cli.Context) (http.Handler, error) {
jwtValidator, err := buildJwtValidator(cliCtx)
if err != nil {
return nil, err
}
applicationClient, err := buildApplicationClient(cliCtx)
if err != nil {
return nil, err
}
controllers, err := buildControllers(cliCtx)
if err != nil {
return nil, err
}
return router.New(jwtValidator, applicationClient, controllers...)
}
func buildControllers(cliCtx *cli.Context) ([]controllers.Controller, error) {
logService, err := buildLogService(cliCtx)
if err != nil {
return nil, err
}
contollers := []controllers.Controller{
logscontroller.New(logService),
}
return contollers, nil
}
func buildLogService(cliCtx *cli.Context) (logservice.Service, error) {
logsClient, err := buildLogsAnalyticsClient()
if err != nil {
return nil, err
}
logService := logservice.New(logsClient, cliCtx.String(LogAnalyticsWorkspaceId), logservice.ContainerLogType(cliCtx.String(LogAnalyticsLogTable)))
return logService, nil
}
func buildJwtValidator(cliCtx *cli.Context) (authn.JwtValidator, error) {
return authn.NewValidator(cliCtx.String(AuthIssuer), cliCtx.String(AuthAudience))
}
func buildApplicationClient(cliCtx *cli.Context) (application.ClientService, error) {
radixApiHost := cliCtx.String(RadixAPIHost)
if len(radixApiHost) == 0 {
return nil, fmt.Errorf("required argument %s is not set", RadixAPIHost)
}
client := application.New(runtimeclient.New(radixApiHost, cliCtx.String(RadixAPIPath), []string{cliCtx.String(RadixAPIScheme)}), strfmt.Default)
return client, nil
}
func buildLogsAnalyticsClient() (*azquery.LogsClient, error) {
cred, err := azidentity.NewDefaultAzureCredential(nil)
if err != nil {
return nil, err
}
return azquery.NewLogsClient(cred, nil)
}
func buildServerConfig(cliCtx *cli.Context) *server.Config {
cfg := &server.Config{
Host: cliCtx.String(HostName),
Port: cliCtx.Int(PortNumber),
}
return cfg
}