pch_xyz/ai
1
0
Fork 0
mirror of https://github.com/syuilo/ai.git synced 2024-11-09 23:48:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

WebSocket再接続が速すぎるのを修正

Browse source
This commit is contained in:
mei23 2018-09-24 14:25:58 +09:00
parent 99c2320312
commit d4095127e9
4 changed files with 9 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
package.json
View file

@ -10,12 +10,12 @@
"@types/node": "10.0.5", "@types/node": "10.0.5",
"@types/promise-retry": "1.1.2", "@types/promise-retry": "1.1.2",
"@types/seedrandom": "2.4.27", "@types/seedrandom": "2.4.27",
"@types/ws": "5.1.2", "@types/ws": "6.0.1",
"lokijs": "1.5.5", "lokijs": "1.5.5",
"mecab-async": "0.1.2", "mecab-async": "0.1.2",
"misskey-reversi": "0.0.5", "misskey-reversi": "0.0.5",
"promise-retry": "1.1.1", "promise-retry": "1.1.1",
"reconnecting-websocket": "4.0.0-rc5", "reconnecting-websocket": "3.2.2",
"request": "2.87.0", "request": "2.87.0",
"request-promise-native": "1.0.5", "request-promise-native": "1.0.5",
"seedrandom": "2.4.3", "seedrandom": "2.4.3",

10
src/ai.ts
View file

@ -9,7 +9,7 @@ import MessageLike from './message-like';
import { FriendDoc } from './friend'; import { FriendDoc } from './friend';
import { User } from './misskey/user'; import { User } from './misskey/user';
import getCollection from './utils/get-collection'; import getCollection from './utils/get-collection';
const ReconnectingWebSocket = require('../node_modules/reconnecting-websocket/dist/reconnecting-websocket-cjs.js'); const ReconnectingWebSocket = require('reconnecting-websocket');
/** /**
* 藍 * 藍
@ -70,7 +70,7 @@ export default class 藍 {
//#region Home stream //#region Home stream
this.connection = new ReconnectingWebSocket(`${config.wsUrl}/?i=${config.i}`, [], { this.connection = new ReconnectingWebSocket(`${config.wsUrl}/?i=${config.i}`, [], {
WebSocket: WebSocket constructor: WebSocket
}); });
this.connection.addEventListener('open', () => { this.connection.addEventListener('open', () => {
@ -79,8 +79,6 @@ export default class 藍 {
this.connection.addEventListener('close', () => { this.connection.addEventListener('close', () => {
console.log('home stream closed'); console.log('home stream closed');
this.connection.reconnect();
}); });
this.connection.addEventListener('message', message => { this.connection.addEventListener('message', message => {
@ -92,7 +90,7 @@ export default class 藍 {
//#region Local timeline stream //#region Local timeline stream
this.localTimelineConnection = new ReconnectingWebSocket(`${config.wsUrl}/local-timeline?i=${config.i}`, [], { this.localTimelineConnection = new ReconnectingWebSocket(`${config.wsUrl}/local-timeline?i=${config.i}`, [], {
WebSocket: WebSocket constructor: WebSocket
}); });
this.localTimelineConnection.addEventListener('open', () => { this.localTimelineConnection.addEventListener('open', () => {
@ -101,8 +99,6 @@ export default class 藍 {
this.localTimelineConnection.addEventListener('close', () => { this.localTimelineConnection.addEventListener('close', () => {
console.log('local-timeline stream closed'); console.log('local-timeline stream closed');
this.localTimelineConnection.reconnect();
}); });
this.localTimelineConnection.addEventListener('message', message => { this.localTimelineConnection.addEventListener('message', message => {

6
src/modules/reversi/index.ts
View file

@ -1,5 +1,5 @@
import * as childProcess from 'child_process'; import * as childProcess from 'child_process';
const ReconnectingWebSocket = require('../../../node_modules/reconnecting-websocket/dist/reconnecting-websocket-cjs.js'); const ReconnectingWebSocket = require('reconnecting-websocket');
import 藍 from '../../ai'; import 藍 from '../../ai';
import IModule from '../../module'; import IModule from '../../module';
import serifs from '../../serifs'; import serifs from '../../serifs';
@ -23,7 +23,7 @@ export default class ReversiModule implements IModule {
this.ai = ai; this.ai = ai;
this.reversiConnection = new ReconnectingWebSocket(`${config.wsUrl}/games/reversi?i=${config.i}`, [], { this.reversiConnection = new ReconnectingWebSocket(`${config.wsUrl}/games/reversi?i=${config.i}`, [], {
WebSocket: WebSocket constructor: WebSocket
}); });
this.reversiConnection.addEventListener('open', () => { this.reversiConnection.addEventListener('open', () => {
@ -32,8 +32,6 @@ export default class ReversiModule implements IModule {
this.reversiConnection.addEventListener('close', () => { this.reversiConnection.addEventListener('close', () => {
console.log('reversi stream closed'); console.log('reversi stream closed');
this.reversiConnection.reconnect();
}); });
this.reversiConnection.addEventListener('message', message => { this.reversiConnection.addEventListener('message', message => {

6
src/modules/server/index.ts
View file

@ -3,7 +3,7 @@ import 藍 from '../../ai';
import IModule from '../../module'; import IModule from '../../module';
import serifs from '../../serifs'; import serifs from '../../serifs';
import config from '../../config'; import config from '../../config';
const ReconnectingWebSocket = require('../../../node_modules/reconnecting-websocket/dist/reconnecting-websocket-cjs.js'); const ReconnectingWebSocket = require('reconnecting-websocket');
export default class ServerModule implements IModule { export default class ServerModule implements IModule {
public readonly name = 'server'; public readonly name = 'server';
@ -23,7 +23,7 @@ export default class ServerModule implements IModule {
this.ai = ai; this.ai = ai;
this.connection = new ReconnectingWebSocket(`${config.wsUrl}/server-stats`, [], { this.connection = new ReconnectingWebSocket(`${config.wsUrl}/server-stats`, [], {
WebSocket: WebSocket constructor: WebSocket
}); });
this.connection.addEventListener('open', () => { this.connection.addEventListener('open', () => {
@ -32,8 +32,6 @@ export default class ServerModule implements IModule {
this.connection.addEventListener('close', () => { this.connection.addEventListener('close', () => {
console.log('server-stats stream closed'); console.log('server-stats stream closed');
this.connection.reconnect();
}); });
this.connection.addEventListener('message', message => { this.connection.addEventListener('message', message => {