mirror of
https://github.com/diced/zipline.git
synced 2025-12-25 12:25:08 -08:00
Compare commits
22 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
48cfa41405 | ||
|
|
9c26d64420 | ||
|
|
f3638f3d6d | ||
|
|
8e59158769 | ||
|
|
317c7365f8 | ||
|
|
974e9f7fa2 | ||
|
|
4330bdcc4c | ||
|
|
7f9de82804 | ||
|
|
70050afb5f | ||
|
|
1f00dd51f9 | ||
|
|
5e37d89b18 | ||
|
|
08d3bfb36d | ||
|
|
56f07cb5ec | ||
|
|
658cc61df0 | ||
|
|
d3be545548 | ||
|
|
c8625c1e13 | ||
|
|
511f17e1a5 | ||
|
|
5b88b59724 | ||
|
|
1816e13879 | ||
|
|
1a837c02d2 | ||
|
|
f3634eff48 | ||
|
|
23ef407dd3 |
@@ -121,7 +121,7 @@ This section requires [Flameshot](https://www.flameshot.org/), [jq](https://sted
|
||||
|
||||
If using wayland you will need to have [wl-clipboard](https://github.com/bugaevc/wl-clipboard) installed, for the `wl-copy` command.
|
||||
|
||||
If you are not using GNOME/KDE/Qtile/Sway, and are using something like a wlroots-based compositor (ex. [Hyprland](https://github.com/hyprwm/Hyprland/), [River](https://github.com/riverwm/river), etc), you will need to set the `XDG_CURRENT_DESKTOP` environment variable to `sway`, which will just override it for this script. Adding `export XDG_CURRENT_DESKTOP=sway` to the start of the script will work.
|
||||
If you are not using GNOME/KDE/Qtile/Sway, and are using something like a wlroots-based or wlroots-compatible compositor (ex. [Hyprland](https://github.com/hyprwm/Hyprland/), [River](https://github.com/riverwm/river), etc), you will need to set the `XDG_CURRENT_DESKTOP` environment variable to `sway`, which will just override it for this script. Adding `export XDG_CURRENT_DESKTOP=sway` to the start of the script will work.
|
||||
|
||||
After this, replace the `xsel -ib` with `wl-copy` in the script.
|
||||
|
||||
@@ -141,7 +141,7 @@ To upload files using flameshot we will use a script. Replace $TOKEN and $HOST w
|
||||
DATE=$(date '+%h_%Y_%d_%I_%m_%S.png');
|
||||
flameshot gui -r > ~/Pictures/$DATE;
|
||||
|
||||
curl -H "Content-Type: multipart/form-data" -H "authorization: $TOKEN" -F file=@$1 $HOST/api/upload | jq -r 'files[0].url' | xsel -ib
|
||||
curl -H "Content-Type: multipart/form-data" -H "authorization: $TOKEN" -F file=@$1 $HOST/api/upload | jq -r '.files[0]' | xsel -ib
|
||||
```
|
||||
|
||||
# Contributing
|
||||
@@ -169,4 +169,4 @@ Create a pull request on GitHub. If your PR does not pass the action checks, the
|
||||
|
||||
# Documentation
|
||||
|
||||
Documentation source code is located in [diced/zipline-docs](https://github.com/diced/zipline-docs), and can be accessed [here](https://zipl.vercel.app).
|
||||
Documentation source code is located in [diced/zipline-docs](https://github.com/diced/zipline-docs), and can be accessed [here](https://zipl.vercel.app).
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "zipline",
|
||||
"version": "3.7.8",
|
||||
"version": "3.7.10",
|
||||
"license": "MIT",
|
||||
"scripts": {
|
||||
"dev": "npm-run-all build:server dev:run",
|
||||
|
||||
14
prisma/migrations/20240912180249_exports/migration.sql
Normal file
14
prisma/migrations/20240912180249_exports/migration.sql
Normal file
@@ -0,0 +1,14 @@
|
||||
-- CreateTable
|
||||
CREATE TABLE "Export" (
|
||||
"id" TEXT NOT NULL,
|
||||
"createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
||||
"updatedAt" TIMESTAMP(3) NOT NULL,
|
||||
"complete" BOOLEAN NOT NULL DEFAULT false,
|
||||
"path" TEXT NOT NULL,
|
||||
"userId" INTEGER NOT NULL,
|
||||
|
||||
CONSTRAINT "Export_pkey" PRIMARY KEY ("id")
|
||||
);
|
||||
|
||||
-- AddForeignKey
|
||||
ALTER TABLE "Export" ADD CONSTRAINT "Export_userId_fkey" FOREIGN KEY ("userId") REFERENCES "User"("id") ON DELETE CASCADE ON UPDATE CASCADE;
|
||||
@@ -27,6 +27,20 @@ model User {
|
||||
Invite Invite[]
|
||||
Folder Folder[]
|
||||
IncompleteFile IncompleteFile[]
|
||||
Exports Export[]
|
||||
}
|
||||
|
||||
model Export {
|
||||
id String @id @default(cuid())
|
||||
createdAt DateTime @default(now())
|
||||
updatedAt DateTime @updatedAt
|
||||
|
||||
complete Boolean @default(false)
|
||||
|
||||
path String
|
||||
|
||||
user User @relation(fields: [userId], references: [id], onDelete: Cascade)
|
||||
userId Int
|
||||
}
|
||||
|
||||
model Folder {
|
||||
|
||||
@@ -356,7 +356,7 @@ export default function Layout({ children, props }) {
|
||||
)
|
||||
}
|
||||
variant='subtle'
|
||||
color='gray'
|
||||
color={theme.colorScheme === 'dark' ? 'dark' : 'gray'}
|
||||
compact
|
||||
size='xl'
|
||||
p='sm'
|
||||
|
||||
@@ -4,6 +4,10 @@ import { useEffect } from 'react';
|
||||
import ayu_dark from 'lib/themes/ayu_dark';
|
||||
import ayu_light from 'lib/themes/ayu_light';
|
||||
import ayu_mirage from 'lib/themes/ayu_mirage';
|
||||
import catppuccin_mocha from 'lib/themes/catppuccin_mocha';
|
||||
import catppuccin_macchiato from 'lib/themes/catppuccin_macchiato';
|
||||
import catppuccin_frappe from 'lib/themes/catppuccin_frappe';
|
||||
import catppuccin_latte from 'lib/themes/catppuccin_latte';
|
||||
import dark from 'lib/themes/dark';
|
||||
import dark_blue from 'lib/themes/dark_blue';
|
||||
import dracula from 'lib/themes/dracula';
|
||||
@@ -32,6 +36,10 @@ export const themes = {
|
||||
ayu_dark,
|
||||
ayu_mirage,
|
||||
ayu_light,
|
||||
catppuccin_mocha,
|
||||
catppuccin_macchiato,
|
||||
catppuccin_frappe,
|
||||
catppuccin_latte,
|
||||
nord,
|
||||
dracula,
|
||||
matcha_dark_azul,
|
||||
@@ -46,6 +54,10 @@ export const friendlyThemeName = {
|
||||
ayu_dark: 'Ayu Dark',
|
||||
ayu_mirage: 'Ayu Mirage',
|
||||
ayu_light: 'Ayu Light',
|
||||
catppuccin_mocha: 'Catppuccin Mocha',
|
||||
catppuccin_macchiato: 'Catppuccin Macchiato',
|
||||
catppuccin_frappe: 'Catppuccin Frappé',
|
||||
catppuccin_latte: 'Catppuccin Latte',
|
||||
nord: 'Nord',
|
||||
dracula: 'Dracula',
|
||||
matcha_dark_azul: 'Matcha Dark Azul',
|
||||
|
||||
@@ -41,6 +41,7 @@ import {
|
||||
IconUserExclamation,
|
||||
IconUserMinus,
|
||||
IconUserX,
|
||||
IconX,
|
||||
} from '@tabler/icons-react';
|
||||
import AnchorNext from 'components/AnchorNext';
|
||||
import { FlameshotIcon, ShareXIcon } from 'components/icons';
|
||||
@@ -264,7 +265,7 @@ export default function Manage({ oauth_registration, oauth_providers: raw_oauth_
|
||||
setExports(
|
||||
res.exports
|
||||
?.map((s) => ({
|
||||
date: new Date(Number(s.name.split('_')[3].slice(0, -4))),
|
||||
date: new Date(s.createdAt),
|
||||
size: s.size,
|
||||
full: s.name,
|
||||
}))
|
||||
@@ -272,6 +273,26 @@ export default function Manage({ oauth_registration, oauth_providers: raw_oauth_
|
||||
);
|
||||
};
|
||||
|
||||
const deleteExport = async (name) => {
|
||||
const res = await useFetch('/api/user/export?name=' + name, 'DELETE');
|
||||
if (res.error) {
|
||||
showNotification({
|
||||
title: 'Error deleting export',
|
||||
message: res.error,
|
||||
color: 'red',
|
||||
icon: <IconX size='1rem' />,
|
||||
});
|
||||
} else {
|
||||
showNotification({
|
||||
message: 'Deleted export',
|
||||
color: 'green',
|
||||
icon: <IconFileZip size='1rem' />,
|
||||
});
|
||||
|
||||
await getExports();
|
||||
}
|
||||
};
|
||||
|
||||
const handleDelete = async () => {
|
||||
const res = await useFetch('/api/user/files', 'DELETE', {
|
||||
all: true,
|
||||
@@ -580,6 +601,7 @@ export default function Manage({ oauth_registration, oauth_providers: raw_oauth_
|
||||
{ id: 'name', name: 'Name' },
|
||||
{ id: 'date', name: 'Date' },
|
||||
{ id: 'size', name: 'Size' },
|
||||
{ id: 'actions', name: '' },
|
||||
]}
|
||||
rows={
|
||||
exports
|
||||
@@ -591,6 +613,11 @@ export default function Manage({ oauth_registration, oauth_providers: raw_oauth_
|
||||
),
|
||||
date: x.date.toLocaleString(),
|
||||
size: bytesToHuman(x.size),
|
||||
actions: (
|
||||
<ActionIcon onClick={() => deleteExport(x.full)}>
|
||||
<IconTrash size='1rem' />
|
||||
</ActionIcon>
|
||||
),
|
||||
}))
|
||||
: []
|
||||
}
|
||||
|
||||
@@ -364,7 +364,8 @@ export default function File({ chunks: chunks_config }) {
|
||||
<Button
|
||||
leftIcon={<IconFileUpload size='1rem' />}
|
||||
onClick={handleUpload}
|
||||
disabled={files.length === 0 ? true : false}
|
||||
loading={loading}
|
||||
disabled={files.length === 0 || loading}
|
||||
>
|
||||
Upload
|
||||
</Button>
|
||||
|
||||
@@ -22,6 +22,7 @@ export default function Text() {
|
||||
|
||||
const [value, setValue] = useState('');
|
||||
const [lang, setLang] = useState('txt');
|
||||
const [loading, setLoading] = useState(false);
|
||||
|
||||
const [options, setOpened, OptionsModal] = useUploadOptions();
|
||||
|
||||
@@ -29,6 +30,9 @@ export default function Text() {
|
||||
const shouldRenderTex = lang === 'tex';
|
||||
|
||||
const handleUpload = async () => {
|
||||
if (value.trim().length === 0) return;
|
||||
|
||||
setLoading(true);
|
||||
const file = new File([value], 'text.' + lang);
|
||||
|
||||
const expiresAt = options.expires === 'never' ? null : expireReadToDate(options.expires);
|
||||
@@ -53,6 +57,16 @@ export default function Text() {
|
||||
message: '',
|
||||
});
|
||||
showFilesModal(clipboard, modals, json.files);
|
||||
setLoading(false);
|
||||
setValue('');
|
||||
} else {
|
||||
updateNotification({
|
||||
id: 'upload-text',
|
||||
title: 'Upload Failed',
|
||||
message: json.error,
|
||||
color: 'red',
|
||||
});
|
||||
setLoading(false);
|
||||
}
|
||||
});
|
||||
|
||||
@@ -136,7 +150,8 @@ export default function Text() {
|
||||
<Button
|
||||
leftIcon={<IconFileUpload size='1rem' />}
|
||||
onClick={handleUpload}
|
||||
disabled={value.trim().length === 0 ? true : false}
|
||||
disabled={value.trim().length === 0 || loading}
|
||||
loading={loading}
|
||||
>
|
||||
Upload
|
||||
</Button>
|
||||
|
||||
39
src/lib/themes/catppuccin_frappe.ts
Normal file
39
src/lib/themes/catppuccin_frappe.ts
Normal file
@@ -0,0 +1,39 @@
|
||||
// https://github.com/SeaswimmerTheFsh
|
||||
// https://catppuccin.com/palette
|
||||
|
||||
import createTheme from '.';
|
||||
|
||||
export default createTheme({
|
||||
colorScheme: 'dark',
|
||||
primaryColor: 'blue',
|
||||
other: {
|
||||
AppShell_backgroundColor: '#232634',
|
||||
hover: '#414559',
|
||||
},
|
||||
colors: {
|
||||
dark: [
|
||||
'#c6d0f5',
|
||||
'#949cbb',
|
||||
'#838ba7',
|
||||
'#737994',
|
||||
'#626880',
|
||||
'#51576d',
|
||||
'#414559',
|
||||
'#303446',
|
||||
'#292c3c',
|
||||
'#232634',
|
||||
],
|
||||
blue: [
|
||||
'#FFFFFF',
|
||||
'#b8caf4',
|
||||
'#a2baf1',
|
||||
'#7599ea',
|
||||
'#5f89e7',
|
||||
'#8c99ee',
|
||||
'#8ca1ee',
|
||||
'#8cb2ee',
|
||||
'#8cbaee',
|
||||
'#8caaee',
|
||||
],
|
||||
},
|
||||
});
|
||||
39
src/lib/themes/catppuccin_latte.ts
Normal file
39
src/lib/themes/catppuccin_latte.ts
Normal file
@@ -0,0 +1,39 @@
|
||||
// https://github.com/SeaswimmerTheFsh
|
||||
// https://catppuccin.com/palette
|
||||
|
||||
import createTheme from '.';
|
||||
|
||||
export default createTheme({
|
||||
colorScheme: 'dark',
|
||||
primaryColor: 'blue',
|
||||
other: {
|
||||
AppShell_backgroundColor: '#dce0e8',
|
||||
hover: '#ccd0da',
|
||||
},
|
||||
colors: {
|
||||
dark: [
|
||||
'#4c4f69',
|
||||
'#8c8fa1',
|
||||
'#8c8fa1',
|
||||
'#9ca0b0',
|
||||
'#acb0be',
|
||||
'#bcc0cc',
|
||||
'#ccd0da',
|
||||
'#eff1f5',
|
||||
'#e6e9ef',
|
||||
'#dce0e8',
|
||||
],
|
||||
blue: [
|
||||
'#FFFFFF',
|
||||
'#3676f6',
|
||||
'#0a57ee',
|
||||
'#094ed6',
|
||||
'#1d42f5',
|
||||
'#1d54f5',
|
||||
'#1d65f5',
|
||||
'#1d77f5',
|
||||
'#1d89f5',
|
||||
'#1e66f5',
|
||||
],
|
||||
},
|
||||
});
|
||||
39
src/lib/themes/catppuccin_macchiato.ts
Normal file
39
src/lib/themes/catppuccin_macchiato.ts
Normal file
@@ -0,0 +1,39 @@
|
||||
// https://github.com/SeaswimmerTheFsh
|
||||
// https://catppuccin.com/palette
|
||||
|
||||
import createTheme from '.';
|
||||
|
||||
export default createTheme({
|
||||
colorScheme: 'dark',
|
||||
primaryColor: 'blue',
|
||||
other: {
|
||||
AppShell_backgroundColor: '#181926',
|
||||
hover: '#363a4f',
|
||||
},
|
||||
colors: {
|
||||
dark: [
|
||||
'#cad3f5',
|
||||
'#8087a2',
|
||||
'#8087a2',
|
||||
'#6e738d',
|
||||
'#5b6078',
|
||||
'#494d64',
|
||||
'#363a4f',
|
||||
'#24273a',
|
||||
'#1e2030',
|
||||
'#181926',
|
||||
],
|
||||
blue: [
|
||||
'#FFFFFF',
|
||||
'#a1bdf6',
|
||||
'#729cf1',
|
||||
'#5b8cef',
|
||||
'#899bf4',
|
||||
'#89a4f4',
|
||||
'#89acf4',
|
||||
'#89b5f4',
|
||||
'#89bef4',
|
||||
'#8aadf4',
|
||||
],
|
||||
},
|
||||
});
|
||||
39
src/lib/themes/catppuccin_mocha.ts
Normal file
39
src/lib/themes/catppuccin_mocha.ts
Normal file
@@ -0,0 +1,39 @@
|
||||
// https://github.com/SeaswimmerTheFsh
|
||||
// https://catppuccin.com/palette
|
||||
|
||||
import createTheme from '.';
|
||||
|
||||
export default createTheme({
|
||||
colorScheme: 'dark',
|
||||
primaryColor: 'blue',
|
||||
other: {
|
||||
AppShell_backgroundColor: '#11111b',
|
||||
hover: '#313244',
|
||||
},
|
||||
colors: {
|
||||
dark: [
|
||||
'#cdd6f4',
|
||||
'#9399b2',
|
||||
'#7f849c',
|
||||
'#6c7086',
|
||||
'#585b70',
|
||||
'#45475a',
|
||||
'#313244',
|
||||
'#1e1e2e',
|
||||
'#181825',
|
||||
'#11111b',
|
||||
],
|
||||
blue: [
|
||||
'#FFFFFF',
|
||||
'#b9d3fc',
|
||||
'#a1c3fb',
|
||||
'#70a4f8',
|
||||
'#5894f7',
|
||||
'#89a1fa',
|
||||
'#89aafa',
|
||||
'#89b4fa',
|
||||
'#89bdfa',
|
||||
'#89c6fa',
|
||||
],
|
||||
},
|
||||
});
|
||||
@@ -24,16 +24,16 @@ export function humanToBytes(value: string): number {
|
||||
return bytes;
|
||||
}
|
||||
|
||||
export function bytesToHuman(value: number): string {
|
||||
if (isNaN(value)) return '0.0 B';
|
||||
export function bytesToHuman(value: number | bigint): string {
|
||||
if (typeof value !== 'bigint' && isNaN(value)) return '0.0 B';
|
||||
if (value === Infinity) return '0.0 B';
|
||||
const units = ['B', 'kB', 'MB', 'GB', 'TB', 'PB'];
|
||||
const units = ['B', 'kB', 'MB', 'GB', 'TB', 'PB']; // if people upload stuff bigger than a petabyte then idk
|
||||
let num = 0;
|
||||
|
||||
while (value > 1024) {
|
||||
value /= 1024;
|
||||
value = Number(value) / 1024;
|
||||
++num;
|
||||
}
|
||||
|
||||
return `${value.toFixed(1)} ${units[num]}`;
|
||||
return `${Number(value).toFixed(1)} ${units[num] || ''}`;
|
||||
}
|
||||
|
||||
@@ -128,6 +128,10 @@ function modifier(mod: string, value: unknown, tzlocale?: string): string {
|
||||
return value.getMinutes().toString();
|
||||
case 'second':
|
||||
return value.getSeconds().toString();
|
||||
case 'ampm':
|
||||
return value.getHours() < 12 ? 'am' : 'pm';
|
||||
case 'AMPM':
|
||||
return value.getHours() < 12 ? 'AM' : 'PM';
|
||||
default:
|
||||
return '{unknown_date_modifier}';
|
||||
}
|
||||
@@ -150,7 +154,7 @@ function modifier(mod: string, value: unknown, tzlocale?: string): string {
|
||||
default:
|
||||
return '{unknown_str_modifier}';
|
||||
}
|
||||
} else if (typeof value === 'number') {
|
||||
} else if (typeof value === 'number' || typeof value === 'bigint') {
|
||||
switch (mod) {
|
||||
case 'comma':
|
||||
return value.toLocaleString();
|
||||
|
||||
@@ -53,8 +53,7 @@ async function handler(req: NextApiReq, res: NextApiRes) {
|
||||
if (!invite || invite?.used) return res.badRequest('Bad invite');
|
||||
usedInvite = true;
|
||||
} else return res.badRequest('Bad Username/Password');
|
||||
} else if (config.features.invites && !config.features.user_registration && !user?.administrator)
|
||||
return res.badRequest('Bad invite');
|
||||
} else if (config.features.invites && !user?.administrator) return res.badRequest('Bad invite');
|
||||
|
||||
const hashed = await hashPassword(password);
|
||||
|
||||
|
||||
@@ -30,6 +30,45 @@ async function handler(req: NextApiReq, res: NextApiRes) {
|
||||
|
||||
if (!user) return res.forbidden('authorization incorrect');
|
||||
|
||||
if (user.ratelimit && !req.headers['content-range']) {
|
||||
const remaining = user.ratelimit.getTime() - Date.now();
|
||||
logger.debug(`${user.id} encountered ratelimit, ${remaining}ms remaining`);
|
||||
if (remaining <= 0) {
|
||||
await prisma.user.update({
|
||||
where: {
|
||||
id: user.id,
|
||||
},
|
||||
data: {
|
||||
ratelimit: null,
|
||||
},
|
||||
});
|
||||
} else {
|
||||
return res.ratelimited(remaining);
|
||||
}
|
||||
} else if (!user.ratelimit && !req.headers['content-range']) {
|
||||
if (user.administrator && zconfig.ratelimit.admin > 0) {
|
||||
await prisma.user.update({
|
||||
where: {
|
||||
id: user.id,
|
||||
},
|
||||
data: {
|
||||
ratelimit: new Date(Date.now() + zconfig.ratelimit.admin * 1000),
|
||||
},
|
||||
});
|
||||
} else if (!user.administrator && zconfig.ratelimit.user > 0) {
|
||||
if (user.administrator && zconfig.ratelimit.user > 0) {
|
||||
await prisma.user.update({
|
||||
where: {
|
||||
id: user.id,
|
||||
},
|
||||
data: {
|
||||
ratelimit: new Date(Date.now() + zconfig.ratelimit.user * 1000),
|
||||
},
|
||||
});
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
await new Promise((resolve, reject) => {
|
||||
uploader.array('file')(req as never, res as never, (result: unknown) => {
|
||||
if (result instanceof Error) reject(result.message);
|
||||
@@ -42,6 +81,7 @@ async function handler(req: NextApiReq, res: NextApiRes) {
|
||||
expiresAt?: Date;
|
||||
removed_gps?: boolean;
|
||||
assumed_mimetype?: string | boolean;
|
||||
folder?: number;
|
||||
} = {
|
||||
files: [],
|
||||
};
|
||||
@@ -82,6 +122,20 @@ async function handler(req: NextApiReq, res: NextApiRes) {
|
||||
if (isNaN(fileMaxViews)) return res.badRequest('invalid max views (invalid number)');
|
||||
if (fileMaxViews < 0) return res.badRequest('invalid max views (max views < 0)');
|
||||
|
||||
const folderToAdd = req.headers['x-zipline-folder'] ? Number(req.headers['x-zipline-folder']) : null;
|
||||
if (folderToAdd) {
|
||||
if (isNaN(folderToAdd)) return res.badRequest('invalid folder id (invalid number)');
|
||||
const folder = await prisma.folder.findFirst({
|
||||
where: {
|
||||
id: folderToAdd,
|
||||
userId: user.id,
|
||||
},
|
||||
});
|
||||
if (!folder) return res.badRequest('invalid folder id (no folder found)');
|
||||
|
||||
response.folder = folder.id;
|
||||
}
|
||||
|
||||
// handle partial uploads before ratelimits
|
||||
if (req.headers['content-range'] && zconfig.chunks.enabled) {
|
||||
if (format === 'name') {
|
||||
@@ -132,6 +186,9 @@ async function handler(req: NextApiReq, res: NextApiRes) {
|
||||
mimetype: req.headers.uploadtext ? 'text/plain' : mimetype,
|
||||
userId: user.id,
|
||||
originalName: req.headers['original-name'] ? filename ?? null : null,
|
||||
...(folderToAdd && {
|
||||
folderId: folderToAdd,
|
||||
}),
|
||||
},
|
||||
});
|
||||
|
||||
@@ -179,23 +236,6 @@ async function handler(req: NextApiReq, res: NextApiRes) {
|
||||
});
|
||||
}
|
||||
|
||||
if (user.ratelimit) {
|
||||
const remaining = user.ratelimit.getTime() - Date.now();
|
||||
logger.debug(`${user.id} encountered ratelimit, ${remaining}ms remaining`);
|
||||
if (remaining <= 0) {
|
||||
await prisma.user.update({
|
||||
where: {
|
||||
id: user.id,
|
||||
},
|
||||
data: {
|
||||
ratelimit: null,
|
||||
},
|
||||
});
|
||||
} else {
|
||||
return res.ratelimited(remaining);
|
||||
}
|
||||
}
|
||||
|
||||
if (!req.files) return res.badRequest('no files');
|
||||
if (req.files && req.files.length === 0) return res.badRequest('no files');
|
||||
|
||||
@@ -266,6 +306,9 @@ async function handler(req: NextApiReq, res: NextApiRes) {
|
||||
maxViews: fileMaxViews,
|
||||
originalName: req.headers['original-name'] ? decodedName ?? null : null,
|
||||
size: file.size,
|
||||
...(folderToAdd && {
|
||||
folderId: folderToAdd,
|
||||
}),
|
||||
},
|
||||
});
|
||||
|
||||
@@ -319,28 +362,6 @@ async function handler(req: NextApiReq, res: NextApiRes) {
|
||||
}
|
||||
}
|
||||
|
||||
if (user.administrator && zconfig.ratelimit.admin > 0) {
|
||||
await prisma.user.update({
|
||||
where: {
|
||||
id: user.id,
|
||||
},
|
||||
data: {
|
||||
ratelimit: new Date(Date.now() + zconfig.ratelimit.admin * 1000),
|
||||
},
|
||||
});
|
||||
} else if (!user.administrator && zconfig.ratelimit.user > 0) {
|
||||
if (user.administrator && zconfig.ratelimit.user > 0) {
|
||||
await prisma.user.update({
|
||||
where: {
|
||||
id: user.id,
|
||||
},
|
||||
data: {
|
||||
ratelimit: new Date(Date.now() + zconfig.ratelimit.user * 1000),
|
||||
},
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
if (req.headers['no-json']) {
|
||||
res.setHeader('Content-Type', 'text/plain');
|
||||
return res.end(response.files.join(','));
|
||||
|
||||
@@ -21,6 +21,9 @@ async function handler(req: NextApiReq, res: NextApiRes, user: UserExtended) {
|
||||
include: {
|
||||
thumbnail: true,
|
||||
},
|
||||
orderBy: {
|
||||
createdAt: 'desc',
|
||||
},
|
||||
},
|
||||
Folder: true,
|
||||
},
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
import { Zip, ZipPassThrough } from 'fflate';
|
||||
import { createReadStream, createWriteStream } from 'fs';
|
||||
import { readdir, stat } from 'fs/promises';
|
||||
import { rm, stat } from 'fs/promises';
|
||||
import datasource from 'lib/datasource';
|
||||
import Logger from 'lib/logger';
|
||||
import prisma from 'lib/prisma';
|
||||
@@ -23,6 +23,13 @@ async function handler(req: NextApiReq, res: NextApiRes, user: UserExtended) {
|
||||
const export_name = `zipline_export_${user.id}_${Date.now()}.zip`;
|
||||
const path = join(config.core.temp_directory, export_name);
|
||||
|
||||
const exportDb = await prisma.export.create({
|
||||
data: {
|
||||
path: export_name,
|
||||
userId: user.id,
|
||||
},
|
||||
});
|
||||
|
||||
logger.debug(`creating write stream at ${path}`);
|
||||
const write_stream = createWriteStream(path);
|
||||
|
||||
@@ -79,11 +86,27 @@ async function handler(req: NextApiReq, res: NextApiRes, user: UserExtended) {
|
||||
logger.info(
|
||||
`Export for ${user.username} (${user.id}) has completed and is available at ${export_name}`,
|
||||
);
|
||||
|
||||
await prisma.export.update({
|
||||
where: {
|
||||
id: exportDb.id,
|
||||
},
|
||||
data: {
|
||||
complete: true,
|
||||
},
|
||||
});
|
||||
}
|
||||
} else {
|
||||
write_stream.close();
|
||||
logger.debug(`error while writing to zip: ${err}`);
|
||||
logger.error(`Export for ${user.username} (${user.id}) has failed\n${err}`);
|
||||
logger.error(
|
||||
`Export for ${user.username} (${user.id}) has failed and has been removed from the database\n${err}`,
|
||||
);
|
||||
|
||||
await prisma.export.delete({
|
||||
where: {
|
||||
id: exportDb.id,
|
||||
},
|
||||
});
|
||||
}
|
||||
};
|
||||
|
||||
@@ -114,27 +137,62 @@ async function handler(req: NextApiReq, res: NextApiRes, user: UserExtended) {
|
||||
res.json({
|
||||
url: '/api/user/export?name=' + export_name,
|
||||
});
|
||||
} else {
|
||||
const export_name = req.query.name as string;
|
||||
if (export_name) {
|
||||
const parts = export_name.split('_');
|
||||
if (Number(parts[2]) !== user.id) return res.unauthorized('cannot access export owned by another user');
|
||||
} else if (req.method === 'DELETE') {
|
||||
const name = req.query.name as string;
|
||||
if (!name) return res.badRequest('no name provided');
|
||||
|
||||
const stream = createReadStream(join(config.core.temp_directory, export_name));
|
||||
const exportDb = await prisma.export.findFirst({
|
||||
where: {
|
||||
userId: user.id,
|
||||
path: name,
|
||||
},
|
||||
});
|
||||
|
||||
if (!exportDb) return res.notFound('export not found');
|
||||
|
||||
await prisma.export.delete({
|
||||
where: {
|
||||
id: exportDb.id,
|
||||
},
|
||||
});
|
||||
|
||||
try {
|
||||
await rm(join(config.core.temp_directory, exportDb.path));
|
||||
} catch (e) {
|
||||
logger
|
||||
.error(`export file ${exportDb.path} has been removed from the database`)
|
||||
.error(`but failed to remove the file from the filesystem: ${e}`);
|
||||
}
|
||||
|
||||
res.json({
|
||||
success: true,
|
||||
});
|
||||
} else {
|
||||
const exportsDb = await prisma.export.findMany({
|
||||
where: {
|
||||
userId: user.id,
|
||||
},
|
||||
});
|
||||
|
||||
const name = req.query.name as string;
|
||||
if (name) {
|
||||
const exportDb = exportsDb.find((e) => e.path === name);
|
||||
if (!exportDb) return res.notFound('export not found');
|
||||
|
||||
const stream = createReadStream(join(config.core.temp_directory, exportDb.path));
|
||||
|
||||
res.setHeader('Content-Type', 'application/zip');
|
||||
res.setHeader('Content-Disposition', `attachment; filename="${export_name}"`);
|
||||
res.setHeader('Content-Disposition', `attachment; filename="${exportDb.path}"`);
|
||||
stream.pipe(res);
|
||||
} else {
|
||||
const files = await readdir(config.core.temp_directory);
|
||||
const exp = files.filter((f) => f.startsWith('zipline_export_'));
|
||||
const exports = [];
|
||||
for (let i = 0; i !== exp.length; ++i) {
|
||||
const name = exp[i];
|
||||
const stats = await stat(join(config.core.temp_directory, name));
|
||||
|
||||
if (Number(exp[i].split('_')[2]) !== user.id) continue;
|
||||
exports.push({ name, size: stats.size });
|
||||
for (let i = 0; i !== exportsDb.length; ++i) {
|
||||
const exportDb = exportsDb[i];
|
||||
if (!exportDb.complete) continue;
|
||||
|
||||
const stats = await stat(join(config.core.temp_directory, exportDb.path));
|
||||
exports.push({ name: exportDb.path, size: stats.size, createdAt: exportDb.createdAt });
|
||||
}
|
||||
|
||||
res.json({
|
||||
@@ -145,6 +203,6 @@ async function handler(req: NextApiReq, res: NextApiRes, user: UserExtended) {
|
||||
}
|
||||
|
||||
export default withZipline(handler, {
|
||||
methods: ['GET', 'POST'],
|
||||
methods: ['GET', 'POST', 'DELETE'],
|
||||
user: true,
|
||||
});
|
||||
|
||||
@@ -16,7 +16,13 @@ async function handler(req: NextApiReq, res: NextApiRes, user: UserExtended) {
|
||||
id: idParsed,
|
||||
},
|
||||
select: {
|
||||
files: !!req.query.files,
|
||||
files: req.query.files
|
||||
? {
|
||||
include: {
|
||||
thumbnail: true,
|
||||
},
|
||||
}
|
||||
: false,
|
||||
id: true,
|
||||
name: true,
|
||||
userId: true,
|
||||
@@ -70,7 +76,13 @@ async function handler(req: NextApiReq, res: NextApiRes, user: UserExtended) {
|
||||
},
|
||||
},
|
||||
select: {
|
||||
files: !!req.query.files,
|
||||
files: req.query.files
|
||||
? {
|
||||
include: {
|
||||
thumbnail: true,
|
||||
},
|
||||
}
|
||||
: false,
|
||||
id: true,
|
||||
name: true,
|
||||
userId: true,
|
||||
@@ -111,7 +123,13 @@ async function handler(req: NextApiReq, res: NextApiRes, user: UserExtended) {
|
||||
public: !!publicFolder,
|
||||
},
|
||||
select: {
|
||||
files: !!req.query.files,
|
||||
files: req.query.files
|
||||
? {
|
||||
include: {
|
||||
thumbnail: true,
|
||||
},
|
||||
}
|
||||
: false,
|
||||
id: true,
|
||||
name: true,
|
||||
userId: true,
|
||||
@@ -200,7 +218,13 @@ async function handler(req: NextApiReq, res: NextApiRes, user: UserExtended) {
|
||||
},
|
||||
},
|
||||
select: {
|
||||
files: !!req.query.files,
|
||||
files: req.query.files
|
||||
? {
|
||||
include: {
|
||||
thumbnail: true,
|
||||
},
|
||||
}
|
||||
: false,
|
||||
id: true,
|
||||
name: true,
|
||||
userId: true,
|
||||
|
||||
@@ -115,6 +115,17 @@ export const getServerSideProps: GetServerSideProps = async (context) => {
|
||||
renderType = null;
|
||||
}
|
||||
|
||||
await prisma.file.update({
|
||||
where: {
|
||||
id: file.id,
|
||||
},
|
||||
data: {
|
||||
views: {
|
||||
increment: 1,
|
||||
},
|
||||
},
|
||||
});
|
||||
|
||||
return {
|
||||
props: {
|
||||
code: await streamToString(data),
|
||||
|
||||
@@ -11,6 +11,7 @@ import Link from 'next/link';
|
||||
import { useRouter } from 'next/router';
|
||||
import { useEffect, useState } from 'react';
|
||||
import zconfig from 'lib/config';
|
||||
import { log } from 'server/util';
|
||||
|
||||
export default function EmbeddedFile({
|
||||
file,
|
||||
@@ -63,11 +64,15 @@ export default function EmbeddedFile({
|
||||
|
||||
const img = new Image();
|
||||
img.addEventListener('load', function () {
|
||||
if (this.naturalWidth > innerWidth)
|
||||
imageEl.width = Math.floor(
|
||||
this.naturalWidth * Math.min(innerHeight / this.naturalHeight, innerWidth / this.naturalWidth),
|
||||
);
|
||||
else imageEl.width = this.naturalWidth;
|
||||
// my best attempt of recreating https://searchfox.org/mozilla-central/source/dom/html/ImageDocument.cpp#271-276
|
||||
// and it actually works
|
||||
|
||||
const ratio = Math.min(innerHeight / this.naturalHeight, innerWidth / this.naturalWidth);
|
||||
const newWidth = Math.max(1, Math.floor(ratio * this.naturalWidth));
|
||||
const newHeight = Math.max(1, Math.floor(ratio * this.naturalHeight));
|
||||
|
||||
imageEl.width = newWidth;
|
||||
imageEl.height = newHeight;
|
||||
});
|
||||
|
||||
img.src = url || dataURL('/r');
|
||||
@@ -80,11 +85,19 @@ export default function EmbeddedFile({
|
||||
useEffect(() => {
|
||||
if (pass) {
|
||||
setOpened(true);
|
||||
} else {
|
||||
updateImage();
|
||||
}
|
||||
}, []);
|
||||
|
||||
useEffect(() => {
|
||||
if (!file?.mimetype?.startsWith('image')) return;
|
||||
|
||||
updateImage();
|
||||
window.addEventListener('resize', () => updateImage());
|
||||
return () => {
|
||||
window.removeEventListener('resize', () => updateImage());
|
||||
};
|
||||
}, []);
|
||||
|
||||
return (
|
||||
<>
|
||||
<Head>
|
||||
@@ -192,15 +205,7 @@ export default function EmbeddedFile({
|
||||
}}
|
||||
>
|
||||
{file.mimetype.startsWith('image') && (
|
||||
<img
|
||||
style={{
|
||||
maxHeight: '100vh',
|
||||
maxWidth: '100vw',
|
||||
}}
|
||||
src={dataURL('/r')}
|
||||
alt={dataURL('/r')}
|
||||
id='image_content'
|
||||
/>
|
||||
<img src={dataURL('/r')} alt={dataURL('/r')} id='image_content' />
|
||||
)}
|
||||
|
||||
{file.mimetype.startsWith('video') && (
|
||||
@@ -247,6 +252,17 @@ export const getServerSideProps: GetServerSideProps = async (context) => {
|
||||
let host = context.req.headers.host;
|
||||
if (!file) return { notFound: true };
|
||||
|
||||
const logger = log('view');
|
||||
|
||||
if (file.maxViews && file.views >= file.maxViews) {
|
||||
await datasource.delete(file.name);
|
||||
await prisma.file.delete({ where: { id: file.id } });
|
||||
|
||||
logger.child('file').info(`File ${file.name} has been deleted due to max views (${file.maxViews})`);
|
||||
|
||||
return { notFound: true };
|
||||
}
|
||||
|
||||
// @ts-ignore
|
||||
file.size = Number(file.size);
|
||||
|
||||
@@ -272,6 +288,7 @@ export const getServerSideProps: GetServerSideProps = async (context) => {
|
||||
delete user.password;
|
||||
delete user.totpSecret;
|
||||
delete user.token;
|
||||
delete user.ratelimit;
|
||||
|
||||
// @ts-ignore workaround because next wont allow date
|
||||
file.createdAt = file.createdAt.toString();
|
||||
@@ -320,6 +337,17 @@ export const getServerSideProps: GetServerSideProps = async (context) => {
|
||||
// @ts-ignore
|
||||
if (file.password) file.password = true;
|
||||
|
||||
await prisma.file.update({
|
||||
where: {
|
||||
id: file.id,
|
||||
},
|
||||
data: {
|
||||
views: {
|
||||
increment: 1,
|
||||
},
|
||||
},
|
||||
});
|
||||
|
||||
return {
|
||||
props: {
|
||||
file,
|
||||
|
||||
@@ -21,6 +21,11 @@ function dbFileDecorator(fastify: FastifyInstance, _, done) {
|
||||
this.header('Content-Length', size);
|
||||
this.header('Content-Type', download ? 'application/octet-stream' : file.mimetype);
|
||||
this.header('Content-Disposition', `inline; filename="${encodeURI(file.originalName || file.name)}"`);
|
||||
if (file.mimetype.startsWith('video/') || file.mimetype.startsWith('audio/')) {
|
||||
this.header('Accept-Ranges', 'bytes');
|
||||
// https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Content-Range
|
||||
this.header('Content-Range', `bytes 0-${size - 1}/${size}`);
|
||||
}
|
||||
|
||||
return this.send(data);
|
||||
}
|
||||
|
||||
@@ -3063,9 +3063,9 @@ __metadata:
|
||||
linkType: hard
|
||||
|
||||
"caniuse-lite@npm:^1.0.30001406":
|
||||
version: 1.0.30001561
|
||||
resolution: "caniuse-lite@npm:1.0.30001561"
|
||||
checksum: 949829fe037e23346595614e01d362130245920503a12677f2506ce68e1240360113d6383febed41e8aa38cd0f5fd9c69c21b0af65a71c0246d560db489f1373
|
||||
version: 1.0.30001642
|
||||
resolution: "caniuse-lite@npm:1.0.30001642"
|
||||
checksum: 23f823ec115306eaf9299521328bb6ad0c4ce65254c375b14fd497ceda759ee8ee5b8763b7b622cb36b6b5fb53c6cb8569785fba842fe289be7dc3fcf008eb4f
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
|
||||
Reference in New Issue
Block a user