lourenco/mgmt
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

engine: Improve debugging for invalid send/recv res

Browse Source 
If we don't implement send/recv properly, at least give the user more
information as to where.
This commit is contained in:
James Shubin
2023-11-12 15:21:08 -05:00
parent 8d7d2fb1f1
commit cb999af653
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
engine/sendrecv.go
View File

@@ -17,6 +17,10 @@
package engine package engine
import (
"fmt"
)
// SendableRes is the interface a resource must implement to support sending // SendableRes is the interface a resource must implement to support sending
// named parameters. You must specify to the engine what kind of values (and // named parameters. You must specify to the engine what kind of values (and
// with their types) you will be sending. This is used for static type checking. // with their types) you will be sending. This is used for static type checking.
@@ -77,7 +81,7 @@ func GenerateSendFunc(res Res) func(interface{}) error {
//fmt.Printf("send: %+v\n", st) //fmt.Printf("send: %+v\n", st)
r, ok := res.(SendableRes) r, ok := res.(SendableRes)
if !ok { if !ok {
panic("res does not support the Sendable trait") panic(fmt.Sprintf("res of kind `%s` does not support the Sendable trait", res.Kind()))
} }
// XXX: type check this // XXX: type check this
//expected := r.Sends() //expected := r.Sends()
@@ -95,7 +99,7 @@ func GenerateRecvFunc(res Res) func() map[string]*Send {
return func() map[string]*Send { // TODO: change this API? return func() map[string]*Send { // TODO: change this API?
r, ok := res.(RecvableRes) r, ok := res.(RecvableRes)
if !ok { if !ok {
panic("res does not support the Recvable trait") panic(fmt.Sprintf("res of kind `%s` does not support the Recvable trait", res.Kind()))
} }
return r.Recv() return r.Recv()
} }