bitsofchris_openaugi-obsidian-plugin/main.ts

import { Plugin, TFile } from 'obsidian';
import OpenAI from 'openai';
import * as dotenv from 'dotenv';

dotenv.config();

export default class TranscriptParserPlugin extends Plugin {
  async onload() {
    this.watchFolder("transcripts");
  }

  watchFolder(folderPath: string) {
    this.registerEvent(this.app.vault.on('create', async (file: TFile) => {
      if (file.path.startsWith(folderPath)) {
        const content = await this.app.vault.read(file);
        await this.parseAndOutput(file.basename, content);
      }
    }));
  }

  async parseAndOutput(filename: string, content: string) {
    const openai = new OpenAI({
      apiKey: process.env.OPENAI_API_KEY
    });

    const prompt = `You will receive a raw transcript from voice notes. Identify all commands that start with the special token "AUGI" and parse them clearly.

Example commands:
- "AUGI create note titled XYZ" → Create a new note with title XYZ.
- "AUGI summarize this" → Summarize preceding context.
- "AUGI add task ABC" → Create a new task item.

Return strictly JSON:
{
  "summary": "Short summary (ignoring commands)",
  "notes": [{"title": "Note Title", "content": "Content"}],
  "tasks": ["task 1", "task 2"]
}

Transcript:\n${content}`;

    const response = await openai.chat.completions.create({
      model: "gpt-4-turbo",
      messages: [{ role: 'user', content: prompt }]
    });

    const messageContent = response.choices[0].message.content;
    if (!messageContent) {
      throw new Error('No response content received from OpenAI');
    }
    const structuredData = JSON.parse(messageContent);

    // Output Summary
    await this.app.vault.create(`Parsed_Notes/summaries/${filename}_summary.md`, structuredData.summary);

    // Output Notes
    for (const note of structuredData.notes) {
      await this.app.vault.create(`Parsed_Notes/notes/${note.title}.md`, note.content);
    }

    // Append Tasks
    const tasksFile = this.app.vault.getAbstractFileByPath("Parsed_Notes/tasks.md");
    if (tasksFile instanceof TFile) {
      let existingTasks = await this.app.vault.read(tasksFile);
      existingTasks += '\n' + structuredData.tasks.map((task: string) => `- [ ] ${task}`).join('\n');
      await this.app.vault.modify(tasksFile, existingTasks);
    } else {
      await this.app.vault.create("Parsed_Notes/tasks.md", structuredData.tasks.map((task: string) => `- [ ] ${task}`).join('\n'));
    }
  }
}