summaryrefslogtreecommitdiff
path: root/src/client/mios.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/client/mios.ts')
-rw-r--r--src/client/mios.ts236
1 files changed, 0 insertions, 236 deletions
diff --git a/src/client/mios.ts b/src/client/mios.ts
deleted file mode 100644
index efeb630d7e..0000000000
--- a/src/client/mios.ts
+++ /dev/null
@@ -1,236 +0,0 @@
-// TODO: このファイル消したい
-
-import autobind from 'autobind-decorator';
-import { EventEmitter } from 'eventemitter3';
-
-import { apiUrl, version } from './config';
-import Progress from './scripts/loading';
-
-import Stream from './scripts/stream';
-import store from './store';
-
-/**
- * Misskey Operating System
- */
-export default class MiOS extends EventEmitter {
- public store: ReturnType<typeof store>;
-
- /**
- * A connection manager of home stream
- */
- public stream: Stream;
-
- /**
- * A registration of service worker
- */
- private swRegistration: ServiceWorkerRegistration = null;
-
- constructor(vuex: MiOS['store']) {
- super();
- this.store = vuex;
- }
-
- @autobind
- public signout() {
- this.store.dispatch('logout');
- location.href = '/';
- }
-
- /**
- * Initialize MiOS (boot)
- * @param callback A function that call when initialized
- */
- @autobind
- public async init(callback) {
- const finish = () => {
- callback();
-
- this.store.dispatch('instance/fetch').then(() => {
- // Init service worker
- if (this.store.state.instance.meta.swPublickey) this.registerSw(this.store.state.instance.meta.swPublickey);
- });
- };
-
- // ユーザーをフェッチしてコールバックする
- const fetchme = (token, cb) => {
- let me = null;
-
- // Return when not signed in
- if (token == null || token === 'null') {
- return done();
- }
-
- // Fetch user
- fetch(`${apiUrl}/i`, {
- method: 'POST',
- body: JSON.stringify({
- i: token
- })
- })
- // When success
- .then(res => {
- // When failed to authenticate user
- if (res.status !== 200 && res.status < 500) {
- return this.signout();
- }
-
- // Parse response
- res.json().then(i => {
- me = i;
- me.token = token;
- done();
- });
- })
- // When failure
- .catch(() => {
- // Render the error screen
- document.body.innerHTML = '<div id="err">Oops!</div>';
-
- Progress.done();
- });
-
- function done() {
- if (cb) cb(me);
- }
- };
-
- // フェッチが完了したとき
- const fetched = () => {
- this.emit('signedin');
-
- this.initStream();
-
- // Finish init
- finish();
- };
-
- // キャッシュがあったとき
- if (this.store.state.i != null) {
- if (this.store.state.i.token == null) {
- this.signout();
- return;
- }
-
- // とりあえずキャッシュされたデータでお茶を濁して(?)おいて、
- fetched();
-
- // 後から新鮮なデータをフェッチ
- fetchme(this.store.state.i.token, freshData => {
- this.store.dispatch('mergeMe', freshData);
- });
- } else {
- // Get token from localStorage
- let i = localStorage.getItem('i');
-
- // 連携ログインの場合用にCookieを参照する
- if (i == null || i === 'null') {
- i = (document.cookie.match(/igi=(\w+)/) || [null, null])[1];
- }
-
- fetchme(i, me => {
- if (me) {
- this.store.dispatch('login', me);
- fetched();
- } else {
- this.initStream();
-
- // Finish init
- finish();
- }
- });
- }
- }
-
- @autobind
- private initStream() {
- this.stream = new Stream(this);
- }
-
- /**
- * Register service worker
- */
- @autobind
- private registerSw(swPublickey: string) {
- // Check whether service worker and push manager supported
- const isSwSupported =
- ('serviceWorker' in navigator) && ('PushManager' in window);
-
- // Reject when browser not service worker supported
- if (!isSwSupported) return;
-
- // Reject when not signed in to Misskey
- if (!this.store.getters.isSignedIn) return;
-
- // When service worker activated
- navigator.serviceWorker.ready.then(registration => {
- this.swRegistration = registration;
-
- // Options of pushManager.subscribe
- // SEE: https://developer.mozilla.org/en-US/docs/Web/API/PushManager/subscribe#Parameters
- const opts = {
- // A boolean indicating that the returned push subscription
- // will only be used for messages whose effect is made visible to the user.
- userVisibleOnly: true,
-
- // A public key your push server will use to send
- // messages to client apps via a push server.
- applicationServerKey: urlBase64ToUint8Array(swPublickey)
- };
-
- // Subscribe push notification
- this.swRegistration.pushManager.subscribe(opts).then(subscription => {
- function encode(buffer: ArrayBuffer) {
- return btoa(String.fromCharCode.apply(null, new Uint8Array(buffer)));
- }
-
- // Register
- this.store.dispatch('api', {
- endpoint: 'sw/register',
- data: {
- endpoint: subscription.endpoint,
- auth: encode(subscription.getKey('auth')),
- publickey: encode(subscription.getKey('p256dh'))
- }
- });
- })
- // When subscribe failed
- .catch(async (err: Error) => {
- // 通知が許可されていなかったとき
- if (err.name === 'NotAllowedError') {
- return;
- }
-
- // 違うapplicationServerKey (または gcm_sender_id)のサブスクリプションが
- // 既に存在していることが原因でエラーになった可能性があるので、
- // そのサブスクリプションを解除しておく
- const subscription = await this.swRegistration.pushManager.getSubscription();
- if (subscription) subscription.unsubscribe();
- });
- });
-
- // The path of service worker script
- const sw = `/sw.${version}.js`;
-
- // Register service worker
- navigator.serviceWorker.register(sw);
- }
-}
-
-/**
- * Convert the URL safe base64 string to a Uint8Array
- * @param base64String base64 string
- */
-function urlBase64ToUint8Array(base64String: string): Uint8Array {
- const padding = '='.repeat((4 - base64String.length % 4) % 4);
- const base64 = (base64String + padding)
- .replace(/-/g, '+')
- .replace(/_/g, '/');
-
- const rawData = window.atob(base64);
- const outputArray = new Uint8Array(rawData.length);
-
- for (let i = 0; i < rawData.length; ++i) {
- outputArray[i] = rawData.charCodeAt(i);
- }
- return outputArray;
-}