1// Code generated by smithy-go-codegen DO NOT EDIT.
2
3package iotjobsdataplane
4
5import (
6	"context"
7	"fmt"
8	smithy "github.com/aws/smithy-go"
9	"github.com/aws/smithy-go/middleware"
10)
11
12type validateOpDescribeJobExecution struct {
13}
14
15func (*validateOpDescribeJobExecution) ID() string {
16	return "OperationInputValidation"
17}
18
19func (m *validateOpDescribeJobExecution) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
20	out middleware.InitializeOutput, metadata middleware.Metadata, err error,
21) {
22	input, ok := in.Parameters.(*DescribeJobExecutionInput)
23	if !ok {
24		return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
25	}
26	if err := validateOpDescribeJobExecutionInput(input); err != nil {
27		return out, metadata, err
28	}
29	return next.HandleInitialize(ctx, in)
30}
31
32type validateOpGetPendingJobExecutions struct {
33}
34
35func (*validateOpGetPendingJobExecutions) ID() string {
36	return "OperationInputValidation"
37}
38
39func (m *validateOpGetPendingJobExecutions) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
40	out middleware.InitializeOutput, metadata middleware.Metadata, err error,
41) {
42	input, ok := in.Parameters.(*GetPendingJobExecutionsInput)
43	if !ok {
44		return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
45	}
46	if err := validateOpGetPendingJobExecutionsInput(input); err != nil {
47		return out, metadata, err
48	}
49	return next.HandleInitialize(ctx, in)
50}
51
52type validateOpStartNextPendingJobExecution struct {
53}
54
55func (*validateOpStartNextPendingJobExecution) ID() string {
56	return "OperationInputValidation"
57}
58
59func (m *validateOpStartNextPendingJobExecution) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
60	out middleware.InitializeOutput, metadata middleware.Metadata, err error,
61) {
62	input, ok := in.Parameters.(*StartNextPendingJobExecutionInput)
63	if !ok {
64		return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
65	}
66	if err := validateOpStartNextPendingJobExecutionInput(input); err != nil {
67		return out, metadata, err
68	}
69	return next.HandleInitialize(ctx, in)
70}
71
72type validateOpUpdateJobExecution struct {
73}
74
75func (*validateOpUpdateJobExecution) ID() string {
76	return "OperationInputValidation"
77}
78
79func (m *validateOpUpdateJobExecution) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
80	out middleware.InitializeOutput, metadata middleware.Metadata, err error,
81) {
82	input, ok := in.Parameters.(*UpdateJobExecutionInput)
83	if !ok {
84		return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
85	}
86	if err := validateOpUpdateJobExecutionInput(input); err != nil {
87		return out, metadata, err
88	}
89	return next.HandleInitialize(ctx, in)
90}
91
92func addOpDescribeJobExecutionValidationMiddleware(stack *middleware.Stack) error {
93	return stack.Initialize.Add(&validateOpDescribeJobExecution{}, middleware.After)
94}
95
96func addOpGetPendingJobExecutionsValidationMiddleware(stack *middleware.Stack) error {
97	return stack.Initialize.Add(&validateOpGetPendingJobExecutions{}, middleware.After)
98}
99
100func addOpStartNextPendingJobExecutionValidationMiddleware(stack *middleware.Stack) error {
101	return stack.Initialize.Add(&validateOpStartNextPendingJobExecution{}, middleware.After)
102}
103
104func addOpUpdateJobExecutionValidationMiddleware(stack *middleware.Stack) error {
105	return stack.Initialize.Add(&validateOpUpdateJobExecution{}, middleware.After)
106}
107
108func validateOpDescribeJobExecutionInput(v *DescribeJobExecutionInput) error {
109	if v == nil {
110		return nil
111	}
112	invalidParams := smithy.InvalidParamsError{Context: "DescribeJobExecutionInput"}
113	if v.JobId == nil {
114		invalidParams.Add(smithy.NewErrParamRequired("JobId"))
115	}
116	if v.ThingName == nil {
117		invalidParams.Add(smithy.NewErrParamRequired("ThingName"))
118	}
119	if invalidParams.Len() > 0 {
120		return invalidParams
121	} else {
122		return nil
123	}
124}
125
126func validateOpGetPendingJobExecutionsInput(v *GetPendingJobExecutionsInput) error {
127	if v == nil {
128		return nil
129	}
130	invalidParams := smithy.InvalidParamsError{Context: "GetPendingJobExecutionsInput"}
131	if v.ThingName == nil {
132		invalidParams.Add(smithy.NewErrParamRequired("ThingName"))
133	}
134	if invalidParams.Len() > 0 {
135		return invalidParams
136	} else {
137		return nil
138	}
139}
140
141func validateOpStartNextPendingJobExecutionInput(v *StartNextPendingJobExecutionInput) error {
142	if v == nil {
143		return nil
144	}
145	invalidParams := smithy.InvalidParamsError{Context: "StartNextPendingJobExecutionInput"}
146	if v.ThingName == nil {
147		invalidParams.Add(smithy.NewErrParamRequired("ThingName"))
148	}
149	if invalidParams.Len() > 0 {
150		return invalidParams
151	} else {
152		return nil
153	}
154}
155
156func validateOpUpdateJobExecutionInput(v *UpdateJobExecutionInput) error {
157	if v == nil {
158		return nil
159	}
160	invalidParams := smithy.InvalidParamsError{Context: "UpdateJobExecutionInput"}
161	if v.JobId == nil {
162		invalidParams.Add(smithy.NewErrParamRequired("JobId"))
163	}
164	if v.ThingName == nil {
165		invalidParams.Add(smithy.NewErrParamRequired("ThingName"))
166	}
167	if len(v.Status) == 0 {
168		invalidParams.Add(smithy.NewErrParamRequired("Status"))
169	}
170	if invalidParams.Len() > 0 {
171		return invalidParams
172	} else {
173		return nil
174	}
175}
176