Transfer existing subdomains to new addresses

.gitignore

@@ -58,8 +58,10 @@ typings/
 # dotenv environment variables file
 .env
 
+.DS_Store
 data
 lib
 tests/lib
 .vscode
 package-lock.json
+*.db

package.json

@@ -13,6 +13,7 @@
     "blockstack": "^21.1.1",
     "bn.js": "^4.11.9",
     "cors": "^2.8.4",
+    "crypto": "^1.0.1",
     "express": "^4.16.2",
     "node-fetch": "^2.6.7",
     "prom-client": "^11.5.3",

src/db.js

@@ -214,6 +214,46 @@ export class RegistrarQueueDB {
     return dbRun(this.db, dbCmd, dbArgs)
   }
 
+  async makeTransferUpdates(
+    transferedSubdomains: QueueRecord[],
+    txHash: string
+  ): Promise<void> {
+    const dbCmd =
+      'INSERT INTO subdomain_queue ' +
+      '(subdomainName, owner, sequenceNumber, zonefile, signature, status, status_more) VALUES ' +
+      '(?, ?, ?, ?, ?, ?, ?)'
+
+    Promise.all(transferedSubdomains.map((subdomain) => dbRun(this.db, dbCmd, [
+      subdomain.subdomainName,
+      subdomain.owner,
+      subdomain.sequenceNumber,
+      subdomain.zonefile,
+      subdomain.signature,
+      'submitted',
+      txHash
+    ])))
+  }
+
+  logTransferRequestorData(
+    subdomainName: string,
+    ownerAddress: string,
+    ipAddress: string
+  ) {
+    const lookup = `SELECT queue_ix FROM subdomain_queue WHERE subdomainName = ?
+                    AND owner = ? AND sequenceNumber = 1`
+    const insert =
+      'INSERT INTO ip_info (ip_address, owner, queue_ix) VALUES (?, ?, ?)'
+    return dbAll(this.db, lookup, [subdomainName, ownerAddress]).then(
+      (results) => {
+        if (results.length != 1) {
+          throw new Error('No queued entry found.')
+        }
+        const queueIndex = results[0].queue_ix
+        return dbRun(this.db, insert, [ipAddress, ownerAddress, queueIndex])
+      }
+    )
+  }
+
   async updateStatusFor(
     subdomains: Array<string>,
     status: string,
@@ -291,6 +331,29 @@ export class RegistrarQueueDB {
     return dbAll(this.db, lookup, [subdomainName])
   }
 
+  async getSubdomainRecord(subdomainName: string): Promise<SubdomainRecord> {
+    const lookup =
+      'SELECT subdomainName, owner, sequenceNumber, zonefile, signature, status, queue_ix' +
+      ' FROM subdomain_queue' +
+      ' WHERE subdomainName = ? ORDER BY queue_ix DESC LIMIT 1'
+
+    const result = await dbAll(this.db, lookup, [subdomainName])
+
+    if (result.length != 1) {
+      throw new Error('no subdomain found')
+    }
+    return {
+      subdomainName: result[0].subdomainName,
+      owner: result[0].owner,
+      sequenceNumber: parseInt(result[0].sequenceNumber),
+      zonefile: result[0].zonefile,
+      signature: result[0].signature,
+      status: result[0].status,
+      queue_ix: result[0].queue_ix
+    }
+
+  }
+
   async listSubdomains(
     iterator: number,
     timeLimit: number