get_pid_config_by_id.go

package queries

import (
	"context"
	"database/sql"
	"errors"
	"fmt"

	"github.com/DIMO-Network/shared/db"
	"github.com/DIMO-Network/vehicle-signal-decoding/internal/infrastructure/db/models"
	"github.com/DIMO-Network/vehicle-signal-decoding/pkg/grpc"
	"github.com/rs/zerolog"
	"google.golang.org/protobuf/types/known/timestamppb"
)

type GetPidByIDQueryHandler struct {
	DBS    func() *db.ReaderWriter
	logger *zerolog.Logger
}

func NewGetPidByIDQueryHandler(dbs func() *db.ReaderWriter, logger *zerolog.Logger) GetPidByIDQueryHandler {
	return GetPidByIDQueryHandler{
		DBS:    dbs,
		logger: logger,
	}
}

type GetPidByIDQueryRequest struct {
	ID int64
}

func (h GetPidByIDQueryHandler) Handle(ctx context.Context, query *GetPidByIDQueryRequest) (*grpc.GetPidByIDResponse, error) {

	item, err := models.PidConfigs(models.PidConfigWhere.ID.EQ(query.ID)).One(ctx, h.DBS().Reader)
	if err != nil {
		if errors.Is(err, sql.ErrNoRows) {
			return nil, fmt.Errorf("template not found id: %d", query.ID)
		}

		return nil, fmt.Errorf("failed to get template")
	}

	result := &grpc.GetPidByIDResponse{
		Pid: &grpc.PidConfig{
			Id:              item.ID,
			TemplateName:    item.TemplateName,
			Header:          item.Header,
			Mode:            item.Mode,
			Pid:             item.Pid,
			Formula:         item.Formula,
			IntervalSeconds: int32(item.IntervalSeconds),
			Protocol:        item.Protocol.Ptr(),
			SignalName:      item.SignalName,
			CreatedAt:       timestamppb.New(item.CreatedAt),
			UpdatedAt:       timestamppb.New(item.UpdatedAt),
		},
	}

	return result, nil
}