puniko/FoundKey
1
0
Fork 0
forked from FoundKeyGang/FoundKey
Code Issues Pull requests Projects Releases Packages Wiki Activity

fix spelling error

Browse source
This commit is contained in:
Johann150 2022-08-04 10:20:48 +02:00
parent a3a3cb7258
commit e2bf2715a6
Signed by untrusted user: Johann150
GPG key ID: 9EE6577A2A06F8F1
5 changed files with 9 additions and 9 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') {

2
packages/backend/src/server/api/streaming.ts
View file

@ -3,7 +3,7 @@ import { EventEmitter } from 'events';
import { ParsedUrlQuery } from 'querystring'; import { ParsedUrlQuery } from 'querystring';
import * as websocket from 'websocket'; import * as websocket from 'websocket';
import { subsdcriber as redisClient } from '@/db/redis.js'; import { subscriber 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 MainStreamConnection from './stream/index.js';
import authenticate from './authenticate.js'; import authenticate from './authenticate.js';

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

@ -1,14 +1,14 @@
import { CacheableLocalUser, CacheableUser, ILocalUser } from '@/models/entities/user.js'; import { CacheableLocalUser, CacheableUser, ILocalUser } 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') {