← Back to Projects
This project is a sub-project of BSDFlow
Query
Mentored by: Kaltura
Query - A multi-tenant, dynamic management system for entities, events, workflows, and real-time operations.
React
NestJS
.NET Core
Kafka
PostgreSQL
Redis
WebSocket
SignalR
Microservices
LLM Integration
Description
Query sub-project of BSDFlow. A full-scale microservices-based management platform supporting dynamic entities, groups, processes, and events. Includes multi-tenant table architecture, generic Kafka handlers with correlation-based async RPC, Redis caching for performance, real-time updates via WebSocket & SignalR, integration with LLMs, Excel watchers, advanced validation using Strategy Pattern, RBAC permissions, GIS mapping, smart search with PostgreSQL FTS+GIN+Trigrams, and a complete load-testing engine. Enables organizations to define custom workflows, attach documents, track participants, and manage system-wide behaviors across distributed services.
Team Members
Cohort: Backend Bootcamp 2025 (Backend)
Responsibilities:
Built the Event Trends read-model, including flattening and aggregating millions of events into a fast analytical structure used for dashboards and search.
I designed and implemented a hybrid incremental aggregation, which combines real-time updates with once-daily recalculation to ensure high accuracy and performance.
Developed and optimized SQL queries for daily and process-level trend analytics, significantly improving query performance.
Created REST and GraphQL endpoints in the Query-API to expose analytical data efficiently and eliminate over-fetching and under-fetching.
Integrated the read-model into the central Gateway service, ensuring consistent API responses across the entire system.
Implemented process-name enrichment inside the projection layer to support advanced filtering on processes.
Built a dynamic dashboard to display event and process trend data.
Led testing and validation for the entire aggregation pipeline, ensuring correct calculations for opened, closed, and cumulative events.
...and more contributions not listed here
Responsibilities:
Developed an advanced service that listens to Kafka and processes data in a generic, fast, and reliable manner, ensuring high consistency and efficiency.
uilt a dedicated Projection (DOCUMENTCOUNTPER_EVENT) aggregating document statuses per event.
Set up a fully operational OpenSearch + Dashboards environment in Docker, indexing events from the Read Model with dynamic initial and delta loading.
Developed a robust search API with fuzzy matching, accompanied by thorough documentation and performance tests, ensuring a reliable and fast user experience.
Implemented automated Code Coverage measurement within the CI pipeline, enforcing a minimum threshold of 70% so that any PR below the standard cannot be merged, guaranteeing optimal code quality.
Integrated the read-model into the central Gateway service to ensure consistent and reliable API responses across the entire system.
...and more contributions not listed here
Responsibilities:
Designed ana set-up a read-only Read Model in C# and PostgreSQL (CQRS) database with projection schemas for optimized query performance.
Exposing Query API (REST + GraphQL) via NestJS service. Done research on automatic table segregation for speed improvement.
Developed an E2E Dynamic Query Builder Engine (Registry → Planner → Builder → Executor) for safe in the C# project of the ReadModel, parameterized SQL generation preventing SQL injection. Participated in design planning – and in performance measurement. All development was done on Dockers using Dockerfiles and DockerCompose.
Reasearch: Tree-Based Architecture (Composite / AST); Powerful but operationally expensive → Switched to Registry → Planner → Builder, a cleaner, predictable, validated pipeline ,and System-specific.
Implementing the UI and integrating with the gateway for my task of dynamic-query-engine and also integrating with Kafka with the team responsible for the entities in the system. Which required a comprehensive system understanding...
...and more contributions not listed here
Responsibilities:
Built a real-time Nest.js microservice that streamed external HTTP API data into Kafka, powering high-volume, event-driven workflows.
Implemented the backend and UI layers of the Saved Reports module, enabling users to create, store, and retrieve report configurations, while integrating with the team’s dynamic query logic.
Improved system performance by ~5× through SQL optimization, flattening JSONB fields into indexed relational structures, and analyzing execution plans to eliminate bottlenecks.
Implemented a full API security layer using Gateway routing combined with Docker private networks, ensuring that internal services and the database remain completely isolated from external access.
Maintained and enhanced a full Docker Compose environment (services, PostgreSQL, Kafka), ensuring consistent development workflows and smooth onboarding across teams.
Developed unit and integration tests across multiple system components, improving overall reliability and supporting stable CI/CD pipelines.
Built a real-time Nest.js microservice that streamed external HTTP API data into Kafka, powering high-volume, event-driven workflows.
...and more contributions not listed here