Infrastructure/zipline
1
Fork 0
Code Issues Pull requests Activity

fix: save imported files to datasource

Browse source
This commit is contained in:
diced 2022-10-23 10:14:29 -07:00
parent 1f44aa7e85
commit b8729a6ec7
No known key found for this signature in database
GPG key ID: 370BD1BA142842D1
2 changed files with 12 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/lib/datasource.ts
View file

@ -1,5 +1,5 @@
import config from './config';
import { Swift, Local, S3 } from './datasources';
import { Swift, Local, S3, Datasource } from './datasources';
import Logger from './logger';
if (!global.datasource) {
@ -21,4 +21,4 @@ if (!global.datasource) {
}
}
export default global.datasource;
export default global.datasource as Datasource;

11
src/scripts/import-dir.ts
View file

@ -1,9 +1,10 @@
import datasource from '../lib/datasource';
import { readdir, stat } from 'fs/promises';
import { readdir, readFile } from 'fs/promises';
import config from '../lib/config';
import { migrations } from '../server/util';
import { PrismaClient } from '@prisma/client';
import { guess } from '../lib/mimes';
import { join } from 'path';
async function main() {
const directory = process.argv[2];
@ -43,6 +44,14 @@ async function main() {
data,
});
console.log('Finished transaction to database.');
// copy files to local storage
console.log(`Copying files to ${config.datasource.type} storage..`);
for (let i = 0; i !== files.length; ++i) {
const file = files[i];
await datasource.save(file, await readFile(join(directory, file)));
}
console.log(`Finished copying files to ${config.datasource.type} storage.`);
}
main();