67 lines
1.8 KiB
TypeScript
67 lines
1.8 KiB
TypeScript
import { Database } from "bun:sqlite";
|
|
import path from "path";
|
|
import fs from "fs";
|
|
|
|
// データベースディレクトリのパスを取得
|
|
const dbDir = path.join(__dirname, "../data");
|
|
|
|
// ディレクトリが存在しない場合は作成
|
|
if (!fs.existsSync(dbDir)) {
|
|
fs.mkdirSync(dbDir, { recursive: true });
|
|
}
|
|
|
|
const dbPath = path.join(dbDir, "podcast.db");
|
|
const db = new Database(dbPath);
|
|
|
|
// Ensure schema is set up
|
|
db.exec(`CREATE TABLE IF NOT EXISTS processed_feed_items (
|
|
feed_url TEXT NOT NULL,
|
|
item_id TEXT NOT NULL,
|
|
processed_at TEXT NOT NULL,
|
|
PRIMARY KEY(feed_url, item_id)
|
|
);
|
|
|
|
CREATE TABLE IF NOT EXISTS episodes (
|
|
id TEXT PRIMARY KEY,
|
|
title TEXT NOT NULL,
|
|
pubDate TEXT NOT NULL,
|
|
audioPath TEXT NOT NULL,
|
|
sourceLink TEXT NOT NULL
|
|
);`);
|
|
|
|
export interface Episode {
|
|
id: string;
|
|
title: string;
|
|
pubDate: string;
|
|
audioPath: string;
|
|
sourceLink: string;
|
|
}
|
|
|
|
export async function markAsProcessed(
|
|
feedUrl: string,
|
|
itemId: string,
|
|
): Promise<boolean> {
|
|
const stmt = db.prepare(
|
|
"SELECT 1 FROM processed_feed_items WHERE feed_url = ? AND item_id = ?",
|
|
);
|
|
const row = stmt.get(feedUrl, itemId);
|
|
if (row) return true;
|
|
const insert = db.prepare(
|
|
"INSERT INTO processed_feed_items (feed_url, item_id, processed_at) VALUES (?, ?, ?)",
|
|
);
|
|
insert.run(feedUrl, itemId, new Date().toISOString());
|
|
return false;
|
|
}
|
|
|
|
export async function saveEpisode(ep: Episode): Promise<void> {
|
|
const stmt = db.prepare(
|
|
"INSERT OR IGNORE INTO episodes (id, title, pubDate, audioPath, sourceLink) VALUES (?, ?, ?, ?, ?)",
|
|
);
|
|
stmt.run(ep.id, ep.title, ep.pubDate, ep.audioPath, ep.sourceLink);
|
|
}
|
|
|
|
export async function fetchAllEpisodes(): Promise<Episode[]> {
|
|
const stmt = db.prepare("SELECT * FROM episodes ORDER BY pubDate DESC");
|
|
return stmt.all() as Episode[];
|
|
}
|