chore(streams): Lint fixes

This commit is contained in:
Teagan glenn 2024-06-29 23:10:33 +00:00
parent 85e7ebac0c
commit 499933e424
2 changed files with 47 additions and 47 deletions

View File

@ -1,5 +1,5 @@
const migrate_name = 'stream_load_balance'; const migrate_name = 'stream_load_balance';
const logger = require('../logger').migrate; const logger = require('../logger').migrate;
/** /**
* Migrate * Migrate

View File

@ -1,65 +1,65 @@
// Objection Docs: // Objection Docs:
// http://vincit.github.io/objection.js/ // http://vincit.github.io/objection.js/
const db = require('../db'); const db = require('../db');
const Model = require('objection').Model; const Model = require('objection').Model;
const User = require('./user'); const User = require('./user');
const now = require('./now_helper'); const now = require('./now_helper');
Model.knex(db); Model.knex(db);
class Stream extends Model { class Stream extends Model {
$beforeInsert() { $beforeInsert() {
this.created_on = now(); this.created_on = now();
this.modified_on = now(); this.modified_on = now();
// Default for forwarding_hosts // Default for forwarding_hosts
if (typeof this.forwarding_hosts === 'undefined') { if (typeof this.forwarding_hosts === 'undefined') {
this.forwarding_hosts = []; this.forwarding_hosts = [];
} }
// Default for meta // Default for meta
if (typeof this.meta === 'undefined') { if (typeof this.meta === 'undefined') {
this.meta = {}; this.meta = {};
} }
} }
$beforeUpdate() { $beforeUpdate() {
this.modified_on = now(); this.modified_on = now();
// Sort domain_names // Sort domain_names
if (typeof this.forwarding_hosts !== 'undefined') { if (typeof this.forwarding_hosts !== 'undefined') {
this.forwarding_hosts.sort(); this.forwarding_hosts.sort();
} }
} }
static get name() { static get name() {
return 'Stream'; return 'Stream';
} }
static get tableName() { static get tableName() {
return 'stream'; return 'stream';
} }
static get jsonAttributes() { static get jsonAttributes() {
return ['forwarding_hosts', 'meta']; return ['forwarding_hosts', 'meta'];
} }
static get relationMappings() { static get relationMappings() {
return { return {
owner: { owner: {
relation: Model.HasOneRelation, relation: Model.HasOneRelation,
modelClass: User, modelClass: User,
join: { join: {
from: 'stream.owner_user_id', from: 'stream.owner_user_id',
to: 'user.id' to: 'user.id'
}, },
modify: function (qb) { modify: function (qb) {
qb.where('user.is_deleted', 0); qb.where('user.is_deleted', 0);
} }
} }
}; };
} }
} }
module.exports = Stream; module.exports = Stream;