Function runActor

test/e2e/tools.mjs:158–267

(dirName, memory = 4096)

 * @param {number} [memory=4096]
 */
export async function runActor(dirName, memory = 4096) {
    let stats;
    let datasetItems;
    let getKeyValueStoreItems;
    let defaultKeyValueStoreItems;

    const inputPath = join(dirName, '..', 'INPUT');
    const input = fs.existsSync(inputPath) ? fs.readFileSync(inputPath) : undefined;
    const contentType = input ? 'application/json' : undefined;

    if (process.env.STORAGE_IMPLEMENTATION === 'PLATFORM') {
        const client = Actor.newClient();
        const id = await pushActor(client, dirName);
        const runId = await startActorOnPlatform(client, id, input, contentType, memory);

        const {
            defaultKeyValueStoreId,
            defaultDatasetId,
            startedAt: runStartedAt,
            finishedAt: runFinishedAt,
            // id: runId,
            buildId,
            userId,
        } = await client.run(runId).waitForFinish();

        getKeyValueStoreItems = async (name) => {
            const kvResult = await client.keyValueStore(name ? `${userId}/${name}` : defaultKeyValueStoreId).get();

            if (kvResult) {
                const { items: keyValueItems } = await client.keyValueStore(kvResult.id).listKeys();

                if (keyValueItems.length) {
                    console.log(`[kv] View storage: https://console.apify.com/storage/key-value/${kvResult.id}`);
                }

                const entries = await Promise.all(
                    keyValueItems.map(async ({ key }) => {
                        const record = await client.keyValueStore(kvResult.id).getRecord(key, { buffer: true });

                        return {
                            name: record.key,
                            raw: record.value,
                        };
                    }),
                );

                return entries.filter(({ name }) => !isPrivateEntry(name));
            }

            return undefined;
        };

        const { startedAt: buildStartedAt, finishedAt: buildFinishedAt } = await client.build(buildId).get();

        const buildTook = (buildFinishedAt.getTime() - buildStartedAt.getTime()) / 1000;
        console.log(`[build] View build log: https://api.apify.com/v2/logs/${buildId} [build took ${buildTook}s]`);

        const runTook = (runFinishedAt.getTime() - runStartedAt.getTime()) / 1000;