adjusts in user api

Author: Adriano Santos

README.md

@@ -3,6 +3,6 @@ plugins {
 }
 
 allprojects {
-    group = "io.creativesource"
+    group = "io.eigr"
     version = "1.0.0"
 }

build.gradle.kts

@@ -1,2 +1,2 @@
-23
+48
 0

docs/Index.md

@@ -1,6 +1,6 @@
-package io.creativesource.synapsys.core
+package io.eigr.synapsys.core
 
-import io.creativesource.synapsys.core.actor.Actor
+import io.eigr.synapsys.core.actor.Actor
 
 class Supervisor {
 

synapsys-core/build/classes/kotlin/main/META-INF/synapsys-core.kotlin_module

@@ -0,0 +1,21 @@
+package io.eigr.synapsys.core.actor
+
+import io.eigr.synapsys.core.internals.persistence.Store
+
+abstract class Actor<S, M, R>(val id: String?, initialState: S?) {
+    var state: Context<S> = Context(initialState)
+
+    internal var store: Store<S>? = null
+
+    abstract fun onReceive(message: M, state: Context<S>): Pair<S, R>
+
+    internal suspend fun onStart()  {
+        this.state = Context(store?.load(id!!))
+    }
+
+    internal suspend fun mutate(state: S): S {
+        this.state = Context(state)
+        store?.save(id!!, state)
+        return state
+    }
+}

synapsys-core/build/classes/kotlin/main/io/creativesource/synapsys/core/Supervisor.class

@@ -0,0 +1,17 @@
+package io.eigr.synapsys.core.actor
+
+import io.eigr.synapsys.core.internals.loggerFor
+import io.eigr.synapsys.core.internals.scheduler.ActorExecutor
+
+class ActorPointer<M : Any>(private val actorId: String, private val executor: ActorExecutor<M>) {
+    private val log = loggerFor(this::class.java)
+
+    fun getAddress(): String {
+        return "<${actorId.lowercase()}>"
+    }
+
+    suspend fun send(message: M) {
+        log.debug("[ActorSystem] Sending message: {} to actor: {}", message, actorId)
+        executor.send(message)
+    }
+}

synapsys-core/build/classes/kotlin/main/io/creativesource/synapsys/core/actor/Actor$mutate$1.class

@@ -0,0 +1,36 @@
+package io.eigr.synapsys.core.actor
+
+import io.eigr.synapsys.core.internals.BaseActorAdapter
+import io.eigr.synapsys.core.internals.mailbox.Mailbox
+import io.eigr.synapsys.core.internals.mailbox.transport.ChannelMailbox
+import io.eigr.synapsys.core.internals.persistence.InMemoryStore
+import io.eigr.synapsys.core.internals.scheduler.ActorExecutor
+import io.eigr.synapsys.core.internals.scheduler.Scheduler
+import io.eigr.synapsys.core.internals.serialization.ProtobufMessageSerializer
+
+object ActorSystem {
+    private val executors: MutableMap<String, ActorExecutor<*>> = mutableMapOf()
+    private lateinit var scheduler: Scheduler
+
+    fun <S, M : Any, R> createActor(
+        id: String,
+        initialState: S,
+        actorFactory: (String, S) -> Actor<S, M, R>
+    ): ActorPointer<M> {
+        val actor = actorFactory(id, initialState)
+        actor.store = InMemoryStore()
+        val adapter = BaseActorAdapter(actor)
+        val mailbox = Mailbox<M>(ChannelMailbox(ProtobufMessageSerializer()))
+        val executor = ActorExecutor(adapter, mailbox)
+
+        executors[id] = executor
+        return ActorPointer(id, executor)
+    }
+
+    fun start() {
+        scheduler = Scheduler(50)
+        executors.values.forEach { executor ->
+            scheduler.enqueue(executor as ActorExecutor<Any>)
+        }
+    }
+}

synapsys-core/build/classes/kotlin/main/io/creativesource/synapsys/core/actor/Actor$onStart$1.class

@@ -0,0 +1,5 @@
+package io.eigr.synapsys.core.actor
+
+class Context<S>(private val internalState: S?) {
+    val state get() = this.internalState
+}

synapsys-core/build/classes/kotlin/main/io/creativesource/synapsys/core/actor/Actor.class

@@ -1,7 +1,7 @@
-package io.creativesource.synapsys.core.internals
+package io.eigr.synapsys.core.internals
 
 interface BaseActor {
     val id: String
     suspend fun processMessageUntyped(message: Any, currentState: Any?): Pair<Any?, Any?>
-    fun getState(): Any?
+    suspend fun getState(): Any?
 }

synapsys-core/build/classes/kotlin/main/io/creativesource/synapsys/core/actor/ActorSystem.class

@@ -1,13 +1,15 @@
-package io.creativesource.synapsys.core.internals
+package io.eigr.synapsys.core.internals
 
-import io.creativesource.synapsys.core.actor.Actor
+import io.eigr.synapsys.core.actor.Actor
+import io.eigr.synapsys.core.actor.Context
 
-class ActorAdapter<S, M, R>(private val actor: Actor<S, M, R>) : BaseActor {
+class BaseActorAdapter<S, M, R>(private val actor: Actor<S, M, R>) :
+    BaseActor {
 
     override val id: String
         get() = actor.id!!
 
-    override fun getState(): S? = actor.state
+    override suspend fun getState(): S? = actor.state.state
 
     override suspend fun processMessageUntyped(message: Any, currentState: Any?): Pair<Any?, Any?> {
         @Suppress("UNCHECKED_CAST")
@@ -17,7 +19,9 @@ class ActorAdapter<S, M, R>(private val actor: Actor<S, M, R>) : BaseActor {
         val typedMessage = message as? M
             ?: throw IllegalArgumentException("Actor $id received a message of invalid type.")
 
-        val (newState, result) = actor.onReceive(typedMessage, typedState)
+        val ctx: Context<S> = Context(typedState)
+        val (newState, result) = actor.onReceive(typedMessage, ctx)
         return Pair(result, actor.mutate(newState))
     }
+
 }

synapsys-core/build/classes/kotlin/main/io/creativesource/synapsys/core/actor/Context.class

@@ -1,4 +1,4 @@
-package io.creativesource.synapsys.core.internals
+package io.eigr.synapsys.core.internals
 
 interface MessageSerializer {
     fun <T> serialize(obj: T): ByteArray

synapsys-core/build/classes/kotlin/main/io/creativesource/synapsys/core/internals/ActorAdapter$processMessageUntyped$1.class

@@ -0,0 +1,16 @@
+package io.eigr.synapsys.core.internals.mailbox
+
+import io.eigr.synapsys.core.internals.mailbox.transport.ChannelMailbox
+
+class Mailbox<M : Any>(private val queue: MailboxAbstractQueue<M> = ChannelMailbox()) {
+
+    suspend fun send(message: M) {
+        queue.send(message)
+    }
+
+    suspend fun receive(): M? {
+        return queue.receive()
+    }
+
+    fun hasMessages(): Boolean = queue.hasMessages()
+}

synapsys-core/build/classes/kotlin/main/io/creativesource/synapsys/core/internals/ActorAdapter.class

@@ -1,6 +1,6 @@
-package io.creativesource.synapsys.core.internals.mailbox
+package io.eigr.synapsys.core.internals.mailbox
 
-abstract class SynapsysAbstractQueue<M> {
+abstract class MailboxAbstractQueue<M> {
     abstract suspend fun send(message: M)
     abstract suspend fun receive(): M?
     abstract fun hasMessages(): Boolean

synapsys-core/build/classes/kotlin/main/io/creativesource/synapsys/core/internals/BaseActor.class

@@ -1,14 +1,14 @@
-package io.creativesource.synapsys.core.internals.mailbox.transport
+package io.eigr.synapsys.core.internals.mailbox.transport
 
-import io.creativesource.synapsys.core.internals.MessageSerializer
-import io.creativesource.synapsys.core.internals.mailbox.SynapsysAbstractQueue
-import io.creativesource.synapsys.core.internals.serialization.ProtobufMessageSerializer
+import io.eigr.synapsys.core.internals.MessageSerializer
+import io.eigr.synapsys.core.internals.mailbox.MailboxAbstractQueue
+import io.eigr.synapsys.core.internals.serialization.ProtobufMessageSerializer
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 
 import kotlinx.coroutines.channels.Channel
 
 class ChannelMailbox<M : Any>(private val serializer: MessageSerializer = ProtobufMessageSerializer()) :
-    SynapsysAbstractQueue<M>() {
+    MailboxAbstractQueue<M>() {
     private lateinit var messageClass: Class<M>
     private val channel = Channel<ByteArray>(Channel.UNLIMITED)
 

synapsys-core/build/classes/kotlin/main/io/creativesource/synapsys/core/internals/MessageSerializer.class

@@ -1,17 +1,17 @@
-package io.creativesource.synapsys.core.internals.mailbox.transport
+package io.eigr.synapsys.core.internals.mailbox.transport
 
-import io.creativesource.synapsys.core.internals.MessageSerializer
-import io.creativesource.synapsys.core.internals.loggerFor
-import io.creativesource.synapsys.core.internals.mailbox.SynapsysAbstractQueue
-import io.creativesource.synapsys.core.internals.serialization.ProtobufMessageSerializer
+import io.eigr.synapsys.core.internals.MessageSerializer
+import io.eigr.synapsys.core.internals.loggerFor
+import io.eigr.synapsys.core.internals.mailbox.MailboxAbstractQueue
+import io.eigr.synapsys.core.internals.serialization.ProtobufMessageSerializer
 
 import org.zeromq.ZMQ
 import org.zeromq.ZMQException
 
 class ZeroMQMailbox<M : Any>(
     private val serializer: MessageSerializer = ProtobufMessageSerializer(),
     private val endpoint: String = "inproc://mailbox"
-) : SynapsysAbstractQueue<M>() {
+) : MailboxAbstractQueue<M>() {
 
     private val log = loggerFor(this::class.java)
     private val context = ZMQ.context(1)

synapsys-core/build/classes/kotlin/main/io/creativesource/synapsys/core/internals/UtilsKt.class

@@ -1,4 +1,4 @@
-package io.creativesource.synapsys.core.internals.persistence
+package io.eigr.synapsys.core.internals.persistence
 
 class InMemoryStore<S> : Store<S> {
     private val store = mutableMapOf<String, S>()

synapsys-core/build/classes/kotlin/main/io/creativesource/synapsys/core/internals/mailbox/Mailbox.class

@@ -1,4 +1,4 @@
-package io.creativesource.synapsys.core.internals.persistence
+package io.eigr.synapsys.core.internals.persistence
 
 interface Store<S> {
     suspend fun save(id: String, state: S)