feat: introduce BootID resource

This resource simply states the Linux value of boot ID. It might be used
to detect reboots easily.

Signed-off-by: Andrey Smirnov <andrey.smirnov@siderolabs.com>

Author: smira

api/resource/definitions/runtime/runtime.proto

@@ -17,6 +17,11 @@ message APIServiceConfigSpec {
   bool skip_verifying_client_cert = 4;
 }
 
+// BootIDSpec presents the kernel boot ID (contents of /proc/sys/kernel/random/boot_id).
+message BootIDSpec {
+  string boot_id = 1;
+}
+
 // BootedEntrySpec describes the booted entry resource properties.
 message BootedEntrySpec {
   string booted_entry = 1;

internal/app/machined/pkg/controllers/runtime/boot_id.go

@@ -0,0 +1,78 @@
+// This Source Code Form is subject to the terms of the Mozilla Public
+// License, v. 2.0. If a copy of the MPL was not distributed with this
+// file, You can obtain one at http://mozilla.org/MPL/2.0/.
+
+//nolint:dupl
+package runtime
+
+import (
+	"context"
+	"fmt"
+	"os"
+	"strings"
+
+	"github.com/cosi-project/runtime/pkg/controller"
+	"github.com/cosi-project/runtime/pkg/safe"
+	"go.uber.org/zap"
+
+	machineruntime "github.com/siderolabs/talos/internal/app/machined/pkg/runtime"
+	"github.com/siderolabs/talos/pkg/machinery/resources/runtime"
+)
+
+// BootIDController presents /proc/sys/kernel/random/boot_id as a resource.
+type BootIDController struct {
+	V1Alpha1Mode machineruntime.Mode
+}
+
+// Name implements controller.Controller interface.
+func (ctrl *BootIDController) Name() string {
+	return "runtime.BootIDController"
+}
+
+// Inputs implements controller.Controller interface.
+func (ctrl *BootIDController) Inputs() []controller.Input {
+	return nil
+}
+
+// Outputs implements controller.Controller interface.
+func (ctrl *BootIDController) Outputs() []controller.Output {
+	return []controller.Output{
+		{
+			Type: runtime.BootIDType,
+			Kind: controller.OutputExclusive,
+		},
+	}
+}
+
+// Run implements controller.Controller interface.
+func (ctrl *BootIDController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error {
+	if ctrl.V1Alpha1Mode.InContainer() {
+		// no boot_id in containers
+		return nil
+	}
+
+	select {
+	case <-ctx.Done():
+		return nil
+	case <-r.EventCh():
+	}
+
+	contents, err := os.ReadFile("/proc/sys/kernel/random/boot_id")
+	if err != nil {
+		return fmt.Errorf("error reading boot_id: %w", err)
+	}
+
+	if err := safe.WriterModify(
+		ctx, r,
+		runtime.NewBootID(),
+		func(res *runtime.BootID) error {
+			res.TypedSpec().BootID = strings.TrimSpace(string(contents))
+
+			return nil
+		},
+	); err != nil {
+		return fmt.Errorf("error updating BootID resource: %w", err)
+	}
+
+	return nil
+}

internal/app/machined/pkg/controllers/runtime/boot_id_test.go

@@ -0,0 +1,41 @@
+// This Source Code Form is subject to the terms of the Mozilla Public
+// License, v. 2.0. If a copy of the MPL was not distributed with this
+// file, You can obtain one at http://mozilla.org/MPL/2.0/.
+
+//nolint:dupl
+package runtime_test
+
+import (
+	"testing"
+	"time"
+
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/suite"
+
+	"github.com/siderolabs/talos/internal/app/machined/pkg/controllers/ctest"
+	runtimectrl "github.com/siderolabs/talos/internal/app/machined/pkg/controllers/runtime"
+	"github.com/siderolabs/talos/pkg/machinery/resources/runtime"
+)
+
+func TestBootIDSuite(t *testing.T) {
+	t.Parallel()
+
+	suite.Run(t, &BootIDSuite{
+		DefaultSuite: ctest.DefaultSuite{
+			Timeout: 5 * time.Second,
+			AfterSetup: func(suite *ctest.DefaultSuite) {
+				suite.Require().NoError(suite.Runtime().RegisterController(&runtimectrl.BootIDController{}))
+			},
+		},
+	})
+}
+
+type BootIDSuite struct {
+	ctest.DefaultSuite
+}
+
+func (suite *BootIDSuite) TestBootID() {
+	ctest.AssertResource(suite, runtime.BootIDID, func(res *runtime.BootID, asrt *assert.Assertions) {
+		asrt.NotEmpty(res.TypedSpec().BootID)
+	})
+}

internal/app/machined/pkg/controllers/runtime/kernel_cmdline.go

@@ -2,6 +2,7 @@
 // License, v. 2.0. If a copy of the MPL was not distributed with this
 // file, You can obtain one at http://mozilla.org/MPL/2.0/.
 
+//nolint:dupl
 package runtime
 
 import (

internal/app/machined/pkg/controllers/runtime/kernel_cmdline_test.go

@@ -2,6 +2,7 @@
 // License, v. 2.0. If a copy of the MPL was not distributed with this
 // file, You can obtain one at http://mozilla.org/MPL/2.0/.
 
+//nolint:dupl
 package runtime_test
 
 import (

internal/app/machined/pkg/runtime/v1alpha2/v1alpha2_controller.go

@@ -450,6 +450,9 @@ func (ctrl *Controller) Run(ctx context.Context, drainer *runtime.Drainer) error
 		},
 		&runtimecontrollers.ExtensionStatusController{},
 		&runtimecontrollers.ImageFactorySchematicController{},
+		&runtimecontrollers.BootIDController{
+			V1Alpha1Mode: ctrl.v1alpha1Runtime.State().Platform().Mode(),
+		},
 		&runtimecontrollers.KernelCmdlineController{
 			V1Alpha1Mode: ctrl.v1alpha1Runtime.State().Platform().Mode(),
 		},

internal/app/machined/pkg/runtime/v1alpha2/v1alpha2_state.go

@@ -216,6 +216,7 @@ func NewState() (*State, error) {
 		&cri.RegistriesConfig{},
 		&runtime.APIServiceConfig{},
 		&runtime.BootedEntry{},
+		&runtime.BootID{},
 		&runtime.DevicesStatus{},
 		&runtime.Diagnostic{},
 		&runtime.Environment{},

internal/integration/base/api.go

@@ -230,26 +230,12 @@ func (apiSuite *APISuite) ReadBootID(ctx context.Context) (string, error) {
 	reqCtx, reqCtxCancel := context.WithTimeout(ctx, 10*time.Second)
 	defer reqCtxCancel()
 
-	reader, err := apiSuite.Client.Read(reqCtx, "/proc/sys/kernel/random/boot_id")
+	bootID, err := safe.StateGetByID[*runtimeres.BootID](reqCtx, apiSuite.Client.COSI, runtimeres.BootIDID)
 	if err != nil {
 		return "", err
 	}
 
-	defer reader.Close() //nolint:errcheck
-
-	body, err := io.ReadAll(reader)
-	if err != nil {
-		return "", err
-	}
-
-	bootID := strings.TrimSpace(string(body))
-
-	_, err = io.Copy(io.Discard, reader)
-	if err != nil {
-		return "", err
-	}
-
-	return bootID, reader.Close()
+	return bootID.TypedSpec().BootID, nil
 }
 
 // ReadBootIDWithRetry reads node boot_id.