mirror of
				https://github.com/ChatGPTNextWeb/ChatGPT-Next-Web.git
				synced 2025-11-04 08:13:43 +08:00 
			
		
		
		
	using CacheStorage to store image #5013
This commit is contained in:
		@@ -29,7 +29,6 @@ import { AuthPage } from "./auth";
 | 
			
		||||
import { getClientConfig } from "../config/client";
 | 
			
		||||
import { type ClientApi, getClientApi } from "../client/api";
 | 
			
		||||
import { useAccessStore } from "../store";
 | 
			
		||||
import { initDB } from "react-indexed-db-hook";
 | 
			
		||||
 | 
			
		||||
export function Loading(props: { noLogo?: boolean }) {
 | 
			
		||||
  return (
 | 
			
		||||
 
 | 
			
		||||
@@ -4,12 +4,8 @@ import { Select, showToast } from "@/app/components/ui-lib";
 | 
			
		||||
import { IconButton } from "@/app/components/button";
 | 
			
		||||
import locales from "@/app/locales";
 | 
			
		||||
import { nanoid } from "nanoid";
 | 
			
		||||
import { useIndexedDB } from "react-indexed-db-hook";
 | 
			
		||||
import { StoreKey } from "@/app/constant";
 | 
			
		||||
import { useSdStore } from "@/app/store/sd";
 | 
			
		||||
import { FileDbInit } from "@/app/utils/file";
 | 
			
		||||
 | 
			
		||||
FileDbInit();
 | 
			
		||||
 | 
			
		||||
const sdCommonParams = (model: string, data: any) => {
 | 
			
		||||
  return [
 | 
			
		||||
@@ -287,7 +283,6 @@ export function SdPanel() {
 | 
			
		||||
    setCurrentModel(model);
 | 
			
		||||
    setParams(getModelParamBasicData(model.params({}), params));
 | 
			
		||||
  };
 | 
			
		||||
  const sdListDb = useIndexedDB(StoreKey.SdList);
 | 
			
		||||
  const sdStore = useSdStore();
 | 
			
		||||
  const handleSubmit = () => {
 | 
			
		||||
    const columns = currentModel.params(params);
 | 
			
		||||
@@ -310,7 +305,7 @@ export function SdPanel() {
 | 
			
		||||
      created_at: new Date().toLocaleString(),
 | 
			
		||||
      img_data: "",
 | 
			
		||||
    };
 | 
			
		||||
    sdStore.sendTask(data, sdListDb, () => {
 | 
			
		||||
    sdStore.sendTask(data, () => {
 | 
			
		||||
      setParams(getModelParamBasicData(columns, params, true));
 | 
			
		||||
    });
 | 
			
		||||
  };
 | 
			
		||||
 
 | 
			
		||||
@@ -30,8 +30,7 @@ import {
 | 
			
		||||
  showImageModal,
 | 
			
		||||
  showModal,
 | 
			
		||||
} from "@/app/components/ui-lib";
 | 
			
		||||
import { func } from "prop-types";
 | 
			
		||||
import { useFileDB, IndexDBImage } from "@/app/utils/file";
 | 
			
		||||
import { removeImage } from "@/app/utils/chat";
 | 
			
		||||
 | 
			
		||||
function getSdTaskStatus(item: any) {
 | 
			
		||||
  let s: string;
 | 
			
		||||
@@ -90,7 +89,6 @@ export function Sd() {
 | 
			
		||||
  const showMaxIcon = !isMobileScreen && !clientConfig?.isApp;
 | 
			
		||||
  const config = useAppConfig();
 | 
			
		||||
  const scrollRef = useRef<HTMLDivElement>(null);
 | 
			
		||||
  const fileDb = useFileDB();
 | 
			
		||||
  const sdStore = useSdStore();
 | 
			
		||||
  const [sdImages, setSdImages] = useState(sdStore.draw);
 | 
			
		||||
 | 
			
		||||
@@ -147,14 +145,13 @@ export function Sd() {
 | 
			
		||||
                  className={styles["sd-img-item"]}
 | 
			
		||||
                >
 | 
			
		||||
                  {item.status === "success" ? (
 | 
			
		||||
                    <IndexDBImage
 | 
			
		||||
                    <img
 | 
			
		||||
                      className={styles["img"]}
 | 
			
		||||
                      db={fileDb}
 | 
			
		||||
                      src={item.img_data}
 | 
			
		||||
                      alt={item.id}
 | 
			
		||||
                      onClick={(data: any, e: any) => {
 | 
			
		||||
                      onClick={(e) =>
 | 
			
		||||
                        showImageModal(
 | 
			
		||||
                          data,
 | 
			
		||||
                          item.img_data,
 | 
			
		||||
                          true,
 | 
			
		||||
                          isMobileScreen
 | 
			
		||||
                            ? { width: "100%", height: "fit-content" }
 | 
			
		||||
@@ -162,8 +159,8 @@ export function Sd() {
 | 
			
		||||
                          isMobileScreen
 | 
			
		||||
                            ? { width: "100%", height: "fit-content" }
 | 
			
		||||
                            : { width: "100%", height: "100%" },
 | 
			
		||||
                        );
 | 
			
		||||
                      }}
 | 
			
		||||
                        )
 | 
			
		||||
                      }
 | 
			
		||||
                    />
 | 
			
		||||
                  ) : item.status === "error" ? (
 | 
			
		||||
                    <div className={styles["pre-img"]}>
 | 
			
		||||
@@ -247,7 +244,7 @@ export function Sd() {
 | 
			
		||||
                              created_at: new Date().toLocaleString(),
 | 
			
		||||
                              img_data: "",
 | 
			
		||||
                            };
 | 
			
		||||
                            sdStore.sendTask(reqData, fileDb);
 | 
			
		||||
                            sdStore.sendTask(reqData);
 | 
			
		||||
                          }}
 | 
			
		||||
                        />
 | 
			
		||||
                        <ChatAction
 | 
			
		||||
@@ -256,7 +253,7 @@ export function Sd() {
 | 
			
		||||
                          onClick={async () => {
 | 
			
		||||
                            if (await showConfirm(Locale.Sd.Danger.Delete)) {
 | 
			
		||||
                              // remove img_data + remove item in list
 | 
			
		||||
                              fileDb.deleteRecord(item.id).then(
 | 
			
		||||
                              removeImage(item.img_data).finally(
 | 
			
		||||
                                () => {
 | 
			
		||||
                                  sdStore.draw = sdImages.filter(
 | 
			
		||||
                                    (i: any) => i.id !== item.id,
 | 
			
		||||
 
 | 
			
		||||
@@ -23,6 +23,8 @@ export const BYTEDANCE_BASE_URL = "https://ark.cn-beijing.volces.com";
 | 
			
		||||
 | 
			
		||||
export const ALIBABA_BASE_URL = "https://dashscope.aliyuncs.com/api/";
 | 
			
		||||
 | 
			
		||||
export const UPLOAD_URL = "/api/cache/upload";
 | 
			
		||||
 | 
			
		||||
export enum Path {
 | 
			
		||||
  Home = "/",
 | 
			
		||||
  Chat = "/chat",
 | 
			
		||||
 
 | 
			
		||||
@@ -3,7 +3,7 @@ import { showToast } from "@/app/components/ui-lib";
 | 
			
		||||
import { getHeaders } from "@/app/client/api";
 | 
			
		||||
import { createPersistStore } from "@/app/utils/store";
 | 
			
		||||
import { nanoid } from "nanoid";
 | 
			
		||||
import { saveFileData, base64Image2Blob } from "@/app/utils/file";
 | 
			
		||||
import { uploadImage, base64Image2Blob } from "@/app/utils/chat";
 | 
			
		||||
 | 
			
		||||
export const useSdStore = createPersistStore<
 | 
			
		||||
  {
 | 
			
		||||
@@ -12,7 +12,7 @@ export const useSdStore = createPersistStore<
 | 
			
		||||
  },
 | 
			
		||||
  {
 | 
			
		||||
    getNextId: () => number;
 | 
			
		||||
    sendTask: (data: any, db: any, okCall?: Function) => void;
 | 
			
		||||
    sendTask: (data: any, okCall?: Function) => void;
 | 
			
		||||
    updateDraw: (draw: any) => void;
 | 
			
		||||
  }
 | 
			
		||||
>(
 | 
			
		||||
@@ -34,15 +34,14 @@ export const useSdStore = createPersistStore<
 | 
			
		||||
        set({ currentId: id });
 | 
			
		||||
        return id;
 | 
			
		||||
      },
 | 
			
		||||
      sendTask(data: any, db: any, okCall?: Function) {
 | 
			
		||||
      sendTask(data: any, okCall?: Function) {
 | 
			
		||||
        data = { ...data, id: nanoid(), status: "running" };
 | 
			
		||||
        set({ draw: [data, ..._get().draw] });
 | 
			
		||||
        // db.update(data);
 | 
			
		||||
        this.getNextId();
 | 
			
		||||
        this.stabilityRequestCall(data, db);
 | 
			
		||||
        this.stabilityRequestCall(data);
 | 
			
		||||
        okCall?.();
 | 
			
		||||
      },
 | 
			
		||||
      stabilityRequestCall(data: any, db: any) {
 | 
			
		||||
      stabilityRequestCall(data: any) {
 | 
			
		||||
        const formData = new FormData();
 | 
			
		||||
        for (let paramsKey in data.params) {
 | 
			
		||||
          formData.append(paramsKey, data.params[paramsKey]);
 | 
			
		||||
@@ -69,18 +68,26 @@ export const useSdStore = createPersistStore<
 | 
			
		||||
              return;
 | 
			
		||||
            }
 | 
			
		||||
            if (resData.finish_reason === "SUCCESS") {
 | 
			
		||||
              this.updateDraw({
 | 
			
		||||
                ...data,
 | 
			
		||||
                status: "success",
 | 
			
		||||
                // save blob to indexeddb instead of base64 image string
 | 
			
		||||
                img_data: saveFileData(
 | 
			
		||||
                  db,
 | 
			
		||||
                  data.id,
 | 
			
		||||
                  base64Image2Blob(resData.image, "image/png"),
 | 
			
		||||
                ),
 | 
			
		||||
              });
 | 
			
		||||
              const self = this;
 | 
			
		||||
              uploadImage(base64Image2Blob(resData.image, "image/png"))
 | 
			
		||||
                .then((img_data) => {
 | 
			
		||||
                  console.debug("uploadImage success", img_data, self);
 | 
			
		||||
                  self.updateDraw({
 | 
			
		||||
                    ...data,
 | 
			
		||||
                    status: "success",
 | 
			
		||||
                    img_data,
 | 
			
		||||
                  });
 | 
			
		||||
                })
 | 
			
		||||
                .catch((e) => {
 | 
			
		||||
                  console.error("uploadImage error", e);
 | 
			
		||||
                  self.updateDraw({
 | 
			
		||||
                    ...data,
 | 
			
		||||
                    status: "error",
 | 
			
		||||
                    error: JSON.stringify(resData),
 | 
			
		||||
                  });
 | 
			
		||||
                });
 | 
			
		||||
            } else {
 | 
			
		||||
              this.updateDraw({
 | 
			
		||||
              self.updateDraw({
 | 
			
		||||
                ...data,
 | 
			
		||||
                status: "error",
 | 
			
		||||
                error: JSON.stringify(resData),
 | 
			
		||||
@@ -94,10 +101,12 @@ export const useSdStore = createPersistStore<
 | 
			
		||||
            this.getNextId();
 | 
			
		||||
          });
 | 
			
		||||
      },
 | 
			
		||||
      updateDraw(draw: any) {
 | 
			
		||||
        _get().draw.some((item, index) => {
 | 
			
		||||
          if (item.id === draw.id) {
 | 
			
		||||
            _get().draw[index] = draw;
 | 
			
		||||
      updateDraw(_draw: any) {
 | 
			
		||||
        const draw = _get().draw || [];
 | 
			
		||||
        draw.some((item, index) => {
 | 
			
		||||
          if (item.id === _draw.id) {
 | 
			
		||||
            draw[index] = _draw;
 | 
			
		||||
            set(() => ({ draw }));
 | 
			
		||||
            return true;
 | 
			
		||||
          }
 | 
			
		||||
        });
 | 
			
		||||
 
 | 
			
		||||
@@ -1,3 +1,4 @@
 | 
			
		||||
import { UPLOAD_URL } from "@/app/constant";
 | 
			
		||||
import heic2any from "heic2any";
 | 
			
		||||
 | 
			
		||||
export function compressImage(file: File, maxSize: number): Promise<string> {
 | 
			
		||||
@@ -52,3 +53,40 @@ export function compressImage(file: File, maxSize: number): Promise<string> {
 | 
			
		||||
    reader.readAsDataURL(file);
 | 
			
		||||
  });
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export function base64Image2Blob(base64Data: string, contentType: string) {
 | 
			
		||||
  const byteCharacters = atob(base64Data);
 | 
			
		||||
  const byteNumbers = new Array(byteCharacters.length);
 | 
			
		||||
  for (let i = 0; i < byteCharacters.length; i++) {
 | 
			
		||||
    byteNumbers[i] = byteCharacters.charCodeAt(i);
 | 
			
		||||
  }
 | 
			
		||||
  const byteArray = new Uint8Array(byteNumbers);
 | 
			
		||||
  return new Blob([byteArray], { type: contentType });
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export function uploadImage(file: File): Promise<string> {
 | 
			
		||||
  const body = new FormData();
 | 
			
		||||
  body.append("file", file);
 | 
			
		||||
  return fetch(UPLOAD_URL, {
 | 
			
		||||
    method: "post",
 | 
			
		||||
    body,
 | 
			
		||||
    mode: "cors",
 | 
			
		||||
    credentials: "include",
 | 
			
		||||
  })
 | 
			
		||||
    .then((res) => res.json())
 | 
			
		||||
    .then((res) => {
 | 
			
		||||
      console.log("res", res);
 | 
			
		||||
      if (res?.code == 0 && res?.data) {
 | 
			
		||||
        return res?.data;
 | 
			
		||||
      }
 | 
			
		||||
      throw Error(`upload Error: ${res?.msg}`);
 | 
			
		||||
    });
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export function removeImage(imageUrl: string) {
 | 
			
		||||
  return fetch(imageUrl, {
 | 
			
		||||
    method: "DELETE",
 | 
			
		||||
    mode: "cors",
 | 
			
		||||
    credentials: "include",
 | 
			
		||||
  });
 | 
			
		||||
}
 | 
			
		||||
 
 | 
			
		||||
@@ -1,95 +0,0 @@
 | 
			
		||||
import { useState, useMemo, useEffect } from "react";
 | 
			
		||||
import { initDB } from "react-indexed-db-hook";
 | 
			
		||||
import { StoreKey } from "@/app/constant";
 | 
			
		||||
import { useIndexedDB } from "react-indexed-db-hook";
 | 
			
		||||
 | 
			
		||||
export const FileDbConfig = {
 | 
			
		||||
  name: "@chatgpt-next-web/file",
 | 
			
		||||
  version: 1,
 | 
			
		||||
  objectStoresMeta: [
 | 
			
		||||
    {
 | 
			
		||||
      store: StoreKey.File,
 | 
			
		||||
      storeConfig: { keyPath: "id", autoIncrement: true },
 | 
			
		||||
      storeSchema: [
 | 
			
		||||
        { name: "data", keypath: "data", options: { unique: false } },
 | 
			
		||||
        {
 | 
			
		||||
          name: "created_at",
 | 
			
		||||
          keypath: "created_at",
 | 
			
		||||
          options: { unique: false },
 | 
			
		||||
        },
 | 
			
		||||
      ],
 | 
			
		||||
    },
 | 
			
		||||
  ],
 | 
			
		||||
};
 | 
			
		||||
 | 
			
		||||
export function FileDbInit() {
 | 
			
		||||
  if (typeof window !== "undefined") {
 | 
			
		||||
    initDB(FileDbConfig);
 | 
			
		||||
  }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export function useFileDB() {
 | 
			
		||||
  return useIndexedDB(StoreKey.File);
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export function base64Image2Blob(base64Data: string, contentType: string) {
 | 
			
		||||
  const byteCharacters = atob(base64Data);
 | 
			
		||||
  const byteNumbers = new Array(byteCharacters.length);
 | 
			
		||||
  for (let i = 0; i < byteCharacters.length; i++) {
 | 
			
		||||
    byteNumbers[i] = byteCharacters.charCodeAt(i);
 | 
			
		||||
  }
 | 
			
		||||
  const byteArray = new Uint8Array(byteNumbers);
 | 
			
		||||
  return new Blob([byteArray], { type: contentType });
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export function saveFileData(db: any, fileId: string, data: Blob | string) {
 | 
			
		||||
  // save file content and return url start with `indexeddb://`
 | 
			
		||||
  db.add({ id: fileId, data });
 | 
			
		||||
  return `indexeddb://${StoreKey.File}@${fileId}`;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export async function getFileData(
 | 
			
		||||
  db: any,
 | 
			
		||||
  fileId: string,
 | 
			
		||||
  contentType = "image/png",
 | 
			
		||||
) {
 | 
			
		||||
  const { data } = await db.getByID(fileId);
 | 
			
		||||
  if (typeof data == "object") {
 | 
			
		||||
    return URL.createObjectURL(data);
 | 
			
		||||
  }
 | 
			
		||||
  return `data:${contentType};base64,${data}`;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export function IndexDBImage({
 | 
			
		||||
  src,
 | 
			
		||||
  alt,
 | 
			
		||||
  onClick,
 | 
			
		||||
  db,
 | 
			
		||||
  className,
 | 
			
		||||
}: {
 | 
			
		||||
  src: string;
 | 
			
		||||
  alt: string;
 | 
			
		||||
  onClick: any;
 | 
			
		||||
  db: any;
 | 
			
		||||
  className: string;
 | 
			
		||||
}) {
 | 
			
		||||
  const [data, setData] = useState(src);
 | 
			
		||||
  const imgId = useMemo(
 | 
			
		||||
    () => src.replace("indexeddb://", "").split("@").pop(),
 | 
			
		||||
    [src],
 | 
			
		||||
  );
 | 
			
		||||
  useEffect(() => {
 | 
			
		||||
    getFileData(db, imgId as string)
 | 
			
		||||
      .then((data) => setData(data))
 | 
			
		||||
      .catch((e) => setData(src));
 | 
			
		||||
  }, [src, imgId]);
 | 
			
		||||
 | 
			
		||||
  return (
 | 
			
		||||
    <img
 | 
			
		||||
      className={className}
 | 
			
		||||
      src={data}
 | 
			
		||||
      alt={alt}
 | 
			
		||||
      onClick={(e) => onClick(data, e)}
 | 
			
		||||
    />
 | 
			
		||||
  );
 | 
			
		||||
}
 | 
			
		||||
@@ -34,7 +34,6 @@
 | 
			
		||||
    "node-fetch": "^3.3.1",
 | 
			
		||||
    "react": "^18.2.0",
 | 
			
		||||
    "react-dom": "^18.2.0",
 | 
			
		||||
    "react-indexed-db-hook": "^1.0.14",
 | 
			
		||||
    "react-markdown": "^8.0.7",
 | 
			
		||||
    "react-router-dom": "^6.15.0",
 | 
			
		||||
    "rehype-highlight": "^6.0.0",
 | 
			
		||||
 
 | 
			
		||||
@@ -1,4 +1,6 @@
 | 
			
		||||
const CHATGPT_NEXT_WEB_CACHE = "chatgpt-next-web-cache";
 | 
			
		||||
const CHATGPT_NEXT_WEB_FILE_CACHE = "chatgpt-next-web-file";
 | 
			
		||||
let a="useandom-26T198340PX75pxJACKVERYMINDBUSHWOLF_GQZbfghjklqvwyzrict";let nanoid=(e=21)=>{let t="",r=crypto.getRandomValues(new Uint8Array(e));for(let n=0;n<e;n++)t+=a[63&r[n]];return t};
 | 
			
		||||
 | 
			
		||||
self.addEventListener("activate", function (event) {
 | 
			
		||||
  console.log("ServiceWorker activated.");
 | 
			
		||||
@@ -12,4 +14,37 @@ self.addEventListener("install", function (event) {
 | 
			
		||||
  );
 | 
			
		||||
});
 | 
			
		||||
 | 
			
		||||
self.addEventListener("fetch", (e) => {});
 | 
			
		||||
async function upload(request, url) {
 | 
			
		||||
  const formData = await request.formData()
 | 
			
		||||
  const file = formData.getAll('file')[0]
 | 
			
		||||
  let ext = file.name.split('.').pop()
 | 
			
		||||
  if (ext === 'blob') {
 | 
			
		||||
    ext = file.type.split('/').pop()
 | 
			
		||||
  }
 | 
			
		||||
  const fileUrl = `${url.origin}/api/cache/${nanoid()}.${ext}`
 | 
			
		||||
  // console.debug('file', file, fileUrl)
 | 
			
		||||
  const cache = await caches.open(CHATGPT_NEXT_WEB_FILE_CACHE)
 | 
			
		||||
  await cache.put(new Request(fileUrl), new Response(file))
 | 
			
		||||
  return Response.json({ code: 0, data: fileUrl })
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
async function remove(request, url) {
 | 
			
		||||
  const cache = await caches.open(CHATGPT_NEXT_WEB_FILE_CACHE)
 | 
			
		||||
  const res = await cache.delete(request.url)
 | 
			
		||||
  return Response.json({ code: 0 })
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
self.addEventListener("fetch", (e) => {
 | 
			
		||||
  const url = new URL(e.request.url);
 | 
			
		||||
  if (/^\/api\/cache/.test(url.pathname)) {
 | 
			
		||||
    if ('GET' == e.request.method) {
 | 
			
		||||
      e.respondWith(caches.match(e.request))
 | 
			
		||||
    }
 | 
			
		||||
    if ('POST' == e.request.method) {
 | 
			
		||||
      e.respondWith(upload(e.request, url))
 | 
			
		||||
    }
 | 
			
		||||
    if ('DELETE' == e.request.method) {
 | 
			
		||||
      e.respondWith(remove(e.request, url))
 | 
			
		||||
    }
 | 
			
		||||
  }
 | 
			
		||||
});
 | 
			
		||||
 
 | 
			
		||||
@@ -5278,11 +5278,6 @@ react-dom@^18.2.0:
 | 
			
		||||
    loose-envify "^1.1.0"
 | 
			
		||||
    scheduler "^0.23.0"
 | 
			
		||||
 | 
			
		||||
react-indexed-db-hook@^1.0.14:
 | 
			
		||||
  version "1.0.14"
 | 
			
		||||
  resolved "https://registry.npmmirror.com/react-indexed-db-hook/-/react-indexed-db-hook-1.0.14.tgz#a29cd732d592735b6a68dfc94316b7a4a091e6be"
 | 
			
		||||
  integrity sha512-tQ6rWofgXUCBhZp9pRpWzthzPbjqcll5uXMo07lbQTKl47VyL9nw9wfVswRxxzS5yj5Sq/VHUkNUjamWbA/M/w==
 | 
			
		||||
 | 
			
		||||
react-is@^16.13.1, react-is@^16.7.0:
 | 
			
		||||
  version "16.13.1"
 | 
			
		||||
  resolved "https://registry.yarnpkg.com/react-is/-/react-is-16.13.1.tgz#789729a4dc36de2999dc156dd6c1d9c18cea56a4"
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user