Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
26 commits
Select commit Hold shift + click to select a range
14c1b46
mongocdc prototype functionality
AVMatthews Apr 9, 2025
a16c7db
merged main
AVMatthews Apr 9, 2025
56b1bf9
first round of linting and reorganization of the server
AVMatthews Apr 10, 2025
dd08d56
just mongo framework server
AVMatthews Apr 10, 2025
a4e9f0f
fix build issue
AVMatthews Apr 10, 2025
1b29ad2
fix file changes
AVMatthews Apr 10, 2025
e30e019
fix file changes
AVMatthews Apr 10, 2025
e37d2d2
fix package.json
AVMatthews Apr 10, 2025
655024b
build: update package-lock.json to include socket.io and related depe…
junhaoliao Apr 10, 2025
2945389
chore: move MongoReplicaServerPlugin and related source files into a …
junhaoliao Apr 10, 2025
e64a375
fix(app): Register MongoReplicaServer only if not in test environment.
junhaoliao Apr 10, 2025
cc24dd2
fix: instead of returning callback(), invoke the callback then return.
junhaoliao Apr 10, 2025
98643f0
fix: update CollectionInitPayload type definition to inline object st…
junhaoliao Apr 11, 2025
61fb259
refactor: use # for labelling private properties.
junhaoliao Apr 11, 2025
8626745
reorder
junhaoliao Apr 11, 2025
738f4a4
refactor: define event handler types and update listener signatures
junhaoliao Apr 11, 2025
f8d58b6
refactor: update event handler types and listener implementations for…
junhaoliao Apr 11, 2025
e1f3f55
refactor: remove unused collection::find::toArray listener and its ha…
junhaoliao Apr 11, 2025
d9e409e
refactor: change #mongoDb to readonly for better immutability
junhaoliao Apr 11, 2025
5dc6052
Documentation and add subscriber count the watcher map
AVMatthews Apr 12, 2025
c7c49ba
linting
AVMatthews Apr 12, 2025
fdf6286
reorganize, debounce updates, enable multiple finds per collection
AVMatthews Apr 21, 2025
440e459
Fix live updated from watcher and improve unsubscribe process
AVMatthews Apr 26, 2025
24d2bdc
refactor and fix missing updates
AVMatthews Apr 30, 2025
d56bd8a
linting fix
AVMatthews Apr 30, 2025
a0377cf
remove duplicate waatcher listener
AVMatthews Apr 30, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
282 changes: 279 additions & 3 deletions components/log-viewer-webui/server/package-lock.json

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

1 change: 1 addition & 0 deletions components/log-viewer-webui/server/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,7 @@
"fastify-plugin": "^5.0.1",
"http-status-codes": "^2.3.0",
"pino-pretty": "^13.0.0",
"socket.io": "^4.8.1",
"typescript": "~5.7.3"
},
"devDependencies": {
Expand Down
6 changes: 6 additions & 0 deletions components/log-viewer-webui/server/src/app.ts

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We should probably register await fastify.register(fastifySocketIO);, and use their existing plugin, instead of setting up socket.io with fastify.server

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

For now we will do our own registration, since https://www.npmjs.com/package/fastify-socket.io does not support Fastify v5 or above.

Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@ import {

import settings from "../settings.json" with {type: "json"};
import DbManager from "./plugins/DbManager.js";
import MongoSocketIoServer from "./plugins/MongoSocketIoServer/index.js";
import S3Manager from "./plugins/S3Manager.js";
import exampleRoutes from "./routes/example.js";
import queryRoutes from "./routes/query.js";
Expand Down Expand Up @@ -54,6 +55,11 @@ const app = async ({
},
});
await server.register(S3Manager, {region: settings.StreamFilesS3Region});
await server.register(MongoSocketIoServer, {
host: settings.MongoDbHost,
port: settings.MongoDbPort,
database: settings.MongoDbName,
});
}

await server.register(staticRoutes);
Expand Down
Loading