WIP add chat plugin.

This commit is contained in:
Miroslav Šedivý 2024-06-09 19:04:47 +02:00
parent 86095ecdb1
commit 2d8e5c9753
21 changed files with 835 additions and 49 deletions

1
.gitignore vendored
View File

@ -34,4 +34,5 @@ playwright-report/
/src/page/plugins/* /src/page/plugins/*
!/src/page/plugins/filetransfer !/src/page/plugins/filetransfer
!/src/page/plugins/chat
!/src/page/plugins/.gitkeep !/src/page/plugins/.gitkeep

View File

@ -95,10 +95,6 @@
<i class="fas fa-microphone" /> <i class="fas fa-microphone" />
<span v-show="tab === 'media'">Media</span> <span v-show="tab === 'media'">Media</span>
</li> </li>
<li :class="{ active: tab === 'chat' }" @click.prevent="tab = 'chat'">
<i class="fas fa-comment-alt" />
<span v-show="tab === 'chat'">Chat</span>
</li>
<!-- Plugins --> <!-- Plugins -->
<component v-for="(el, key) in pluginsTabs" :key="key" :is="el" :tab="tab" @tab="tab = $event" /> <component v-for="(el, key) in pluginsTabs" :key="key" :is="el" :tab="tab" @tab="tab = $event" />
@ -108,7 +104,6 @@
<NekoEvents v-if="tab === 'events'" :neko="neko" /> <NekoEvents v-if="tab === 'events'" :neko="neko" />
<NekoMembers v-if="tab === 'members'" :neko="neko" /> <NekoMembers v-if="tab === 'members'" :neko="neko" />
<NekoMedia v-if="tab === 'media'" :neko="neko" /> <NekoMedia v-if="tab === 'media'" :neko="neko" />
<NekoChat v-show="tab === 'chat'" :neko="neko" />
<!-- Plugins --> <!-- Plugins -->
<component v-for="(el, key) in pluginsComponents" :key="key" :is="el" :tab="tab" :neko="neko" /> <component v-for="(el, key) in pluginsComponents" :key="key" :is="el" :tab="tab" :neko="neko" />
@ -354,7 +349,6 @@ import NekoControls from './components/controls.vue'
import NekoEvents from './components/events.vue' import NekoEvents from './components/events.vue'
import NekoMembers from './components/members.vue' import NekoMembers from './components/members.vue'
import NekoMedia from './components/media.vue' import NekoMedia from './components/media.vue'
import NekoChat from './components/chat.vue'
const neko = ref<typeof NekoCanvas>() const neko = ref<typeof NekoCanvas>()

View File

@ -0,0 +1,102 @@
openapi: 3.0.0
info:
title: n.eko REST API
description: Next Gen Renderer Browser.
license:
name: Apache 2.0
url: 'http://www.apache.org/licenses/LICENSE-2.0.html'
version: "1.0.0"
servers:
- description: Local server
url: http://localhost:3000
# Added by API Auto Mocking Plugin
- description: SwaggerHub API Auto Mocking
url: https://virtserver.swaggerhub.com/m1k1o/n.eko/1.0.0
tags:
- name: chat
description: Chat API
paths:
#
# chat
#
/api/chat:
post:
tags:
- chat
summary: Send a chat message
operationId: sendChatMessage
responses:
'200':
description: OK
'401':
$ref: '#/components/responses/Unauthorized'
'403':
$ref: '#/components/responses/Forbidden'
requestBody:
content:
multipart/form-data:
schema:
$ref: '#/components/schemas/Content'
components:
securitySchemes:
CookieAuth:
type: apiKey
in: cookie
name: NEKO_SESSION
BearerAuth:
type: http
scheme: bearer
TokenAuth:
type: apiKey
in: query
name: token
responses:
NotFound:
description: The specified resource was not found
content:
application/json:
schema:
$ref: '#/components/schemas/ErrorMessage'
Unauthorized:
description: Unauthorized
content:
application/json:
schema:
$ref: '#/components/schemas/ErrorMessage'
Forbidden:
description: Forbidden
content:
application/json:
schema:
$ref: '#/components/schemas/ErrorMessage'
schemas:
ErrorMessage:
type: object
properties:
message:
type: string
#
# chat
#
Content:
type: object
properties:
text:
type: string
description: The message content
security:
- BearerAuth: []
- CookieAuth: []
- TokenAuth: []

18
src/page/plugins/chat/api-gen Executable file
View File

@ -0,0 +1,18 @@
#!/bin/bash
VERSION="1.0.0"
rm -rf "${PWD}/api"
mkdir "${PWD}/api"
docker run --rm \
--user "$(id -u):$(id -g)" \
-v "${PWD}/api:/local/out" \
-v "${PWD}/OpenApi.yaml:/local/in.yaml" \
openapitools/openapi-generator-cli generate \
-i /local/in.yaml \
-g typescript-axios \
-o /local/out \
--additional-properties=enumPropertyNaming=original,modelPropertyNaming=original,withSeparateModelsAndApi=true,modelPackage=models,apiPackage=api
# Remove not needed git_push.sh
rm -f "${PWD}/api/git_push.sh"

4
src/page/plugins/chat/api/.gitignore vendored Normal file
View File

@ -0,0 +1,4 @@
wwwroot/*.js
node_modules
typings
dist

View File

@ -0,0 +1 @@
# empty npmignore to ensure all required files (e.g., in the dist folder) are published by npm

View File

@ -0,0 +1,23 @@
# OpenAPI Generator Ignore
# Generated by openapi-generator https://github.com/openapitools/openapi-generator
# Use this file to prevent files from being overwritten by the generator.
# The patterns follow closely to .gitignore or .dockerignore.
# As an example, the C# client generator defines ApiClient.cs.
# You can make changes and tell OpenAPI Generator to ignore just this file by uncommenting the following line:
#ApiClient.cs
# You can match any string of characters against a directory, file or extension with a single asterisk (*):
#foo/*/qux
# The above matches foo/bar/qux and foo/baz/qux, but not foo/bar/baz/qux
# You can recursively match patterns against a directory, file or extension with a double asterisk (**):
#foo/**/qux
# This matches foo/bar/qux, foo/baz/qux, and foo/bar/baz/qux
# You can also negate patterns with an exclamation (!).
# For example, you can ignore all files in a docs folder with the file extension .md:
#docs/*.md
# Then explicitly reverse the ignore rule for a single file:
#!docs/README.md

View File

@ -0,0 +1,12 @@
.gitignore
.npmignore
.openapi-generator-ignore
api.ts
api/chat-api.ts
base.ts
common.ts
configuration.ts
git_push.sh
index.ts
models/error-message.ts
models/index.ts

View File

@ -0,0 +1 @@
7.5.0-SNAPSHOT

View File

@ -0,0 +1,18 @@
/* tslint:disable */
/* eslint-disable */
/**
* n.eko REST API
* Next Gen Renderer Browser.
*
* The version of the OpenAPI document: 1.0.0
*
*
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
* https://openapi-generator.tech
* Do not edit the class manually.
*/
export * from './api/chat-api';

View File

@ -0,0 +1,145 @@
/* tslint:disable */
/* eslint-disable */
/**
* n.eko REST API
* Next Gen Renderer Browser.
*
* The version of the OpenAPI document: 1.0.0
*
*
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
* https://openapi-generator.tech
* Do not edit the class manually.
*/
import type { Configuration } from '../configuration';
import type { AxiosPromise, AxiosInstance, RawAxiosRequestConfig } from 'axios';
import globalAxios from 'axios';
// Some imports not used depending on template conditions
// @ts-ignore
import { DUMMY_BASE_URL, assertParamExists, setApiKeyToObject, setBasicAuthToObject, setBearerAuthToObject, setOAuthToObject, setSearchParams, serializeDataIfNeeded, toPathString, createRequestFunction } from '../common';
// @ts-ignore
import { BASE_PATH, COLLECTION_FORMATS, RequestArgs, BaseAPI, RequiredError, operationServerMap } from '../base';
// @ts-ignore
import { ErrorMessage } from '../models';
/**
* ChatApi - axios parameter creator
* @export
*/
export const ChatApiAxiosParamCreator = function (configuration?: Configuration) {
return {
/**
*
* @summary Send a chat message
* @param {string} [content] The message content
* @param {*} [options] Override http request option.
* @throws {RequiredError}
*/
sendChatMessage: async (content?: string, options: RawAxiosRequestConfig = {}): Promise<RequestArgs> => {
const localVarPath = `/api/chat`;
// use dummy base URL string because the URL constructor only accepts absolute URLs.
const localVarUrlObj = new URL(localVarPath, DUMMY_BASE_URL);
let baseOptions;
if (configuration) {
baseOptions = configuration.baseOptions;
}
const localVarRequestOptions = { method: 'POST', ...baseOptions, ...options};
const localVarHeaderParameter = {} as any;
const localVarQueryParameter = {} as any;
const localVarFormParams = new ((configuration && configuration.formDataCtor) || FormData)();
// authentication CookieAuth required
// authentication TokenAuth required
await setApiKeyToObject(localVarQueryParameter, "token", configuration)
// authentication BearerAuth required
// http bearer authentication required
await setBearerAuthToObject(localVarHeaderParameter, configuration)
if (content !== undefined) {
localVarFormParams.append('content', content as any);
}
localVarHeaderParameter['Content-Type'] = 'multipart/form-data';
setSearchParams(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};
localVarRequestOptions.data = localVarFormParams;
return {
url: toPathString(localVarUrlObj),
options: localVarRequestOptions,
};
},
}
};
/**
* ChatApi - functional programming interface
* @export
*/
export const ChatApiFp = function(configuration?: Configuration) {
const localVarAxiosParamCreator = ChatApiAxiosParamCreator(configuration)
return {
/**
*
* @summary Send a chat message
* @param {string} [content] The message content
* @param {*} [options] Override http request option.
* @throws {RequiredError}
*/
async sendChatMessage(content?: string, options?: RawAxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<void>> {
const localVarAxiosArgs = await localVarAxiosParamCreator.sendChatMessage(content, options);
const localVarOperationServerIndex = configuration?.serverIndex ?? 0;
const localVarOperationServerBasePath = operationServerMap['ChatApi.sendChatMessage']?.[localVarOperationServerIndex]?.url;
return (axios, basePath) => createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration)(axios, localVarOperationServerBasePath || basePath);
},
}
};
/**
* ChatApi - factory interface
* @export
*/
export const ChatApiFactory = function (configuration?: Configuration, basePath?: string, axios?: AxiosInstance) {
const localVarFp = ChatApiFp(configuration)
return {
/**
*
* @summary Send a chat message
* @param {string} [content] The message content
* @param {*} [options] Override http request option.
* @throws {RequiredError}
*/
sendChatMessage(content?: string, options?: any): AxiosPromise<void> {
return localVarFp.sendChatMessage(content, options).then((request) => request(axios, basePath));
},
};
};
/**
* ChatApi - object-oriented interface
* @export
* @class ChatApi
* @extends {BaseAPI}
*/
export class ChatApi extends BaseAPI {
/**
*
* @summary Send a chat message
* @param {string} [content] The message content
* @param {*} [options] Override http request option.
* @throws {RequiredError}
* @memberof ChatApi
*/
public sendChatMessage(content?: string, options?: RawAxiosRequestConfig) {
return ChatApiFp(this.configuration).sendChatMessage(content, options).then((request) => request(this.axios, this.basePath));
}
}

View File

@ -0,0 +1,86 @@
/* tslint:disable */
/* eslint-disable */
/**
* n.eko REST API
* Next Gen Renderer Browser.
*
* The version of the OpenAPI document: 1.0.0
*
*
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
* https://openapi-generator.tech
* Do not edit the class manually.
*/
import type { Configuration } from './configuration';
// Some imports not used depending on template conditions
// @ts-ignore
import type { AxiosPromise, AxiosInstance, RawAxiosRequestConfig } from 'axios';
import globalAxios from 'axios';
export const BASE_PATH = "http://localhost:3000".replace(/\/+$/, "");
/**
*
* @export
*/
export const COLLECTION_FORMATS = {
csv: ",",
ssv: " ",
tsv: "\t",
pipes: "|",
};
/**
*
* @export
* @interface RequestArgs
*/
export interface RequestArgs {
url: string;
options: RawAxiosRequestConfig;
}
/**
*
* @export
* @class BaseAPI
*/
export class BaseAPI {
protected configuration: Configuration | undefined;
constructor(configuration?: Configuration, protected basePath: string = BASE_PATH, protected axios: AxiosInstance = globalAxios) {
if (configuration) {
this.configuration = configuration;
this.basePath = configuration.basePath ?? basePath;
}
}
};
/**
*
* @export
* @class RequiredError
* @extends {Error}
*/
export class RequiredError extends Error {
constructor(public field: string, msg?: string) {
super(msg);
this.name = "RequiredError"
}
}
interface ServerMap {
[key: string]: {
url: string,
description: string,
}[];
}
/**
*
* @export
*/
export const operationServerMap: ServerMap = {
}

View File

@ -0,0 +1,150 @@
/* tslint:disable */
/* eslint-disable */
/**
* n.eko REST API
* Next Gen Renderer Browser.
*
* The version of the OpenAPI document: 1.0.0
*
*
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
* https://openapi-generator.tech
* Do not edit the class manually.
*/
import type { Configuration } from "./configuration";
import type { RequestArgs } from "./base";
import type { AxiosInstance, AxiosResponse } from 'axios';
import { RequiredError } from "./base";
/**
*
* @export
*/
export const DUMMY_BASE_URL = 'https://example.com'
/**
*
* @throws {RequiredError}
* @export
*/
export const assertParamExists = function (functionName: string, paramName: string, paramValue: unknown) {
if (paramValue === null || paramValue === undefined) {
throw new RequiredError(paramName, `Required parameter ${paramName} was null or undefined when calling ${functionName}.`);
}
}
/**
*
* @export
*/
export const setApiKeyToObject = async function (object: any, keyParamName: string, configuration?: Configuration) {
if (configuration && configuration.apiKey) {
const localVarApiKeyValue = typeof configuration.apiKey === 'function'
? await configuration.apiKey(keyParamName)
: await configuration.apiKey;
object[keyParamName] = localVarApiKeyValue;
}
}
/**
*
* @export
*/
export const setBasicAuthToObject = function (object: any, configuration?: Configuration) {
if (configuration && (configuration.username || configuration.password)) {
object["auth"] = { username: configuration.username, password: configuration.password };
}
}
/**
*
* @export
*/
export const setBearerAuthToObject = async function (object: any, configuration?: Configuration) {
if (configuration && configuration.accessToken) {
const accessToken = typeof configuration.accessToken === 'function'
? await configuration.accessToken()
: await configuration.accessToken;
object["Authorization"] = "Bearer " + accessToken;
}
}
/**
*
* @export
*/
export const setOAuthToObject = async function (object: any, name: string, scopes: string[], configuration?: Configuration) {
if (configuration && configuration.accessToken) {
const localVarAccessTokenValue = typeof configuration.accessToken === 'function'
? await configuration.accessToken(name, scopes)
: await configuration.accessToken;
object["Authorization"] = "Bearer " + localVarAccessTokenValue;
}
}
function setFlattenedQueryParams(urlSearchParams: URLSearchParams, parameter: any, key: string = ""): void {
if (parameter == null) return;
if (typeof parameter === "object") {
if (Array.isArray(parameter)) {
(parameter as any[]).forEach(item => setFlattenedQueryParams(urlSearchParams, item, key));
}
else {
Object.keys(parameter).forEach(currentKey =>
setFlattenedQueryParams(urlSearchParams, parameter[currentKey], `${key}${key !== '' ? '.' : ''}${currentKey}`)
);
}
}
else {
if (urlSearchParams.has(key)) {
urlSearchParams.append(key, parameter);
}
else {
urlSearchParams.set(key, parameter);
}
}
}
/**
*
* @export
*/
export const setSearchParams = function (url: URL, ...objects: any[]) {
const searchParams = new URLSearchParams(url.search);
setFlattenedQueryParams(searchParams, objects);
url.search = searchParams.toString();
}
/**
*
* @export
*/
export const serializeDataIfNeeded = function (value: any, requestOptions: any, configuration?: Configuration) {
const nonString = typeof value !== 'string';
const needsSerialization = nonString && configuration && configuration.isJsonMime
? configuration.isJsonMime(requestOptions.headers['Content-Type'])
: nonString;
return needsSerialization
? JSON.stringify(value !== undefined ? value : {})
: (value || "");
}
/**
*
* @export
*/
export const toPathString = function (url: URL) {
return url.pathname + url.search + url.hash
}
/**
*
* @export
*/
export const createRequestFunction = function (axiosArgs: RequestArgs, globalAxios: AxiosInstance, BASE_PATH: string, configuration?: Configuration) {
return <T = unknown, R = AxiosResponse<T>>(axios: AxiosInstance = globalAxios, basePath: string = BASE_PATH) => {
const axiosRequestArgs = {...axiosArgs.options, url: (axios.defaults.baseURL ? '' : configuration?.basePath ?? basePath) + axiosArgs.url};
return axios.request<T, R>(axiosRequestArgs);
};
}

View File

@ -0,0 +1,110 @@
/* tslint:disable */
/* eslint-disable */
/**
* n.eko REST API
* Next Gen Renderer Browser.
*
* The version of the OpenAPI document: 1.0.0
*
*
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
* https://openapi-generator.tech
* Do not edit the class manually.
*/
export interface ConfigurationParameters {
apiKey?: string | Promise<string> | ((name: string) => string) | ((name: string) => Promise<string>);
username?: string;
password?: string;
accessToken?: string | Promise<string> | ((name?: string, scopes?: string[]) => string) | ((name?: string, scopes?: string[]) => Promise<string>);
basePath?: string;
serverIndex?: number;
baseOptions?: any;
formDataCtor?: new () => any;
}
export class Configuration {
/**
* parameter for apiKey security
* @param name security name
* @memberof Configuration
*/
apiKey?: string | Promise<string> | ((name: string) => string) | ((name: string) => Promise<string>);
/**
* parameter for basic security
*
* @type {string}
* @memberof Configuration
*/
username?: string;
/**
* parameter for basic security
*
* @type {string}
* @memberof Configuration
*/
password?: string;
/**
* parameter for oauth2 security
* @param name security name
* @param scopes oauth2 scope
* @memberof Configuration
*/
accessToken?: string | Promise<string> | ((name?: string, scopes?: string[]) => string) | ((name?: string, scopes?: string[]) => Promise<string>);
/**
* override base path
*
* @type {string}
* @memberof Configuration
*/
basePath?: string;
/**
* override server index
*
* @type {number}
* @memberof Configuration
*/
serverIndex?: number;
/**
* base options for axios calls
*
* @type {any}
* @memberof Configuration
*/
baseOptions?: any;
/**
* The FormData constructor that will be used to create multipart form data
* requests. You can inject this here so that execution environments that
* do not support the FormData class can still run the generated client.
*
* @type {new () => FormData}
*/
formDataCtor?: new () => any;
constructor(param: ConfigurationParameters = {}) {
this.apiKey = param.apiKey;
this.username = param.username;
this.password = param.password;
this.accessToken = param.accessToken;
this.basePath = param.basePath;
this.serverIndex = param.serverIndex;
this.baseOptions = param.baseOptions;
this.formDataCtor = param.formDataCtor;
}
/**
* Check if the given MIME is a JSON MIME.
* JSON MIME examples:
* application/json
* application/json; charset=UTF8
* APPLICATION/JSON
* application/vnd.company+json
* @param mime - MIME (Multipurpose Internet Mail Extensions)
* @return True if the given MIME is JSON, false otherwise.
*/
public isJsonMime(mime: string): boolean {
const jsonMime: RegExp = new RegExp('^(application\/json|[^;/ \t]+\/[^;/ \t]+[+]json)[ \t]*(;.*)?$', 'i');
return mime !== null && (jsonMime.test(mime) || mime.toLowerCase() === 'application/json-patch+json');
}
}

View File

@ -0,0 +1,18 @@
/* tslint:disable */
/* eslint-disable */
/**
* n.eko REST API
* Next Gen Renderer Browser.
*
* The version of the OpenAPI document: 1.0.0
*
*
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
* https://openapi-generator.tech
* Do not edit the class manually.
*/
export * from "./api";
export * from "./configuration";
export * from "./models";

View File

@ -0,0 +1,30 @@
/* tslint:disable */
/* eslint-disable */
/**
* n.eko REST API
* Next Gen Renderer Browser.
*
* The version of the OpenAPI document: 1.0.0
*
*
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
* https://openapi-generator.tech
* Do not edit the class manually.
*/
/**
*
* @export
* @interface ErrorMessage
*/
export interface ErrorMessage {
/**
*
* @type {string}
* @memberof ErrorMessage
*/
'message'?: string;
}

View File

@ -0,0 +1 @@
export * from './error-message';

View File

@ -1,5 +1,13 @@
<template> <template>
<div class="chat"> <div class="chat" v-if="tab === 'chat'">
<div class="chat-header">
<p>Chat is {{ isLocked ? 'locked' : 'unlocked' }} for users</p>
<i :class="['fas', isLocked ? 'fa-lock' : 'fa-unlock', 'refresh']" @click="setLock(!isLocked)" :title="isLocked ? 'Unlock' : 'Lock'" />
</div>
<div class="chat-header">
<p>Chat is {{ !enabled ? 'disabled' : 'enabled' }}</p>
<i class="fas fa-rotate-right refresh" />
</div>
<ul class="chat-history" ref="history"> <ul class="chat-history" ref="history">
<template v-for="(message, index) in messages" :key="index"> <template v-for="(message, index) in messages" :key="index">
<li class="message" v-show="neko && neko.connected"> <li class="message" v-show="neko && neko.connected">
@ -8,7 +16,7 @@
<span class="session">{{ session(message.id) }}</span> <span class="session">{{ session(message.id) }}</span>
<span class="timestamp">{{ timestamp(message.created) }}</span> <span class="timestamp">{{ timestamp(message.created) }}</span>
</div> </div>
<p>{{ message.content }}</p> <p>{{ message.content.text }}</p>
</div> </div>
</li> </li>
</template> </template>
@ -32,6 +40,20 @@
max-width: 100%; max-width: 100%;
overflow-x: hidden; overflow-x: hidden;
.chat-header {
display: flex;
flex-direction: row;
margin: 10px 10px 0px 10px;
padding: 0.5em;
font-weight: 600;
background-color: rgba($color: #fff, $alpha: 0.05);
border-radius: 5px;
.refresh {
margin-left: auto;
}
}
.chat-history { .chat-history {
flex: 1; flex: 1;
overflow-y: scroll; overflow-y: scroll;
@ -163,31 +185,46 @@
</style> </style>
<script lang="ts" setup> <script lang="ts" setup>
import { ref, watch, onMounted } from 'vue' import { ref, watch, computed, onMounted } from 'vue'
import type Neko from '@/component/main.vue' import type Neko from '@/component/main.vue'
import * as types from './types'
// TODO: Use API.
// import { ChatApi } from './api'
// const api = props.neko.withApi(ChatApi) as ChatApi
const length = 512 // max length of message const length = 512 // max length of message
const history = ref<HTMLUListElement | null>(null) const history = ref<HTMLUListElement | null>(null)
const props = defineProps<{ const props = defineProps<{
neko: typeof Neko neko: typeof Neko,
tab: string
}>() }>()
const emit = defineEmits(['send_message']) const enabled = ref(false)
const enabledForMe = computed(() => enabled.value && (props.neko.is_admin || (!props.neko.is_admin && !isLocked.value)))
type Message = { const messages = ref<types.Message[]>([])
id: string
created: Date
content: string
}
const messages = ref<Message[]>([])
const content = ref('') const content = ref('')
onMounted(() => { onMounted(() => {
props.neko.events.on('message', async (event: string, payload: any) => {
switch (event) {
case types.CHAT_INIT: {
const message = payload as types.Init
enabled.value = message.enabled
break
}
case types.CHAT_MESSAGE: {
const message = payload as types.Message
messages.value = [...messages.value, message]
break
}
}
})
setTimeout(() => { setTimeout(() => {
history.value!.scrollTop = history.value!.scrollHeight if (history.value)
history.value.scrollTop = history.value.scrollHeight
}, 0) }, 0)
}) })
@ -214,24 +251,12 @@ function session(id: string) {
return session ? session.profile.name : id return session ? session.profile.name : id
} }
function onNekoChange() { watch(messages, function() {
props.neko.events.on('receive.broadcast', (sender: string, subject: string, body: any) => {
if (subject === 'chat') {
const message = body as Message
messages.value = [...messages.value, message]
}
})
}
watch(() => props.neko, onNekoChange)
function onHistroyChange() {
setTimeout(() => { setTimeout(() => {
history.value!.scrollTop = history.value!.scrollHeight if (history.value)
history.value.scrollTop = history.value.scrollHeight
}, 0) }, 0)
} })
watch(messages, onHistroyChange)
function onKeyDown(event: KeyboardEvent) { function onKeyDown(event: KeyboardEvent) {
if (content.value.length > length) { if (content.value.length > length) {
@ -253,23 +278,29 @@ function onKeyDown(event: KeyboardEvent) {
return return
} }
sendMessage()
event.preventDefault()
}
function sendMessage() {
if (content.value === '') { if (content.value === '') {
event.preventDefault()
return return
} }
emit('send_message', content.value) props.neko.sendMessage(types.CHAT_MESSAGE, {
text: content.value,
let message = { } as types.Content)
id: props.neko.state.session_id,
created: new Date(),
content: content.value,
}
props.neko.sendBroadcast('chat', message)
messages.value = [...messages.value, message]
content.value = '' content.value = ''
event.preventDefault() }
const isLocked = computed(() => props.neko.state.settings?.plugins?.chat === true)
async function setLock(isLocked = true) {
try {
await props.neko.room.settingsSet({ plugins: { chat: isLocked } })
} catch (e: any) {
alert(e.response ? e.response.data.message : e)
}
} }
</script> </script>

View File

@ -0,0 +1,7 @@
import Components from './component.vue'
import Tabs from './tab.vue'
export {
Components,
Tabs,
}

View File

@ -0,0 +1,18 @@
<template>
<span>
<li :class="{ active: tab === 'chat' }" @click.prevent="emit('tab', 'chat')">
<i class="fas fa-comment-alt"></i>
<span v-show="tab === 'chat'">Chat</span>
</li>
</span>
</template>
<script lang="ts" setup>
defineProps<{
tab: string
}>()
const emit = defineEmits<{
(event: 'tab', tab: string): void
}>()
</script>

View File

@ -0,0 +1,16 @@
export const CHAT_INIT = "chat/init"
export const CHAT_MESSAGE = "chat/message"
export interface Init {
enabled: boolean
}
export interface Content {
text: string
}
export interface Message {
id: string
created: Date
content: Content
}