chore(working-with-kafka): touch conf files

orbitalapi · Feb 26, 2025 · 282ef67 · 282ef67
1 parent 3326e19
commit 282ef67
Show file tree

Hide file tree

Showing 7 changed files with 17 additions and 3 deletions.
diff --git a/csv-to-api/taxi.conf b/csv-to-api/taxi.conf
@@ -1,7 +1,6 @@
 name: com.acme/csv-to-api
 version: 0.1.0
 sourceRoot: src/
-additionalSources: {}
 additionalSources: {
    "@orbital/config" : "orbital/config/*.conf",
    "@orbital/nebula" : "orbital/nebula/*.nebula.kts"

diff --git a/large-file-feed/orbital/nebula/stack.nebula.kts b/large-file-feed/orbital/nebula/stack.nebula.kts
@@ -15,6 +15,7 @@ data class Warehouse(
 )
 
 
+
 val warehouseTestData = listOf(
    Warehouse(
       name = "UK-LONDON-01",

diff --git a/working-with-kafka/orbital/config/connections.conf b/working-with-kafka/orbital/config/connections.conf
@@ -13,3 +13,4 @@ hazelcast {
       addresses = ["localhost:"${NEBULA_HAZELCAST_PORT}]
    }
 }
+
diff --git a/working-with-kafka/orbital/config/services.conf b/working-with-kafka/orbital/config/services.conf
@@ -3,3 +3,4 @@ services {
       url="http://localhost:"${NEBULA_HTTP_PORT}""
    }
 }
+
diff --git a/working-with-kafka/orbital/nebula/stack.nebula.kts b/working-with-kafka/orbital/nebula/stack.nebula.kts
@@ -114,7 +114,6 @@ stack {
 
       val activeDeliveries = ConcurrentHashMap<String, DeliveryState>()
 
-
       // Generate new orders
       producer("2000ms".duration(), "orders") {
          jsonMessage {

diff --git a/working-with-kafka/src/customer.api.taxi b/working-with-kafka/src/customer.api.taxi
@@ -13,5 +13,5 @@ closed model Customer {
 
 service CustomerService {
    @HttpOperation(url="http://customerApi/customers/{customerId}", method = "GET")
-   operation findCustomer(@PathVariable("customerId") customerId: CustomerId): Customer
+   operation findCustomer(@PathVariable("customerId") customerId: CustomerId): Customer(...)
 }
diff --git a/working-with-kafka/src/orderStream.taxi b/working-with-kafka/src/orderStream.taxi
@@ -0,0 +1,13 @@
+import com.orbitEats.delivery.DeliveryUpdate
+
+@HttpOperation(method = "GET", url = "/api/q/orders")
+query orderStream {
+   stream { OrderPlaced & DeliveryUpdate } as {
+    orderId,
+    items,
+    status,
+    timestamp,
+    currentLocation,
+    customerName: CustomerName
+}[]
+}
-Original file line number
+Diff line change
@@ Expand Up / @@ -15,6 +15,7 @@ data class Warehouse( @@
     )
     val warehouseTestData = listOf(
        Warehouse(
           name = "UK-LONDON-01",
@@ Expand Down @@
Original file line number	Diff line number	Diff line change
Expand Up		@@ -13,3 +13,4 @@ hazelcast {
		addresses = ["localhost:"${NEBULA_HAZELCAST_PORT}]
		}
		}
Original file line number	Diff line number	Diff line change
Expand Up		@@ -3,3 +3,4 @@ services {
		url="http://localhost:"${NEBULA_HTTP_PORT}""
		}
		}