fluencelabs/aqua
1
0
Fork 0
mirror of https://github.com/fluencelabs/aqua.git synced 2025-03-15 11:40:50 +00:00
Code Issues Projects Releases Wiki Activity

Fixes #99: use impossible name for relay (#103)

Browse Source
This commit is contained in:
Dmitry Kurinskiy 2021-04-30 11:51:55 +03:00 committed by GitHub
parent 53ad29ab31
commit 231cd2a9d0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
README.md
View File

@ -1,5 +1,7 @@
## Aqua ## Aqua
[![release](https://github.com/fluencelabs/aqua/actions/workflows/release.yml/badge.svg)](https://github.com/fluencelabs/aqua/actions/workflows/release.yml)
Aqua is a new-gen language for distributed systems. Aqua is a new-gen language for distributed systems.
Aqua programs are executed on many peers, sequentially Aqua programs are executed on many peers, sequentially

2
model/src/main/scala/aqua/model/transform/BodyConfig.scala
View File

@ -8,7 +8,7 @@ case class BodyConfig(
errorHandlingService: String = "errorHandlingSrv", errorHandlingService: String = "errorHandlingSrv",
errorFuncName: String = "error", errorFuncName: String = "error",
respFuncName: String = "response", respFuncName: String = "response",
relayVarName: Option[String] = Some("relay"), relayVarName: Option[String] = Some("-relay-"),
wrapWithXor: Boolean = true wrapWithXor: Boolean = true
) { ) {

4
model/src/test/scala/aqua/model/Node.scala
View File

@ -84,8 +84,8 @@ object Node {
implicit def nodeToCof(tree: Node): Cof = implicit def nodeToCof(tree: Node): Cof =
Cofree(tree.tag, Eval.later(Chain.fromSeq(tree.ops.map(nodeToCof)))) Cofree(tree.tag, Eval.later(Chain.fromSeq(tree.ops.map(nodeToCof))))
val relay = LiteralModel("relay") val relay = LiteralModel("-relay-")
val relayV = VarModel("relay", ScalarType.string) val relayV = VarModel("-relay-", ScalarType.string)
val initPeer = LiteralModel.initPeerId val initPeer = LiteralModel.initPeerId
val emptyCall = Call(Nil, None) val emptyCall = Call(Nil, None)
val otherPeer = LiteralModel("other-peer") val otherPeer = LiteralModel("other-peer")

6
model/src/test/scala/aqua/model/transform/TransformSpec.scala
View File

@ -33,7 +33,7 @@ class TransformSpec extends AnyFlatSpec with Matchers {
val expectedFC = val expectedFC =
xor( xor(
seq( seq(
dataCall(bc, "relay", initPeer), dataCall(bc, "-relay-", initPeer),
through(relayV), through(relayV),
call(1, otherPeer), call(1, otherPeer),
through(relayV), through(relayV),
@ -71,7 +71,7 @@ class TransformSpec extends AnyFlatSpec with Matchers {
val expectedFC = val expectedFC =
xor( xor(
seq( seq(
dataCall(bc, "relay", initPeer), dataCall(bc, "-relay-", initPeer),
call(0, initPeer), call(0, initPeer),
through(relayV), through(relayV),
call(1, otherPeer), call(1, otherPeer),
@ -136,7 +136,7 @@ class TransformSpec extends AnyFlatSpec with Matchers {
res.equalsOrPrintDiff( res.equalsOrPrintDiff(
seq( seq(
dataCall(bc, "relay", initPeer), dataCall(bc, "-relay-", initPeer),
Node( Node(
CallServiceTag( CallServiceTag(
LiteralModel("\"srv1\""), LiteralModel("\"srv1\""),