[Assistnats] improve reporting (#797)

* [Assistnats] improve reporting

* typo

* make it more general

* typo

* update prodEnv script

* Update scripts/updateProdEnv.ts

.env

@@ -133,4 +133,6 @@ EXPOSE_API=true
 
 ENABLE_ASSISTANTS=false #set to true to enable assistants feature
 
-ALTERNATIVE_REDIRECT_URLS=`[]` #valide alternative redirect URL for OAuth
+ALTERNATIVE_REDIRECT_URLS=`[]` #valide alternative redirect URL for OAuth
+
+WEBHOOK_URL_REPORT_ASSISTANT=#provide webhook url to get notified when an assistant gets reported

scripts/updateProdEnv.ts

@@ -6,6 +6,7 @@ const SERPER_API_KEY = process.env.SERPER_API_KEY;
 const OPENID_CONFIG = process.env.OPENID_CONFIG;
 const MONGODB_URL = process.env.MONGODB_URL;
 const HF_TOKEN = process.env.HF_TOKEN ?? process.env.HF_ACCESS_TOKEN; // token used for API requests in prod
+const WEBHOOK_URL_REPORT_ASSISTANT = process.env.WEBHOOK_URL_REPORT_ASSISTANT; // slack webhook url used to get "report assistant" events
 
 // Read the content of the file .env.template
 const PUBLIC_CONFIG = fs.readFileSync(".env.template", "utf8");
@@ -16,6 +17,7 @@ MONGODB_URL=${MONGODB_URL}
 OPENID_CONFIG=${OPENID_CONFIG}
 SERPER_API_KEY=${SERPER_API_KEY}
 HF_TOKEN=${HF_TOKEN}
+WEBHOOK_URL_REPORT_ASSISTANT=${WEBHOOK_URL_REPORT_ASSISTANT}
 `;
 
 // Make an HTTP POST request to add the space secrets

src/routes/settings/assistants/[assistantId]/+page.server.ts

@@ -3,6 +3,8 @@ import { type Actions, fail, redirect } from "@sveltejs/kit";
 import { ObjectId } from "mongodb";
 import { authCondition } from "$lib/server/auth";
 import { base } from "$app/paths";
+import { PUBLIC_ORIGIN, PUBLIC_SHARE_PREFIX } from "$env/static/public";
+import { WEBHOOK_URL_REPORT_ASSISTANT } from "$env/static/private";
 
 async function assistantOnlyIfAuthor(locals: App.Locals, assistantId?: string) {
 	const assistant = await collections.assistants.findOne({ _id: new ObjectId(assistantId) });
@@ -49,7 +51,7 @@ export const actions: Actions = {
 
 		throw redirect(302, `${base}/settings`);
 	},
-	report: async ({ params, locals }) => {
+	report: async ({ params, locals, url }) => {
 		// is there already a report from this user for this model ?
 		const report = await collections.reports.findOne({
 			assistantId: new ObjectId(params.assistantId),
@@ -71,6 +73,31 @@ export const actions: Actions = {
 		if (!acknowledged) {
 			return fail(500, { error: true, message: "Failed to report assistant" });
 		}
+
+		if (WEBHOOK_URL_REPORT_ASSISTANT) {
+			const prefixUrl = PUBLIC_SHARE_PREFIX || `${PUBLIC_ORIGIN || url.origin}${base}`;
+			const assistantUrl = `${prefixUrl}/assistant/${params.assistantId}`;
+
+			const assistant = await collections.assistants.findOne(
+				{ _id: new ObjectId(params.assistantId) },
+				{ projection: { name: 1 } }
+			);
+
+			const res = await fetch(WEBHOOK_URL_REPORT_ASSISTANT, {
+				method: "POST",
+				headers: {
+					"Content-type": "application/json",
+				},
+				body: JSON.stringify({
+					text: `Assistant <${assistantUrl}|${assistant?.name}> reported by <http://hf.co/${locals.user?.username}|${locals.user?.username}>`,
+				}),
+			});
+
+			if (!res.ok) {
+				console.error(`Webhook assistant report failed. ${res.statusText} ${res.text}`);
+			}
+		}
+
 		return { from: "report", ok: true, message: "Assistant reported" };
 	},