You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
|
|
|
import { FileData } from './types/definitions';
|
|
|
|
import fs, { ReadStream } from 'fs-extra';
|
|
|
|
import { path } from './utils';
|
|
|
|
import { SkynetClient } from '@skynetlabs/skynet-nodejs';
|
|
|
|
|
|
|
|
function getFullPath(fileData: FileData) {
|
|
|
|
return path('share', '.skynet', `${fileData.randomId}${fileData.ext}`.replace(/sia\:\/\//gi, ''));
|
|
|
|
}
|
|
|
|
|
|
|
|
// Create the SkyNet client
|
|
|
|
export const Skynet = new SkynetClient();
|
|
|
|
|
|
|
|
export function SkynetUpload(path: string): Promise<string> {
|
|
|
|
return new Promise(async (resolve, reject) => {
|
|
|
|
try {
|
|
|
|
const skylink = await Skynet.uploadFile(path);
|
|
|
|
resolve(skylink);
|
|
|
|
} catch (error) {
|
|
|
|
reject(error);
|
|
|
|
}
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
export function SkynetDownload(fileData: FileData): Promise<ReadStream> {
|
|
|
|
return new Promise((resolve: Function, reject) =>
|
|
|
|
fs.ensureDir(path('share', '.skynet'))
|
|
|
|
.then(async () => {
|
|
|
|
await Skynet.downloadFile(getFullPath(fileData), fileData.randomId);
|
|
|
|
return fs.createReadStream(getFullPath(fileData))
|
|
|
|
})
|
|
|
|
.then((stream) => resolve(stream))
|
|
|
|
.catch(reject));
|
|
|
|
}
|
|
|
|
|
|
|
|
export function SkynetDelete(fileData: FileData) {
|
|
|
|
return fs.remove(getFullPath(fileData));
|
|
|
|
}
|