Skip to content

Commit 03a838f

Browse files
committed
fix: async in top levels
1 parent 622c5f7 commit 03a838f

File tree

3 files changed

+18
-8
lines changed

3 files changed

+18
-8
lines changed

apps/basket/src/index.ts

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,8 +41,6 @@ const app = new Elysia()
4141

4242
const port = process.env.PORT || 4000;
4343

44-
await new Promise(resolve => setTimeout(resolve, 400));
45-
4644
console.log(`Starting basket service on port ${port}`);
4745
console.log(`Basket service running on http://localhost:${port}`);
4846

apps/basket/src/lib/producer.ts

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,11 +13,17 @@ const producer = kafka.producer({
1313
});
1414

1515
let connected = false;
16-
await producer.connect();
17-
connected = true;
16+
17+
const connectProducer = async () => {
18+
if (!connected) {
19+
await producer.connect();
20+
connected = true;
21+
}
22+
};
1823

1924
export const sendEventSync = async (topic: string, event: any, key?: string) => {
2025
try {
26+
await connectProducer();
2127
await producer.send({
2228
topic,
2329
messages: [{
@@ -35,6 +41,7 @@ export const sendEventSync = async (topic: string, event: any, key?: string) =>
3541

3642
export const sendEvent = async (topic: string, event: any, key?: string) => {
3743
try {
44+
await connectProducer();
3845
producer.send({
3946
topic,
4047
messages: [{

basket.Dockerfile

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,13 @@
1-
FROM oven/bun AS build
1+
FROM oven/bun:1.3.0-debian AS build
22

33
WORKDIR /app
44

5-
# Cache packages installation
5+
RUN apt-get update && apt-get install -y \
6+
python3 \
7+
make \
8+
g++ \
9+
&& rm -rf /var/lib/apt/lists/*
10+
611
COPY package.json package.json
712
COPY apps/basket/package.json ./apps/basket/package.json
813
COPY packages/*/package.json ./packages/
@@ -21,8 +26,8 @@ RUN bun build \
2126
--minify-syntax \
2227
--target bun \
2328
--outfile server \
24-
--sourcemap \
25-
--bytecode \
29+
--sourcemap \
30+
--bytecode \
2631
./apps/basket/src/index.ts
2732

2833
FROM gcr.io/distroless/base

0 commit comments

Comments
 (0)