Rename types package to common (#488)

* Few renamings to reduce breakage, plus improve javadocs of `Context`

* Reintroduce RestateHttpEndpointBuilder to reduce breakage

* Reintroduce JsonSerdes to reduce breakage

* Javadocs cosmetics

Author: slinkydeveloper

examples/src/main/java/my/restate/sdk/examples/Counter.java

@@ -13,9 +13,9 @@
 import dev.restate.sdk.annotation.Name;
 import dev.restate.sdk.annotation.Shared;
 import dev.restate.sdk.annotation.VirtualObject;
+import dev.restate.sdk.common.StateKey;
 import dev.restate.sdk.endpoint.Endpoint;
 import dev.restate.sdk.http.vertx.RestateHttpServer;
-import dev.restate.sdk.types.StateKey;
 import java.time.Duration;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;

examples/src/main/java/my/restate/sdk/examples/LoanWorkflow.java

@@ -15,11 +15,11 @@
 import dev.restate.sdk.annotation.Service;
 import dev.restate.sdk.annotation.Shared;
 import dev.restate.sdk.annotation.Workflow;
+import dev.restate.sdk.common.DurablePromiseKey;
+import dev.restate.sdk.common.StateKey;
+import dev.restate.sdk.common.TerminalException;
 import dev.restate.sdk.endpoint.Endpoint;
 import dev.restate.sdk.http.vertx.RestateHttpServer;
-import dev.restate.sdk.types.DurablePromiseKey;
-import dev.restate.sdk.types.StateKey;
-import dev.restate.sdk.types.TerminalException;
 import java.math.BigDecimal;
 import java.time.Duration;
 import java.time.Instant;

examples/src/main/kotlin/my/restate/sdk/examples/CounterKt.kt

@@ -18,8 +18,6 @@ import kotlinx.serialization.Serializable
 import org.apache.logging.log4j.LogManager
 import org.apache.logging.log4j.Logger
 
-@Serializable data class CounterUpdate(var oldValue: Long, val newValue: Long)
-
 @VirtualObject
 class CounterKt {
 
@@ -28,6 +26,8 @@ class CounterKt {
     private val LOG: Logger = LogManager.getLogger(CounterKt::class.java)
   }
 
+  @Serializable data class CounterUpdate(var oldValue: Long, val newValue: Long)
+
   @Handler
   suspend fun reset(ctx: ObjectContext) {
     ctx.clear(TOTAL)

sdk-api-gen/src/main/resources/templates/Client.hbs

@@ -2,7 +2,7 @@
 
 import dev.restate.sdk.CallDurableFuture;
 import dev.restate.sdk.Context;
-import dev.restate.sdk.types.StateKey;
+import dev.restate.sdk.common.StateKey;
 import dev.restate.serde.Serde;
 import dev.restate.common.Target;
 import java.util.Optional;

sdk-api-kotlin/src/main/kotlin/dev/restate/sdk/kotlin/ContextImpl.kt

@@ -11,11 +11,11 @@ package dev.restate.sdk.kotlin
 import dev.restate.common.Output
 import dev.restate.common.Request
 import dev.restate.common.Slice
+import dev.restate.sdk.common.DurablePromiseKey
+import dev.restate.sdk.common.HandlerRequest
+import dev.restate.sdk.common.StateKey
+import dev.restate.sdk.common.TerminalException
 import dev.restate.sdk.endpoint.definition.HandlerContext
-import dev.restate.sdk.types.DurablePromiseKey
-import dev.restate.sdk.types.HandlerRequest
-import dev.restate.sdk.types.StateKey
-import dev.restate.sdk.types.TerminalException
 import dev.restate.serde.Serde
 import dev.restate.serde.SerdeFactory
 import dev.restate.serde.TypeTag
@@ -127,7 +127,7 @@ internal constructor(
     var coroutineCtx = currentCoroutineContext()
     val javaRetryPolicy =
         retryPolicy?.let {
-          dev.restate.sdk.types.RetryPolicy.exponential(
+          dev.restate.sdk.common.RetryPolicy.exponential(
                   it.initialDelay.toJavaDuration(), it.exponentiationFactor)
               .setMaxAttempts(it.maxAttempts)
               .setMaxDelay(it.maxDelay?.toJavaDuration())
@@ -165,7 +165,7 @@ internal constructor(
   }
 
   override fun random(): RestateRandom {
-    return RestateRandom(handlerContext.request().invocationId().toRandomSeed())
+    return RestateRandom(handlerContext.request().getInvocationId().toRandomSeed())
   }
 
   override fun <T : Any> promise(key: DurablePromiseKey<T>): DurablePromise<T> {

sdk-api-kotlin/src/main/kotlin/dev/restate/sdk/kotlin/HandlerRunner.kt

@@ -9,8 +9,8 @@
 package dev.restate.sdk.kotlin
 
 import dev.restate.common.Slice
+import dev.restate.sdk.common.TerminalException
 import dev.restate.sdk.endpoint.definition.HandlerContext
-import dev.restate.sdk.types.TerminalException
 import dev.restate.serde.Serde
 import dev.restate.serde.SerdeFactory
 import io.opentelemetry.extension.kotlin.asContextElement
@@ -108,7 +108,7 @@ internal constructor(
             options.coroutineContext +
                 dev.restate.sdk.endpoint.definition.HandlerRunner.HANDLER_CONTEXT_THREAD_LOCAL
                     .asContextElement(handlerContext) +
-                handlerContext.request().otelContext()!!.asContextElement())
+                handlerContext.request().getOpenTelemetryContext()!!.asContextElement())
 
     val completableFuture = CompletableFuture<Slice>()
     val job =

sdk-api-kotlin/src/main/kotlin/dev/restate/sdk/kotlin/api.kt

@@ -10,10 +10,10 @@ package dev.restate.sdk.kotlin
 
 import dev.restate.common.Output
 import dev.restate.common.Request
-import dev.restate.sdk.types.DurablePromiseKey
-import dev.restate.sdk.types.HandlerRequest
-import dev.restate.sdk.types.StateKey
-import dev.restate.sdk.types.TerminalException
+import dev.restate.sdk.common.DurablePromiseKey
+import dev.restate.sdk.common.HandlerRequest
+import dev.restate.sdk.common.StateKey
+import dev.restate.sdk.common.TerminalException
 import dev.restate.serde.TypeTag
 import dev.restate.serde.kotlinx.*
 import java.util.*
@@ -173,7 +173,7 @@ sealed interface Context {
 
   /**
    * Create a [RestateRandom] instance inherently predictable, seeded on the
-   * [dev.restate.sdk.types.InvocationId], which is not secret.
+   * [dev.restate.sdk.common.InvocationId], which is not secret.
    *
    * This instance is useful to generate identifiers, idempotency keys, and for uniform sampling
    * from a set of options. If a cryptographically secure value is needed, please generate that
@@ -394,7 +394,7 @@ class RestateRandom(seed: Long) : Random() {
  * waits until the asynchronous result is available.
  *
  * The result can be either a success or a failure. In case of a failure, [await] will throw a
- * [dev.restate.sdk.types.TerminalException].
+ * [dev.restate.sdk.common.TerminalException].
  *
  * @param T type of this future's result
  */
@@ -408,14 +408,14 @@ sealed interface DurableFuture<T> {
   suspend fun await(): T
 
   /**
-   * Same as [await] but throws a [dev.restate.sdk.types.TimeoutException] if this [DurableFuture]
+   * Same as [await] but throws a [dev.restate.sdk.common.TimeoutException] if this [DurableFuture]
    * doesn't complete before the provided `timeout`.
    */
   suspend fun await(duration: Duration): T
 
   /**
-   * Creates a [DurableFuture] that throws a [dev.restate.sdk.types.TimeoutException] if this future
-   * doesn't complete before the provided `timeout`.
+   * Creates a [DurableFuture] that throws a [dev.restate.sdk.common.TimeoutException] if this
+   * future doesn't complete before the provided `timeout`.
    */
   suspend fun withTimeout(duration: Duration): DurableFuture<T>
 
@@ -426,7 +426,7 @@ sealed interface DurableFuture<T> {
    * Map the success result of this [DurableFuture].
    *
    * @param transform the mapper to execute if this [DurableFuture] completes with success. The
-   *   mapper can throw a [dev.restate.sdk.types.TerminalException], thus failing the returned
+   *   mapper can throw a [dev.restate.sdk.common.TerminalException], thus failing the returned
    *   [DurableFuture].
    * @return a new [DurableFuture] with the mapped result, when completed
    */
@@ -436,10 +436,10 @@ sealed interface DurableFuture<T> {
    * Map both the success and the failure result of this [DurableFuture].
    *
    * @param transformSuccess the mapper to execute if this [DurableFuture] completes with success.
-   *   The mapper can throw a [dev.restate.sdk.types.TerminalException], thus failing the returned
+   *   The mapper can throw a [dev.restate.sdk.common.TerminalException], thus failing the returned
    *   [DurableFuture].
    * @param transformFailure the mapper to execute if this [DurableFuture] completes with failure.
-   *   The mapper can throw a [dev.restate.sdk.types.TerminalException], thus failing the returned
+   *   The mapper can throw a [dev.restate.sdk.common.TerminalException], thus failing the returned
    *   [DurableFuture].
    * @return a new [DurableFuture] with the mapped result, when completed
    */
@@ -452,7 +452,7 @@ sealed interface DurableFuture<T> {
    * Map the failure result of this [DurableFuture].
    *
    * @param transform the mapper to execute if this [DurableFuture] completes with failure. The
-   *   mapper can throw a [dev.restate.sdk.types.TerminalException], thus failing the returned
+   *   mapper can throw a [dev.restate.sdk.common.TerminalException], thus failing the returned
    *   [DurableFuture].
    * @return a new [DurableFuture] with the mapped result, when completed
    */

sdk-api-kotlin/src/main/kotlin/dev/restate/sdk/kotlin/futures.kt

@@ -10,10 +10,10 @@ package dev.restate.sdk.kotlin
 
 import dev.restate.common.Output
 import dev.restate.common.Slice
+import dev.restate.sdk.common.TerminalException
+import dev.restate.sdk.common.TimeoutException
 import dev.restate.sdk.endpoint.definition.AsyncResult
 import dev.restate.sdk.endpoint.definition.HandlerContext
-import dev.restate.sdk.types.TerminalException
-import dev.restate.sdk.types.TimeoutException
 import dev.restate.serde.Serde
 import dev.restate.serde.TypeTag
 import java.util.concurrent.CompletableFuture