100 lines
4.7 KiB
JavaScript
100 lines
4.7 KiB
JavaScript
// Generated, do not edit. sha256:db61aab12929b00d557fdd117e7a5efb89fd1b2bb3eb23c37364a1d19f493bbc
|
|
import * as db from '../db.js';
|
|
import { SOURCE_CAPABILITIES, SOURCE_ENDPOINTS } from '../../shared/config.js';
|
|
import { assertEnum } from './_shared.js';
|
|
import { hasFeature } from '../license.mjs';
|
|
import { fail } from '../../shared/app-error.js';
|
|
import { refreshNotifications } from './notifications.js';
|
|
|
|
export function priceSourceChain(assetId, capability) {
|
|
return db.all(
|
|
`SELECT Provider.key AS key
|
|
FROM PriceSource
|
|
JOIN Provider ON Provider.id = PriceSource.providerId
|
|
WHERE PriceSource.assetId = ? AND PriceSource.capability = ? AND PriceSource.rank IS NOT NULL
|
|
ORDER BY PriceSource.rank`,
|
|
[assetId, capability]
|
|
).map(r => r.key);
|
|
}
|
|
|
|
export function ownPriceSourceChain(assetId, capability) {
|
|
return db.all(
|
|
`SELECT Provider.key AS key
|
|
FROM PriceSource
|
|
JOIN Provider ON Provider.id = PriceSource.providerId
|
|
WHERE PriceSource.assetId = ? AND PriceSource.capability = ? AND PriceSource.rank IS NOT NULL
|
|
AND PriceSource.status = 'manual'
|
|
ORDER BY PriceSource.rank`,
|
|
[assetId, capability]
|
|
).map(r => r.key);
|
|
}
|
|
|
|
export function listPriceSource() {
|
|
return db.all(`SELECT assetId, capability, providerId, rank, status FROM PriceSource`);
|
|
}
|
|
|
|
function assertMatrixAllowed() {
|
|
if (hasFeature('sourceMatrix')) return;
|
|
fail('integrations.matrixPaid', null,
|
|
'The source matrix belongs to the paid version. The app keeps using the standard sources.');
|
|
}
|
|
|
|
function assertAnswers(providerId, capability) {
|
|
const eindpunten = SOURCE_ENDPOINTS[capability];
|
|
if (!db.one(`SELECT 1 AS x FROM ProviderEndpoint WHERE providerId = ? AND capability IN (${eindpunten.map(() => '?').join(',')})`,
|
|
[providerId, ...eindpunten]))
|
|
throw new Error('This provider does not cover this capability.');
|
|
}
|
|
|
|
export async function setPriceSourceRank(assetId, capability, providerId) {
|
|
assertMatrixAllowed();
|
|
assertEnum('capability', SOURCE_CAPABILITIES, capability);
|
|
assertAnswers(providerId, capability);
|
|
const used = db.all(`SELECT DISTINCT PriceSource.rank FROM PriceSource
|
|
JOIN Asset ON Asset.id = PriceSource.assetId
|
|
JOIN ProviderCoverage ON ProviderCoverage.providerId = PriceSource.providerId
|
|
AND ProviderCoverage.symbol = Asset.symbol
|
|
WHERE PriceSource.assetId = ? AND PriceSource.capability = ?
|
|
AND PriceSource.rank IS NOT NULL AND PriceSource.status IN ('confirmed','manual')`,
|
|
[assetId, capability]).map(r => r.rank);
|
|
let next = 1;
|
|
while (used.includes(next)) next += 1;
|
|
db.run(`DELETE FROM PriceSource WHERE assetId = ? AND capability = ? AND (providerId = ? OR rank = ?)`,
|
|
[assetId, capability, providerId, next]);
|
|
db.run(`INSERT INTO PriceSource (assetId, capability, providerId, rank, status, createdAt) VALUES (?,?,?,?,'manual',?)`,
|
|
[assetId, capability, providerId, next, new Date().toISOString()]);
|
|
await db.persist();
|
|
return next;
|
|
}
|
|
export async function placePriceSourceFirst(assetId, capability, providerId) {
|
|
assertMatrixAllowed();
|
|
assertEnum('capability', SOURCE_CAPABILITIES, capability);
|
|
assertAnswers(providerId, capability);
|
|
const rest = db.all(`SELECT providerId, status, createdAt FROM PriceSource
|
|
WHERE assetId = ? AND capability = ? AND rank IS NOT NULL AND providerId <> ?
|
|
ORDER BY rank`, [assetId, capability, providerId]);
|
|
db.run(`DELETE FROM PriceSource WHERE assetId = ? AND capability = ? AND (rank IS NOT NULL OR providerId = ?)`,
|
|
[assetId, capability, providerId]);
|
|
db.run(`INSERT INTO PriceSource (assetId, capability, providerId, rank, status, createdAt) VALUES (?,?,?,1,'manual',?)`,
|
|
[assetId, capability, providerId, new Date().toISOString()]);
|
|
rest.forEach((r, i) => db.run(
|
|
`INSERT INTO PriceSource (assetId, capability, providerId, rank, status, createdAt) VALUES (?,?,?,?,?,?)`,
|
|
[assetId, capability, r.providerId, i + 2, r.status, r.createdAt]));
|
|
await db.persist();
|
|
}
|
|
|
|
export async function clearPriceSourceCell(assetId, capability, providerId) {
|
|
assertMatrixAllowed();
|
|
db.run(`DELETE FROM PriceSource WHERE assetId = ? AND capability = ? AND providerId = ?`,
|
|
[assetId, capability, providerId]);
|
|
await db.persist();
|
|
}
|
|
export async function confirmPriceSourceCell(assetId, capability, providerId) {
|
|
assertMatrixAllowed();
|
|
db.run(`UPDATE PriceSource SET status = 'confirmed'
|
|
WHERE assetId = ? AND capability = ? AND providerId = ? AND status = 'proposed'`,
|
|
[assetId, capability, providerId]);
|
|
await db.persist();
|
|
await refreshNotifications();
|
|
}
|