feat: retry and retry delay

src/nest-minio.options.ts

@@ -1,3 +1,6 @@
 import { ClientOptions } from 'minio';
 
-export type NestMinioOptions = ClientOptions;
+export type NestMinioOptions = ClientOptions & {
+	retries?: number
+	retryDelay?: number
+};

src/nest-minio.service.ts

@@ -2,6 +2,7 @@ import { Inject, Injectable, Logger } from '@nestjs/common';
 import * as minio from 'minio';
 import { MODULE_OPTIONS_TOKEN } from './nest-minio.module-definition';
 import { NestMinioOptions } from './nest-minio.options';
+import { from, lastValueFrom, retry } from "rxjs"
 
 interface INestMinioService {
 	getMinio(): minio.Client
@@ -14,22 +15,28 @@ export class NestMinioService implements INestMinioService {
 	private readonly logger = new Logger(NestMinioService.name);
 
 	constructor(
-		@Inject(MODULE_OPTIONS_TOKEN) private _NestMinioOptions: NestMinioOptions,
-	) {}
+		@Inject(MODULE_OPTIONS_TOKEN) private nestMinioOptions: NestMinioOptions,
+	) { }
 
 	getMinio(): minio.Client {
 		if (!this._minioConnection) {
-			this._minioConnection = new minio.Client(this._NestMinioOptions);
+			const { retries, ...options } = this.nestMinioOptions;
+			this._minioConnection = new minio.Client(options);
 		}
 		return this._minioConnection;
 	}
 
-	checkConnection(){
-		this._minioConnection.listBuckets().then(()=>{
-			this.logger.log("Successfullly connected to minio.")
-		})
-		.catch(error =>{
-			this.logger.error(error)
-		})
+	checkConnection() {
+		const { retries = 5, retryDelay = 1000 } = this.nestMinioOptions
+
+		lastValueFrom(from(this._minioConnection.listBuckets()).pipe(
+			retry({ count: retries, delay: retryDelay })
+		))
+			.then(() => {
+				this.logger.log("Successfully connected to minio.")
+			})
+			.catch(error => {
+				this.logger.error(error)
+			})
 	}
 }