@@ -21,21 +21,38 @@ export default class ReleasesFactory {
2121 constructor ( dbConnection : Db , dataLoaders : DataLoaders ) {
2222 this . collection = dbConnection . collection ( 'releases' ) ;
2323 this . dataLoaders = dataLoaders ;
24+ console . log ( "[ReleasesFactory] Initialized with collection 'releases'" ) ;
2425 }
2526
2627 /**
2728 * Получить релиз по его идентификатору с использованием DataLoader
2829 * @param id - идентификатор релиза
2930 */
3031 public async getReleaseById ( id : string ) : Promise < ReleaseDBScheme | null > {
31- return this . dataLoaders . releaseById . load ( id ) ;
32+ console . log ( `[ReleasesFactory] getReleaseById called with id: ${ id } ` ) ;
33+ try {
34+ const release = await this . dataLoaders . releaseById . load ( id ) ;
35+ console . log ( `[ReleasesFactory] getReleaseById result:` , release ) ;
36+ return release ;
37+ } catch ( error ) {
38+ console . error ( `[ReleasesFactory] Error in getReleaseById:` , error ) ;
39+ throw error ;
40+ }
3241 }
3342
3443 /**
3544 * Получить все релизы
3645 */
3746 public async getAllReleases ( ) : Promise < ReleaseDBScheme [ ] > {
38- return this . collection . find ( { } ) . toArray ( ) ;
47+ console . log ( `[ReleasesFactory] getAllReleases called` ) ;
48+ try {
49+ const releases = await this . collection . find ( { } ) . toArray ( ) ;
50+ console . log ( `[ReleasesFactory] getAllReleases returned ${ releases . length } releases` ) ;
51+ return releases ;
52+ } catch ( error ) {
53+ console . error ( `[ReleasesFactory] Error in getAllReleases:` , error ) ;
54+ throw error ;
55+ }
3956 }
4057
4158 /**
@@ -45,14 +62,30 @@ export default class ReleasesFactory {
4562 */
4663 public async getReleasesPaginated ( page : number , limit : number ) : Promise < ReleaseDBScheme [ ] > {
4764 const skip = ( page - 1 ) * limit ;
48- return this . collection . find ( { } ) . skip ( skip ) . limit ( limit ) . toArray ( ) ;
65+ console . log ( `[ReleasesFactory] getReleasesPaginated called with page: ${ page } , limit: ${ limit } , skip: ${ skip } ` ) ;
66+ try {
67+ const releases = await this . collection . find ( { } ) . skip ( skip ) . limit ( limit ) . toArray ( ) ;
68+ console . log ( `[ReleasesFactory] getReleasesPaginated returned ${ releases . length } releases` ) ;
69+ return releases ;
70+ } catch ( error ) {
71+ console . error ( `[ReleasesFactory] Error in getReleasesPaginated:` , error ) ;
72+ throw error ;
73+ }
4974 }
5075
5176 /**
5277 * Получить релизы по идентификатору проекта
5378 * @param projectId - идентификатор проекта
5479 */
5580 public async getReleasesByProjectId ( projectId : string ) : Promise < ReleaseDBScheme [ ] > {
56- return this . collection . find ( { projectId } ) . toArray ( ) ;
81+ console . log ( `[ReleasesFactory] getReleasesByProjectId called with projectId: ${ projectId } ` ) ;
82+ try {
83+ const releases = await this . collection . find ( { projectId : projectId } ) . toArray ( ) ;
84+ console . log ( `[ReleasesFactory] getReleasesByProjectId returned ${ releases . length } releases` ) ;
85+ return releases ;
86+ } catch ( error ) {
87+ console . error ( `[ReleasesFactory] Error in getReleasesByProjectId:` , error ) ;
88+ throw error ;
89+ }
5790 }
5891}
0 commit comments