Na}{

File Content: `heart.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.Heart = void 0;
exports.heartbeatTimer = heartbeatTimer;
const logger_1 = require("@coder/logger");
const fs_1 = require("fs");
/**
 * Provides a heartbeat using a local file to indicate activity.
 */
class Heart {
    constructor(heartbeatPath, isActive) {
        this.heartbeatPath = heartbeatPath;
        this.isActive = isActive;
        this.heartbeatInterval = 60000;
        this.lastHeartbeat = 0;
        this.beat = this.beat.bind(this);
        this.alive = this.alive.bind(this);
    }
    alive() {
        const now = Date.now();
        return now - this.lastHeartbeat < this.heartbeatInterval;
    }
    /**
     * Write to the heartbeat file if we haven't already done so within the
     * timeout and start or reset a timer that keeps running as long as there is
     * activity. Failures are logged as warnings.
     */
    beat() {
        return __awaiter(this, void 0, void 0, function* () {
            if (this.alive()) {
                return;
            }
            logger_1.logger.debug("heartbeat");
            this.lastHeartbeat = Date.now();
            if (typeof this.heartbeatTimer !== "undefined") {
                clearTimeout(this.heartbeatTimer);
            }
            this.heartbeatTimer = setTimeout(() => heartbeatTimer(this.isActive, this.beat), this.heartbeatInterval);
            try {
                return yield fs_1.promises.writeFile(this.heartbeatPath, "");
            }
            catch (error) {
                logger_1.logger.warn(error.message);
            }
        });
    }
    /**
     * Call to clear any heartbeatTimer for shutdown.
     */
    dispose() {
        if (typeof this.heartbeatTimer !== "undefined") {
            clearTimeout(this.heartbeatTimer);
        }
    }
}
exports.Heart = Heart;
/**
 * Helper function for the heartbeatTimer.
 *
 * If heartbeat is active, call beat. Otherwise do nothing.
 *
 * Extracted to make it easier to test.
 */
function heartbeatTimer(isActive, beat) {
    return __awaiter(this, void 0, void 0, function* () {
        try {
            if (yield isActive()) {
                beat();
            }
        }
        catch (error) {
            logger_1.logger.warn(error.message);
        }
    });
}
//# sourceMappingURL=heart.js.map

Name	Size	Permission
i18n	---	0755
routes	---	0755
app.js	6398 bytes	0644
app.js.map	3494 bytes	0644
cli.js	27712 bytes	0644
cli.js.map	19411 bytes	0644
constants.js	3005 bytes	0644
constants.js.map	1481 bytes	0644
entry.js	3618 bytes	0755
entry.js.map	2094 bytes	0644
heart.js	3026 bytes	0644
heart.js.map	1621 bytes	0644
http.js	16133 bytes	0644
http.js.map	9711 bytes	0644
main.js	9640 bytes	0644
main.js.map	6451 bytes	0644
proxy.js	1519 bytes	0644
proxy.js.map	967 bytes	0644
settings.js	2303 bytes	0644
settings.js.map	1054 bytes	0644
socket.js	5787 bytes	0644
socket.js.map	3308 bytes	0644
update.js	7125 bytes	0644
update.js.map	4156 bytes	0644
util.js	18167 bytes	0644
util.js.map	11784 bytes	0644
vscodeSocket.js	9229 bytes	0644
vscodeSocket.js.map	5555 bytes	0644
wrapper.js	13535 bytes	0644
wrapper.js.map	9398 bytes	0644
wsRouter.js	2776 bytes	0644
wsRouter.js.map	1370 bytes	0644

File Content: heart.js

File Content: `heart.js`