import { Buffer } from 'buffer';

import { IAppAccessors, IHttp, ILogger, IModify, IPersistence, IRead } from '@rocket.chat/apps-engine/definition/accessors';
import { App } from '@rocket.chat/apps-engine/definition/App';
import { IMessage, IPostMessageSent } from '@rocket.chat/apps-engine/definition/messages';
import { IAppInfo } from '@rocket.chat/apps-engine/definition/metadata';

export class FileUploadApp extends App implements IPostMessageSent {
    constructor(info: IAppInfo, logger: ILogger, accessors: IAppAccessors) {
        super(info, logger, accessors);
    }
    public async executePostMessageSent(message: IMessage, read: IRead, http: IHttp, persistence: IPersistence, modify: IModify): Promise<void> {
        try {
            const { text, room } = message;

            if (!text) {
                return;
            }

            // ! An error will be thrown if without extension name
            // await modify.getCreator().getUploadCreator().createUpload(room, 'example', Buffer.from(files.txt, 'base64'));

            // ! An error will be thrown if extension is not matched with detected MIME type
            // await modify.getCreator().getUploadCreator().createUpload(room, 'example.png', Buffer.from(files.pdf, 'base64'));

            // Upload a txt file (plain text)
            // const r1 = await modify.getCreator().getUploadCreator().createUpload(room, 'example.txt', Buffer.from(files.txt, 'base64'));
            // console.log(`${ r1.name }: ${ r1.url }`);

            // Upload a pdf file (binary)
            // const r2 = await createUpload(room, 'example.pdf', Buffer.from(files.pdf, 'base64'));
            // console.log(`${ r2.name }: ${ r2.url }`);

            // Pressure Testing
            const { name, complete, uploading, updatedAt, url } = await modify
                .getCreator()
                .getUploadCreator()
                .createUpload(room, `${ Math.random() }.txt`, Buffer.from((Math.random() * 10 ** 6).toFixed(0)));
            console.log({ name, complete, uploading, updatedAt, url });
        } catch (err) {
            console.error(err);
        }
    }
}