Function migrateToLowdb

shift/shift.ts:205–273

()

    const newRules: { [key: string]: ShiftRule } = {};
    for (const rule of rules) {
      newRules[String(rule.source_id)] = {
        target_id: rule.target_id,
        options: JSON.parse(rule.options || "[]"),
        target_type: rule.target_type,
        paused: rule.paused === 1,
        created_at: rule.created_at,
        filters: JSON.parse(rule.filters || "[]"),
      };
    }

    // 转换统计
    const newStats: { [date: string]: { [sourceId: string]: any } } = {};
    for (const stat of stats) {
      const parts = stat.stats_key.split(".");
      if (parts.length >= 4) {
        const date = parts[3];
        const sourceId = parts[2];
        if (!newStats[date]) newStats[date] = {};
        newStats[date][sourceId] = JSON.parse(stat.stats_data);
      }
    }

    // 创建 lowdb 数据库
    const migratedData: ShiftDatabaseV2 = {
      version: "2.0.0",
      rules: newRules,
      stats: newStats,
      backups: {},
      config: {
        autoCleanOldStats: true,
        statsRetentionDays: 30,
        enableChainForwarding: true,
        useLowdb: true,
      },
    };

    lowdb = await JSONFilePreset<ShiftDatabaseV2>(lowdbPath, migratedData);
    await lowdb.write();

    // 备份旧数据库
    const backupPath = sqlitePath + `.backup.${Date.now()}`;
    fs.renameSync(sqlitePath, backupPath);

    sqliteDb.close();
    sqliteDb = null;
    useLowdb = true;

    console.log(
      `[SHIFT] 成功迁移 ${rules.length} 条规则，备份至: ${backupPath}`
    );
    return true;
  } catch (error) {
    console.error("[SHIFT] 迁移失败:", error);
    return false;
  }
}

// Rule interface