Address feedback

typescript/food-ordering/.gitignore

@@ -0,0 +1,22 @@
+*/.idea/*
+*/dist
+*/node_modules
+*/services/proto/buf.lock
+*/services/src/generated
+
+# dependencies
+*/.pnp
+*/.pnp.js
+
+# testing
+/coverage
+
+# production
+*/build
+
+*/npm-debug.log*
+*/yarn-debug.log*
+*/yarn-error.log*
+
+# Local Netlify folder
+*/.netlify

typescript/food-ordering/app/package.json

@@ -10,7 +10,7 @@
     "bundle": "esbuild src/restate-app/app.ts --bundle --minify --sourcemap --platform=node --target=es2020 --outfile=dist/index.js",
     "postbundle": "cd dist && zip -r index.zip index.js*",
     "app": "node ./dist/app/app.js",
-    "app": "node ./dist/restaurant/server.js",
+    "restaurant-app": "node ./dist/restaurant/server.js",
     "app-dev": "ts-node-dev --watch src --respawn --transpile-only src/restate-app/app.ts"
   },
   "dependencies": {

typescript/food-ordering/app/src/restate-app/app.ts

@@ -1,7 +1,7 @@
 import * as restate from "@restatedev/restate-sdk";
-import * as driverDigitalTwin from "./driver-digital-twin";
+import * as driverDigitalTwin from "./driver_digital_twin";
 import * as driverDeliveryMatcher from "./driver_delivery_matcher";
-import * as deliveryManager from "./delivery-manager";
+import * as deliveryManager from "./delivery_manager";
 import * as orderWorkflow from "./order_workflow";
 import * as orderstatus from "./order_status_service";
 import * as driverMobileAppSimulator from "./external/driver_mobile_app_sim";

typescript/food-ordering/app/src/restate-app/clients/kafka-publisher.ts → typescript/food-ordering/app/src/restate-app/clients/kafka_publisher.ts

@@ -6,13 +6,13 @@ const KAFKA_BOOTSTRAP_SERVERS = process.env.KAFKA_BOOTSTRAP_SERVERS || "localhos
 const KAFKA_CONFIG: KafkaConfig = { brokers: [KAFKA_BOOTSTRAP_SERVERS] };
 const KAFKA_TOPIC = "driver-updates";
 
-export class KafkaPublisher {
+export class Kafka_publisher {
 
   private readonly kafka = new Kafka(KAFKA_CONFIG);
   private readonly producer = this.kafka.producer();
   private connected = false;
 
-  public async send(_ctx: restate.RpcContext, driverId: string, location: Location) {
+  public async send(driverId: string, location: Location) {
     if (!this.connected) {
       console.info("Connecting Kafka producer");
       await this.producer.connect();
@@ -26,6 +26,6 @@ export class KafkaPublisher {
   }
 }
 
-export function getPublisher(): KafkaPublisher {
-    return new KafkaPublisher();
+export function getPublisher(): Kafka_publisher {
+    return new Kafka_publisher();
 }

typescript/food-ordering/app/src/restate-app/delivery-manager.ts → typescript/food-ordering/app/src/restate-app/delivery_manager.ts

@@ -1,5 +1,5 @@
 import * as restate from "@restatedev/restate-sdk";
-import * as driverDigitalTwin from "./driver-digital-twin";
+import * as driverDigitalTwin from "./driver_digital_twin";
 import * as driverDeliveryMatcher from "./driver_delivery_matcher";
 import * as geo from "./utils/geo";
 import {DEMO_REGION, Location, DeliveryInformation, OrderAndPromise, Status} from "./types/types";

typescript/food-ordering/app/src/restate-app/driver-digital-twin.ts → typescript/food-ordering/app/src/restate-app/driver_digital_twin.ts

@@ -1,6 +1,6 @@
 import * as restate from "@restatedev/restate-sdk";
 import * as driverDeliveryMatcher from "./driver_delivery_matcher";
-import * as deliveryManager from "./delivery-manager";
+import * as deliveryManager from "./delivery_manager";
 import {DeliveryRequest, DriverStatus, Location} from "./types/types";
 
 /**

typescript/food-ordering/app/src/restate-app/external/driver_mobile_app_sim.ts

@@ -10,10 +10,10 @@
  */
 
 import * as restate from "@restatedev/restate-sdk";
-import * as driverDigitalTwin from "../driver-digital-twin";
+import * as driverDigitalTwin from "../driver_digital_twin";
 import * as geo from "../utils/geo";
 import {DEMO_REGION, Location, DeliveryState} from "../types/types";
-import { getPublisher } from "../clients/kafka-publisher";
+import { getPublisher } from "../clients/kafka_publisher";
 import {updateLocation} from "./driver_mobile_app_sim_utils";
 
 /**
@@ -47,7 +47,7 @@ async function startDriver(ctx: restate.RpcContext, driverId: string) {
 
   const location = await ctx.sideEffect(async () => geo.randomLocation());
   ctx.set(CURRENT_LOCATION, location);
-  await kafkaPublisher.send(ctx, driverId, location);
+  await kafkaPublisher.send(driverId, location);
 
   ctx.send(driverDigitalTwin.service).setDriverAvailable(driverId, DEMO_REGION);
   ctx.send(service).pollForWork(driverId);
@@ -86,7 +86,7 @@ async function move(ctx: restate.RpcContext, driverId: string) {
   const { newLocation, arrived } = updateLocation(currentLocation, nextTarget);
 
   ctx.set(CURRENT_LOCATION, newLocation);
-  await kafkaPublisher.send(ctx, driverId, currentLocation);
+  await kafkaPublisher.send(driverId, currentLocation);
 
   if (arrived) {
     if (assignedDelivery.orderPickedUp) {

typescript/food-ordering/app/src/restate-app/order_workflow.ts

@@ -1,5 +1,5 @@
 import * as restate from "@restatedev/restate-sdk";
-import * as deliveryManager from "./delivery-manager";
+import * as deliveryManager from "./delivery_manager";
 import {Order, Status} from "./types/types";
 import * as orderstatus from "./order_status_service";
 import { completed } from "./utils/utils";

typescript/food-ordering/docker-compose.yml

@@ -80,7 +80,7 @@ services:
       - RESTATE_RUNTIME_ENDPOINT=http://runtime:8080
 
   runtime:
-    image: docker.io/restatedev/restate:latest
+    image: docker.io/restatedev/restate:0.7
     depends_on:
       - restate_app
       - restaurant_pos