Bluemedia/muse
1
0
Fork 0
mirror of https://github.com/BluemediaGER/muse.git synced 2024-09-20 03:25:29 +02:00
Code Issues Packages Projects Releases Wiki Activity

add some debug logs

Browse source
This commit is contained in:
Hellyson Rodrigo Parteka 2021-12-03 03:26:36 -03:00
parent af82be13f9
commit b52f9253c2
No known key found for this signature in database
GPG key ID: 3055745CA21934C7
1 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/services/file-cache.ts
View file

@ -6,6 +6,7 @@ import {FileCache} from '../models/index.js';
import {TYPES} from '../types.js'; import {TYPES} from '../types.js';
import Config from './config.js'; import Config from './config.js';
import PQueue from 'p-queue'; import PQueue from 'p-queue';
import debug from '../utils/debug.js';
@injectable() @injectable()
export default class FileCacheProvider { export default class FileCacheProvider {
@ -65,7 +66,7 @@ export default class FileCacheProvider {
await FileCache.create({hash, bytes: stats.size, accessedAt: new Date()}); await FileCache.create({hash, bytes: stats.size, accessedAt: new Date()});
} catch (e: unknown) { } catch (e: unknown) {
console.error(e); debug(`Caught error trying to move a finished cache file: ${String(e)}`);
} }
} }
@ -87,11 +88,13 @@ export default class FileCacheProvider {
private evictOldestIfNecessary() { private evictOldestIfNecessary() {
if (FileCacheProvider.evictionQueue.size === 0 && FileCacheProvider.evictionQueue.pending === 0) { if (FileCacheProvider.evictionQueue.size === 0 && FileCacheProvider.evictionQueue.pending === 0) {
debug('Adding evictOldest task to queue');
void FileCacheProvider.evictionQueue.add(this.evictOldest.bind(this)); void FileCacheProvider.evictionQueue.add(this.evictOldest.bind(this));
} }
} }
private async evictOldest() { private async evictOldest() {
debug('Evicting oldest (if found)');
const [{dataValues: {totalSizeBytes}}] = await FileCache.findAll({ const [{dataValues: {totalSizeBytes}}] = await FileCache.findAll({
attributes: [ attributes: [
[sequelize.fn('sum', sequelize.col('bytes')), 'totalSizeBytes'], [sequelize.fn('sum', sequelize.col('bytes')), 'totalSizeBytes'],
@ -111,8 +114,11 @@ export default class FileCacheProvider {
} }
// Continue to evict until we're under the limit // Continue to evict until we're under the limit
debug('Scheduling another eviction');
void FileCacheProvider.evictionQueue.add(this.evictOldest.bind(this)); void FileCacheProvider.evictionQueue.add(this.evictOldest.bind(this));
} }
debug('Finished evictOldest');
} }
private async removeOrphans() { private async removeOrphans() {