[enh] #1084 WS2P: add WS2P handling in PeerDTO + database search

app/lib/common-libs/constants.ts

@@ -27,6 +27,7 @@ const UNLOCK       = "(SIG\\(" + INTEGER + "\\)|XHX\\(" + XUNLOCK + "\\))"
 const CONDITIONS   = "(&&|\\|\\|| |[()]|(SIG\\(" + PUBKEY + "\\)|(XHX\\([A-F0-9]{64}\\)|CLTV\\(" + CLTV_INTEGER + "\\)|CSV\\(" + CSV_INTEGER + "\\))))*"
 
 const BMA_REGEXP  = /^BASIC_MERKLED_API( ([a-z_][a-z0-9-_.]*))?( ([0-9.]+))?( ([0-9a-f:]+))?( ([0-9]+))$/
+const WS2P_REGEXP = /^WS2P ([a-f0-9]{8}) ([a-z_][a-z0-9-_.]*|[0-9.]+|[0-9a-f:]+) ([0-9]+)$/
 
 const MAXIMUM_LEN_OF_COMPACT_TX = 100
 const MAXIMUM_LEN_OF_OUTPUT = 2000
@@ -76,6 +77,7 @@ export const CommonConstants = {
   SWITCH_ON_BRANCH_AHEAD_BY_X_BLOCKS: 3,
 
   BMA_REGEXP,
+  WS2P_REGEXP,
   PUBLIC_KEY: exact(PUBKEY),
   INTEGER: /^\d+$/,
   BASE58: exact(BASE58),

app/lib/dal/fileDAL.ts

@@ -141,6 +141,10 @@ export class FileDAL {
     }
   }
 
+  async getWS2Peers() {
+    return this.peerDAL.getPeersWithEndpointsLike('WS2P ')
+  }
+
   async getBlock(number:number) {
     const block = await this.blockDAL.getBlock(number)
     return block || null;

app/lib/dal/sqliteDAL/PeerDAL.ts

@@ -93,6 +93,10 @@ export class PeerDAL extends AbstractSQLite<DBPeer> {
     return this.sqlFindOne({ pubkey: pubkey })
   }
 
+  getPeersWithEndpointsLike(str:string) {
+    return this.query('SELECT * FROM peer WHERE endpoints LIKE ?', ['%' + str + '%'])
+  }
+
   savePeer(peer:DBPeer) {
     return this.saveEntity(peer)
   }

app/lib/dto/ConfDTO.ts

@@ -60,6 +60,7 @@ export interface NetworkConfDTO {
 
 export interface WS2PConfDTO {
   ws2p?: {
+    uuid: string
     upnp?: boolean
     remotehost?: string|null
     remoteport?: number|null
@@ -68,7 +69,7 @@ export interface WS2PConfDTO {
   }
 }
 
-export class ConfDTO implements CurrencyConfDTO, KeypairConfDTO, NetworkConfDTO, BranchingDTO {
+export class ConfDTO implements CurrencyConfDTO, KeypairConfDTO, NetworkConfDTO, BranchingDTO, WS2PConfDTO {
 
   constructor(
     public loglevel: string,
@@ -124,6 +125,14 @@ export class ConfDTO implements CurrencyConfDTO, KeypairConfDTO, NetworkConfDTO,
     public upnp: boolean,
     public homename: string,
     public memory: boolean,
+    public ws2p?: {
+      uuid: string
+      upnp?: boolean
+      remotehost?: string|null
+      remoteport?: number|null
+      port?: number
+      host?: string
+    }
 ) {}
 
   static mock() {

app/lib/dto/PeerDTO.ts

@@ -3,6 +3,12 @@ import {hashf} from "../common"
 import {CommonConstants} from "../common-libs/constants"
 import {Cloneable} from "./Cloneable"
 
+export interface WS2PEndpoint {
+  uuid:string
+  host:string
+  port:number
+}
+
 export class PeerDTO implements Cloneable {
 
   clone(): any {
@@ -86,7 +92,22 @@ export class PeerDTO implements Cloneable {
       }
     });
     return bma || {};
-  };
+  }
+
+  getWS2P() {
+    let api:any = null;
+    this.endpoints.forEach((ep) => {
+      const matches = !api && ep.match(CommonConstants.WS2P_REGEXP)
+      if (matches) {
+        api = {
+          uuid: matches[1],
+          host: matches[2] || '',
+          port: parseInt(matches[3]) || 0
+        }
+      }
+    })
+    return api || {}
+  }
 
   getDns() {
     const bma = this.getBMA();