Skip to content

Commit

Permalink
chore: pertier
Browse files Browse the repository at this point in the history
  • Loading branch information
brent-hoover committed Jun 16, 2024
1 parent fd59d5d commit 9879d1b
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 5 deletions.
1 change: 1 addition & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@ An ultra-fast, easy-to-use framework that has "ready for the big time" features
* Plugin architecture that allows you to create and extend models and resolvers via plugins
* Role-Based auth
* Integration and e2e tests
* Event system backed by Kafka

## Features under construction
Check the GH issues for things I plan to add in the near future
Expand Down
4 changes: 2 additions & 2 deletions src/event/kafka-event-service.ts
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ class KafkaEventService {
if (message.value) {
const handlers = this.eventHandlers[topic] || [];
const parsedMessage = JSON.parse(message.value.toString());
handlers.forEach(handler => handler(parsedMessage));
handlers.forEach((handler) => handler(parsedMessage));
}
},
});
Expand All @@ -52,7 +52,7 @@ class KafkaEventService {
console.error(`Connection attempt ${i + 1} failed: ${err}`);
}
if (i === retries - 1) throw err;
await new Promise(res => setTimeout(res, 2000)); // Wait for 2 seconds before retrying
await new Promise((res) => setTimeout(res, 2000)); // Wait for 2 seconds before retrying
}
}
}
Expand Down
4 changes: 1 addition & 3 deletions src/plugins/sample-plugin/resolvers/sample-resolver.ts
Original file line number Diff line number Diff line change
Expand Up @@ -7,9 +7,7 @@ import FunctionRegistry from '../../function-registry';
@Service()
@Resolver()
export class SampleResolver {
constructor(
@Inject(() => SampleService) private readonly sampleService: SampleService
) {}
constructor(@Inject(() => SampleService) private readonly sampleService: SampleService) {}

@Query(() => [Sample])
async samples() {
Expand Down

0 comments on commit 9879d1b

Please sign in to comment.