mirror of
https://github.com/Cameri/nostream.git
synced 2025-06-06 04:59:19 +02:00
refactor: linting and pr feedback
This commit is contained in:
parent
e5c070b66b
commit
34f4c93d9d
@ -85,7 +85,7 @@ const parseOneLevelDeepConfigs = (configs, category) => {
|
|||||||
console.log(keys)
|
console.log(keys)
|
||||||
const flattenedConfigs = Object.keys(configs).map(key => {
|
const flattenedConfigs = Object.keys(configs).map(key => {
|
||||||
return {
|
return {
|
||||||
id: uuidv5('id', NAMESPACE),
|
id: uuidv5('key', NAMESPACE),
|
||||||
key,
|
key,
|
||||||
value: configs[key],
|
value: configs[key],
|
||||||
category
|
category
|
||||||
|
@ -2,8 +2,8 @@ import { PassThrough } from 'stream'
|
|||||||
|
|
||||||
import { DatabaseClient, EventId, Pubkey } from './base'
|
import { DatabaseClient, EventId, Pubkey } from './base'
|
||||||
import { DBEvent, Event } from './event'
|
import { DBEvent, Event } from './event'
|
||||||
import { Setting } from './setting'
|
|
||||||
import { Invoice } from './invoice'
|
import { Invoice } from './invoice'
|
||||||
|
import { Setting } from './setting'
|
||||||
import { SubscriptionFilter } from './subscription'
|
import { SubscriptionFilter } from './subscription'
|
||||||
import { User } from './user'
|
import { User } from './user'
|
||||||
|
|
||||||
|
@ -9,7 +9,6 @@ import { IRunnable } from '../@types/base'
|
|||||||
import packageJson from '../../package.json'
|
import packageJson from '../../package.json'
|
||||||
import { Serializable } from 'child_process'
|
import { Serializable } from 'child_process'
|
||||||
import { Settings } from '../@types/settings'
|
import { Settings } from '../@types/settings'
|
||||||
import { SettingsStatic } from '../utils/settings'
|
|
||||||
|
|
||||||
const debug = createLogger('app-primary')
|
const debug = createLogger('app-primary')
|
||||||
|
|
||||||
@ -38,7 +37,6 @@ export class App implements IRunnable {
|
|||||||
|
|
||||||
public run(): void {
|
public run(): void {
|
||||||
const settings = this.settings()
|
const settings = this.settings()
|
||||||
// this.watchers = SettingsStatic.watchSettings()
|
|
||||||
console.log(`
|
console.log(`
|
||||||
███▄ █ ▒█████ ██████ ▄▄▄█████▓ ██▀███ ▓█████ ▄▄▄ ███▄ ▄███▓
|
███▄ █ ▒█████ ██████ ▄▄▄█████▓ ██▀███ ▓█████ ▄▄▄ ███▄ ▄███▓
|
||||||
██ ▀█ █ ▒██▒ ██▒▒██ ▒ ▓ ██▒ ▓▒▓██ ▒ ██▒▓█ ▀▒████▄ ▓██▒▀█▀ ██▒
|
██ ▀█ █ ▒██▒ ██▒▒██ ▒ ▓ ██▒ ▓▒▓██ ▒ ██▒▓█ ▀▒████▄ ▓██▒▀█▀ ██▒
|
||||||
|
@ -3,11 +3,11 @@ import dotenv from 'dotenv'
|
|||||||
dotenv.config()
|
dotenv.config()
|
||||||
|
|
||||||
import { appFactory } from './factories/app-factory'
|
import { appFactory } from './factories/app-factory'
|
||||||
|
import { getMasterDbClient } from './database/client'
|
||||||
import { maintenanceWorkerFactory } from './factories/maintenance-worker-factory'
|
import { maintenanceWorkerFactory } from './factories/maintenance-worker-factory'
|
||||||
|
import { SettingsStatic } from './utils/settings'
|
||||||
import { staticMirroringWorkerFactory } from './factories/static-mirroring.worker-factory'
|
import { staticMirroringWorkerFactory } from './factories/static-mirroring.worker-factory'
|
||||||
import { workerFactory } from './factories/worker-factory'
|
import { workerFactory } from './factories/worker-factory'
|
||||||
import { getMasterDbClient } from './database/client'
|
|
||||||
import { SettingsStatic } from './utils/settings'
|
|
||||||
|
|
||||||
export const getRunner = (): any => {
|
export const getRunner = (): any => {
|
||||||
const dbClient = getMasterDbClient()
|
const dbClient = getMasterDbClient()
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
import { always, applySpec, omit, prop } from 'ramda'
|
import { always, applySpec, omit, prop } from 'ramda'
|
||||||
|
|
||||||
import { Setting, DBSetting } from '../@types/setting'
|
import { DBSetting, Setting } from '../@types/setting'
|
||||||
import { createLogger } from '../factories/logger-factory'
|
import { createLogger } from '../factories/logger-factory'
|
||||||
import { DatabaseClient } from '../@types/base'
|
import { DatabaseClient } from '../@types/base'
|
||||||
import { fromDBSetting } from '../utils/transform'
|
import { fromDBSetting } from '../utils/transform'
|
||||||
@ -16,7 +16,7 @@ export class SettingRepository implements ISettingRepository {
|
|||||||
key: string,
|
key: string,
|
||||||
client: DatabaseClient = this.dbClient
|
client: DatabaseClient = this.dbClient
|
||||||
): Promise<Setting | undefined> {
|
): Promise<Setting | undefined> {
|
||||||
debug('find config by key: %s and category %s', category, key);
|
debug('find config by key: %s and category %s', category, key)
|
||||||
const [dbsetting] = await client<DBSetting>('configs')
|
const [dbsetting] = await client<DBSetting>('configs')
|
||||||
.where('key', key)
|
.where('key', key)
|
||||||
.where('category', category)
|
.where('category', category)
|
||||||
@ -32,7 +32,7 @@ export class SettingRepository implements ISettingRepository {
|
|||||||
public async getSettings(
|
public async getSettings(
|
||||||
client: DatabaseClient = this.dbClient
|
client: DatabaseClient = this.dbClient
|
||||||
): Promise<Setting[] | undefined> {
|
): Promise<Setting[] | undefined> {
|
||||||
debug('get all configs');
|
debug('get all configs')
|
||||||
const settings = await client<Setting>('configs')
|
const settings = await client<Setting>('configs')
|
||||||
.select()
|
.select()
|
||||||
|
|
||||||
|
@ -1,8 +1,8 @@
|
|||||||
import { createLogger } from '../factories/logger-factory'
|
import { createLogger } from '../factories/logger-factory'
|
||||||
import { Settings } from '../@types/settings'
|
|
||||||
import { SettingRepository } from '../repositories/settings-repository'
|
|
||||||
import { Setting } from '../@types/setting'
|
|
||||||
import { DatabaseClient } from '../@types/base'
|
import { DatabaseClient } from '../@types/base'
|
||||||
|
import { Setting } from '../@types/setting'
|
||||||
|
import { SettingRepository } from '../repositories/settings-repository'
|
||||||
|
import { Settings } from '../@types/settings'
|
||||||
|
|
||||||
const debug = createLogger('settings')
|
const debug = createLogger('settings')
|
||||||
|
|
||||||
@ -15,10 +15,11 @@ export class SettingsStatic {
|
|||||||
constructor(dbClient: DatabaseClient) {
|
constructor(dbClient: DatabaseClient) {
|
||||||
SettingsStatic.dbClient = dbClient
|
SettingsStatic.dbClient = dbClient
|
||||||
SettingsStatic.settingsRepository = new SettingRepository(dbClient)
|
SettingsStatic.settingsRepository = new SettingRepository(dbClient)
|
||||||
if (SettingsStatic._instance)
|
if (SettingsStatic._instance) {
|
||||||
throw new Error("Use Singleton.instance instead of new.")
|
throw new Error('Use Singleton.instance instead of new.')
|
||||||
|
}
|
||||||
|
|
||||||
SettingsStatic._instance = this;
|
SettingsStatic._instance = this
|
||||||
}
|
}
|
||||||
|
|
||||||
public init() {
|
public init() {
|
||||||
@ -33,7 +34,7 @@ export class SettingsStatic {
|
|||||||
}
|
}
|
||||||
|
|
||||||
static get instance() {
|
static get instance() {
|
||||||
return SettingsStatic._instance ?? (SettingsStatic._instance = new SettingsStatic(this.dbClient));
|
return SettingsStatic._instance ?? (SettingsStatic._instance = new SettingsStatic(this.dbClient))
|
||||||
}
|
}
|
||||||
|
|
||||||
private static loadSettingsFromDb(callback) {
|
private static loadSettingsFromDb(callback) {
|
||||||
@ -41,9 +42,9 @@ export class SettingsStatic {
|
|||||||
const promise = SettingsStatic.settingsRepository.getSettings()
|
const promise = SettingsStatic.settingsRepository.getSettings()
|
||||||
|
|
||||||
return promise.then(rawSettingsFromDb => {
|
return promise.then(rawSettingsFromDb => {
|
||||||
const settingsJsonBlob = callback(rawSettingsFromDb);
|
const settingsJsonBlob = callback(rawSettingsFromDb)
|
||||||
this._settings = settingsJsonBlob
|
this._settings = settingsJsonBlob
|
||||||
});
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@ -2,8 +2,8 @@ import { always, applySpec, ifElse, is, isNil, path, pipe, prop, propSatisfies }
|
|||||||
import { bech32 } from 'bech32'
|
import { bech32 } from 'bech32'
|
||||||
|
|
||||||
import { Invoice } from '../@types/invoice'
|
import { Invoice } from '../@types/invoice'
|
||||||
import { User } from '../@types/user'
|
|
||||||
import { Setting } from '../@types/setting'
|
import { Setting } from '../@types/setting'
|
||||||
|
import { User } from '../@types/user'
|
||||||
|
|
||||||
export const toJSON = (input: any) => JSON.stringify(input)
|
export const toJSON = (input: any) => JSON.stringify(input)
|
||||||
|
|
||||||
|
@ -11,7 +11,6 @@ import {
|
|||||||
import { assocPath, pipe } from 'ramda'
|
import { assocPath, pipe } from 'ramda'
|
||||||
import { fromEvent, map, Observable, ReplaySubject, Subject, takeUntil } from 'rxjs'
|
import { fromEvent, map, Observable, ReplaySubject, Subject, takeUntil } from 'rxjs'
|
||||||
import WebSocket, { MessageEvent } from 'ws'
|
import WebSocket, { MessageEvent } from 'ws'
|
||||||
import Sinon from 'sinon'
|
|
||||||
|
|
||||||
import { connect, createIdentity, createSubscription, sendEvent } from './helpers'
|
import { connect, createIdentity, createSubscription, sendEvent } from './helpers'
|
||||||
import { getMasterDbClient, getReadReplicaDbClient } from '../../../src/database/client'
|
import { getMasterDbClient, getReadReplicaDbClient } from '../../../src/database/client'
|
||||||
@ -39,7 +38,6 @@ BeforeAll({ timeout: 1000 }, async function () {
|
|||||||
dbClient = getMasterDbClient()
|
dbClient = getMasterDbClient()
|
||||||
rrDbClient = getReadReplicaDbClient()
|
rrDbClient = getReadReplicaDbClient()
|
||||||
await dbClient.raw('SELECT 1=1')
|
await dbClient.raw('SELECT 1=1')
|
||||||
// Sinon.stub(SettingsStatic, 'watchSettings')
|
|
||||||
const settings = SettingsStatic.createSettings()
|
const settings = SettingsStatic.createSettings()
|
||||||
|
|
||||||
SettingsStatic._settings = pipe(
|
SettingsStatic._settings = pipe(
|
||||||
|
Loading…
x
Reference in New Issue
Block a user