feat: Removing no reply

codegen/build.sbt

@@ -101,7 +101,7 @@ lazy val `kalix-codegen-js-cli` =
 lazy val library =
   new {
     object Version {
-      val kalix = "1.0.0-M2"
+      val kalix = "1.0.2"
       val commonsIo = "2.8.0"
       val kiama = "2.4.0"
       val logback = "1.2.3"

codegen/js-gen-cli/src/it/resources/application.conf

@@ -4,5 +4,5 @@ kalix-npm-js {
 }
 
 kalix-proxy {
-    image = "gcr.io/kalix-public/kalix-proxy:1.0.0-M2"
+    image = "gcr.io/kalix-public/kalix-proxy:1.0.2"
 }

docs/src/modules/javascript/examples/action/src/action.ts

@@ -37,7 +37,7 @@ function processUnary(request: Request): replies.Reply {
 }
 
 function processStreamedIn(context: Action.StreamedInContext) {
-  let reply = replies.noReply();
+  let reply = replies.emptyReply();
   context.on("data", request => {
     const replyForThisRequest = createReplyForGroup(request.groups[0]);
     if (!replyForThisRequest.isEmpty()) {
@@ -82,7 +82,7 @@ function createReplies(request: Request): replies.Reply[] {
 }
 
 function createReplyForGroup(group: ProcessGroup): replies.Reply {
-  let reply = replies.noReply();
+  let reply = replies.emptyReply();
   group.steps?.forEach(step => {
     if (step.reply) {
       reply = replies.message(Response.create({ message: step.reply.message }));

npm-js/create-kalix-entity/template/base/docker-compose.yml

@@ -1,7 +1,7 @@
 version: "3"
 services:
   kalix-proxy:
-    image: gcr.io/kalix-public/kalix-proxy:1.0.0-M2
+    image: gcr.io/kalix-public/kalix-proxy:1.0.2
     command: -Dconfig.resource=dev-mode.conf -kalix.proxy.eventing.support=google-pubsub-emulator
     ports:
       - "9000:9000"

samples/js/js-customer-registry/customer-event-sourced-entity.js

@@ -57,15 +57,15 @@ entity.setBehavior(state => {
 function create(customer, customerState, ctx) {
   let domainCustomer = apiCustomerToCustomerState(customer)
   ctx.emit(domain.CustomerCreated.create({customer: domainCustomer}))
-  return replies.noReply()
+  return replies.emptyReply()
 }
 
 function changeName(changeNameRequest, customerState, ctx) {
   if (!customerState.name && !customer.email) {
     return replies.failure("Customer must be created before name can be changed.")
   } else {
     ctx.emit(domain.CustomerNameChanged.create({ newName: changeNameRequest.newName }))
-    return replies.noReply()
+    return replies.emptyReply()
   }
 }
 
@@ -74,7 +74,7 @@ function changeAddress(changeAddressRequest, customerState, ctx) {
     return replies.failure("Customer must be created before address can be changed.")
   } else {
     ctx.emit(domain.CustomerAddressChanged.create({ newAddress: changeAddressRequest.newAddress }))
-    return replies.noReply()
+    return replies.emptyReply()
   }
 }
 

samples/js/js-customer-registry/customer-value-entity.js

@@ -45,7 +45,7 @@ entity.setCommandHandlers({
 function create(customer, customerState, ctx) {
   let domainCustomer = apiCustomerToCustomerState(customer)
   ctx.updateState(domainCustomer)
-  return replies.noReply()
+  return replies.emptyReply()
 }
 
 function changeName(changeNameRequest, customerState, ctx) {
@@ -54,7 +54,7 @@ function changeName(changeNameRequest, customerState, ctx) {
   } else {
     customerState.name = changeNameRequest.newName
     ctx.updateState(customerState)
-    return replies.noReply()
+    return replies.emptyReply()
   }
 }
 
@@ -64,7 +64,7 @@ function changeAddress(changeAddressRequest, customerState, ctx) {
   } else {
     customerState.address = changeAddressRequest.newAddress
     ctx.updateState(customerState)
-    return replies.noReply()
+    return replies.emptyReply()
   }
 }
 

samples/js/js-doc-snippets/docker-compose.yml

@@ -1,7 +1,7 @@
 version: "3"
 services:
   kalix-proxy:
-    image: gcr.io/kalix-public/kalix-proxy:1.0.0-M2
+    image: gcr.io/kalix-public/kalix-proxy:1.0.2
     command: -Dconfig.resource=dev-mode.conf -Dkalix.proxy.eventing.support=google-pubsub-emulator
     ports:
       - "9000:9000"

samples/js/js-doc-snippets/src/myservice.js

@@ -43,7 +43,7 @@ const action = new Action(
 action.commandHandlers = {
   async Consume(request) {
     console.log(request);
-    return replies.noReply();
+    return replies.emptyReply();
   },
   // tag::produce[]
   async Produce(request) {

samples/js/js-eventsourced-shopping-cart/docker-compose.yml

@@ -1,7 +1,7 @@
 version: "3"
 services:
   kalix-proxy:
-    image: gcr.io/kalix-public/kalix-proxy:1.0.0-M2
+    image: gcr.io/kalix-public/kalix-proxy:1.0.2
     command: -Dconfig.resource=dev-mode.conf -Dkalix.proxy.eventing.support=google-pubsub-emulator
     ports:
       - "9000:9000"

samples/js/js-replicated-entity-shopping-cart/docker-compose.yml

@@ -1,7 +1,7 @@
 version: "3"
 services:
   kalix-proxy:
-    image: gcr.io/kalix-public/kalix-proxy:1.0.0-M2
+    image: gcr.io/kalix-public/kalix-proxy:1.0.2
     command: -Dconfig.resource=dev-mode.conf -Dkalix.proxy.eventing.support=google-pubsub-emulator
     ports:
       - "9000:9000"

samples/js/js-valueentity-shopping-cart/docker-compose.yml

@@ -1,7 +1,7 @@
 version: "3"
 services:
   kalix-proxy:
-    image: gcr.io/kalix-public/kalix-proxy:1.0.0-M2
+    image: gcr.io/kalix-public/kalix-proxy:1.0.2
     command: -Dconfig.resource=dev-mode.conf -Dkalix.proxy.eventing.support=google-pubsub-emulator
     ports:
       - "9000:9000"

samples/js/valueentity-counter/docker-compose.yml

@@ -1,7 +1,7 @@
 version: "3"
 services:
   kalix-proxy:
-    image: gcr.io/kalix-public/kalix-proxy:1.0.0-M2
+    image: gcr.io/kalix-public/kalix-proxy:1.0.2
     command: -Dconfig.resource=dev-mode.conf -Dkalix.proxy.eventing.support=google-pubsub-emulator
     ports:
       - "9000:9000"

samples/ts/ts-eventsourced-shopping-cart/docker-compose.yml

@@ -1,7 +1,7 @@
 version: "3"
 services:
   kalix-proxy:
-    image: gcr.io/kalix-public/kalix-proxy:1.0.0-M2
+    image: gcr.io/kalix-public/kalix-proxy:1.0.2
     command: -Dconfig.resource=dev-mode.conf -Dkalix.proxy.eventing.support=google-pubsub-emulator
     ports:
       - "9000:9000"

samples/ts/ts-replicated-entity-shopping-cart/docker-compose.yml

@@ -1,7 +1,7 @@
 version: "3"
 services:
   kalix-proxy:
-    image: gcr.io/kalix-public/kalix-proxy:1.0.0-M2
+    image: gcr.io/kalix-public/kalix-proxy:1.0.2
     command: -Dconfig.resource=dev-mode.conf -Dkalix.proxy.eventing.support=google-pubsub-emulator
     ports:
       - "9000:9000"

samples/ts/ts-valueentity-counter/docker-compose.yml

@@ -1,7 +1,7 @@
 version: "3"
 services:
   kalix-proxy:
-    image: gcr.io/kalix-public/kalix-proxy:1.0.0-M2
+    image: gcr.io/kalix-public/kalix-proxy:1.0.2
     command: -Dconfig.resource=dev-mode.conf -Dkalix.proxy.eventing.support=google-pubsub-emulator
     ports:
       - "9000:9000"

samples/ts/ts-valueentity-shopping-cart/docker-compose.yml

@@ -1,7 +1,7 @@
 version: "3"
 services:
   kalix-proxy:
-    image: gcr.io/kalix-public/kalix-proxy:1.0.0-M2
+    image: gcr.io/kalix-public/kalix-proxy:1.0.2
     command: -Dconfig.resource=dev-mode.conf -Dkalix.proxy.eventing.support=google-pubsub-emulator
     ports:
       - "9000:9000"

sdk/config.json

@@ -1,3 +1,3 @@
 {
-  "frameworkVersion": "1.0.0-M2"
+  "frameworkVersion": "1.0.2"
 }

sdk/src/action-support.ts

@@ -262,7 +262,7 @@ class ActionHandler {
       );
     } else {
       // no reply
-      ctx.write(null);
+      ctx.write(reply);
     }
   }
 

sdk/src/reply.jsdoc

@@ -167,7 +167,7 @@
  *
  * This may be useful for emitting effects without sending a message.
  *
- * @function module:kalix.replies~noReply
+ * @function module:kalix.replies~emptyReply
  * @return {module:kalix.replies.Reply} An empty reply.
  */
 

sdk/src/reply.ts

@@ -241,11 +241,11 @@ export function failure(description: string, status?: GrpcStatus): Reply {
 /**
  * Create a reply that contains neither a message nor a forward nor a failure.
  *
- * This may be useful for emitting effects without sending a message.
+ * This may be useful for emitting effects while sending an empty message.
  *
  * @returns an empty reply
  */
-export function noReply(): Reply {
+export function emptyReply(): Reply {
   return new Reply();
 }
 

sdk/test/reply.test.ts

@@ -22,7 +22,7 @@ import { GrpcStatus } from '../src/kalix';
 
 describe('Replies', () => {
   it('should create an empty Reply', () => {
-    const reply = replies.noReply();
+    const reply = replies.emptyReply();
 
     expect(reply.isEmpty()).to.be.true;
     expect(reply.getMethod()).to.be.undefined;

tck/src/action.ts

@@ -38,7 +38,7 @@ function processUnary(request: Request) {
 }
 
 function processStreamedIn(context: Action.StreamedInContext) {
-  let reply = replies.noReply();
+  let reply = replies.emptyReply();
   context.on('data', (request) => {
     const replyForThisRequest = createReplyForGroup(request.groups[0]);
     if (!replyForThisRequest.isEmpty()) {
@@ -81,7 +81,7 @@ function createReplies(request: Request): replies.Reply[] {
 }
 
 function createReplyForGroup(group: IProcessGroup): replies.Reply {
-  let reply = replies.noReply();
+  let reply = replies.emptyReply();
   group.steps?.forEach((step) => {
     if (step.reply) {
       reply = replies.message(Response.create({ message: step.reply.message }));