Method getOpenListCredentials

openlist/openlist.ts:669–722

()

      // 移除多余的斜杠
      fullPath = fullPath.replace(/\/+/g, "/");

      await msg.edit({ text: `正在上传到: ${codeTag(fullPath)}`, parseMode: "html" });

      const apiUrl = "http://127.0.0.1:5244/api/fs/put";
      
      // 注意：Header 中的中文路径需要编码
      await axios.put(apiUrl, buffer, {
        headers: {
          "Authorization": token,
          "File-Path": encodeURIComponent(fullPath),
          "path": encodeURIComponent(fullPath), 
          "Content-Type": "application/octet-stream",
          "As-Task": "false"
        },
        maxBodyLength: Infinity,
        maxContentLength: Infinity
      });

      await msg.edit({ text: `✅ 文件已上传到 OpenList: ${codeTag(fullPath)}`, parseMode: "html" });

    } catch (error: any) {
      console.error("OpenList Upload Error:", error);
      const errMsg = error?.response?.data?.message || error.message || "未知错误";
      throw new Error(`上传失败: ${errMsg}`);
    }
  }

  private async getOpenListCredentials() {
    // 1. Get DB credentials
    let dbUser = "";
    let dbPass = "";
    try {
      const db = await this.getDb();
      dbUser = db.data.username;
      dbPass = db.data.password;
    } catch (e) {}

    // 2. Get Config credentials
    let configUser = "";
    let configPass = "";
    const installPath = await this.detectInstalledPath();
    const configPath = `${installPath}/data/config.json`;

    if (await this.fileExists(configPath)) {
      try {
        let configContent = "";
        try {
          configContent = await fs.readFile(configPath, "utf-8");
        } catch {
          const { stdout } = await execAsync(`cat "${configPath}" 2>/dev/null`);
          configContent = stdout;
        }

        if (configContent) {
          const config = JSON.parse(configContent);
          if (config.users && config.users.length > 0) {
            configUser = config.users[0].username;