Skip to content

Commit

Permalink
Provisioner: Add kbs provisioner in provisioner-cli
Browse files Browse the repository at this point in the history
Fixes: confidential-containers#1471
Signed-off-by: Kartik Joshi <kartikjoshi@microsoft.com>
  • Loading branch information
kartikjoshi21 committed Feb 8, 2024
1 parent af2b436 commit 9f20b2c
Showing 1 changed file with 39 additions and 2 deletions.
41 changes: 39 additions & 2 deletions test/tools/provisioner-cli/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -83,11 +83,38 @@ func main() {
}
}

props := provisioner.GetProperties(context.TODO(), cfg)
log.Info("Deploying kbs")
if props["KBS_IMAGE"] == "" || props["KBS_IMAGE_TAG"] == "" {
log.Fatal("kbs image not provided")
}

keyBrokerService, err := pv.NewKeyBrokerService(props["CLUSTER_NAME"])
if err != nil {
log.Fatal(err)
}

if err = keyBrokerService.Deploy(context.TODO(), cfg, props); err != nil {
log.Fatal(err)
}

var kbsPodIP string
kbsPodIP, err = keyBrokerService.GetKbsSvcIP(context.TODO(), cfg)
if err != nil {
log.Fatal(err)
}

kbsparams := "cc_kbc::http:" + kbsPodIP + ":8080"
log.Infof("KBS PARAMS%s:", kbsparams)

props = provisioner.GetProperties(context.TODO(), cfg)
props["AA_KBC_PARAMS"] = kbsparams

cloudAPIAdaptor, err := pv.NewCloudAPIAdaptor(cloudProvider, installDirectory)
if err != nil {
log.Fatal(err)
}
if err := cloudAPIAdaptor.Deploy(context.TODO(), cfg, provisioner.GetProperties(context.TODO(), cfg)); err != nil {
if err := cloudAPIAdaptor.Deploy(context.TODO(), cfg, props); err != nil {
log.Fatal(err)
}
}
Expand Down Expand Up @@ -128,7 +155,7 @@ func main() {
if kubeconfigPath == "" {
log.Fatal("Unabled to find a kubeconfig file")
}
cfg := envconf.NewWithKubeConfig(kubeconfigPath)
cfg = envconf.NewWithKubeConfig(kubeconfigPath)

err = deployer.Deploy(context.TODO(), cfg, provisioner.GetProperties(context.TODO(), cfg))
if err != nil {
Expand All @@ -143,6 +170,16 @@ func main() {
log.Fatal(err)
}

props := provisioner.GetProperties(context.TODO(), cfg)
keyBrokerService, err := pv.NewKeyBrokerService(props["CLUSTER_NAME"])
if err != nil {
log.Fatal(err)
}

if err = keyBrokerService.Delete(context.TODO(), cfg); err != nil {
log.Fatal(err)
}

kubeconfigPath := kconf.ResolveKubeConfigFile()
if kubeconfigPath == "" {
log.Fatal("Unabled to find a kubeconfig file")
Expand Down

0 comments on commit 9f20b2c

Please sign in to comment.