+35

src/modules/search/infrastructure/http/controllers/GetSimilarUrlsForUrlController.ts

··· 1 1 + import { Controller } from '../../../../../shared/infrastructure/http/Controller'; 2 2 + import { Response } from 'express'; 3 3 + import { GetSimilarUrlsForUrlUseCase } from '../../../application/useCases/queries/GetSimilarUrlsForUrlUseCase'; 4 4 + import { AuthenticatedRequest } from '../../../../../shared/infrastructure/http/middleware/AuthMiddleware'; 5 5 + 6 6 + export class GetSimilarUrlsForUrlController extends Controller { 7 7 + constructor(private getSimilarUrlsForUrlUseCase: GetSimilarUrlsForUrlUseCase) { 8 8 + super(); 9 9 + } 10 10 + 11 11 + async executeImpl(req: AuthenticatedRequest, res: Response): Promise<any> { 12 12 + try { 13 13 + const { url, page, limit, threshold } = req.query; 14 14 + 15 15 + if (!url || typeof url !== 'string') { 16 16 + return this.fail(res, 'URL parameter is required'); 17 17 + } 18 18 + 19 19 + const result = await this.getSimilarUrlsForUrlUseCase.execute({ 20 20 + url, 21 21 + page: page ? parseInt(page as string) : undefined, 22 22 + limit: limit ? parseInt(limit as string) : undefined, 23 23 + threshold: threshold ? parseFloat(threshold as string) : undefined, 24 24 + }); 25 25 + 26 26 + if (result.isErr()) { 27 27 + return this.fail(res, result.error); 28 28 + } 29 29 + 30 30 + return this.ok(res, result.value); 31 31 + } catch (error: any) { 32 32 + return this.fail(res, error); 33 33 + } 34 34 + } 35 35 + }

+17

src/modules/search/infrastructure/http/routes/searchRoutes.ts

··· 1 1 + import { Router } from 'express'; 2 2 + import { GetSimilarUrlsForUrlController } from '../controllers/GetSimilarUrlsForUrlController'; 3 3 + import { AuthMiddleware } from '../../../../../shared/infrastructure/http/middleware/AuthMiddleware'; 4 4 + 5 5 + export function createSearchRoutes( 6 6 + authMiddleware: AuthMiddleware, 7 7 + getSimilarUrlsForUrlController: GetSimilarUrlsForUrlController, 8 8 + ): Router { 9 9 + const router = Router(); 10 10 + 11 11 + // GET /api/search/similar-urls - Get similar URLs for a given URL 12 12 + router.get('/similar-urls', authMiddleware.optionalAuth(), (req, res) => 13 13 + getSimilarUrlsForUrlController.execute(req, res), 14 14 + ); 15 15 + 16 16 + return router; 17 17 + }

+7

src/shared/infrastructure/http/app.ts

··· 6 6 import { createAtprotoRoutes } from '../../../modules/atproto/infrastructure/atprotoRoutes'; 7 7 import { createCardsModuleRoutes } from '../../../modules/cards/infrastructure/http/routes'; 8 8 import { createFeedRoutes } from '../../../modules/feeds/infrastructure/http/routes/feedRoutes'; 9 9 + import { createSearchRoutes } from '../../../modules/search/infrastructure/http/routes/searchRoutes'; 9 10 import { 10 11 EnvironmentConfigService, 11 12 Environment, ··· 118 119 controllers.getGlobalFeedController, 119 120 ); 120 121 122 122 + const searchRouter = createSearchRoutes( 123 123 + services.authMiddleware, 124 124 + controllers.getSimilarUrlsForUrlController, 125 125 + ); 126 126 + 121 127 // Register routes 122 128 app.use('/api/users', userRouter); 123 129 app.use('/atproto', atprotoRouter); 124 130 app.use('/api', cardsRouter); 125 131 app.use('/api/feeds', feedRouter); 132 132 + app.use('/api/search', searchRouter); 126 133 127 134 return app; 128 135 };

+6

src/shared/infrastructure/http/factories/ControllerFactory.ts

··· 19 19 import { GetCollectionPageController } from '../../../../modules/cards/infrastructure/http/controllers/GetCollectionPageController'; 20 20 import { GetMyCollectionsController } from '../../../../modules/cards/infrastructure/http/controllers/GetMyCollectionsController'; 21 21 import { GetGlobalFeedController } from '../../../../modules/feeds/infrastructure/http/controllers/GetGlobalFeedController'; 22 22 + import { GetSimilarUrlsForUrlController } from '../../../../modules/search/infrastructure/http/controllers/GetSimilarUrlsForUrlController'; 22 23 import { UseCases } from './UseCaseFactory'; 23 24 import { GetMyProfileController } from 'src/modules/cards/infrastructure/http/controllers/GetMyProfileController'; 24 25 import { GetUserProfileController } from 'src/modules/cards/infrastructure/http/controllers/GetUserProfileController'; ··· 183 184 getGlobalFeedController: new GetGlobalFeedController( 184 185 useCases.getGlobalFeedUseCase, 185 186 ), 187 187 + // Search controllers 188 188 + getSimilarUrlsForUrlController: new GetSimilarUrlsForUrlController( 189 189 + useCases.getSimilarUrlsForUrlUseCase, 190 190 + ), 186 191 }; 187 192 } 188 193 } 194 194 + import { GetSimilarUrlsForUrlController } from '../../../../modules/search/infrastructure/http/controllers/GetSimilarUrlsForUrlController';

+5

src/types/src/api/requests.ts

··· 135 135 export interface GetCollectionsForUrlParams extends PaginatedSortedParams { 136 136 url: string; 137 137 } 138 138 + 139 139 + export interface GetSimilarUrlsForUrlParams extends PaginatedSortedParams { 140 140 + url: string; 141 141 + threshold?: number; 142 142 + }

+8

src/webapp/api-client/ApiClient.ts

··· 62 62 GetNoteCardsForUrlResponse, 63 63 GetCollectionsForUrlParams, 64 64 GetCollectionsForUrlResponse, 65 65 + GetSimilarUrlsForUrlParams, 66 66 + GetSimilarUrlsForUrlResponse, 65 67 } from '@semble/types'; 66 68 67 69 // Main API Client class using composition ··· 160 162 params: GetCollectionsForUrlParams, 161 163 ): Promise<GetCollectionsForUrlResponse> { 162 164 return this.queryClient.getCollectionsForUrl(params); 165 165 + } 166 166 + 167 167 + async getSimilarUrlsForUrl( 168 168 + params: GetSimilarUrlsForUrlParams, 169 169 + ): Promise<GetSimilarUrlsForUrlResponse> { 170 170 + return this.queryClient.getSimilarUrlsForUrl(params); 163 171 } 164 172 165 173 // Card operations - delegate to CardClient

+274

src/webapp/api-client/clients/QueryClient.ts

··· 221 221 ); 222 222 } 223 223 } 224 224 + import type { 225 225 + GetUrlMetadataResponse, 226 226 + GetMyUrlCardsParams, 227 227 + GetUrlCardsParams, 228 228 + GetUrlCardsResponse, 229 229 + GetUrlCardViewResponse, 230 230 + GetLibrariesForCardResponse, 231 231 + GetProfileResponse, 232 232 + GetProfileParams, 233 233 + GetCollectionPageParams, 234 234 + GetCollectionPageResponse, 235 235 + GetCollectionPageByAtUriParams, 236 236 + GetMyCollectionsParams, 237 237 + GetCollectionsResponse, 238 238 + GetCollectionsParams, 239 239 + GetUrlStatusForMyLibraryParams, 240 240 + GetUrlStatusForMyLibraryResponse, 241 241 + GetLibrariesForUrlParams, 242 242 + GetLibrariesForUrlResponse, 243 243 + GetNoteCardsForUrlParams, 244 244 + GetNoteCardsForUrlResponse, 245 245 + GetCollectionsForUrlParams, 246 246 + GetCollectionsForUrlResponse, 247 247 + GetSimilarUrlsForUrlParams, 248 248 + GetSimilarUrlsForUrlResponse, 249 249 + } from '@semble/types'; 250 250 + 251 251 + export class QueryClient { 252 252 + constructor(private baseUrl: string) {} 253 253 + 254 254 + async getUrlMetadata(url: string): Promise<GetUrlMetadataResponse> { 255 255 + const response = await fetch( 256 256 + `${this.baseUrl}/api/cards/metadata?url=${encodeURIComponent(url)}`, 257 257 + { 258 258 + credentials: 'include', 259 259 + }, 260 260 + ); 261 261 + return response.json(); 262 262 + } 263 263 + 264 264 + async getMyUrlCards( 265 265 + params?: GetMyUrlCardsParams, 266 266 + ): Promise<GetUrlCardsResponse> { 267 267 + const searchParams = new URLSearchParams(); 268 268 + if (params?.page) searchParams.set('page', params.page.toString()); 269 269 + if (params?.limit) searchParams.set('limit', params.limit.toString()); 270 270 + if (params?.sortBy) searchParams.set('sortBy', params.sortBy); 271 271 + if (params?.sortOrder) searchParams.set('sortOrder', params.sortOrder); 272 272 + 273 273 + const response = await fetch( 274 274 + `${this.baseUrl}/api/cards/my?${searchParams}`, 275 275 + { 276 276 + credentials: 'include', 277 277 + }, 278 278 + ); 279 279 + return response.json(); 280 280 + } 281 281 + 282 282 + async getUserUrlCards(params: GetUrlCardsParams): Promise<GetUrlCardsResponse> { 283 283 + const searchParams = new URLSearchParams(); 284 284 + if (params.page) searchParams.set('page', params.page.toString()); 285 285 + if (params.limit) searchParams.set('limit', params.limit.toString()); 286 286 + if (params.sortBy) searchParams.set('sortBy', params.sortBy); 287 287 + if (params.sortOrder) searchParams.set('sortOrder', params.sortOrder); 288 288 + 289 289 + const response = await fetch( 290 290 + `${this.baseUrl}/api/cards/user/${params.identifier}?${searchParams}`, 291 291 + { 292 292 + credentials: 'include', 293 293 + }, 294 294 + ); 295 295 + return response.json(); 296 296 + } 297 297 + 298 298 + async getUrlCardView(cardId: string): Promise<GetUrlCardViewResponse> { 299 299 + const response = await fetch(`${this.baseUrl}/api/cards/${cardId}`, { 300 300 + credentials: 'include', 301 301 + }); 302 302 + return response.json(); 303 303 + } 304 304 + 305 305 + async getLibrariesForCard( 306 306 + cardId: string, 307 307 + ): Promise<GetLibrariesForCardResponse> { 308 308 + const response = await fetch( 309 309 + `${this.baseUrl}/api/cards/${cardId}/libraries`, 310 310 + { 311 311 + credentials: 'include', 312 312 + }, 313 313 + ); 314 314 + return response.json(); 315 315 + } 316 316 + 317 317 + async getMyProfile(): Promise<GetProfileResponse> { 318 318 + const response = await fetch(`${this.baseUrl}/api/users/me`, { 319 319 + credentials: 'include', 320 320 + }); 321 321 + return response.json(); 322 322 + } 323 323 + 324 324 + async getUserProfile(params: GetProfileParams): Promise<GetProfileResponse> { 325 325 + const response = await fetch( 326 326 + `${this.baseUrl}/api/users/${params.identifier}`, 327 327 + { 328 328 + credentials: 'include', 329 329 + }, 330 330 + ); 331 331 + return response.json(); 332 332 + } 333 333 + 334 334 + async getCollectionPage( 335 335 + collectionId: string, 336 336 + params?: GetCollectionPageParams, 337 337 + ): Promise<GetCollectionPageResponse> { 338 338 + const searchParams = new URLSearchParams(); 339 339 + if (params?.page) searchParams.set('page', params.page.toString()); 340 340 + if (params?.limit) searchParams.set('limit', params.limit.toString()); 341 341 + if (params?.sortBy) searchParams.set('sortBy', params.sortBy); 342 342 + if (params?.sortOrder) searchParams.set('sortOrder', params.sortOrder); 343 343 + 344 344 + const response = await fetch( 345 345 + `${this.baseUrl}/api/collections/${collectionId}?${searchParams}`, 346 346 + { 347 347 + credentials: 'include', 348 348 + }, 349 349 + ); 350 350 + return response.json(); 351 351 + } 352 352 + 353 353 + async getCollectionPageByAtUri( 354 354 + params: GetCollectionPageByAtUriParams, 355 355 + ): Promise<GetCollectionPageResponse> { 356 356 + const searchParams = new URLSearchParams(); 357 357 + if (params.page) searchParams.set('page', params.page.toString()); 358 358 + if (params.limit) searchParams.set('limit', params.limit.toString()); 359 359 + if (params.sortBy) searchParams.set('sortBy', params.sortBy); 360 360 + if (params.sortOrder) searchParams.set('sortOrder', params.sortOrder); 361 361 + 362 362 + const response = await fetch( 363 363 + `${this.baseUrl}/api/collections/at-uri/${params.handle}/${params.recordKey}?${searchParams}`, 364 364 + { 365 365 + credentials: 'include', 366 366 + }, 367 367 + ); 368 368 + return response.json(); 369 369 + } 370 370 + 371 371 + async getMyCollections( 372 372 + params?: GetMyCollectionsParams, 373 373 + ): Promise<GetCollectionsResponse> { 374 374 + const searchParams = new URLSearchParams(); 375 375 + if (params?.page) searchParams.set('page', params.page.toString()); 376 376 + if (params?.limit) searchParams.set('limit', params.limit.toString()); 377 377 + if (params?.sortBy) searchParams.set('sortBy', params.sortBy); 378 378 + if (params?.sortOrder) searchParams.set('sortOrder', params.sortOrder); 379 379 + if (params?.searchText) searchParams.set('searchText', params.searchText); 380 380 + 381 381 + const response = await fetch( 382 382 + `${this.baseUrl}/api/collections/my?${searchParams}`, 383 383 + { 384 384 + credentials: 'include', 385 385 + }, 386 386 + ); 387 387 + return response.json(); 388 388 + } 389 389 + 390 390 + async getUserCollections( 391 391 + params: GetCollectionsParams, 392 392 + ): Promise<GetCollectionsResponse> { 393 393 + const searchParams = new URLSearchParams(); 394 394 + if (params.page) searchParams.set('page', params.page.toString()); 395 395 + if (params.limit) searchParams.set('limit', params.limit.toString()); 396 396 + if (params.sortBy) searchParams.set('sortBy', params.sortBy); 397 397 + if (params.sortOrder) searchParams.set('sortOrder', params.sortOrder); 398 398 + if (params.searchText) searchParams.set('searchText', params.searchText); 399 399 + 400 400 + const response = await fetch( 401 401 + `${this.baseUrl}/api/collections/user/${params.identifier}?${searchParams}`, 402 402 + { 403 403 + credentials: 'include', 404 404 + }, 405 405 + ); 406 406 + return response.json(); 407 407 + } 408 408 + 409 409 + async getUrlStatusForMyLibrary( 410 410 + params: GetUrlStatusForMyLibraryParams, 411 411 + ): Promise<GetUrlStatusForMyLibraryResponse> { 412 412 + const response = await fetch( 413 413 + `${this.baseUrl}/api/cards/library/status?url=${encodeURIComponent(params.url)}`, 414 414 + { 415 415 + credentials: 'include', 416 416 + }, 417 417 + ); 418 418 + return response.json(); 419 419 + } 420 420 + 421 421 + async getLibrariesForUrl( 422 422 + params: GetLibrariesForUrlParams, 423 423 + ): Promise<GetLibrariesForUrlResponse> { 424 424 + const searchParams = new URLSearchParams(); 425 425 + searchParams.set('url', params.url); 426 426 + if (params.page) searchParams.set('page', params.page.toString()); 427 427 + if (params.limit) searchParams.set('limit', params.limit.toString()); 428 428 + if (params.sortBy) searchParams.set('sortBy', params.sortBy); 429 429 + if (params.sortOrder) searchParams.set('sortOrder', params.sortOrder); 430 430 + 431 431 + const response = await fetch( 432 432 + `${this.baseUrl}/api/cards/libraries/url?${searchParams}`, 433 433 + { 434 434 + credentials: 'include', 435 435 + }, 436 436 + ); 437 437 + return response.json(); 438 438 + } 439 439 + 440 440 + async getNoteCardsForUrl( 441 441 + params: GetNoteCardsForUrlParams, 442 442 + ): Promise<GetNoteCardsForUrlResponse> { 443 443 + const searchParams = new URLSearchParams(); 444 444 + searchParams.set('url', params.url); 445 445 + if (params.page) searchParams.set('page', params.page.toString()); 446 446 + if (params.limit) searchParams.set('limit', params.limit.toString()); 447 447 + if (params.sortBy) searchParams.set('sortBy', params.sortBy); 448 448 + if (params.sortOrder) searchParams.set('sortOrder', params.sortOrder); 449 449 + 450 450 + const response = await fetch( 451 451 + `${this.baseUrl}/api/cards/notes/url?${searchParams}`, 452 452 + { 453 453 + credentials: 'include', 454 454 + }, 455 455 + ); 456 456 + return response.json(); 457 457 + } 458 458 + 459 459 + async getCollectionsForUrl( 460 460 + params: GetCollectionsForUrlParams, 461 461 + ): Promise<GetCollectionsForUrlResponse> { 462 462 + const searchParams = new URLSearchParams(); 463 463 + searchParams.set('url', params.url); 464 464 + if (params.page) searchParams.set('page', params.page.toString()); 465 465 + if (params.limit) searchParams.set('limit', params.limit.toString()); 466 466 + if (params.sortBy) searchParams.set('sortBy', params.sortBy); 467 467 + if (params.sortOrder) searchParams.set('sortOrder', params.sortOrder); 468 468 + 469 469 + const response = await fetch( 470 470 + `${this.baseUrl}/api/cards/collections/url?${searchParams}`, 471 471 + { 472 472 + credentials: 'include', 473 473 + }, 474 474 + ); 475 475 + return response.json(); 476 476 + } 477 477 + 478 478 + async getSimilarUrlsForUrl( 479 479 + params: GetSimilarUrlsForUrlParams, 480 480 + ): Promise<GetSimilarUrlsForUrlResponse> { 481 481 + const searchParams = new URLSearchParams(); 482 482 + searchParams.set('url', params.url); 483 483 + if (params.page) searchParams.set('page', params.page.toString()); 484 484 + if (params.limit) searchParams.set('limit', params.limit.toString()); 485 485 + if (params.sortBy) searchParams.set('sortBy', params.sortBy); 486 486 + if (params.sortOrder) searchParams.set('sortOrder', params.sortOrder); 487 487 + if (params.threshold) searchParams.set('threshold', params.threshold.toString()); 488 488 + 489 489 + const response = await fetch( 490 490 + `${this.baseUrl}/api/search/similar-urls?${searchParams}`, 491 491 + { 492 492 + credentials: 'include', 493 493 + }, 494 494 + ); 495 495 + return response.json(); 496 496 + } 497 497 + }