Add VLAN ID to hardware interface spec

buf.lock

@@ -4,7 +4,4 @@ deps:
   - remote: buf.build
     owner: googleapis
     repository: googleapis
-    branch: main
-    commit: 389e82394fcc4e18b2463c26674170b3
-    digest: b1-j-IWUPcGJWMkqbee6hR7IJCXlLF9Y5P4ARue8gLwLP0=
-    create_time: 2021-10-01T15:05:49.20888Z
+    commit: 8d7204855ec14631a499bd7393ce1970

client/main.go

@@ -9,6 +9,7 @@ import (
 	"go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/credentials"
+	"google.golang.org/grpc/credentials/insecure"
 )
 
 // gRPC clients.
@@ -40,7 +41,7 @@ func NewClientConn(authority string, tls bool) (*grpc.ClientConn, error) {
 	if tls {
 		creds = grpc.WithTransportCredentials(credentials.NewTLS(nil))
 	} else {
-		creds = grpc.WithInsecure()
+		creds = grpc.WithTransportCredentials(insecure.NewCredentials())
 	}
 
 	conn, err := grpc.Dial(authority,

cmd/tink-cli/cmd/delete/delete.go

@@ -1,4 +1,4 @@
-package delete // nolint:predeclared // package name delete has same name as predeclared identifier
+package delete //nolint:predeclared // package name delete has same name as predeclared identifier
 
 import (
 	"context"

cmd/tink-cli/cmd/delete/delete_test.go

@@ -1,9 +1,9 @@
-package delete // nolint:predeclared // package name delete has same name as predeclared identifier
+package delete //nolint:predeclared // package name delete has same name as predeclared identifier
 
 import (
 	"bytes"
 	"context"
-	"io/ioutil"
+	"io"
 	"testing"
 
 	"github.com/google/go-cmp/cmp"
@@ -86,7 +86,7 @@ func TestNewDeleteCommand(t *testing.T) {
 			if err != nil {
 				t.Error(err)
 			}
-			out, err := ioutil.ReadAll(stdout)
+			out, err := io.ReadAll(stdout)
 			if err != nil {
 				t.Error(err)
 			}

cmd/tink-cli/cmd/delete/doc.go

@@ -1,4 +1,4 @@
 // Package delete provides a reusable implementation of the Delete command
 // for the tink cli. The Delete command deletes resources. It is designed
 // to be extendible and usable across resources.
-package delete // nolint:predeclared // package name delete has same name as predeclared identifier
+package delete //nolint:predeclared // package name delete has same name as predeclared identifier

cmd/tink-cli/cmd/docs_test.go

@@ -3,7 +3,6 @@ package cmd
 
 import (
 	"bytes"
-	"io/ioutil"
 	"os"
 	"path"
 	"strings"
@@ -63,7 +62,7 @@ func Test_docsCmd(t *testing.T) {
 			cmdFunc: func(t *testing.T, c *cobra.Command) {
 				t.Helper()
 
-				dir, err := ioutil.TempDir("", "tink-test-*")
+				dir, err := os.MkdirTemp("", "tink-test-*")
 				if err != nil {
 					t.Fatal(err)
 				}
@@ -95,7 +94,7 @@ func Test_docsCmd(t *testing.T) {
 			cmdFunc: func(t *testing.T, c *cobra.Command) {
 				t.Helper()
 
-				dir, err := ioutil.TempDir("", "tink-test-*")
+				dir, err := os.MkdirTemp("", "tink-test-*")
 				if err != nil {
 					t.Fatal(err)
 				}

cmd/tink-cli/cmd/get/get_test.go

@@ -5,7 +5,6 @@ import (
 	"context"
 	"fmt"
 	"io"
-	"io/ioutil"
 	"testing"
 
 	"github.com/google/go-cmp/cmp"
@@ -234,7 +233,7 @@ func TestNewGetCommand(t *testing.T) {
 			if fmt.Sprint(err) != fmt.Sprint(s.ExpectError) {
 				t.Errorf("unexpected error: want=%v, got=%v", s.ExpectError, err)
 			}
-			out, err := ioutil.ReadAll(stdout)
+			out, err := io.ReadAll(stdout)
 			if err != nil {
 				t.Error(err)
 			}

cmd/tink-cli/cmd/hardware/get_test.go

@@ -4,7 +4,6 @@ import (
 	"bytes"
 	"context"
 	"io"
-	"io/ioutil"
 	"testing"
 
 	"github.com/google/go-cmp/cmp"
@@ -101,7 +100,7 @@ func TestGetHardware(t *testing.T) {
 			if err != nil {
 				t.Error(err)
 			}
-			out, err := ioutil.ReadAll(stdout)
+			out, err := io.ReadAll(stdout)
 			if err != nil {
 				t.Error(err)
 			}

cmd/tink-cli/cmd/hardware/push.go

@@ -6,7 +6,7 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	"io/ioutil"
+	"io"
 	"log"
 	"os"
 	"path/filepath"
@@ -82,7 +82,7 @@ func isInputFromPipe() bool {
 }
 
 func readDataFromStdin() string {
-	data, err := ioutil.ReadAll(os.Stdin)
+	data, err := io.ReadAll(os.Stdin)
 	if err != nil {
 		return ""
 	}
@@ -96,7 +96,7 @@ func readDataFromFile() (string, error) {
 	}
 	defer f.Close()
 
-	data, err := ioutil.ReadAll(f)
+	data, err := io.ReadAll(f)
 	if err != nil {
 		return "", err
 	}

cmd/tink-cli/cmd/template/create.go

@@ -5,7 +5,6 @@ import (
 	"context"
 	"fmt"
 	"io"
-	"io/ioutil"
 	"log"
 	"os"
 	"path/filepath"
@@ -64,7 +63,7 @@ $ tink template create --file /tmp/example.tmpl
 }
 
 func readAll(reader io.Reader) []byte {
-	data, err := ioutil.ReadAll(reader)
+	data, err := io.ReadAll(reader)
 	if err != nil {
 		log.Fatal(err)
 	}

cmd/tink-cli/cmd/template/get_test.go

@@ -4,7 +4,6 @@ import (
 	"bytes"
 	"context"
 	"io"
-	"io/ioutil"
 	"testing"
 	"time"
 
@@ -76,7 +75,7 @@ func TestGetTemplate(t *testing.T) {
 			if err != nil {
 				t.Error(err)
 			}
-			out, err := ioutil.ReadAll(stdout)
+			out, err := io.ReadAll(stdout)
 			if err != nil {
 				t.Error(err)
 			}

cmd/tink-cli/cmd/template/update.go

@@ -4,7 +4,6 @@ import (
 	"context"
 	"fmt"
 	"io"
-	"io/ioutil"
 	"log"
 	"os"
 	"path/filepath"
@@ -94,7 +93,7 @@ func readTemplateData() (string, error) {
 		reader = f
 	}
 
-	data, err := ioutil.ReadAll(reader)
+	data, err := io.ReadAll(reader)
 	if err != nil {
 		return "", err
 	}

cmd/tink-worker/worker/container_manager.go

@@ -38,7 +38,9 @@ func (m *containerManager) getLogger(ctx context.Context) *log.Logger {
 	if loggerIface == nil {
 		return &m.logger
 	}
-	return loggerIface.(*log.Logger)
+	l, _ := loggerIface.(*log.Logger)
+
+	return l
 }
 
 // NewContainerManager returns a new container manager.
@@ -89,7 +91,7 @@ func (m *containerManager) StartContainer(ctx context.Context, id string) error
 func (m *containerManager) WaitForContainer(ctx context.Context, id string) (pb.State, error) {
 	// Inspect whether the container is in running state
 	if _, err := m.cli.ContainerInspect(ctx, id); err != nil {
-		return pb.State_STATE_FAILED, nil // nolint:nilerr // error is not nil, but it returns nil
+		return pb.State_STATE_FAILED, nil //nolint:nilerr // error is not nil, but it returns nil
 	}
 
 	// send API call to wait for the container completion

cmd/tink-worker/worker/container_manager_test.go

@@ -39,7 +39,8 @@ func newFakeDockerClient(containerID, imagePullContent string, delay time.Durati
 }
 
 func (c *fakeDockerClient) ContainerCreate(
-	context.Context, *containertypes.Config, *containertypes.HostConfig, *networktypes.NetworkingConfig, *specs.Platform, string) (containertypes.ContainerCreateCreatedBody, error) {
+	context.Context, *containertypes.Config, *containertypes.HostConfig, *networktypes.NetworkingConfig, *specs.Platform, string,
+) (containertypes.ContainerCreateCreatedBody, error) {
 	if c.err != nil {
 		return containertypes.ContainerCreateCreatedBody{}, c.err
 	}

cmd/tink-worker/worker/log_capturer.go

@@ -24,7 +24,9 @@ func (l *DockerLogCapturer) getLogger(ctx context.Context) *log.Logger {
 	if loggerIface == nil {
 		return &l.logger
 	}
-	return loggerIface.(*log.Logger)
+	lg, _ := loggerIface.(*log.Logger)
+
+	return lg
 }
 
 // NewDockerLogCapturer returns a LogCapturer that can stream container logs to a given writer.

cmd/tink-worker/worker/worker.go

@@ -6,7 +6,7 @@ import (
 	"encoding/base64"
 	"encoding/json"
 	"fmt"
-	"io/ioutil"
+	"io"
 	"os"
 	"path/filepath"
 	"strconv"
@@ -127,7 +127,8 @@ func NewWorker(
 	containerManager ContainerManager,
 	logCapturer LogCapturer,
 	logger log.Logger,
-	opts ...Option) *Worker {
+	opts ...Option,
+) *Worker {
 	w := &Worker{
 		workerID:         workerID,
 		dataDir:          defaultDataDir,
@@ -154,7 +155,9 @@ func (w Worker) getLogger(ctx context.Context) *log.Logger {
 	if loggerIface == nil {
 		return &w.logger
 	}
-	return loggerIface.(*log.Logger)
+	l, _ := loggerIface.(*log.Logger)
+
+	return l
 }
 
 // execute executes a workflow action, optionally capturing logs.
@@ -400,7 +403,7 @@ func (w *Worker) ProcessWorkflowActions(ctx context.Context) error {
 				if len(actions.GetActionList()) == actionIndex+1 {
 					l.Info("reached to end of workflow")
 					delete(workflowcontexts, wfID)
-					turn = false // nolint:wastedassign // assigned to turn, but reassigned without using the value
+					turn = false //nolint:wastedassign // assigned to turn, but reassigned without using the value
 					break
 				}
 
@@ -494,7 +497,7 @@ func (w *Worker) updateWorkflowData(ctx context.Context, actionStatus *pb.Workfl
 		}
 	}()
 
-	data, err := ioutil.ReadAll(f)
+	data, err := io.ReadAll(f)
 	if err != nil {
 		l.Error(err)
 	}

config/crd/bases/tinkerbell.org_hardware.yaml

@@ -120,6 +120,8 @@ spec:
                             type: array
                           uefi:
                             type: boolean
+                          vlan_id:
+                            type: integer
                         type: object
                       netboot:
                         description: Netboot configuration.

db/db_test.go

@@ -76,7 +76,7 @@ func NewPostgresDatabaseClient(ctx context.Context, t *testing.T, req NewPostgre
 		if err != nil {
 			t.Error(err)
 		}
-		t.Log(fmt.Sprintf("applied %d migrations", n))
+		t.Logf("applied %d migrations", n)
 	}
 	return dbCon, tinkDB, func() error {
 		return postgresC.Terminate(ctx)

db/hardware_test.go

@@ -5,7 +5,7 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	"io/ioutil"
+	"os"
 	"strings"
 	"sync"
 	"testing"
@@ -364,10 +364,8 @@ func TestGetByIP(t *testing.T) {
 				for ii := 0; ii < 10; ii++ {
 					hw := readHardwareData("./testdata/hardware.json")
 					hw.Id = uuid.New().String()
-					hw.Network.Interfaces[0].Dhcp.Ip.Address =
-						strings.Replace(hw.Network.Interfaces[0].Dhcp.Ip.Address, "1", fmt.Sprintf("%d", ii), 1)
-					hw.Network.Interfaces[0].Dhcp.Mac =
-						strings.Replace(hw.Network.Interfaces[0].Dhcp.Mac, "00", fmt.Sprintf("0%d", ii), 1)
+					hw.Network.Interfaces[0].Dhcp.Ip.Address = strings.Replace(hw.Network.Interfaces[0].Dhcp.Ip.Address, "1", fmt.Sprintf("%d", ii), 1)
+					hw.Network.Interfaces[0].Dhcp.Mac = strings.Replace(hw.Network.Interfaces[0].Dhcp.Mac, "00", fmt.Sprintf("0%d", ii), 1)
 				}
 				return input
 			}(),
@@ -477,8 +475,7 @@ func TestGetByMAC(t *testing.T) {
 				for ii := 0; ii < 10; ii++ {
 					hw := readHardwareData("./testdata/hardware.json")
 					hw.Id = uuid.New().String()
-					hw.Network.Interfaces[0].Dhcp.Mac =
-						strings.Replace(hw.Network.Interfaces[0].Dhcp.Mac, "00", fmt.Sprintf("0%d", ii), 1)
+					hw.Network.Interfaces[0].Dhcp.Mac = strings.Replace(hw.Network.Interfaces[0].Dhcp.Mac, "00", fmt.Sprintf("0%d", ii), 1)
 				}
 				return input
 			}(),
@@ -549,7 +546,7 @@ func TestGetByMAC_WithNonExistingMAC(t *testing.T) {
 }
 
 func readHardwareData(file string) *hardware.Hardware {
-	data, err := ioutil.ReadFile(file)
+	data, err := os.ReadFile(file)
 	if err != nil {
 		panic(err)
 	}

db/workflow.go

@@ -257,7 +257,7 @@ func (d TinkDB) GetfromWfDataTable(ctx context.Context, req *pb.GetWorkflowDataR
 		return buf, nil
 	}
 
-	if err != sql.ErrNoRows {
+	if err != sql.ErrNoRows { //nolint:errorlint // there's no wrapping going on here
 		err = errors.Wrap(err, "SELECT")
 		d.logger.Error(err)
 	}
@@ -288,7 +288,7 @@ func (d TinkDB) GetWorkflowMetadata(ctx context.Context, req *pb.GetWorkflowData
 		return buf, nil
 	}
 
-	if err != sql.ErrNoRows {
+	if err != sql.ErrNoRows { //nolint:errorlint // there's no wrapping going on here
 		err = errors.Wrap(err, "SELECT from workflow_data")
 		d.logger.Error(err)
 	}
@@ -359,7 +359,7 @@ func (d TinkDB) GetWorkflow(ctx context.Context, id string) (Workflow, error) {
 			UpdatedAt: updatedAt,
 		}, nil
 	}
-	if err != sql.ErrNoRows {
+	if err != sql.ErrNoRows { //nolint:errorlint // there's no wrapping going on here
 		err = errors.Wrap(err, "SELECT")
 		d.logger.Error(err)
 		return Workflow{}, err
@@ -538,7 +538,7 @@ func (d TinkDB) GetWorkflowContexts(ctx context.Context, wfID string) (*pb.Workf
 			TotalNumberOfActions: tact,
 		}, nil
 	}
-	if err != sql.ErrNoRows {
+	if err != sql.ErrNoRows { //nolint:errorlint // there's no wrapping going on here
 		err = errors.Wrap(err, "SELECT from worflow_state")
 		d.logger.Error(err)
 		return &pb.WorkflowContext{}, err
@@ -566,7 +566,7 @@ func (d TinkDB) GetWorkflowActions(ctx context.Context, wfID string) (*pb.Workfl
 			ActionList: actions,
 		}, nil
 	}
-	if err != sql.ErrNoRows {
+	if err != sql.ErrNoRows { //nolint:errorlint // there's no wrapping going on here
 		err = errors.Wrap(err, "SELECT from worflow_state")
 		d.logger.Error(err)
 	}