initial dockerizing

This commit is contained in:
raiper34
2024-06-22 21:30:53 +02:00
parent da9cf53c69
commit ef028d7745
12 changed files with 110 additions and 27 deletions
+5 -3
View File
@@ -3,13 +3,15 @@ import {TrackService} from "./track.service";
import {TrackModel} from "./track.model";
import {TrackEntity} from "./track.entity";
import {createReadStream} from "fs";
import { join } from 'path';
import { resolve } from 'path';
import type { Response } from 'express';
import {ConfigService} from "@nestjs/config";
@Controller('track')
export class TrackController {
constructor(private readonly service: TrackService) {
constructor(private readonly service: TrackService,
private readonly configService: ConfigService) {
}
@Get()
@@ -40,7 +42,7 @@ export class TrackController {
@Get('download/:id')
async getFile(@Res({ passthrough: true }) res: Response, @Param('id') id: number): Promise<StreamableFile> {
const track = await this.service.findOne(id);
const file = createReadStream(join(process.cwd(), 'downloads', `${track.artist} - ${track.song}.mp3`));
const file = createReadStream(resolve(__dirname, '..', this.configService.get<string>('DOWNLOADS'), `${track.artist} - ${track.song}.mp3`));
res.set({'Content-Disposition': `attachment; filename="${track.artist} - ${track.song}.mp3"`,});
return new StreamableFile(file);
}
+5 -1
View File
@@ -3,9 +3,13 @@ import { TypeOrmModule } from '@nestjs/typeorm';
import {TrackEntity} from "./track.entity";
import {TrackService} from "./track.service";
import {TrackController} from "./track.controller";
import {ConfigModule} from "@nestjs/config";
@Module({
imports: [TypeOrmModule.forFeature([TrackEntity])],
imports: [
TypeOrmModule.forFeature([TrackEntity]),
ConfigModule,
],
providers: [TrackService],
controllers: [TrackController],
exports: [TrackService],
+9 -1
View File
@@ -8,12 +8,15 @@ import {TrackStatusEnum} from "./track.model";
import * as yts from 'yt-search';
import * as ytdl from 'ytdl-core';
import * as fs from 'fs';
import {ConfigService} from "@nestjs/config";
import {resolve} from "path";
@Injectable()
export class TrackService {
constructor(
@InjectRepository(TrackEntity)
private repository: Repository<TrackEntity>,
private readonly configService: ConfigService,
) {}
findAll(criteria?: Partial<TrackEntity>): Promise<TrackEntity[]> {
@@ -50,7 +53,12 @@ export class TrackService {
const queuedTracks = await this.findAll({status: TrackStatusEnum.Queued});
queuedTracks.forEach(async track => {
await ytdl(track.youtubeUrl, {quality: "highestaudio", filter: "audioonly"}).pipe(
fs.createWriteStream(`downloads/${track.artist} - ${track.song.replace('/', '')}.mp3`)
fs.createWriteStream(resolve(
__dirname,
'..',
this.configService.get<string>('DOWNLOADS'),
`${track.artist} - ${track.song.replace('/', '')}.mp3`,
))
);
await this.update(track.id, {...track, status: TrackStatusEnum.Completed})
});