mirror of
https://github.com/bulwarkmail/webmail.git
synced 2026-11-02 16:15:39 +00:00
Merge branch 'main' of https://github.com/bulwarkmail/webmail
This commit is contained in:
@@ -83,10 +83,12 @@ const PERMISSION_LABELS: Record<string, { title: string; body: string }> = {
|
||||
'settings:write': { title: 'Modify your settings', body: 'Change non-secret user preferences.' },
|
||||
'security:read': { title: 'Read account security state', body: 'See whether TOTP / encryption are enabled (no secrets exposed).' },
|
||||
'auth:observe': { title: 'Observe login events', body: 'See when you log in, log out, or switch accounts.' },
|
||||
'auth:emit': { title: 'Emit login events', body: 'Emit auth events such as logout.' },
|
||||
'http:post': { title: 'Call same-origin APIs', body: 'Make authenticated requests to the webmail backend on your behalf.' },
|
||||
'http:fetch': { title: 'Talk to external services', body: 'Make uncredentialled requests to the third-party origins listed in the manifest.' },
|
||||
'admin:config': { title: 'Read/write admin config', body: 'Access this plugin\'s admin-supplied configuration values.' },
|
||||
'ui:download-file': { title: 'Download files', body: 'Download custom files generated by the plugin.' },
|
||||
'account:read': { title: 'Read your accounts', body: 'Access the list of accounts you have configured in the app.' },
|
||||
};
|
||||
|
||||
export function describePermission(perm: string): { title: string; body: string } {
|
||||
|
||||
@@ -6,6 +6,8 @@ import type { InstalledPlugin, Permission } from '../plugin-types';
|
||||
import { IMPLICIT_PERMISSIONS } from '../plugin-types';
|
||||
import { toast as appToast } from '@/stores/toast-store';
|
||||
import { useAuthStore } from '@/stores/auth-store';
|
||||
import { useAccountStore } from '@/stores/account-store';
|
||||
import { useIdentityStore } from '@/stores/identity-store';
|
||||
import { useEmailStore } from '@/stores/email-store';
|
||||
import { useFilterStore } from '@/stores/filter-store';
|
||||
import { useMessageListTabsStore } from '@/stores/message-list-tabs-store';
|
||||
@@ -14,7 +16,7 @@ import { apiFetch } from '../browser-navigation';
|
||||
import { awaitDialog, awaitPrompt, type PromptField } from './host-dialog';
|
||||
import { fileStorage } from '../plugin-storage';
|
||||
import { generateUUID } from '../utils';
|
||||
import { ContactCard } from '../jmap/types';
|
||||
import { ContactCard, Identity } from '../jmap/types';
|
||||
|
||||
/**
|
||||
* Methods only callable from the privileged (same-origin) tier. These expose
|
||||
@@ -62,6 +64,10 @@ const PERM_PER_METHOD: Record<string, Permission | null> = {
|
||||
'contact.update': 'contacts:write',
|
||||
'contact.create': 'contacts:write',
|
||||
'contact.search': 'contacts:read',
|
||||
// user
|
||||
'user.getAccounts': 'account:read',
|
||||
'user.getIdentities': 'identity:read',
|
||||
'user.logout': 'auth:emit',
|
||||
// admin
|
||||
'admin.getConfig': 'admin:config',
|
||||
'admin.getAllConfig': 'admin:config',
|
||||
@@ -157,6 +163,45 @@ function storageKeys(pluginId: string): string[] {
|
||||
return out;
|
||||
}
|
||||
|
||||
// ─── user ─────────────────────────────────────────────────────
|
||||
interface AccountResponse {
|
||||
id: string;
|
||||
label: string;
|
||||
serverUrl: string;
|
||||
username: string;
|
||||
displayName: string;
|
||||
email: string;
|
||||
avatarColor: string;
|
||||
isConnected: boolean;
|
||||
isDefault: boolean;
|
||||
}
|
||||
function doUserGetAccounts(): AccountResponse[] {
|
||||
const state = useAccountStore.getState();
|
||||
|
||||
// we remove sensitive fields from the account entries before returning to the plugin
|
||||
const accounts = state.accounts.map((account) => ({
|
||||
id: account.id,
|
||||
label: account.label,
|
||||
serverUrl: account.serverUrl,
|
||||
username: account.username,
|
||||
displayName: account.displayName,
|
||||
email: account.email,
|
||||
avatarColor: account.avatarColor,
|
||||
isConnected: account.isConnected,
|
||||
isDefault: account.isDefault,
|
||||
}));
|
||||
|
||||
return accounts;
|
||||
}
|
||||
|
||||
function doUserGetIdentities(): Identity[] {
|
||||
return useIdentityStore.getState().identities;
|
||||
}
|
||||
|
||||
async function doUserLogout(): Promise<void>{
|
||||
return useAuthStore.getState().logout();
|
||||
}
|
||||
|
||||
// ─── http.post (same-origin /api/*) ───────────────────────────
|
||||
|
||||
/**
|
||||
@@ -744,6 +789,10 @@ export async function dispatchApiCall(
|
||||
case 'contact.create': return doContactCreate(args[0] as ContactCard);
|
||||
case 'contact.search': return doContactSearch(args[0] as string);
|
||||
|
||||
case 'user.getAccounts': return doUserGetAccounts();
|
||||
case 'user.getIdentities': return doUserGetIdentities();
|
||||
case 'user.logout' : return doUserLogout();
|
||||
|
||||
case 'admin.getConfig': return adminGet(plugin.id, args[0] as string);
|
||||
case 'admin.getAllConfig': return adminGetAll(plugin.id);
|
||||
case 'admin.setConfig': await adminSet(plugin.id, args[0] as string, args[1]); return undefined;
|
||||
|
||||
@@ -175,6 +175,11 @@ function buildPluginApi(manifest: PluginManifest) {
|
||||
remove: (key: string) => callApi('storage.remove', [key]),
|
||||
keys: () => callApi('storage.keys', []),
|
||||
},
|
||||
user: {
|
||||
getAccounts: () => callApi('user.getAccounts', []),
|
||||
getIdentities: () => callApi('user.getIdentities', []),
|
||||
logout: () => callApi('user.logout', []),
|
||||
},
|
||||
http: {
|
||||
post: (path: string, body: Record<string, unknown>) => callApi('http.post', [path, body]),
|
||||
fetch: (url: string, init?: unknown) => callApi('http.fetch', [url, init]),
|
||||
|
||||
@@ -1035,6 +1035,8 @@ export const ALL_PERMISSIONS = [
|
||||
'settings:read', 'settings:write',
|
||||
'security:read',
|
||||
'auth:observe',
|
||||
'auth:emit',
|
||||
'account:read',
|
||||
'http:post', 'http:fetch',
|
||||
'ui:observe', 'ui:toolbar', 'ui:app-top-banner', 'ui:email-banner', 'ui:email-footer',
|
||||
'ui:email-details',
|
||||
|
||||
@@ -41,7 +41,7 @@ describe('auth-store logout redirects', () => {
|
||||
vi.useRealTimers();
|
||||
});
|
||||
|
||||
it('redirects full logout to the locale login page', () => {
|
||||
it('redirects full logout to the locale login page', async () => {
|
||||
const fetchMock = vi.fn().mockResolvedValue({ ok: true, json: async () => ({}) });
|
||||
vi.stubGlobal('fetch', fetchMock);
|
||||
const replaceSpy = vi.spyOn(browserNavigation, 'replaceWindowLocation').mockImplementation(() => {});
|
||||
@@ -49,7 +49,7 @@ describe('auth-store logout redirects', () => {
|
||||
window.history.pushState({}, '', '/fr/calendar');
|
||||
useAuthStore.setState({ isAuthenticated: true, authMode: 'basic' });
|
||||
|
||||
useAuthStore.getState().logout();
|
||||
await useAuthStore.getState().logout();
|
||||
|
||||
expect(replaceSpy).toHaveBeenCalledWith('/fr/login');
|
||||
expect(fetchMock).toHaveBeenCalledWith('/api/auth/session?slot=0', { method: 'DELETE', keepalive: true });
|
||||
@@ -169,7 +169,7 @@ describe('auth-store logout redirects', () => {
|
||||
|
||||
// Refresh goes in flight, then the user signs out before it settles.
|
||||
const pending = useAuthStore.getState().refreshAccessToken();
|
||||
useAuthStore.getState().logout();
|
||||
await useAuthStore.getState().logout();
|
||||
resolveInFlight!({ ok: false, status: 503, json: async () => ({}) });
|
||||
await pending;
|
||||
|
||||
|
||||
+30
-4
@@ -17,6 +17,7 @@ import { replaceWindowLocation, getPathPrefix, getLocaleFromPath, apiFetch } fro
|
||||
import { notifyParent } from '@/lib/iframe-bridge';
|
||||
import { snapshotAccount, restoreAccount, clearAllStores, evictAccount, evictAll } from '@/lib/account-state-manager';
|
||||
import type { Identity } from '@/lib/jmap/types';
|
||||
import { authHooks } from '@/lib/plugin-hooks';
|
||||
|
||||
interface AuthState {
|
||||
isAuthenticated: boolean;
|
||||
@@ -42,8 +43,8 @@ interface AuthState {
|
||||
loginWithServerSso: (code: string, state: string) => Promise<boolean>;
|
||||
loginDemo: () => Promise<boolean>;
|
||||
refreshAccessToken: () => Promise<string | null>;
|
||||
logout: () => void;
|
||||
logoutAll: () => void;
|
||||
logout: () => Promise<void>;
|
||||
logoutAll: () => Promise<void>;
|
||||
removeAccount: (accountId: string) => void;
|
||||
switchAccount: (accountId: string) => Promise<void>;
|
||||
checkAuth: () => Promise<void>;
|
||||
@@ -1196,7 +1197,7 @@ export const useAuthStore = create<AuthState>()(
|
||||
return promise;
|
||||
},
|
||||
|
||||
logout: () => {
|
||||
logout: async () => {
|
||||
const state = get();
|
||||
const wasDemoMode = state.isDemoMode;
|
||||
const wasOAuth = state.authMode === 'oauth';
|
||||
@@ -1206,6 +1207,15 @@ export const useAuthStore = create<AuthState>()(
|
||||
const slot = account?.cookieSlot ?? 0;
|
||||
|
||||
// Stop refresh timers immediately
|
||||
|
||||
const ok = await authHooks.onBeforeLogout.intercept({
|
||||
accountId: accountId ?? 'all',
|
||||
});
|
||||
|
||||
if(!ok){
|
||||
return;
|
||||
}
|
||||
|
||||
clearRefreshTimer(accountId ?? undefined);
|
||||
|
||||
// Disconnect and null out the client BEFORE clearing stores so the
|
||||
@@ -1223,6 +1233,10 @@ export const useAuthStore = create<AuthState>()(
|
||||
|
||||
useSettingsStore.getState().disableSync();
|
||||
|
||||
await authHooks.onAfterLogout.emit({
|
||||
accountId: accountId ?? 'all',
|
||||
});
|
||||
|
||||
// Check if there are remaining accounts to switch to
|
||||
const remainingAccounts = accountStore.accounts;
|
||||
|
||||
@@ -1320,7 +1334,15 @@ export const useAuthStore = create<AuthState>()(
|
||||
}
|
||||
},
|
||||
|
||||
logoutAll: () => {
|
||||
logoutAll: async () => {
|
||||
const ok = await authHooks.onBeforeLogout.intercept({
|
||||
accountId: 'all'
|
||||
});
|
||||
|
||||
if(!ok){
|
||||
return;
|
||||
}
|
||||
|
||||
// Disconnect all clients
|
||||
for (const c of clients.values()) {
|
||||
c.disconnect();
|
||||
@@ -1338,6 +1360,10 @@ export const useAuthStore = create<AuthState>()(
|
||||
accountStore.removeAccount(account.id);
|
||||
}
|
||||
|
||||
await authHooks.onAfterLogout.emit({
|
||||
accountId: 'all'
|
||||
});
|
||||
|
||||
// Background cookie/token cleanup
|
||||
apiFetch('/api/auth/session?all=true', { method: 'DELETE', keepalive: true }).catch(() => {});
|
||||
apiFetch('/api/auth/token?all=true', { method: 'DELETE', keepalive: true }).catch(() => {});
|
||||
|
||||
Reference in New Issue
Block a user