remove default export in streaming API
All checks were successful
ci/woodpecker/push/lint-backend Pipeline was successful
ci/woodpecker/push/lint-client Pipeline was successful
ci/woodpecker/push/build Pipeline was successful
ci/woodpecker/push/lint-foundkey-js Pipeline was successful
ci/woodpecker/push/lint-sw Pipeline was successful
ci/woodpecker/push/test Pipeline was successful
All checks were successful
ci/woodpecker/push/lint-backend Pipeline was successful
ci/woodpecker/push/lint-client Pipeline was successful
ci/woodpecker/push/build Pipeline was successful
ci/woodpecker/push/lint-foundkey-js Pipeline was successful
ci/woodpecker/push/lint-sw Pipeline was successful
ci/woodpecker/push/test Pipeline was successful
This commit is contained in:
parent
8c2b7e20b2
commit
57d1af1117
2 changed files with 3 additions and 3 deletions
|
@ -17,7 +17,7 @@ import { StreamEventEmitter, StreamMessages } from './types.js';
|
|||
/**
|
||||
* Main stream connection
|
||||
*/
|
||||
export default class Connection {
|
||||
export class Connection {
|
||||
public user?: User;
|
||||
public userProfile?: UserProfile | null;
|
||||
public following: Set<User['id']> = new Set();
|
||||
|
|
|
@ -5,7 +5,7 @@ import * as websocket from 'websocket';
|
|||
|
||||
import { subscriber as redisClient } from '@/db/redis.js';
|
||||
import { Users } from '@/models/index.js';
|
||||
import MainStreamConnection from './stream/index.js';
|
||||
import { Connection } from './stream/index.js';
|
||||
import authenticate from './authenticate.js';
|
||||
|
||||
export const initializeStreamingServer = (server: http.Server): void => {
|
||||
|
@ -42,7 +42,7 @@ export const initializeStreamingServer = (server: http.Server): void => {
|
|||
|
||||
redisClient.on('message', onRedisMessage);
|
||||
|
||||
const main = new MainStreamConnection(connection, ev, user, app);
|
||||
const main = new Connection(connection, ev, user, app);
|
||||
|
||||
const intervalId = user ? setInterval(() => {
|
||||
Users.update(user.id, {
|
||||
|
|
Loading…
Reference in a new issue