val a = SKRole("ClientA")
val b = SKRole("ClientB")
val seller = SKRole("Seller")

globalProtocol("Protocol") {
    send<String>(a, seller, "id")

    send<Int>(seller, a, "valA")
    send<Int>(seller, b, "valB", "valA == valB")

    send<Int>(a, b, "proposal", "proposal <= valA")

    choice(b) {
        branch {
            send<Address>(b, seller, "buy")
            send<Date>(seller, b)
            send<Date>(b, a, "ok")
        }
        branch {
            send<Unit>(b, seller, "quit")
            send<Unit>(b, a, "quit")
        }
    }
}

val a = SKRole("A")
val b = SKRole("B")

fun subProtocol(x: SKRole, y: SKRole): GlobalProtocol = {
    send<Int>(x, y)
    send<Int>(y, x)
}

globalProtocol("ComplexProtocol") {
    choice(a) {
        branch {
            send<Int>(a, b, "branch1")
            subProtocol(a, b)()  // Proceed with subProtocol
        }
        branch {
            send<Int>(a, b, "branch2")
            subProtocol(b, a)()  // Proceed with subProtocol
        }
    }
}

val a = SKRole("A")
val b = SKRole("B")

globalProtocol("RefinedProtocol") {
    send<Int>(a, b, "val1")
    send<Int>(b, a, "val2", "val2 >= val1")
}

runBlocking {
    val chan = SKChannel()

    // Alice
    launch {
        SKMPEndpoint().use { e ->
            e.connect(Bob, chan)

            val buf = SKBuffer<Int>()

            ExampleProtocolAlice1(e)
                .sendToBob(1)
                .receiveFromBob(buf)
                .also { println("Alice received ${buf.value} from Bob") }
                .sendToBob("Hello")
        }
    }

    // Bob
    launch {
        var received = 0

        val callbacks = object : ExampleProtocolCallbacksBob {
            override fun onReceiveVal1FromAlice(value: Int) {
                received = value
            }
            override fun onSendVal2ToAlice(): Int = received * 2

            override fun onReceiveStringValueFromAlice(value: String) {
                println(value)
            }
        }

        ExampleProtocolCallbacksClassBob(callbacks).use { e ->
            e.connect(Alice, chan)
            e.start()
        }
    }
}

val chanAB = SKChannel()

// Endpoint A
SKMPEndpoint().use { e ->
    e.connect(B, chanAB)
    // ...
}

// Endpoint B
SKMPEndpoint().use { e ->
    e.connect(A, chanAB)
    e.accept(C, 9999)
    // ...
}

// Endpoint C
SKMPEndpoint().use { e ->
    e.request(B, "localhost", 9999)
    // ...
}

sessionkotlin {
    cleanBeforeCopying = false //  always clean the solver dependencies before copying
}