GitHub/mysa-js-sdk
1
0
Fork 0
mirror of https://github.com/bourquep/mysa-js-sdk.git synced 2026-02-04 09:41:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(logging): Reduced the log level of session-related logs (#14)

Browse Source
This commit is contained in:
Pascal Bourque
2025-06-05 08:11:37 -04:00
committed by GitHub
parent 6b4e41828a
commit 7f89e9867a
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/api/MysaApiClient.ts
View File

@@ -288,10 +288,10 @@ export class MysaApiClient {
* @param deviceId - The ID of the device to start receiving updates for. * @param deviceId - The ID of the device to start receiving updates for.
*/ */
async startRealtimeUpdates(deviceId: string) { async startRealtimeUpdates(deviceId: string) {
this._logger.info(`Starting realtime updates for device '${deviceId}'`); this._logger.info(`Starting real-time updates for device '${deviceId}'`);
if (this._realtimeDeviceIds.has(deviceId)) { if (this._realtimeDeviceIds.has(deviceId)) {
this._logger.debug(`Realtime updates for device '${deviceId}' already started`); this._logger.debug(`Real-time updates for device '${deviceId}' already started`);
return; return;
} }
@@ -332,6 +332,8 @@ export class MysaApiClient {
* @param deviceId - The ID of the device to stop receiving real-time updates for. * @param deviceId - The ID of the device to stop receiving real-time updates for.
*/ */
async stopRealtimeUpdates(deviceId: string) { async stopRealtimeUpdates(deviceId: string) {
this._logger.info(`Stopping real-time updates for device '${deviceId}'`);
const timer = this._realtimeDeviceIds.get(deviceId); const timer = this._realtimeDeviceIds.get(deviceId);
if (!timer) { if (!timer) {
this._logger.warn(`No real-time updates are running for device '${deviceId}'`); this._logger.warn(`No real-time updates are running for device '${deviceId}'`);
@@ -344,7 +346,6 @@ export class MysaApiClient {
this._logger.debug(`Unsubscribing to MQTT topic '/v1/dev/${deviceId}/out'...`); this._logger.debug(`Unsubscribing to MQTT topic '/v1/dev/${deviceId}/out'...`);
await mqttConnection.unsubscribe(`/v1/dev/${deviceId}/out`); await mqttConnection.unsubscribe(`/v1/dev/${deviceId}/out`);
this._logger.debug(`Stopping real-time updates for device '${deviceId}'...`);
clearInterval(timer); clearInterval(timer);
this._realtimeDeviceIds.delete(deviceId); this._realtimeDeviceIds.delete(deviceId);
} }
@@ -358,18 +359,18 @@ export class MysaApiClient {
this._cognitoUserSession.isValid() && this._cognitoUserSession.isValid() &&
dayjs.unix(this._cognitoUserSession.getIdToken().getExpiration()).isAfter() dayjs.unix(this._cognitoUserSession.getIdToken().getExpiration()).isAfter()
) { ) {
this._logger.info('Session is valid, no need to refresh'); this._logger.debug('Session is valid, no need to refresh');
return Promise.resolve(this._cognitoUserSession); return Promise.resolve(this._cognitoUserSession);
} }
this._logger.info('Session is not valid or expired, refreshing...'); this._logger.debug('Session is not valid or expired, refreshing...');
return new Promise<CognitoUserSession>((resolve, reject) => { return new Promise<CognitoUserSession>((resolve, reject) => {
this._cognitoUser!.refreshSession(this._cognitoUserSession!.getRefreshToken(), (error, session) => { this._cognitoUser!.refreshSession(this._cognitoUserSession!.getRefreshToken(), (error, session) => {
if (error) { if (error) {
this._logger.error('Failed to refresh session:', error); this._logger.error('Failed to refresh session:', error);
reject(new UnauthenticatedError('Unable to refresh the authentication session.')); reject(new UnauthenticatedError('Unable to refresh the authentication session.'));
} else { } else {
this._logger.info('Session refreshed successfully'); this._logger.debug('Session refreshed successfully');
this._cognitoUserSession = session; this._cognitoUserSession = session;
this.emitter.emit('sessionChanged', this.session); this.emitter.emit('sessionChanged', this.session);
resolve(session); resolve(session);