-
Notifications
You must be signed in to change notification settings - Fork 0
/
server.go
95 lines (80 loc) · 2.89 KB
/
server.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
package protocol
// This is the server interface for a plugin. This will be used in the plugin
// to make the functions available to the client (mach-composer)
import (
"github.com/hashicorp/go-hclog"
)
type PluginRPCServer struct {
adapter *Adapter
name string
logger hclog.Logger
}
func (s *PluginRPCServer) Identifier(_ any, resp *string) error {
*resp = s.adapter.Identifier()
return nil
}
func (s *PluginRPCServer) Configure(args ConfigureInput, resp *ErrorOutput) error {
err := s.adapter.Configure(args.Environment, args.Provider)
resp.Err = wrapError(err)
return nil
}
func (s *PluginRPCServer) GetValidationSchema(_ any, resp *GetValidationSchemaOutput) error {
result, err := s.adapter.GetValidationSchema()
resp.Result = *result
resp.Err = wrapError(err)
return nil
}
func (s *PluginRPCServer) SetGlobalConfig(args SetGlobalConfigInput, resp *ErrorOutput) error {
err := s.adapter.SetGlobalConfig(args.Data)
resp.Err = wrapError(err)
return nil
}
func (s *PluginRPCServer) SetSiteConfig(args SetSiteConfigInput, resp *ErrorOutput) error {
err := s.adapter.SetSiteConfig(args.Name, args.Data)
resp.Err = wrapError(err)
return nil
}
func (s *PluginRPCServer) SetSiteComponentConfig(args SetSiteComponentConfigInput, resp *SetSiteComponentConfigOutput) error {
err := s.adapter.SetSiteComponentConfig(args.Site, args.Component, args.Data)
resp.Err = wrapError(err)
return nil
}
func (s *PluginRPCServer) SetSiteEndpointConfig(args SetSiteEndpointsConfigInput, resp *SetSiteEndpointsConfigOutput) error {
err := s.adapter.SetSiteEndpointConfig(args.Site, args.Name, args.Data)
resp.Err = wrapError(err)
return nil
}
func (s *PluginRPCServer) SetComponentConfig(args SetComponentConfigInput, resp *SetComponentConfigOutput) error {
err := s.adapter.SetComponentConfig(args.Component, args.Version, args.Data)
resp.Err = wrapError(err)
return nil
}
func (s *PluginRPCServer) SetComponentEndpointsConfig(args SetComponentEndpointsConfigInput, resp *SetSiteComponentConfigOutput) error {
err := s.adapter.SetComponentEndpointsConfig(args.Component, args.Endpoints)
resp.Err = wrapError(err)
return nil
}
func (s *PluginRPCServer) RenderTerraformProviders(
args RenderTerraformProvidersInput,
resp *RenderTerraformProvidersOutput) error {
result, err := s.adapter.RenderTerraformProviders(args.Site)
resp.Result = result
resp.Err = wrapError(err)
return nil
}
func (s *PluginRPCServer) RenderTerraformResources(
args RenderTerraformResourcesInput,
resp *RenderTerraformResourcesOutput) error {
result, err := s.adapter.RenderTerraformResources(args.Site)
resp.Result = result
resp.Err = wrapError(err)
return nil
}
func (s *PluginRPCServer) RenderTerraformComponent(
args RenderTerraformComponentInput,
resp *RenderTerraformComponentOutput) error {
result, err := s.adapter.RenderTerraformComponent(args.Site, args.Component)
resp.Result = result
resp.Err = wrapError(err)
return nil
}