caa: remove option to configure agent via userdata

src/cloud-api-adaptor/docs/initdata.md

@@ -146,8 +146,6 @@ spec:
 cloud-api-adaptor will read the annotation and write it to [write_files](../../cloud-providers/util/cloudinit/cloudconfig.go). Note: files unrelated to initdata (like network tunnel configuration in `/run/peerpod/daemon.json`) are also part of the `write_files` directive.
 ```yaml
 write_files:
-- path: /run/peerpod/agent-config.toml
-  content: 
 - path: /run/peerpod/daemon.json
   content: 
 - path: /run/peerpod/auth.json

src/cloud-api-adaptor/pkg/adaptor/cloud/cloud.go

@@ -23,7 +23,6 @@ import (
 
 	"github.com/confidential-containers/cloud-api-adaptor/src/cloud-api-adaptor/pkg/adaptor/k8sops"
 	"github.com/confidential-containers/cloud-api-adaptor/src/cloud-api-adaptor/pkg/adaptor/proxy"
-	"github.com/confidential-containers/cloud-api-adaptor/src/cloud-api-adaptor/pkg/agent"
 	"github.com/confidential-containers/cloud-api-adaptor/src/cloud-api-adaptor/pkg/forwarder"
 	. "github.com/confidential-containers/cloud-api-adaptor/src/cloud-api-adaptor/pkg/paths"
 	"github.com/confidential-containers/cloud-api-adaptor/src/cloud-api-adaptor/pkg/podnetwork"
@@ -255,7 +254,6 @@ func (s *cloudService) CreateVM(ctx context.Context, req *pb.CreateVMRequest) (r
 	agentProxy := s.proxyFactory.New(serverName, socketPath)
 
 	var authJSON []byte
-	var authFilePath string
 	_, err = os.Stat(SrcAuthfilePath)
 	if err != nil {
 		logger.Printf("credential file %s is not present, skipping image auth config", SrcAuthfilePath)
@@ -264,15 +262,9 @@ func (s *cloudService) CreateVM(ctx context.Context, req *pb.CreateVMRequest) (r
 		if err != nil {
 			return nil, fmt.Errorf("error reading %s: %v", SrcAuthfilePath, err)
 		}
-		authFilePath = AuthFilePath
 		logger.Printf("configure agent to use credentials file %s", SrcAuthfilePath)
 	}
 
-	agentConfig, err := agent.CreateConfigFile(authFilePath)
-	if err != nil {
-		return nil, fmt.Errorf("creating agent config: %w", err)
-	}
-
 	daemonConfig := forwarder.Config{
 		PodNamespace: namespace,
 		PodName:      pod,
@@ -321,10 +313,6 @@ func (s *cloudService) CreateVM(ctx context.Context, req *pb.CreateVMRequest) (r
 
 	cloudConfig := &cloudinit.CloudConfig{
 		WriteFiles: []cloudinit.WriteFile{
-			{
-				Path:    agent.ConfigFilePath,
-				Content: agentConfig,
-			},
 			{
 				Path:    forwarder.DefaultConfigPath,
 				Content: string(daemonJSON),

src/cloud-api-adaptor/pkg/userdata/provision.go

@@ -37,7 +37,7 @@ const (
 )
 
 var logger = log.New(log.Writer(), "[userdata/provision] ", log.LstdFlags|log.Lmsgprefix)
-var WriteFilesList = []string{AACfgPath, CDHCfgPath, AgentCfgPath, ForwarderCfgPath, AuthFilePath, InitDataPath}
+var WriteFilesList = []string{AACfgPath, CDHCfgPath, ForwarderCfgPath, AuthFilePath, InitDataPath}
 var InitdDataFilesList = []string{AACfgPath, CDHCfgPath, PolicyPath}
 
 type Config struct {

src/cloud-api-adaptor/pkg/userdata/provision_test.go

@@ -14,10 +14,6 @@ import (
 	"time"
 )
 
-var testAgentConfig string = `server_addr = 'unix:///run/kata-containers/agent.sock'
-guest_components_procs = 'none'
-`
-
 var testDaemonConfig string = `{
 	"pod-network": {
 		"podip": "10.244.0.19/24",
@@ -336,12 +332,11 @@ func TestProcessCloudConfig(t *testing.T) {
 	defer os.RemoveAll(tempDir)
 
 	var aaCfgPath = filepath.Join(tempDir, "aa.toml")
-	var agentCfgPath = filepath.Join(tempDir, "agent-config.toml")
 	var cdhCfgPath = filepath.Join(tempDir, "cdh.toml")
 	var daemonPath = filepath.Join(tempDir, "daemon.json")
 	var authPath = filepath.Join(tempDir, "auth.json")
 	var initdataPath = filepath.Join(tempDir, "initdata")
-	var writeFilesList = []string{aaCfgPath, agentCfgPath, cdhCfgPath, daemonPath, authPath, initdataPath}
+	var writeFilesList = []string{aaCfgPath, cdhCfgPath, daemonPath, authPath, initdataPath}
 
 	content := fmt.Sprintf(`#cloud-config
 write_files:
@@ -360,14 +355,9 @@ write_files:
 - path: %s
   content: |
 %s
-- path: %s
-  content: |
-%s
 `,
 		aaCfgPath,
 		indentTextBlock(testAAConfig, 4),
-		agentCfgPath,
-		indentTextBlock(testAgentConfig, 4),
 		cdhCfgPath,
 		indentTextBlock(testCDHConfig, 4),
 		daemonPath,
@@ -403,12 +393,6 @@ write_files:
 		t.Fatalf("file content does not match aa config fixture: got %q", fileContent)
 	}
 
-	data, _ = os.ReadFile(agentCfgPath)
-	fileContent = string(data)
-	if fileContent != testAgentConfig {
-		t.Fatalf("file content does not match agent config fixture: got %q", fileContent)
-	}
-
 	data, _ = os.ReadFile(cdhCfgPath)
 	fileContent = string(data)
 	if fileContent != testCDHConfig {
@@ -439,12 +423,11 @@ func TestProcessCloudConfigWithMalicious(t *testing.T) {
 	defer os.RemoveAll(tempDir)
 
 	var aaCfgPath = filepath.Join(tempDir, "aa.toml")
-	var agentCfgPath = filepath.Join(tempDir, "agent-config.toml")
 	var cdhCfgPath = filepath.Join(tempDir, "cdh.toml")
 	var daemonPath = filepath.Join(tempDir, "daemon.json")
 	var authPath = filepath.Join(tempDir, "auth.json")
 	var malicious = filepath.Join(tempDir, "malicious")
-	var writeFilesList = []string{aaCfgPath, agentCfgPath, cdhCfgPath, daemonPath, authPath}
+	var writeFilesList = []string{aaCfgPath, cdhCfgPath, daemonPath, authPath}
 
 	content := fmt.Sprintf(`#cloud-config
 write_files:
@@ -463,14 +446,9 @@ write_files:
 - path: %s
   content: |
 %s
-- path: %s
-  content: |
-%s
 `,
 		aaCfgPath,
 		indentTextBlock(testAAConfig, 4),
-		agentCfgPath,
-		indentTextBlock(testAgentConfig, 4),
 		cdhCfgPath,
 		indentTextBlock(testCDHConfig, 4),
 		daemonPath,
@@ -506,12 +484,6 @@ write_files:
 		t.Fatalf("file content does not match aa config fixture: got %q", fileContent)
 	}
 
-	data, _ = os.ReadFile(agentCfgPath)
-	fileContent = string(data)
-	if fileContent != testAgentConfig {
-		t.Fatalf("file content does not match agent config fixture: got %q", fileContent)
-	}
-
 	data, _ = os.ReadFile(cdhCfgPath)
 	fileContent = string(data)
 	if fileContent != testCDHConfig {

src/cloud-api-adaptor/podvm/files/etc/agent-config.toml

@@ -0,0 +1,3 @@
+server_addr = "unix:///run/kata-containers/agent.sock"
+guest_components_procs = "none"
+image_registry_auth = "file:///etc/kata-oci/auth.json"

src/cloud-api-adaptor/podvm/files/etc/kata-oci/empty-auth.json

@@ -0,0 +1,3 @@
+{
+  "auths": {}
+}

src/cloud-api-adaptor/podvm/files/etc/systemd/system/kata-agent.service

@@ -5,9 +5,9 @@ [email protected] process-user-data.service
 
 [Service]
 ExecStartPre=mkdir -p /run/kata-containers
-ExecStart=/usr/local/bin/kata-agent --config /run/peerpod/agent-config.toml
+ExecStart=/usr/local/bin/kata-agent --config /etc/agent-config.toml
 ExecStartPre=-umount /sys/fs/cgroup/misc
-ExecStopPost=/usr/local/bin/kata-agent-clean --config /run/peerpod/agent-config.toml
+ExecStopPost=/usr/local/bin/kata-agent-clean --config /etc/agent-config.toml
 SyslogIdentifier=kata-agent
 
 [Install]

src/cloud-api-adaptor/podvm/files/etc/tmpfiles.d/auth.conf

@@ -0,0 +1,2 @@
+#Type   Path                            Mode User Group Age     Argument
+C       /run/peerpod/auth.json          -    -    -     -       /etc/kata-oci/empty-auth.json

src/cloud-api-adaptor/podvm/qcow2/copy-files.sh

@@ -30,3 +30,8 @@ sudo cp -a /tmp/files/pause_bundle /
 sudo mkdir -p /etc/kata-opa
 sudo cp -a /tmp/files/etc/kata-opa/* /etc/kata-opa/
 sudo cp -a /tmp/files/etc/tmpfiles.d/policy.conf /etc/tmpfiles.d/
+
+# Copy an empty auth.json for image pulling
+sudo mkdir -p /etc/kata-oci
+sudo cp -a /tmp/files/etc/kata-oci/* /etc/kata-oci/
+sudo cp -a /tmp/files/etc/tmpfiles.d/auth.conf /etc/tmpfiles.d/