Handoff: Spec: Mission Language + Observer Protocol — Refactoring Approach (16 files)

Author: CodeByMAB

BRS.md

@@ -35,17 +35,17 @@
 
 ## 1. Executive Summary
 
-The **Open World Model (OWM)** is an open-source, federated ensemble of AI models that collectively builds, maintains, and continuously updates a comprehensive model of the real world — encompassing geography, science, code, language, and live data streams. The system runs on a permissionless, decentralized network of GPU-equipped nodes. Node operators are compensated in Bitcoin via the Lightning Network for their compute and data contributions. Model versioning and integrity are anchored to the Bitcoin blockchain via **OpenTimestamps**. The project is well-versed in software engineering and Git, enabling it to autonomously analyze, improve, and generate pull requests for GitHub repositories. The treasury is controlled by a Bitcoin multisig wallet; technical governance follows a rough-consensus model.
+The **Open World Model (OWM)** is not a model of the world — it is a **distributed AI** formed from many different AI models that work together as a single conglomerate. It is an open-source, federated ensemble that collectively builds, maintains, and continuously updates this conglomerate, with diverse capabilities encompassing geography, science, code, language, and live data streams. The system runs on a permissionless, decentralized network of GPU-equipped nodes. Node operators are compensated in Bitcoin via the Lightning Network for their compute and data contributions. Model versioning and integrity are anchored to the Bitcoin blockchain via **OpenTimestamps**. The project is well-versed in software engineering and Git, enabling it to autonomously analyze, improve, and generate pull requests for GitHub repositories. The treasury is controlled by a Bitcoin multisig wallet; technical governance follows a rough-consensus model.
 
 Node participation is secured by two complementary Bitcoin-native mechanisms: **Proof-of-Work (PoW)** — nodes may optionally contribute hashrate to the OWM-operated Stratum v2 Bitcoin mining pool, with mining revenue split between the miner and the treasury; and **Proof-of-Stake (PoS)** — all joining nodes must open a Lightning payment channel to the treasury of a minimum size determined by their hardware tier, locking in a financial commitment that can be force-closed upon verified misbehavior.
 
 ---
 
 ## 2. Business Context & Problem Statement
 
-### 2.1 Current State of World Models
+### 2.1 Current State of Large-Scale AI
 
-Existing large-scale AI world models (e.g., large language models, knowledge graphs) are:
+Existing large-scale AI systems (e.g., large language models, knowledge graphs) are:
 
 - **Centralized**: Controlled by a small number of corporations with opaque governance.
 - **Expensive to run**: Requiring massive proprietary data centers inaccessible to independent contributors.
@@ -59,7 +59,7 @@ Bitcoin's Lightning Network enables programmable, near-zero-fee micropayments gl
 
 ### 2.3 Problem Statement
 
-There is no open, continuously updated, decentralized AI world model that:
+There is no open, continuously updated, decentralized distributed AI (conglomerate of many models) that:
 1. Compensates contributors fairly and automatically with real money (Bitcoin).
 2. Allows anyone with a GPU to join and earn rewards.
 3. Is demonstrably trustworthy via cryptographic model provenance (OpenTimestamps).
@@ -70,9 +70,9 @@ There is no open, continuously updated, decentralized AI world model that:
 
 ## 3. Project Vision
 
-> **"A living, open model of our world — built by everyone, owned by no one, powered by Bitcoin."**
+> **"A distributed AI built by everyone, owned by no one, powered by Bitcoin."**
 
-The Open World Model will be the world's first community-owned, continuously updated AI that understands the planet — its geography, science, culture, code, and events — funded and incentivized entirely through the Bitcoin economy.
+The Open World Model is a conglomerate AI: many different AI models combined into one distributed system. It will be the world's first community-owned, continuously updated distributed AI of this kind — capable across geography, science, culture, code, and events — funded and incentivized entirely through the Bitcoin economy.
 
 ---
 
@@ -387,7 +387,7 @@ The Lightning channel stake acts as OWM's native Proof-of-Stake mechanism — en
 
 | Term | Definition |
 |---|---|
-| **OWM** | Open World Model — the project name |
+| **OWM** | Open World Model — distributed/conglomerate AI project (many models, one system) |
 | **Node** | A machine operated by a contributor that provides GPU compute to the OWM network |
 | **Federated Ensemble** | A collection of specialized AI sub-models that collaborate to produce outputs, where each sub-model may be trained on different nodes |
 | **Federated Learning** | A machine learning approach where model training occurs locally on nodes; only gradient updates (not raw data) are shared |

README.md

@@ -1,10 +1,10 @@
 # Open World Model (OWM)
 
-> *"A living, open model of our world — built by everyone, owned by no one, powered by Bitcoin."*
+> *"A distributed AI built by everyone, owned by no one, powered by Bitcoin."*
 
 ## What is OWM?
 
-The **Open World Model** is an open-source, federated ensemble of AI models that build and maintain a comprehensive, continuously updated model of the real world — geography, science, code, language, and live data. The system runs on a permissionless network of GPU nodes. Node operators are compensated in **Bitcoin** via the **Lightning Network**. Model versions are anchored to the Bitcoin blockchain via **OpenTimestamps**. The project integrates with **GitHub** for automated code analysis, security audits, and PR generation. Participation is secured by Bitcoin-native **Proof-of-Work** (optional mining pool contribution) and **Proof-of-Stake** (Lightning channel stake to the treasury); there is no new token.
+The **Open World Model** is not a model of the world — it is a **distributed AI** formed from many different AI models working together as a single conglomerate. It is an open-source, federated ensemble of models that collectively run on a permissionless network, continuously updated with diverse capabilities (e.g. geography, science, code, language, live data). The system runs on a permissionless network of GPU nodes. Node operators are compensated in **Bitcoin** via the **Lightning Network**. Model versions are anchored to the Bitcoin blockchain via **OpenTimestamps**. The project integrates with **GitHub** for automated code analysis, security audits, and PR generation. Participation is secured by Bitcoin-native **Proof-of-Work** (optional mining pool contribution) and **Proof-of-Stake** (Lightning channel stake to the treasury); there is no new token.
 
 For full business and technical requirements, see [BRS.md](BRS.md) and [SRS.md](SRS.md).
 

SRS.md

@@ -84,7 +84,7 @@ This document covers all software components of the OWM system: the node daemon,
 
 ### 2.1 Product Perspective
 
-OWM is a standalone distributed system composed of:
+OWM is a **distributed AI**: many different AI models form one conglomerate system (it is not a single "model of the world"). It is a standalone distributed system composed of:
 - A **P2P node network** where each node runs the OWM daemon.
 - A **coordinator layer** that bootstraps the network and routes tasks (decentralizes progressively).
 - A **model layer** consisting of a federated ensemble of transformer-based sub-models.
@@ -98,7 +98,7 @@ OWM is a standalone distributed system composed of:
 |---|---|---|
 | Node Operator | CLI + Dashboard | Run node daemon, earn BTC |
 | Data Contributor | CLI + API | Submit datasets, earn BTC |
-| API Consumer | REST/WebSocket API | Query world model |
+| API Consumer | REST/WebSocket API | Query the conglomerate model (OWM) |
 | GitHub User | GitHub App + Bounty Board | Contribute code, earn BTC |
 | Core Maintainer | All interfaces + admin CLI | Deploy, configure, govern |
 | Treasury Signer | Multisig wallet UI | Approve treasury transactions |
@@ -539,7 +539,7 @@ jobs:
 
 ```
 # Query API
-POST   /v1/query                    # Send a query to the world model
+POST   /v1/query                    # Send a query to the conglomerate model (OWM)
 POST   /v1/query/stream             # Streaming token generation (WebSocket)
 GET    /v1/query/{query_id}         # Retrieve cached query result
 

owm-coordinator/cmd/coordinator/main.go

@@ -33,6 +33,7 @@ import (
 	_ "github.com/owmnetwork/owm-coordinator/internal/metrics"
 	"github.com/owmnetwork/owm-coordinator/internal/lightning"
 	"github.com/owmnetwork/owm-coordinator/internal/lightning/mock"
+	"github.com/owmnetwork/owm-coordinator/internal/observer"
 	"github.com/owmnetwork/owm-coordinator/internal/payment"
 	"github.com/owmnetwork/owm-coordinator/internal/registry"
 	"github.com/owmnetwork/owm-coordinator/internal/rpc"
@@ -197,7 +198,33 @@ func run() error {
 		GradientL2ClipNorm:     cfg.FL.GradientL2ClipNorm,
 		AnomalyStdDevThreshold: cfg.FL.AnomalyStdDevThreshold,
 	}, log)
-	disp := payment.New(lnPayment, db, rdb, log)
+
+	var obsClient *observer.Client
+	if cfg.Observer.Enabled {
+		keyData, err := os.ReadFile(cfg.Observer.SigningKeyPath)
+		if err != nil {
+			return fmt.Errorf("observer signing key: %w", err)
+		}
+		obsClient, err = observer.NewClient(observer.ClientConfig{
+			APIEndpoint:       cfg.Observer.APIEndpoint,
+			SigningKeyPEMOrHex: keyData,
+			Log:               log,
+		})
+		if err != nil {
+			return fmt.Errorf("observer client: %w", err)
+		}
+		info, err := lnReadonly.GetInfo(context.Background())
+		if err != nil {
+			return fmt.Errorf("observer: get treasury pubkey (GetInfo): %w", err)
+		}
+		senderPubkeyHash := observer.PubkeyHashHex(info.PubkeyHex)
+		if senderPubkeyHash == "" {
+			return fmt.Errorf("observer: treasury pubkey from GetInfo produced empty hash (pubkey_hex length=%d); cannot set sender_public_key_hash for receipt submission", len(info.PubkeyHex))
+		}
+		obsClient.SetSenderPubkeyHash(senderPubkeyHash)
+		log.Info("observer protocol enabled", zap.String("api", cfg.Observer.APIEndpoint))
+	}
+	disp := payment.New(lnPayment, db, rdb, log, obsClient)
 
 	// ── gRPC server ───────────────────────────────────────────────────────────
 	srv := rpc.New(reg, sched, verif, flOrch, disp, rdb, db, log)