Leahnaya/nxapi
1
0
Fork 0
mirror of https://github.com/samuelthomas2774/nxapi.git synced 2026-10-23 01:54:10 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update splatnet3-types

Browse Source
This commit is contained in:
Samuel Elliott
2022-12-12 22:54:01 +00:00
parent 205f01ebf0
commit 2ab832f6b6
7 changed files with 52 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
src/cli/pctl/dump-summaries.ts
View File

@@ -57,8 +57,11 @@ export async function handler(argv: ArgumentsCamelCase<Arguments>) {
console.warn('Downloading summaries for device %s (%s)', device.label, device.deviceId);
await dumpMonthlySummariesForDevice(moon, directory, device.deviceId);
await dumpDailySummariesForDevice(moon, directory, device.deviceId);
const monthly = await dumpMonthlySummariesForDevice(moon, directory, device.deviceId);
const daily = await dumpDailySummariesForDevice(moon, directory, device.deviceId);
console.warn('Downloaded %d monthly and %d daily summaries for device %s (%s)',
monthly.length, daily.length, device.label, device.deviceId);
}
}
@@ -66,22 +69,35 @@ async function dumpMonthlySummariesForDevice(moon: MoonApi, directory: string, d
debug('Fetching monthly summaries for device %s', device);
const monthlySummaries = await moon.getMonthlySummaries(device);
const downloaded = [];
const skipped = [];
for (const item of monthlySummaries.items) {
const filename = 'pctl-monthly-' + item.deviceId + '-' + item.month + '.json';
const file = path.join(directory, filename);
try {
await fs.stat(file);
debug('Skipping monthly summary %s for device %s, file already exists', item.month, item.deviceId);
skipped.push(item.month);
continue;
} catch (err) {}
debug('Fetching monthly summary %s for device %s', item.month, item.deviceId);
console.warn('Fetching monthly summary %s for device %s', item.month, item.deviceId);
const summary = await moon.getMonthlySummary(item.deviceId, item.month);
debug('Writing %s', filename);
await fs.writeFile(file, JSON.stringify(summary, null, 4) + '\n', 'utf-8');
downloaded.push(item.month);
}
if (skipped.length) {
if (skipped.length === 1) debug('Skipped monthly summary %s for device %s, file already exists', skipped[0], device);
else debug('Skipped monthly summaries %s for device %s, files already exist', skipped.join(', '), device);
}
return downloaded;
}
async function dumpDailySummariesForDevice(moon: MoonApi, directory: string, device: string) {
@@ -89,6 +105,9 @@ async function dumpDailySummariesForDevice(moon: MoonApi, directory: string, dev
const summaries = await moon.getDailySummaries(device);
const timestamp = Date.now();
const downloaded = [];
const skipped = [];
for (const summary of summaries.items) {
const filename = 'pctl-daily-' + summary.deviceId + '-' + summary.date +
(summary.result === DailySummaryResult.ACHIEVED ? '' : '-' + timestamp) + '.json';
@@ -96,11 +115,20 @@ async function dumpDailySummariesForDevice(moon: MoonApi, directory: string, dev
try {
await fs.stat(file);
debug('Skipping daily summary %s for device %s, file already exists', summary.date, summary.deviceId);
skipped.push(summary.date);
continue;
} catch (err) {}
debug('Writing %s', filename);
await fs.writeFile(file, JSON.stringify(summary, null, 4) + '\n', 'utf-8');
downloaded.push(summary.date);
}
if (skipped.length) {
if (skipped.length === 1) debug('Skipped daily summary %s for device %s, file already exists', skipped[0], device);
else debug('Skipped daily summaries %s for device %s, files already exist', skipped.join(', '), device);
}
return downloaded;
}