Titan

Total Integrated Transfer Architecture Network

A signal-based reactive state management engine for Dart & Flutter — fine-grained reactivity, zero boilerplate, surgical rebuilds.

---

The Titan Lexicon

Standard Term	Titan Name	Description
Store / Bloc	Pillar	Structured state module with lifecycle
State	Core	Reactive mutable state
Computed	Derived	Auto-computed from Cores, cached, lazy
Dispatch / Add	Strike	Batched, tracked mutations
Side Effect	Watch	Reactive side effect — re-runs on change
Global DI	Titan	Global Pillar registry
Observer	Oracle	All-seeing state monitor
DI Container	Vault	Hierarchical dependency container
Module	Forge	Dependency assembly unit
Config	Edict	Global Titan configuration
Event Bus	Herald	Cross-domain Pillar messaging
Error Tracking	Vigil	Centralized error capture & handlers
Logger	Chronicle	Structured logging with pluggable sinks
Undo/Redo	Epoch	Core with time-travel history
Stream Operators	Flux	Debounce, throttle, asStream
Persistence	Relic	Auto-save & hydrate Cores
Async Data	Ether	Loading / error / data wrapper
Form Field	Scroll	Reactive form field with validation
Form Group	ScrollGroup	Aggregate form state
Middleware	Conduit	Core-level pipeline — transform, validate, reject
State Selector	Prism	Fine-grained, memoized state projections
Reactive Collection	Nexus	In-place reactive List, Map, Set with change records
Hooks Widget	Spark	Hooks-style widget — useCore, useEffect, auto-lifecycle
Async Derived	Omen	Reactive async computed with auto-tracking & debounce
Reactive Policy	Mandate	Declarative policy engine with reactive writ rules
State Transaction	Ledger	Atomic commit/rollback for multi-Core mutations

---

Quick Start

dart pub add titan
# or for Flutter projects:
# flutter pub add titan

Or see the latest version on pub.dev.

Define a Pillar

import 'package:titan/titan.dart';

class CounterPillar extends Pillar {
  late final _count = core(0);
  ReadCore<int> get count => _count; // read-only public view

  late final doubled = derived(() => _count.value * 2);
  late final isEven = derived(() => _count.value % 2 == 0);

  void increment() => strike(() => _count.value++);
  void decrement() => strike(() => _count.value--);
  void reset() => strike(() => _count.value = 0);
}

ReadCore convention: Core fields are private; public getters return ReadCore<T> which hides the setter. All mutations go through named Pillar methods. See Core Concepts.

Use It (Pure Dart)

final counter = CounterPillar();

print(counter.count.value);    // 0
print(counter.doubled.value);  // 0

counter.increment();
print(counter.count.value);    // 1
print(counter.doubled.value);  // 2
print(counter.isEven.value);   // false

counter.dispose();

Standalone Signals

final count = Core(0);
final doubled = Derived(() => count.value * 2);

count.value = 5;
print(doubled.value); // 10

---

Key Features

Fine-Grained Reactivity

Each Core is an independent reactive node. Reading .value inside a Derived auto-registers the dependency. Only dependents of changed Cores recompute — nothing else.

Strike — Batched Mutations

// Inside a Pillar:
void updateProfile() => strike(() {
  name.value = 'Alice';
  age.value = 30;
  role.value = 'Admin';
});
// Dependents recompute ONCE, not three times

// Standalone (outside a Pillar):
titanBatch(() {
  name.value = 'Alice';
  age.value = 30;
});

Watch — Reactive Side Effects

class AuthPillar extends Pillar {
  late final user = core<User?>(null);
  late final isLoggedIn = derived(() => user.value != null);

  @override
  void onInit() {
    watch(() {
      if (isLoggedIn.value) {
        analytics.track('logged_in');
      }
    });
  }
}

Lifecycle

class DataPillar extends Pillar {
  @override
  void onInit() {
    // Called once after construction
  }

  @override
  void onDispose() {
    // Called on dispose — cleanup resources
  }
}

Herald — Cross-Pillar Events

// Define events (plain Dart classes)
class UserLoggedIn {
  final String userId;
  UserLoggedIn(this.userId);
}

// In AuthPillar — emit events
void login() {
  // ... authenticate ...
  emit(UserLoggedIn(user.id));
}

// In CartPillar — listen for events (auto-disposed)
@override
void onInit() {
  listen<UserLoggedIn>((event) {
    strike(() => loadCartForUser(event.userId));
  });
}

// Or use Herald directly
Herald.emit(UserLoggedIn('abc'));
Herald.on<UserLoggedIn>((e) => print(e.userId));
Herald.once<AppReady>((_) => startUp());
final last = Herald.last<UserLoggedIn>(); // Replay

Global DI

Titan.put(AuthPillar());
final auth = Titan.get<AuthPillar>();
Titan.remove<AuthPillar>();
Titan.reset(); // Remove all

AsyncValue (Ether)

late final users = core(AsyncValue<List<User>>.loading());

Future<void> loadUsers() async {
  users.value = AsyncValue.loading();
  try {
    final data = await api.fetchUsers();
    users.value = AsyncValue.data(data);
  } catch (e) {
    users.value = AsyncValue.error(e);
  }
}

// Pattern match
users.value.when(
  onData: (list) => print('Got ${list.length} users'),
  onLoading: () => print('Loading...'),
  onError: (e, _) => print('Error: $e'),
);

Vigil — Centralized Error Tracking

// Add handlers (console, Crashlytics, Sentry, etc.)
Vigil.addHandler(ConsoleErrorHandler());
Vigil.addHandler(myCrashlyticsHandler);

// Errors in strikeAsync are auto-captured with Pillar context
Future<void> loadData() => strikeAsync(() async {
  final data = await api.fetchData(); // If this throws → auto-captured
  items.value = data;
});

// Manual capture with context
try {
  await riskyOperation();
} catch (e, s) {
  captureError(e, stackTrace: s, action: 'riskyOperation');
}

// Query error history
final fatals = Vigil.bySeverity(ErrorSeverity.fatal);
final authErrors = Vigil.bySource(AuthPillar);
final lastError = Vigil.lastError;

// Guarded execution (captures error, returns null on failure)
final result = Vigil.guard(() => parseConfig(raw));
final users = await Vigil.guardAsync(() => api.fetchUsers());

Oracle — Global Observer

class LoggingOracle extends TitanObserver {
  @override
  void onStateChange(String name, dynamic prev, dynamic next) {
    print('$name: $prev → $next');
  }
}

TitanConfig.observer = LoggingOracle();

Chronicle — Structured Logging

class AuthPillar extends Pillar {
  @override
  void onInit() {
    log.info('AuthPillar initialized');  // auto-named 'AuthPillar'
  }

  Future<void> login(String email) async {
    log.debug('Attempting login', {'email': email});
    try {
      final user = await api.login(email);
      log.info('Login successful');
    } catch (e, s) {
      log.error('Login failed', e, s);
    }
  }
}

// Configure globally
Chronicle.level = LogLevel.info;     // Suppress trace/debug
Chronicle.addSink(MyFileSink());     // Custom output

Epoch — Undo/Redo History

class EditorPillar extends Pillar {
  late final text = epoch('');            // Core with history!
  late final fontSize = epoch(14.0);

  void type(String s) => strike(() => text.value = s);
  void undo() => text.undo();
  void redo() => text.redo();
  // text.canUndo, text.canRedo, text.history
}

Flux — Stream Operators

class SearchPillar extends Pillar {
  late final query = core('');
  late final debouncedQuery = query.debounce(Duration(milliseconds: 300));

  // Also: query.throttle(), query.asStream(), query.onChange
}

Relic — Persistence & Hydration

class SettingsPillar extends Pillar {
  late final theme = core('light');
  late final relic = Relic(
    adapter: sharedPrefsAdapter,
    entries: {
      'theme': RelicEntry(core: theme, toJson: (v) => v, fromJson: (v) => v as String),
    },
  );

  @override
  void onInit() async {
    await relic.hydrate();        // Restore from storage
    relic.enableAutoSave();       // Auto-persist on changes
  }
}

Scroll — Form Management

class LoginPillar extends Pillar {
  late final email = scroll<String>('',
    validator: (v) => v.contains('@') ? null : 'Invalid email',
  );
  late final password = scroll<String>('',
    validator: (v) => v.length >= 8 ? null : 'Min 8 characters',
  );
  late final form = ScrollGroup([email, password]);

  void submit() {
    if (form.validateAll()) { /* submit */ }
  }
}

Nexus — Reactive Collections

class InventoryPillar extends Pillar {
  late final items = nexusList<String>(['sword', 'shield']);
  late final tags = nexusSet<String>({'equipped'});
  late final stats = nexusMap<String, int>({'hp': 100});

  late final itemCount = derived(() => items.length);

  void addItem(String item) => items.add(item); // In-place O(1)
  void toggleTag(String tag) => tags.toggle(tag);
}

In-place mutations, no copy-on-write. Granular NexusChange records for pattern matching.

Omen — Reactive Async Derived

class DashboardPillar extends Pillar {
  late final userId = core('user-42');
  late final includeArchived = core(false);

  late final stats = omen<DashboardStats>(
    () async => api.fetchStats(
      userId.value,
      archived: includeArchived.value,
    ),
    debounce: Duration(milliseconds: 500),
  );
}

Reactive async computed — auto-tracks Core reads, re-executes on changes. AsyncValue lifecycle with stale-while-revalidate, debounce, and cancellation.

Mandate — Reactive Policy Engine

class DocumentPillar extends Pillar {
  late final role = core('viewer');
  late final isVerified = core(false);

  late final editAccess = mandate(
    writs: [
      Writ(
        name: 'is-editor',
        evaluate: () => role.value == 'editor' || role.value == 'admin',
        reason: 'Editor or admin role required',
      ),
      Writ(
        name: 'verified',
        evaluate: () => isVerified.value,
        reason: 'Email verification required',
      ),
    ],
  );
}

// Reactive — auto-updates when role or isVerified change
switch (pillar.editAccess.verdict.value) {
  case MandateGrant():
    return EditButton();
  case MandateDenial(:final violations):
    return DeniedBanner(violations);
}

Declarative reactive policy engine with named writs, sealed verdicts, weighted majority strategy, dynamic writ management, and per-writ can() queries.

Ledger — State Transactions

class CheckoutPillar extends Pillar {
  late final inventory = core(100);
  late final balance = core(500.0);
  late final txManager = ledger(name: 'checkout');

  Future<void> placeOrder(int qty, double price) async {
    await txManager.transact((tx) async {
      tx.capture(inventory);
      tx.capture(balance);
      inventory.value -= qty;
      balance.value -= price;
      await api.charge(price); // throws → auto-rollback
    }, name: 'order');
  }
}

// Reactive counters
print(txManager.commitCount);  // 1
print(txManager.hasActive);    // false
print(txManager.lastRecord);   // LedgerRecord(#0, committed, cores: 2)

Atomic state transactions with capture() snapshots, auto-commit/rollback, reactive counters, and LedgerRecord audit history.

Infrastructure features — Codex, Quarry, Trove, Moat, Pyre, Portcullis, Anvil, Bulwark, Saga, Volley, Tether, Annals, Banner, Sieve, Warden, Arbiter, Lode, Tithe, Sluice, Clarion, and Tapestry are in the titan_basalt package. Add import 'package:titan_basalt/titan_basalt.dart'; to use them.

---

Why Titan?

Feature	Provider	Bloc	Riverpod	GetX	Titan
Fine-grained reactivity	❌	❌	⚠️	⚠️	✅
Zero boilerplate	✅	❌	⚠️	✅	✅
Auto-tracking rebuilds	❌	❌	❌	❌	✅
Structured scalability	⚠️	✅	✅	❌	✅
Lifecycle management	❌	✅	✅	⚠️	✅
Scoped + Global DI	❌	⚠️	✅	❌	✅
Pure Dart core	❌	✅	✅	❌	✅
Undo/Redo built-in	❌	❌	❌	❌	✅
Persistence layer	❌	⚠️	❌	❌	✅
Structured logging	❌	❌	❌	❌	✅
Form management	❌	❌	❌	❌	✅
Pagination	❌	❌	❌	❌	✅
SWR data fetching	❌	❌	❌	❌	✅
State middleware	❌	❌	❌	❌	✅
State transactions	❌	❌	❌	❌	✅
Circuit breaker	❌	❌	❌	❌	✅
Dead letter queue	❌	❌	❌	❌	✅
Reactive collections	❌	❌	❌	❌	✅
Reactive async derived	❌	❌	⚠️	❌	✅
Priority task queue	❌	❌	❌	❌	✅

---

Testing — Pure Dart

test('counter pillar works', () {
  final counter = CounterPillar();
  expect(counter.count.value, 0);

  counter.increment();
  expect(counter.count.value, 1);
  expect(counter.doubled.value, 2);

  counter.dispose();
});

---

Packages

Package	Description
titan	Core reactive engine — pure Dart (this package)
titan_basalt	Infrastructure & resilience (Trove, Moat, Portcullis, Anvil, Pyre, Codex, Quarry, Bulwark, Saga, Volley, Tether, Annals, Banner, Sieve, Lattice, Embargo, Census, Warden, Arbiter, Lode, Tithe, Sluice, Clarion, Tapestry)
titan_bastion	Flutter widgets (Vestige, Beacon)
titan_atlas	Routing & navigation (Atlas)
titan_argus	Authentication & authorization
titan_colossus	Enterprise performance monitoring

Documentation

Guide	Link
Introduction	01-introduction.md
Getting Started	02-getting-started.md
Core Concepts	03-core-concepts.md
Pillars	04-stores.md
Flutter Integration	05-flutter-integration.md
Oracle & Observation	06-middleware.md
Testing	07-testing.md
Advanced Patterns	08-advanced-patterns.md
API Reference	09-api-reference.md
Migration Guide	10-migration-guide.md
Architecture	11-architecture.md
Atlas Routing	12-atlas-routing.md
Chronicles of Titan	Story-driven tutorial

License

MIT — Ikolvi