import { URL } from 'url';
import { Database } from './database';
import { resolvedPorts } from './SocketData';

// npx ts-node src/server/remapUrl.ts

const suffixMap: { [type: string]: true } = {
    video: true,
    pdf: true,
    audio: true,
    web: true,
    image: true,
    map: true,
};

async function update() {
    await new Promise(res => {
        setTimeout(res, 10);
    });
    console.log('update');
    const cursor = await Database.Instance.query({});
    console.log('Cleared');
    const updates: [string, any][] = [];
    function updateDoc(doc: any) {
        if (doc.__type !== 'Doc') {
            return;
        }
        const { fields } = doc;
        if (!fields) {
            return;
        }
        const updated: any = {};
        let dynfield = false;
        Array.from(Object.keys(fields)).forEach(key => {
            const value = fields[key];
            if (value && value.__type && suffixMap[value.__type]) {
                const url = new URL(value.url);
                if (url.href.includes('localhost') && url.href.includes('Bill')) {
                    dynfield = true;

                    updated.$set = { ['fields.' + key + '.url']: `${url.protocol}//dash-web.eastus2.cloudapp.azure.com:${resolvedPorts.server}${url.pathname}` };
                }
            }
        });
        if (dynfield) {
            updates.push([doc._id, updated]);
        }
    }
    await cursor.forEach(updateDoc);
    await Promise.all(
        updates.map(doc => {
            console.log(doc[0], doc[1]);
            return new Promise<void>(res => {
                Database.Instance.update(
                    doc[0],
                    doc[1],
                    () => {
                        console.log('wrote ' + JSON.stringify(doc[1]));
                        res();
                    },
                    false
                );
            });
        })
    );
    console.log('Done');
    // await Promise.all(updates.map(update => {
    //     return limit(() => Search.updateDocument(update));
    // }));
    cursor.close();
}

update();