Spaces:

mithril-security
/

blind_chat

Runtime error

App Files Files Community

JoFrost commited on Oct 2, 2023

Commit

0015338

•

1 Parent(s): cd86937

feat: add phi

Browse files

Files changed (19) hide show

.env +28 -0
.svelte-kit/ambient.d.ts +2 -2
.svelte-kit/generated/server/internal.js +2 -2
.svelte-kit/types/src/routes/proxy+layout.server.ts +2 -2
src/lib/components/InitModelModal.svelte +16 -0
src/lib/components/LoadingModal.svelte +66 -13
src/lib/components/LoadingModalWritable.js +1 -0
src/lib/components/chat/ChatMessage.svelte +10 -42
src/lib/server/models.ts +1 -0
src/routes/+layout.server.ts +1 -0
src/routes/+layout.svelte +10 -0
src/routes/LayoutWritable.js +2 -0
src/routes/LocalDB.ts +3 -0
src/routes/conversation/[id]/+page.svelte +22 -18
src/routes/conversation/[id]/phi/m.d.ts +65 -0
src/routes/conversation/[id]/phi/m.js +476 -0
src/routes/conversation/[id]/phi/m_bg.wasm +3 -0
src/routes/conversation/[id]/phi/m_bg.wasm.d.ts +14 -0
src/routes/conversation/[id]/worker.js +169 -23

.env CHANGED Viewed

@@ -29,6 +29,34 @@ REJECT_UNAUTHORIZED=true
 # 'name', 'userMessageToken', 'assistantMessageToken' are required
 MODELS=`[
   {
     "name": "Xenova/LaMini-Flan-T5-783M",
     "is_local": true,

 # 'name', 'userMessageToken', 'assistantMessageToken' are required
 MODELS=`[
+  {
+    "name": "microsoft/phi-1_5",
+    "is_local": true,
+    "is_phi": true,
+    "type": "text-generation",
+    "userMessageToken": "<|prompter|>",
+    "assistantMessageToken": "<|assistant|>",
+    "messageEndToken": "</s>",
+    "preprompt": "",
+    "promptExamples": [
+      {
+        "title": "What is love?",
+        "prompt": "Describe what love is in a few sentences."
+      },
+      {
+        "title": "What does end-to-end protected mean?",
+        "prompt": "Describe what does end-to-end protected mean in a few sentences."
+      }
+    ],
+    "parameters": {
+      "temperature": 0.5,
+      "top_p": 0.95,
+      "repetition_penalty": 1.2,
+      "top_k": 50,
+      "truncate": 1000,
+      "max_new_tokens": 256
+    }
+  },
   {
     "name": "Xenova/LaMini-Flan-T5-783M",
     "is_local": true,

.svelte-kit/ambient.d.ts CHANGED Viewed

@@ -64,7 +64,7 @@ declare module '$env/static/private' {
 	export const ComSpec: string;
 	export const DriverData: string;
 	export const EDITOR: string;
-	export const EFC_47272: string;
 	export const EnableLog: string;
 	export const GIT_ASKPASS: string;
 	export const HOME: string;
@@ -213,7 +213,7 @@ declare module '$env/dynamic/private' {
 		ComSpec: string;
 		DriverData: string;
 		EDITOR: string;
-		EFC_47272: string;
 		EnableLog: string;
 		GIT_ASKPASS: string;
 		HOME: string;

 	export const ComSpec: string;
 	export const DriverData: string;
 	export const EDITOR: string;
+	export const EFC_29500: string;
 	export const EnableLog: string;
 	export const GIT_ASKPASS: string;
 	export const HOME: string;
 		ComSpec: string;
 		DriverData: string;
 		EDITOR: string;
+		EFC_29500: string;
 		EnableLog: string;
 		GIT_ASKPASS: string;
 		HOME: string;

.svelte-kit/generated/server/internal.js CHANGED Viewed

@@ -17,10 +17,10 @@ export const options = {
 	root,
 	service_worker: false,
 	templates: {
-		app: ({ head, body, assets, nonce, env }) => "<!DOCTYPE html>\r\n<html lang=\"en\" class=\"h-full\">\r\n\t<link rel=\"stylesheet\" href=\"https://www.w3schools.com/w3css/4/w3.css\" />\r\n\t<head>\r\n\t\t<meta charset=\"utf-8\" />\r\n\t\t<meta name=\"viewport\" content=\"width=device-width, initial-scale=1, user-scalable=no\" />\r\n\t\t<meta property=\"og:image\" content=\"/chatui/thumbnail.jpg\"/>\r\n\t\t<script>\r\n\t\t\tif (\r\n\t\t\t\tlocalStorage.theme === \"dark\" ||\r\n\t\t\t\t(!(\"theme\" in localStorage) && window.matchMedia(\"(prefers-color-scheme: dark)\").matches)\r\n\t\t\t) {\r\n\t\t\t\tdocument.documentElement.classList.add(\"dark\");\r\n\t\t\t}\r\n\t\t</script>\r\n\t\t" + head + "\r\n\t</head>\r\n\t<body data-sveltekit-preload-data=\"hover\" class=\"h-full dark:bg-gray-900\">\r\n\t\t<div id=\"app\" class=\"contents h-full\">" + body + "</div>\r\n\t</body>\r\n</html>\r\n",
 		error: ({ status, message }) => "<!DOCTYPE html>\n<html lang=\"en\">\n\t<head>\n\t\t<meta charset=\"utf-8\" />\n\t\t<title>" + message + "</title>\n\n\t\t<style>\n\t\t\tbody {\n\t\t\t\t--bg: white;\n\t\t\t\t--fg: #222;\n\t\t\t\t--divider: #ccc;\n\t\t\t\tbackground: var(--bg);\n\t\t\t\tcolor: var(--fg);\n\t\t\t\tfont-family: system-ui, -apple-system, BlinkMacSystemFont, 'Segoe UI', Roboto, Oxygen,\n\t\t\t\t\tUbuntu, Cantarell, 'Open Sans', 'Helvetica Neue', sans-serif;\n\t\t\t\tdisplay: flex;\n\t\t\t\talign-items: center;\n\t\t\t\tjustify-content: center;\n\t\t\t\theight: 100vh;\n\t\t\t\tmargin: 0;\n\t\t\t}\n\n\t\t\t.error {\n\t\t\t\tdisplay: flex;\n\t\t\t\talign-items: center;\n\t\t\t\tmax-width: 32rem;\n\t\t\t\tmargin: 0 1rem;\n\t\t\t}\n\n\t\t\t.status {\n\t\t\t\tfont-weight: 200;\n\t\t\t\tfont-size: 3rem;\n\t\t\t\tline-height: 1;\n\t\t\t\tposition: relative;\n\t\t\t\ttop: -0.05rem;\n\t\t\t}\n\n\t\t\t.message {\n\t\t\t\tborder-left: 1px solid var(--divider);\n\t\t\t\tpadding: 0 0 0 1rem;\n\t\t\t\tmargin: 0 0 0 1rem;\n\t\t\t\tmin-height: 2.5rem;\n\t\t\t\tdisplay: flex;\n\t\t\t\talign-items: center;\n\t\t\t}\n\n\t\t\t.message h1 {\n\t\t\t\tfont-weight: 400;\n\t\t\t\tfont-size: 1em;\n\t\t\t\tmargin: 0;\n\t\t\t}\n\n\t\t\t@media (prefers-color-scheme: dark) {\n\t\t\t\tbody {\n\t\t\t\t\t--bg: #222;\n\t\t\t\t\t--fg: #ddd;\n\t\t\t\t\t--divider: #666;\n\t\t\t\t}\n\t\t\t}\n\t\t</style>\n\t</head>\n\t<body>\n\t\t<div class=\"error\">\n\t\t\t<span class=\"status\">" + status + "</span>\n\t\t\t<div class=\"message\">\n\t\t\t\t<h1>" + message + "</h1>\n\t\t\t</div>\n\t\t</div>\n\t</body>\n</html>\n"
 	},
-	version_hash: "aw3qnn"
 };
 export function get_hooks() {

 	root,
 	service_worker: false,
 	templates: {
+		app: ({ head, body, assets, nonce, env }) => "<!DOCTYPE html>\r\n<html lang=\"en\" class=\"h-full\">\r\n\t<link rel=\"stylesheet\" href=\"https://www.w3schools.com/w3css/4/w3.css\" />\r\n\t<head>\r\n\t\t<!-- Google Tag Manager -->\r\n\t\t<script>\r\n\t\tvar _paq = window._paq || [];\r\n\t\twindow._paq=_paq;\r\n\t\t(function(w,d,s,l,i){w[l]=w[l]||[];w[l].push({'gtm.start':\r\n\t\tnew Date().getTime(),event:'gtm.js'});var f=d.getElementsByTagName(s)[0],\r\n\t\tj=d.createElement(s),dl=l!='dataLayer'?'&l='+l:'';j.async=true;j.src=\r\n\t\t'https://www.googletagmanager.com/gtm.js?id='+i+dl;f.parentNode.insertBefore(j,f);\r\n\t\t})(window,document,'script','dataLayer','GTM-TVD93MF');\r\n\t\t</script>\r\n\t\t<!-- End Google Tag Manager -->\r\n\t\t<meta charset=\"utf-8\" />\r\n\t\t<meta name=\"viewport\" content=\"width=device-width, initial-scale=1, user-scalable=no\" />\r\n\t\t<meta property=\"og:image\" content=\"/chatui/thumbnail.jpg\" />\r\n\t\t<script>\r\n\t\t\tif (\r\n\t\t\t\tlocalStorage.theme === \"dark\" ||\r\n\t\t\t\t(!(\"theme\" in localStorage) && window.matchMedia(\"(prefers-color-scheme: dark)\").matches)\r\n\t\t\t) {\r\n\t\t\t\tdocument.documentElement.classList.add(\"dark\");\r\n\t\t\t}\r\n\t\t</script>\r\n\t\t" + head + "\r\n\t</head>\r\n\t<body data-sveltekit-preload-data=\"hover\" class=\"h-full dark:bg-gray-900\">\r\n\t\t<div id=\"app\" class=\"contents h-full\">" + body + "</div>\r\n\t</body>\r\n</html>\r\n",
 		error: ({ status, message }) => "<!DOCTYPE html>\n<html lang=\"en\">\n\t<head>\n\t\t<meta charset=\"utf-8\" />\n\t\t<title>" + message + "</title>\n\n\t\t<style>\n\t\t\tbody {\n\t\t\t\t--bg: white;\n\t\t\t\t--fg: #222;\n\t\t\t\t--divider: #ccc;\n\t\t\t\tbackground: var(--bg);\n\t\t\t\tcolor: var(--fg);\n\t\t\t\tfont-family: system-ui, -apple-system, BlinkMacSystemFont, 'Segoe UI', Roboto, Oxygen,\n\t\t\t\t\tUbuntu, Cantarell, 'Open Sans', 'Helvetica Neue', sans-serif;\n\t\t\t\tdisplay: flex;\n\t\t\t\talign-items: center;\n\t\t\t\tjustify-content: center;\n\t\t\t\theight: 100vh;\n\t\t\t\tmargin: 0;\n\t\t\t}\n\n\t\t\t.error {\n\t\t\t\tdisplay: flex;\n\t\t\t\talign-items: center;\n\t\t\t\tmax-width: 32rem;\n\t\t\t\tmargin: 0 1rem;\n\t\t\t}\n\n\t\t\t.status {\n\t\t\t\tfont-weight: 200;\n\t\t\t\tfont-size: 3rem;\n\t\t\t\tline-height: 1;\n\t\t\t\tposition: relative;\n\t\t\t\ttop: -0.05rem;\n\t\t\t}\n\n\t\t\t.message {\n\t\t\t\tborder-left: 1px solid var(--divider);\n\t\t\t\tpadding: 0 0 0 1rem;\n\t\t\t\tmargin: 0 0 0 1rem;\n\t\t\t\tmin-height: 2.5rem;\n\t\t\t\tdisplay: flex;\n\t\t\t\talign-items: center;\n\t\t\t}\n\n\t\t\t.message h1 {\n\t\t\t\tfont-weight: 400;\n\t\t\t\tfont-size: 1em;\n\t\t\t\tmargin: 0;\n\t\t\t}\n\n\t\t\t@media (prefers-color-scheme: dark) {\n\t\t\t\tbody {\n\t\t\t\t\t--bg: #222;\n\t\t\t\t\t--fg: #ddd;\n\t\t\t\t\t--divider: #666;\n\t\t\t\t}\n\t\t\t}\n\t\t</style>\n\t</head>\n\t<body>\n\t\t<div class=\"error\">\n\t\t\t<span class=\"status\">" + status + "</span>\n\t\t\t<div class=\"message\">\n\t\t\t\t<h1>" + message + "</h1>\n\t\t\t</div>\n\t\t</div>\n\t</body>\n</html>\n"
 	},
+	version_hash: "1iyihr1"
 };
 export function get_hooks() {

.svelte-kit/types/src/routes/proxy+layout.server.ts CHANGED Viewed

@@ -32,8 +32,7 @@ export const load = async ({ locals, depends, url }: Parameters<LayoutServerLoad
 	return {
 		conversations: [],
 		settings: {
-			shareConversationsWithModelAuthors:
-				DEFAULT_SETTINGS.shareConversationsWithModelAuthors,
 			ethicsModalAcceptedAt: null,
 			activeModel: DEFAULT_SETTINGS.activeModel,
 			searchEnabled: false,
@@ -45,6 +44,7 @@ export const load = async ({ locals, depends, url }: Parameters<LayoutServerLoad
 			websiteUrl: model.websiteUrl,
 			modelUrl: model.modelUrl,
 			is_local: model.is_local,
 			is_code: model.is_code,
 			type: model.type,
 			datasetName: model.datasetName,

 	return {
 		conversations: [],
 		settings: {
+			shareConversationsWithModelAuthors: DEFAULT_SETTINGS.shareConversationsWithModelAuthors,
 			ethicsModalAcceptedAt: null,
 			activeModel: DEFAULT_SETTINGS.activeModel,
 			searchEnabled: false,
 			websiteUrl: model.websiteUrl,
 			modelUrl: model.modelUrl,
 			is_local: model.is_local,
+			is_phi: model.is_phi,
 			is_code: model.is_code,
 			type: model.type,
 			datasetName: model.datasetName,

src/lib/components/InitModelModal.svelte ADDED Viewed

	@@ -0,0 +1,16 @@

+<script lang="ts">
+	import Modal from "$lib/components/Modal.svelte";
+</script>
+<Modal>
+	<div class="flex w-full flex-col gap-0 p-2">
+		<div class="flex items-start text-xl font-bold text-gray-800">
+			<h2>Initializing the model...</h2>
+			<br />
+		</div>
+		<div class="text-s flex items-start text-gray-800">
+			<br />The model is preparing the answer for your queries...
+		</div>
+		<br />
+	</div>
+</Modal>

src/lib/components/LoadingModal.svelte CHANGED Viewed

@@ -1,19 +1,44 @@
 <script lang="ts">
 	import Modal from "$lib/components/Modal.svelte";
-	import { progress_writable, curr_model_writable, map_writable } from "./LoadingModalWritable.js";
 	const forceUpdate = async (_) => {};
 	let loadingMap = new Map<string, number>();
 	let pr = 1;
 	map_writable.subscribe((value) => {
 		const [model, percent] = value;
 		pr = Number(percent);
-		if (model.startsWith("onnx")) {
 			loadingMap.set(model, Math.floor(Number(percent)));
-			//console.log(loadingMap);
 		}
 	});
 </script>
@@ -21,20 +46,48 @@
 	<div class="flex w-full flex-col gap-0 p-2">
 		<div class="flex items-start text-xl font-bold text-gray-800">
 			<h2>Loading the model...</h2>
-			<br />
-		</div>
-		<div class="text-s flex items-start text-gray-800">
-			<br />Please wait while we download the model. This has to be done only once.
 		</div>
 		<br />
 		{#await forceUpdate(pr) then _}
-			{#each [...loadingMap] as [key, value]}
-				<p class="text-s text-gray-800">{key}</p>
-				<div class="w3-light-grey">
-					<div class="w3-blue" style="width:{value}%">{value}%</div>
-				</div>
 				<br />
-			{/each}
 		{/await}
 	</div>
 </Modal>

 <script lang="ts">
 	import Modal from "$lib/components/Modal.svelte";
+	import is from "date-fns/locale/is";
+	import { progress_writable, curr_model_writable, map_writable, phi_writable } from "./LoadingModalWritable.js";
 	const forceUpdate = async (_) => {};
 	let loadingMap = new Map<string, number>();
 	let pr = 1;
+	let other_loading = false;
+	let is_phi_loading = false;
+	let is_phi = false;
+	phi_writable.subscribe((value) => {
+		is_phi = value;
+		if (value) {
+			other_loading = true;
+		}
+	});
 	map_writable.subscribe((value) => {
 		const [model, percent] = value;
 		pr = Number(percent);
+		if (model != undefined && model.startsWith("onnx")) {
+			is_phi_loading = false;
 			loadingMap.set(model, Math.floor(Number(percent)));
 		}
+		else if (model != undefined && model.startsWith("phi")) {
+			is_phi_loading = true;
+		}
+		if (loadingMap.size > 0)
+		{
+			is_phi_loading = false;
+			other_loading = true;
+			loadingMap.forEach((per, model, map) => {
+				if (per < 100 && loadingMap.size > 0) {
+					other_loading = false;
+				}
+			})
+		}
 	});
 </script>
 	<div class="flex w-full flex-col gap-0 p-2">
 		<div class="flex items-start text-xl font-bold text-gray-800">
 			<h2>Loading the model...</h2>
 		</div>
 		<br />
 		{#await forceUpdate(pr) then _}
+			{#if other_loading == false}
+			<div class="text-s flex items-start text-gray-800">
+				Please wait while we download the model. This has to be done only once.
 				<br />
+			</div>
+				{#if is_phi_loading == false}
+					<br />
+					{#each [...loadingMap] as [key, value]}
+						<p class="text-s text-gray-800">{key}</p>
+						<div class="w3-light-grey">
+							<div class="w3-blue" style="width:{value}%">{value}%</div>
+						</div>
+						<br />
+					{/each}
+				{:else}
+				<div class="text-left">
+					<div role="status">
+						<svg aria-hidden="true" class="inline w-8 h-8 mr-2 text-gray-200 animate-spin dark:text-gray-600 fill-gray-600 dark:fill-gray-300" viewBox="0 0 100 101" fill="none" xmlns="http://www.w3.org/2000/svg">
+							<path d="M100 50.5908C100 78.2051 77.6142 100.591 50 100.591C22.3858 100.591 0 78.2051 0 50.5908C0 22.9766 22.3858 0.59082 50 0.59082C77.6142 0.59082 100 22.9766 100 50.5908ZM9.08144 50.5908C9.08144 73.1895 27.4013 91.5094 50 91.5094C72.5987 91.5094 90.9186 73.1895 90.9186 50.5908C90.9186 27.9921 72.5987 9.67226 50 9.67226C27.4013 9.67226 9.08144 27.9921 9.08144 50.5908Z" fill="currentColor"/>
+							<path d="M93.9676 39.0409C96.393 38.4038 97.8624 35.9116 97.0079 33.5539C95.2932 28.8227 92.871 24.3692 89.8167 20.348C85.8452 15.1192 80.8826 10.7238 75.2124 7.41289C69.5422 4.10194 63.2754 1.94025 56.7698 1.05124C51.7666 0.367541 46.6976 0.446843 41.7345 1.27873C39.2613 1.69328 37.813 4.19778 38.4501 6.62326C39.0873 9.04874 41.5694 10.4717 44.0505 10.1071C47.8511 9.54855 51.7191 9.52689 55.5402 10.0491C60.8642 10.7766 65.9928 12.5457 70.6331 15.2552C75.2735 17.9648 79.3347 21.5619 82.5849 25.841C84.9175 28.9121 86.7997 32.2913 88.1811 35.8758C89.083 38.2158 91.5421 39.6781 93.9676 39.0409Z" fill="currentFill"/>
+						</svg>
+						<span class="sr-only">Loading...</span>
+					</div>
+				</div>
+				{/if}
+			{:else}
+				<div class="text-s flex items-start text-gray-800">
+					Loading the model into memory...
+				</div>
+				<div class="text-left">
+					<div role="status">
+						<svg aria-hidden="true" class="inline w-8 h-8 mr-2 text-gray-200 animate-spin dark:text-gray-600 fill-gray-600 dark:fill-gray-300" viewBox="0 0 100 101" fill="none" xmlns="http://www.w3.org/2000/svg">
+							<path d="M100 50.5908C100 78.2051 77.6142 100.591 50 100.591C22.3858 100.591 0 78.2051 0 50.5908C0 22.9766 22.3858 0.59082 50 0.59082C77.6142 0.59082 100 22.9766 100 50.5908ZM9.08144 50.5908C9.08144 73.1895 27.4013 91.5094 50 91.5094C72.5987 91.5094 90.9186 73.1895 90.9186 50.5908C90.9186 27.9921 72.5987 9.67226 50 9.67226C27.4013 9.67226 9.08144 27.9921 9.08144 50.5908Z" fill="currentColor"/>
+							<path d="M93.9676 39.0409C96.393 38.4038 97.8624 35.9116 97.0079 33.5539C95.2932 28.8227 92.871 24.3692 89.8167 20.348C85.8452 15.1192 80.8826 10.7238 75.2124 7.41289C69.5422 4.10194 63.2754 1.94025 56.7698 1.05124C51.7666 0.367541 46.6976 0.446843 41.7345 1.27873C39.2613 1.69328 37.813 4.19778 38.4501 6.62326C39.0873 9.04874 41.5694 10.4717 44.0505 10.1071C47.8511 9.54855 51.7191 9.52689 55.5402 10.0491C60.8642 10.7766 65.9928 12.5457 70.6331 15.2552C75.2735 17.9648 79.3347 21.5619 82.5849 25.841C84.9175 28.9121 86.7997 32.2913 88.1811 35.8758C89.083 38.2158 91.5421 39.6781 93.9676 39.0409Z" fill="currentFill"/>
+						</svg>
+						<span class="sr-only">Loading...</span>
+					</div>
+				</div>
+			{/if}
 		{/await}
 	</div>
 </Modal>

src/lib/components/LoadingModalWritable.js CHANGED Viewed

@@ -3,3 +3,4 @@ import { writable } from "svelte/store";
 export const progress_writable = writable(0);
 export const curr_model_writable = writable("");
 export const map_writable = writable(["", ""]);

 export const progress_writable = writable(0);
 export const curr_model_writable = writable("");
 export const map_writable = writable(["", ""]);
+export const phi_writable = writable(false);

src/lib/components/chat/ChatMessage.svelte CHANGED Viewed

@@ -83,16 +83,16 @@
 		clearTimeout(pendingTimeout);
 		// Add loading animation to the last message if update takes more than 600ms
-		if (loading) {
-			pendingTimeout = setTimeout(() => {
-				if (contentEl) {
-					loadingEl = new IconLoading({
-						target: deepestChild(contentEl),
-						props: { classNames: "loading inline ml-2" },
-					});
-				}
-			}, 600);
-		}
 	});
 	$: downloadLink =
@@ -142,38 +142,6 @@
 				{/if}
 			</div>
 		</div>
-		<!-- {#if isAuthor && !loading && message.content}
-			<div
-				class="absolute bottom-1 right-0 flex max-md:transition-all md:bottom-0 md:group-hover:visible md:group-hover:opacity-100
-					{message.score ? 'visible opacity-100' : 'invisible max-md:-translate-y-4 max-md:opacity-0'}
-					{isTapped ? 'max-md:visible max-md:translate-y-0 max-md:opacity-100' : ''}
-				"
-			>
-				<button
-					class="btn rounded-sm p-1 text-sm text-gray-400 focus:ring-0 hover:text-gray-500 dark:text-gray-400 dark:hover:text-gray-300
-					{message.score && message.score > 0
-						? 'text-green-500 hover:text-green-500 dark:text-green-400 hover:dark:text-green-400'
-						: ''}"
-					title={message.score === 1 ? "Remove +1" : "+1"}
-					type="button"
-					on:click={() => dispatch("vote", { score: message.score === 1 ? 0 : 1, id: message.id })}
-				>
-					<CarbonThumbsUp class="h-[1.14em] w-[1.14em]" />
-				</button>
-				<button
-					class="btn rounded-sm p-1 text-sm text-gray-400 focus:ring-0 hover:text-gray-500 dark:text-gray-400 dark:hover:text-gray-300
-					{message.score && message.score < 0
-						? 'text-red-500 hover:text-red-500 dark:text-red-400 hover:dark:text-red-400'
-						: ''}"
-					title={message.score === -1 ? "Remove -1" : "-1"}
-					type="button"
-					on:click={() =>
-						dispatch("vote", { score: message.score === -1 ? 0 : -1, id: message.id })}
-				>
-					<CarbonThumbsDown class="h-[1.14em] w-[1.14em]" />
-				</button>
-			</div>
-		{/if} -->
 	</div>
 {/if}
 {#if message.from === "user"}

 		clearTimeout(pendingTimeout);
 		// Add loading animation to the last message if update takes more than 600ms
+		// if (loading) {
+		// 	pendingTimeout = setTimeout(() => {
+		// 		if (contentEl) {
+		// 			loadingEl = new IconLoading({
+		// 				target: deepestChild(contentEl),
+		// 				props: { classNames: "loading inline ml-2" },
+		// 			});
+		// 		}
+		// 	}, 600);
+		// }
 	});
 	$: downloadLink =
 				{/if}
 			</div>
 		</div>
 	</div>
 {/if}
 {#if message.from === "user"}

src/lib/server/models.ts CHANGED Viewed

@@ -65,6 +65,7 @@ const modelsRaw = z
 			description: z.string().min(1).optional(),
 			is_local: z.boolean().optional(),
 			is_code: z.boolean().optional(),
 			type: z.string().min(1),
 			websiteUrl: z.string().url().optional(),
 			modelUrl: z.string().url().optional(),

 			description: z.string().min(1).optional(),
 			is_local: z.boolean().optional(),
 			is_code: z.boolean().optional(),
+			is_phi: z.boolean().optional(),
 			type: z.string().min(1),
 			websiteUrl: z.string().url().optional(),
 			modelUrl: z.string().url().optional(),

src/routes/+layout.server.ts CHANGED Viewed

@@ -43,6 +43,7 @@ export const load: LayoutServerLoad = async ({ locals, depends, url }) => {
 			websiteUrl: model.websiteUrl,
 			modelUrl: model.modelUrl,
 			is_local: model.is_local,
 			is_code: model.is_code,
 			type: model.type,
 			datasetName: model.datasetName,

 			websiteUrl: model.websiteUrl,
 			modelUrl: model.modelUrl,
 			is_local: model.is_local,
+			is_phi: model.is_phi,
 			is_code: model.is_code,
 			type: model.type,
 			datasetName: model.datasetName,

src/routes/+layout.svelte CHANGED Viewed

@@ -21,6 +21,7 @@
 	import { PUBLIC_APP_ASSETS, PUBLIC_APP_NAME } from "$env/static/public";
 	import {
 		isloading_writable,
 		refresh_chats_writable,
 		refresh_chats_writable_empty,
 	} from "./LayoutWritable";
@@ -32,15 +33,21 @@
 		modifyTitle,
 	} from "../routes/LocalDB";
 	import { env } from "$env/dynamic/public";
 	export let data;
 	let isloading = false;
 	let showWarning = true;
 	let go_to_main = false;
 	let conversations_list = [];
 	isloading_writable.subscribe((value) => {
 		isloading = value;
 	});
@@ -205,6 +212,9 @@
 	{#if showWarning}
 		<ConfirmModal on:close={() => (showWarning = false)} />
 	{/if}
 	{#if isloading}
 		<LoadingModal />
 	{/if}

 	import { PUBLIC_APP_ASSETS, PUBLIC_APP_NAME } from "$env/static/public";
 	import {
 		isloading_writable,
+		is_init_writable,
 		refresh_chats_writable,
 		refresh_chats_writable_empty,
 	} from "./LayoutWritable";
 		modifyTitle,
 	} from "../routes/LocalDB";
 	import { env } from "$env/dynamic/public";
+	import InitModelModal from "$lib/components/InitModelModal.svelte";
 	export let data;
 	let isloading = false;
+	let isInit = false;
 	let showWarning = true;
 	let go_to_main = false;
 	let conversations_list = [];
+	is_init_writable.subscribe((value) => {
+		isInit = value;
+	});
 	isloading_writable.subscribe((value) => {
 		isloading = value;
 	});
 	{#if showWarning}
 		<ConfirmModal on:close={() => (showWarning = false)} />
 	{/if}
+	{#if isInit}
+		<InitModelModal />
+	{/if}
 	{#if isloading}
 		<LoadingModal />
 	{/if}

src/routes/LayoutWritable.js CHANGED Viewed

@@ -1,6 +1,8 @@
 import { writable } from "svelte/store";
 export const isloading_writable = writable(false);
 export const refresh_chats_writable = writable([]);
 export const refresh_chats_writable_empty = writable(false);
 export const curr_model_writable = writable(0);

 import { writable } from "svelte/store";
 export const isloading_writable = writable(false);
+export const is_init_writable = writable(false);
+export const cancel_writable = writable(false);
 export const refresh_chats_writable = writable([]);
 export const refresh_chats_writable_empty = writable(false);
 export const curr_model_writable = writable(0);

src/routes/LocalDB.ts CHANGED Viewed

@@ -28,6 +28,9 @@ export class ChatDatabase extends Dexie {
 			chats: null,
 		});
 		this.version(17).stores({
 			chats: "++index, title, createdAt, id, message, model",
 		});
 	}

 			chats: null,
 		});
 		this.version(17).stores({
+			chats: null,
+		});
+		this.version(18).stores({
 			chats: "++index, title, createdAt, id, message, model",
 		});
 	}

src/routes/conversation/[id]/+page.svelte CHANGED Viewed

@@ -16,8 +16,8 @@
 	import type { Message } from "$lib/types/Message";
 	import { PUBLIC_APP_DISCLAIMER } from "$env/static/public";
 	import { pipeline, Pipeline, env as env_transformers } from "@xenova/transformers";
-	import { isloading_writable, curr_model_writable } from "../../LayoutWritable.js";
-	import { map_writable } from "$lib/components/LoadingModalWritable.js";
 	import { params_writable } from "./ParamsWritable.js";
 	import { addMessageToChat, getChats, getMessages, getTitle, getModel } from "../../LocalDB.js";
 	import { env } from "$env/dynamic/public";
@@ -48,18 +48,13 @@
 	let webSearchMessages: WebSearchMessage[] = [];
-	// // Since we modify the messages array locally, we don't want to reset it if an old version is passed
-	// $: if (data.messages !== lastLoadedMessages) {
-	// 	messages = data.messages;
-	// 	lastLoadedMessages = data.messages;
-	// }
 	let loading = false;
 	let pending = false;
 	let loginRequired = false;
 	// Create a callback function for messages from the worker thread.
 	const onMessageReceived = (e) => {
 		let lastMessage: any = undefined;
 		switch (e.data.status) {
 			case "initiate":
@@ -67,7 +62,16 @@
 			case "progress":
 				isloading_writable.set(true);
-				map_writable.set([e.data.file, e.data.progress]);
 				break;
 			case "done":
@@ -75,6 +79,8 @@
 			case "ready":
 				isloading_writable.set(false);
 				break;
 			case "update":
@@ -85,8 +91,12 @@
 					lastMessage.updatedAt = new Date();
 					messages = [...messages];
 				}
 				break;
 			case "complete":
 				if (e.data.id_now == id_now) {
 					lastMessage = messages[messages.length - 1];
@@ -120,8 +130,6 @@
 		let opt = "";
-		console.log(curr_model_obj);
 		messages = [
 			...messages,
 			// id doesn't match the backend id but it's not important for assistant messages
@@ -148,6 +156,7 @@
 		let lastMessage = messages[messages.length - 1];
 		pipelineWorker.postMessage({
 			id_now: id_now,
 			task: curr_model_obj.type,
 			max_new_tokens: curr_model_obj.parameters?.max_new_tokens ?? 256,
@@ -251,7 +260,7 @@
 			}
 			console.error(err);
 		} finally {
-			loading = false;
 			pending = false;
 		}
 	}
@@ -298,15 +307,10 @@
 			} else {
 				curr_model_obj = findCurrentModel([...data.models, ...data.oldModels], curr_model);
 			}
-			console.log(curr_model);
-			console.log(curr_model_obj);
 			if (res != undefined) {
 				messages = res;
 				lastLoadedMessages = res;
 			}
 			id_now = randomUUID();
 		}
 	});
@@ -373,7 +377,7 @@
 	on:retry={(event) => writeMessage(event.detail.content, event.detail.id)}
 	on:vote={(event) => voteMessage(event.detail.score, event.detail.id)}
 	on:share={() => shareConversation($page.params.id, data.title)}
-	on:stop={() => (isAborted = true)}
 	models={data.models}
 	currentModel={findCurrentModel([...data.models, ...data.oldModels], curr_model)}
 	settings={data.settings}

 	import type { Message } from "$lib/types/Message";
 	import { PUBLIC_APP_DISCLAIMER } from "$env/static/public";
 	import { pipeline, Pipeline, env as env_transformers } from "@xenova/transformers";
+	import { isloading_writable, curr_model_writable, is_init_writable, cancel_writable } from "../../LayoutWritable.js";
+	import { map_writable, phi_writable } from "$lib/components/LoadingModalWritable.js";
 	import { params_writable } from "./ParamsWritable.js";
 	import { addMessageToChat, getChats, getMessages, getTitle, getModel } from "../../LocalDB.js";
 	import { env } from "$env/dynamic/public";
 	let webSearchMessages: WebSearchMessage[] = [];
 	let loading = false;
 	let pending = false;
 	let loginRequired = false;
 	// Create a callback function for messages from the worker thread.
 	const onMessageReceived = (e) => {
+		console.log(e)
 		let lastMessage: any = undefined;
 		switch (e.data.status) {
 			case "initiate":
 			case "progress":
 				isloading_writable.set(true);
+				if (e.data.no_progress_bar == undefined || e.data.no_progress_bar == false) {
+					map_writable.set([e.data.file, e.data.progress]);
+				}
+				else {
+					map_writable.set(["phi", "-1"])
+				}
+				break;
+			case "init_model":
+				phi_writable.set(true);
 				break;
 			case "done":
 			case "ready":
 				isloading_writable.set(false);
+				is_init_writable.set(false);
+				phi_writable.set(false);
 				break;
 			case "update":
 					lastMessage.updatedAt = new Date();
 					messages = [...messages];
 				}
+				else {
+					pipelineWorker.postMessage({ command: "abort" })
+				}
 				break;
+			case "aborted":
 			case "complete":
 				if (e.data.id_now == id_now) {
 					lastMessage = messages[messages.length - 1];
 		let opt = "";
 		messages = [
 			...messages,
 			// id doesn't match the backend id but it's not important for assistant messages
 		let lastMessage = messages[messages.length - 1];
 		pipelineWorker.postMessage({
+			is_phi: curr_model_obj.is_phi ?? false,
 			id_now: id_now,
 			task: curr_model_obj.type,
 			max_new_tokens: curr_model_obj.parameters?.max_new_tokens ?? 256,
 			}
 			console.error(err);
 		} finally {
+			loading = curr_model_obj.is_phi ?? false;
 			pending = false;
 		}
 	}
 			} else {
 				curr_model_obj = findCurrentModel([...data.models, ...data.oldModels], curr_model);
 			}
 			if (res != undefined) {
 				messages = res;
 				lastLoadedMessages = res;
 			}
 			id_now = randomUUID();
 		}
 	});
 	on:retry={(event) => writeMessage(event.detail.content, event.detail.id)}
 	on:vote={(event) => voteMessage(event.detail.score, event.detail.id)}
 	on:share={() => shareConversation($page.params.id, data.title)}
+	on:stop={() => (isAborted = true, pipelineWorker.postMessage({ command: "abort" }))}
 	models={data.models}
 	currentModel={findCurrentModel([...data.models, ...data.oldModels], curr_model)}
 	settings={data.settings}

src/routes/conversation/[id]/phi/m.d.ts ADDED Viewed

	@@ -0,0 +1,65 @@

+/* tslint:disable */
+/* eslint-disable */
+/**
+*/
+export class Model {
+    free(): void;
+  /**
+  * @param {Uint8Array} weights
+  * @param {Uint8Array} tokenizer
+  * @param {boolean} quantized
+  */
+    constructor(weights: Uint8Array, tokenizer: Uint8Array, quantized: boolean);
+  /**
+  * @param {string} prompt
+  * @param {number} temp
+  * @param {number} top_p
+  * @param {number} repeat_penalty
+  * @param {number} repeat_last_n
+  * @param {bigint} seed
+  * @returns {string}
+  */
+    init_with_prompt(prompt: string, temp: number, top_p: number, repeat_penalty: number, repeat_last_n: number, seed: bigint): string;
+  /**
+  * @returns {string}
+  */
+    next_token(): string;
+  }
+  export type InitInput = RequestInfo | URL | Response | BufferSource | WebAssembly.Module;
+  export interface InitOutput {
+    readonly memory: WebAssembly.Memory;
+    readonly __wbg_model_free: (a: number) => void;
+    readonly model_load: (a: number, b: number, c: number, d: number, e: number, f: number) => void;
+    readonly model_init_with_prompt: (a: number, b: number, c: number, d: number, e: number, f: number, g: number, h: number, i: number) => void;
+    readonly model_next_token: (a: number, b: number) => void;
+    readonly main: (a: number, b: number) => number;
+    readonly __wbindgen_add_to_stack_pointer: (a: number) => number;
+    readonly __wbindgen_malloc: (a: number, b: number) => number;
+    readonly __wbindgen_realloc: (a: number, b: number, c: number, d: number) => number;
+    readonly __wbindgen_free: (a: number, b: number, c: number) => void;
+    readonly __wbindgen_exn_store: (a: number) => void;
+    readonly __wbindgen_start: () => void;
+  }
+  export type SyncInitInput = BufferSource | WebAssembly.Module;
+  /**
+  * Instantiates the given `module`, which can either be bytes or
+  * a precompiled `WebAssembly.Module`.
+  *
+  * @param {SyncInitInput} module
+  *
+  * @returns {InitOutput}
+  */
+  export function initSync(module: SyncInitInput): InitOutput;
+  /**
+  * If `module_or_path` is {RequestInfo} or {URL}, makes a request and
+  * for everything else, calls `WebAssembly.instantiate` directly.
+  *
+  * @param {InitInput | Promise<InitInput>} module_or_path
+  *
+  * @returns {Promise<InitOutput>}
+  */
+  export default function __wbg_init (module_or_path?: InitInput | Promise<InitInput>): Promise<InitOutput>;

src/routes/conversation/[id]/phi/m.js ADDED Viewed

	@@ -0,0 +1,476 @@

+let wasm;
+const cachedTextDecoder = (typeof TextDecoder !== 'undefined' ? new TextDecoder('utf-8', { ignoreBOM: true, fatal: true }) : { decode: () => { throw Error('TextDecoder not available') } } );
+if (typeof TextDecoder !== 'undefined') { cachedTextDecoder.decode(); };
+let cachedUint8Memory0 = null;
+function getUint8Memory0() {
+    if (cachedUint8Memory0 === null || cachedUint8Memory0.byteLength === 0) {
+        cachedUint8Memory0 = new Uint8Array(wasm.memory.buffer);
+    }
+    return cachedUint8Memory0;
+}
+function getStringFromWasm0(ptr, len) {
+    ptr = ptr >>> 0;
+    return cachedTextDecoder.decode(getUint8Memory0().subarray(ptr, ptr + len));
+}
+const heap = new Array(128).fill(undefined);
+heap.push(undefined, null, true, false);
+let heap_next = heap.length;
+function addHeapObject(obj) {
+    if (heap_next === heap.length) heap.push(heap.length + 1);
+    const idx = heap_next;
+    heap_next = heap[idx];
+    heap[idx] = obj;
+    return idx;
+}
+function getObject(idx) { return heap[idx]; }
+function dropObject(idx) {
+    if (idx < 132) return;
+    heap[idx] = heap_next;
+    heap_next = idx;
+}
+function takeObject(idx) {
+    const ret = getObject(idx);
+    dropObject(idx);
+    return ret;
+}
+let WASM_VECTOR_LEN = 0;
+function passArray8ToWasm0(arg, malloc) {
+    const ptr = malloc(arg.length * 1, 1) >>> 0;
+    getUint8Memory0().set(arg, ptr / 1);
+    WASM_VECTOR_LEN = arg.length;
+    return ptr;
+}
+let cachedInt32Memory0 = null;
+function getInt32Memory0() {
+    if (cachedInt32Memory0 === null || cachedInt32Memory0.byteLength === 0) {
+        cachedInt32Memory0 = new Int32Array(wasm.memory.buffer);
+    }
+    return cachedInt32Memory0;
+}
+const cachedTextEncoder = (typeof TextEncoder !== 'undefined' ? new TextEncoder('utf-8') : { encode: () => { throw Error('TextEncoder not available') } } );
+const encodeString = (typeof cachedTextEncoder.encodeInto === 'function'
+    ? function (arg, view) {
+    return cachedTextEncoder.encodeInto(arg, view);
+}
+    : function (arg, view) {
+    const buf = cachedTextEncoder.encode(arg);
+    view.set(buf);
+    return {
+        read: arg.length,
+        written: buf.length
+    };
+});
+function passStringToWasm0(arg, malloc, realloc) {
+    if (realloc === undefined) {
+        const buf = cachedTextEncoder.encode(arg);
+        const ptr = malloc(buf.length, 1) >>> 0;
+        getUint8Memory0().subarray(ptr, ptr + buf.length).set(buf);
+        WASM_VECTOR_LEN = buf.length;
+        return ptr;
+    }
+    let len = arg.length;
+    let ptr = malloc(len, 1) >>> 0;
+    const mem = getUint8Memory0();
+    let offset = 0;
+    for (; offset < len; offset++) {
+        const code = arg.charCodeAt(offset);
+        if (code > 0x7F) break;
+        mem[ptr + offset] = code;
+    }
+    if (offset !== len) {
+        if (offset !== 0) {
+            arg = arg.slice(offset);
+        }
+        ptr = realloc(ptr, len, len = offset + arg.length * 3, 1) >>> 0;
+        const view = getUint8Memory0().subarray(ptr + offset, ptr + len);
+        const ret = encodeString(arg, view);
+        offset += ret.written;
+    }
+    WASM_VECTOR_LEN = offset;
+    return ptr;
+}
+function handleError(f, args) {
+    try {
+        return f.apply(this, args);
+    } catch (e) {
+        wasm.__wbindgen_exn_store(addHeapObject(e));
+    }
+}
+/**
+*/
+export class Model {
+    static __wrap(ptr) {
+        ptr = ptr >>> 0;
+        const obj = Object.create(Model.prototype);
+        obj.__wbg_ptr = ptr;
+        return obj;
+    }
+    __destroy_into_raw() {
+        const ptr = this.__wbg_ptr;
+        this.__wbg_ptr = 0;
+        return ptr;
+    }
+    free() {
+        const ptr = this.__destroy_into_raw();
+        wasm.__wbg_model_free(ptr);
+    }
+    /**
+    * @param {Uint8Array} weights
+    * @param {Uint8Array} tokenizer
+    * @param {boolean} quantized
+    */
+    constructor(weights, tokenizer, quantized) {
+        try {
+            const retptr = wasm.__wbindgen_add_to_stack_pointer(-16);
+            const ptr0 = passArray8ToWasm0(weights, wasm.__wbindgen_malloc);
+            const len0 = WASM_VECTOR_LEN;
+            const ptr1 = passArray8ToWasm0(tokenizer, wasm.__wbindgen_malloc);
+            const len1 = WASM_VECTOR_LEN;
+            wasm.model_load(retptr, ptr0, len0, ptr1, len1, quantized);
+            var r0 = getInt32Memory0()[retptr / 4 + 0];
+            var r1 = getInt32Memory0()[retptr / 4 + 1];
+            var r2 = getInt32Memory0()[retptr / 4 + 2];
+            if (r2) {
+                throw takeObject(r1);
+            }
+            return Model.__wrap(r0);
+        } finally {
+            wasm.__wbindgen_add_to_stack_pointer(16);
+        }
+    }
+    /**
+    * @param {string} prompt
+    * @param {number} temp
+    * @param {number} top_p
+    * @param {number} repeat_penalty
+    * @param {number} repeat_last_n
+    * @param {bigint} seed
+    * @returns {string}
+    */
+    init_with_prompt(prompt, temp, top_p, repeat_penalty, repeat_last_n, seed) {
+        let deferred3_0;
+        let deferred3_1;
+        try {
+            const retptr = wasm.__wbindgen_add_to_stack_pointer(-16);
+            const ptr0 = passStringToWasm0(prompt, wasm.__wbindgen_malloc, wasm.__wbindgen_realloc);
+            const len0 = WASM_VECTOR_LEN;
+            wasm.model_init_with_prompt(retptr, this.__wbg_ptr, ptr0, len0, temp, top_p, repeat_penalty, repeat_last_n, seed);
+            var r0 = getInt32Memory0()[retptr / 4 + 0];
+            var r1 = getInt32Memory0()[retptr / 4 + 1];
+            var r2 = getInt32Memory0()[retptr / 4 + 2];
+            var r3 = getInt32Memory0()[retptr / 4 + 3];
+            var ptr2 = r0;
+            var len2 = r1;
+            if (r3) {
+                ptr2 = 0; len2 = 0;
+                throw takeObject(r2);
+            }
+            deferred3_0 = ptr2;
+            deferred3_1 = len2;
+            return getStringFromWasm0(ptr2, len2);
+        } finally {
+            wasm.__wbindgen_add_to_stack_pointer(16);
+            wasm.__wbindgen_free(deferred3_0, deferred3_1, 1);
+        }
+    }
+    /**
+    * @returns {string}
+    */
+    next_token() {
+        let deferred2_0;
+        let deferred2_1;
+        try {
+            const retptr = wasm.__wbindgen_add_to_stack_pointer(-16);
+            wasm.model_next_token(retptr, this.__wbg_ptr);
+            var r0 = getInt32Memory0()[retptr / 4 + 0];
+            var r1 = getInt32Memory0()[retptr / 4 + 1];
+            var r2 = getInt32Memory0()[retptr / 4 + 2];
+            var r3 = getInt32Memory0()[retptr / 4 + 3];
+            var ptr1 = r0;
+            var len1 = r1;
+            if (r3) {
+                ptr1 = 0; len1 = 0;
+                throw takeObject(r2);
+            }
+            deferred2_0 = ptr1;
+            deferred2_1 = len1;
+            return getStringFromWasm0(ptr1, len1);
+        } finally {
+            wasm.__wbindgen_add_to_stack_pointer(16);
+            wasm.__wbindgen_free(deferred2_0, deferred2_1, 1);
+        }
+    }
+}
+async function __wbg_load(module, imports) {
+    if (typeof Response === 'function' && module instanceof Response) {
+        if (typeof WebAssembly.instantiateStreaming === 'function') {
+            try {
+                return await WebAssembly.instantiateStreaming(module, imports);
+            } catch (e) {
+                if (module.headers.get('Content-Type') != 'application/wasm') {
+                    console.warn("`WebAssembly.instantiateStreaming` failed because your server does not serve wasm with `application/wasm` MIME type. Falling back to `WebAssembly.instantiate` which is slower. Original error:\n", e);
+                } else {
+                    throw e;
+                }
+            }
+        }
+        const bytes = await module.arrayBuffer();
+        return await WebAssembly.instantiate(bytes, imports);
+    } else {
+        const instance = await WebAssembly.instantiate(module, imports);
+        if (instance instanceof WebAssembly.Instance) {
+            return { instance, module };
+        } else {
+            return instance;
+        }
+    }
+}
+function __wbg_get_imports() {
+    const imports = {};
+    imports.wbg = {};
+    imports.wbg.__wbindgen_error_new = function(arg0, arg1) {
+        const ret = new Error(getStringFromWasm0(arg0, arg1));
+        return addHeapObject(ret);
+    };
+    imports.wbg.__wbg_new_abda76e883ba8a5f = function() {
+        const ret = new Error();
+        return addHeapObject(ret);
+    };
+    imports.wbg.__wbg_stack_658279fe44541cf6 = function(arg0, arg1) {
+        const ret = getObject(arg1).stack;
+        const ptr1 = passStringToWasm0(ret, wasm.__wbindgen_malloc, wasm.__wbindgen_realloc);
+        const len1 = WASM_VECTOR_LEN;
+        getInt32Memory0()[arg0 / 4 + 1] = len1;
+        getInt32Memory0()[arg0 / 4 + 0] = ptr1;
+    };
+    imports.wbg.__wbg_error_f851667af71bcfc6 = function(arg0, arg1) {
+        let deferred0_0;
+        let deferred0_1;
+        try {
+            deferred0_0 = arg0;
+            deferred0_1 = arg1;
+            console.error(getStringFromWasm0(arg0, arg1));
+        } finally {
+            wasm.__wbindgen_free(deferred0_0, deferred0_1, 1);
+        }
+    };
+    imports.wbg.__wbindgen_object_drop_ref = function(arg0) {
+        takeObject(arg0);
+    };
+    imports.wbg.__wbg_log_ff7e0b5e6573cdff = function(arg0, arg1) {
+        console.log(getStringFromWasm0(arg0, arg1));
+    };
+    imports.wbg.__wbg_crypto_c48a774b022d20ac = function(arg0) {
+        const ret = getObject(arg0).crypto;
+        return addHeapObject(ret);
+    };
+    imports.wbg.__wbindgen_is_object = function(arg0) {
+        const val = getObject(arg0);
+        const ret = typeof(val) === 'object' && val !== null;
+        return ret;
+    };
+    imports.wbg.__wbg_process_298734cf255a885d = function(arg0) {
+        const ret = getObject(arg0).process;
+        return addHeapObject(ret);
+    };
+    imports.wbg.__wbg_versions_e2e78e134e3e5d01 = function(arg0) {
+        const ret = getObject(arg0).versions;
+        return addHeapObject(ret);
+    };
+    imports.wbg.__wbg_node_1cd7a5d853dbea79 = function(arg0) {
+        const ret = getObject(arg0).node;
+        return addHeapObject(ret);
+    };
+    imports.wbg.__wbindgen_is_string = function(arg0) {
+        const ret = typeof(getObject(arg0)) === 'string';
+        return ret;
+    };
+    imports.wbg.__wbg_msCrypto_bcb970640f50a1e8 = function(arg0) {
+        const ret = getObject(arg0).msCrypto;
+        return addHeapObject(ret);
+    };
+    imports.wbg.__wbg_require_8f08ceecec0f4fee = function() { return handleError(function () {
+        const ret = module.require;
+        return addHeapObject(ret);
+    }, arguments) };
+    imports.wbg.__wbindgen_is_function = function(arg0) {
+        const ret = typeof(getObject(arg0)) === 'function';
+        return ret;
+    };
+    imports.wbg.__wbindgen_string_new = function(arg0, arg1) {
+        const ret = getStringFromWasm0(arg0, arg1);
+        return addHeapObject(ret);
+    };
+    imports.wbg.__wbg_getRandomValues_37fa2ca9e4e07fab = function() { return handleError(function (arg0, arg1) {
+        getObject(arg0).getRandomValues(getObject(arg1));
+    }, arguments) };
+    imports.wbg.__wbg_randomFillSync_dc1e9a60c158336d = function() { return handleError(function (arg0, arg1) {
+        getObject(arg0).randomFillSync(takeObject(arg1));
+    }, arguments) };
+    imports.wbg.__wbg_newnoargs_581967eacc0e2604 = function(arg0, arg1) {
+        const ret = new Function(getStringFromWasm0(arg0, arg1));
+        return addHeapObject(ret);
+    };
+    imports.wbg.__wbg_call_cb65541d95d71282 = function() { return handleError(function (arg0, arg1) {
+        const ret = getObject(arg0).call(getObject(arg1));
+        return addHeapObject(ret);
+    }, arguments) };
+    imports.wbg.__wbindgen_object_clone_ref = function(arg0) {
+        const ret = getObject(arg0);
+        return addHeapObject(ret);
+    };
+    imports.wbg.__wbg_self_1ff1d729e9aae938 = function() { return handleError(function () {
+        const ret = self.self;
+        return addHeapObject(ret);
+    }, arguments) };
+    imports.wbg.__wbg_window_5f4faef6c12b79ec = function() { return handleError(function () {
+        const ret = window.window;
+        return addHeapObject(ret);
+    }, arguments) };
+    imports.wbg.__wbg_globalThis_1d39714405582d3c = function() { return handleError(function () {
+        const ret = globalThis.globalThis;
+        return addHeapObject(ret);
+    }, arguments) };
+    imports.wbg.__wbg_global_651f05c6a0944d1c = function() { return handleError(function () {
+        const ret = global.global;
+        return addHeapObject(ret);
+    }, arguments) };
+    imports.wbg.__wbindgen_is_undefined = function(arg0) {
+        const ret = getObject(arg0) === undefined;
+        return ret;
+    };
+    imports.wbg.__wbg_call_01734de55d61e11d = function() { return handleError(function (arg0, arg1, arg2) {
+        const ret = getObject(arg0).call(getObject(arg1), getObject(arg2));
+        return addHeapObject(ret);
+    }, arguments) };
+    imports.wbg.__wbg_now_9c5990bda04c7e53 = function() {
+        const ret = Date.now();
+        return ret;
+    };
+    imports.wbg.__wbg_buffer_085ec1f694018c4f = function(arg0) {
+        const ret = getObject(arg0).buffer;
+        return addHeapObject(ret);
+    };
+    imports.wbg.__wbg_newwithbyteoffsetandlength_6da8e527659b86aa = function(arg0, arg1, arg2) {
+        const ret = new Uint8Array(getObject(arg0), arg1 >>> 0, arg2 >>> 0);
+        return addHeapObject(ret);
+    };
+    imports.wbg.__wbg_new_8125e318e6245eed = function(arg0) {
+        const ret = new Uint8Array(getObject(arg0));
+        return addHeapObject(ret);
+    };
+    imports.wbg.__wbg_set_5cf90238115182c3 = function(arg0, arg1, arg2) {
+        getObject(arg0).set(getObject(arg1), arg2 >>> 0);
+    };
+    imports.wbg.__wbg_newwithlength_e5d69174d6984cd7 = function(arg0) {
+        const ret = new Uint8Array(arg0 >>> 0);
+        return addHeapObject(ret);
+    };
+    imports.wbg.__wbg_subarray_13db269f57aa838d = function(arg0, arg1, arg2) {
+        const ret = getObject(arg0).subarray(arg1 >>> 0, arg2 >>> 0);
+        return addHeapObject(ret);
+    };
+    imports.wbg.__wbindgen_throw = function(arg0, arg1) {
+        throw new Error(getStringFromWasm0(arg0, arg1));
+    };
+    imports.wbg.__wbindgen_memory = function() {
+        const ret = wasm.memory;
+        return addHeapObject(ret);
+    };
+    return imports;
+}
+function __wbg_init_memory(imports, maybe_memory) {
+}
+function __wbg_finalize_init(instance, module) {
+    wasm = instance.exports;
+    __wbg_init.__wbindgen_wasm_module = module;
+    cachedInt32Memory0 = null;
+    cachedUint8Memory0 = null;
+    wasm.__wbindgen_start();
+    return wasm;
+}
+function initSync(module) {
+    if (wasm !== undefined) return wasm;
+    const imports = __wbg_get_imports();
+    __wbg_init_memory(imports);
+    if (!(module instanceof WebAssembly.Module)) {
+        module = new WebAssembly.Module(module);
+    }
+    const instance = new WebAssembly.Instance(module, imports);
+    return __wbg_finalize_init(instance, module);
+}
+async function __wbg_init(input) {
+    if (wasm !== undefined) return wasm;
+    if (typeof input === 'undefined') {
+        input = new URL('m_bg.wasm', import.meta.url);
+    }
+    const imports = __wbg_get_imports();
+    if (typeof input === 'string' || (typeof Request === 'function' && input instanceof Request) || (typeof URL === 'function' && input instanceof URL)) {
+        input = fetch(input);
+    }
+    __wbg_init_memory(imports);
+    const { instance, module } = await __wbg_load(await input, imports);
+    return __wbg_finalize_init(instance, module);
+}
+export { initSync }
+export default __wbg_init;

src/routes/conversation/[id]/phi/m_bg.wasm ADDED Viewed

	@@ -0,0 +1,3 @@

+version https://git-lfs.github.com/spec/v1
+oid sha256:4f38c8d88da95e96b33813a5e6f0479028ec4c550ea4a055082d2c5ff129605f
+size 4368129

src/routes/conversation/[id]/phi/m_bg.wasm.d.ts ADDED Viewed

	@@ -0,0 +1,14 @@

+/* tslint:disable */
+/* eslint-disable */
+export const memory: WebAssembly.Memory;
+export function __wbg_model_free(a: number): void;
+export function model_load(a: number, b: number, c: number, d: number, e: number, f: number): void;
+export function model_init_with_prompt(a: number, b: number, c: number, d: number, e: number, f: number, g: number, h: number, i: number): void;
+export function model_next_token(a: number, b: number): void;
+export function main(a: number, b: number): number;
+export function __wbindgen_add_to_stack_pointer(a: number): number;
+export function __wbindgen_malloc(a: number, b: number): number;
+export function __wbindgen_realloc(a: number, b: number, c: number, d: number): number;
+export function __wbindgen_free(a: number, b: number, c: number): void;
+export function __wbindgen_exn_store(a: number): void;
+export function __wbindgen_start(): void;

src/routes/conversation/[id]/worker.js CHANGED Viewed

@@ -1,4 +1,48 @@
 import { pipeline, env } from "@xenova/transformers";
 export class FlanPipeline {
 	static curr_model = "";
@@ -18,33 +62,135 @@ export class FlanPipeline {
 	}
 }
 // Listen for messages from the main thread
 self.addEventListener("message", async (event) => {
-	let pipe = await FlanPipeline.getInstance(
-		(x) => {
-			self.postMessage(x);
-		},
-		event.data.model,
-		event.data.task
-	);
-	let output = await pipe(event.data.text, {
-		max_new_tokens: event.data.max_new_tokens,
-		temperature: event.data.temperature,
-		callback_function: (x) => {
 			self.postMessage({
-				status: "update",
-				output: pipe.tokenizer.decode(x[0].output_token_ids, { skip_special_tokens: true }),
 				id_now: event.data.id_now,
 			});
-		},
-	});
-	// Send the output back to the main thread
-	self.postMessage({
 		status: "complete",
-		output: output,
-		searchID: event.data.searchID,
-		id_now: event.data.id_now,
-	});
-});

 import { pipeline, env } from "@xenova/transformers";
+import init, { Model } from "./phi/m.js";
+async function fetchArrayBuffer(url) {
+	const cacheName = "phi-mixformer-candle-cache";
+	const cache = await caches.open(cacheName);
+	const cachedResponse = await cache.match(url);
+	if (cachedResponse) {
+	  const data = await cachedResponse.arrayBuffer();
+	  return new Uint8Array(data);
+	}
+	const res = await fetch(url, { cache: "force-cache" });
+	cache.put(url, res.clone());
+	return new Uint8Array(await res.arrayBuffer());
+}
+class Phi {
+	static instance = {};
+	static async getInstance(weightsURL, modelID, tokenizerURL, quantized) {
+	  // load individual modelID only once
+	  if (!this.instance[modelID]) {
+		await init();
+		self.postMessage({ status: "loading", message: "Loading Model" });
+		self.postMessage({ status: "progress", file: "model-q4k.gguf", no_progress_bar: true, message: "Starting Phi" });
+		const [weightsArrayU8, tokenizerArrayU8] = await Promise.all([
+		  fetchArrayBuffer(weightsURL),
+		  fetchArrayBuffer(tokenizerURL),
+		]);
+		self.postMessage({ status: "init_model" });
+		this.instance[modelID] = new Model(
+		  weightsArrayU8,
+		  tokenizerArrayU8,
+		  quantized
+		);
+		self.postMessage({ status: "ready" });
+	  }
+	  return this.instance[modelID];
+	}
+ }
 export class FlanPipeline {
 	static curr_model = "";
 	}
 }
+let controller = null;
 // Listen for messages from the main thread
 self.addEventListener("message", async (event) => {
+	if (event.data.command != "abort") {
+		if (event.data.is_phi) {
+			controller = new AbortController();
+			generate_phi(event.data);
+		}
+		else {
+			let pipe = await FlanPipeline.getInstance(
+				(x) => {
+					self.postMessage(x);
+				},
+				event.data.model,
+				event.data.task
+			);
+			let output = await pipe(event.data.text, {
+				max_new_tokens: event.data.max_new_tokens,
+				temperature: event.data.temperature,
+				callback_function: (x) => {
+					self.postMessage({
+						status: "update",
+						output: pipe.tokenizer.decode(x[0].output_token_ids, { skip_special_tokens: true }),
+						id_now: event.data.id_now,
+					});
+				},
+			});
+			// Send the output back to the main thread
 			self.postMessage({
+				status: "complete",
+				output: output,
+				searchID: event.data.searchID,
 				id_now: event.data.id_now,
 			});
+		}
+	}
+	else {
+		if (controller != null)
+			controller.abort();
+	}
+});
+async function generate_phi(data) {
+	const tokenizerURL = "https://huggingface.co/microsoft/phi-1_5/raw/main/tokenizer.json";
+	const weightsURL = "https://huggingface.co/lmz/candle-quantized-phi/resolve/main/model-q4k.gguf";
+	let prompt = data.text
+	let maxSeqLen = data.max_new_tokens
+	let temp = data.temperature
+	let modelID = 0;
+	let quantized = true;
+	let top_p = 1;
+	let repeatPenalty = 1.1;
+	let seed = 299792458;
+	try {
+	  const model = await Phi.getInstance(
+		weightsURL,
+		modelID,
+		tokenizerURL,
+		quantized
+	  );
+	  const firstToken = model.init_with_prompt(
+		prompt,
+		temp,
+		top_p,
+		repeatPenalty,
+		64,
+		BigInt(seed)
+	  );
+	  const seq_len = 2048;
+	  let sentence = firstToken;
+	  let maxTokens = maxSeqLen ? maxSeqLen : seq_len - prompt.length - 1;
+	  let startTime = performance.now();
+	  let tokensCount = 0;
+	  while (tokensCount < maxTokens) {
+		await new Promise(async (resolve) => {
+		  if (controller && controller.signal.aborted) {
+			self.postMessage({
+			  status: "aborted",
+			  message: "Aborted",
+			  output: sentence,
+			  searchID: data.searchID,
+			  id_now: data.id_now,
+			});
+			return;
+		  }
+		  const token = await model.next_token();
+		  if (token === "<|endoftext|>") {
+			self.postMessage({
+			  status: "complete",
+			  output: sentence,
+			  searchID: data.searchID,
+			  id_now: data.id_now,
+			});
+			return;
+		  }
+		  const tokensSec =
+			((tokensCount + 1) / (performance.now() - startTime)) * 1000;
+		  sentence += token;
+		  self.postMessage({
+			status: "update",
+			message: "Generating token",
+			token: token,
+			output: sentence,
+			totalTime: performance.now() - startTime,
+			tokensSec,
+			prompt: prompt,
+			id_now: data.id_now,
+		  });
+		  setTimeout(resolve, 0);
+		});
+		tokensCount++;
+	  }
+	  self.postMessage({
 		status: "complete",
+		output: sentence,
+		searchID: data.searchID,
+		id_now: data.id_now,
+	  });
+	} catch (e) {
+      console.log(e)
+	  self.postMessage({ error: e });
+	}
+  }