2021-08-06 16:44:57 +02:00
|
|
|
import os
|
2021-08-16 20:15:12 +02:00
|
|
|
import asyncio
|
|
|
|
import logging
|
|
|
|
|
|
|
|
log = logging.getLogger(__name__)
|
2021-08-06 16:44:57 +02:00
|
|
|
|
|
|
|
|
|
|
|
class DiskSpaceManager:
|
|
|
|
|
2021-09-08 16:55:21 +02:00
|
|
|
def __init__(self, config, db, blob_manager, cleaning_interval=30 * 60):
|
2021-08-06 16:44:57 +02:00
|
|
|
self.config = config
|
2021-09-08 16:55:21 +02:00
|
|
|
self.db = db
|
|
|
|
self.blob_manager = blob_manager
|
2021-08-16 20:15:12 +02:00
|
|
|
self.cleaning_interval = cleaning_interval
|
|
|
|
self.running = False
|
|
|
|
self.task = None
|
2021-08-06 16:44:57 +02:00
|
|
|
|
2021-09-08 16:55:21 +02:00
|
|
|
async def get_space_used_bytes(self):
|
|
|
|
return await self.db.get_stored_blob_disk_usage()
|
2021-08-06 16:44:57 +02:00
|
|
|
|
2021-09-08 16:55:21 +02:00
|
|
|
async def get_space_used_mb(self):
|
|
|
|
return int(await self.get_space_used_bytes()/1024.0/1024.0)
|
2021-08-16 20:15:12 +02:00
|
|
|
|
2021-09-08 16:55:21 +02:00
|
|
|
async def clean(self):
|
2021-08-16 20:15:12 +02:00
|
|
|
if not self.config.blob_storage_limit:
|
2021-08-16 23:03:40 +02:00
|
|
|
return 0
|
2021-09-08 16:55:21 +02:00
|
|
|
delete = []
|
2021-09-10 16:53:52 +02:00
|
|
|
available = (self.config.blob_storage_limit*1024*1024) - await self.get_space_used_bytes()
|
|
|
|
if available > 0:
|
|
|
|
return 0
|
|
|
|
for blob_hash, file_size, added_on in await self.db.get_stored_blobs(is_mine=False):
|
|
|
|
delete.append(blob_hash)
|
2021-08-16 20:15:12 +02:00
|
|
|
available += file_size
|
|
|
|
if available > 0:
|
|
|
|
break
|
2021-09-08 16:55:21 +02:00
|
|
|
if delete:
|
|
|
|
await self.blob_manager.delete_blobs(delete, delete_from_db=True)
|
|
|
|
return len(delete)
|
2021-08-16 20:15:12 +02:00
|
|
|
|
|
|
|
async def cleaning_loop(self):
|
|
|
|
while self.running:
|
|
|
|
await asyncio.sleep(self.cleaning_interval)
|
2021-09-08 16:55:21 +02:00
|
|
|
await self.clean()
|
2021-08-16 20:15:12 +02:00
|
|
|
|
|
|
|
async def start(self):
|
|
|
|
self.running = True
|
|
|
|
self.task = asyncio.create_task(self.cleaning_loop())
|
|
|
|
self.task.add_done_callback(lambda _: log.info("Stopping blob cleanup service."))
|
|
|
|
|
|
|
|
async def stop(self):
|
|
|
|
if self.running:
|
|
|
|
self.running = False
|
|
|
|
self.task.cancel()
|