Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
ca773a56c6 |
Binary file not shown.
@@ -31,17 +31,17 @@ body {
|
|||||||
|
|
||||||
.p-select-overlay {
|
.p-select-overlay {
|
||||||
/* Force dropdown width to match computed min-width from PrimeVue internals. */
|
/* Force dropdown width to match computed min-width from PrimeVue internals. */
|
||||||
width: 0 !important;
|
width: 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
.p-select-label {
|
.p-select-label {
|
||||||
width: 0 !important;
|
width: 0;
|
||||||
overflow: hidden !important;
|
overflow: hidden;
|
||||||
text-overflow: ellipsis !important;
|
text-overflow: ellipsis;
|
||||||
}
|
}
|
||||||
|
|
||||||
.p-select-option-label {
|
.p-select-option-label {
|
||||||
min-width: 0 !important;
|
min-width: 0;
|
||||||
overflow: hidden !important;
|
overflow: hidden;
|
||||||
text-overflow: ellipsis !important;
|
text-overflow: ellipsis;
|
||||||
}
|
}
|
||||||
9
client/app/components.d.ts
vendored
9
client/app/components.d.ts
vendored
@@ -13,16 +13,19 @@ declare module 'vue' {
|
|||||||
PrimeButton: typeof import('primevue/button')['default']
|
PrimeButton: typeof import('primevue/button')['default']
|
||||||
PrimeButtonGroup: typeof import('primevue/buttongroup')['default']
|
PrimeButtonGroup: typeof import('primevue/buttongroup')['default']
|
||||||
PrimeCard: typeof import('primevue/card')['default']
|
PrimeCard: typeof import('primevue/card')['default']
|
||||||
PrimeDivider: typeof import('primevue/divider')['default']
|
|
||||||
PrimeFloatLabel: typeof import('primevue/floatlabel')['default']
|
PrimeFloatLabel: typeof import('primevue/floatlabel')['default']
|
||||||
PrimeInputText: typeof import('primevue/inputtext')['default']
|
PrimeInputText: typeof import('primevue/inputtext')['default']
|
||||||
PrimePassword: typeof import('primevue/password')['default']
|
PrimePassword: typeof import('primevue/password')['default']
|
||||||
PrimeScrollPanel: typeof import('primevue/scrollpanel')['default']
|
PrimeScrollPanel: typeof import('primevue/scrollpanel')['default']
|
||||||
PrimeSelect: typeof import('primevue/select')['default']
|
|
||||||
PrimeSelectButton: typeof import('primevue/selectbutton')['default']
|
PrimeSelectButton: typeof import('primevue/selectbutton')['default']
|
||||||
PrimeSlider: typeof import('primevue/slider')['default']
|
PrimeSlider: typeof import('primevue/slider')['default']
|
||||||
|
PrimeTab: typeof import('primevue/tab')['default']
|
||||||
|
PrimeTabList: typeof import('primevue/tablist')['default']
|
||||||
|
PrimeTabPanel: typeof import('primevue/tabpanel')['default']
|
||||||
|
PrimeTabPanels: typeof import('primevue/tabpanels')['default']
|
||||||
|
PrimeTabs: typeof import('primevue/tabs')['default']
|
||||||
|
PrimeTextarea: typeof import('primevue/textarea')['default']
|
||||||
PrimeToast: typeof import('primevue/toast')['default']
|
PrimeToast: typeof import('primevue/toast')['default']
|
||||||
PrimeToggleSwitch: typeof import('primevue/toggleswitch')['default']
|
|
||||||
RouterLink: typeof import('vue-router')['RouterLink']
|
RouterLink: typeof import('vue-router')['RouterLink']
|
||||||
RouterView: typeof import('vue-router')['RouterView']
|
RouterView: typeof import('vue-router')['RouterView']
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -27,7 +27,7 @@
|
|||||||
<PrimeBadge v-if="isMe" severity="secondary" value="You" size="small" class="shrink-0" />
|
<PrimeBadge v-if="isMe" severity="secondary" value="You" size="small" class="shrink-0" />
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<Component :is="expanded ? ChevronUp : ChevronDown" v-if="!isMe" :size="20" class="text-muted-color" />
|
<Component :is="expanded ? ChevronUp : ChevronDown" v-if="!isMe" :size="20" />
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<CollapseTransition v-if="!isMe">
|
<CollapseTransition v-if="!isMe">
|
||||||
|
|||||||
28
client/app/components/chat/ChatEditor.vue
Normal file
28
client/app/components/chat/ChatEditor.vue
Normal file
@@ -0,0 +1,28 @@
|
|||||||
|
<template>
|
||||||
|
<div class="chat-editor">
|
||||||
|
<PrimeTextarea v-model="msg" />
|
||||||
|
<PrimeButton :disabled="!msg" @click="handleSend()">
|
||||||
|
Send
|
||||||
|
</PrimeButton>
|
||||||
|
</div>
|
||||||
|
</template>
|
||||||
|
|
||||||
|
<script lang="ts" setup>
|
||||||
|
interface Emits {
|
||||||
|
(e: 'send', msg: string): void
|
||||||
|
}
|
||||||
|
|
||||||
|
const emit = defineEmits<Emits>()
|
||||||
|
|
||||||
|
const msg = ref<string | undefined>()
|
||||||
|
|
||||||
|
function handleSend() {
|
||||||
|
emit('send', msg.value!)
|
||||||
|
|
||||||
|
msg.value = ''
|
||||||
|
}
|
||||||
|
</script>
|
||||||
|
|
||||||
|
<style lang="scss">
|
||||||
|
|
||||||
|
</style>
|
||||||
27
client/app/components/chat/ChatMessage.vue
Normal file
27
client/app/components/chat/ChatMessage.vue
Normal file
@@ -0,0 +1,27 @@
|
|||||||
|
<template>
|
||||||
|
<PrimeCard>
|
||||||
|
<template #header>
|
||||||
|
<span class="font-bold">
|
||||||
|
{{ username }}
|
||||||
|
</span>
|
||||||
|
</template>
|
||||||
|
<template #content>
|
||||||
|
{{ message }}
|
||||||
|
</template>
|
||||||
|
<template #footer>
|
||||||
|
{{ createdAt }}
|
||||||
|
</template>
|
||||||
|
</PrimeCard>
|
||||||
|
</template>
|
||||||
|
|
||||||
|
<script lang="ts" setup>
|
||||||
|
interface Props {
|
||||||
|
username: string
|
||||||
|
message: string
|
||||||
|
createdAt: Date
|
||||||
|
}
|
||||||
|
|
||||||
|
defineProps<Props>()
|
||||||
|
</script>
|
||||||
|
|
||||||
|
<style lang="scss"></style>
|
||||||
33
client/app/components/chat/ChatWidget.vue
Normal file
33
client/app/components/chat/ChatWidget.vue
Normal file
@@ -0,0 +1,33 @@
|
|||||||
|
<template>
|
||||||
|
<div class="chat-tabs">
|
||||||
|
<div class="chat-tabs__messages">
|
||||||
|
<ChatMessage v-for="msg in messages" :key="msg.id" :created-at="msg.createdAt" :username="msg.username" :message="msg.message" />
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<PrimeTabs :value="channels[0]">
|
||||||
|
<PrimeTabList>
|
||||||
|
<PrimeTab v-for="channel in channels" :key="channel" :value="channel">
|
||||||
|
Channel: {{ channel }}
|
||||||
|
</PrimeTab>
|
||||||
|
</PrimeTabList>
|
||||||
|
<PrimeTabPanels>
|
||||||
|
<PrimeTabPanel :value="channel">
|
||||||
|
<ChatEditor />
|
||||||
|
</PrimeTabPanel>
|
||||||
|
</PrimeTabPanels>
|
||||||
|
</PrimeTabs>
|
||||||
|
</div>
|
||||||
|
</template>
|
||||||
|
|
||||||
|
<script lang="ts" setup>
|
||||||
|
const {
|
||||||
|
channel,
|
||||||
|
|
||||||
|
messages,
|
||||||
|
channels,
|
||||||
|
} = useChat()
|
||||||
|
</script>
|
||||||
|
|
||||||
|
<style lang="scss" scoped>
|
||||||
|
|
||||||
|
</style>
|
||||||
@@ -12,17 +12,7 @@ export const useApp = createGlobalState(() => {
|
|||||||
const ready = ref(false)
|
const ready = ref(false)
|
||||||
const isTauri = computed(() => '__TAURI_INTERNALS__' in window)
|
const isTauri = computed(() => '__TAURI_INTERNALS__' in window)
|
||||||
const commitSha = __COMMIT_SHA__
|
const commitSha = __COMMIT_SHA__
|
||||||
const version = computedAsync(() => {
|
const version = computedAsync(() => isTauri.value ? getVersion() : 'web', '-')
|
||||||
if (import.meta.dev) {
|
|
||||||
return 'dev'
|
|
||||||
}
|
|
||||||
else if (isTauri.value) {
|
|
||||||
return getVersion()
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
return 'web'
|
|
||||||
}
|
|
||||||
}, '-')
|
|
||||||
|
|
||||||
const inputMuted = computed(() => {
|
const inputMuted = computed(() => {
|
||||||
return !!mediasoup.micProducer.value?.paused
|
return !!mediasoup.micProducer.value?.paused
|
||||||
|
|||||||
44
client/app/composables/use-chat.ts
Normal file
44
client/app/composables/use-chat.ts
Normal file
@@ -0,0 +1,44 @@
|
|||||||
|
import { createGlobalState } from '@vueuse/core'
|
||||||
|
|
||||||
|
interface ChatMessage {
|
||||||
|
id: string
|
||||||
|
username: string
|
||||||
|
message: string
|
||||||
|
}
|
||||||
|
|
||||||
|
interface ChatChannel {
|
||||||
|
id: number
|
||||||
|
name: string
|
||||||
|
}
|
||||||
|
|
||||||
|
export const useChat = createGlobalState(() => {
|
||||||
|
const messages = ref([
|
||||||
|
{
|
||||||
|
id: '1337',
|
||||||
|
username: 'Yes',
|
||||||
|
message: 'Fisting is 300 bucks',
|
||||||
|
createdAt: Date.now(),
|
||||||
|
},
|
||||||
|
])
|
||||||
|
|
||||||
|
const channel = ref<number>(0)
|
||||||
|
|
||||||
|
async function sendMsg(channelId: ChatChannel['id'], msg: ChatMessage['message']) {
|
||||||
|
console.log('Trying to send message', channelId, msg)
|
||||||
|
}
|
||||||
|
|
||||||
|
watch(channel, async (id) => {
|
||||||
|
await console.log('Yes', id)
|
||||||
|
}, {
|
||||||
|
immediate: true,
|
||||||
|
})
|
||||||
|
|
||||||
|
return {
|
||||||
|
channel,
|
||||||
|
|
||||||
|
channels,
|
||||||
|
messages,
|
||||||
|
|
||||||
|
sendMsg,
|
||||||
|
}
|
||||||
|
})
|
||||||
@@ -29,25 +29,11 @@ export const useFullscreenVideo = createGlobalState(() => {
|
|||||||
videoEl.value = el
|
videoEl.value = el
|
||||||
}
|
}
|
||||||
|
|
||||||
stream.getTracks().forEach(t =>
|
|
||||||
t.addEventListener('ended', hide),
|
|
||||||
)
|
|
||||||
videoEl.value.addEventListener('ended', hide)
|
|
||||||
|
|
||||||
await videoEl.value.requestFullscreen()
|
await videoEl.value.requestFullscreen()
|
||||||
}
|
}
|
||||||
|
|
||||||
function hide() {
|
function hide() {
|
||||||
if (!videoEl.value)
|
|
||||||
return
|
|
||||||
|
|
||||||
(videoEl.value.srcObject as MediaStream).getTracks().forEach(t =>
|
|
||||||
t.removeEventListener('ended', hide),
|
|
||||||
)
|
|
||||||
videoEl.value.removeEventListener('ended', hide)
|
|
||||||
|
|
||||||
videoEl.value?.remove()
|
videoEl.value?.remove()
|
||||||
videoEl.value = undefined
|
|
||||||
}
|
}
|
||||||
|
|
||||||
useEventListener(document, 'fullscreenchange', () => {
|
useEventListener(document, 'fullscreenchange', () => {
|
||||||
|
|||||||
@@ -317,7 +317,7 @@ export const useMediasoup = createSharedComposable(() => {
|
|||||||
if (!device.value)
|
if (!device.value)
|
||||||
return
|
return
|
||||||
|
|
||||||
const stream = await getShareStream(preferences.shareFps.value)
|
const stream = await getShareStream()
|
||||||
|
|
||||||
const track = stream.getVideoTracks()[0]
|
const track = stream.getVideoTracks()[0]
|
||||||
|
|
||||||
|
|||||||
@@ -19,8 +19,6 @@ export const usePreferences = createGlobalState(() => {
|
|||||||
const noiseSuppression = useLocalStorage('NOISE_SUPPRESSION', true)
|
const noiseSuppression = useLocalStorage('NOISE_SUPPRESSION', true)
|
||||||
const echoCancellation = useLocalStorage('ECHO_CANCELLATION', true)
|
const echoCancellation = useLocalStorage('ECHO_CANCELLATION', true)
|
||||||
|
|
||||||
const shareFps = useLocalStorage('SHARE_FPS', 30)
|
|
||||||
|
|
||||||
const toggleInputHotkey = ref<SyncedPreferences['toggleInputHotkey']>('')
|
const toggleInputHotkey = ref<SyncedPreferences['toggleInputHotkey']>('')
|
||||||
const toggleOutputHotkey = ref<SyncedPreferences['toggleOutputHotkey']>('')
|
const toggleOutputHotkey = ref<SyncedPreferences['toggleOutputHotkey']>('')
|
||||||
|
|
||||||
@@ -59,7 +57,6 @@ export const usePreferences = createGlobalState(() => {
|
|||||||
autoGainControl,
|
autoGainControl,
|
||||||
noiseSuppression,
|
noiseSuppression,
|
||||||
echoCancellation,
|
echoCancellation,
|
||||||
shareFps,
|
|
||||||
toggleInputHotkey,
|
toggleInputHotkey,
|
||||||
toggleOutputHotkey,
|
toggleOutputHotkey,
|
||||||
inputDeviceExist,
|
inputDeviceExist,
|
||||||
|
|||||||
@@ -4,7 +4,7 @@
|
|||||||
class="flex items-center justify-between gap-2 rounded-xl p-3 bg-surface-950"
|
class="flex items-center justify-between gap-2 rounded-xl p-3 bg-surface-950"
|
||||||
>
|
>
|
||||||
<div class="inline-flex items-center gap-3">
|
<div class="inline-flex items-center gap-3">
|
||||||
<PrimeBadge class="opacity-50" severity="secondary" :value="version" size="small" />
|
<PrimeBadge v-if="isTauri" class="opacity-50" severity="secondary" :value="version" size="small" />
|
||||||
<PrimeBadge :severity="connected ? 'success' : 'danger' " />
|
<PrimeBadge :severity="connected ? 'success' : 'danger' " />
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
@@ -72,6 +72,7 @@ import {
|
|||||||
} from 'lucide-vue-next'
|
} from 'lucide-vue-next'
|
||||||
|
|
||||||
const {
|
const {
|
||||||
|
isTauri,
|
||||||
version,
|
version,
|
||||||
clients,
|
clients,
|
||||||
inputMuted,
|
inputMuted,
|
||||||
|
|||||||
@@ -3,7 +3,7 @@
|
|||||||
<div class="flex items-center justify-center">
|
<div class="flex items-center justify-center">
|
||||||
<PrimeCard>
|
<PrimeCard>
|
||||||
<template #content>
|
<template #content>
|
||||||
The chat is under development.
|
<ChatWidget />
|
||||||
</template>
|
</template>
|
||||||
</PrimeCard>
|
</PrimeCard>
|
||||||
</div>
|
</div>
|
||||||
|
|||||||
@@ -47,18 +47,6 @@
|
|||||||
<!-- <label for="outputDevice">Output device</label> -->
|
<!-- <label for="outputDevice">Output device</label> -->
|
||||||
<!-- </PrimeFloatLabel> -->
|
<!-- </PrimeFloatLabel> -->
|
||||||
|
|
||||||
<PrimeDivider align="left">
|
|
||||||
Video
|
|
||||||
</PrimeDivider>
|
|
||||||
|
|
||||||
<div>
|
|
||||||
<div class="flex justify-between text-sm mb-3">
|
|
||||||
<span>FPS</span>
|
|
||||||
<span>{{ shareFps }}</span>
|
|
||||||
</div>
|
|
||||||
<PrimeSlider v-model="shareFps" class="mx-[10px]" :min="30" :max="60" :step="5" />
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<template v-if="isTauri">
|
<template v-if="isTauri">
|
||||||
<PrimeDivider align="left">
|
<PrimeDivider align="left">
|
||||||
Hotkeys
|
Hotkeys
|
||||||
@@ -129,7 +117,6 @@ const {
|
|||||||
toggleOutputHotkey,
|
toggleOutputHotkey,
|
||||||
inputDeviceExist,
|
inputDeviceExist,
|
||||||
outputDeviceExist,
|
outputDeviceExist,
|
||||||
shareFps,
|
|
||||||
} = usePreferences()
|
} = usePreferences()
|
||||||
|
|
||||||
const setupToggleInputHotkey = (event: KeyboardEvent) => setupHotkey(event, toggleInputHotkey)
|
const setupToggleInputHotkey = (event: KeyboardEvent) => setupHotkey(event, toggleInputHotkey)
|
||||||
|
|||||||
@@ -4,7 +4,7 @@ pub fn run() {
|
|||||||
.plugin(tauri_plugin_global_shortcut::Builder::new().build())
|
.plugin(tauri_plugin_global_shortcut::Builder::new().build())
|
||||||
.plugin(tauri_plugin_process::init())
|
.plugin(tauri_plugin_process::init())
|
||||||
.plugin(tauri_plugin_updater::Builder::new().build())
|
.plugin(tauri_plugin_updater::Builder::new().build())
|
||||||
.plugin(tauri_plugin_single_instance::init(|_, _, _| {}))
|
// .plugin(tauri_plugin_single_instance::init(|_, _, _| {}))
|
||||||
.setup(|app| {
|
.setup(|app| {
|
||||||
if cfg!(debug_assertions) {
|
if cfg!(debug_assertions) {
|
||||||
app.handle().plugin(
|
app.handle().plugin(
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
{
|
{
|
||||||
"$schema": "../node_modules/@tauri-apps/cli/config.schema.json",
|
"$schema": "../node_modules/@tauri-apps/cli/config.schema.json",
|
||||||
"productName": "chad",
|
"productName": "chad",
|
||||||
"version": "0.2.19",
|
"version": "0.2.17",
|
||||||
"identifier": "xyz.koptilnya.chad",
|
"identifier": "xyz.koptilnya.chad",
|
||||||
"build": {
|
"build": {
|
||||||
"frontendDist": "../.output/public",
|
"frontendDist": "../.output/public",
|
||||||
|
|||||||
12
node_modules/.yarn-integrity
generated
vendored
Normal file
12
node_modules/.yarn-integrity
generated
vendored
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
{
|
||||||
|
"systemParams": "win32-x64-137",
|
||||||
|
"modulesFolders": [
|
||||||
|
"node_modules"
|
||||||
|
],
|
||||||
|
"flags": [],
|
||||||
|
"linkedModules": [],
|
||||||
|
"topLevelPatterns": [],
|
||||||
|
"lockfileEntries": {},
|
||||||
|
"files": [],
|
||||||
|
"artifacts": {}
|
||||||
|
}
|
||||||
22
server/modules/chat/index.ts
Normal file
22
server/modules/chat/index.ts
Normal file
@@ -0,0 +1,22 @@
|
|||||||
|
import client from '../../prisma/client.ts'
|
||||||
|
|
||||||
|
export async function chatInit() {
|
||||||
|
const existing = client.chatChannel.findFirst({
|
||||||
|
where: {
|
||||||
|
id: 0,
|
||||||
|
},
|
||||||
|
})
|
||||||
|
|
||||||
|
if (!existing) {
|
||||||
|
await client.chatChannel.create({
|
||||||
|
create: {
|
||||||
|
id: 0,
|
||||||
|
name: 'Main channel',
|
||||||
|
},
|
||||||
|
update: null,
|
||||||
|
where: {
|
||||||
|
id: 0,
|
||||||
|
},
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,20 @@
|
|||||||
|
/*
|
||||||
|
Warnings:
|
||||||
|
|
||||||
|
- You are about to drop the column `volumes` on the `UserPreferences` table. All the data in the column will be lost.
|
||||||
|
|
||||||
|
*/
|
||||||
|
-- RedefineTables
|
||||||
|
PRAGMA defer_foreign_keys=ON;
|
||||||
|
PRAGMA foreign_keys=OFF;
|
||||||
|
CREATE TABLE "new_UserPreferences" (
|
||||||
|
"userId" TEXT NOT NULL PRIMARY KEY,
|
||||||
|
"toggleInputHotkey" TEXT DEFAULT '',
|
||||||
|
"toggleOutputHotkey" TEXT DEFAULT '',
|
||||||
|
CONSTRAINT "UserPreferences_userId_fkey" FOREIGN KEY ("userId") REFERENCES "User" ("id") ON DELETE CASCADE ON UPDATE CASCADE
|
||||||
|
);
|
||||||
|
INSERT INTO "new_UserPreferences" ("toggleInputHotkey", "toggleOutputHotkey", "userId") SELECT "toggleInputHotkey", "toggleOutputHotkey", "userId" FROM "UserPreferences";
|
||||||
|
DROP TABLE "UserPreferences";
|
||||||
|
ALTER TABLE "new_UserPreferences" RENAME TO "UserPreferences";
|
||||||
|
PRAGMA foreign_keys=ON;
|
||||||
|
PRAGMA defer_foreign_keys=OFF;
|
||||||
18
server/prisma/migrations/20251226190516_chat/migration.sql
Normal file
18
server/prisma/migrations/20251226190516_chat/migration.sql
Normal file
@@ -0,0 +1,18 @@
|
|||||||
|
-- CreateTable
|
||||||
|
CREATE TABLE "ChatMessage" (
|
||||||
|
"id" TEXT NOT NULL PRIMARY KEY,
|
||||||
|
"userId" TEXT NOT NULL,
|
||||||
|
"channelId" TEXT NOT NULL,
|
||||||
|
"content" TEXT NOT NULL DEFAULT '',
|
||||||
|
CONSTRAINT "ChatMessage_userId_fkey" FOREIGN KEY ("userId") REFERENCES "User" ("id") ON DELETE RESTRICT ON UPDATE CASCADE,
|
||||||
|
CONSTRAINT "ChatMessage_channelId_fkey" FOREIGN KEY ("channelId") REFERENCES "ChatChannel" ("id") ON DELETE CASCADE ON UPDATE CASCADE
|
||||||
|
);
|
||||||
|
|
||||||
|
-- CreateTable
|
||||||
|
CREATE TABLE "ChatChannel" (
|
||||||
|
"id" TEXT NOT NULL PRIMARY KEY,
|
||||||
|
"name" TEXT NOT NULL
|
||||||
|
);
|
||||||
|
|
||||||
|
-- CreateIndex
|
||||||
|
CREATE UNIQUE INDEX "ChatChannel_name_key" ON "ChatChannel"("name");
|
||||||
@@ -0,0 +1,34 @@
|
|||||||
|
/*
|
||||||
|
Warnings:
|
||||||
|
|
||||||
|
- The primary key for the `ChatChannel` table will be changed. If it partially fails, the table could be left without primary key constraint.
|
||||||
|
- You are about to alter the column `id` on the `ChatChannel` table. The data in that column could be lost. The data in that column will be cast from `String` to `Int`.
|
||||||
|
- You are about to alter the column `channelId` on the `ChatMessage` table. The data in that column could be lost. The data in that column will be cast from `String` to `Int`.
|
||||||
|
- Added the required column `createdAt` to the `ChatMessage` table without a default value. This is not possible if the table is not empty.
|
||||||
|
|
||||||
|
*/
|
||||||
|
-- RedefineTables
|
||||||
|
PRAGMA defer_foreign_keys=ON;
|
||||||
|
PRAGMA foreign_keys=OFF;
|
||||||
|
CREATE TABLE "new_ChatChannel" (
|
||||||
|
"id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
|
||||||
|
"name" TEXT NOT NULL
|
||||||
|
);
|
||||||
|
INSERT INTO "new_ChatChannel" ("id", "name") SELECT "id", "name" FROM "ChatChannel";
|
||||||
|
DROP TABLE "ChatChannel";
|
||||||
|
ALTER TABLE "new_ChatChannel" RENAME TO "ChatChannel";
|
||||||
|
CREATE UNIQUE INDEX "ChatChannel_name_key" ON "ChatChannel"("name");
|
||||||
|
CREATE TABLE "new_ChatMessage" (
|
||||||
|
"id" TEXT NOT NULL PRIMARY KEY,
|
||||||
|
"userId" TEXT NOT NULL,
|
||||||
|
"channelId" INTEGER NOT NULL,
|
||||||
|
"content" TEXT NOT NULL DEFAULT '',
|
||||||
|
"createdAt" DATETIME NOT NULL,
|
||||||
|
CONSTRAINT "ChatMessage_userId_fkey" FOREIGN KEY ("userId") REFERENCES "User" ("id") ON DELETE RESTRICT ON UPDATE CASCADE,
|
||||||
|
CONSTRAINT "ChatMessage_channelId_fkey" FOREIGN KEY ("channelId") REFERENCES "ChatChannel" ("id") ON DELETE CASCADE ON UPDATE CASCADE
|
||||||
|
);
|
||||||
|
INSERT INTO "new_ChatMessage" ("channelId", "content", "id", "userId") SELECT "channelId", "content", "id", "userId" FROM "ChatMessage";
|
||||||
|
DROP TABLE "ChatMessage";
|
||||||
|
ALTER TABLE "new_ChatMessage" RENAME TO "ChatMessage";
|
||||||
|
PRAGMA foreign_keys=ON;
|
||||||
|
PRAGMA defer_foreign_keys=OFF;
|
||||||
@@ -0,0 +1,17 @@
|
|||||||
|
-- RedefineTables
|
||||||
|
PRAGMA defer_foreign_keys=ON;
|
||||||
|
PRAGMA foreign_keys=OFF;
|
||||||
|
CREATE TABLE "new_ChatMessage" (
|
||||||
|
"id" TEXT NOT NULL PRIMARY KEY,
|
||||||
|
"userId" TEXT NOT NULL,
|
||||||
|
"channelId" INTEGER NOT NULL,
|
||||||
|
"content" TEXT NOT NULL,
|
||||||
|
"createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
||||||
|
CONSTRAINT "ChatMessage_userId_fkey" FOREIGN KEY ("userId") REFERENCES "User" ("id") ON DELETE RESTRICT ON UPDATE CASCADE,
|
||||||
|
CONSTRAINT "ChatMessage_channelId_fkey" FOREIGN KEY ("channelId") REFERENCES "ChatChannel" ("id") ON DELETE CASCADE ON UPDATE CASCADE
|
||||||
|
);
|
||||||
|
INSERT INTO "new_ChatMessage" ("channelId", "content", "createdAt", "id", "userId") SELECT "channelId", "content", "createdAt", "id", "userId" FROM "ChatMessage";
|
||||||
|
DROP TABLE "ChatMessage";
|
||||||
|
ALTER TABLE "new_ChatMessage" RENAME TO "ChatMessage";
|
||||||
|
PRAGMA foreign_keys=ON;
|
||||||
|
PRAGMA defer_foreign_keys=OFF;
|
||||||
@@ -18,6 +18,8 @@ model User {
|
|||||||
|
|
||||||
Session Session[]
|
Session Session[]
|
||||||
UserPreferences UserPreferences?
|
UserPreferences UserPreferences?
|
||||||
|
|
||||||
|
ChatMessage ChatMessage[]
|
||||||
}
|
}
|
||||||
|
|
||||||
model Session {
|
model Session {
|
||||||
@@ -34,7 +36,26 @@ model UserPreferences {
|
|||||||
userId String @id
|
userId String @id
|
||||||
toggleInputHotkey String? @default("")
|
toggleInputHotkey String? @default("")
|
||||||
toggleOutputHotkey String? @default("")
|
toggleOutputHotkey String? @default("")
|
||||||
volumes Json? @default("{}")
|
|
||||||
|
|
||||||
user User @relation(fields: [userId], references: [id], onDelete: Cascade)
|
user User @relation(fields: [userId], references: [id], onDelete: Cascade)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
model ChatMessage {
|
||||||
|
id String @id
|
||||||
|
|
||||||
|
userId String
|
||||||
|
channelId Int
|
||||||
|
content String
|
||||||
|
|
||||||
|
createdAt DateTime @default(now())
|
||||||
|
|
||||||
|
user User @relation(fields: [userId], references: [id], onDelete: Restrict)
|
||||||
|
channel ChatChannel @relation(fields: [channelId], references: [id], onDelete: Cascade)
|
||||||
|
}
|
||||||
|
|
||||||
|
model ChatChannel {
|
||||||
|
id Int @id
|
||||||
|
name String @unique
|
||||||
|
|
||||||
|
messages ChatMessage[]
|
||||||
|
}
|
||||||
23
server/routes/chat.ts
Normal file
23
server/routes/chat.ts
Normal file
@@ -0,0 +1,23 @@
|
|||||||
|
import type { FastifyInstance } from 'fastify'
|
||||||
|
import prisma from '../prisma/client.ts'
|
||||||
|
|
||||||
|
export default function (fastify: FastifyInstance) {
|
||||||
|
fastify.get('/chats', async (req, reply) => {
|
||||||
|
if (req.user) {
|
||||||
|
return prisma.chatChannel.findMany()
|
||||||
|
}
|
||||||
|
|
||||||
|
reply.code(401).send(false)
|
||||||
|
})
|
||||||
|
|
||||||
|
fastify.get('/chats/:id', async (req, reply) => {
|
||||||
|
if (req.user) {
|
||||||
|
console.log('Trying to fetch chat with id', req.body.id)
|
||||||
|
|
||||||
|
// return prisma.userPreferences.findFirst({ where: { userId: req.user.id } })
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
reply.code(401).send(false)
|
||||||
|
})
|
||||||
|
}
|
||||||
@@ -4,6 +4,7 @@ import FastifyAutoLoad from '@fastify/autoload'
|
|||||||
import FastifyCookie from '@fastify/cookie'
|
import FastifyCookie from '@fastify/cookie'
|
||||||
import FastifyCors from '@fastify/cors'
|
import FastifyCors from '@fastify/cors'
|
||||||
import Fastify from 'fastify'
|
import Fastify from 'fastify'
|
||||||
|
import { chatInit } from './modules/chat/index.ts'
|
||||||
import prisma from './prisma/client.ts'
|
import prisma from './prisma/client.ts'
|
||||||
|
|
||||||
const __filename = fileURLToPath(import.meta.url)
|
const __filename = fileURLToPath(import.meta.url)
|
||||||
@@ -43,6 +44,8 @@ fastify.register(FastifyAutoLoad, {
|
|||||||
|
|
||||||
await prisma.$connect()
|
await prisma.$connect()
|
||||||
fastify.log.info('Testing DB Connection. OK')
|
fastify.log.info('Testing DB Connection. OK')
|
||||||
|
|
||||||
|
await chatInit()
|
||||||
}
|
}
|
||||||
catch (err) {
|
catch (err) {
|
||||||
fastify.log.error(err)
|
fastify.log.error(err)
|
||||||
|
|||||||
Reference in New Issue
Block a user