Add configurable boot_check_pattern for turingpi_node resource

- Add boot_check_pattern option (default: 'login:')
- Support Talos Linux detection ('machine is running and ready')
- Update documentation with pattern examples
- Update all versions to 1.0.5

Author: jfreed-dev

CHANGELOG.md

@@ -7,6 +7,13 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## [1.0.5] - 2025-12-22
+
+### Added
+- `boot_check_pattern` option for turingpi_node resource
+- Configurable pattern matching for boot verification (default: `"login:"`)
+- Support for Talos Linux boot detection (`"machine is running and ready"`)
+
 ## [1.0.4] - 2025-12-22
 
 ### Added
@@ -67,7 +74,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Release automation workflow with GoReleaser
 - Multi-platform binaries (linux/darwin/windows, amd64/arm64)
 
-[Unreleased]: https://github.com/jfreed-dev/terraform-provider-turingpi/compare/v1.0.4...HEAD
+[Unreleased]: https://github.com/jfreed-dev/terraform-provider-turingpi/compare/v1.0.5...HEAD
+[1.0.5]: https://github.com/jfreed-dev/terraform-provider-turingpi/compare/v1.0.4...v1.0.5
 [1.0.4]: https://github.com/jfreed-dev/terraform-provider-turingpi/compare/v1.0.3...v1.0.4
 [1.0.3]: https://github.com/jfreed-dev/terraform-provider-turingpi/compare/v1.0.2...v1.0.3
 [1.0.2]: https://github.com/jfreed-dev/terraform-provider-turingpi/compare/v1.0.1...v1.0.2

README.md

@@ -18,7 +18,7 @@ terraform {
   required_providers {
     turingpi = {
       source  = "jfreed-dev/turingpi"
-      version = "1.0.4"
+      version = "1.0.5"
     }
   }
 }
@@ -74,11 +74,19 @@ Comprehensive node management: power control, firmware flashing, and boot verifi
 
 ```hcl
 resource "turingpi_node" "node1" {
-  node                 = 1                        # Node ID (1-4)
-  power_state          = "on"                     # "on" or "off" (default: "on")
-  firmware_file        = "/path/to/firmware.img"  # optional
-  boot_check           = true                     # Monitor UART for login prompt (default: false)
-  login_prompt_timeout = 120                      # Timeout in seconds (default: 60)
+  node                 = 1                              # Node ID (1-4)
+  power_state          = "on"                           # "on" or "off" (default: "on")
+  firmware_file        = "/path/to/firmware.img"        # optional
+  boot_check           = true                           # Monitor UART for boot pattern (default: false)
+  boot_check_pattern   = "login:"                       # Pattern to detect (default: "login:")
+  login_prompt_timeout = 120                            # Timeout in seconds (default: 60)
+}
+
+# For Talos Linux, use the appropriate boot pattern:
+resource "turingpi_node" "talos" {
+  node               = 2
+  boot_check         = true
+  boot_check_pattern = "machine is running and ready"
 }
 ```
 

docs/index.md

@@ -23,7 +23,7 @@ terraform {
   required_providers {
     turingpi = {
       source  = "jfreed-dev/turingpi"
-      version = "1.0.4"
+      version = "1.0.5"
     }
   }
 }

docs/resources/node.md

@@ -42,6 +42,18 @@ resource "turingpi_node" "node1" {
 }
 ```
 
+### Talos Linux Boot Verification
+
+```hcl
+resource "turingpi_node" "talos_node" {
+  node                 = 1
+  power_state          = "on"
+  boot_check           = true
+  boot_check_pattern   = "machine is running and ready"
+  login_prompt_timeout = 180
+}
+```
+
 ### Complete Cluster Setup
 
 ```hcl
@@ -95,8 +107,9 @@ output "node_status" {
 - `node` - (Required, Integer) The node ID (1-4).
 - `power_state` - (Optional, String) The desired power state. Valid values are `"on"` or `"off"`. Defaults to `"on"`.
 - `firmware_file` - (Optional, String) Path to the firmware image file. If specified, firmware will be flashed to the node.
-- `boot_check` - (Optional, Boolean) Whether to monitor UART output for login prompt to verify successful boot. Defaults to `false`.
-- `login_prompt_timeout` - (Optional, Integer) Timeout in seconds to wait for login prompt when `boot_check` is enabled. Defaults to `60`.
+- `boot_check` - (Optional, Boolean) Whether to monitor UART output to verify successful boot. Defaults to `false`.
+- `boot_check_pattern` - (Optional, String) The pattern to search for in UART output to confirm successful boot. Defaults to `"login:"`. Use `"machine is running and ready"` for Talos Linux.
+- `login_prompt_timeout` - (Optional, Integer) Timeout in seconds to wait for boot pattern when `boot_check` is enabled. Defaults to `60`.
 
 ## Attribute Reference
 
@@ -106,12 +119,20 @@ In addition to all arguments above, the following attributes are exported:
 
 ## Boot Verification
 
-When `boot_check` is enabled, the provider monitors the node's UART output for a login prompt, indicating the operating system has successfully booted. This is useful for:
+When `boot_check` is enabled, the provider monitors the node's UART output for a specific pattern indicating the operating system has successfully booted. This is useful for:
 
 - Ensuring firmware flashing completed successfully
 - Waiting for nodes to be ready before dependent operations
 - Detecting boot failures
 
+### Supported Operating Systems
+
+| OS | Pattern |
+|----|---------|
+| Standard Linux | `login:` (default) |
+| Talos Linux | `machine is running and ready` |
+| Custom | Any string present in UART output |
+
 The `login_prompt_timeout` controls how long to wait for the boot to complete. Increase this value for slower compute modules or complex boot processes.
 
 ## Import

examples/basic/main.tf

@@ -2,7 +2,7 @@ terraform {
   required_providers {
     turingpi = {
       source  = "jfreed-dev/turingpi"
-      version = "1.0.4"
+      version = "1.0.5"
     }
   }
 }

examples/flash-firmware/main.tf

@@ -2,7 +2,7 @@ terraform {
   required_providers {
     turingpi = {
       source  = "jfreed-dev/turingpi"
-      version = "1.0.4"
+      version = "1.0.5"
     }
   }
 }

examples/full-provisioning/main.tf

@@ -2,7 +2,7 @@ terraform {
   required_providers {
     turingpi = {
       source  = "jfreed-dev/turingpi"
-      version = "1.0.4"
+      version = "1.0.5"
     }
   }
 }

provider/helpers.go

@@ -32,7 +32,7 @@ func flashNode(node int, firmware string) {
 	// Replace this with an API call to flash the firmware
 }
 
-func checkBootStatus(endpoint string, node int, timeout int, token string) (bool, error) {
+func checkBootStatus(endpoint string, node int, timeout int, token string, pattern string) (bool, error) {
 	url := fmt.Sprintf("%s/api/bmc?opt=get&type=uart&node=%d", endpoint, node)
 
 	deadline := time.Now().Add(time.Duration(timeout) * time.Second)
@@ -55,14 +55,14 @@ func checkBootStatus(endpoint string, node int, timeout int, token string) (bool
 			return false, fmt.Errorf("failed to read UART response: %v", err)
 		}
 
-		// Simulate login prompt detection
-		if strings.Contains(string(body), "login:") {
-			fmt.Printf("Node %d booted successfully: login prompt detected.\n", node)
+		// Check for configured boot pattern in UART output
+		if strings.Contains(string(body), pattern) {
+			fmt.Printf("Node %d booted successfully: pattern %q detected.\n", node, pattern)
 			return true, nil
 		}
 
 		time.Sleep(5 * time.Second)
 	}
 
-	return false, fmt.Errorf("timeout reached: node %d did not boot successfully", node)
+	return false, fmt.Errorf("timeout reached: node %d did not boot successfully (pattern %q not found)", node, pattern)
 }

provider/helpers_test.go

@@ -94,7 +94,7 @@ func TestCheckBootStatus_Success(t *testing.T) {
 	defer server.Close()
 
 	// Use short timeout since mock server returns immediately
-	success, err := checkBootStatus(server.URL, 1, 1, "test-token")
+	success, err := checkBootStatus(server.URL, 1, 1, "test-token", "login:")
 	if err != nil {
 		t.Fatalf("unexpected error: %s", err)
 	}
@@ -115,7 +115,7 @@ func TestCheckBootStatus_TokenInHeader(t *testing.T) {
 	}))
 	defer server.Close()
 
-	_, _ = checkBootStatus(server.URL, 1, 1, expectedToken)
+	_, _ = checkBootStatus(server.URL, 1, 1, expectedToken, "login:")
 
 	expectedHeader := "Bearer " + expectedToken
 	if capturedAuth != expectedHeader {
@@ -144,7 +144,7 @@ func TestCheckBootStatus_NodeInURL(t *testing.T) {
 			}))
 			defer server.Close()
 
-			_, _ = checkBootStatus(server.URL, tc.node, 1, "token")
+			_, _ = checkBootStatus(server.URL, tc.node, 1, "token", "login:")
 
 			if capturedNode != tc.expectedNode {
 				t.Errorf("expected node=%s in URL, got node=%s", tc.expectedNode, capturedNode)
@@ -163,7 +163,7 @@ func TestCheckBootStatus_Timeout(t *testing.T) {
 
 	// Use very short timeout to speed up test
 	// Note: This test will take at least 1 second due to the timeout
-	success, err := checkBootStatus(server.URL, 1, 1, "token")
+	success, err := checkBootStatus(server.URL, 1, 1, "token", "login:")
 
 	if success {
 		t.Error("expected success=false on timeout")
@@ -180,7 +180,7 @@ func TestCheckBootStatus_Timeout(t *testing.T) {
 
 func TestCheckBootStatus_ConnectionError(t *testing.T) {
 	// Use invalid URL to simulate connection error
-	success, err := checkBootStatus("http://localhost:99999", 1, 1, "token")
+	success, err := checkBootStatus("http://localhost:99999", 1, 1, "token", "login:")
 
 	if success {
 		t.Error("expected success=false on connection error")
@@ -203,7 +203,7 @@ func TestCheckBootStatus_URLConstruction(t *testing.T) {
 	}))
 	defer server.Close()
 
-	_, _ = checkBootStatus(server.URL, 2, 1, "token")
+	_, _ = checkBootStatus(server.URL, 2, 1, "token", "login:")
 
 	if capturedPath != "/api/bmc" {
 		t.Errorf("expected path /api/bmc, got %s", capturedPath)
@@ -244,11 +244,42 @@ func TestCheckBootStatus_LoginPromptVariations(t *testing.T) {
 			}))
 			defer server.Close()
 
-			success, _ := checkBootStatus(server.URL, 1, 1, "token")
+			success, _ := checkBootStatus(server.URL, 1, 1, "token", "login:")
 
 			if success != tc.expected {
 				t.Errorf("expected success=%v for response '%s', got %v", tc.expected, tc.response, success)
 			}
 		})
 	}
 }
+
+func TestCheckBootStatus_CustomPattern(t *testing.T) {
+	testCases := []struct {
+		name     string
+		response string
+		pattern  string
+		expected bool
+	}{
+		{"talos ready pattern", "[talos] machine is running and ready", "machine is running and ready", true},
+		{"talos boot sequence done", "[talos] boot sequence: done", "boot sequence: done", true},
+		{"custom pattern match", "System initialized successfully", "initialized successfully", true},
+		{"pattern not found", "still booting...", "machine is running and ready", false},
+		{"wrong pattern", "login:", "machine is running and ready", false},
+	}
+
+	for _, tc := range testCases {
+		t.Run(tc.name, func(t *testing.T) {
+			server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+				w.WriteHeader(http.StatusOK)
+				_, _ = w.Write([]byte(tc.response))
+			}))
+			defer server.Close()
+
+			success, _ := checkBootStatus(server.URL, 1, 1, "token", tc.pattern)
+
+			if success != tc.expected {
+				t.Errorf("expected success=%v for pattern '%s' in response '%s', got %v", tc.expected, tc.pattern, tc.response, success)
+			}
+		})
+	}
+}

provider/resource_node.go

@@ -39,7 +39,13 @@ func resourceNode() *schema.Resource {
 				Type:        schema.TypeInt,
 				Optional:    true,
 				Default:     60,
-				Description: "Timeout in seconds to wait for login prompt via UART",
+				Description: "Timeout in seconds to wait for boot check pattern via UART",
+			},
+			"boot_check_pattern": {
+				Type:        schema.TypeString,
+				Optional:    true,
+				Default:     "login:",
+				Description: "Pattern to search for in UART output to confirm successful boot (e.g., 'login:' for standard Linux, 'machine is running and ready' for Talos)",
 			},
 		},
 	}
@@ -52,6 +58,7 @@ func resourceNodeProvision(d *schema.ResourceData, meta interface{}) error {
 	powerState := d.Get("power_state").(string)
 	bootCheck := d.Get("boot_check").(bool)
 	timeout := d.Get("login_prompt_timeout").(int)
+	bootCheckPattern := d.Get("boot_check_pattern").(string)
 
 	// Step 1: Turn on the node
 	if powerState == "on" {
@@ -67,8 +74,8 @@ func resourceNodeProvision(d *schema.ResourceData, meta interface{}) error {
 
 	// Step 3: Boot check
 	if bootCheck {
-		fmt.Printf("Checking boot status for node %d...\n", node)
-		success, err := checkBootStatus(config.Endpoint, node, timeout, config.Token)
+		fmt.Printf("Checking boot status for node %d (pattern: %q)...\n", node, bootCheckPattern)
+		success, err := checkBootStatus(config.Endpoint, node, timeout, config.Token, bootCheckPattern)
 		if err != nil {
 			return fmt.Errorf("boot status check failed for node %d: %v", node, err)
 		}