Val Town Code SearchReturn to Val Town

6
71. Sign up for [Cerebras](https://cloud.cerebras.ai/)
82. Get a Cerebras API Key
93. Save it in a [Val Town environment variable](https://www.val.town/settings/environment-variables) called `CEREBRAS_API_KEY`

73  const menuRef = useRef(null);
74  const isPublic = blob.key.startsWith("__public/");
75  const publicUrl = isPublic ? `${window.location.origin}/api/public/${encodeURIComponent(blob.key.slice(9))}` : null;
76
77  useEffect(() => {
237    setLoading(true);
238    try {
239      const response = await fetch(`/api/blobs?prefix=${encodeKey(searchPrefix)}&limit=${limit}`);
240      const data = await response.json();
241      setBlobs(data);
264      setBlobContentLoading(true);
265      try {
266        const response = await fetch(`/api/blob?key=${encodeKey(clickedBlob.key)}`);
267        const content = await response.text();
268        setSelectedBlob({ ...clickedBlob, key: decodeKey(clickedBlob.key) });
278  const handleSave = async () => {
279    try {
280      await fetch(`/api/blob?key=${encodeKey(selectedBlob.key)}`, {
281        method: "PUT",
282        body: editContent,
290  const handleDelete = async (key) => {
291    try {
292      await fetch(`/api/blob?key=${encodeKey(key)}`, { method: "DELETE" });
293      setBlobs(blobs.filter(b => b.key !== key));
294      if (selectedBlob && selectedBlob.key === key) {
307        const key = `${searchPrefix}${file.name}`;
308        formData.append("key", encodeKey(key));
309        await fetch("/api/blob", { method: "POST", body: formData });
310        const newBlob = { key, size: file.size, lastModified: new Date().toISOString() };
311        setBlobs([newBlob, ...blobs]);
329      try {
330        const fullKey = `${searchPrefix}${key}`;
331        await fetch(`/api/blob?key=${encodeKey(fullKey)}`, {
332          method: "PUT",
333          body: "",
344  const handleDownload = async (key) => {
345    try {
346      const response = await fetch(`/api/blob?key=${encodeKey(key)}`);
347      const blob = await response.blob();
348      const url = window.URL.createObjectURL(blob);
363    if (newKey && newKey !== oldKey) {
364      try {
365        const response = await fetch(`/api/blob?key=${encodeKey(oldKey)}`);
366        const content = await response.blob();
367        await fetch(`/api/blob?key=${encodeKey(newKey)}`, {
368          method: "PUT",
369          body: content,
370        });
371        await fetch(`/api/blob?key=${encodeKey(oldKey)}`, { method: "DELETE" });
372        setBlobs(blobs.map(b => b.key === oldKey ? { ...b, key: newKey } : b));
373        if (selectedBlob && selectedBlob.key === oldKey) {
383    const newKey = `__public/${key}`;
384    try {
385      const response = await fetch(`/api/blob?key=${encodeKey(key)}`);
386      const content = await response.blob();
387      await fetch(`/api/blob?key=${encodeKey(newKey)}`, {
388        method: "PUT",
389        body: content,
390      });
391      await fetch(`/api/blob?key=${encodeKey(key)}`, { method: "DELETE" });
392      setBlobs(blobs.map(b => b.key === key ? { ...b, key: newKey } : b));
393      if (selectedBlob && selectedBlob.key === key) {
402    const newKey = key.slice(9); // Remove "__public/" prefix
403    try {
404      const response = await fetch(`/api/blob?key=${encodeKey(key)}`);
405      const content = await response.blob();
406      await fetch(`/api/blob?key=${encodeKey(newKey)}`, {
407        method: "PUT",
408        body: content,
409      });
410      await fetch(`/api/blob?key=${encodeKey(key)}`, { method: "DELETE" });
411      setBlobs(blobs.map(b => b.key === key ? { ...b, key: newKey } : b));
412      if (selectedBlob && selectedBlob.key === key) {
557                        onClick={() =>
558                          copyToClipboard(
559                            `${window.location.origin}/api/public/${encodeURIComponent(selectedBlob.key.slice(9))}`,
560                          )}
561                        className="text-blue-400 hover:text-blue-300 text-sm"
580                        >
581                          <img
582                            src={`/api/blob?key=${encodeKey(selectedBlob.key)}`}
583                            alt="Blob content"
584                            className="max-w-full h-auto"
660
661// Public route without authentication
662app.get("/api/public/:id", async (c) => {
663  const key = `__public/${c.req.param("id")}`;
664  const { blob } = await import("https://esm.town/v/std/blob");
766};
767
768app.get("/api/blobs", checkAuth, async (c) => {
769  const prefix = c.req.query("prefix") || "";
770  const limit = parseInt(c.req.query("limit") || "20", 10);
775});
776
777app.get("/api/blob", checkAuth, async (c) => {
778  const key = c.req.query("key");
779  if (!key) return c.text("Missing key parameter", 400);
783});
784
785app.put("/api/blob", checkAuth, async (c) => {
786  const key = c.req.query("key");
787  if (!key) return c.text("Missing key parameter", 400);
792});
793
794app.delete("/api/blob", checkAuth, async (c) => {
795  const key = c.req.query("key");
796  if (!key) return c.text("Missing key parameter", 400);
800});
801
802app.post("/api/blob", checkAuth, async (c) => {
803  const { file, key } = await c.req.parseBody();
804  if (!file || !key) return c.text("Missing file or key", 400);

20
212. Set up the required environment variables:
22   - OPENAI_API_KEY: Your OpenAI API key
23   - MD_API_KEY: Your API key for the markdown extraction service (optional)
24
25   You can set these using Val Town's environment variables: https://docs.val.town/reference/environment-variables/
45
46- PDFs: Text content will be extracted and analyzed
47- Images: Will be analyzed using GPT-4 Vision API
48- Websites: Content will be extracted and converted to markdown for analysis
49- Other file types are not currently supported and will be ignored
60// Main controller function
61export default async function emailValHandler(receivedEmail) {
62  const openaiUrl = "https://api.openai.com/v1/chat/completions";
63  const openaiKey = Deno.env.get("OPENAI_API_KEY");
64  const mdApiKey = Deno.env.get("MD_API_KEY");
65  const model = "o1-2024-12-17";
66
80  // Step 3: Process different types of content
81  const { pdfTexts, imageAnalysis } = await processAttachments(attachments, openaiKey, transformedPrompt);
82  const websiteMarkdown = await extractWebsiteMarkdown(links, mdApiKey);
83
84  // Step 4: Create final prompt with all context
123
124// Extract website markdown content
125async function extractWebsiteMarkdown(links, apiKey) {
126  const markdownResults = [];
127  const requestsPerMinute = 5;
139
140      console.log(`Fetching markdown for ${url}`);
141      console.log(`API Key present: ${!!apiKey}`);
142
143      const fetchUrl = `https://md.dhr.wtf/?url=${encodeURIComponent(url)}`;
148      };
149
150      // Only add headers if API key is available
151      if (apiKey) {
152        fetchOptions.headers = {
153          "Authorization": `Bearer ${apiKey}`,
154        };
155      }
177
178// Process image attachments with GPT-4V
179async function analyzeImage(imageAttachment, apiKey, transformedPrompt) {
180  try {
181    const response = await fetch("https://api.openai.com/v1/chat/completions", {
182      method: "POST",
183      headers: {
184        "Content-Type": "application/json",
185        "Authorization": `Bearer ${apiKey}`,
186      },
187      body: JSON.stringify({
221
222// Transform the original prompt using the prompt transformer
223async function transformPrompt(emailText, openaiUrl, apiKey, model) {
224  const promptTransformerText =
225    `You are an AI assistant tasked with transforming user queries into structured research or information requests. Your goal is to take a simple query and expand it into a comprehensive research objective with specific formatting requirements.
295      headers: {
296        "Content-Type": "application/json",
297        Authorization: `Bearer ${apiKey}`,
298      },
299    });
301    const data = await response.json();
302    if (data.error) {
303      throw new Error(`OpenAI API Error: ${data.error.message}`);
304    }
305    return data.choices[0]?.message?.content || emailText;
311
312// Process all attachments (PDFs and Images)
313async function processAttachments(attachments, apiKey, transformedPrompt) {
314  const pdfTexts = [];
315  const imageAnalysis = [];
320      pdfTexts.push(...pdfText);
321    } else if (attachment.type.startsWith("image/")) {
322      const analysis = await analyzeImage(attachment, apiKey, transformedPrompt);
323      imageAnalysis.push({
324        filename: attachment.filename,
388
389// Helper function to send a request to OpenAI
390async function sendRequestToOpenAI(prompt, transformedPrompt, openaiUrl, apiKey, model) {
391  try {
392    // Debug logging for the prompt and transformed prompt
423      headers: {
424        "Content-Type": "application/json",
425        Authorization: `Bearer ${apiKey}`,
426      },
427    });
430    const data = await response.json();
431    if (data.error) {
432      throw new Error(`OpenAI API Error: ${data.error.message}`);
433    }
434    return data.choices[0]?.message?.content || "No response from OpenAI.";

73  const menuRef = useRef(null);
74  const isPublic = blob.key.startsWith("__public/");
75  const publicUrl = isPublic ? `${window.location.origin}/api/public/${encodeURIComponent(blob.key.slice(9))}` : null;
76
77  useEffect(() => {
237    setLoading(true);
238    try {
239      const response = await fetch(`/api/blobs?prefix=${encodeKey(searchPrefix)}&limit=${limit}`);
240      const data = await response.json();
241      setBlobs(data);
264      setBlobContentLoading(true);
265      try {
266        const response = await fetch(`/api/blob?key=${encodeKey(clickedBlob.key)}`);
267        const content = await response.text();
268        setSelectedBlob({ ...clickedBlob, key: decodeKey(clickedBlob.key) });
278  const handleSave = async () => {
279    try {
280      await fetch(`/api/blob?key=${encodeKey(selectedBlob.key)}`, {
281        method: "PUT",
282        body: editContent,
290  const handleDelete = async (key) => {
291    try {
292      await fetch(`/api/blob?key=${encodeKey(key)}`, { method: "DELETE" });
293      setBlobs(blobs.filter(b => b.key !== key));
294      if (selectedBlob && selectedBlob.key === key) {
307        const key = `${searchPrefix}${file.name}`;
308        formData.append("key", encodeKey(key));
309        await fetch("/api/blob", { method: "POST", body: formData });
310        const newBlob = { key, size: file.size, lastModified: new Date().toISOString() };
311        setBlobs([newBlob, ...blobs]);
329      try {
330        const fullKey = `${searchPrefix}${key}`;
331        await fetch(`/api/blob?key=${encodeKey(fullKey)}`, {
332          method: "PUT",
333          body: "",
344  const handleDownload = async (key) => {
345    try {
346      const response = await fetch(`/api/blob?key=${encodeKey(key)}`);
347      const blob = await response.blob();
348      const url = window.URL.createObjectURL(blob);
363    if (newKey && newKey !== oldKey) {
364      try {
365        const response = await fetch(`/api/blob?key=${encodeKey(oldKey)}`);
366        const content = await response.blob();
367        await fetch(`/api/blob?key=${encodeKey(newKey)}`, {
368          method: "PUT",
369          body: content,
370        });
371        await fetch(`/api/blob?key=${encodeKey(oldKey)}`, { method: "DELETE" });
372        setBlobs(blobs.map(b => b.key === oldKey ? { ...b, key: newKey } : b));
373        if (selectedBlob && selectedBlob.key === oldKey) {
383    const newKey = `__public/${key}`;
384    try {
385      const response = await fetch(`/api/blob?key=${encodeKey(key)}`);
386      const content = await response.blob();
387      await fetch(`/api/blob?key=${encodeKey(newKey)}`, {
388        method: "PUT",
389        body: content,
390      });
391      await fetch(`/api/blob?key=${encodeKey(key)}`, { method: "DELETE" });
392      setBlobs(blobs.map(b => b.key === key ? { ...b, key: newKey } : b));
393      if (selectedBlob && selectedBlob.key === key) {
402    const newKey = key.slice(9); // Remove "__public/" prefix
403    try {
404      const response = await fetch(`/api/blob?key=${encodeKey(key)}`);
405      const content = await response.blob();
406      await fetch(`/api/blob?key=${encodeKey(newKey)}`, {
407        method: "PUT",
408        body: content,
409      });
410      await fetch(`/api/blob?key=${encodeKey(key)}`, { method: "DELETE" });
411      setBlobs(blobs.map(b => b.key === key ? { ...b, key: newKey } : b));
412      if (selectedBlob && selectedBlob.key === key) {
557                        onClick={() =>
558                          copyToClipboard(
559                            `${window.location.origin}/api/public/${encodeURIComponent(selectedBlob.key.slice(9))}`,
560                          )}
561                        className="text-blue-400 hover:text-blue-300 text-sm"
580                        >
581                          <img
582                            src={`/api/blob?key=${encodeKey(selectedBlob.key)}`}
583                            alt="Blob content"
584                            className="max-w-full h-auto"
660
661// Public route without authentication
662app.get("/api/public/:id", async (c) => {
663  const key = `__public/${c.req.param("id")}`;
664  const { blob } = await import("https://esm.town/v/std/blob");
766};
767
768app.get("/api/blobs", checkAuth, async (c) => {
769  const prefix = c.req.query("prefix") || "";
770  const limit = parseInt(c.req.query("limit") || "20", 10);
775});
776
777app.get("/api/blob", checkAuth, async (c) => {
778  const key = c.req.query("key");
779  if (!key) return c.text("Missing key parameter", 400);
783});
784
785app.put("/api/blob", checkAuth, async (c) => {
786  const key = c.req.query("key");
787  if (!key) return c.text("Missing key parameter", 400);
792});
793
794app.delete("/api/blob", checkAuth, async (c) => {
795  const key = c.req.query("key");
796  if (!key) return c.text("Missing key parameter", 400);
800});
801
802app.post("/api/blob", checkAuth, async (c) => {
803  const { file, key } = await c.req.parseBody();
804  if (!file || !key) return c.text("Missing file or key", 400);

1import process from "node:process";
2import { AppBskyFeedPost, AtpAgent } from "npm:@atproto/api";
3
4const agent = new AtpAgent({

6
71. Sign up for [Cerebras](https://cloud.cerebras.ai/)
82. Get a Cerebras API Key
93. Save it in a [Val Town environment variable](https://www.val.town/settings/environment-variables) called `CEREBRAS_API_KEY`

217    } catch (error) {
218      Toastify({
219        text: "We may have hit our Cerebras Usage limits. Try again later or fork this and use your own API key.",
220        position: "center",
221        duration: 3000,
970    };
971  } else {
972    const client = new Cerebras({ apiKey: Deno.env.get("CEREBRAS_API_KEY") });
973    const completion = await client.chat.completions.create({
974      messages: [
1095        <meta name="viewport" content="width=device-width, initial-scale=1.0">
1096        <title>CerebrasCoder</title>
1097        <link rel="preconnect" href="https://fonts.googleapis.com" />
1098        <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin />
1099        <link
1100          href="https://fonts.googleapis.com/css2?family=DM+Mono:ital,wght@0,300;0,400;0,500;1,300;1,400;1,500&family=DM+Sans:ital,opsz,wght@0,9..40,100..1000;1,9..40,100..1000&display=swap"
1101          rel="stylesheet"
1102        />
1111        <meta property="og:description" content="Turn your ideas into fully functional apps in less than a second – powered by Llama3.3-70b on Cerebras's super-fast wafer chips. Code is 100% open-source, hosted on Val Town."">
1112        <meta property="og:type" content="website">
1113        <meta property="og:image" content="https://stevekrouse-blob_admin.web.val.run/api/public/CerebrasCoderOG.jpg">
1114        
1115            

6
71. Sign up for [Cerebras](https://cloud.cerebras.ai/)
82. Get a Cerebras API Key
93. Save it in a [Val Town environment variable](https://www.val.town/settings/environment-variables) called `CEREBRAS_API_KEY`

217    } catch (error) {
218      Toastify({
219        text: "We may have hit our Cerebras Usage limits. Try again later or fork this and use your own API key.",
220        position: "center",
221        duration: 3000,
970    };
971  } else {
972    const client = new Cerebras({ apiKey: Deno.env.get("CEREBRAS_API_KEY") });
973    const completion = await client.chat.completions.create({
974      messages: [
1095        <meta name="viewport" content="width=device-width, initial-scale=1.0">
1096        <title>CerebrasCoder</title>
1097        <link rel="preconnect" href="https://fonts.googleapis.com" />
1098        <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin />
1099        <link
1100          href="https://fonts.googleapis.com/css2?family=DM+Mono:ital,wght@0,300;0,400;0,500;1,300;1,400;1,500&family=DM+Sans:ital,opsz,wght@0,9..40,100..1000;1,9..40,100..1000&display=swap"
1101          rel="stylesheet"
1102        />
1111        <meta property="og:description" content="Turn your ideas into fully functional apps in less than a second – powered by Llama3.3-70b on Cerebras's super-fast wafer chips. Code is 100% open-source, hosted on Val Town."">
1112        <meta property="og:type" content="website">
1113        <meta property="og:image" content="https://stevekrouse-blob_admin.web.val.run/api/public/CerebrasCoderOG.jpg">
1114        
1115            

6
71. Sign up for [Cerebras](https://cloud.cerebras.ai/)
82. Get a Cerebras API Key
93. Save it in a [Val Town environment variable](https://www.val.town/settings/environment-variables) called `CEREBRAS_API_KEY`