chore: fix codes

Author: ww24

pbtask.go

@@ -3,6 +3,7 @@ package scheduler
 import (
 	"bytes"
 	"context"
+	"errors"
 	"fmt"
 	"io"
 	"net/http"
@@ -12,6 +13,8 @@ import (
 	"google.golang.org/protobuf/types/known/timestamppb"
 )
 
+var ErrInvalidTask = errors.New("invalid task")
+
 func PbTaskToTask(ctx context.Context, queuePath, taskIDPrefix string, pb *taskspb.Task) (*Task, error) {
 	id, version, err := ParseTaskName(taskIDPrefix, pb.Name)
 	if err != nil {
@@ -34,7 +37,7 @@ func PbTaskToTask(ctx context.Context, queuePath, taskIDPrefix string, pb *tasks
 		}
 		authorizationToken = at
 	default:
-		return nil, fmt.Errorf("unsupported message type: %s", pb.MessageType)
+		return nil, fmt.Errorf("unsupported message type (%s): %w", pb.MessageType, ErrInvalidTask)
 	}
 
 	return &Task{
@@ -66,7 +69,7 @@ func convertHTTPRequest(ctx context.Context, req *taskspb.HttpRequest) (*http.Re
 	case taskspb.HttpMethod_OPTIONS:
 		method = http.MethodOptions
 	default:
-		return nil, fmt.Errorf("unsupported http method: %s", req.HttpMethod.String())
+		return nil, fmt.Errorf("unsupported http method (%s): %w", req.HttpMethod.String(), ErrInvalidTask)
 	}
 
 	var body io.Reader
@@ -104,7 +107,7 @@ func convertAuthorizationToken(req *taskspb.HttpRequest) (isAuthorizationToken,
 		}, nil
 
 	default:
-		return nil, fmt.Errorf("unsupported authorization header type: %s", h)
+		return nil, fmt.Errorf("unsupported authorization header type (%+v): %w", h, ErrInvalidTask)
 	}
 }
 

scheduler.go

@@ -130,7 +130,7 @@ func (s *Scheduler) Create(ctx context.Context, task *Task, opts ...gax.CallOpti
 		case codes.AlreadyExists:
 			return ErrTaskAlreadyExists
 		default:
-			return err
+			return fmt.Errorf("failed to create task: %w", err)
 		}
 	}
 
@@ -142,7 +142,7 @@ func (s *Scheduler) Delete(ctx context.Context, taskName string, opts ...gax.Cal
 		Name: taskName,
 	}
 	if err := s.client.DeleteTask(ctx, req, opts...); err != nil {
-		return err
+		return fmt.Errorf("failed to delete task: %w", err)
 	}
 
 	return nil

task.go

@@ -16,6 +16,8 @@ const (
 	taskVersionSeparator   = "v"
 )
 
+var ErrInvalidTaskName = errors.New("invalid task name")
+
 type Task struct {
 	QueuePath     string
 	Prefix        string
@@ -125,25 +127,26 @@ func ParseTaskName(prefix, taskName string) (string, int, error) {
 	v := path.Base(taskName)
 
 	if !strings.HasPrefix(v, prefix) {
-		return "", 0, errors.New("task name has no valid prefix")
+		return "", 0, fmt.Errorf("task name has no valid prefix: %w", ErrInvalidTaskName)
 	}
 
 	v = strings.TrimPrefix(v, prefix)
 	tsIdx := strings.LastIndex(v, taskTimestampSeparator)
 	if tsIdx < 0 {
-		return "", 0, errors.New("invalid task name format")
+		return "", 0, fmt.Errorf("invalid task name format: %w", ErrInvalidTaskName)
 	}
 
 	id := v[:tsIdx]
 	v = v[tsIdx+1:]
 	vIdx := strings.LastIndex(v, taskVersionSeparator)
 	if vIdx < 0 {
-		return "", 0, errors.New("task name has no valid version")
+		return "", 0, fmt.Errorf("task name has no valid version: %w", ErrInvalidTaskName)
 	}
 
-	version, err := strconv.Atoi(v[vIdx+1:])
+	vs := v[vIdx+1:]
+	version, err := strconv.Atoi(vs)
 	if err != nil {
-		return "", 0, fmt.Errorf("failed to parse version: %w", err)
+		return "", 0, fmt.Errorf("failed to parse version (%s): %w", vs, ErrInvalidTaskName)
 	}
 
 	return id, version, nil