-3

.github/ISSUE_TEMPLATE/bug-report.md

··· 4 title: '' 5 labels: bug 6 assignees: '' 7 - 8 --- 9 - 10 -

··· 4 title: '' 5 labels: bug 6 assignees: '' 0 7 --- 0 0

-3

.github/ISSUE_TEMPLATE/feature.md

··· 4 title: '' 5 labels: feature 6 assignees: '' 7 - 8 --- 9 - 10 -

··· 4 title: '' 5 labels: feature 6 assignees: '' 0 7 --- 0 0

-3

.github/ISSUE_TEMPLATE/task.md

··· 4 title: '' 5 labels: task 6 assignees: '' 7 - 8 --- 9 - 10 -

··· 4 title: '' 5 labels: task 6 assignees: '' 0 7 --- 0 0

+1 -1

package.json

··· 34 "dev:app:inner": "dotenv -e .env.local -- concurrently -k -n TYPE,APP -c red,blue \"tsc --noEmit --watch\" \"tsup --watch --onSuccess='node dist/index.js'\"", 35 "dev:worker:feeds:inner": "dotenv -e .env.local -- concurrently -k -n WORKER -c green \"tsup --watch --onSuccess='node dist/workers/feed-worker.js'\"", 36 "dev:worker:search:inner": "dotenv -e .env.local -- concurrently -k -n WORKER -c yellow \"tsup --watch --onSuccess='node dist/workers/search-worker.js'\"", 37 - "dev:mock": "USE_PERSISTENCE=false USE_FAKE_PUBLISHERS=true USE_MOCK_AUTH=true npm run dev:app:inner", 38 "dev:mock:pub:auth": "USE_FAKE_PUBLISHERS=true USE_MOCK_AUTH=true npm run dev", 39 "dev": "bash ./scripts/dev-combined.sh", 40 "migrate": "node dist/scripts/migrate.js",

··· 34 "dev:app:inner": "dotenv -e .env.local -- concurrently -k -n TYPE,APP -c red,blue \"tsc --noEmit --watch\" \"tsup --watch --onSuccess='node dist/index.js'\"", 35 "dev:worker:feeds:inner": "dotenv -e .env.local -- concurrently -k -n WORKER -c green \"tsup --watch --onSuccess='node dist/workers/feed-worker.js'\"", 36 "dev:worker:search:inner": "dotenv -e .env.local -- concurrently -k -n WORKER -c yellow \"tsup --watch --onSuccess='node dist/workers/search-worker.js'\"", 37 + "dev:mock": "USE_MOCK_PERSISTENCE=true USE_FAKE_PUBLISHERS=true USE_MOCK_AUTH=true USE_MOCK_VECTOR_DB=true npm run dev:app:inner", 38 "dev:mock:pub:auth": "USE_FAKE_PUBLISHERS=true USE_MOCK_AUTH=true npm run dev", 39 "dev": "bash ./scripts/dev-combined.sh", 40 "migrate": "node dist/scripts/migrate.js",

+2 -2

src/modules/atproto/infrastructure/__tests__/ATProtoCardPublisher.integration.test.ts

··· 12 dotenv.config({ path: '.env.test' }); 13 14 // Set to false to skip unpublishing (useful for debugging published records) 15 - const UNPUBLISH = false; 16 17 - describe('ATProtoCardPublisher', () => { 18 let publisher: ATProtoCardPublisher; 19 let curatorId: CuratorId; 20 let publishedCardIds: PublishedRecordId[] = [];

··· 12 dotenv.config({ path: '.env.test' }); 13 14 // Set to false to skip unpublishing (useful for debugging published records) 15 + const UNPUBLISH = true; 16 17 + describe.skip('ATProtoCardPublisher', () => { 18 let publisher: ATProtoCardPublisher; 19 let curatorId: CuratorId; 20 let publishedCardIds: PublishedRecordId[] = [];

+2 -2

src/modules/atproto/infrastructure/__tests__/ATProtoCollectionPublisher.integration.test.ts

··· 15 dotenv.config({ path: '.env.test' }); 16 17 // Set to false to skip unpublishing (useful for debugging published records) 18 - const UNPUBLISH = false; 19 20 - describe('ATProtoCollectionPublisher', () => { 21 let collectionPublisher: ATProtoCollectionPublisher; 22 let cardPublisher: FakeCardPublisher; 23 let curatorId: CuratorId;

··· 15 dotenv.config({ path: '.env.test' }); 16 17 // Set to false to skip unpublishing (useful for debugging published records) 18 + const UNPUBLISH = true; 19 20 + describe.skip('ATProtoCollectionPublisher', () => { 21 let collectionPublisher: ATProtoCollectionPublisher; 22 let cardPublisher: FakeCardPublisher; 23 let curatorId: CuratorId;

+15 -15

src/shared/infrastructure/config/EnvironmentConfigService.ts

··· 7 export interface EnvironmentConfig { 8 environment: Environment; 9 runtime: { 10 - usePersistence: boolean; 11 useMockAuth: boolean; 12 useFakePublishers: boolean; 13 useMockVectorDb: boolean; ··· 64 this.config = { 65 environment, 66 runtime: { 67 - usePersistence: this.determinePersistenceFlag(), 68 useMockAuth: process.env.USE_MOCK_AUTH === 'true', 69 useFakePublishers: process.env.USE_FAKE_PUBLISHERS === 'true', 70 useMockVectorDb: process.env.USE_MOCK_VECTOR_DB === 'true', ··· 198 return this.config.runtime; 199 } 200 201 - public shouldUsePersistence(): boolean { 202 - return this.config.runtime.usePersistence; 203 } 204 205 public shouldUseMockRepos(): boolean { 206 - return !this.config.runtime.usePersistence; 207 } 208 209 public shouldUseInMemoryEvents(): boolean { 210 - return !this.config.runtime.usePersistence; 211 } 212 213 public shouldUseMockAuth(): boolean { ··· 225 // Convenience methods for common combinations 226 public isFullyMocked(): boolean { 227 const r = this.config.runtime; 228 - return !r.usePersistence && r.useMockAuth && r.useFakePublishers; 229 } 230 231 - public isPersistenceEnabled(): boolean { 232 - return this.config.runtime.usePersistence; 233 } 234 235 - private determinePersistenceFlag(): boolean { 236 // New unified flag takes precedence 237 - if (process.env.USE_PERSISTENCE !== undefined) { 238 - return process.env.USE_PERSISTENCE === 'true'; 239 } 240 241 // Legacy support - if either old flag is false, persistence is disabled ··· 243 process.env.USE_MOCK_REPOS === 'true' || 244 process.env.USE_IN_MEMORY_EVENTS === 'true' 245 ) { 246 - return false; 247 } 248 249 - // Default to true (use persistence) unless explicitly disabled 250 - return true; 251 } 252 }

··· 7 export interface EnvironmentConfig { 8 environment: Environment; 9 runtime: { 10 + useMockPersistence: boolean; 11 useMockAuth: boolean; 12 useFakePublishers: boolean; 13 useMockVectorDb: boolean; ··· 64 this.config = { 65 environment, 66 runtime: { 67 + useMockPersistence: this.determineMockPersistenceFlag(), 68 useMockAuth: process.env.USE_MOCK_AUTH === 'true', 69 useFakePublishers: process.env.USE_FAKE_PUBLISHERS === 'true', 70 useMockVectorDb: process.env.USE_MOCK_VECTOR_DB === 'true', ··· 198 return this.config.runtime; 199 } 200 201 + public shouldUseMockPersistence(): boolean { 202 + return this.config.runtime.useMockPersistence; 203 } 204 205 public shouldUseMockRepos(): boolean { 206 + return this.config.runtime.useMockPersistence; 207 } 208 209 public shouldUseInMemoryEvents(): boolean { 210 + return this.config.runtime.useMockPersistence; 211 } 212 213 public shouldUseMockAuth(): boolean { ··· 225 // Convenience methods for common combinations 226 public isFullyMocked(): boolean { 227 const r = this.config.runtime; 228 + return r.useMockPersistence && r.useMockAuth && r.useFakePublishers; 229 } 230 231 + public isMockPersistenceEnabled(): boolean { 232 + return this.config.runtime.useMockPersistence; 233 } 234 235 + private determineMockPersistenceFlag(): boolean { 236 // New unified flag takes precedence 237 + if (process.env.USE_MOCK_PERSISTENCE !== undefined) { 238 + return process.env.USE_MOCK_PERSISTENCE === 'true'; 239 } 240 241 // Legacy support - if either old flag is false, persistence is disabled ··· 243 process.env.USE_MOCK_REPOS === 'true' || 244 process.env.USE_IN_MEMORY_EVENTS === 'true' 245 ) { 246 + return true; 247 } 248 249 + // Default to false (use mock persistence) unless explicitly enabled 250 + return false; 251 } 252 }

+2 -3

src/shared/infrastructure/http/factories/ServiceFactory.ts

··· 48 import { RedisFactory } from '../../redis/RedisFactory'; 49 import { IEventSubscriber } from 'src/shared/application/events/IEventSubscriber'; 50 import { FeedService } from '../../../../modules/feeds/domain/services/FeedService'; 51 - import { CardCollectionSaga } from '../../../../modules/feeds/application/sagas/CardCollectionSaga'; 52 import { ATProtoIdentityResolutionService } from '../../../../modules/atproto/infrastructure/services/ATProtoIdentityResolutionService'; 53 import { IIdentityResolutionService } from '../../../../modules/atproto/domain/services/IIdentityResolutionService'; 54 import { CookieService } from '../services/CookieService'; ··· 293 const baseProfileService = new BlueskyProfileService(atProtoAgentService); 294 295 let profileService: IProfileService; 296 - const usePersistence = configService.shouldUsePersistence(); 297 298 // caching requires persistence 299 - if (!usePersistence) { 300 profileService = baseProfileService; 301 } else { 302 // Create Redis connection for caching

··· 48 import { RedisFactory } from '../../redis/RedisFactory'; 49 import { IEventSubscriber } from 'src/shared/application/events/IEventSubscriber'; 50 import { FeedService } from '../../../../modules/feeds/domain/services/FeedService'; 0 51 import { ATProtoIdentityResolutionService } from '../../../../modules/atproto/infrastructure/services/ATProtoIdentityResolutionService'; 52 import { IIdentityResolutionService } from '../../../../modules/atproto/domain/services/IIdentityResolutionService'; 53 import { CookieService } from '../services/CookieService'; ··· 292 const baseProfileService = new BlueskyProfileService(atProtoAgentService); 293 294 let profileService: IProfileService; 295 + const useMockPersistence = configService.shouldUseMockPersistence(); 296 297 // caching requires persistence 298 + if (useMockPersistence) { 299 profileService = baseProfileService; 300 } else { 301 // Create Redis connection for caching

+3 -2

src/shared/infrastructure/locking/LockServiceFactory.ts

··· 2 import { RedisLockService } from './RedisLockService'; 3 import { InMemoryLockService } from './InMemoryLockService'; 4 import { RedisFactory } from '../redis/RedisFactory'; 0 5 6 export class LockServiceFactory { 7 static create(): ILockService { 8 - const useMockRepos = process.env.USE_MOCK_REPOS === 'true'; 9 - if (!useMockRepos) { 10 try { 11 const redis = RedisFactory.createConnection({ 12 host: process.env.REDIS_HOST || 'localhost',

··· 2 import { RedisLockService } from './RedisLockService'; 3 import { InMemoryLockService } from './InMemoryLockService'; 4 import { RedisFactory } from '../redis/RedisFactory'; 5 + import { configService } from '../config'; 6 7 export class LockServiceFactory { 8 static create(): ILockService { 9 + const useMockPersistence = configService.shouldUseMockPersistence(); 10 + if (!useMockPersistence) { 11 try { 12 const redis = RedisFactory.createConnection({ 13 host: process.env.REDIS_HOST || 'localhost',

+2 -2

src/shared/infrastructure/processes/AppProcess.ts

··· 10 // Get configuration 11 const config = this.configService.get(); 12 13 - const useMockRepos = process.env.USE_MOCK_REPOS === 'true'; 14 - if (!useMockRepos) { 15 // Create database connection with config 16 const db = DatabaseFactory.createConnection( 17 this.configService.getDatabaseConfig(),

··· 10 // Get configuration 11 const config = this.configService.get(); 12 13 + const useMockPersistence = this.configService.shouldUseMockPersistence(); 14 + if (!useMockPersistence) { 15 // Create database connection with config 16 const db = DatabaseFactory.createConnection( 17 this.configService.getDatabaseConfig(),

+1 -1

src/webapp/lib/auth/dal.server.ts

··· 2 import { cookies } from 'next/headers'; 3 import { cache } from 'react'; 4 5 - const appUrl = process.env.APP_URL || 'http://127.0.0.1:4000'; 6 7 export const verifySessionOnServer = cache(async () => { 8 const cookieStore = await cookies();

··· 2 import { cookies } from 'next/headers'; 3 import { cache } from 'react'; 4 5 + const appUrl = process.env.NEXT_PUBLIC_APP_URL || 'http://127.0.0.1:4000'; 6 7 export const verifySessionOnServer = cache(async () => { 8 const cookieStore = await cookies();