Feat/settle taggers

src/controllers/index.ts

@@ -23,6 +23,7 @@ import { failure } from '../utils/res'
 import * as auth from './auth'
 import * as personal from './api/personal'
 import * as lsats from './lsats'
+import * as taggers from './taggers'
 import { Req } from '../types'
 
 export async function set(app) {
@@ -170,6 +171,8 @@ export async function set(app) {
   app.post('/lsats', lsats.saveLsat)
   app.put('/lsats/:identifier', lsats.updateLsat)
   app.delete('/lsats/:identifier', lsats.deleteLsat)
+
+  app.post('/pay_taggers', taggers.payTagger)
 }
 
 const msgtypes = constants.message_types

src/controllers/taggers.ts

@@ -0,0 +1,59 @@
+import { Req } from '../types'
+import { Response } from 'express'
+import { failure, success } from '../utils/res'
+import * as Lightning from '../grpc/lightning'
+import { models } from '../models'
+
+export const payTagger = async (
+  req: Req,
+  res: Response
+): Promise<void | Response> => {
+  if (!req.owner) return failure(res, 'no owner')
+  const { amount, pubkey, ref_id, timestamp, type } = req.body
+
+  if (!amount && !pubkey && !ref_id && !type) {
+    return failure(res, 'Invalid data provided')
+  }
+
+  if (
+    typeof amount !== 'number' &&
+    typeof pubkey !== 'string' &&
+    typeof ref_id !== 'string' &&
+    typeof timestamp !== 'string' &&
+    typeof type != 'string'
+  )
+    return failure(res, 'Invalid data provided')
+
+  if (pubkey.length !== 66) {
+    return failure(res, 'Invalid Public Key')
+  }
+  const tenant: number = req.owner.id
+  try {
+    await Lightning.keysend({
+      amt: amount,
+      dest: pubkey,
+    })
+    await models.Tagger.create({
+      tenant,
+      amount,
+      pubkey,
+      type,
+      refId: ref_id,
+      timestamp,
+      status: 1,
+    })
+    return success(res, 'Payment Successful')
+  } catch (e) {
+    console.log(e)
+    await models.Tagger.create({
+      tenant,
+      amount,
+      pubkey,
+      type,
+      refId: ref_id,
+      timestamp,
+      status: 0,
+    })
+    return failure(res, 'An error occured')
+  }
+}

src/models/index.ts

@@ -21,6 +21,7 @@ import * as minimist from 'minimist'
 import { loadConfig } from '../utils/config'
 import { isProxy } from '../utils/proxy'
 import { readFileSync } from 'fs'
+import Tagger, { TaggerRecord } from './sql/taggers'
 
 const argv = minimist(process.argv.slice(2))
 
@@ -51,6 +52,7 @@ const opts = {
     Accounting,
     Lsat,
     RequestsTransportTokens,
+    Tagger,
   ],
 }
 if (isProxy()) {
@@ -92,4 +94,6 @@ export {
   Lsat,
   BotMember,
   RequestsTransportTokens,
+  Tagger,
+  TaggerRecord,
 }

src/models/sql/taggers.ts

@@ -0,0 +1,38 @@
+import { Table, Column, Model, DataType, AllowNull } from 'sequelize-typescript'
+
+@Table({ tableName: 'sphinx_tagger', underscored: true })
+export default class Tagger extends Model<Tagger> {
+  @Column({
+    type: DataType.BIGINT,
+    primaryKey: true,
+    unique: true,
+    autoIncrement: true,
+  })
+  id: number
+
+  @Column
+  pubkey: string
+
+  @Column
+  tenant: number
+
+  @Column
+  type: string
+
+  @Column(DataType.DECIMAL)
+  amount: number
+
+  @Column
+  refId: string
+
+  @Column
+  status: number
+
+  @AllowNull(true)
+  @Column
+  timestamp: string
+}
+
+export interface TaggerRecord extends Tagger {
+  dataValues: Tagger
+}

testing/stack/alice-db.json

@@ -1,6 +1,6 @@
 {
   "development": {
     "dialect": "sqlite",
-    "storage": "/Users/evanfeenstra/code/sphinx/sphinx-stack/relay/db/alice.db"
+    "storage": "/Users/mac/Desktop/work/sphinx/sphinx-stack/relay/db/alice.db"
   }
 }

testing/stack/alice.json

@@ -3,8 +3,8 @@
     "node_ip": "127.0.0.1",
     "lnd_ip": "127.0.0.1",
     "lnd_port": "10009",
-    "tls_location": "/Users/evanfeenstra/code/sphinx/sphinx-stack/lnd/alice/.lnd/tls.cert",
-    "macaroon_location": "/Users/evanfeenstra/code/sphinx/sphinx-stack/lnd/alice/.lnd/data/chain/bitcoin/regtest/admin.macaroon",
+    "tls_location": "/Users/mac/Desktop/work/sphinx/sphinx-stack/lnd/alice/.lnd/tls.cert",
+    "macaroon_location": "/Users/mac/Desktop/work/sphinx/sphinx-stack/lnd/alice/.lnd/data/chain/bitcoin/regtest/admin.macaroon",
     "node_http_protocol": "http",
     "node_http_port": "3001",
     "media_host": "localhost:5555",