nandi.uk
This repository has no description
index url from connections
author
Wesley Finck
date
(Apr 13, 2026, 5:48 PM -0700)
commit
8a9565a2
8a9565a285dab5cd46b301fd78ff5accee7a05ab
parent
9f9f6702
9f9f67023ad7f0f0e27467daafe8bdd16d56ca20
+81
-3
-1
src/modules/search/application/eventHandlers/CardAddedToLibraryEventHandler.ts
-1
src/modules/search/application/eventHandlers/CardAddedToLibraryEventHandler.ts
+69
src/modules/search/application/eventHandlers/ConnectionCreatedEventHandler.ts
+69
src/modules/search/application/eventHandlers/ConnectionCreatedEventHandler.ts
···
1
+
import { ConnectionCreatedEvent } from '../../../cards/domain/events/ConnectionCreatedEvent';
2
+
import { IEventHandler } from '../../../../shared/application/events/IEventSubscriber';
3
+
import { Result, ok } from '../../../../shared/core/Result';
4
+
import { IndexUrlForSearchUseCase } from '../useCases/commands/IndexUrlForSearchUseCase';
5
+
import { IConnectionRepository } from '../../../cards/domain/IConnectionRepository';
6
+
7
+
export class ConnectionCreatedEventHandler
8
+
implements IEventHandler<ConnectionCreatedEvent>
9
+
{
10
+
constructor(
11
+
private indexUrlForSearchUseCase: IndexUrlForSearchUseCase,
12
+
private connectionRepository: IConnectionRepository,
13
+
) {}
14
+
15
+
async handle(event: ConnectionCreatedEvent): Promise<Result<void>> {
16
+
// Get connection details
17
+
const connectionResult = await this.connectionRepository.findById(
18
+
event.connectionId,
19
+
);
20
+
if (connectionResult.isErr()) {
21
+
console.error(
22
+
'Failed to find connection for search indexing:',
23
+
connectionResult.error,
24
+
);
25
+
return ok(undefined); // Don't fail the event processing
26
+
}
27
+
28
+
const connection = connectionResult.value;
29
+
if (!connection) {
30
+
console.warn(
31
+
'Connection not found for search indexing:',
32
+
event.connectionId.getStringValue(),
33
+
);
34
+
return ok(undefined);
35
+
}
36
+
37
+
// Index source URL if it exists
38
+
if (connection.source.url) {
39
+
const sourceIndexResult = await this.indexUrlForSearchUseCase.execute({
40
+
url: connection.source.url.value,
41
+
});
42
+
43
+
if (sourceIndexResult.isErr()) {
44
+
console.error(
45
+
'Failed to index source URL for search:',
46
+
sourceIndexResult.error,
47
+
);
48
+
// Don't fail the event processing - search indexing is not critical
49
+
}
50
+
}
51
+
52
+
// Index target URL if it exists
53
+
if (connection.target.url) {
54
+
const targetIndexResult = await this.indexUrlForSearchUseCase.execute({
55
+
url: connection.target.url.value,
56
+
});
57
+
58
+
if (targetIndexResult.isErr()) {
59
+
console.error(
60
+
'Failed to index target URL for search:',
61
+
targetIndexResult.error,
62
+
);
63
+
// Don't fail the event processing - search indexing is not critical
64
+
}
65
+
}
66
+
67
+
return ok(undefined);
68
+
}
69
+
}