fix: adding cloudEvent wrapper to counterSubscriber (#35)

* fix: adding cloudEvent wrapper to counterSubscriber

* fix: increasing registration limit for bigs to 12

Author: AlexZangerle

big/src/main/kotlin/ac/at/uibk/dps/dapr/big/sink/SinkActorImpl.kt

@@ -16,7 +16,7 @@ class SinkActorImpl(runtimeContext: ActorRuntimeContext<SinkActorImpl>, actorId:
 
   override fun register() {
     ++registered
-    if (registered == 6) {
+    if (registered == 12) {
       client.publishEvent("pubsub", "initial", 0L).subscribe()
     }
   }

count/src/main/kotlin/ac/at/uibk/dps/dapr/count/counter/CounterSubscriber.kt

@@ -4,6 +4,7 @@ import io.dapr.Topic
 import io.dapr.actors.ActorId
 import io.dapr.actors.client.ActorClient
 import io.dapr.actors.client.ActorProxyBuilder
+import io.dapr.client.domain.CloudEvent
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty
 import org.springframework.web.bind.annotation.PostMapping
 import org.springframework.web.bind.annotation.RequestBody
@@ -18,7 +19,7 @@ class CounterSubscriber {
 
   @Topic(name = "increment", pubsubName = "pubsub")
   @PostMapping("/increment")
-  fun handleIncrement(@RequestBody body: Map<String, Any>) {
-    counterProxy.increment(body["data"] as Long)
+  fun incrementSubscriber(@RequestBody event: CloudEvent<Long>) {
+    counterProxy.increment(event.data)
   }
 }