Function task

packages/migrate/scripts/vijos.ts:397–467

(name: any, src: Db, report: Report)

}

async function task(name: any, src: Db, report: Report) {
    await report({ progress: 1, message: `${name}` });
    let lastProgress = -1;
    for (let i = 0; ; i++) {
        const docs = await cursor[name](src).skip(i * 50).limit(50).toArray();
        if (!docs.length) break;
        const res = [];
        for (const doc of docs) {
            let d: any = {};
            if (typeof tasks[name].call === 'function') {
                d = await tasks[name](doc);
            } else {
                const mapper = tasks[name];
                for (const key in doc) {
                    if (typeof mapper[key] === 'string') {
                        d[mapper[key]] = doc[key];
                    } else if (mapper[key] === null) {
                        // Ignore this key
                    } else if (typeof mapper[key] === 'object') {
                        d[mapper[key].field] = mapper[key].processer(doc[key], doc);
                    } else {
                        await report({ message: `Unknown key ${key} in collection ${name}` });
                    }
                }
            }
            if (d) {
                if (d.rule) d.rated = true; // Hack contest rated field
                const docWithoutId = {};
                const docWithoutDid = {};
                for (const key in d) {
                    if (key !== '_id') {
                        if (key !== 'domainId' && key !== 'docId' && key !== 'docType' && key !== 'uid') {
                            docWithoutDid[key] = d[key];
                        }
                        docWithoutId[key] = d[key];
                    }
                }
                if (d.domainId && d.docId && d.docType) {
                    const query: any = { domainId: d.domainId, docId: d.docId, docType: d.docType };
                    if (d.uid) query.uid = d.uid;
                    res.push((async () => {
                        const data = await dst.collection(name).findOne(query);
                        if (data) {
                            await dst.collection(name).updateOne(query, { $set: docWithoutDid });
                        } else if (d._id) {
                            const dat = await dst.collection(name).findOne({ _id: d._id });
                            if (dat) {
                                await dst.collection(name).updateOne({
                                    _id: d._id,
                                }, { $set: docWithoutId });
                            } else {
                                await dst.collection(name).insertOne(d);
                            }
                        } else {
                            await dst.collection(name).insertOne(d);
                        }
                    })());
                } else if (d._id) {