feat/stream-type-191 #192

Merged

einar merged 12 commits from feat/stream-type-191 into main 2026-03-06 15:29:06 +00:00

Conversation 0 Commits 12 Files changed 202 +2457 -2087

einar commented 2026-03-06 15:26:20 +00:00

Owner

Copy link

No description provided.

einar added 12 commits 2026-03-06 15:26:20 +00:00

chore: save pre-refactor benchmarks — ref #191 b89a5b35c0

feat: add StreamType to core types, interfaces, and all store implementations — ref #191 ... f4d8c6f379

- Event struct gets StreamType field
- EventStore interface: Append/Load/LoadFrom take streamType parameter
- Decider struct gets StreamType field (validated at command.Register)
- MemoryStore uses composite key internally
- Updated all wrappers: crypto, tenant, hooks, middleware, otelkit, observability
- Updated command package to read StreamType from Decider
- Updated conformance suite and eventstoretest
- Updated subscription GlobalEvent with StreamType field
- Added ReadByStreamType to MemoryStore
- Added StreamTypeReader interface

fix: update all test files to pass streamType parameter — ref #191 cc24d71b89

chore: add *.test to gitignore, remove test binaries 7a19551b9a

fix: add StreamType to all Decider literals in tests, fix double-application issues — ref #191 599ad4410b

feat: replace StreamID() with Stream() on Command interface — ref #191 ... 0c785f648f

- Add eskit.Stream struct (Type + ID)
- Command interface: Stream() eskit.Stream replaces StreamID() string
- command.Register gets streamType from cmd.Stream().Type
- Remove StreamType from Decider (comes from Command now)
- Update all command implementations across codebase
- CommandHandler.Handle takes streamType parameter
- Worker keys use stream.String() for proper isolation

feat: remove Command interface, commands are plain structs — ref #191 ... 6af2eb23d3

Register now takes streamType + streamID extractor:
  command.Register(bus, store, decider, "order", func(c PlaceOrder) string { return c.OrderID })

HintNewStream/HintExisting are RegisterOption values directly.
Domain commands have zero framework imports.

fix: update all tests to new Register API (streamType + extractor) — ref #191 18e857ffb0

fix: update stores, examples, and remaining tests for streamType API — ref #191 eaf9402c5d

fix: integration tests for new API, remove stale processor tests — ref #191 797f3c6ec8

feat: red team tests for stream type + ID extractor design — ref #191 ... 1192f2e293

Tests cover:
- Empty streamType panics at registration
- Nil extractor panics at registration
- Empty streamID returns error at send time
- Special chars in stream type/ID (unicode, slashes, null bytes)
- Composite key isolation (same ID, different types)
- Concurrent writes to different streams
- Version conflicts with HintNewStream
- Worker key isolation across stream types

fix: update all examples and tests for stream_type refactor ... 6a36a828ae

- Update command.Register calls with streamType and streamID extractor
- Remove 'order-'/'account-' prefix patterns from StreamID usage
- StreamID is now the pure business ID (projections, automations, tests)
- Fix sqlitestore test files for two-arg Load/Archive/Restore/AppendWithOptions API
- Fix multicodec_test.go and store_comprehensive_test.go signatures
- All examples compile and test green

Refs #191

einar merged commit 196a8fe6ed into main 2026-03-06 15:29:06 +00:00

einar referenced this pull request from a commit 2026-03-06 15:29:08 +00:00

Merge pull request 'feat/stream-type-191' (#192) from feat/stream-type-191 into main

Sign in to join this conversation.

Reviewers

No reviewers

Labels

Clear labels   

bug

  

documentation

  

enhancement

  

investigation

  

nice-to-have

  

performance

  

production-ready

  

testing

No labels

bug

documentation

enhancement

investigation

nice-to-have

performance

production-ready

testing

Milestone

Clear milestone

No items

No milestone

Projects

Clear projects

No items

No project

Assignees

Clear assignees

No assignees

1 participant

Notifications

Subscribe

Due date

The due date is invalid or out of range. Please use the format "yyyy-mm-dd".

No due date set.

Dependencies

No dependencies set.

Reference

ash/eskit!192

No description provided.