// TODO: なんでもかんでもos.tsに突っ込むのやめたいのでよしなに分割する import { Component, defineAsyncComponent, markRaw, reactive, Ref, ref } from 'vue'; import { EventEmitter } from 'eventemitter3'; import insertTextAtCursor from 'insert-text-at-cursor'; import * as Misskey from 'misskey-js'; import { apiUrl, url } from '@/config'; import MkPostFormDialog from '@/components/post-form-dialog.vue'; import MkWaitingDialog from '@/components/waiting-dialog.vue'; import { resolve } from '@/router'; import { $i } from '@/account'; export const pendingApiRequestsCount = ref(0); const apiClient = new Misskey.api.APIClient({ origin: url, }); export const api = ((endpoint: string, data: Record = {}, token?: string | null | undefined) => { pendingApiRequestsCount.value++; const onFinally = () => { pendingApiRequestsCount.value--; }; const promise = new Promise((resolve, reject) => { // Append a credential if ($i) (data as any).i = $i.token; if (token !== undefined) (data as any).i = token; // Send request fetch(endpoint.indexOf('://') > -1 ? endpoint : `${apiUrl}/${endpoint}`, { method: 'POST', body: JSON.stringify(data), credentials: 'omit', cache: 'no-cache' }).then(async (res) => { const body = res.status === 204 ? null : await res.json(); if (res.status === 200) { resolve(body); } else if (res.status === 204) { resolve(); } else { reject(body.error); } }).catch(reject); }); promise.then(onFinally, onFinally); return promise; }) as typeof apiClient.request; export const apiWithDialog = (( endpoint: string, data: Record = {}, token?: string | null | undefined, ) => { const promise = api(endpoint, data, token); promiseDialog(promise, null, (e) => { alert({ type: 'error', text: e.message + '\n' + (e as any).id, }); }); return promise; }) as typeof api; export function promiseDialog>( promise: T, onSuccess?: ((res: any) => void) | null, onFailure?: ((e: Error) => void) | null, text?: string, ): T { const showing = ref(true); const success = ref(false); promise.then(res => { if (onSuccess) { showing.value = false; onSuccess(res); } else { success.value = true; window.setTimeout(() => { showing.value = false; }, 1000); } }).catch(e => { showing.value = false; if (onFailure) { onFailure(e); } else { alert({ type: 'error', text: e }); } }); // NOTE: dynamic importすると挙動がおかしくなる(showingの変更が伝播しない) popup(MkWaitingDialog, { success: success, showing: showing, text: text, }, {}, 'closed'); return promise; } function isModule(x: any): x is typeof import('*.vue') { return x.default != null; } let popupIdCount = 0; export const popups = ref([]) as Ref<{ id: any; component: any; props: Record; }[]>; const zIndexes = { low: 1000000, middle: 2000000, high: 3000000, }; export function claimZIndex(priority: 'low' | 'middle' | 'high' = 'low'): number { zIndexes[priority] += 100; return zIndexes[priority]; } export async function popup(component: Component | typeof import('*.vue') | Promise, props: Record, events = {}, disposeEvent?: string) { if (component.then) component = await component; if (isModule(component)) component = component.default; markRaw(component); const id = ++popupIdCount; const dispose = () => { // このsetTimeoutが無いと挙動がおかしくなる(autocompleteが閉じなくなる)。Vueのバグ? window.setTimeout(() => { popups.value = popups.value.filter(popup => popup.id !== id); }, 0); }; const state = { component, props, events: disposeEvent ? { ...events, [disposeEvent]: dispose } : events, id, }; popups.value.push(state); return { dispose, }; } export function pageWindow(path: string) { const { component, props } = resolve(path); popup(import('@/components/page-window.vue'), { initialPath: path, initialComponent: markRaw(component), initialProps: props, }, {}, 'closed'); } export function modalPageWindow(path: string) { const { component, props } = resolve(path); popup(import('@/components/modal-page-window.vue'), { initialPath: path, initialComponent: markRaw(component), initialProps: props, }, {}, 'closed'); } export function toast(message: string) { popup(import('@/components/toast.vue'), { message }, {}, 'closed'); } export function alert(props: { type?: 'error' | 'info' | 'success' | 'warning' | 'waiting' | 'question'; title?: string | null; text?: string | null; }): Promise { return new Promise((resolve, reject) => { popup(import('@/components/dialog.vue'), props, { done: result => { resolve(); }, }, 'closed'); }); } export function confirm(props: { type: 'error' | 'info' | 'success' | 'warning' | 'waiting' | 'question'; title?: string | null; text?: string | null; }): Promise<{ canceled: boolean }> { return new Promise((resolve, reject) => { popup(import('@/components/dialog.vue'), { ...props, showCancelButton: true, }, { done: result => { resolve(result ? result : { canceled: true }); }, }, 'closed'); }); } export function inputText(props: { type?: 'text' | 'email' | 'password' | 'url'; title?: string | null; text?: string | null; placeholder?: string | null; default?: string | null; }): Promise<{ canceled: true; result: undefined; } | { canceled: false; result: string; }> { return new Promise((resolve, reject) => { popup(import('@/components/dialog.vue'), { title: props.title, text: props.text, input: { type: props.type, placeholder: props.placeholder, default: props.default, } }, { done: result => { resolve(result ? result : { canceled: true }); }, }, 'closed'); }); } export function inputNumber(props: { title?: string | null; text?: string | null; placeholder?: string | null; default?: number | null; }): Promise<{ canceled: true; result: undefined; } | { canceled: false; result: number; }> { return new Promise((resolve, reject) => { popup(import('@/components/dialog.vue'), { title: props.title, text: props.text, input: { type: 'number', placeholder: props.placeholder, default: props.default, } }, { done: result => { resolve(result ? result : { canceled: true }); }, }, 'closed'); }); } export function inputDate(props: { title?: string | null; text?: string | null; placeholder?: string | null; default?: Date | null; }): Promise<{ canceled: true; result: undefined; } | { canceled: false; result: Date; }> { return new Promise((resolve, reject) => { popup(import('@/components/dialog.vue'), { title: props.title, text: props.text, input: { type: 'date', placeholder: props.placeholder, default: props.default, } }, { done: result => { resolve(result ? { result: new Date(result.result), canceled: false } : { canceled: true }); }, }, 'closed'); }); } export function select(props: { title?: string | null; text?: string | null; default?: string | null; items?: { value: string; text: string; }[]; groupedItems?: { label: string; items: { value: string; text: string; }[]; }[]; }): Promise<{ canceled: true; result: undefined; } | { canceled: false; result: string; }> { return new Promise((resolve, reject) => { popup(import('@/components/dialog.vue'), { title: props.title, text: props.text, select: { items: props.items, groupedItems: props.groupedItems, default: props.default, } }, { done: result => { resolve(result ? result : { canceled: true }); }, }, 'closed'); }); } export function success() { return new Promise((resolve, reject) => { const showing = ref(true); window.setTimeout(() => { showing.value = false; }, 1000); popup(import('@/components/waiting-dialog.vue'), { success: true, showing: showing }, { done: () => resolve(), }, 'closed'); }); } export function waiting() { return new Promise((resolve, reject) => { const showing = ref(true); popup(import('@/components/waiting-dialog.vue'), { success: false, showing: showing }, { done: () => resolve(), }, 'closed'); }); } export function form(title, form) { return new Promise((resolve, reject) => { popup(import('@/components/form-dialog.vue'), { title, form }, { done: result => { resolve(result); }, }, 'closed'); }); } export async function selectUser() { return new Promise((resolve, reject) => { popup(import('@/components/user-select-dialog.vue'), {}, { ok: user => { resolve(user); }, }, 'closed'); }); } export async function selectDriveFile(multiple: boolean) { return new Promise((resolve, reject) => { popup(import('@/components/drive-select-dialog.vue'), { type: 'file', multiple }, { done: files => { if (files) { resolve(multiple ? files : files[0]); } }, }, 'closed'); }); } export async function selectDriveFolder(multiple: boolean) { return new Promise((resolve, reject) => { popup(import('@/components/drive-select-dialog.vue'), { type: 'folder', multiple }, { done: folders => { if (folders) { resolve(multiple ? folders : folders[0]); } }, }, 'closed'); }); } export async function pickEmoji(src?: HTMLElement, opts) { return new Promise((resolve, reject) => { popup(import('@/components/emoji-picker-dialog.vue'), { src, ...opts }, { done: emoji => { resolve(emoji); }, }, 'closed'); }); } type AwaitType = T extends Promise ? U : T extends (...args: any[]) => Promise ? V : T; let openingEmojiPicker: AwaitType> | null = null; let activeTextarea: HTMLTextAreaElement | HTMLInputElement | null = null; export async function openEmojiPicker(src?: HTMLElement, opts, initialTextarea: typeof activeTextarea) { if (openingEmojiPicker) return; activeTextarea = initialTextarea; const textareas = document.querySelectorAll('textarea, input'); for (const textarea of Array.from(textareas)) { textarea.addEventListener('focus', () => { activeTextarea = textarea; }); } const observer = new MutationObserver(records => { for (const record of records) { for (const node of Array.from(record.addedNodes).filter(node => node instanceof HTMLElement) as HTMLElement[]) { const textareas = node.querySelectorAll('textarea, input') as NodeListOf>; for (const textarea of Array.from(textareas).filter(textarea => textarea.dataset.preventEmojiInsert == null)) { if (document.activeElement === textarea) activeTextarea = textarea; textarea.addEventListener('focus', () => { activeTextarea = textarea; }); } } } }); observer.observe(document.body, { childList: true, subtree: true, attributes: false, characterData: false, }); openingEmojiPicker = await popup(import('@/components/emoji-picker-window.vue'), { src, ...opts }, { chosen: emoji => { insertTextAtCursor(activeTextarea, emoji); }, closed: () => { openingEmojiPicker!.dispose(); openingEmojiPicker = null; observer.disconnect(); } }); } export function popupMenu(items: any[] | Ref, src?: HTMLElement, options?: { align?: string; width?: number; viaKeyboard?: boolean; }) { return new Promise((resolve, reject) => { let dispose; popup(import('@/components/ui/popup-menu.vue'), { items, src, width: options?.width, align: options?.align, viaKeyboard: options?.viaKeyboard }, { closed: () => { resolve(); dispose(); }, }).then(res => { dispose = res.dispose; }); }); } export function contextMenu(items: any[], ev: MouseEvent) { ev.preventDefault(); return new Promise((resolve, reject) => { let dispose; popup(import('@/components/ui/context-menu.vue'), { items, ev, }, { closed: () => { resolve(); dispose(); }, }).then(res => { dispose = res.dispose; }); }); } export function post(props: Record = {}) { return new Promise((resolve, reject) => { // NOTE: MkPostFormDialogをdynamic importするとiOSでテキストエリアに自動フォーカスできない // NOTE: ただ、dynamic importしない場合、MkPostFormDialogインスタンスが使いまわされ、 // Vueが渡されたコンポーネントに内部的に__propsというプロパティを生やす影響で、 // 複数のpost formを開いたときに場合によってはエラーになる // もちろん複数のpost formを開けること自体Misskeyサイドのバグなのだが let dispose; popup(MkPostFormDialog, props, { closed: () => { resolve(); dispose(); }, }).then(res => { dispose = res.dispose; }); }); } export const deckGlobalEvents = new EventEmitter(); export const uploads = ref<{ id: string; name: string; progressMax: number | undefined; progressValue: number | undefined; img: string; }[]>([]); export function upload(file: File, folder?: any, name?: string): Promise { if (folder && typeof folder == 'object') folder = folder.id; return new Promise((resolve, reject) => { const id = Math.random().toString(); const reader = new FileReader(); reader.onload = (e) => { const ctx = reactive({ id: id, name: name || file.name || 'untitled', progressMax: undefined, progressValue: undefined, img: window.URL.createObjectURL(file) }); uploads.value.push(ctx); const data = new FormData(); data.append('i', $i.token); data.append('force', 'true'); data.append('file', file); if (folder) data.append('folderId', folder); if (name) data.append('name', name); const xhr = new XMLHttpRequest(); xhr.open('POST', apiUrl + '/drive/files/create', true); xhr.onload = (ev) => { if (ev.target == null || ev.target.response == null) { // TODO: 消すのではなくて再送できるようにしたい uploads.value = uploads.value.filter(x => x.id != id); alert({ type: 'error', text: 'upload failed' }); reject(); return; } const driveFile = JSON.parse(ev.target.response); resolve(driveFile); uploads.value = uploads.value.filter(x => x.id != id); }; xhr.upload.onprogress = e => { if (e.lengthComputable) { ctx.progressMax = e.total; ctx.progressValue = e.loaded; } }; xhr.send(data); }; reader.readAsArrayBuffer(file); }); } /* export function checkExistence(fileData: ArrayBuffer): Promise { return new Promise((resolve, reject) => { const data = new FormData(); data.append('md5', getMD5(fileData)); os.api('drive/files/find-by-hash', { md5: getMD5(fileData) }).then(resp => { resolve(resp.length > 0 ? resp[0] : null); }); }); }*/