slow-zone/dist/index.js

"use strict";
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
    return new (P || (P = Promise))(function (resolve, reject) {
        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
        step((generator = generator.apply(thisArg, _arguments || [])).next());
    });
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.SlowZone = void 0;
const node_https_1 = require("node:https");
const train_1 = require("./parsers/train");
const API_BASE_URL = "lapi.transitchicago.com";
const API_BASE_PATH = "/api/1.0";
const PKG_VERSION = "3.0.4";
class SlowZone {
    constructor(options) {
        this.apiKey = options.apiKey;
    }
    getArrivalsForStation(stationId, options = {}) {
        return this.getArrivals(Object.assign(Object.assign({}, options), { mapid: stationId }));
    }
    getArrivalsForStop(stopId, options = {}) {
        return this.getArrivals(Object.assign(Object.assign({}, options), { stpid: stopId }));
    }
    followTrain(runId) {
        return this.fetch("ttfollow.aspx", { runnumber: runId });
    }
    getArrivals(options = {}) {
        return this.fetch("ttarrivals.aspx", options);
    }
    fetch(endpoint, queryParams) {
        return __awaiter(this, void 0, void 0, function* () {
            return this.makeRequest(endpoint, queryParams).then((resp) => {
                return new Promise((resolve, reject) => {
                    if (!resp) {
                        reject(new Error("invalid response"));
                    }
                    if (resp.ctatt.errCd != "0") {
                        return reject(new Error(`[${resp.ctatt.errCd}] ${resp.ctatt.errNm}`));
                    }
                    resolve(resp.ctatt.eta.map((trainData) => new train_1.Train(trainData).toJSON()));
                });
            });
        });
    }
    makeRequest(endpoint, queryParams = {}) {
        return __awaiter(this, void 0, void 0, function* () {
            const query = new URLSearchParams(Object.assign(Object.assign({}, queryParams), { key: this.apiKey, outputType: "json" }));
            const options = {
                hostname: API_BASE_URL,
                port: 443,
                path: `${API_BASE_PATH}/${endpoint}?${query.toString()}`,
                method: "GET",
                headers: {
                    Accept: "application/json",
                    "User-Agent": `slow-zone/${PKG_VERSION}`,
                },
            };
            return new Promise(function (resolve, reject) {
                const req = (0, node_https_1.request)(options, (res) => {
                    if (res.statusCode && (res.statusCode < 200 || res.statusCode >= 300)) {
                        return reject(new Error(res.statusCode.toString()));
                    }
                    let body = [], json;
                    res.on("data", (chunk) => {
                        body.push(chunk);
                    });
                    res.on("end", () => {
                        try {
                            json = JSON.parse(Buffer.concat(body).toString());
                        }
                        catch (e) {
                            return reject(e);
                        }
                        return resolve(json);
                    });
                });
                req.on("error", (err) => {
                    return reject(err);
                });
                req.end();
            });
        });
    }
}
exports.SlowZone = SlowZone;
module.exports = SlowZone;