[WAIT,SDK] Implemented Wait stage with SDK

pkg/app/pipedv1/controller/scheduler.go

@@ -534,7 +534,7 @@ func (s *scheduler) executeStage(sig StopSignal, ps *model.PipelineStage) (final
 	}
 
 	// Load the stage configuration.
-	stageConfig, stageConfigFound := s.genericApplicationConfig.GetStageByte(ps.Index)
+	stageConfig, stageConfigFound := s.genericApplicationConfig.GetStageConfigByte(ps.Index)
 	if !stageConfigFound {
 		s.logger.Error("Unable to find the stage configuration", zap.String("stage-name", ps.Name))
 		if err := s.reportStageStatus(ctx, ps.Id, model.StageStatus_STAGE_FAILURE, ps.Requires); err != nil {

pkg/app/pipedv1/plugin/example/plugin.go

@@ -17,7 +17,6 @@
 import (
 	"context"
 
-	"github.com/pipe-cd/pipecd/pkg/plugin/logpersister"
 	"github.com/pipe-cd/pipecd/pkg/plugin/sdk"
 )
 
@@ -36,13 +35,13 @@
 }
 
 // BuildPipelineSyncStages implements sdk.PipelineSyncPlugin.
-func (p *plugin) BuildPipelineSyncStages(context.Context, *config, *sdk.Client, *sdk.BuildPipelineSyncStagesRequest) (*sdk.BuildPipelineSyncStagesResponse, error) {
+func (p *plugin) BuildPipelineSyncStages(context.Context, *config, *sdk.BuildPipelineSyncStagesInput) (*sdk.BuildPipelineSyncStagesResponse, error) {
 	return &sdk.BuildPipelineSyncStagesResponse{}, nil
 }
 
 // ExecuteStage implements sdk.PipelineSyncPlugin.
-func (p *plugin) ExecuteStage(context.Context, *config, sdk.DeployTargetsNone, *sdk.Client, logpersister.StageLogPersister, sdk.TODO) (sdk.TODO, error) {
-	return sdk.TODO{}, nil
+func (p *plugin) ExecuteStage(context.Context, *config, sdk.DeployTargetsNone, *sdk.ExecuteStageInput) (*sdk.ExecuteStageResponse, error) {
+	return &sdk.ExecuteStageResponse{}, nil
 }
 
 // FetchDefinedStages implements sdk.PipelineSyncPlugin.

pkg/app/pipedv1/plugin/wait/main.go

@@ -1,4 +1,4 @@
-// Copyright 2024 The PipeCD Authors.
+// Copyright 2025 The PipeCD Authors.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -17,18 +17,13 @@
 import (
 	"log"
 
-	"github.com/pipe-cd/pipecd/pkg/cli"
+	"github.com/pipe-cd/pipecd/pkg/plugin/sdk"
 )
 
 func main() {
-	app := cli.NewApp(
-		"pipecd-plugin-stage-wait",
-		"Plugin component to execute Wait Stage.",
-	)
-	app.AddCommands(
-		newPluginCommand(),
-	)
-	if err := app.Run(); err != nil {
-		log.Fatal(err)
+	sdk.RegisterPipelineSyncPlugin(&plugin{})
+
+	if err := sdk.Run(); err != nil {
+		log.Fatalln(err)
 	}
 }

pkg/app/pipedv1/plugin/wait/config/options.go → pkg/app/pipedv1/plugin/wait/options.go

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package config
+package main
 
 import (
 	"encoding/json"
@@ -24,8 +24,6 @@ import (
 // WaitStageOptions contains configurable values for a WAIT stage.
 type WaitStageOptions struct {
 	Duration config.Duration `json:"duration,omitempty"`
-	// TODO: Handle SkipOn options.
-	// SkipOn   config.SkipOptions `json:"skipOn,omitempty"`
 }
 
 func (o WaitStageOptions) validate() error {
@@ -35,8 +33,8 @@ func (o WaitStageOptions) validate() error {
 	return nil
 }
 
-// Decode decodes the raw JSON data and validates it.
-func Decode(data json.RawMessage) (WaitStageOptions, error) {
+// decode decodes the raw JSON data and validates it.
+func decode(data json.RawMessage) (WaitStageOptions, error) {
 	var opts WaitStageOptions
 	if err := json.Unmarshal(data, &opts); err != nil {
 		return WaitStageOptions{}, fmt.Errorf("failed to unmarshal the config: %w", err)

pkg/app/pipedv1/plugin/wait/config/options_test.go → pkg/app/pipedv1/plugin/wait/options_test.go

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package config
+package main
 
 import (
 	"encoding/json"
@@ -73,7 +73,7 @@ func TestDecode(t *testing.T) {
 	for _, tc := range testcases {
 		t.Run(tc.name, func(t *testing.T) {
 			t.Parallel()
-			got, err := Decode(tc.data)
+			got, err := decode(tc.data)
 			assert.Equal(t, tc.wantErr, err != nil)
 			assert.Equal(t, tc.expected, got)
 		})