Merge pull request #40 from joyja/indexes

Indexes

.gitignore

@@ -91,3 +91,4 @@ sw.*
 
 # production database
 /spread-edge*.db
+/tentacle-edge*.db

src/database/model.js

@@ -50,7 +50,7 @@ class Model {
       logger.error(error, { message: `sql: ${sql}` })
     })
   }
-  static createTable() {
+  static async createTable() {
     // fields should be formatted { colName, colType } for typical columns
     // fields should be formatted { colName, colRef, onDelete } for foreign key
     this.checkInitialized()
@@ -69,7 +69,14 @@ class Model {
       }
     })
     sql = `${sql});`
-    return this.executeUpdate(sql)
+    const result = await this.executeUpdate(sql)
+    for (const field of this.fields) {
+      if (field.colRef) {
+        sql = `CREATE INDEX IF NOT EXISTS idx_${this.table}_${field.colName} ON ${this.table} (${field.colName});`
+        await this.executeUpdate(sql)
+      }
+    }
+    return result
   }
   static async initialize(db, pubsub) {
     this.initialized = true

src/index.js

@@ -1,4 +1,4 @@
 #!/usr/bin/env node
 require('make-promises-safe')
 const { start } = require('./server')
-start('spread-edge.db')
+start('tentacle-edge.db')

src/relations.js

@@ -10,7 +10,7 @@ const { Service, Mqtt, MqttSource, MqttHistory } = require('./service')
 const { User } = require('./auth')
 const getTime = require('date-fns/getTime')
 
-// This file creates any properties that form relationships with other models.
+// This file creates properties and defines methods requiring relationships with other models.
 // It is defined here to prevent circular dependencies.
 
 // ==============================
@@ -45,6 +45,13 @@ Object.defineProperties(ScanClass.prototype, {
   }
 })
 
+Tag.delete = async function(selector) {
+  const deleted = await this._deleteModel(selector)
+  await ModbusSource.getAll()
+  await EthernetIPSource.getAll()
+  return deleted
+}
+
 Tag.prototype.setScanClass = async function(id) {
   const scanClass = ScanClass.findById(id)
   if (scanClass) {

src/service/service.js

@@ -40,9 +40,6 @@ class Service extends Model {
     this._createdBy = result.createdBy
     this._createdOn = result.createdOn
   }
-  delete() {
-    return super.delete(Service)
-  }
   get name() {
     this.checkInit()
     return this._name

src/tag.js

@@ -46,6 +46,9 @@ class Tag extends Model {
     }
     return super.create(fields)
   }
+  static _deleteModel(selector) {
+    return super.delete(selector)
+  }
   async init(async) {
     const result = await super.init(async)
     this._name = result.name