natty
/
calckey
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix spelling error

This commit is contained in:
Johann150 2022-08-04 10:20:48 +02:00 committed by ThatOneCalculator
parent 725ee609dd
commit dd28859348
5 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
packages/backend/src/db/redis.ts
View File

@ -12,7 +12,7 @@ export function createConnection() {
}); });
} }
export const subsdcriber = createConnection(); export const subscriber = createConnection();
subsdcriber.subscribe(config.host); subscriber.subscribe(config.host);
export const redisClient = createConnection(); export const redisClient = createConnection();

4
packages/backend/src/misc/antenna-cache.ts
View File

@ -1,6 +1,6 @@
import { Antennas } from '@/models/index.js'; import { Antennas } from '@/models/index.js';
import { Antenna } from '@/models/entities/antenna.js'; import { Antenna } from '@/models/entities/antenna.js';
import { subsdcriber } from '../db/redis.js'; import { subscriber } from '@/db/redis.js';
let antennasFetched = false; let antennasFetched = false;
let antennas: Antenna[] = []; let antennas: Antenna[] = [];
@ -14,7 +14,7 @@ export async function getAntennas() {
return antennas; return antennas;
} }
subsdcriber.on('message', async (_, data) => { subscriber.on('message', async (_, data) => {
const obj = JSON.parse(data); const obj = JSON.parse(data);
if (obj.channel === 'internal') { if (obj.channel === 'internal') {

4
packages/backend/src/misc/webhook-cache.ts
View File

@ -1,6 +1,6 @@
import { Webhooks } from '@/models/index.js'; import { Webhooks } from '@/models/index.js';
import { Webhook } from '@/models/entities/webhook.js'; import { Webhook } from '@/models/entities/webhook.js';
import { subsdcriber } from '../db/redis.js'; import { subscriber } from '@/db/redis.js';
let webhooksFetched = false; let webhooksFetched = false;
let webhooks: Webhook[] = []; let webhooks: Webhook[] = [];
@ -16,7 +16,7 @@ export async function getActiveWebhooks() {
return webhooks; return webhooks;
} }
subsdcriber.on('message', async (_, data) => { subscriber.on('message', async (_, data) => {
const obj = JSON.parse(data); const obj = JSON.parse(data);
if (obj.channel === 'internal') { if (obj.channel === 'internal') {

10
packages/backend/src/server/api/streaming.ts
View File

@ -1,12 +1,12 @@
import * as http from 'node:http'; import * as http from 'node:http';
import { EventEmitter } from 'events';
import { ParsedUrlQuery } from 'querystring';
import * as websocket from 'websocket'; import * as websocket from 'websocket';
import MainStreamConnection from './stream/index.js'; import { subscriber as redisClient } from '@/db/redis.js';
import { ParsedUrlQuery } from 'querystring';
import authenticate from './authenticate.js';
import { EventEmitter } from 'events';
import { subsdcriber as redisClient } from '../../db/redis.js';
import { Users } from '@/models/index.js'; import { Users } from '@/models/index.js';
import MainStreamConnection from './stream/index.js';
import authenticate from './authenticate.js';
export const initializeStreamingServer = (server: http.Server) => { export const initializeStreamingServer = (server: http.Server) => {
// Init websocket server // Init websocket server

4
packages/backend/src/services/user-cache.ts
View File

@ -1,14 +1,14 @@
import { CacheableLocalUser, CacheableUser, ILocalUser, User } from '@/models/entities/user.js'; import { CacheableLocalUser, CacheableUser, ILocalUser, User } from '@/models/entities/user.js';
import { Users } from '@/models/index.js'; import { Users } from '@/models/index.js';
import { Cache } from '@/misc/cache.js'; import { Cache } from '@/misc/cache.js';
import { subsdcriber } from '@/db/redis.js'; import { subscriber } from '@/db/redis.js';
export const userByIdCache = new Cache<CacheableUser>(Infinity); export const userByIdCache = new Cache<CacheableUser>(Infinity);
export const localUserByNativeTokenCache = new Cache<CacheableLocalUser | null>(Infinity); export const localUserByNativeTokenCache = new Cache<CacheableLocalUser | null>(Infinity);
export const localUserByIdCache = new Cache<CacheableLocalUser>(Infinity); export const localUserByIdCache = new Cache<CacheableLocalUser>(Infinity);
export const uriPersonCache = new Cache<CacheableUser | null>(Infinity); export const uriPersonCache = new Cache<CacheableUser | null>(Infinity);
subsdcriber.on('message', async (_, data) => { subscriber.on('message', async (_, data) => {
const obj = JSON.parse(data); const obj = JSON.parse(data);
if (obj.channel === 'internal') { if (obj.channel === 'internal') {