mirror of
https://github.com/micromdm/micromdm/
synced 2026-08-05 00:45:50 +08:00
93fb332b84
Closes #302 This package still needs a lot of work, but I feel like this is a good stopping point. In a follow up, I plan on writing some tests, and refactoring some of the ways the sync.Watcher goroutines are managed.
111 lines
2.8 KiB
Go
111 lines
2.8 KiB
Go
package main
|
|
|
|
import (
|
|
"github.com/go-kit/kit/log"
|
|
httptransport "github.com/go-kit/kit/transport/http"
|
|
|
|
"github.com/micromdm/micromdm/platform/appstore"
|
|
"github.com/micromdm/micromdm/platform/blueprint"
|
|
"github.com/micromdm/micromdm/platform/config"
|
|
"github.com/micromdm/micromdm/platform/dep"
|
|
"github.com/micromdm/micromdm/platform/dep/sync"
|
|
"github.com/micromdm/micromdm/platform/device"
|
|
"github.com/micromdm/micromdm/platform/profile"
|
|
"github.com/micromdm/micromdm/platform/remove"
|
|
"github.com/micromdm/micromdm/platform/user"
|
|
)
|
|
|
|
type remoteServices struct {
|
|
profilesvc profile.Service
|
|
blueprintsvc blueprint.Service
|
|
blocksvc remove.Service
|
|
usersvc user.Service
|
|
devicesvc device.Service
|
|
configsvc config.Service
|
|
appsvc appstore.Service
|
|
depsvc dep.Service
|
|
depsyncsvc sync.Service
|
|
}
|
|
|
|
func setupClient(logger log.Logger) (*remoteServices, error) {
|
|
cfg, err := LoadServerConfig()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
profilesvc, err := profile.NewHTTPClient(
|
|
cfg.ServerURL, cfg.APIToken, logger,
|
|
httptransport.SetClient(skipVerifyHTTPClient(cfg.SkipVerify)))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
blueprintsvc, err := blueprint.NewHTTPClient(
|
|
cfg.ServerURL, cfg.APIToken, logger,
|
|
httptransport.SetClient(skipVerifyHTTPClient(cfg.SkipVerify)))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
blocksvc, err := remove.NewHTTPClient(
|
|
cfg.ServerURL, cfg.APIToken, logger,
|
|
httptransport.SetClient(skipVerifyHTTPClient(cfg.SkipVerify)))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
usersvc, err := user.NewHTTPClient(
|
|
cfg.ServerURL, cfg.APIToken, logger,
|
|
httptransport.SetClient(skipVerifyHTTPClient(cfg.SkipVerify)))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
devicesvc, err := device.NewHTTPClient(
|
|
cfg.ServerURL, cfg.APIToken, logger,
|
|
httptransport.SetClient(skipVerifyHTTPClient(cfg.SkipVerify)))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
configsvc, err := config.NewHTTPClient(
|
|
cfg.ServerURL, cfg.APIToken, logger,
|
|
httptransport.SetClient(skipVerifyHTTPClient(cfg.SkipVerify)))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
appsvc, err := appstore.NewHTTPClient(
|
|
cfg.ServerURL, cfg.APIToken, logger,
|
|
httptransport.SetClient(skipVerifyHTTPClient(cfg.SkipVerify)))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
depsvc, err := dep.NewHTTPClient(
|
|
cfg.ServerURL, cfg.APIToken, logger,
|
|
httptransport.SetClient(skipVerifyHTTPClient(cfg.SkipVerify)))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
depsyncsvc, err := sync.NewHTTPClient(
|
|
cfg.ServerURL, cfg.APIToken, logger,
|
|
httptransport.SetClient(skipVerifyHTTPClient(cfg.SkipVerify)))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &remoteServices{
|
|
profilesvc: profilesvc,
|
|
blueprintsvc: blueprintsvc,
|
|
blocksvc: blocksvc,
|
|
usersvc: usersvc,
|
|
devicesvc: devicesvc,
|
|
configsvc: configsvc,
|
|
appsvc: appsvc,
|
|
depsvc: depsvc,
|
|
depsyncsvc: depsyncsvc,
|
|
}, nil
|
|
}
|