app.ts

var childProcess = require('child_process');
var fs = require('fs');
var http = require('http');

interface IImportData {
    importedPath: string;
}

interface IEpisode {
    date: string;
    data: IImportData;
}

interface IResponse {
    records: IEpisode[];
}

var LatestEpisodePath = 'synopoke.lst';

var host = process.argv[2];
var port = process.argv[3];
var apiKey = process.argv[4];
var restartAfter = parseInt(process.argv[5]);

function index(episodes: IEpisode[]) {
    if (episodes != null && episodes.length > 0) {
        var episodesNum = episodes.length;
        for (var i = 0; i < episodesNum; ++i) {
            childProcess.execFile('/usr/syno/bin/synoindex', ['-a', episodes[i].data.importedPath]);
            console.log('indexing ' + episodes[i].data.importedPath);
        }

        // Store the latest episode we got so we don't have to get everything again on suceeding runs
        fs.writeFile(LatestEpisodePath, episodes[0].date);
    }

    start(restartAfter);
}

function findLastValidEpisode(episodes: IEpisode[], until: Date): number {
    var i = episodes.length - 1;

    if (i >= 0) {
        for (i; i >= 0; --i) {
            if (new Date(episodes[i].date) > until) {
                return i;
            }
        }
    }

    return -1;
}

// Gets all media imported by Sonarr from the present until the given date
function indexCompletedImpl(episodes: IEpisode[], page: number, until: Date) {
    var request = http.request(
        {
            host: host,
            port: port,
            path: '/api/History?&pageSize=1000&sortKey=date&sortDir=desc&filterKey=eventType&filterValue=3' + '&page=' + page + '&apiKey=' + apiKey
        },
        response => {
            var rawData = '';

            response.on('data', chunk => {
                rawData += chunk;
            });

            response.on('end', () => {
                var response = <IResponse>JSON.parse(rawData);

                var lastValidIndex = findLastValidEpisode(response.records, until);
                if (lastValidIndex >= 0) {
                    var validSlice = response.records.slice(0, lastValidIndex + 1);

                    var sliceNum = validSlice.length; 
                    for (var i = 0; i < sliceNum; ++i) {
                        episodes.push(validSlice[i]);
                    }

                    // There probably is more. Get the next page.
                    indexCompletedImpl(episodes, page + 1, until);
                    return;
                }

                // Got everything. Poke Synology to index these.
                index(episodes);
            });
        });

    request.end();
}

function indexCompleted(until: Date) {
    var episodes: IEpisode[] = [];
    indexCompletedImpl(episodes, 1, until);
}

if (!(host && port && apiKey) || isNaN(restartAfter)) {
    console.log("Usage: node synopoke.js <host> <port> <apiKey> <restartAfter>");
    process.exit(1);
}

function start(timeout: number) {
    setTimeout(
        () => {
            fs.readFile(LatestEpisodePath, 'utf8', (err, data) => {
                if (err) {
                    console.log('Unable to load ' + LatestEpisodePath);
                    console.log('Scanning for downloads all downloads...');

                    indexCompleted(new Date(0));
                }
                else {
                    var latestEpisode = new Date(data);

                    if (isNaN(latestEpisode.getTime())) {
                        console.log(LatestEpisodePath + ' has invalid data');
                        console.log('Scanning for all downloads...');

                        indexCompleted(new Date(0));
                    }
                    else {
                        console.log('Scanning for downloads until ' + latestEpisode);
                        indexCompleted(latestEpisode);
                    }
                }
            });
        },
        timeout);
}

process.on('uncaughtException', err => {
    console.error('Ooops, that didn\'t work:');
    console.error(err);
    process.exit(1);
});

start(0);