Fix remote drive expire (#7543)
This commit is contained in:
		
							parent
							
								
									52e54cf0dc
								
							
						
					
					
						commit
						0263539202
					
				
					 3 changed files with 7 additions and 2 deletions
				
			
		|  | @ -59,6 +59,7 @@ export class DriveFileRepository extends Repository<DriveFile> { | |||
| 		const { sum } = await this | ||||
| 			.createQueryBuilder('file') | ||||
| 			.where('file.userId = :id', { id: id }) | ||||
| 			.andWhere('file.isLink = FALSE') | ||||
| 			.select('SUM(file.size)', 'sum') | ||||
| 			.getRawOne(); | ||||
| 
 | ||||
|  | @ -69,6 +70,7 @@ export class DriveFileRepository extends Repository<DriveFile> { | |||
| 		const { sum } = await this | ||||
| 			.createQueryBuilder('file') | ||||
| 			.where('file.userHost = :host', { host: toPuny(host) }) | ||||
| 			.andWhere('file.isLink = FALSE') | ||||
| 			.select('SUM(file.size)', 'sum') | ||||
| 			.getRawOne(); | ||||
| 
 | ||||
|  | @ -79,6 +81,7 @@ export class DriveFileRepository extends Repository<DriveFile> { | |||
| 		const { sum } = await this | ||||
| 			.createQueryBuilder('file') | ||||
| 			.where('file.userHost IS NULL') | ||||
| 			.andWhere('file.isLink = FALSE') | ||||
| 			.select('SUM(file.size)', 'sum') | ||||
| 			.getRawOne(); | ||||
| 
 | ||||
|  | @ -89,6 +92,7 @@ export class DriveFileRepository extends Repository<DriveFile> { | |||
| 		const { sum } = await this | ||||
| 			.createQueryBuilder('file') | ||||
| 			.where('file.userHost IS NOT NULL') | ||||
| 			.andWhere('file.isLink = FALSE') | ||||
| 			.select('SUM(file.size)', 'sum') | ||||
| 			.getRawOne(); | ||||
| 
 | ||||
|  |  | |||
|  | @ -267,7 +267,8 @@ async function upload(key: string, stream: fs.ReadStream | Buffer, type: string, | |||
| 
 | ||||
| async function deleteOldFile(user: IRemoteUser) { | ||||
| 	const q = DriveFiles.createQueryBuilder('file') | ||||
| 		.where('file.userId = :userId', { userId: user.id }); | ||||
| 		.where('file.userId = :userId', { userId: user.id }) | ||||
| 		.andWhere('file.isLink = FALSE'); | ||||
| 
 | ||||
| 	if (user.avatarId) { | ||||
| 		q.andWhere('file.id != :avatarId', { avatarId: user.avatarId }); | ||||
|  |  | |||
|  | @ -79,7 +79,7 @@ async function postProcess(file: DriveFile, isExpired = false) { | |||
| 			url: file.uri, | ||||
| 			thumbnailUrl: null, | ||||
| 			webpublicUrl: null, | ||||
| 			size: 0, | ||||
| 			storedInternal: false, | ||||
| 			// ローカルプロキシ用
 | ||||
| 			accessKey: uuid(), | ||||
| 			thumbnailAccessKey: 'thumbnail-' + uuid(), | ||||
|  |  | |||
		Loading…
	
	Add table
		Add a link
		
	
		Reference in a new issue