115
}
116
117
>
func (u UpdateUtils) UpdateRejectMessages(tv *testvars.TestVars, updRequestMsg *protocolpb.Message) []*protocolpb.Message {
update.go
118
>
if th, ok := u.t.(helper); ok {
119
>
th.Helper()
120
>
}
121
>
updRequest := protoutils.UnmarshalAny[*updatepb.Request](u.t, updRequestMsg.GetBody())
122
>
123
>
return []*protocolpb.Message{
124
>
{
125
>
Id: tv.MessageID() + "_update-rejected",
126
>
ProtocolInstanceId: updRequest.GetMeta().GetUpdateId(),
127
>
SequencingId: nil,
128
>
Body: protoutils.MarshalAny(u.t, &updatepb.Rejection{
129
>
RejectedRequestMessageId: updRequestMsg.GetId(),
130
>
RejectedRequestSequencingEventId: updRequestMsg.GetEventId(),
131
>
RejectedRequest: updRequest,
132
>
Failure: &failurepb.Failure{
133
>
Message: "rejection-of-" + updRequest.GetMeta().GetUpdateId(),
134
>
FailureInfo: &failurepb.Failure_ApplicationFailureInfo{ApplicationFailureInfo: &failurepb.ApplicationFailureInfo{}},
135
>
},
136
>
}),
137
>
},
138
>
}
139
}