import { addFeed } from "#server/service/rss";
import { RssUrlUnsafeError } from "#server/utils/rss-url";

export default defineWrappedResponseHandler(async (event) => {
  const user = await event.context.auth.requireUser();
  const body = await readBody<{ feedUrl: string }>(event);
  try {
    const feed = await addFeed(user.id, body.feedUrl);
    return R.success({ feed });
  } catch (e) {
    if (e instanceof RssUrlUnsafeError) {
      throw createError({ statusCode: 400, statusMessage: e.message });
    }
    throw e;
  }
});