Create vin-decode.js

drivly · Aug 23, 2023 · d4ebac9 · d4ebac9
1 parent a61dc9e
commit d4ebac9
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/examples/vin-decode.js b/examples/vin-decode.js
@@ -0,0 +1,12 @@
+import { QueueConsumer } from 'kafka.do'
+
+export default QueueConsumer({
+  async queue(batch, env, ctx) {
+    for (const message of batch.messages) {
+      const { vin, nextQueue } = message
+      // TODO: get this `decodeVIN` method implemented
+      const { squishVIN, year, make, model, trim, style } = await decodeVIN(vin)
+      env[nextQueue].send({ vin, squishVIN, year, make, model, trim, style })
+    }
+  },
+})