summaryrefslogtreecommitdiff
path: root/src/web/app/common/scripts
diff options
context:
space:
mode:
authortamaina <tamaina@hotmail.co.jp>2018-04-11 20:27:09 +0900
committerGitHub <noreply@github.com>2018-04-11 20:27:09 +0900
commitd43fe853c3605696e2e57e240845d0fc9c284f61 (patch)
tree838914e262c0fca5737588a7bba64e2b9f3d8e5f /src/web/app/common/scripts
parentUpdate README.md (diff)
parentwip #1443 (diff)
downloadmisskey-d43fe853c3605696e2e57e240845d0fc9c284f61.tar.gz
misskey-d43fe853c3605696e2e57e240845d0fc9c284f61.tar.bz2
misskey-d43fe853c3605696e2e57e240845d0fc9c284f61.zip
Merge pull request #1 from syuilo/master
追従
Diffstat (limited to 'src/web/app/common/scripts')
-rw-r--r--src/web/app/common/scripts/api.ts47
-rw-r--r--src/web/app/common/scripts/bytes-to-size.ts6
-rw-r--r--src/web/app/common/scripts/check-for-update.ts24
-rw-r--r--src/web/app/common/scripts/compose-notification.ts60
-rw-r--r--src/web/app/common/scripts/contains.ts8
-rw-r--r--src/web/app/common/scripts/copy-to-clipboard.ts13
-rw-r--r--src/web/app/common/scripts/date-stringify.ts13
-rw-r--r--src/web/app/common/scripts/gcd.ts2
-rw-r--r--src/web/app/common/scripts/get-kao.ts5
-rw-r--r--src/web/app/common/scripts/get-median.ts11
-rw-r--r--src/web/app/common/scripts/is-promise.ts1
-rw-r--r--src/web/app/common/scripts/loading.ts21
-rw-r--r--src/web/app/common/scripts/signout.ts7
-rw-r--r--src/web/app/common/scripts/streaming/channel-stream.ts12
-rw-r--r--src/web/app/common/scripts/streaming/drive-stream-manager.ts20
-rw-r--r--src/web/app/common/scripts/streaming/drive-stream.ts12
-rw-r--r--src/web/app/common/scripts/streaming/home-stream-manager.ts20
-rw-r--r--src/web/app/common/scripts/streaming/home-stream.ts28
-rw-r--r--src/web/app/common/scripts/streaming/messaging-index-stream-manager.ts20
-rw-r--r--src/web/app/common/scripts/streaming/messaging-index-stream.ts12
-rw-r--r--src/web/app/common/scripts/streaming/messaging-stream.ts19
-rw-r--r--src/web/app/common/scripts/streaming/requests-stream-manager.ts12
-rw-r--r--src/web/app/common/scripts/streaming/requests-stream.ts10
-rw-r--r--src/web/app/common/scripts/streaming/server-stream-manager.ts12
-rw-r--r--src/web/app/common/scripts/streaming/server-stream.ts10
-rw-r--r--src/web/app/common/scripts/streaming/stream-manager.ts89
-rw-r--r--src/web/app/common/scripts/streaming/stream.ts96
-rw-r--r--src/web/app/common/scripts/text-compiler.ts48
28 files changed, 0 insertions, 638 deletions
diff --git a/src/web/app/common/scripts/api.ts b/src/web/app/common/scripts/api.ts
deleted file mode 100644
index 2008e6f5ac..0000000000
--- a/src/web/app/common/scripts/api.ts
+++ /dev/null
@@ -1,47 +0,0 @@
-/**
- * API Request
- */
-
-declare const _API_URL_: string;
-
-let spinner = null;
-let pending = 0;
-
-/**
- * Send a request to API
- * @param {string|Object} i Credential
- * @param {string} endpoint Endpoint
- * @param {any} [data={}] Data
- * @return {Promise<any>} Response
- */
-export default (i, endpoint, data = {}): Promise<{ [x: string]: any }> => {
- if (++pending === 1) {
- spinner = document.createElement('div');
- spinner.setAttribute('id', 'wait');
- document.body.appendChild(spinner);
- }
-
- // Append the credential
- if (i != null) (data as any).i = typeof i === 'object' ? i.token : i;
-
- return new Promise((resolve, reject) => {
- // Send request
- fetch(endpoint.indexOf('://') > -1 ? endpoint : `${_API_URL_}/${endpoint}`, {
- method: 'POST',
- body: JSON.stringify(data),
- credentials: endpoint === 'signin' ? 'include' : 'omit',
- cache: 'no-cache'
- }).then(res => {
- if (--pending === 0) spinner.parentNode.removeChild(spinner);
- if (res.status === 200) {
- res.json().then(resolve);
- } else if (res.status === 204) {
- resolve();
- } else {
- res.json().then(err => {
- reject(err.error);
- });
- }
- }).catch(reject);
- });
-};
diff --git a/src/web/app/common/scripts/bytes-to-size.ts b/src/web/app/common/scripts/bytes-to-size.ts
deleted file mode 100644
index 1d2b1e7ce3..0000000000
--- a/src/web/app/common/scripts/bytes-to-size.ts
+++ /dev/null
@@ -1,6 +0,0 @@
-export default (bytes, digits = 0) => {
- const sizes = ['Bytes', 'KB', 'MB', 'GB', 'TB'];
- if (bytes == 0) return '0Byte';
- const i = Math.floor(Math.log(bytes) / Math.log(1024));
- return (bytes / Math.pow(1024, i)).toFixed(digits).replace(/\.0+$/, '') + sizes[i];
-};
diff --git a/src/web/app/common/scripts/check-for-update.ts b/src/web/app/common/scripts/check-for-update.ts
deleted file mode 100644
index 0b58c0a674..0000000000
--- a/src/web/app/common/scripts/check-for-update.ts
+++ /dev/null
@@ -1,24 +0,0 @@
-import MiOS from '../mios';
-
-declare const _VERSION_: string;
-
-export default async function(mios: MiOS) {
- const meta = await mios.getMeta();
-
- if (meta.version != _VERSION_) {
- localStorage.setItem('should-refresh', 'true');
-
- // Clear cache (serive worker)
- try {
- navigator.serviceWorker.controller.postMessage('clear');
-
- navigator.serviceWorker.getRegistrations().then(registrations => {
- registrations.forEach(registration => registration.unregister());
- });
- } catch (e) {
- console.error(e);
- }
-
- alert('%i18n:common.update-available%'.replace('{newer}', meta.version).replace('{current}', _VERSION_));
- }
-}
diff --git a/src/web/app/common/scripts/compose-notification.ts b/src/web/app/common/scripts/compose-notification.ts
deleted file mode 100644
index d0e0c2098d..0000000000
--- a/src/web/app/common/scripts/compose-notification.ts
+++ /dev/null
@@ -1,60 +0,0 @@
-import getPostSummary from '../../../../common/get-post-summary';
-import getReactionEmoji from '../../../../common/get-reaction-emoji';
-
-type Notification = {
- title: string;
- body: string;
- icon: string;
- onclick?: any;
-};
-
-// TODO: i18n
-
-export default function(type, data): Notification {
- switch (type) {
- case 'drive_file_created':
- return {
- title: 'ファイルがアップロードされました',
- body: data.name,
- icon: data.url + '?thumbnail&size=64'
- };
-
- case 'mention':
- return {
- title: `${data.user.name}さんから:`,
- body: getPostSummary(data),
- icon: data.user.avatar_url + '?thumbnail&size=64'
- };
-
- case 'reply':
- return {
- title: `${data.user.name}さんから返信:`,
- body: getPostSummary(data),
- icon: data.user.avatar_url + '?thumbnail&size=64'
- };
-
- case 'quote':
- return {
- title: `${data.user.name}さんが引用:`,
- body: getPostSummary(data),
- icon: data.user.avatar_url + '?thumbnail&size=64'
- };
-
- case 'reaction':
- return {
- title: `${data.user.name}: ${getReactionEmoji(data.reaction)}:`,
- body: getPostSummary(data.post),
- icon: data.user.avatar_url + '?thumbnail&size=64'
- };
-
- case 'unread_messaging_message':
- return {
- title: `${data.user.name}さんからメッセージ:`,
- body: data.text, // TODO: getMessagingMessageSummary(data),
- icon: data.user.avatar_url + '?thumbnail&size=64'
- };
-
- default:
- return null;
- }
-}
diff --git a/src/web/app/common/scripts/contains.ts b/src/web/app/common/scripts/contains.ts
deleted file mode 100644
index a5071b3f25..0000000000
--- a/src/web/app/common/scripts/contains.ts
+++ /dev/null
@@ -1,8 +0,0 @@
-export default (parent, child) => {
- let node = child.parentNode;
- while (node) {
- if (node == parent) return true;
- node = node.parentNode;
- }
- return false;
-};
diff --git a/src/web/app/common/scripts/copy-to-clipboard.ts b/src/web/app/common/scripts/copy-to-clipboard.ts
deleted file mode 100644
index 3d2741f8d7..0000000000
--- a/src/web/app/common/scripts/copy-to-clipboard.ts
+++ /dev/null
@@ -1,13 +0,0 @@
-/**
- * Clipboardに値をコピー(TODO: 文字列以外も対応)
- */
-export default val => {
- const form = document.createElement('textarea');
- form.textContent = val;
- document.body.appendChild(form);
- form.select();
- const result = document.execCommand('copy');
- document.body.removeChild(form);
-
- return result;
-};
diff --git a/src/web/app/common/scripts/date-stringify.ts b/src/web/app/common/scripts/date-stringify.ts
deleted file mode 100644
index e51de8833d..0000000000
--- a/src/web/app/common/scripts/date-stringify.ts
+++ /dev/null
@@ -1,13 +0,0 @@
-export default date => {
- if (typeof date == 'string') date = new Date(date);
- return (
- date.getFullYear() + '年' +
- (date.getMonth() + 1) + '月' +
- date.getDate() + '日' +
- ' ' +
- date.getHours() + '時' +
- date.getMinutes() + '分' +
- ' ' +
- `(${['日', '月', '火', '水', '木', '金', '土'][date.getDay()]})`
- );
-};
diff --git a/src/web/app/common/scripts/gcd.ts b/src/web/app/common/scripts/gcd.ts
deleted file mode 100644
index 9a19f9da66..0000000000
--- a/src/web/app/common/scripts/gcd.ts
+++ /dev/null
@@ -1,2 +0,0 @@
-const gcd = (a, b) => !b ? a : gcd(b, a % b);
-export default gcd;
diff --git a/src/web/app/common/scripts/get-kao.ts b/src/web/app/common/scripts/get-kao.ts
deleted file mode 100644
index 2168c5be88..0000000000
--- a/src/web/app/common/scripts/get-kao.ts
+++ /dev/null
@@ -1,5 +0,0 @@
-export default () => [
- '(=^・・^=)',
- 'v(‘ω’)v',
- '🐡( \'-\' 🐡 )フグパンチ!!!!'
-][Math.floor(Math.random() * 3)];
diff --git a/src/web/app/common/scripts/get-median.ts b/src/web/app/common/scripts/get-median.ts
deleted file mode 100644
index 91a415d5b2..0000000000
--- a/src/web/app/common/scripts/get-median.ts
+++ /dev/null
@@ -1,11 +0,0 @@
-/**
- * 中央値を求めます
- * @param samples サンプル
- */
-export default function(samples) {
- if (!samples.length) return 0;
- const numbers = samples.slice(0).sort((a, b) => a - b);
- const middle = Math.floor(numbers.length / 2);
- const isEven = numbers.length % 2 === 0;
- return isEven ? (numbers[middle] + numbers[middle - 1]) / 2 : numbers[middle];
-}
diff --git a/src/web/app/common/scripts/is-promise.ts b/src/web/app/common/scripts/is-promise.ts
deleted file mode 100644
index 3b4cd70b49..0000000000
--- a/src/web/app/common/scripts/is-promise.ts
+++ /dev/null
@@ -1 +0,0 @@
-export default x => typeof x.then == 'function';
diff --git a/src/web/app/common/scripts/loading.ts b/src/web/app/common/scripts/loading.ts
deleted file mode 100644
index c48e626648..0000000000
--- a/src/web/app/common/scripts/loading.ts
+++ /dev/null
@@ -1,21 +0,0 @@
-const NProgress = require('nprogress');
-NProgress.configure({
- trickleSpeed: 500,
- showSpinner: false
-});
-
-const root = document.getElementsByTagName('html')[0];
-
-export default {
- start: () => {
- root.classList.add('progress');
- NProgress.start();
- },
- done: () => {
- root.classList.remove('progress');
- NProgress.done();
- },
- set: val => {
- NProgress.set(val);
- }
-};
diff --git a/src/web/app/common/scripts/signout.ts b/src/web/app/common/scripts/signout.ts
deleted file mode 100644
index 2923196549..0000000000
--- a/src/web/app/common/scripts/signout.ts
+++ /dev/null
@@ -1,7 +0,0 @@
-declare const _HOST_: string;
-
-export default () => {
- localStorage.removeItem('me');
- document.cookie = `i=; domain=.${_HOST_}; expires=Thu, 01 Jan 1970 00:00:01 GMT;`;
- location.href = '/';
-};
diff --git a/src/web/app/common/scripts/streaming/channel-stream.ts b/src/web/app/common/scripts/streaming/channel-stream.ts
deleted file mode 100644
index 434b108b9e..0000000000
--- a/src/web/app/common/scripts/streaming/channel-stream.ts
+++ /dev/null
@@ -1,12 +0,0 @@
-import Stream from './stream';
-
-/**
- * Channel stream connection
- */
-export default class Connection extends Stream {
- constructor(channelId) {
- super('channel', {
- channel: channelId
- });
- }
-}
diff --git a/src/web/app/common/scripts/streaming/drive-stream-manager.ts b/src/web/app/common/scripts/streaming/drive-stream-manager.ts
deleted file mode 100644
index 8acdd7cbba..0000000000
--- a/src/web/app/common/scripts/streaming/drive-stream-manager.ts
+++ /dev/null
@@ -1,20 +0,0 @@
-import StreamManager from './stream-manager';
-import Connection from './drive-stream';
-
-export default class DriveStreamManager extends StreamManager<Connection> {
- private me;
-
- constructor(me) {
- super();
-
- this.me = me;
- }
-
- public getConnection() {
- if (this.connection == null) {
- this.connection = new Connection(this.me);
- }
-
- return this.connection;
- }
-}
diff --git a/src/web/app/common/scripts/streaming/drive-stream.ts b/src/web/app/common/scripts/streaming/drive-stream.ts
deleted file mode 100644
index 0da3f12554..0000000000
--- a/src/web/app/common/scripts/streaming/drive-stream.ts
+++ /dev/null
@@ -1,12 +0,0 @@
-import Stream from './stream';
-
-/**
- * Drive stream connection
- */
-export default class Connection extends Stream {
- constructor(me) {
- super('drive', {
- i: me.token
- });
- }
-}
diff --git a/src/web/app/common/scripts/streaming/home-stream-manager.ts b/src/web/app/common/scripts/streaming/home-stream-manager.ts
deleted file mode 100644
index ad1dc870eb..0000000000
--- a/src/web/app/common/scripts/streaming/home-stream-manager.ts
+++ /dev/null
@@ -1,20 +0,0 @@
-import StreamManager from './stream-manager';
-import Connection from './home-stream';
-
-export default class HomeStreamManager extends StreamManager<Connection> {
- private me;
-
- constructor(me) {
- super();
-
- this.me = me;
- }
-
- public getConnection() {
- if (this.connection == null) {
- this.connection = new Connection(this.me);
- }
-
- return this.connection;
- }
-}
diff --git a/src/web/app/common/scripts/streaming/home-stream.ts b/src/web/app/common/scripts/streaming/home-stream.ts
deleted file mode 100644
index 11ad754ef0..0000000000
--- a/src/web/app/common/scripts/streaming/home-stream.ts
+++ /dev/null
@@ -1,28 +0,0 @@
-import Stream from './stream';
-import signout from '../signout';
-
-/**
- * Home stream connection
- */
-export default class Connection extends Stream {
- constructor(me) {
- super('', {
- i: me.token
- });
-
- // 最終利用日時を更新するため定期的にaliveメッセージを送信
- setInterval(() => {
- this.send({ type: 'alive' });
- }, 1000 * 60);
-
- // 自分の情報が更新されたとき
- this.on('i_updated', me.update);
-
- // トークンが再生成されたとき
- // このままではAPIが利用できないので強制的にサインアウトさせる
- this.on('my_token_regenerated', () => {
- alert('%i18n:common.my-token-regenerated%');
- signout();
- });
- }
-}
diff --git a/src/web/app/common/scripts/streaming/messaging-index-stream-manager.ts b/src/web/app/common/scripts/streaming/messaging-index-stream-manager.ts
deleted file mode 100644
index 0f08b01481..0000000000
--- a/src/web/app/common/scripts/streaming/messaging-index-stream-manager.ts
+++ /dev/null
@@ -1,20 +0,0 @@
-import StreamManager from './stream-manager';
-import Connection from './messaging-index-stream';
-
-export default class MessagingIndexStreamManager extends StreamManager<Connection> {
- private me;
-
- constructor(me) {
- super();
-
- this.me = me;
- }
-
- public getConnection() {
- if (this.connection == null) {
- this.connection = new Connection(this.me);
- }
-
- return this.connection;
- }
-}
diff --git a/src/web/app/common/scripts/streaming/messaging-index-stream.ts b/src/web/app/common/scripts/streaming/messaging-index-stream.ts
deleted file mode 100644
index 8015c840b4..0000000000
--- a/src/web/app/common/scripts/streaming/messaging-index-stream.ts
+++ /dev/null
@@ -1,12 +0,0 @@
-import Stream from './stream';
-
-/**
- * Messaging index stream connection
- */
-export default class Connection extends Stream {
- constructor(me) {
- super('messaging-index', {
- i: me.token
- });
- }
-}
diff --git a/src/web/app/common/scripts/streaming/messaging-stream.ts b/src/web/app/common/scripts/streaming/messaging-stream.ts
deleted file mode 100644
index 68dfc5ec09..0000000000
--- a/src/web/app/common/scripts/streaming/messaging-stream.ts
+++ /dev/null
@@ -1,19 +0,0 @@
-import Stream from './stream';
-
-/**
- * Messaging stream connection
- */
-export default class Connection extends Stream {
- constructor(me, otherparty) {
- super('messaging', {
- i: me.token,
- otherparty
- });
-
- (this as any).on('_connected_', () => {
- this.send({
- i: me.token
- });
- });
- }
-}
diff --git a/src/web/app/common/scripts/streaming/requests-stream-manager.ts b/src/web/app/common/scripts/streaming/requests-stream-manager.ts
deleted file mode 100644
index 44db913e78..0000000000
--- a/src/web/app/common/scripts/streaming/requests-stream-manager.ts
+++ /dev/null
@@ -1,12 +0,0 @@
-import StreamManager from './stream-manager';
-import Connection from './requests-stream';
-
-export default class RequestsStreamManager extends StreamManager<Connection> {
- public getConnection() {
- if (this.connection == null) {
- this.connection = new Connection();
- }
-
- return this.connection;
- }
-}
diff --git a/src/web/app/common/scripts/streaming/requests-stream.ts b/src/web/app/common/scripts/streaming/requests-stream.ts
deleted file mode 100644
index 22ecea6c07..0000000000
--- a/src/web/app/common/scripts/streaming/requests-stream.ts
+++ /dev/null
@@ -1,10 +0,0 @@
-import Stream from './stream';
-
-/**
- * Requests stream connection
- */
-export default class Connection extends Stream {
- constructor() {
- super('requests');
- }
-}
diff --git a/src/web/app/common/scripts/streaming/server-stream-manager.ts b/src/web/app/common/scripts/streaming/server-stream-manager.ts
deleted file mode 100644
index a170daebb9..0000000000
--- a/src/web/app/common/scripts/streaming/server-stream-manager.ts
+++ /dev/null
@@ -1,12 +0,0 @@
-import StreamManager from './stream-manager';
-import Connection from './server-stream';
-
-export default class ServerStreamManager extends StreamManager<Connection> {
- public getConnection() {
- if (this.connection == null) {
- this.connection = new Connection();
- }
-
- return this.connection;
- }
-}
diff --git a/src/web/app/common/scripts/streaming/server-stream.ts b/src/web/app/common/scripts/streaming/server-stream.ts
deleted file mode 100644
index b9e0684465..0000000000
--- a/src/web/app/common/scripts/streaming/server-stream.ts
+++ /dev/null
@@ -1,10 +0,0 @@
-import Stream from './stream';
-
-/**
- * Server stream connection
- */
-export default class Connection extends Stream {
- constructor() {
- super('server');
- }
-}
diff --git a/src/web/app/common/scripts/streaming/stream-manager.ts b/src/web/app/common/scripts/streaming/stream-manager.ts
deleted file mode 100644
index 5bb0dc701c..0000000000
--- a/src/web/app/common/scripts/streaming/stream-manager.ts
+++ /dev/null
@@ -1,89 +0,0 @@
-import { EventEmitter } from 'eventemitter3';
-import * as uuid from 'uuid';
-import Connection from './stream';
-
-/**
- * ストリーム接続を管理するクラス
- * 複数の場所から同じストリームを利用する際、接続をまとめたりする
- */
-export default abstract class StreamManager<T extends Connection> extends EventEmitter {
- private _connection: T = null;
-
- private disposeTimerId: any;
-
- /**
- * コネクションを必要としているユーザー
- */
- private users = [];
-
- protected set connection(connection: T) {
- this._connection = connection;
-
- if (this._connection == null) {
- this.emit('disconnected');
- } else {
- this.emit('connected', this._connection);
- }
- }
-
- protected get connection() {
- return this._connection;
- }
-
- /**
- * コネクションを持っているか否か
- */
- public get hasConnection() {
- return this._connection != null;
- }
-
- /**
- * コネクションを要求します
- */
- public abstract getConnection(): T;
-
- /**
- * 現在接続しているコネクションを取得します
- */
- public borrow() {
- return this._connection;
- }
-
- /**
- * コネクションを要求するためのユーザーIDを発行します
- */
- public use() {
- // タイマー解除
- if (this.disposeTimerId) {
- clearTimeout(this.disposeTimerId);
- this.disposeTimerId = null;
- }
-
- // ユーザーID生成
- const userId = uuid();
-
- this.users.push(userId);
-
- return userId;
- }
-
- /**
- * コネクションを利用し終わってもう必要ないことを通知します
- * @param userId use で発行したユーザーID
- */
- public dispose(userId) {
- this.users = this.users.filter(id => id != userId);
-
- // 誰もコネクションの利用者がいなくなったら
- if (this.users.length == 0) {
- // また直ぐに再利用される可能性があるので、一定時間待ち、
- // 新たな利用者が現れなければコネクションを切断する
- this.disposeTimerId = setTimeout(() => {
- this.disposeTimerId = null;
-
- this.connection.close();
- this.connection = null;
- }, 3000);
- }
- }
-}
diff --git a/src/web/app/common/scripts/streaming/stream.ts b/src/web/app/common/scripts/streaming/stream.ts
deleted file mode 100644
index 770d77510f..0000000000
--- a/src/web/app/common/scripts/streaming/stream.ts
+++ /dev/null
@@ -1,96 +0,0 @@
-declare const _API_URL_: string;
-
-import { EventEmitter } from 'eventemitter3';
-import * as ReconnectingWebsocket from 'reconnecting-websocket';
-
-/**
- * Misskey stream connection
- */
-export default class Connection extends EventEmitter {
- private state: string;
- private buffer: any[];
- private socket: ReconnectingWebsocket;
-
- constructor(endpoint, params?) {
- super();
-
- //#region BIND
- this.onOpen = this.onOpen.bind(this);
- this.onClose = this.onClose.bind(this);
- this.onMessage = this.onMessage.bind(this);
- this.send = this.send.bind(this);
- this.close = this.close.bind(this);
- //#endregion
-
- this.state = 'initializing';
- this.buffer = [];
-
- const host = _API_URL_.replace('http', 'ws');
- const query = params
- ? Object.keys(params)
- .map(k => encodeURIComponent(k) + '=' + encodeURIComponent(params[k]))
- .join('&')
- : null;
-
- this.socket = new ReconnectingWebsocket(`${host}/${endpoint}${query ? '?' + query : ''}`);
- this.socket.addEventListener('open', this.onOpen);
- this.socket.addEventListener('close', this.onClose);
- this.socket.addEventListener('message', this.onMessage);
- }
-
- /**
- * Callback of when open connection
- */
- private onOpen() {
- this.state = 'connected';
- this.emit('_connected_');
-
- // バッファーを処理
- const _buffer = [].concat(this.buffer); // Shallow copy
- this.buffer = []; // Clear buffer
- _buffer.forEach(message => {
- this.send(message); // Resend each buffered messages
- });
- }
-
- /**
- * Callback of when close connection
- */
- private onClose() {
- this.state = 'reconnecting';
- this.emit('_closed_');
- }
-
- /**
- * Callback of when received a message from connection
- */
- private onMessage(message) {
- try {
- const msg = JSON.parse(message.data);
- if (msg.type) this.emit(msg.type, msg.body);
- } catch (e) {
- // noop
- }
- }
-
- /**
- * Send a message to connection
- */
- public send(message) {
- // まだ接続が確立されていなかったらバッファリングして次に接続した時に送信する
- if (this.state != 'connected') {
- this.buffer.push(message);
- return;
- }
-
- this.socket.send(JSON.stringify(message));
- }
-
- /**
- * Close this connection
- */
- public close() {
- this.socket.removeEventListener('open', this.onOpen);
- this.socket.removeEventListener('message', this.onMessage);
- }
-}
diff --git a/src/web/app/common/scripts/text-compiler.ts b/src/web/app/common/scripts/text-compiler.ts
deleted file mode 100644
index e0ea47df26..0000000000
--- a/src/web/app/common/scripts/text-compiler.ts
+++ /dev/null
@@ -1,48 +0,0 @@
-declare const _URL_: string;
-
-import * as riot from 'riot';
-import * as pictograph from 'pictograph';
-
-const escape = text =>
- text
- .replace(/>/g, '&gt;')
- .replace(/</g, '&lt;');
-
-export default (tokens, shouldBreak) => {
- if (shouldBreak == null) {
- shouldBreak = true;
- }
-
- const me = (riot as any).mixin('i').me;
-
- let text = tokens.map(token => {
- switch (token.type) {
- case 'text':
- return escape(token.content)
- .replace(/(\r\n|\n|\r)/g, shouldBreak ? '<br>' : ' ');
- case 'bold':
- return `<strong>${escape(token.bold)}</strong>`;
- case 'url':
- return `<mk-url href="${escape(token.content)}" target="_blank"></mk-url>`;
- case 'link':
- return `<a class="link" href="${escape(token.url)}" target="_blank" title="${escape(token.url)}">${escape(token.title)}</a>`;
- case 'mention':
- return `<a href="${_URL_ + '/' + escape(token.username)}" target="_blank" data-user-preview="${token.content}" ${me && me.username == token.username ? 'data-is-me' : ''}>${token.content}</a>`;
- case 'hashtag': // TODO
- return `<a>${escape(token.content)}</a>`;
- case 'code':
- return `<pre><code>${token.html}</code></pre>`;
- case 'inline-code':
- return `<code>${token.html}</code>`;
- case 'emoji':
- return pictograph.dic[token.emoji] || token.content;
- }
- }).join('');
-
- // Remove needless whitespaces
- text = text
- .replace(/ <code>/g, '<code>').replace(/<\/code> /g, '</code>')
- .replace(/<br><code><pre>/g, '<code><pre>').replace(/<\/code><\/pre><br>/g, '</code></pre>');
-
- return text;
-};