test again

Author: spigell

README.md

@@ -1,6 +1,6 @@
-# THIS PROJECT IS FROZEN NOW
+## Switching to TALOS linux (https://github.com/spigell/pulumi-hcloud-kube-hetzner/tree/exp/move-to-talos)
 
-## Pulumi Hcloud Kube Hetzner
+## Pulumi Hcloud Kube Hetzner (WIP)
 This is a [Pulumi component](https://www.pulumi.com/docs/concepts/resources/components) (only GO and Typescript/JS are supported now) for creating Kubernetes clusters in Hetzner Cloud. It is inspired by [terraform-hcloud-kube-hetzner](https://github.com/kube-hetzner/terraform-hcloud-kube-hetzner).
 
 *Note: This project is in active development, and not everything is completed. However, it DOES work and is usable right now. I definitely appreciate feedback and will help with any issues*

go.mod

@@ -13,13 +13,15 @@ require (
 	github.com/pulumi/pulumi-kubernetes/sdk/v3 v3.30.2
 	github.com/pulumi/pulumi-kubernetes/sdk/v4 v4.12.0
 	github.com/pulumi/pulumi/pkg/v3 v3.118.0
-	github.com/pulumi/pulumi/sdk/v3 v3.129.0
+	github.com/pulumi/pulumi/sdk/v3 v3.137.0
 	github.com/pulumiverse/pulumi-talos/sdk v0.2.1-0.20241010205148-1f0d724ea2b4
 	github.com/sanity-io/litter v1.5.5
 	github.com/seancfoley/ipaddress-go v1.6.0
+	github.com/siderolabs/talos/pkg/machinery v1.8.2
 	github.com/spigell/pulumi-automation-api-apps v0.0.0-20231022103528-4099afba2f99
 	github.com/spigell/pulumi-automation-api-apps/hetzner-snapshots-manager/sdk v0.0.0-20231022103528-4099afba2f99
 	github.com/spigell/pulumi-file/sdk v0.0.0-20240124083824-da5e49302f10
+	github.com/spigell/pulumi-talos-cluster/sdk v0.0.0-00010101000000-000000000000
 	github.com/stretchr/testify v1.9.0
 	golang.org/x/crypto v0.26.0
 	gopkg.in/yaml.v3 v3.0.1
@@ -143,7 +145,6 @@ require (
 	github.com/siderolabs/go-pointer v1.0.0 // indirect
 	github.com/siderolabs/net v0.4.0 // indirect
 	github.com/siderolabs/protoenc v0.2.1 // indirect
-	github.com/siderolabs/talos/pkg/machinery v1.8.2 // indirect
 	github.com/sourcegraph/conc v0.3.0 // indirect
 	github.com/stoewer/go-strcase v1.2.0 // indirect
 	github.com/xeipuuv/gojsonpointer v0.0.0-20190905194746-02993c407bfb // indirect
@@ -288,3 +289,5 @@ require (
 	gopkg.in/warnings.v0 v0.1.2 // indirect
 	lukechampine.com/frand v1.4.2 // indirect
 )
+
+replace github.com/spigell/pulumi-talos-cluster/sdk => ../pulumi-talos-cluster/sdk

go.sum

@@ -149,7 +149,7 @@ func (h *Hetzner) FirewallConfigByID(id, pool string) (*firewall.Config, error)
 
 // Up creates hetzner cloud infrastructure.
 // It must be refactored.
-func (h *Hetzner) Up(keys *sshkeypair.KeyPair) (*Deployed, error) { //nolint: gocognit
+func (h *Hetzner) Up(keys *sshkeypair.KeyPair, serverUserdata *pulumi.StringOutput) (*Deployed, error) { //nolint: gocognit
 	nodes := make(map[string]*Server)
 	firewalls := make(map[string]*firewall.Firewall)
 	firewallsByNodeRole := make(map[string]pulumi.IntArray)
@@ -201,7 +201,7 @@ func (h *Hetzner) Up(keys *sshkeypair.KeyPair) (*Deployed, error) { //nolint: go
 			netID = net.ID
 		}
 
-		s := server.New(srv.Server, key)
+		s := server.New(srv.Server, key).WithUserata(serverUserdata)
 		if err := s.Validate(); err != nil {
 			return nil, err
 		}

internal/hetzner/hetzner.go

@@ -4,8 +4,6 @@ import (
 	"errors"
 	"fmt"
 
-	"github.com/spigell/pulumi-hcloud-kube-hetzner/internal/hetzner/server/scripts"
-
 	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
 	"gopkg.in/yaml.v3"
 )
@@ -73,19 +71,3 @@ func (c *CloudInit) render() pulumi.StringOutput {
 		return cloudConfigHeader + string(cfg), nil
 	}).(pulumi.StringOutput)
 }
-
-func RenameInterfaceScript() *CloudInitWriteFile {
-	return &CloudInitWriteFile{
-		Path:        "/etc/cloud/rename_interface.sh",
-		Content:     scripts.RenameInterface,
-		Permissions: "0755",
-	}
-}
-
-func WriteTalosScript() *CloudInitWriteFile {
-	return &CloudInitWriteFile{
-		Path:        "/etc/cloud/write-talos.sh",
-		Content:     scripts.WriteTalos,
-		Permissions: "0755",
-	}
-}

internal/hetzner/server/cloudinit.go

@@ -45,7 +45,7 @@ var (
 
 type Server struct {
 	Config   *config.ServerConfig
-	Userdata *CloudInit
+	Userdata *pulumi.StringOutput
 	KeyName  pulumi.StringOutput
 }
 
@@ -104,10 +104,11 @@ func New(srv *config.ServerConfig, key *hcloud.SshKey) *Server {
 	userdata.Inputs = &CloudInitPulumiInputs{
 		Key: &key.PublicKey,
 	}
+	ud := pulumi.ToSecret(userdata.render()).(pulumi.StringOutput)
 
 	return &Server{
 		Config:   srv,
-		Userdata: userdata,
+		Userdata: &ud,
 		KeyName:  key.Name,
 	}
 }
@@ -116,6 +117,12 @@ func (s *Server) Validate() error {
 	return nil
 }
 
+func (s *Server) WithUserata(u *pulumi.StringOutput) *Server {
+	s.Userdata = u
+
+	return s
+}
+
 func (s *Server) Up(ctx *program.Context, id string, internalIP string, netID pulumi.IntInput, deps []pulumi.Resource) (*Deployed, error) {
 	// Get image ID from user input
 	image := pulumi.String(s.Config.Image)
@@ -144,7 +151,7 @@ func (s *Server) Up(ctx *program.Context, id string, internalIP string, netID pu
 		Location:   pulumi.String(s.Config.Location),
 		Name:       pulumi.String(s.Config.Hostname),
 		Image:      image,
-		Rescue:     pulumi.String("linux64"),
+		// Rescue:     pulumi.String("linux64"),
 		SshKeys: pulumi.StringArray{
 			s.KeyName,
 		},
@@ -164,7 +171,7 @@ func (s *Server) Up(ctx *program.Context, id string, internalIP string, netID pu
 		}
 	}
 
-	args.UserData = pulumi.ToSecret(s.Userdata.render()).(pulumi.StringOutput)
+	args.UserData = s.Userdata
 
 	if os.Getenv(autoApiApps.EnvAutomaionAPIAddr) != "" {
 		sn, err := snapshots.GetLastSnapshot(&http.Client{}, s.Config.Hostname)

internal/hetzner/server/scripts/rename-interface.go

@@ -2,6 +2,7 @@ package distributions
 
 const (
 	K3SDistrName = "k3s"
+	TalosDistrName = "talos"
 )
 
 type Distribution interface {

internal/hetzner/server/scripts/write-talos.go

@@ -45,6 +45,7 @@ func (s *System) MicroOS() *microos.MicroOS {
 	return os
 }
 
+
 func (s *System) WithOS(os os.OperatingSystem) *System {
 	s.OS = os