=> {
event.preventDefault();
const formData = new FormData(event.currentTarget);
@@ -264,35 +190,34 @@ export default function Form() {
[save],
);
+ const isTauriEnv = isTauri();
+
return (
-
- {isTauri() ? (
+
+ {isTauriEnv ? (
<>
{
if (!data.startsWith("tensamin://tu::")) {
toast("error", "Invalid QR code");
return;
- }
+ } else {
+ const decoded = data.replace("tensamin://tu::", "");
- const decoded = data.replace("tensamin://tu::", "");
-
- try {
- const { userId, privateKey, domain } =
- parseTuFileContent(decoded);
-
- await save("session_id", Date.now());
- await save("user_id", userId);
- await save("private_key", privateKey);
-
- if (domain) {
- await save("ttp_url", `https://${domain}/`);
+ try {
+ const { userId, privateKey, domain } =
+ parseTuFileContent(decoded);
+ await save("session_id", Date.now());
+ await save("user_id", userId);
+ await save("private_key", privateKey);
+ if (domain) {
+ await save("ttp_url", `https://${domain}/`);
+ }
+ location.href = "/";
+ } catch (error) {
+ log(0, "login", "red", error);
+ toast("error", "Failed to parse QR code data");
}
-
- location.href = "/";
- } catch (error) {
- log(0, "login", "red", error);
- toast("error", "Failed to parse QR code data");
}
}}
/>
@@ -303,30 +228,10 @@ export default function Form() {
) : (
uploadRef.current?.click()}
- className={cn(
- "flex flex-col gap-3 cursor-pointer w-55 aspect-square",
- "border-3 items-center justify-center rounded-lg",
- "transition-all duration-300 ease-in-out",
- "border-input",
- "bg-input/13 hover:bg-input/30",
- isDragging ? "animate-wiggle" : "",
- )}
+ className="flex flex-col gap-3 cursor-pointer w-55 aspect-square bg-input/13 hover:bg-input/30 transition-all duration-300 ease-in-out border-3 items-center justify-center rounded-lg"
>
-
-
-
- Select .tu file
-
+
+
Select .tu file
- Change Enter behavior to Shift +{" "}
- Enter
-
- }
+ label="Reverse Enter Key Behavior"
id="settings.reverse_enter_behavior"
/>
-
-
-
);
}
diff --git a/apps/web/src/routes/settings/security.tsx b/apps/web/src/routes/settings/security.tsx
index 86c580e..15a6155 100644
--- a/apps/web/src/routes/settings/security.tsx
+++ b/apps/web/src/routes/settings/security.tsx
@@ -46,7 +46,6 @@ function QrCodeLogin() {
const [qrCodeBase64, setQrCodeBase64] = useState(
undefined,
);
- const [connectionString, setConnectionString] = useState(null);
useEffect(() => {
load("private_key").then((value) => {
@@ -59,25 +58,15 @@ function QrCodeLogin() {
setUserId(value);
}
});
- load("ttp_url")
- .then((value) => {
- if (value) {
- const url = new URL(value);
- setConnectionString(`@${url.host}`);
- } else {
- setConnectionString("");
- }
- })
- .catch(() => setConnectionString(""));
}, [load]);
useEffect(() => {
- if (userId && privateKey && connectionString !== null) {
- generateQR(
- `tensamin://tu::${userId}${connectionString}::${privateKey}`,
- ).then(setQrCodeBase64);
+ if (userId && privateKey) {
+ generateQR(`tensamin://tu::${userId}::${privateKey}`).then(
+ setQrCodeBase64,
+ );
}
- }, [userId, privateKey, connectionString]);
+ }, [userId, privateKey]);
const [qrCodeVisible, setQrCodeVisible] = useState(false);
diff --git a/bun.lock b/bun.lock
index 1f1b34a..ff51499 100644
--- a/bun.lock
+++ b/bun.lock
@@ -40,7 +40,6 @@
},
"devDependencies": {
"@tauri-apps/cli": "^2",
- "@types/node": "^25.9.1",
},
},
"apps/web": {
@@ -171,7 +170,6 @@
"name": "@tensamin/notifications",
"version": "0.0.0",
"dependencies": {
- "@tanstack/react-router": "^1.169.1",
"@tauri-apps/api": "^2.11.0",
"@tensamin/chat": "workspace:*",
"@tensamin/crypto": "workspace:*",
@@ -1663,8 +1661,6 @@
"@tailwindcss/oxide-wasm32-wasi/tslib": ["tslib@2.8.1", "", { "bundled": true }, "sha512-oJFu94HQb+KVduSUQL7wnpmqnfmLsOA/nAh6b6EH0wCEoK0/mPeXU6c3wKDV83MkOuHPRHtSXKKU99IBazS/2w=="],
- "@tensamin/tauri/@types/node": ["@types/node@25.9.1", "", { "dependencies": { "undici-types": ">=7.24.0 <7.24.7" } }, "sha512-xfrlY7UD5rMJk3ZVJP8BNzS28J36YJg+xp+LPXV1TdWxr8uMH5A860QNxYDGQe/ylDSgjxE52Q9VnO7p75tJxg=="],
-
"@tensamin/ui/recharts": ["recharts@3.8.0", "", { "dependencies": { "@reduxjs/toolkit": "^1.9.0 || 2.x.x", "clsx": "^2.1.1", "decimal.js-light": "^2.5.1", "es-toolkit": "^1.39.3", "eventemitter3": "^5.0.1", "immer": "^10.1.1", "react-redux": "8.x.x || 9.x.x", "reselect": "5.1.1", "tiny-invariant": "^1.3.3", "use-sync-external-store": "^1.2.2", "victory-vendor": "^37.0.2" }, "peerDependencies": { "react": "^16.8.0 || ^17.0.0 || ^18.0.0 || ^19.0.0", "react-dom": "^16.0.0 || ^17.0.0 || ^18.0.0 || ^19.0.0", "react-is": "^16.8.0 || ^17.0.0 || ^18.0.0 || ^19.0.0" } }, "sha512-Z/m38DX3L73ExO4Tpc9/iZWHmHnlzWG4njQbxsF5aSjwqmHNDDIm0rdEBArkwsBvR8U6EirlEHiQNYWCVh9sGQ=="],
"@tensamin/ui/shadcn": ["shadcn@3.8.5", "", { "dependencies": { "@antfu/ni": "^25.0.0", "@babel/core": "^7.28.0", "@babel/parser": "^7.28.0", "@babel/plugin-transform-typescript": "^7.28.0", "@babel/preset-typescript": "^7.27.1", "@dotenvx/dotenvx": "^1.48.4", "@modelcontextprotocol/sdk": "^1.26.0", "@types/validate-npm-package-name": "^4.0.2", "browserslist": "^4.26.2", "commander": "^14.0.0", "cosmiconfig": "^9.0.0", "dedent": "^1.6.0", "deepmerge": "^4.3.1", "diff": "^8.0.2", "execa": "^9.6.0", "fast-glob": "^3.3.3", "fs-extra": "^11.3.1", "fuzzysort": "^3.1.0", "https-proxy-agent": "^7.0.6", "kleur": "^4.1.5", "msw": "^2.10.4", "node-fetch": "^3.3.2", "open": "^11.0.0", "ora": "^8.2.0", "postcss": "^8.5.6", "postcss-selector-parser": "^7.1.0", "prompts": "^2.4.2", "recast": "^0.23.11", "stringify-object": "^5.0.0", "tailwind-merge": "^3.0.1", "ts-morph": "^26.0.0", "tsconfig-paths": "^4.2.0", "validate-npm-package-name": "^7.0.1", "zod": "^3.24.1", "zod-to-json-schema": "^3.24.6" }, "bin": { "shadcn": "dist/index.js" } }, "sha512-jPRx44e+eyeV7xwY3BLJXcfrks00+M0h5BGB9l6DdcBW4BpAj4x3lVmVy0TXPEs2iHEisxejr62sZAAw6B1EVA=="],
@@ -1725,8 +1721,6 @@
"@modelcontextprotocol/sdk/ajv/json-schema-traverse": ["json-schema-traverse@1.0.0", "", {}, "sha512-NM8/P9n3XjXhIZn1lLhkFaACTOURQXjWhV4BA/RnOv8xvgqtqpAX9IO4mRQxSx1Rlo4tqzeqb0sOlruaOy3dug=="],
- "@tensamin/tauri/@types/node/undici-types": ["undici-types@7.24.6", "", {}, "sha512-WRNW+sJgj5OBN4/0JpHFqtqzhpbnV0GuB+OozA9gCL7a993SmU+1JBZCzLNxYsbMfIeDL+lTsphD5jN5N+n0zg=="],
-
"@tensamin/ui/shadcn/zod": ["zod@3.25.76", "", {}, "sha512-gzUt/qt81nXsFGKIFcC3YnfEAx5NkunCfnDlvuBSSFS02bcXu4Lmea0AFIUwbLWxWPx3d9p8S5QoaujKcNQxcQ=="],
"ajv-formats/ajv/json-schema-traverse": ["json-schema-traverse@1.0.0", "", {}, "sha512-NM8/P9n3XjXhIZn1lLhkFaACTOURQXjWhV4BA/RnOv8xvgqtqpAX9IO4mRQxSx1Rlo4tqzeqb0sOlruaOy3dug=="],
diff --git a/package.json b/package.json
index d408353..b0dfc08 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
{
"name": "tensamin",
- "version": "0.0.3",
+ "version": "0.0.2",
"private": true,
"workspaces": [
"packages/*",
diff --git a/packages/call/src/components/sidebarBox.tsx b/packages/call/src/components/sidebarBox.tsx
index ac715e9..6a850f0 100644
--- a/packages/call/src/components/sidebarBox.tsx
+++ b/packages/call/src/components/sidebarBox.tsx
@@ -1,5 +1,5 @@
import { Lock, LockOpen } from "lucide-react";
-import { openCallPage, useCall, getRoom } from "../store";
+import { openCallPage, useCall } from "../store";
import {
Button,
Card,
@@ -78,7 +78,7 @@ function ConnectionBar() {
}
export function TinyPingGraph() {
- const room = getRoom();
+ const room = useCall((store) => store.room);
const [mapData, setMapData] = useState>(() => new Map());
diff --git a/packages/call/src/components/top.tsx b/packages/call/src/components/top.tsx
index 610493a..62e8bfc 100644
--- a/packages/call/src/components/top.tsx
+++ b/packages/call/src/components/top.tsx
@@ -1,5 +1,5 @@
import { useUser, type User } from "@tensamin/user/context";
-import { useCall, getRoom } from "../store";
+import { useCall } from "../store";
import { useEffect, useState } from "react";
import { useStorage } from "@tensamin/storage/context";
import {
@@ -14,7 +14,7 @@ import {
export default function TopBar() {
const { get } = useUser();
const { load } = useStorage();
- const room = getRoom();
+ const room = useCall((state) => state.room);
const screenRef = useCall((state) => state.screenRef);
const [portalContainer, setPortalContainer] = useState();
diff --git a/packages/call/src/components/videoViewer.tsx b/packages/call/src/components/videoViewer.tsx
index 1268b22..40cf6ac 100644
--- a/packages/call/src/components/videoViewer.tsx
+++ b/packages/call/src/components/videoViewer.tsx
@@ -1,6 +1,6 @@
import { VideoTrack, useParticipantTracks } from "@livekit/components-react";
import { TrackPublication } from "livekit-client";
-import { getRoom } from "../store";
+import { useCall } from "../store";
import { cn } from "@tensamin/ui";
import { Loader2 } from "lucide-react";
@@ -17,7 +17,7 @@ export default function VideoViewer({
publication: TrackPublication;
participantId: string;
}) {
- const room = getRoom();
+ const room = useCall((state) => state.room);
const tracks = useParticipantTracks([publication.source], {
participantIdentity: participantId,
room,
diff --git a/packages/call/src/store.tsx b/packages/call/src/store.tsx
index 5398e70..3d63963 100644
--- a/packages/call/src/store.tsx
+++ b/packages/call/src/store.tsx
@@ -101,46 +101,27 @@ type CallStore = {
callIsPopout: boolean;
layoutVersion: number;
screenRef: React.RefObject | null;
+ room: Room;
+ keyProvider: ExternalE2EEKeyProvider;
+ e2eeWorker: Worker;
runtime: Runtime | null;
speakingParticipantIds: Set;
micGated: boolean;
};
-let _keyProvider: ExternalE2EEKeyProvider | null = null;
-let _e2eeWorker: Worker | null = null;
-let _room: Room | null = null;
-
-function getKeyProvider(): ExternalE2EEKeyProvider {
- if (!_keyProvider) {
- _keyProvider = new ExternalE2EEKeyProvider();
- }
- return _keyProvider;
-}
-
-function getE2EEWorker(): Worker {
- if (!_e2eeWorker) {
- _e2eeWorker = new Worker(
- new URL("livekit-client/e2ee-worker", import.meta.url),
- );
- }
- return _e2eeWorker;
-}
-
-export function getRoom(): Room {
- if (!_room) {
- _room = new Room({
- dynacast: true,
- adaptiveStream: true,
- loggerName: "tensamin",
- encryption: {
- keyProvider: getKeyProvider(),
- worker: getE2EEWorker(),
- },
- });
- }
- return _room;
-}
-
+const keyProvider = new ExternalE2EEKeyProvider();
+const e2eeWorker = new Worker(
+ new URL("livekit-client/e2ee-worker", import.meta.url),
+);
+const room = new Room({
+ dynacast: true,
+ adaptiveStream: true,
+ loggerName: "tensamin",
+ encryption: {
+ keyProvider,
+ worker: e2eeWorker,
+ },
+});
const remoteAudioElements = new Map();
const SCREEN_SHARE_PREVIEW_MAX_WIDTH = 320;
@@ -189,7 +170,6 @@ export function getParticipantId(identity: string | undefined): number | null {
}
function getAllParticipants(): Participant[] {
- const room = getRoom();
return [...room.remoteParticipants.values(), room.localParticipant];
}
@@ -207,7 +187,7 @@ function getTrackPublicationBySource(
}
function getRemoteParticipant(participantId: number) {
- return [...getRoom().remoteParticipants.values()].find(
+ return [...room.remoteParticipants.values()].find(
(participant) => getParticipantId(participant.identity) === participantId,
);
}
@@ -235,7 +215,7 @@ function syncRemoteParticipantTrackSubscriptions(participantId: number) {
}
function syncAllRemoteTrackSubscriptions() {
- for (const participant of getRoom().remoteParticipants.values()) {
+ for (const participant of room.remoteParticipants.values()) {
const participantId = getParticipantId(participant.identity);
if (participantId != null) {
@@ -276,7 +256,7 @@ function hasParticipant(participantId: number) {
function getLocalScreenShareTrack(): MediaStreamTrack | null {
const track = getTrackPublicationBySource(
- getRoom().localParticipant,
+ room.localParticipant,
Track.Source.ScreenShare,
)?.track;
@@ -295,15 +275,13 @@ async function updateLocalParticipantAttributes(
screenSharePreviewLength: attributes.screenSharePreview?.length ?? 0,
});
- await getRoom()
- .localParticipant.setAttributes(attributes)
- .catch((error) => {
- log(1, "call", "red", "Failed to update local participant attributes", {
- attributes: Object.keys(attributes),
- error,
- });
- throw error;
+ await room.localParticipant.setAttributes(attributes).catch((error) => {
+ log(1, "call", "red", "Failed to update local participant attributes", {
+ attributes: Object.keys(attributes),
+ error,
});
+ throw error;
+ });
log(2, "call", "purple", "Updated local participant attributes", {
attributeKeys: Object.keys(attributes),
@@ -509,7 +487,7 @@ function requireRuntime(runtime: Runtime | null): Runtime {
}
export function getRoomMetadata() {
- const roomMetadata = getRoom().metadata;
+ const roomMetadata = room.metadata;
try {
const data = JSON.parse(roomMetadata || '{"admins": []}');
return data as { admins: number[] };
@@ -520,8 +498,7 @@ export function getRoomMetadata() {
// Sync local participant flags and screen-share derived state for the active call UI.
export function syncParticipantState() {
- const { screenShareSession } = useCall.getState();
- const room = getRoom();
+ const { room, screenShareSession } = useCall.getState();
useCall.setState({
micEnabled: room.localParticipant.isMicrophoneEnabled,
@@ -744,7 +721,7 @@ let screenShareController: ReturnType<
function getScreenShareController() {
if (!screenShareController) {
screenShareController = createScreenShareController({
- room: getRoom(),
+ room,
getState: () => ({
screenShareSession: useCall.getState().screenShareSession,
}),
@@ -756,7 +733,7 @@ function getScreenShareController() {
);
},
getLocalParticipantId: () =>
- getParticipantId(getRoom().localParticipant.identity),
+ getParticipantId(room.localParticipant.identity),
startWatching: startWatchingStream,
stopWatching: stopWatchingStream,
syncParticipantState,
@@ -781,7 +758,7 @@ export async function connect(callId: string) {
callSecret: useCall.getState().callSecret,
});
- await getRoom()
+ await room
.connect("wss://call.tensamin.net", token, {
autoSubscribe: false,
})
@@ -797,13 +774,11 @@ export async function connect(callId: string) {
syncAllRemoteTrackSubscriptions();
- await getRoom()
- .localParticipant.setMicrophoneEnabled(true)
- .catch((error) => {
- log(1, "call", "red", "Failed to enable microphone", error);
- toast("error", "Failed to enable microphone.");
- throw error;
- });
+ await room.localParticipant.setMicrophoneEnabled(true).catch((error) => {
+ log(1, "call", "red", "Failed to enable microphone", error);
+ toast("error", "Failed to enable microphone.");
+ throw error;
+ });
syncParticipantState();
}
@@ -844,12 +819,12 @@ export async function disconnect() {
micGated: false,
});
- getRoom().remoteParticipants.forEach((participant) => {
+ room.remoteParticipants.forEach((participant) => {
participant.setVolume(1);
});
try {
- await getRoom().disconnect();
+ await room.disconnect();
} catch (error) {
log(1, "call", "red", "Failed to disconnect from room", error);
} finally {
@@ -892,8 +867,8 @@ export async function joinCall(
callSecret,
);
- await getKeyProvider().setKey(decryptedSecret);
- await getRoom().setE2EEEnabled(true);
+ await keyProvider.setKey(decryptedSecret);
+ await room.setE2EEEnabled(true);
useCall.setState({ callSecret: decryptedSecret });
} catch (err) {
log(1, "call", "red", "Failed getting call secret", err);
@@ -903,8 +878,8 @@ export async function joinCall(
} else {
const random = crypto.randomUUID();
- await getKeyProvider().setKey(random);
- await getRoom().setE2EEEnabled(true);
+ await keyProvider.setKey(random);
+ await room.setE2EEEnabled(true);
useCall.setState({ callSecret: random });
}
@@ -923,11 +898,11 @@ export async function joinCall(
export async function toggleDeaf() {
const nextDeaf = !useCall.getState().deaf;
- getRoom().remoteParticipants.forEach((participant) => {
+ room.remoteParticipants.forEach((participant) => {
participant.setVolume(nextDeaf ? 0 : 1);
});
- if (nextDeaf && getRoom().localParticipant.isMicrophoneEnabled) {
+ if (nextDeaf && room.localParticipant.isMicrophoneEnabled) {
await toggleMute();
}
@@ -947,7 +922,7 @@ export async function toggleMute() {
await toggleDeaf();
}
- await getRoom().localParticipant.setMicrophoneEnabled(!micEnabled);
+ await room.localParticipant.setMicrophoneEnabled(!micEnabled);
syncParticipantState();
}
@@ -1011,7 +986,7 @@ export function resetCallState() {
async function ensureNoiseFilter(
noiseFilter: DeepFilterNoiseFilterProcessor,
): Promise {
- const microphoneTrack = getRoom().localParticipant.getTrackPublication(
+ const microphoneTrack = room.localParticipant.getTrackPublication(
Track.Source.Microphone,
)?.track;
@@ -1026,7 +1001,7 @@ async function ensureNoiseFilter(
log(1, "call", "red", "Failed to enable noise filter", err);
});
- const participantId = getParticipantId(getRoom().localParticipant.identity);
+ const participantId = getParticipantId(room.localParticipant.identity);
if (participantId != null) {
const processedTrack = microphoneTrack.mediaStreamTrack;
getSpeakingDetector().addTrack(
@@ -1046,8 +1021,8 @@ export const useCall = create(() => ({
livekitToken: null,
currentCallData: null,
deaf: false,
- micEnabled: false,
- screenShareEnabled: false,
+ micEnabled: room.localParticipant.isMicrophoneEnabled,
+ screenShareEnabled: room.localParticipant.isScreenShareEnabled,
screenShareSession: null,
focusedParticipantId: null,
focusedParticipantType: null,
@@ -1055,11 +1030,15 @@ export const useCall = create(() => ({
watchedStreamParticipantIds: [],
pendingWatchedParticipantIds: [],
activeScreenShareParticipantIds: [],
- isEncrypted: false,
+ isEncrypted:
+ room.localParticipant.isE2EEEnabled && room.localParticipant.isEncrypted,
callIsFullscreen: false,
callIsPopout: false,
layoutVersion: 0,
screenRef: null,
+ room,
+ keyProvider,
+ e2eeWorker,
runtime: null,
speakingParticipantIds: new Set(),
micGated: false,
@@ -1405,7 +1384,6 @@ export function useInitializeCall() {
syncParticipantState();
};
- const room = getRoom();
room.on(RoomEvent.Connected, onConnected);
room.on(RoomEvent.Reconnected, onConnected);
room.on(RoomEvent.Disconnected, onDisconnected);
@@ -1446,7 +1424,7 @@ export function useInitializeCall() {
clearRemoteAudio();
listenersRegistered.current = false;
room.disconnect();
- if (_e2eeWorker) _e2eeWorker.terminate();
+ e2eeWorker.terminate();
};
}, [noiseFilter, load]);
diff --git a/packages/call/src/views/main/focused.tsx b/packages/call/src/views/main/focused.tsx
index f8239c5..78d1740 100644
--- a/packages/call/src/views/main/focused.tsx
+++ b/packages/call/src/views/main/focused.tsx
@@ -1,13 +1,13 @@
import { RoomEvent } from "livekit-client";
import { useEffect, useLayoutEffect, useMemo, useRef, useState } from "react";
-import { useCall, getRoom } from "../../store";
+import { useCall } from "../../store";
import Base from "../../components/modals/base";
const SECONDARY_ROW_HEIGHT_PX = 180;
const STACK_GAP_PX = 12;
export default function View() {
- const room = getRoom();
+ const room = useCall((state) => state.room);
const layoutVersion = useCall((state) => state.layoutVersion);
const usersInFocusedViewHidden = useCall(
diff --git a/packages/call/src/views/main/grid.tsx b/packages/call/src/views/main/grid.tsx
index 956842d..833d7b5 100644
--- a/packages/call/src/views/main/grid.tsx
+++ b/packages/call/src/views/main/grid.tsx
@@ -1,6 +1,6 @@
import { RoomEvent } from "livekit-client";
import { useEffect, useMemo, useRef, useState } from "react";
-import { useCall, getRoom } from "../../store";
+import { useCall } from "../../store";
import Base from "../../components/modals/base";
const TILE_ASPECT_RATIO = 16 / 9;
@@ -82,7 +82,7 @@ function calculateOptimalGridLayout(
}
export default function View() {
- const room = getRoom();
+ const room = useCall((state) => state.room);
const layoutVersion = useCall((state) => state.layoutVersion);
const activeScreenShareParticipantIds = useCall(
(state) => state.activeScreenShareParticipantIds,
diff --git a/packages/chat/src/components/input.tsx b/packages/chat/src/components/input.tsx
index cf74848..b2aef9e 100644
--- a/packages/chat/src/components/input.tsx
+++ b/packages/chat/src/components/input.tsx
@@ -97,7 +97,6 @@ export default function InputComponent({
>
- (
- <>
- {grouped ? (
-
- {new Date(message.send_time).toLocaleString([], {
- hour: "2-digit",
- minute: "2-digit",
- })}
-
- ) : (
-
-
-
- {user.display.slice(0, 2).toUpperCase()}
-
-
- )}
- {message.failed && message.message_state === "awaiting" && (
-
-
- Failed to send message
-
- } />
-
- )}
-
- {!grouped && (
-
-
{user.display}
-
- {new Date(message.send_time).toLocaleString([], {
- hour: "2-digit",
- minute: "2-digit",
- })}
-
-
- )}
-
-
Failed to send message
+
+ } />
+
+ )}
+
}
/>
diff --git a/packages/chat/src/screen.tsx b/packages/chat/src/screen.tsx
index 30344a5..a23760d 100644
--- a/packages/chat/src/screen.tsx
+++ b/packages/chat/src/screen.tsx
@@ -435,10 +435,10 @@ export default function Screen() {
@@ -461,11 +461,12 @@ export default function Screen() {
left: 0,
width: "100%",
transform: `translateY(${virtualRow.start + verticalOffset}px)`,
+ padding: "4px 0",
}}
>
-
- Conversation start
+
+ This is the start of your conversation with{" "}
@@ -480,13 +481,6 @@ export default function Screen() {
return null;
}
- const lastMessage = messages[messageIndex - 1];
- const isGrouped =
- lastMessage &&
- lastMessage.sent_by_self === message.sent_by_self &&
- Math.round(lastMessage.send_time / 10000) ===
- Math.round(message.send_time / 10000);
-
return (
-
+
);
})}
@@ -514,25 +509,17 @@ export default function Screen() {
className="pointer-events-none absolute left-0 top-0 -z-10 overflow-hidden opacity-0"
style={{ width: scrollWidth > 0 ? `${scrollWidth}px` : "100%" }}
>
- {messages.map((message, messageIndex) => {
- const lastMessage = messages[messageIndex - 1];
- const isGrouped =
- lastMessage &&
- lastMessage.sent_by_self === message.sent_by_self &&
- Math.round(lastMessage.send_time / 10000) ===
- Math.round(message.send_time / 10000);
-
- return (
-
{
- setMeasurementRef(message.send_time, element);
- }}
- >
-
-
- );
- })}
+ {messages.map((message) => (
+
{
+ setMeasurementRef(message.send_time, element);
+ }}
+ style={{ padding: "4px 0" }}
+ >
+
+
+ ))}
+
{block.text.split("\n").map((line, lineIndex) => (
{lineIndex > 0 ?
: null}
@@ -645,6 +645,7 @@ export const markdownStyles = `
.tm-md-h4 { font-size: 1.1rem; }
.tm-md-h5 { font-size: 1rem; }
.tm-md-h6 { font-size: 0.95rem; opacity: 0.9; }
+.tm-md-p { margin: 0.25rem 0; }
.tm-md-blockquote { margin: 0.45rem 0; padding-left: 0.75rem; opacity: 0.95; }
.tm-md-blockquote p { margin: 0.2rem 0; }
.tm-md-pre { margin: 0.45rem 0; padding: 0.65rem 0.75rem; border-radius: 0.5rem; background: hsl(var(--muted)); overflow-x: auto; }
diff --git a/packages/notifications/package.json b/packages/notifications/package.json
index a6b06be..af90c45 100644
--- a/packages/notifications/package.json
+++ b/packages/notifications/package.json
@@ -12,7 +12,6 @@
"build": "tsc -p tsconfig.json --noEmit"
},
"dependencies": {
- "@tanstack/react-router": "^1.169.1",
"@tauri-apps/api": "^2.11.0",
"@tensamin/crypto": "workspace:*",
"@tensamin/shared": "workspace:*",
diff --git a/packages/notifications/src/context.tsx b/packages/notifications/src/context.tsx
index 8da45f4..4e433a3 100644
--- a/packages/notifications/src/context.tsx
+++ b/packages/notifications/src/context.tsx
@@ -10,27 +10,25 @@ import { message as messageSchema } from "@tensamin/shared/data";
import { Avatar, AvatarFallback, AvatarImage } from "@tensamin/ui";
import { isTauri } from "@tauri-apps/api/core";
import { useSession } from "@tensamin/storage/session";
-import { useNavigate } from "@tanstack/react-router";
export const context = createContext(undefined);
-async function requestNotificationPermission() {
- if (!("Notification" in window)) return false;
-
- if (Notification.permission === "granted") return true;
-
- const permission = await Notification.requestPermission();
- return permission === "granted";
+function reduceDisplay(display: string) {
+ const words = display.split(" ");
+ if (words.length === 1) {
+ return display.slice(0, 2).toUpperCase();
+ } else {
+ return words[0].charAt(0).toUpperCase() + words[1].charAt(0).toUpperCase();
+ }
}
export default function Provider(props: { children: React.ReactNode }) {
- const { subscribePush, send } = useTTP();
+ const { subscribePush } = useTTP();
const { load } = useStorage();
const { get } = useUser();
const { decryptText, getSharedSecret } = useCrypto();
const { addLiveMessage, userId } = useChat();
const { moveUserIdToTop } = useSession();
- const navigate = useNavigate();
useEffect(() => {
return subscribePush(async (ttpMessage) => {
@@ -51,32 +49,7 @@ export default function Provider(props: { children: React.ReactNode }) {
message.content,
);
- // Update message state
- if (
- (await load("settings.read_confirmations")) &&
- userId === sender_id
- ) {
- void send(
- "message_state",
- {
- message_state: "read",
- },
- {
- id: ttpMessage.id,
- },
- );
- } else {
- void send(
- "message_state",
- {
- message_state: "received",
- },
- {
- id: ttpMessage.id,
- },
- );
- }
-
+ console.log(userId, sender_id, userId === sender_id);
if (userId === sender_id) {
addLiveMessage({
...message,
@@ -87,48 +60,25 @@ export default function Provider(props: { children: React.ReactNode }) {
return;
}
- // todo: add notification symbol to conversation cards (incl. message start)
+ // add notification symbol to conversation cards
moveUserIdToTop(sender_id);
if (isTauri()) {
console.log("weewoo");
} else {
- const hasPermissions = await requestNotificationPermission();
-
- if (hasPermissions) {
- const notification = new Notification(user.display, {
- body: decryptedContent,
- icon: user.avatar || user.display.slice(0, 2).toUpperCase(),
- badge: user.avatar || user.display.slice(0, 2).toUpperCase(),
- tag: `message-${user.user_id}`,
- silent: true,
- });
-
- notification.onclick = () => {
- window.focus();
- navigate({
- to: `/chat?id=${user.user_id}`,
- });
-
- notification.close();
- };
- } else {
- sonnerToast(user.display, {
- classNames: {
- content: "pl-4",
- },
- description: decryptedContent,
- icon: (
-
-
-
- {user.display.slice(0, 2).toUpperCase()}
-
-
- ),
- });
- }
+ sonnerToast(user.display, {
+ classNames: {
+ content: "pl-4",
+ },
+ description: decryptedContent,
+ icon: (
+
+
+ {reduceDisplay(user.display)}
+
+ ),
+ });
}
}
});
@@ -141,8 +91,6 @@ export default function Provider(props: { children: React.ReactNode }) {
addLiveMessage,
userId,
moveUserIdToTop,
- send,
- navigate,
]);
return (
diff --git a/packages/shared/src/data.ts b/packages/shared/src/data.ts
index 2210192..58851ce 100644
--- a/packages/shared/src/data.ts
+++ b/packages/shared/src/data.ts
@@ -167,17 +167,11 @@ export const ttp = {
response: z.object({}),
},
message_state: {
- request: z
- .object({
- chat_partner_id: z.number(),
- send_time: z.number(),
- message_state: message.shape.message_state,
- })
- .or(
- z.object({
- message_state: message.shape.message_state,
- }),
- ),
+ request: z.object({
+ chat_partner_id: z.number(),
+ send_time: z.number(),
+ message_state: message.shape.message_state,
+ }),
response: z.object({
chat_partner_id: z.number(),
message_state: message.shape.message_state,
diff --git a/packages/shared/src/settings.ts b/packages/shared/src/settings.ts
index aacc162..0099f64 100644
--- a/packages/shared/src/settings.ts
+++ b/packages/shared/src/settings.ts
@@ -28,21 +28,6 @@ const settings = {
type: "boolean",
default: false,
},
- read_confirmations: {
- display: "Enable Read Confirmations",
- type: "boolean",
- default: true,
- },
- receive_confirmations: {
- display: "Enable Receive Confirmations",
- type: "boolean",
- default: true,
- },
- show_start_of_last_message_in_sidebar: {
- display: "Show Start of Last Message in Sidebar",
- type: "boolean",
- default: true,
- },
},
},
application: {
@@ -50,7 +35,6 @@ const settings = {
},
} as const satisfies SettingsSchema;
-// Assemble storage defaults
export default settings;
type BooleanSettingNames = {
diff --git a/packages/ttp/src/context.tsx b/packages/ttp/src/context.tsx
index d33313d..0a2ea2c 100644
--- a/packages/ttp/src/context.tsx
+++ b/packages/ttp/src/context.tsx
@@ -191,7 +191,6 @@ export function Provider(props: {
typeof createTransportClient
> | null>(null);
const identificationStartedRef = useRef(false);
- const identificationCancelRef = useRef(false);
// Load ttp url
const [ttpUrl, setTtpUrl] = useState(null);
@@ -243,23 +242,6 @@ export function Provider(props: {
return client.subscribePush(handler);
}, []);
- // Check for error_no_iota
- useEffect(() => {
- if (!connected) return;
-
- return subscribePush((message) => {
- if (message.type !== "error_no_iota") return;
-
- identificationCancelRef.current = true;
- setIdentified(false);
- setIdentifying(false);
- setError("We couldn't reach your Iota");
- setErrorDescription(
- "You could try to restart your Iota, check for updates or check your network connection.",
- );
- });
- }, [connected, subscribePush]);
-
useEffect(() => {
if (!connected || !identified) {
return;
@@ -381,7 +363,6 @@ export function Provider(props: {
clearReconnectTimer();
scheduleReconnectReset();
identificationStartedRef.current = false;
- identificationCancelRef.current = false;
setConnected(true);
setIdentified(false);
setError("");
@@ -502,11 +483,6 @@ export function Provider(props: {
return;
}
- if (identificationCancelRef.current) {
- identificationStartedRef.current = false;
- return;
- }
-
if (identificationStartedRef.current) {
return;
}
@@ -575,12 +551,10 @@ export function Provider(props: {
const finalResponse = await send("challenge_response", {
challenge: decryptedChallenge,
}).catch((error) => {
- if (!identificationCancelRef.current) {
- setError("Identification Failed");
- setErrorDescription(
- "Unable to complete secure identification. Please verify your credentials and try again.",
- );
- }
+ setError("Identification Failed");
+ setErrorDescription(
+ "Unable to complete secure identification. Please verify your credentials and try again.",
+ );
throw error;
});
@@ -588,7 +562,7 @@ export function Provider(props: {
setFreshContacts(finalResponse.data.contacts);
setFreshCommunities(finalResponse.data.communities);
setFreshCalls(finalResponse.data.calls);
- if (cancelled || identificationCancelRef.current) {
+ if (cancelled) {
return;
}
@@ -600,10 +574,6 @@ export function Provider(props: {
return;
}
- if (identificationCancelRef.current) {
- return;
- }
-
if (isStopSendingError(identificationError)) {
setError("Connection closed");
setErrorDescription(
@@ -634,7 +604,7 @@ export function Provider(props: {
: "Unable to complete secure identification because the transport request failed.",
);
} finally {
- if (!cancelled && !identificationCancelRef.current) {
+ if (!cancelled) {
setIdentifying(false);
}
}