80 lines
2.3 KiB
TypeScript
80 lines
2.3 KiB
TypeScript
// Copyright 2018-2021 Signal Messenger, LLC
|
|
// SPDX-License-Identifier: AGPL-3.0-only
|
|
|
|
import * as z from 'zod';
|
|
import FormData from 'form-data';
|
|
import { gzip } from 'zlib';
|
|
import pify from 'pify';
|
|
import got, { Response } from 'got';
|
|
import { getUserAgent } from '../util/getUserAgent';
|
|
import { maybeParseUrl } from '../util/url';
|
|
|
|
const BASE_URL = 'https://debuglogs.org';
|
|
|
|
const tokenBodySchema = z
|
|
.object({
|
|
fields: z.record(z.unknown()),
|
|
url: z.string(),
|
|
})
|
|
.nonstrict();
|
|
|
|
const parseTokenBody = (
|
|
rawBody: unknown
|
|
): { fields: Record<string, unknown>; url: string } => {
|
|
const body = tokenBodySchema.parse(rawBody);
|
|
|
|
const parsedUrl = maybeParseUrl(body.url);
|
|
if (!parsedUrl) {
|
|
throw new Error("Token body's URL was not a valid URL");
|
|
}
|
|
if (parsedUrl.protocol !== 'https:') {
|
|
throw new Error("Token body's URL was not HTTPS");
|
|
}
|
|
|
|
return body;
|
|
};
|
|
|
|
export const uploadDebugLogs = async (
|
|
content: string,
|
|
appVersion: string
|
|
): Promise<string> => {
|
|
const headers = { 'User-Agent': getUserAgent(appVersion) };
|
|
|
|
const signedForm = await got.get(BASE_URL, { json: true, headers });
|
|
const { fields, url } = parseTokenBody(signedForm.body);
|
|
|
|
const form = new FormData();
|
|
// The API expects `key` to be the first field:
|
|
form.append('key', fields.key);
|
|
Object.entries(fields)
|
|
.filter(([key]) => key !== 'key')
|
|
.forEach(([key, value]) => {
|
|
form.append(key, value);
|
|
});
|
|
|
|
const contentBuffer = await pify(gzip)(Buffer.from(content, 'utf8'));
|
|
const contentType = 'application/gzip';
|
|
form.append('Content-Type', contentType);
|
|
form.append('file', contentBuffer, {
|
|
contentType,
|
|
filename: `signal-desktop-debug-log-${appVersion}.txt.gz`,
|
|
});
|
|
|
|
window.log.info('Debug log upload starting...');
|
|
try {
|
|
const { statusCode, body } = await got.post(url, { headers, body: form });
|
|
if (statusCode !== 204) {
|
|
throw new Error(
|
|
`Failed to upload to S3, got status ${statusCode}, body '${body}'`
|
|
);
|
|
}
|
|
} catch (error) {
|
|
const response = error.response as Response<string>;
|
|
throw new Error(
|
|
`Got threw on upload to S3, got status ${response?.statusCode}, body '${response?.body}' `
|
|
);
|
|
}
|
|
window.log.info('Debug log upload complete.');
|
|
|
|
return `${BASE_URL}/${fields.key}`;
|
|
};
|