machankura/mempool
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Store AS organization in geo_names

Browse Source
This commit is contained in:
nymkappa 2022-07-12 12:12:10 +02:00
parent 47ad5fffc8
commit 3d2ff7ef62
No known key found for this signature in database
GPG Key ID: E155910B16E8BD04
2 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
backend/src/api/database-migration.ts
View File

@ -4,7 +4,7 @@ import logger from '../logger';
import { Common } from './common'; import { Common } from './common';
class DatabaseMigration { class DatabaseMigration {
private static currentVersion = 29; private static currentVersion = 30;
private queryTimeout = 120000; private queryTimeout = 120000;
private statisticsAddedIndexed = false; private statisticsAddedIndexed = false;
private uniqueLogs: string[] = []; private uniqueLogs: string[] = [];
@ -291,6 +291,10 @@ class DatabaseMigration {
await this.$executeQuery('ALTER TABLE `nodes` ADD latitude double NULL DEFAULT NULL'); await this.$executeQuery('ALTER TABLE `nodes` ADD latitude double NULL DEFAULT NULL');
} }
if (databaseSchemaVersion < 30 && isBitcoin === true) {
await this.$executeQuery('ALTER TABLE `geo_names` CHANGE `type` `type` enum("city","country","division","continent","as_organization") NOT NULL');
}
} catch (e) { } catch (e) {
throw e; throw e;
} }

7
backend/src/tasks/lightning/sync-tasks/node-locations.ts
View File

@ -52,6 +52,13 @@ export async function $lookupNodeLocation(): Promise<void> {
`INSERT IGNORE INTO geo_names (id, type, names) VALUES (?, 'city', ?)`, `INSERT IGNORE INTO geo_names (id, type, names) VALUES (?, 'city', ?)`,
[city.city?.geoname_id, JSON.stringify(city.city?.names)]); [city.city?.geoname_id, JSON.stringify(city.city?.names)]);
} }
// Store AS name
if (asn.autonomous_system_organization) {
await DB.query(
`INSERT IGNORE INTO geo_names (id, type, names) VALUES (?, 'as_organization', ?)`,
[asn.autonomous_system_number, JSON.stringify(asn.autonomous_system_organization)]);
}
} }
} }
} }