pockethost/packages/daemon/pb_hooks/update-usage.pb.js

"use strict";
// src/hooks/src/update-usage.pb.ts
console.log("update-usage");
onRecordAfterUpdateRequest(function(e) {
    var _require = require("".concat(__hooks, "/lib.js")), _unsafe_assert = _require._unsafe_assert, startOfMonth = _require.startOfMonth, endOfMonth = _require.endOfMonth, queryOne = _require.queryOne, updateInstance = _require.updateInstance, getInstance = _require.getInstance, updateUser = _require.updateUser;
    var assert = _unsafe_assert;
    var record = e.record;
    assert(record, "Expected record here");
    var instanceId = record.getString("instanceId");
    var instance = getInstance(instanceId);
    assert(instance);
    var uid = instance.getString("uid");
    assert(uid);
    var now = /* @__PURE__ */ new Date();
    var startIso = startOfMonth(now);
    var endIso = endOfMonth(now);
    {
        var result = queryOne("SELECT cast(sum(totalSeconds) as int) as t FROM invocations WHERE instanceId={:instanceId} and startedAt>={:startIso} and startedAt<={:endIso}", {
            instanceId: instanceId,
            startIso: startIso,
            endIso: endIso
        }, {
            t: 0
        });
        var secondsThisMonth = result.t;
        console.log("Instance seconds, ".concat(secondsThisMonth));
        updateInstance(instance, {
            secondsThisMonth: secondsThisMonth
        });
    }
    {
        var result1 = queryOne("SELECT cast(sum(totalSeconds) as int) as t FROM invocations WHERE uid={:uid} and startedAt>={:startIso} and startedAt<={:endIso}", {
            uid: uid,
            startIso: startIso,
            endIso: endIso
        }, {
            t: 0
        });
        var secondsThisMonth1 = result1.t;
        console.log("User seconds, ".concat(secondsThisMonth1));
        updateUser(uid, {
            secondsThisMonth: secondsThisMonth1
        });
    }
}, "invocations");