engine: task naming consistency

Signed-off-by: Andrea Luzzardi <aluzzardi@gmail.com>

plan/task/proxyendpoint.go

@@ -0,0 +1,58 @@
+package task
+
+import (
+	"context"
+	"errors"
+
+	"cuelang.org/go/cue"
+	"github.com/rs/zerolog/log"
+	"go.dagger.io/dagger/compiler"
+	"go.dagger.io/dagger/plancontext"
+	"go.dagger.io/dagger/solver"
+)
+
+func init() {
+	Register("ProxyEndpoint", func() Task { return &proxyEndpointTask{} })
+}
+
+type proxyEndpointTask struct {
+}
+
+func (c *proxyEndpointTask) Run(ctx context.Context, pctx *plancontext.Context, s solver.Solver, v *compiler.Value) (*compiler.Value, error) {
+	var unix, npipe string
+	var stringErr error
+
+	unixV := v.Lookup("unix")
+	npipeV := v.Lookup("npipe")
+
+	if unixV.Exists() && unixV.IsConcrete() {
+		unix, stringErr = unixV.String()
+	}
+
+	if npipeV.Exists() && npipeV.IsConcrete() {
+		npipe, stringErr = npipeV.String()
+	}
+
+	if stringErr != nil {
+		return nil, stringErr
+	}
+
+	if unix == "" && npipe == "" {
+		return nil, errors.New("invalid service")
+	}
+
+	lg := log.Ctx(ctx)
+
+	if unix != "" {
+		lg.Debug().Str("unix", unix).Msg("loading service")
+	} else if npipe != "" {
+		lg.Debug().Str("npipe", npipe).Msg("loading service")
+	}
+
+	service := pctx.Services.New(unix, npipe)
+	out := compiler.NewValue()
+	if err := out.FillPath(cue.ParsePath("service"), service.MarshalCUE()); err != nil {
+		return nil, err
+	}
+	return out, nil
+}