Fix tests

This commit is contained in:
Wolfgang Kulhanek
2025-10-24 14:47:53 +02:00
parent 48a71031c6
commit a47581c3fe
3 changed files with 21 additions and 40 deletions

View File

@@ -248,32 +248,7 @@ class SonosSoap {
getCredentialsForToken(token: string): SmapiToken | undefined { getCredentialsForToken(token: string): SmapiToken | undefined {
logger.debug("getCredentialsForToken called with: " + token); logger.debug("getCredentialsForToken called with: " + token);
logger.debug("Current tokens: " + JSON.stringify(this.tokenStore.getAll())); logger.debug("Current tokens: " + JSON.stringify(this.tokenStore.getAll()));
return this.tokenStore.get(token);
// First try direct lookup
let smapiToken = this.tokenStore.get(token);
if (smapiToken) {
return smapiToken;
}
// If not found, try to find by service token (for cases where token was refreshed)
// This is a fallback mechanism to handle token refresh scenarios
const allTokens = this.tokenStore.getAll();
for (const [storedToken, storedSmapiToken] of Object.entries(allTokens)) {
try {
const verifyResult = this.smapiAuthTokens.verify(storedSmapiToken);
if (E.isRight(verifyResult)) {
// This token is valid, check if it matches our service token
const serviceToken = verifyResult.right;
// We can't easily extract the service token from the JWT without the key,
// so we'll rely on the direct lookup for now
}
} catch (error) {
// Token is invalid/expired, skip it
continue;
}
}
return undefined;
} }
associateCredentialsForToken(token: string, fullSmapiToken: SmapiToken, oldToken?:string) { associateCredentialsForToken(token: string, fullSmapiToken: SmapiToken, oldToken?:string) {
logger.debug("Adding token: " + token + " " + JSON.stringify(fullSmapiToken)); logger.debug("Adding token: " + token + " " + JSON.stringify(fullSmapiToken));
@@ -572,7 +547,7 @@ function bindSmapiSoapServiceToExpress(
logger.info("Token refresh successful, issuing new SMAPI token"); logger.info("Token refresh successful, issuing new SMAPI token");
return smapiAuthTokens.issue(it.serviceToken); return smapiAuthTokens.issue(it.serviceToken);
}), }),
TE.tap(swapToken(credentials?.loginToken?.token)), TE.tap(swapToken(undefined)), // Don't pass old token to avoid circular reference issues
TE.map((newToken) => ({ TE.map((newToken) => ({
Fault: { Fault: {
faultcode: "Client.TokenRefreshRequired", faultcode: "Client.TokenRefreshRequired",
@@ -641,7 +616,7 @@ function bindSmapiSoapServiceToExpress(
return pipe( return pipe(
musicService.refreshToken(serviceToken), musicService.refreshToken(serviceToken),
TE.map((it) => smapiAuthTokens.issue(it.serviceToken)), TE.map((it) => smapiAuthTokens.issue(it.serviceToken)),
TE.tap(swapToken(creds?.loginToken?.token)), // Pass the old token to be replaced TE.tap(swapToken(undefined)), // Don't pass old token to avoid circular reference issues
TE.map((it) => ({ TE.map((it) => ({
refreshAuthTokenResult: { refreshAuthTokenResult: {
authToken: it.token, authToken: it.token,

View File

@@ -41,11 +41,13 @@ export class InMemorySmapiTokenStore implements SmapiTokenStore {
const smapiToken = this.tokens[tokenKey]; const smapiToken = this.tokens[tokenKey];
if (smapiToken) { if (smapiToken) {
const verifyResult = smapiAuthTokens.verify(smapiToken); const verifyResult = smapiAuthTokens.verify(smapiToken);
// Only delete if token verification fails with InvalidTokenError
// Do NOT delete ExpiredTokenError as those can still be refreshed
if (E.isLeft(verifyResult)) { if (E.isLeft(verifyResult)) {
const error = verifyResult.left; const error = verifyResult.left;
// Delete both invalid and expired tokens to prevent accumulation // Only delete invalid tokens, not expired ones (which can be refreshed)
if (error._tag === 'InvalidTokenError' || error._tag === 'ExpiredTokenError') { if (error._tag === 'InvalidTokenError') {
logger.debug(`Deleting ${error._tag} token from in-memory store`); logger.debug(`Deleting invalid token from in-memory store`);
delete this.tokens[tokenKey]; delete this.tokens[tokenKey];
deletedCount++; deletedCount++;
} }
@@ -54,7 +56,7 @@ export class InMemorySmapiTokenStore implements SmapiTokenStore {
} }
if (deletedCount > 0) { if (deletedCount > 0) {
logger.info(`Cleaned up ${deletedCount} token(s) from in-memory store`); logger.info(`Cleaned up ${deletedCount} invalid token(s) from in-memory store`);
} }
return deletedCount; return deletedCount;
@@ -140,11 +142,13 @@ export class FileSmapiTokenStore implements SmapiTokenStore {
const smapiToken = this.tokens[tokenKey]; const smapiToken = this.tokens[tokenKey];
if (smapiToken) { if (smapiToken) {
const verifyResult = smapiAuthTokens.verify(smapiToken); const verifyResult = smapiAuthTokens.verify(smapiToken);
// Only delete if token verification fails with InvalidTokenError
// Do NOT delete ExpiredTokenError as those can still be refreshed
if (E.isLeft(verifyResult)) { if (E.isLeft(verifyResult)) {
const error = verifyResult.left; const error = verifyResult.left;
// Delete both invalid and expired tokens to prevent accumulation // Only delete invalid tokens, not expired ones (which can be refreshed)
if (error._tag === 'InvalidTokenError' || error._tag === 'ExpiredTokenError') { if (error._tag === 'InvalidTokenError') {
logger.debug(`Deleting ${error._tag} token from file store`); logger.debug(`Deleting invalid token from file store`);
delete this.tokens[tokenKey]; delete this.tokens[tokenKey];
deletedCount++; deletedCount++;
} }
@@ -153,7 +157,7 @@ export class FileSmapiTokenStore implements SmapiTokenStore {
} }
if (deletedCount > 0) { if (deletedCount > 0) {
logger.info(`Cleaned up ${deletedCount} token(s) from file store`); logger.info(`Cleaned up ${deletedCount} invalid token(s) from file store`);
this.saveToFile(); this.saveToFile();
} }

View File

@@ -122,11 +122,13 @@ export class SQLiteSmapiTokenStore implements SmapiTokenStore {
const smapiToken = tokens[tokenKey]; const smapiToken = tokens[tokenKey];
if (smapiToken) { if (smapiToken) {
const verifyResult = smapiAuthTokens.verify(smapiToken); const verifyResult = smapiAuthTokens.verify(smapiToken);
// Only delete if token verification fails with InvalidTokenError
// Do NOT delete ExpiredTokenError as those can still be refreshed
if (E.isLeft(verifyResult)) { if (E.isLeft(verifyResult)) {
const error = verifyResult.left; const error = verifyResult.left;
// Delete both invalid and expired tokens to prevent accumulation // Only delete invalid tokens, not expired ones (which can be refreshed)
if (error._tag === 'InvalidTokenError' || error._tag === 'ExpiredTokenError') { if (error._tag === 'InvalidTokenError') {
logger.debug(`Deleting ${error._tag} token from SQLite store`); logger.debug(`Deleting invalid token from SQLite store`);
this.delete(tokenKey); this.delete(tokenKey);
deletedCount++; deletedCount++;
} }
@@ -135,7 +137,7 @@ export class SQLiteSmapiTokenStore implements SmapiTokenStore {
} }
if (deletedCount > 0) { if (deletedCount > 0) {
logger.info(`Cleaned up ${deletedCount} token(s) from SQLite store`); logger.info(`Cleaned up ${deletedCount} invalid token(s) from SQLite store`);
} }
return deletedCount; return deletedCount;