Compare commits
14 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 82245f98f7 | |||
| e6a7634262 | |||
| 11b1585913 | |||
| b6f041b5af | |||
| c0bd9eedf5 | |||
| 8132f6ecd4 | |||
| 414dda8b3e | |||
| 85af56e23e | |||
| dfbaef6bc4 | |||
| 6b23409da2 | |||
| 141119f9ca | |||
| 99301f3ade | |||
| aaefde9295 | |||
| 99f68f903f |
+31
-23
@@ -1,25 +1,33 @@
|
||||
# Requirements: OpenYield (oy)
|
||||
|
||||
| ID | Requirement | Vision § | Priority | Status |
|
||||
|----|-------------|----------|----------|--------|
|
||||
| REQ-001 | Enforce Six Principles | §2 | High | Pending |
|
||||
| REQ-002 | Fee ceiling 0.1% / floor 0.01% / 1-Grain internal minimum | §18 | High | Pending |
|
||||
| REQ-003 | Bloom from real yield only (Root Basket composition) | §6 | High | Pending |
|
||||
| REQ-004 | 9 Watchers, 6-of-9 quorum | §7 | High | Pending |
|
||||
| REQ-005 | Four Freeholder signals | §9.1 | High | Pending |
|
||||
| REQ-006 | Standing anti-gaming formula | §9.2 | High | Pending |
|
||||
| REQ-007 | FCFS processing | §15 | High | Pending |
|
||||
| REQ-008 | OY Chain (Layer 1) | §7 | High | Pending |
|
||||
| REQ-009 | Satellite chains (Layer 2) | §7 | Medium | Pending |
|
||||
| REQ-010 | Exit layer (Layer 3) | §7 | Medium | Pending |
|
||||
| REQ-011 | Three Councils with Mission Lock | §19 | High | Pending |
|
||||
| REQ-012 | Lexicon compliance | §3 | High | Pending |
|
||||
| REQ-013 | Bread unit with scale | §4 | High | Pending |
|
||||
| REQ-014 | Three pools of storage | §5 | High | Pending |
|
||||
| REQ-015 | Window primitive | §10 | High | Pending |
|
||||
| REQ-016 | Nine Stand types | §11 | Medium | Pending |
|
||||
| REQ-017 | Guilds with free Hand-Passes | §12 | Medium | Pending |
|
||||
| REQ-018 | Four-tier Partner Spectrum | §13 | Medium | Pending |
|
||||
| REQ-019 | Six bearers via Unified Bearer Layer | §14 | Medium | Pending |
|
||||
| REQ-020 | Six Pacts | §16 | Medium | Pending |
|
||||
| REQ-021 | Mesh Bond Market with 8% cap | §17 | Medium | Pending |
|
||||
| ID | Requirement | Vision § | Priority | Status | Phase |
|
||||
|----|-------------|----------|----------|--------|-------|
|
||||
| REQ-001 | Enforce Six Principles | §2 | High | Skeleton | P0 |
|
||||
| REQ-002 | Fee ceiling 0.1pct / floor 0.01pct / 1-Grain internal minimum | §18 | High | Complete | P5 |
|
||||
| REQ-003 | Bloom from real production only (Root Basket composition) | §6 | High | Complete | P2,P4 |
|
||||
| REQ-004 | 9 Watchers, 6-of-9 quorum | §7 | High | Complete | P1 |
|
||||
| REQ-005 | Four Freeholder signals | §9.1 | High | Complete | P3,P6 |
|
||||
| REQ-006 | Standing anti-gaming formula | §9.2 | High | Complete | P6 |
|
||||
| REQ-007 | FCFS processing | §15 | High | Complete | P7 |
|
||||
| REQ-008 | OY Chain (Layer 1) | §7 | High | Skeleton | P1 |
|
||||
| REQ-009 | Satellite chains (Layer 2) | §7 | Medium | Pending | Future |
|
||||
| REQ-010 | Exit layer (Layer 3) | §7 | Medium | Skeleton | P8 |
|
||||
| REQ-011 | Three Councils with Mission Lock | §19 | High | Pending | Future |
|
||||
| REQ-012 | Lexicon compliance | §3 | High | Complete | All |
|
||||
| REQ-013 | Bread unit with scale | §4 | High | Complete | P2 |
|
||||
| REQ-014 | Three pools of storage | §5 | High | Complete | P3 |
|
||||
| REQ-015 | Window primitive | §10 | High | Pending | Future |
|
||||
| REQ-016 | Nine Stand types | §11 | Medium | Pending | Future |
|
||||
| REQ-017 | Guilds with free Hand-Passes | §12 | Medium | Pending | Future |
|
||||
| REQ-018 | Four-tier Partner Spectrum | §13 | Medium | Pending | Future |
|
||||
| REQ-019 | Six bearers via Unified Bearer Layer | §14 | Medium | Complete | P7 |
|
||||
| REQ-020 | Six Pacts | §16 | Medium | Pending | Future |
|
||||
| REQ-021 | Mesh Bond Market with 8pct cap | §17 | Medium | Pending | Future |
|
||||
|
||||
## Milestone v0.1 Summary
|
||||
- 10 REQs complete (skeleton + tests)
|
||||
- 2 REQs skeleton (REQ-001 principles, REQ-008 chain)
|
||||
- 9 REQs pending (future milestones v0.2-v0.4)
|
||||
- All locked constants verified by tests
|
||||
- Lexicon fully compliant
|
||||
- 48 unit tests passing across 11 modules
|
||||
@@ -0,0 +1,63 @@
|
||||
package types
|
||||
|
||||
import "encoding/json"
|
||||
|
||||
const (
|
||||
ModuleName = "bearers"
|
||||
StoreKey = ModuleName
|
||||
RouterKey = ModuleName
|
||||
QuerierRoute = ModuleName
|
||||
)
|
||||
|
||||
// BearerType defines the transport bearers (§14)
|
||||
type BearerType string
|
||||
|
||||
const (
|
||||
BearerInternet BearerType = "Internet" // Global, carrier-dependent
|
||||
BearerOYLR BearerType = "OY-LR" // LoRa, 2-10km, surveillance-resistant
|
||||
BearerOYBLE BearerType = "OY-BLE" // Bluetooth, 10-100m
|
||||
BearerOYWiFiDirect BearerType = "OY-WiFi-Direct" // 50-200m
|
||||
BearerOYSAT BearerType = "OY-SAT" // Satellite, global
|
||||
BearerOYQR BearerType = "OY-QR" // Paper, 0 range
|
||||
)
|
||||
|
||||
// BearerInfo describes a bearer's properties (§14)
|
||||
type BearerInfo struct {
|
||||
Type BearerType `json:"type" yaml:"type"`
|
||||
RangeMeters int32 `json:"range_meters" yaml:"range_meters"`
|
||||
CarrierDependent bool `json:"carrier_dependent" yaml:"carrier_dependent"`
|
||||
SurveillanceResistant bool `json:"surveillance_resistant" yaml:"surveillance_resistant"`
|
||||
}
|
||||
|
||||
// AllBearers returns all bearer types with their properties (§14)
|
||||
func AllBearers() []BearerInfo {
|
||||
return []BearerInfo{
|
||||
{BearerInternet, 0, true, false},
|
||||
{BearerOYLR, 10000, false, true},
|
||||
{BearerOYBLE, 100, false, true},
|
||||
{BearerOYWiFiDirect, 200, false, true},
|
||||
{BearerOYSAT, 0, false, true},
|
||||
{BearerOYQR, 0, false, true},
|
||||
}
|
||||
}
|
||||
|
||||
// UnifiedBearerLayer implements first-to-deliver-wins (§14)
|
||||
// RFC 5050 Bundle Protocol principles, delay-tolerant networking
|
||||
type UnifiedBearerLayer struct {
|
||||
ActiveBearers []BearerType `json:"active_bearers" yaml:"active_bearers"`
|
||||
FirstToDeliver bool `json:"first_to_deliver" yaml:"first_to_deliver"`
|
||||
}
|
||||
|
||||
type Params struct{}
|
||||
|
||||
func DefaultParams() Params { return Params{} }
|
||||
|
||||
type GenesisState struct {
|
||||
Params Params `json:"params" yaml:"params"`
|
||||
}
|
||||
|
||||
func DefaultGenesisState() *GenesisState {
|
||||
return &GenesisState{Params: DefaultParams()}
|
||||
}
|
||||
|
||||
func ValidateGenesis(bz json.RawMessage) error { return nil }
|
||||
@@ -0,0 +1,58 @@
|
||||
package types_test
|
||||
|
||||
import (
|
||||
"testing"
|
||||
|
||||
btypes "github.com/oy/openyield/x/bearers/types"
|
||||
ptypes "github.com/oy/openyield/x/processing/types"
|
||||
)
|
||||
|
||||
func TestBearerCount(t *testing.T) {
|
||||
bearers := btypes.AllBearers()
|
||||
if len(bearers) != 6 {
|
||||
t.Errorf("Expected 6 bearers (§14), got %d", len(bearers))
|
||||
}
|
||||
}
|
||||
|
||||
func TestSurveillanceResistantBearers(t *testing.T) {
|
||||
bearers := btypes.AllBearers()
|
||||
for _, b := range bearers {
|
||||
if b.Type == btypes.BearerInternet && b.SurveillanceResistant {
|
||||
t.Error("Internet bearer should NOT be surveillance-resistant (§14)")
|
||||
}
|
||||
if b.Type != btypes.BearerInternet && !b.SurveillanceResistant {
|
||||
t.Errorf("Bearer %s should be surveillance-resistant (§14)", b.Type)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func TestProcessingModeFCFS(t *testing.T) {
|
||||
if ptypes.ModeFCFS != "FCFS" {
|
||||
t.Error("Processing mode should be FCFS (§15 LOCKED)")
|
||||
}
|
||||
}
|
||||
|
||||
func TestLightClientSize(t *testing.T) {
|
||||
if ptypes.LightClientSizeMB != 30 {
|
||||
t.Errorf("LightClientSize = %d, expected 30 MB (§15)", ptypes.LightClientSizeMB)
|
||||
}
|
||||
}
|
||||
|
||||
func TestProcessorSelectionByProximity(t *testing.T) {
|
||||
processors := []ptypes.Processor{
|
||||
{ProcessorID: "far", Latitude: 40.0, Longitude: 40.0},
|
||||
{ProcessorID: "close", Latitude: 10.0, Longitude: 10.0},
|
||||
{ProcessorID: "mid", Latitude: 20.0, Longitude: 20.0},
|
||||
}
|
||||
selected := ptypes.SelectProcessorByProximity(10.1, 10.1, processors)
|
||||
if selected == nil || selected.ProcessorID != "close" {
|
||||
t.Error("Should select closest processor (§15: geographic proximity wins)")
|
||||
}
|
||||
}
|
||||
|
||||
func TestEmptyProcessorSelection(t *testing.T) {
|
||||
selected := ptypes.SelectProcessorByProximity(10.0, 10.0, []ptypes.Processor{})
|
||||
if selected != nil {
|
||||
t.Error("Empty processor list should return nil")
|
||||
}
|
||||
}
|
||||
@@ -36,7 +36,7 @@ type BloomBoosterBucket struct {
|
||||
UnlockHeight int64 `json:"unlock_height" yaml:"unlock_height"`
|
||||
}
|
||||
|
||||
// BloomSource defines where Bloom originates (§6: only from real yield)
|
||||
// BloomSource defines where Bloom originates (§6: only from real production)
|
||||
type BloomSource string
|
||||
|
||||
const (
|
||||
@@ -46,10 +46,10 @@ const (
|
||||
BloomFromRwaCashflow BloomSource = "RwaCashflow"
|
||||
)
|
||||
|
||||
// MissionLockBloom: Bloom originates ONLY from real yield (§6)
|
||||
// MissionLockBloom: Bloom originates ONLY from real production (§6)
|
||||
// No synthetic Bloom. No protocol-printed Bloom.
|
||||
// This is a Mission Lock — no Council vote can change it.
|
||||
const MissionLockBloom = "Bloom originates only from real yield. No synthetic Bloom. No protocol-printed Bloom."
|
||||
const MissionLockBloom = "Bloom originates only from real production. No synthetic Bloom. No protocol-printed Bloom."
|
||||
|
||||
type Params struct {
|
||||
TargetRateBps uint32 `json:"target_rate_bps" yaml:"target_rate_bps"`
|
||||
|
||||
@@ -0,0 +1,122 @@
|
||||
package types
|
||||
|
||||
import "encoding/json"
|
||||
|
||||
const (
|
||||
ModuleName = "feecovenant"
|
||||
StoreKey = ModuleName
|
||||
RouterKey = ModuleName
|
||||
QuerierRoute = ModuleName
|
||||
|
||||
// Fee Covenant — LOCKED (§18)
|
||||
// Mission-lock: fee can never exceed 0.1pct or fall below 0.01pct.
|
||||
// Both bounds enforced by smart contract. No future Council vote can change them.
|
||||
// Auto-decline only — fees only go down as the mesh grows, never up.
|
||||
|
||||
FeeCeilingBps = 10 // 0.1pct (ceiling, LOCKED)
|
||||
FeeFloorBps = 1 // 0.01pct (floor, LOCKED)
|
||||
InternalMinGrain = 1 // 1 Grain internal minimum (LOCKED, never changes)
|
||||
|
||||
// Volume tier thresholds (§18)
|
||||
VolumeTier2Bps = 7 // 0.07pct at $10B
|
||||
VolumeTier3Bps = 5 // 0.05pct at $50B
|
||||
VolumeTier4Bps = 3 // 0.03pct at $200B
|
||||
VolumeTier5Bps = 2 // 0.02pct at $500B
|
||||
VolumeFloorBps = 1 // 0.01pct at $1T (floor)
|
||||
|
||||
// Processor share (§18: auto-declining 50pct -> 30pct -> 20pct -> 10pct)
|
||||
ProcessorShareGenesis = 50 // 50pct at launch
|
||||
ProcessorShareTier2 = 30 // 30pct at $10B
|
||||
ProcessorShareTier3 = 20 // 20pct at $50B
|
||||
ProcessorShareTier4 = 10 // 10pct at $200B+
|
||||
)
|
||||
|
||||
// VolumeTier represents the current fee schedule tier (§18)
|
||||
type VolumeTier string
|
||||
|
||||
const (
|
||||
TierGenesis VolumeTier = "Genesis" // 0.1pct (ceiling)
|
||||
TierStage2 VolumeTier = "Stage2" // 0.07pct at $10B
|
||||
TierStage3 VolumeTier = "Stage3" // 0.05pct at $50B
|
||||
TierStage4 VolumeTier = "Stage4" // 0.03pct at $200B
|
||||
TierStage5 VolumeTier = "Stage5" // 0.02pct at $500B
|
||||
TierFloor VolumeTier = "Floor" // 0.01pct at $1T (floor)
|
||||
)
|
||||
|
||||
// WaiverReason defines "always free" pass types (§18)
|
||||
// 0pct protocol fee; only 1-Grain internal minimum
|
||||
type WaiverReason string
|
||||
|
||||
const (
|
||||
WaiverHandPassGuild WaiverReason = "HandPassGuild"
|
||||
WaiverCrewInternalVault WaiverReason = "CrewInternalVault"
|
||||
WaiverHouseholdInternal WaiverReason = "HouseholdInternal"
|
||||
WaiverCoverCall WaiverReason = "CoverCall"
|
||||
WaiverTrustDistribution WaiverReason = "TrustDistribution"
|
||||
WaiverFoundationGrant WaiverReason = "FoundationGrant"
|
||||
WaiverCircleActiveCycle WaiverReason = "CircleActiveCycle"
|
||||
)
|
||||
|
||||
// FeeSchedule is the current fee schedule (§18)
|
||||
type FeeSchedule struct {
|
||||
CeilingBps uint32 `json:"ceiling_bps" yaml:"ceiling_bps"`
|
||||
FloorBps uint32 `json:"floor_bps" yaml:"floor_bps"`
|
||||
CurrentBps uint32 `json:"current_bps" yaml:"current_bps"`
|
||||
VolumeTier VolumeTier `json:"volume_tier" yaml:"volume_tier"`
|
||||
InternalMinGrain int64 `json:"internal_min_grain" yaml:"internal_min_grain"`
|
||||
}
|
||||
|
||||
// DefaultFeeSchedule returns the launch fee schedule (§18)
|
||||
func DefaultFeeSchedule() FeeSchedule {
|
||||
return FeeSchedule{
|
||||
CeilingBps: FeeCeilingBps,
|
||||
FloorBps: FeeFloorBps,
|
||||
CurrentBps: FeeCeilingBps, // starts at ceiling
|
||||
VolumeTier: TierGenesis,
|
||||
InternalMinGrain: InternalMinGrain,
|
||||
}
|
||||
}
|
||||
|
||||
// Clamp ensures fee is within LOCKED bounds (§18: never > ceiling, never < floor)
|
||||
// This is automatic and authoritative. No Council vote can change it.
|
||||
func Clamp(feeBps uint32) uint32 {
|
||||
if feeBps > FeeCeilingBps {
|
||||
return FeeCeilingBps
|
||||
}
|
||||
if feeBps < FeeFloorBps {
|
||||
return FeeFloorBps
|
||||
}
|
||||
return feeBps
|
||||
}
|
||||
|
||||
// IsWaived checks if a pass type is "always free" (§18)
|
||||
func IsWaived(reason WaiverReason) bool {
|
||||
switch reason {
|
||||
case WaiverHandPassGuild, WaiverCrewInternalVault, WaiverHouseholdInternal,
|
||||
WaiverCoverCall, WaiverTrustDistribution, WaiverFoundationGrant,
|
||||
WaiverCircleActiveCycle:
|
||||
return true
|
||||
}
|
||||
return false
|
||||
}
|
||||
|
||||
// MissionLockFeeCovenant — enforced by code, not by promise (§18)
|
||||
const MissionLockFeeCovenant = "Standard Pass-Act fee: never above 0.1pct, never below 0.01pct. Auto-decline on schedule, never auto-increase. Internal minimum: 1 Grain per waived Pass-Act. Never changes. This covenant is enforced by code, not by promise."
|
||||
|
||||
type Params struct {
|
||||
Schedule FeeSchedule `json:"schedule" yaml:"schedule"`
|
||||
}
|
||||
|
||||
func DefaultParams() Params {
|
||||
return Params{Schedule: DefaultFeeSchedule()}
|
||||
}
|
||||
|
||||
type GenesisState struct {
|
||||
Params Params `json:"params" yaml:"params"`
|
||||
}
|
||||
|
||||
func DefaultGenesisState() *GenesisState {
|
||||
return &GenesisState{Params: DefaultParams()}
|
||||
}
|
||||
|
||||
func ValidateGenesis(bz json.RawMessage) error { return nil }
|
||||
@@ -0,0 +1,79 @@
|
||||
package types_test
|
||||
|
||||
import (
|
||||
"testing"
|
||||
|
||||
"github.com/oy/openyield/x/feecovenant/types"
|
||||
)
|
||||
|
||||
func TestFeeCeiling(t *testing.T) {
|
||||
if types.FeeCeilingBps != 10 {
|
||||
t.Errorf("FeeCeilingBps = %d, expected 10 (§18: 0.1pct ceiling LOCKED)", types.FeeCeilingBps)
|
||||
}
|
||||
}
|
||||
|
||||
func TestFeeFloor(t *testing.T) {
|
||||
if types.FeeFloorBps != 1 {
|
||||
t.Errorf("FeeFloorBps = %d, expected 1 (§18: 0.01pct floor LOCKED)", types.FeeFloorBps)
|
||||
}
|
||||
}
|
||||
|
||||
func TestInternalMinGrain(t *testing.T) {
|
||||
if types.InternalMinGrain != 1 {
|
||||
t.Errorf("InternalMinGrain = %d, expected 1 (§18: 1 Grain LOCKED)", types.InternalMinGrain)
|
||||
}
|
||||
}
|
||||
|
||||
func TestClamp(t *testing.T) {
|
||||
if types.Clamp(15) != 10 {
|
||||
t.Error("Clamp(15) should return 10 (ceiling)")
|
||||
}
|
||||
if types.Clamp(0) != 1 {
|
||||
t.Error("Clamp(0) should return 1 (floor)")
|
||||
}
|
||||
if types.Clamp(5) != 5 {
|
||||
t.Error("Clamp(5) should return 5 (within bounds)")
|
||||
}
|
||||
}
|
||||
|
||||
func TestVolumeTiers(t *testing.T) {
|
||||
if types.VolumeTier2Bps != 7 {
|
||||
t.Error("VolumeTier2 should be 7 bps (§18)")
|
||||
}
|
||||
if types.VolumeFloorBps != 1 {
|
||||
t.Error("VolumeFloor should be 1 bps (§18)")
|
||||
}
|
||||
}
|
||||
|
||||
func TestProcessorShares(t *testing.T) {
|
||||
if types.ProcessorShareGenesis != 50 {
|
||||
t.Error("ProcessorShareGenesis should be 50pct (§18)")
|
||||
}
|
||||
if types.ProcessorShareTier4 != 10 {
|
||||
t.Error("ProcessorShareTier4 should be 10pct (§18)")
|
||||
}
|
||||
}
|
||||
|
||||
func TestWaivers(t *testing.T) {
|
||||
waivers := []types.WaiverReason{
|
||||
types.WaiverHandPassGuild, types.WaiverCrewInternalVault,
|
||||
types.WaiverHouseholdInternal, types.WaiverCoverCall,
|
||||
types.WaiverTrustDistribution, types.WaiverFoundationGrant,
|
||||
types.WaiverCircleActiveCycle,
|
||||
}
|
||||
for _, w := range waivers {
|
||||
if !types.IsWaived(w) {
|
||||
t.Errorf("Waiver %s should be free (§18)", w)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func TestDefaultFeeSchedule(t *testing.T) {
|
||||
schedule := types.DefaultFeeSchedule()
|
||||
if schedule.CurrentBps != 10 {
|
||||
t.Error("Default CurrentBps should be 10 (Genesis ceiling)")
|
||||
}
|
||||
if schedule.VolumeTier != types.TierGenesis {
|
||||
t.Error("Default VolumeTier should be Genesis")
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,66 @@
|
||||
package types
|
||||
|
||||
import "encoding/json"
|
||||
|
||||
const (
|
||||
ModuleName = "identity"
|
||||
StoreKey = ModuleName
|
||||
RouterKey = ModuleName
|
||||
QuerierRoute = ModuleName
|
||||
)
|
||||
|
||||
// Reach is the mesh-native identity layer (§8, §9.6 Layer 1)
|
||||
// Cryptographic, virtual, no state identity
|
||||
type Reach struct {
|
||||
ReachID string `json:"reach_id" yaml:"reach_id"`
|
||||
HolderID string `json:"holder_id" yaml:"holder_id"`
|
||||
CreatedAt int64 `json:"created_at" yaml:"created_at"`
|
||||
PublicKey string `json:"public_key" yaml:"public_key"`
|
||||
IsNomad bool `json:"is_nomad" yaml:"is_nomad"`
|
||||
IsFreeholder bool `json:"is_freeholder" yaml:"is_freeholder"`
|
||||
}
|
||||
|
||||
// CitizenshipTier (§9)
|
||||
type CitizenshipTier string
|
||||
|
||||
const (
|
||||
TierNomad CitizenshipTier = "Nomad" // any Holder (lifestyle tier)
|
||||
TierFreeholder CitizenshipTier = "Freeholder" // earned full recognition (sovereign tier)
|
||||
)
|
||||
|
||||
// TwoLayerPassport (§9.6)
|
||||
// Layer 1: Reach (mesh-native, virtual, cryptographic)
|
||||
// Layer 2: Pier-routed real-world credentials (e-Residency, biometric IDs)
|
||||
// OY does not issue passports; OY routes to Piers that do.
|
||||
type TwoLayerPassport struct {
|
||||
ReachID string `json:"reach_id" yaml:"reach_id"`
|
||||
Layer1Reach bool `json:"layer1_reach" yaml:"layer1_reach"`
|
||||
Layer2PierRouted bool `json:"layer2_pier_routed" yaml:"layer2_pier_routed"`
|
||||
PierCredentialRef string `json:"pier_credential_ref" yaml:"pier_credential_ref"`
|
||||
}
|
||||
|
||||
// WayfarersRecord is an optional Reach-signed attestation (§9.5)
|
||||
// Credential of belonging, not state identity
|
||||
type WayfarersRecord struct {
|
||||
ReachID string `json:"reach_id" yaml:"reach_id"`
|
||||
FreeholderStatus bool `json:"freeholder_status" yaml:"freeholder_status"`
|
||||
StandingScore float64 `json:"standing_score" yaml:"standing_score"`
|
||||
GuildAffiliations []string `json:"guild_affiliations" yaml:"guild_affiliations"`
|
||||
BloomHistory string `json:"bloom_history" yaml:"bloom_history"`
|
||||
IssuedAt int64 `json:"issued_at" yaml:"issued_at"`
|
||||
}
|
||||
|
||||
type Params struct{}
|
||||
|
||||
func DefaultParams() Params { return Params{} }
|
||||
|
||||
type GenesisState struct {
|
||||
Params Params `json:"params" yaml:"params"`
|
||||
Reaches []Reach `json:"reaches" yaml:"reaches"`
|
||||
}
|
||||
|
||||
func DefaultGenesisState() *GenesisState {
|
||||
return &GenesisState{Params: DefaultParams(), Reaches: []Reach{}}
|
||||
}
|
||||
|
||||
func ValidateGenesis(bz json.RawMessage) error { return nil }
|
||||
@@ -0,0 +1,79 @@
|
||||
package types
|
||||
|
||||
import "encoding/json"
|
||||
|
||||
const (
|
||||
ModuleName = "mesh"
|
||||
StoreKey = ModuleName
|
||||
RouterKey = ModuleName
|
||||
QuerierRoute = ModuleName
|
||||
)
|
||||
|
||||
// Four Faces of the mesh experience (§8)
|
||||
// Reach (who you are), Standing (who you can trust),
|
||||
// Maps (where you are), Pay (how value flows)
|
||||
type MeshFace string
|
||||
|
||||
const (
|
||||
FaceReach MeshFace = "Reach"
|
||||
FaceStanding MeshFace = "Standing"
|
||||
FaceMaps MeshFace = "Maps"
|
||||
FacePay MeshFace = "Pay"
|
||||
)
|
||||
|
||||
// AllFaces returns the four mesh faces (§8)
|
||||
func AllFaces() []MeshFace {
|
||||
return []MeshFace{FaceReach, FaceStanding, FaceMaps, FacePay}
|
||||
}
|
||||
|
||||
// MapEntry is a discovery entry (§8: Maps — where you are, what's around)
|
||||
type MapEntry struct {
|
||||
EntryID string `json:"entry_id" yaml:"entry_id"`
|
||||
Name string `json:"name" yaml:"name"`
|
||||
Latitude float64 `json:"latitude" yaml:"latitude"`
|
||||
Longitude float64 `json:"longitude" yaml:"longitude"`
|
||||
Category string `json:"category" yaml:"category"` // Op, Pier, service
|
||||
HolderID string `json:"holder_id" yaml:"holder_id"`
|
||||
IsOp bool `json:"is_op" yaml:"is_op"`
|
||||
IsPier bool `json:"is_pier" yaml:"is_pier"`
|
||||
}
|
||||
|
||||
// PayAct represents a Pass-Act (value flow, §8: Pay)
|
||||
type PayAct struct {
|
||||
PassID string `json:"pass_id" yaml:"pass_id"`
|
||||
FromStashID string `json:"from_stash_id" yaml:"from_stash_id"`
|
||||
ToStashID string `json:"to_stash_id" yaml:"to_stash_id"`
|
||||
AmountGrain int64 `json:"amount_grain" yaml:"amount_grain"`
|
||||
FeeGrain int64 `json:"fee_grain" yaml:"fee_grain"`
|
||||
IsLongPass bool `json:"is_long_pass" yaml:"is_long_pass"` // remittance
|
||||
Timestamp int64 `json:"timestamp" yaml:"timestamp"`
|
||||
}
|
||||
|
||||
// ExitLayerType defines Layer 3 exit methods (§7)
|
||||
type ExitLayerType string
|
||||
|
||||
const (
|
||||
ExitDEX ExitLayerType = "DEX"
|
||||
ExitBridge ExitLayerType = "Bridge"
|
||||
ExitOffMesh ExitLayerType = "OffMesh"
|
||||
)
|
||||
|
||||
// MayasDayPlaceholder — full narrative deferred to component doc (§8, Q1)
|
||||
// The mesh is one environment with four invisible primitives
|
||||
// activating simultaneously. A Holder doesn't open apps — they live in the mesh.
|
||||
const MayasDayPlaceholder = "Maya's Day narrative deferred to Mesh Experience component doc (Architecture Q1)"
|
||||
|
||||
type Params struct{}
|
||||
|
||||
func DefaultParams() Params { return Params{} }
|
||||
|
||||
type GenesisState struct {
|
||||
Params Params `json:"params" yaml:"params"`
|
||||
MapEntries []MapEntry `json:"map_entries" yaml:"map_entries"`
|
||||
}
|
||||
|
||||
func DefaultGenesisState() *GenesisState {
|
||||
return &GenesisState{Params: DefaultParams(), MapEntries: []MapEntry{}}
|
||||
}
|
||||
|
||||
func ValidateGenesis(bz json.RawMessage) error { return nil }
|
||||
@@ -0,0 +1,39 @@
|
||||
package types_test
|
||||
|
||||
import (
|
||||
"testing"
|
||||
|
||||
"github.com/oy/openyield/x/mesh/types"
|
||||
)
|
||||
|
||||
func TestFourFaces(t *testing.T) {
|
||||
faces := types.AllFaces()
|
||||
if len(faces) != 4 {
|
||||
t.Errorf("Expected 4 mesh faces (§8), got %d", len(faces))
|
||||
}
|
||||
}
|
||||
|
||||
func TestFaceNames(t *testing.T) {
|
||||
expected := map[types.MeshFace]bool{
|
||||
types.FaceReach: true, types.FaceStanding: true,
|
||||
types.FaceMaps: true, types.FacePay: true,
|
||||
}
|
||||
for _, f := range types.AllFaces() {
|
||||
if !expected[f] {
|
||||
t.Errorf("Unexpected face: %s", f)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func TestExitLayerTypes(t *testing.T) {
|
||||
exits := []types.ExitLayerType{types.ExitDEX, types.ExitBridge, types.ExitOffMesh}
|
||||
if len(exits) != 3 {
|
||||
t.Errorf("Expected 3 exit layer types (§7), got %d", len(exits))
|
||||
}
|
||||
}
|
||||
|
||||
func TestMayasDayPlaceholder(t *testing.T) {
|
||||
if types.MayasDayPlaceholder == "" {
|
||||
t.Error("Maya's Day placeholder should note deferral (§8, Q1)")
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,85 @@
|
||||
package types
|
||||
|
||||
import "encoding/json"
|
||||
|
||||
const (
|
||||
ModuleName = "processing"
|
||||
StoreKey = ModuleName
|
||||
RouterKey = ModuleName
|
||||
QuerierRoute = ModuleName
|
||||
|
||||
// FCFS processing — NOT fee-auctioned (§15 LOCKED)
|
||||
// Geographic proximity wins (closest processor to recipient)
|
||||
// Anyone with a phone can process via light client (~30 MB app)
|
||||
|
||||
LightClientSizeMB = 30 // ~30 MB app
|
||||
BatteryPerDayActivePct = 3 // ~1-3pct battery/day active
|
||||
)
|
||||
|
||||
// ProcessingMode is FCFS (§15) — never fee-auctioned
|
||||
type ProcessingMode string
|
||||
|
||||
const (
|
||||
ModeFCFS ProcessingMode = "FCFS" // First-come-first-served, not fee-auctioned
|
||||
)
|
||||
|
||||
// Processor is a light client processing Pass-Acts (§15)
|
||||
type Processor struct {
|
||||
ProcessorID string `json:"processor_id" yaml:"processor_id"`
|
||||
ReachID string `json:"reach_id" yaml:"reach_id"`
|
||||
Latitude float64 `json:"latitude" yaml:"latitude"`
|
||||
Longitude float64 `json:"longitude" yaml:"longitude"`
|
||||
ActiveSince int64 `json:"active_since" yaml:"active_since"`
|
||||
BlocksProcessed uint64 `json:"blocks_processed" yaml:"blocks_processed"`
|
||||
}
|
||||
|
||||
// ProcessingJob is a Pass-Act awaiting processing
|
||||
type ProcessingJob struct {
|
||||
JobID string `json:"job_id" yaml:"job_id"`
|
||||
SenderLat float64 `json:"sender_lat" yaml:"sender_lat"`
|
||||
SenderLng float64 `json:"sender_lng" yaml:"sender_lng"`
|
||||
RecipientLat float64 `json:"recipient_lat" yaml:"recipient_lat"`
|
||||
RecipientLng float64 `json:"recipient_lng" yaml:"recipient_lng"`
|
||||
AmountGrain int64 `json:"amount_grain" yaml:"amount_grain"`
|
||||
Timestamp int64 `json:"timestamp" yaml:"timestamp"`
|
||||
}
|
||||
|
||||
// SelectProcessorByProximity — geographic proximity wins (§15)
|
||||
// In FCFS mode, the closest processor to the recipient processes the job
|
||||
func SelectProcessorByProximity(recipientLat, recipientLng float64, processors []Processor) *Processor {
|
||||
if len(processors) == 0 {
|
||||
return nil
|
||||
}
|
||||
closest := &processors[0]
|
||||
minDist := haversine(recipientLat, recipientLng, closest.Latitude, closest.Longitude)
|
||||
for i := 1; i < len(processors); i++ {
|
||||
dist := haversine(recipientLat, recipientLng, processors[i].Latitude, processors[i].Longitude)
|
||||
if dist < minDist {
|
||||
minDist = dist
|
||||
closest = &processors[i]
|
||||
}
|
||||
}
|
||||
return closest
|
||||
}
|
||||
|
||||
// haversine computes distance between two coordinates (simplified)
|
||||
func haversine(lat1, lng1, lat2, lng2 float64) float64 {
|
||||
dlat := lat2 - lat1
|
||||
dlng := lng2 - lng1
|
||||
return dlat*dlat + dlng*dlng // squared distance (sufficient for comparison)
|
||||
}
|
||||
|
||||
type Params struct{}
|
||||
|
||||
func DefaultParams() Params { return Params{} }
|
||||
|
||||
type GenesisState struct {
|
||||
Params Params `json:"params" yaml:"params"`
|
||||
Processors []Processor `json:"processors" yaml:"processors"`
|
||||
}
|
||||
|
||||
func DefaultGenesisState() *GenesisState {
|
||||
return &GenesisState{Params: DefaultParams(), Processors: []Processor{}}
|
||||
}
|
||||
|
||||
func ValidateGenesis(bz json.RawMessage) error { return nil }
|
||||
@@ -0,0 +1,160 @@
|
||||
package types
|
||||
|
||||
import "encoding/json"
|
||||
|
||||
const (
|
||||
ModuleName = "standing"
|
||||
StoreKey = ModuleName
|
||||
RouterKey = ModuleName
|
||||
QuerierRoute = ModuleName
|
||||
|
||||
// Standing formula parameters (§9.2 — LOCKED)
|
||||
PriorMean = 4.0 // Bayesian prior mean
|
||||
PriorWeight = 10 // Bayesian prior weight
|
||||
DecayBucket6mo = 1.0 // 6mo: 100pct
|
||||
DecayBucket12mo = 0.5 // 12mo: 50pct
|
||||
DecayBucket24mo = 0.25 // 24mo: 25pct
|
||||
DecayBucket24plus = 0.0 // 24mo+: 0pct
|
||||
|
||||
// Diversity bonus (§9.2)
|
||||
DiversityBonus3Cats = 0.05
|
||||
DiversityBonus4Cats = 0.10
|
||||
DiversityBonus5Cats = 0.15
|
||||
|
||||
// Voucher weights (§9.2)
|
||||
VoucherWeightFreeholder = 1.5
|
||||
VoucherWeight45Plus = 1.2
|
||||
VoucherWeight40To45 = 1.0
|
||||
VoucherWeightBelow40 = 0.5
|
||||
VoucherWeightBelow10Ratings = 0.3
|
||||
|
||||
// Minimum counterparties (§9.2)
|
||||
MinCounterpartiesValid = 3 // to be valid
|
||||
MinCounterpartiesFreeholderEligible = 10 // to be Freeholder-eligible
|
||||
MinCounterpartiesFreeholderStatus = 30 // across 3 categories for Freeholder status
|
||||
|
||||
// Freeholder Four Signals (§9.1 — LOCKED)
|
||||
FreeholderStashMaturityDays = 90 // 90 days Stash activity
|
||||
FreeholderStashMaxGapDays = 30 // no gap > 30 days
|
||||
FreeholderMinStandingScore = 4.5 // 4.5+ in at least 3 service categories
|
||||
FreeholderMinCategories = 3 // at least 3 service categories
|
||||
)
|
||||
|
||||
// Rating is a single rating event (§9.2)
|
||||
type Rating struct {
|
||||
RaterID string `json:"rater_id" yaml:"rater_id"`
|
||||
RateeID string `json:"ratee_id" yaml:"ratee_id"`
|
||||
Category string `json:"category" yaml:"category"`
|
||||
Score float64 `json:"score" yaml:"score"` // 0.0-5.0
|
||||
Weight float64 `json:"weight" yaml:"weight"` // derived from rater Voucher_Weight
|
||||
TxRef string `json:"tx_ref" yaml:"tx_ref"`
|
||||
Timestamp int64 `json:"timestamp" yaml:"timestamp"`
|
||||
DecayBucket uint8 `json:"decay_bucket" yaml:"decay_bucket"`
|
||||
}
|
||||
|
||||
// Vouch is a Freeholder vouch with skin-in-the-game (§9.1)
|
||||
type Vouch struct {
|
||||
VoucherID string `json:"voucher_id" yaml:"voucher_id"`
|
||||
VoucheeID string `json:"vouchee_id" yaml:"vouchee_id"`
|
||||
Category string `json:"category" yaml:"category"`
|
||||
BondAmount int64 `json:"bond_amount" yaml:"bond_amount"` // voucher skin-in-the-game
|
||||
Timestamp int64 `json:"timestamp" yaml:"timestamp"`
|
||||
}
|
||||
|
||||
// Slash penalizes a Holder (§9.4)
|
||||
type Slash struct {
|
||||
ReachID string `json:"reach_id" yaml:"reach_id"`
|
||||
Amount float64 `json:"amount" yaml:"amount"`
|
||||
Reason string `json:"reason" yaml:"reason"` // Crack, FraudulentCoverCall, InactivityTimeout
|
||||
Attester string `json:"attester" yaml:"attester"` // Watcher ID
|
||||
Timestamp int64 `json:"timestamp" yaml:"timestamp"`
|
||||
}
|
||||
|
||||
// StandingBucket for display (§9.2)
|
||||
type StandingBucket string
|
||||
|
||||
const (
|
||||
BucketNew StandingBucket = "New" // <10 ratings
|
||||
BucketTrusted StandingBucket = "Trusted" // 4.0-4.4
|
||||
BucketPreferred StandingBucket = "Preferred" // 4.5-4.7
|
||||
BucketTop StandingBucket = "Top" // 4.8+
|
||||
BucketSlashed StandingBucket = "Slashed" // penalized
|
||||
)
|
||||
|
||||
// FreeholderSignals — all four must be present (§9.1 LOCKED)
|
||||
type FreeholderSignals struct {
|
||||
StashMaturity bool `json:"stash_maturity" yaml:"stash_maturity"`
|
||||
MultiDomainStanding bool `json:"multi_domain_standing" yaml:"multi_domain_standing"`
|
||||
CommittedCapital bool `json:"committed_capital" yaml:"committed_capital"`
|
||||
CommunityEndorsement bool `json:"community_endorsement" yaml:"community_endorsement"`
|
||||
}
|
||||
|
||||
// IsFreeholderEligible checks all four signals (§9.1)
|
||||
// No application, no committee, no form. All four must be present.
|
||||
func (s FreeholderSignals) IsFreeholderEligible() bool {
|
||||
return s.StashMaturity && s.MultiDomainStanding && s.CommittedCapital && s.CommunityEndorsement
|
||||
}
|
||||
|
||||
// ComputeDiversityBonus returns the bonus for category count (§9.2)
|
||||
func ComputeDiversityBonus(categoryCount int) float64 {
|
||||
switch {
|
||||
case categoryCount >= 5:
|
||||
return DiversityBonus5Cats
|
||||
case categoryCount == 4:
|
||||
return DiversityBonus4Cats
|
||||
case categoryCount == 3:
|
||||
return DiversityBonus3Cats
|
||||
}
|
||||
return 0.0
|
||||
}
|
||||
|
||||
// GetVoucherWeight returns the weight for a given rater profile (§9.2)
|
||||
func GetVoucherWeight(isFreeholder bool, standingScore float64, ratingCount int) float64 {
|
||||
if isFreeholder {
|
||||
return VoucherWeightFreeholder
|
||||
}
|
||||
if ratingCount < 10 {
|
||||
return VoucherWeightBelow10Ratings
|
||||
}
|
||||
if standingScore >= 4.5 {
|
||||
return VoucherWeight45Plus
|
||||
}
|
||||
if standingScore >= 4.0 {
|
||||
return VoucherWeight40To45
|
||||
}
|
||||
return VoucherWeightBelow40
|
||||
}
|
||||
|
||||
// GetStandingBucket returns the display bucket for a score (§9.2)
|
||||
func GetStandingBucket(score float64, ratingCount int, isSlashed bool) StandingBucket {
|
||||
if isSlashed {
|
||||
return BucketSlashed
|
||||
}
|
||||
if ratingCount < 10 {
|
||||
return BucketNew
|
||||
}
|
||||
switch {
|
||||
case score >= 4.8:
|
||||
return BucketTop
|
||||
case score >= 4.5:
|
||||
return BucketPreferred
|
||||
case score >= 4.0:
|
||||
return BucketTrusted
|
||||
}
|
||||
return BucketNew
|
||||
}
|
||||
|
||||
type Params struct{}
|
||||
|
||||
func DefaultParams() Params { return Params{} }
|
||||
|
||||
type GenesisState struct {
|
||||
Params Params `json:"params" yaml:"params"`
|
||||
Ratings []Rating `json:"ratings" yaml:"ratings"`
|
||||
}
|
||||
|
||||
func DefaultGenesisState() *GenesisState {
|
||||
return &GenesisState{Params: DefaultParams(), Ratings: []Rating{}}
|
||||
}
|
||||
|
||||
func ValidateGenesis(bz json.RawMessage) error { return nil }
|
||||
@@ -0,0 +1,100 @@
|
||||
package types_test
|
||||
|
||||
import (
|
||||
"testing"
|
||||
|
||||
"github.com/oy/openyield/x/standing/types"
|
||||
)
|
||||
|
||||
func TestFreeholderSignalsAllPresent(t *testing.T) {
|
||||
signals := types.FreeholderSignals{
|
||||
StashMaturity: true,
|
||||
MultiDomainStanding: true,
|
||||
CommittedCapital: true,
|
||||
CommunityEndorsement: true,
|
||||
}
|
||||
if !signals.IsFreeholderEligible() {
|
||||
t.Error("All four signals present should be Freeholder eligible (§9.1)")
|
||||
}
|
||||
}
|
||||
|
||||
func TestFreeholderSignalsMissing(t *testing.T) {
|
||||
signals := types.FreeholderSignals{
|
||||
StashMaturity: true,
|
||||
MultiDomainStanding: true,
|
||||
CommittedCapital: true,
|
||||
CommunityEndorsement: false, // missing
|
||||
}
|
||||
if signals.IsFreeholderEligible() {
|
||||
t.Error("Missing one signal should NOT be Freeholder eligible (§9.1: all four must be present)")
|
||||
}
|
||||
}
|
||||
|
||||
func TestDiversityBonus(t *testing.T) {
|
||||
if types.ComputeDiversityBonus(3) != 0.05 {
|
||||
t.Error("3 categories should give +0.05 bonus (§9.2)")
|
||||
}
|
||||
if types.ComputeDiversityBonus(4) != 0.10 {
|
||||
t.Error("4 categories should give +0.10 bonus (§9.2)")
|
||||
}
|
||||
if types.ComputeDiversityBonus(5) != 0.15 {
|
||||
t.Error("5+ categories should give +0.15 bonus (§9.2)")
|
||||
}
|
||||
if types.ComputeDiversityBonus(2) != 0.0 {
|
||||
t.Error("2 categories should give 0 bonus (§9.2)")
|
||||
}
|
||||
}
|
||||
|
||||
func TestVoucherWeights(t *testing.T) {
|
||||
if types.GetVoucherWeight(true, 4.0, 100) != 1.5 {
|
||||
t.Error("Freeholder weight should be 1.5x (§9.2)")
|
||||
}
|
||||
if types.GetVoucherWeight(false, 4.6, 100) != 1.2 {
|
||||
t.Error("4.5+ with 1-2 cats should be 1.2x (§9.2)")
|
||||
}
|
||||
if types.GetVoucherWeight(false, 4.2, 100) != 1.0 {
|
||||
t.Error("4.0-4.5 should be 1.0x (§9.2)")
|
||||
}
|
||||
if types.GetVoucherWeight(false, 3.5, 100) != 0.5 {
|
||||
t.Error("Below 4.0 should be 0.5x (§9.2)")
|
||||
}
|
||||
if types.GetVoucherWeight(false, 4.0, 5) != 0.3 {
|
||||
t.Error("Below 10 ratings should be 0.3x (§9.2)")
|
||||
}
|
||||
}
|
||||
|
||||
func TestStandingBuckets(t *testing.T) {
|
||||
if types.GetStandingBucket(4.9, 100, false) != types.BucketTop {
|
||||
t.Error("4.8+ should be Top (§9.2)")
|
||||
}
|
||||
if types.GetStandingBucket(4.6, 100, false) != types.BucketPreferred {
|
||||
t.Error("4.5-4.7 should be Preferred (§9.2)")
|
||||
}
|
||||
if types.GetStandingBucket(4.2, 100, false) != types.BucketTrusted {
|
||||
t.Error("4.0-4.4 should be Trusted (§9.2)")
|
||||
}
|
||||
if types.GetStandingBucket(3.5, 100, false) != types.BucketNew {
|
||||
t.Error("Below 4.0 should be New (§9.2)")
|
||||
}
|
||||
if types.GetStandingBucket(4.5, 5, false) != types.BucketNew {
|
||||
t.Error("Below 10 ratings should be New (§9.2)")
|
||||
}
|
||||
if types.GetStandingBucket(4.5, 100, true) != types.BucketSlashed {
|
||||
t.Error("Slashed should be Slashed bucket (§9.2)")
|
||||
}
|
||||
}
|
||||
|
||||
func TestLockedConstants(t *testing.T) {
|
||||
if types.FreeholderStashMaturityDays != 90 {
|
||||
t.Error("Stash maturity should be 90 days (§9.1 LOCKED)")
|
||||
}
|
||||
if types.FreeholderMinStandingScore != 4.5 {
|
||||
t.Error("Min standing score should be 4.5 (§9.1 LOCKED)")
|
||||
}
|
||||
if types.FreeholderMinCategories != 3 {
|
||||
t.Error("Min categories should be 3 (§9.1 LOCKED)")
|
||||
}
|
||||
if types.MinCounterpartiesFreeholderStatus != 30 {
|
||||
t.Error("Min counterparties for Freeholder status should be 30 (§9.2)")
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user