refactor: move article flow tasks to shared directory and update imports (#566)

# Reorganize Article Flow Structure for Better Maintainability

This PR reorganizes the article flow implementation to improve code organization and maintainability:

- Moved task files from `functions/article_flow_worker/tasks/` to a centralized `tasks/` directory at the project root
- Created a new `flows/` directory to house flow definitions separately from worker implementations
- Renamed `ArticleFlow` export to use named exports for consistency
- Updated import paths in all affected files to reflect the new structure
- Added a new index.ts file in the tasks directory to provide centralized exports
- Added a deno.lock file for better dependency management
- Included a database migration for pgflow to support flow input column

These changes separate the flow definition from its worker implementation, making it easier to maintain and test each component independently while providing a clearer project structure.

Author: jumski

…ions/article_flow_worker/article_flow.ts apps/demo/supabase/flows/article_flow.tsapps/demo/supabase/functions/article_flow_worker/article_flow.ts renamed to apps/demo/supabase/flows/article_flow.ts apps/demo/supabase/functions/article_flow_worker/article_flow.ts renamed to apps/demo/supabase/flows/article_flow.ts

@@ -1,8 +1,8 @@
 import { Flow } from '@pgflow/dsl';
-import { fetchArticle } from './tasks/fetch-article.ts';
-import { summarizeArticle } from './tasks/summarize-article.ts';
-import { extractKeywords } from './tasks/extract-keywords.ts';
-import { publishArticle } from './tasks/publish-article.ts';
+import { fetchArticle } from '../tasks/fetch-article.ts';
+import { summarizeArticle } from '../tasks/summarize-article.ts';
+import { extractKeywords } from '../tasks/extract-keywords.ts';
+import { publishArticle } from '../tasks/publish-article.ts';
 
 const SLEEP_MS = 1000;
 
@@ -12,7 +12,7 @@ function sleep(ms: number) {
 }
 
 // Flow definition - clean and minimal
-export default new Flow<{ url: string }>({
+export const ArticleFlow = new Flow<{ url: string }>({
 	slug: 'article_flow',
 	baseDelay: 1,
 	maxAttempts: 2

apps/demo/supabase/flows/index.ts

@@ -1,2 +1,3 @@
 // Re-export all flows from this directory
-// Example: export { MyFlow } from './my-flow.ts';
+
+export { ArticleFlow } from './article_flow.ts';

apps/demo/supabase/functions/article_flow_worker/deno.lock

@@ -1,4 +1,4 @@
 import { EdgeWorker } from '@pgflow/edge-worker';
-import ArticleFlow from './article_flow.ts';
+import { ArticleFlow } from '../../flows/article_flow.ts';
 
 EdgeWorker.start(ArticleFlow, { maxPollSeconds: 5, pollIntervalMs: 100 });

apps/demo/supabase/functions/article_flow_worker/index.ts

@@ -1,5 +1,5 @@
 import { assert } from 'https://deno.land/std@0.208.0/assert/mod.ts';
-import { extractKeywords } from '../tasks/extract-keywords.ts';
+import { extractKeywords } from '../../../tasks/extract-keywords.ts';
 import { load } from 'https://deno.land/std@0.208.0/dotenv/mod.ts';
 
 // Load environment variables from .env file if it exists

apps/demo/supabase/functions/article_flow_worker/tests/extract-keywords.test.ts

@@ -1,6 +1,6 @@
 import { assert } from 'https://deno.land/std@0.208.0/assert/mod.ts';
 import { stub } from 'https://deno.land/std@0.208.0/testing/mock.ts';
-import { fetchArticle } from '../tasks/fetch-article.ts';
+import { fetchArticle } from '../../../tasks/fetch-article.ts';
 import { load } from 'https://deno.land/std@0.208.0/dotenv/mod.ts';
 
 // Load environment variables from .env file if it exists

apps/demo/supabase/functions/article_flow_worker/tests/fetch-article.test.ts

@@ -1,5 +1,5 @@
 import { assertEquals, assert } from 'https://deno.land/std@0.208.0/assert/mod.ts';
-import { publishArticle } from '../tasks/publish-article.ts';
+import { publishArticle } from '../../../tasks/publish-article.ts';
 
 Deno.test('publishArticle - generates article ID and timestamp', () => {
 	const summary = 'Test summary';

apps/demo/supabase/functions/article_flow_worker/tests/publish-article.test.ts

@@ -1,5 +1,5 @@
 import { assert, assertRejects } from 'https://deno.land/std@0.208.0/assert/mod.ts';
-import { summarizeArticle } from '../tasks/summarize-article.ts';
+import { summarizeArticle } from '../../../tasks/summarize-article.ts';
 import { load } from 'https://deno.land/std@0.208.0/dotenv/mod.ts';
 
 // Load environment variables from .env file if it exists