@@ -21,54 +21,17 @@ 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'" ) ;
2524 }
2625
2726 /**
2827 * Get a release by its identifier using DataLoader
29- * @param id - release identifier
28+ * @param releaseId - release identifier
3029 */
31- public async getReleaseById ( id : string ) : Promise < ReleaseDBScheme | null > {
32- console . log ( `[ReleasesFactory] getReleaseById called with id: ${ id } ` ) ;
30+ public async findById ( releaseId : string ) : Promise < ReleaseDBScheme | null > {
3331 try {
34- const release = await this . dataLoaders . releaseById . load ( id ) ;
35- console . log ( `[ReleasesFactory] getReleaseById result:` , release ) ;
36- return release ;
32+ return await this . dataLoaders . releaseById . load ( releaseId ) ;
3733 } catch ( error ) {
38- console . error ( `[ReleasesFactory] Error in getReleaseById:` , error ) ;
39- throw error ;
40- }
41- }
42-
43- /**
44- * Get all releases
45- */
46- public async getAllReleases ( ) : Promise < ReleaseDBScheme [ ] > {
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- }
56- }
57-
58- /**
59- * Get releases with pagination
60- * @param page - page number (starting from 1)
61- * @param limit - number of items per page
62- */
63- public async getReleasesPaginated ( page : number , limit : number ) : Promise < ReleaseDBScheme [ ] > {
64- const skip = ( page - 1 ) * limit ;
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 ) ;
34+ console . error ( `[ReleasesFactory] Error in findById:` , error ) ;
7235 throw error ;
7336 }
7437 }
@@ -77,14 +40,11 @@ export default class ReleasesFactory {
7740 * Get releases by project identifier
7841 * @param projectId - project identifier
7942 */
80- public async getReleasesByProjectId ( projectId : string ) : Promise < ReleaseDBScheme [ ] > {
81- console . log ( `[ReleasesFactory] getReleasesByProjectId called with projectId: ${ projectId } ` ) ;
43+ public async findManyByProjectId ( projectId : string ) : Promise < ReleaseDBScheme [ ] > {
8244 try {
83- const releases = await this . collection . find ( { projectId : projectId } ) . toArray ( ) ;
84- console . log ( `[ReleasesFactory] getReleasesByProjectId returned ${ releases . length } releases` ) ;
85- return releases ;
45+ return await this . collection . find ( { projectId : projectId } ) . toArray ( ) ;
8646 } catch ( error ) {
87- console . error ( `[ReleasesFactory] Error in getReleasesByProjectId :` , error ) ;
47+ console . error ( `[ReleasesFactory] Error in findManyByProjectId :` , error ) ;
8848 throw error ;
8949 }
9050 }
0 commit comments