diff --git a/.github/CODEOWNERS b/.github/CODEOWNERS new file mode 100644 index 0000000..024f043 --- /dev/null +++ b/.github/CODEOWNERS @@ -0,0 +1 @@ +* @alkemics/transversal diff --git a/.github/workflows/go-test.yml b/.github/workflows/go-test.yml index 8e1fcd4..e77d768 100644 --- a/.github/workflows/go-test.yml +++ b/.github/workflows/go-test.yml @@ -14,7 +14,7 @@ jobs: - name: Set up Go uses: actions/setup-go@v2 with: - go-version: ^1.14 + go-version: ^1.17 id: go - name: Check out code into the Go module directory diff --git a/.github/workflows/release.yml b/.github/workflows/release.yml index e37287d..5e49aa8 100644 --- a/.github/workflows/release.yml +++ b/.github/workflows/release.yml @@ -13,7 +13,7 @@ jobs: - name: Set up Go uses: actions/setup-go@v2 with: - go-version: ^1.14 + go-version: ^1.17 id: go - name: Check out code into the Go module directory diff --git a/CODEOWNERS b/CODEOWNERS deleted file mode 100644 index b5f1c34..0000000 --- a/CODEOWNERS +++ /dev/null @@ -1 +0,0 @@ -* @alk-xchassin @alk-gpajot diff --git a/gfutil/gfgo/writer.go b/gfutil/gfgo/writer.go index 6c6b34d..e69d087 100644 --- a/gfutil/gfgo/writer.go +++ b/gfutil/gfgo/writer.go @@ -48,7 +48,7 @@ func (w *Writer) Flush() error { return err } - src, err = format.Source(src, "") + src, err = format.Source(src, format.Options{}) if err != nil { return err } diff --git a/go.mod b/go.mod index 3a1e858..fb594b2 100644 --- a/go.mod +++ b/go.mod @@ -1,15 +1,20 @@ module github.com/alkemics/goflow -go 1.14 +go 1.17 require ( - github.com/davecgh/go-spew v1.1.1 // indirect - github.com/google/go-cmp v0.4.1 // indirect - github.com/kr/text v0.2.0 // indirect - github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e // indirect - github.com/stretchr/testify v1.6.1 - golang.org/x/tools v0.0.0-20200716134326-a8f9df4c9543 - gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f // indirect - gopkg.in/yaml.v2 v2.3.0 - mvdan.cc/gofumpt v0.0.0-20200513141252-abc0db2c416a + github.com/stretchr/testify v1.7.0 + golang.org/x/tools v0.1.8 + gopkg.in/yaml.v2 v2.4.0 + mvdan.cc/gofumpt v0.2.0 +) + +require ( + github.com/davecgh/go-spew v1.1.0 // indirect + github.com/google/go-cmp v0.5.6 // indirect + github.com/pmezard/go-difflib v1.0.0 // indirect + golang.org/x/mod v0.5.1 // indirect + golang.org/x/sys v0.0.0-20211102192858-4dd72447c267 // indirect + golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 // indirect + gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c // indirect ) diff --git a/go.sum b/go.sum index 67a4f5c..818f9fe 100644 --- a/go.sum +++ b/go.sum @@ -1,61 +1,64 @@ github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E= github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= -github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= -github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= -github.com/google/go-cmp v0.4.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= -github.com/google/go-cmp v0.4.1 h1:/exdXoGamhu5ONeUJH0deniYLWYvQwW66yvlfiiKTu0= -github.com/google/go-cmp v0.4.1/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= +github.com/frankban/quicktest v1.14.0 h1:+cqqvzZV87b4adx/5ayVOaYZ2CrvM4ejQvUdBzPPUss= +github.com/frankban/quicktest v1.14.0/go.mod h1:NeW+ay9A/U67EYXNFA1nPE8e/tnQv/09mUdL/ijj8og= +github.com/google/go-cmp v0.5.6 h1:BKbKCqvP6I+rmFHt06ZmyQtvB8xAkWdhFyr0ZUNZcxQ= +github.com/google/go-cmp v0.5.6/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo= +github.com/kr/pretty v0.3.0 h1:WgNl7dwNpEZ6jJ9k1snq4pZsg7DOEN8hP9Xw0Tsjwk0= +github.com/kr/pretty v0.3.0/go.mod h1:640gp4NfQd8pI5XOwp5fnNeVWj67G7CFk/SaSQn7NBk= github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ= github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI= github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= -github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e h1:fD57ERR4JtEqsWbfPhv4DMiApHyliiK5xCTNVSPiaAs= -github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e/go.mod h1:zD1mROLANZcx1PVRCS0qkT7pwLkGfwJo4zjcN/Tysno= +github.com/pkg/diff v0.0.0-20210226163009-20ebb0f2a09e/go.mod h1:pJLUxLENpZxwdsKMEsNbx1VGcRFpLqf3715MtcvvzbA= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= -github.com/rogpeppe/go-internal v1.5.2/go.mod h1:xXDCJY+GAPziupqXw64V24skbSoqbTEfhy4qGm1nDQc= +github.com/rogpeppe/go-internal v1.6.1/go.mod h1:xXDCJY+GAPziupqXw64V24skbSoqbTEfhy4qGm1nDQc= +github.com/rogpeppe/go-internal v1.8.1-0.20211023094830-115ce09fd6b4 h1:Ha8xCaq6ln1a+R91Km45Oq6lPXj2Mla6CRJYcuV2h1w= +github.com/rogpeppe/go-internal v1.8.1-0.20211023094830-115ce09fd6b4/go.mod h1:JeRgkft04UBgHMgCIwADu4Pn6Mtm5d4nPKWu0nJ5d+o= github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= -github.com/stretchr/testify v1.6.1 h1:hDPOHmpOpP40lSULcqw7IrRb/u7w6RpDC9399XyoNd0= -github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= -github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74= -github.com/yuin/goldmark v1.1.32/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74= +github.com/stretchr/testify v1.7.0 h1:nwc3DEeHmmLAfoZucVR881uASk0Mfjw8xYJ99tb5CcY= +github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= +github.com/yuin/goldmark v1.4.1/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1Zlc8k= golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI= -golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto= -golang.org/x/mod v0.2.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= -golang.org/x/mod v0.3.0 h1:RM4zey1++hCTbCVQfnWeKs9/IEsaBLA8vTkd0WVtmH4= -golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= +golang.org/x/mod v0.5.1 h1:OJxoQ/rynoF0dcCdI7cLPktw/hR2cueqYfjm43oqK38= +golang.org/x/mod v0.5.1/go.mod h1:5OXOZSfqPIIbmVBIIKWRFfZjPR0E5r58TLhUjH0a2Ro= golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg= golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= -golang.org/x/net v0.0.0-20200226121028-0de0cce0169b/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= -golang.org/x/net v0.0.0-20200625001655-4c5254603344 h1:vGXIOMxbNfDTk/aXCmfdLgkrSV+Z2tcbze+pEc3v5W4= -golang.org/x/net v0.0.0-20200625001655-4c5254603344/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA= +golang.org/x/net v0.0.0-20211015210444-4f30a5c0130f/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= -golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= -golang.org/x/sync v0.0.0-20200625203802-6e8e738ad208/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20211019181941-9d821ace8654/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.0.0-20211102192858-4dd72447c267 h1:7zYaz3tjChtpayGDzu6H0hDAUM5zIGA2XW7kRNgQ0jc= +golang.org/x/sys v0.0.0-20211102192858-4dd72447c267/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= +golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= +golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ= +golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= -golang.org/x/tools v0.0.0-20200428185508-e9a00ec82136/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE= -golang.org/x/tools v0.0.0-20200716134326-a8f9df4c9543 h1:onHykNOjYYTQ3AMcREXdnzWl4I4CIs9BMiMkJ7ctODc= -golang.org/x/tools v0.0.0-20200716134326-a8f9df4c9543/go.mod h1:njjCfa9FT2d7l9Bc6FUM5FLjQPp3cFF28FI3qnDFljA= +golang.org/x/tools v0.1.8-0.20211102182255-bb4add04ddef/go.mod h1:nABZi5QlRsZVlzPpHl034qft6wpY4eDcsTt5AaioBiU= +golang.org/x/tools v0.1.8 h1:P1HhGGuLW4aAclzjtmJdf0mJOjVUZUzOTqkAkWL+l6w= +golang.org/x/tools v0.1.8/go.mod h1:nABZi5QlRsZVlzPpHl034qft6wpY4eDcsTt5AaioBiU= golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= -golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4= golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= +golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 h1:go1bK/D/BFZV2I8cIQd1NKEZ+0owSTG1fDTci4IqFcE= +golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127 h1:qIbj1fsPNlZgppZ+VLlY7N33q108Sa+fhmuc+sWQYwY= gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= -gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= -gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f h1:BLraFXnmrev5lT+xlilqcH8XK9/i0At2xKjWk4p6zsU= -gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI= -gopkg.in/yaml.v2 v2.3.0 h1:clyUAQHOM3G0M3f5vQj7LuJrETvjVot3Z5el9nffUtU= -gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= +gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY= +gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ= gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c h1:dUUwHk2QECo/6vqA44rthZ8ie2QXMNeKRTHCNY2nXvo= gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= -mvdan.cc/gofumpt v0.0.0-20200513141252-abc0db2c416a h1:TTEzidAa7rn93JGy1ACigx6o9VcsRLKG7qICdErmvUs= -mvdan.cc/gofumpt v0.0.0-20200513141252-abc0db2c416a/go.mod h1:4q/PlrZKQLU5MowSvCKM3U4xJUPtJ8vKWx7vsWFJ3MI= +mvdan.cc/gofumpt v0.2.0 h1:AInyCTHfhp4bFrP2VYC5kR2wPwgWj7eGSb+7437zn7I= +mvdan.cc/gofumpt v0.2.0/go.mod h1:TiGmrf914DAuT6+hDIxOqoDb4QXIzAuEUSXqEf9hGKY= diff --git a/wrappers/bind/graph/bind.go b/wrappers/bind/graph/bind.go index 98d6c01..a74b10a 100644 --- a/wrappers/bind/graph/bind.go +++ b/wrappers/bind/graph/bind.go @@ -1,5 +1,6 @@ // Code generated by goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main @@ -26,6 +27,7 @@ func newBind(id string) Bind { */ func (g *Bind) Run() { + // __add_reducer outputs var __add_reducer_aggregated functions.IntReducer diff --git a/wrappers/bind/graph/main.go b/wrappers/bind/graph/main.go index 096aa91..89a4843 100644 --- a/wrappers/bind/graph/main.go +++ b/wrappers/bind/graph/main.go @@ -1,5 +1,6 @@ // Code generated by lib-go/goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main diff --git a/wrappers/constants/graph/constants.go b/wrappers/constants/graph/constants.go index e3b4af3..365085b 100644 --- a/wrappers/constants/graph/constants.go +++ b/wrappers/constants/graph/constants.go @@ -1,5 +1,6 @@ // Code generated by goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main @@ -27,6 +28,7 @@ func newConstants(id string) Constants { */ func (g *Constants) Run() { + // __add_list outputs var __add_list_aggregated []int diff --git a/wrappers/constants/graph/main.go b/wrappers/constants/graph/main.go index b387c95..a3e660d 100644 --- a/wrappers/constants/graph/main.go +++ b/wrappers/constants/graph/main.go @@ -1,5 +1,6 @@ // Code generated by lib-go/goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main diff --git a/wrappers/ctx/graph/ctx.go b/wrappers/ctx/graph/ctx.go index e418732..c70b1bf 100644 --- a/wrappers/ctx/graph/ctx.go +++ b/wrappers/ctx/graph/ctx.go @@ -1,5 +1,6 @@ // Code generated by goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main @@ -27,6 +28,7 @@ func newCtx(id string) Ctx { */ func (g *Ctx) Run(ctx context.Context) { + // __ctx outputs var __ctx_ctx context.Context @@ -80,6 +82,7 @@ func (g *Ctx) Run(ctx context.Context) { igniteNodeID: {}, }, run: func() { + done <- "inputs" }, alreadyDone: false, diff --git a/wrappers/ctx/graph/main.go b/wrappers/ctx/graph/main.go index 21ce787..9db33d4 100644 --- a/wrappers/ctx/graph/main.go +++ b/wrappers/ctx/graph/main.go @@ -1,12 +1,14 @@ // Code generated by lib-go/goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main import ( - "context" "fmt" + + "context" ) func assert(b bool) { diff --git a/wrappers/gonodes/graph/gonodes.go b/wrappers/gonodes/graph/gonodes.go index 4cd50bf..6a0ca57 100644 --- a/wrappers/gonodes/graph/gonodes.go +++ b/wrappers/gonodes/graph/gonodes.go @@ -1,5 +1,6 @@ // Code generated by goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main @@ -29,6 +30,7 @@ func newGoNodes(id string, debug bool) GoNodes { */ func (g *GoNodes) Run() { + // __add_slice_list outputs var __add_slice_list_aggregated []int diff --git a/wrappers/gonodes/graph/main.go b/wrappers/gonodes/graph/main.go index 2084551..860b240 100644 --- a/wrappers/gonodes/graph/main.go +++ b/wrappers/gonodes/graph/main.go @@ -1,5 +1,6 @@ // Code generated by lib-go/goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main diff --git a/wrappers/ifs/graph/ifs.go b/wrappers/ifs/graph/ifs.go index ca5d156..17301b5 100644 --- a/wrappers/ifs/graph/ifs.go +++ b/wrappers/ifs/graph/ifs.go @@ -1,5 +1,6 @@ // Code generated by goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main @@ -26,6 +27,7 @@ func newIfs(id string) Ifs { */ func (g *Ifs) Run() { + // __print_again_values outputs var __print_again_values_aggregated []interface{} diff --git a/wrappers/ifs/graph/main.go b/wrappers/ifs/graph/main.go index 9b8d5e3..7b54bae 100644 --- a/wrappers/ifs/graph/main.go +++ b/wrappers/ifs/graph/main.go @@ -1,5 +1,6 @@ // Code generated by lib-go/goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main diff --git a/wrappers/inputs/graph/inputs.go b/wrappers/inputs/graph/inputs.go index fd2f045..42cc3f2 100644 --- a/wrappers/inputs/graph/inputs.go +++ b/wrappers/inputs/graph/inputs.go @@ -1,5 +1,6 @@ // Code generated by goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main @@ -28,6 +29,7 @@ func newInputs(id string) Inputs { optional: no */ func (g *Inputs) Run(ctx context.Context, a int, b []int, no bool) { + // __add_list outputs var __add_list_aggregated []int diff --git a/wrappers/inputs/graph/main.go b/wrappers/inputs/graph/main.go index 09737ff..b2afb74 100644 --- a/wrappers/inputs/graph/main.go +++ b/wrappers/inputs/graph/main.go @@ -1,12 +1,14 @@ // Code generated by lib-go/goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main import ( - "context" "fmt" + + "context" ) func assert(b bool) { diff --git a/wrappers/mockingjay/graph/main.go b/wrappers/mockingjay/graph/main.go index f67fd57..4c9126e 100644 --- a/wrappers/mockingjay/graph/main.go +++ b/wrappers/mockingjay/graph/main.go @@ -1,13 +1,15 @@ // Code generated by lib-go/goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main import ( - "context" "fmt" + "context" + "github.com/alkemics/goflow/wrappers/mockingjay" ) diff --git a/wrappers/mockingjay/graph/mockingjay.go b/wrappers/mockingjay/graph/mockingjay.go index 53b710c..084854c 100644 --- a/wrappers/mockingjay/graph/mockingjay.go +++ b/wrappers/mockingjay/graph/mockingjay.go @@ -1,5 +1,6 @@ // Code generated by goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main @@ -27,7 +28,8 @@ func newMockingjay(id string) Mockingjay { /* */ -func (g *Mockingjay) Run(ctx context.Context, a, b int) (sum int) { +func (g *Mockingjay) Run(ctx context.Context, a int, b int) (sum int) { + // __add_a outputs var __add_a_aggregated int @@ -97,6 +99,7 @@ func (g *Mockingjay) Run(ctx context.Context, a, b int) (sum int) { igniteNodeID: {}, }, run: func() { + __output_sum_builder_sum = add_sum sum = __output_sum_builder_sum done <- "__output_sum_builder" @@ -111,6 +114,7 @@ func (g *Mockingjay) Run(ctx context.Context, a, b int) (sum int) { igniteNodeID: {}, }, run: func() { + var _mock []interface{} if _mocks, ok := ctx.Value(mockingjay.ContextKey).(map[string][]interface{}); ok && _mocks != nil { m, ok := _mocks["add"] @@ -134,6 +138,7 @@ func (g *Mockingjay) Run(ctx context.Context, a, b int) (sum int) { igniteNodeID: {}, }, run: func() { + var _mock []interface{} if _mocks, ok := ctx.Value(mockingjay.ContextKey).(map[string][]interface{}); ok && _mocks != nil { m, ok := _mocks["inputs"] diff --git a/wrappers/outputs/graph/main.go b/wrappers/outputs/graph/main.go index b3a7c11..2346bd4 100644 --- a/wrappers/outputs/graph/main.go +++ b/wrappers/outputs/graph/main.go @@ -1,5 +1,6 @@ // Code generated by lib-go/goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main diff --git a/wrappers/outputs/graph/outputs.go b/wrappers/outputs/graph/outputs.go index 6575f11..48f620a 100644 --- a/wrappers/outputs/graph/outputs.go +++ b/wrappers/outputs/graph/outputs.go @@ -1,5 +1,6 @@ // Code generated by goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main @@ -25,6 +26,7 @@ func newOuputs(id string) Ouputs { */ func (g *Ouputs) Run() (random_int int, random_ints []int) { + // __output_random_int_builder outputs var __output_random_int_builder_random_int int @@ -55,6 +57,7 @@ func (g *Ouputs) Run() (random_int int, random_ints []int) { igniteNodeID: {}, }, run: func() { + __output_random_int_builder_random_int = produce_random_int_n random_int = __output_random_int_builder_random_int done <- "__output_random_int_builder" @@ -68,6 +71,7 @@ func (g *Ouputs) Run() (random_int int, random_ints []int) { igniteNodeID: {}, }, run: func() { + __output_random_ints_builder_random_ints = append(__output_random_ints_builder_random_ints, produce_random_int_n) __output_random_ints_builder_random_ints = append(__output_random_ints_builder_random_ints, produce_another_random_int_n) random_ints = __output_random_ints_builder_random_ints diff --git a/wrappers/types/graph/main.go b/wrappers/types/graph/main.go index a56feb5..a49ab44 100644 --- a/wrappers/types/graph/main.go +++ b/wrappers/types/graph/main.go @@ -1,12 +1,14 @@ // Code generated by lib-go/goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main import ( - "context" "fmt" + + "context" ) func assert(b bool) { diff --git a/wrappers/types/graph/types.go b/wrappers/types/graph/types.go index e93bf6e..9d34d75 100644 --- a/wrappers/types/graph/types.go +++ b/wrappers/types/graph/types.go @@ -1,5 +1,6 @@ // Code generated by goflow DO NOT EDIT. +//go:build !codeanalysis // +build !codeanalysis package main @@ -28,7 +29,8 @@ func newTypes(id string) Types { /* optional: no */ -func (g *Types) Run(ctx context.Context, a uint, b []uint, c uint, no bool) (add, add_10 uint, forwardedInputs []uint) { +func (g *Types) Run(ctx context.Context, a uint, b []uint, c uint, no bool) (add uint, add_10 uint, forwardedInputs []uint) { + // __add_10_a outputs var __add_10_a_aggregated uint @@ -170,6 +172,7 @@ func (g *Types) Run(ctx context.Context, a uint, b []uint, c uint, no bool) (add igniteNodeID: {}, }, run: func() { + __output_add_10_builder_add_10 = add_10_sum add_10 = __output_add_10_builder_add_10 done <- "__output_add_10_builder" @@ -182,6 +185,7 @@ func (g *Types) Run(ctx context.Context, a uint, b []uint, c uint, no bool) (add igniteNodeID: {}, }, run: func() { + __output_add_builder_add = add_result add = __output_add_builder_add done <- "__output_add_builder" @@ -194,6 +198,7 @@ func (g *Types) Run(ctx context.Context, a uint, b []uint, c uint, no bool) (add igniteNodeID: {}, }, run: func() { + __output_forwardedInputs_builder_forwardedInputs = append(__output_forwardedInputs_builder_forwardedInputs, inputs_a) __output_forwardedInputs_builder_forwardedInputs = append(__output_forwardedInputs_builder_forwardedInputs, inputs_b...) __output_forwardedInputs_builder_forwardedInputs = append(__output_forwardedInputs_builder_forwardedInputs, inputs_c)