package feeds

import (
	"context"

	"github.com/google/uuid"

	pb "github.com/smartcontractkit/chainlink/v2/core/services/feeds/proto"
)

// RPCHandlers define handlers for RPC method calls from the Feeds Manager
type RPCHandlers struct {
	svc            Service
	feedsManagerID int64
}

func NewRPCHandlers(svc Service, feedsManagerID int64) *RPCHandlers {
	return &RPCHandlers{
		svc:            svc,
		feedsManagerID: feedsManagerID,
	}
}

// ProposeJob creates a new job proposal record for the feeds manager
func (h *RPCHandlers) ProposeJob(ctx context.Context, req *pb.ProposeJobRequest) (*pb.ProposeJobResponse, error) {
	remoteUUID, err := uuid.Parse(req.Id)
	if err != nil {
		return nil, err
	}

	_, err = h.svc.ProposeJob(ctx, &ProposeJobArgs{
		Spec:           req.GetSpec(),
		FeedsManagerID: h.feedsManagerID,
		RemoteUUID:     remoteUUID,
		Version:        int32(req.GetVersion()),
		Multiaddrs:     req.GetMultiaddrs(),
	})
	if err != nil {
		return nil, err
	}

	return &pb.ProposeJobResponse{}, nil
}

// DeleteJob deletes a job proposal record.
func (h *RPCHandlers) DeleteJob(ctx context.Context, req *pb.DeleteJobRequest) (*pb.DeleteJobResponse, error) {
	remoteUUID, err := uuid.Parse(req.Id)
	if err != nil {
		return nil, err
	}

	_, err = h.svc.DeleteJob(ctx, &DeleteJobArgs{
		FeedsManagerID: h.feedsManagerID,
		RemoteUUID:     remoteUUID,
	})
	if err != nil {
		return nil, err
	}

	return &pb.DeleteJobResponse{}, nil
}

// RevokeJob revokes a pending job proposal record.
func (h *RPCHandlers) RevokeJob(ctx context.Context, req *pb.RevokeJobRequest) (*pb.RevokeJobResponse, error) {
	remoteUUID, err := uuid.Parse(req.Id)
	if err != nil {
		return nil, err
	}

	_, err = h.svc.RevokeJob(ctx, &RevokeJobArgs{
		FeedsManagerID: h.feedsManagerID,
		RemoteUUID:     remoteUUID,
	})
	if err != nil {
		return nil, err
	}

	return &pb.RevokeJobResponse{}, nil
}