cosmik.network
A social knowledge tool for researchers built on ATProto
refactor: introduce IProcess interface and separate process implementations
Co-authored-by: aider (anthropic/claude-sonnet-4-20250514) <aider@aider.chat>
+10
-36
src/index.ts
+10
-36
src/index.ts
···
1
-
import { createExpressApp } from './shared/infrastructure/http/app';
2
-
import { DatabaseFactory } from './shared/infrastructure/database/DatabaseFactory';
3
1
import { configService } from './shared/infrastructure/config';
4
-
import { startFeedWorker } from './workers/feed-worker';
5
-
6
-
async function startServer() {
7
-
// Get configuration
8
-
const config = configService.get();
9
-
10
-
const useMockRepos = process.env.USE_MOCK_REPOS === 'true';
11
-
if (!useMockRepos) {
12
-
// Create database connection with config
13
-
const db = DatabaseFactory.createConnection(
14
-
configService.getDatabaseConfig(),
15
-
);
16
-
17
-
// Run migrations
18
-
try {
19
-
await DatabaseFactory.runMigrations(db);
20
-
console.log('Database migrations completed successfully');
21
-
} catch (error) {
22
-
console.error('Error running database migrations:', error);
23
-
process.exit(1);
24
-
}
25
-
}
2
+
import { AppProcess } from './shared/infrastructure/processes/AppProcess';
3
+
import { FeedWorkerProcess } from './shared/infrastructure/processes/FeedWorkerProcess';
26
4
27
-
// Create and start Express app with config
28
-
const app = createExpressApp(configService);
29
-
const PORT = config.server.port;
30
-
const HOST = config.server.host;
5
+
async function main() {
6
+
const appProcess = new AppProcess(configService);
31
7
32
-
app.listen(PORT, HOST, () => {
33
-
console.log(
34
-
`Server running on http://${HOST}:${PORT} in ${config.environment} environment`,
35
-
);
36
-
});
8
+
// Start the app process
9
+
await appProcess.start();
37
10
38
11
// Start feed worker in the same process if using in-memory events
39
12
const useInMemoryEvents = process.env.USE_IN_MEMORY_EVENTS === 'true';
40
13
if (useInMemoryEvents) {
41
14
console.log('Starting feed worker in the same process...');
42
-
await startFeedWorker();
15
+
const feedWorkerProcess = new FeedWorkerProcess(configService);
16
+
await feedWorkerProcess.start();
43
17
}
44
18
}
45
19
46
-
startServer().catch((error) => {
47
-
console.error('Failed to start server:', error);
20
+
main().catch((error) => {
21
+
console.error('Failed to start application:', error);
48
22
process.exit(1);
49
23
});
+6
-74
src/workers/feed-worker.ts
+6
-74
src/workers/feed-worker.ts
···
1
1
import { EnvironmentConfigService } from '../shared/infrastructure/config/EnvironmentConfigService';
2
-
import { RepositoryFactory } from '../shared/infrastructure/http/factories/RepositoryFactory';
3
-
import { ServiceFactory } from '../shared/infrastructure/http/factories/ServiceFactory';
4
-
import { UseCaseFactory } from '../shared/infrastructure/http/factories/UseCaseFactory';
5
-
import { CardAddedToLibraryEventHandler } from '../modules/feeds/application/eventHandlers/CardAddedToLibraryEventHandler';
6
-
import { CardAddedToCollectionEventHandler } from '../modules/feeds/application/eventHandlers/CardAddedToCollectionEventHandler';
7
-
import { CardCollectionSaga } from '../modules/feeds/application/sagas/CardCollectionSaga';
8
-
import { QueueNames } from '../shared/infrastructure/events/QueueConfig';
9
-
import { EventNames } from '../shared/infrastructure/events/EventConfig';
10
-
11
-
export async function startFeedWorker() {
12
-
console.log('Starting feed worker...');
2
+
import { FeedWorkerProcess } from '../shared/infrastructure/processes/FeedWorkerProcess';
13
3
4
+
async function main() {
14
5
const configService = new EnvironmentConfigService();
15
-
16
-
// Create dependencies using factories
17
-
const repositories = RepositoryFactory.create(configService);
18
-
const services = ServiceFactory.createForWorker(configService, repositories);
19
-
const useCases = UseCaseFactory.createForWorker(repositories, services);
20
-
21
-
// Test Redis connection (only if using Redis)
22
-
if (services.redisConnection) {
23
-
try {
24
-
await services.redisConnection.ping();
25
-
console.log('Connected to Redis successfully');
26
-
} catch (error) {
27
-
console.error('Failed to connect to Redis:', error);
28
-
process.exit(1);
29
-
}
30
-
} else {
31
-
console.log('Using in-memory event system');
32
-
}
33
-
34
-
// Create subscriber for feeds queue
35
-
const eventSubscriber = services.createEventSubscriber(QueueNames.FEEDS);
36
-
37
-
// Create the saga with proper dependencies
38
-
const cardCollectionSaga = new CardCollectionSaga(
39
-
useCases.addActivityToFeedUseCase,
40
-
);
41
-
42
-
// Create event handlers with the saga
43
-
const cardAddedToLibraryHandler = new CardAddedToLibraryEventHandler(
44
-
cardCollectionSaga,
45
-
);
46
-
const cardAddedToCollectionHandler = new CardAddedToCollectionEventHandler(
47
-
cardCollectionSaga,
48
-
);
49
-
50
-
// Register handlers
51
-
await eventSubscriber.subscribe(
52
-
EventNames.CARD_ADDED_TO_LIBRARY,
53
-
cardAddedToLibraryHandler,
54
-
);
55
-
56
-
await eventSubscriber.subscribe(
57
-
EventNames.CARD_ADDED_TO_COLLECTION,
58
-
cardAddedToCollectionHandler,
59
-
);
60
-
61
-
// Start the worker
62
-
await eventSubscriber.start();
63
-
64
-
console.log('Feed worker started and listening for events...');
65
-
66
-
// Graceful shutdown
67
-
const shutdown = async () => {
68
-
console.log('Shutting down feed worker...');
69
-
await eventSubscriber.stop();
70
-
if (services.redisConnection) {
71
-
await services.redisConnection.quit();
72
-
}
73
-
process.exit(0);
74
-
};
6
+
const feedWorkerProcess = new FeedWorkerProcess(configService);
75
7
76
-
process.on('SIGTERM', shutdown);
77
-
process.on('SIGINT', shutdown);
8
+
await feedWorkerProcess.start();
78
9
}
10
+
79
11
if (process.env.USE_IN_MEMORY_EVENTS !== 'true') {
80
-
startFeedWorker().catch((error) => {
12
+
main().catch((error) => {
81
13
console.error('Failed to start feed worker:', error);
82
14
process.exit(1);
83
15
});