Merge pull request #57 from Reef-Network/staging

staging 2 main

Author: KjetilVaa

README.md

@@ -12,7 +12,7 @@
 </p>
 
 <p align="center">
-  <img src="https://img.shields.io/badge/version-0.2.16-blue" alt="Version 0.2.16" />
+  <img src="https://img.shields.io/badge/version-0.2.17-blue" alt="Version 0.2.17" />
   <img src="https://img.shields.io/badge/A2A-v0.3.0-blueviolet" alt="A2A v0.3.0" />
   <img src="https://img.shields.io/badge/license-MIT-green" alt="MIT License" />
   <img src="https://img.shields.io/badge/status-beta-orange" alt="Status: Beta" />
@@ -449,7 +449,7 @@ The protocol version is defined in a single place:
 
 ```typescript
 // protocol/src/types.ts
-export const REEF_VERSION = "0.2.16";
+export const REEF_VERSION = "0.2.17";
 export const A2A_PROTOCOL_VERSION = "0.3.0";
 ```
 

client/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@reef-protocol/client",
-  "version": "0.2.16",
+  "version": "0.2.17",
   "description": "Reef Protocol client — daemon, CLI, and identity management",
   "type": "module",
   "main": "dist/daemon.js",

client/src/app-markdown.ts

@@ -157,6 +157,11 @@ function parseFrontmatter(text: string): FrontmatterMap {
       const items: FrontmatterMap[] = [];
       i++;
       while (i < lines.length) {
+        // Skip blank lines between array items
+        if (!lines[i].trim()) {
+          i++;
+          continue;
+        }
         const itemLine = lines[i];
         if (!itemLine.match(/^\s+-\s/)) break;
 
@@ -176,8 +181,7 @@ function parseFrontmatter(text: string): FrontmatterMap {
           const contLine = lines[i];
           if (
             contLine.match(/^\s+-\s/) || // next array item
-            !contLine.match(/^\s/) || // back to top-level
-            !contLine.trim()
+            !contLine.match(/^\s/) // back to top-level
           ) {
             break;
           }

directory/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@reef-protocol/directory",
   "private": true,
-  "version": "0.2.16",
+  "version": "0.2.17",
   "description": "Reef Protocol directory server — agent discovery and network stats",
   "type": "module",
   "main": "dist/index.js",

directory/src/__tests__/api.test.ts

@@ -649,7 +649,8 @@ describe("heartbeat piggybacking for coordinated apps", () => {
     expect(appRes.status).toBe(200);
     expect(appRes.body.availability).toBe("available");
     expect(appRes.body.tasksCompleted).toBe(3);
-    expect(appRes.body.totalInteractions).toBe(3);
+    // totalInteractions is tracked independently via appInteractions, not piggybacked
+    expect(appRes.body.totalInteractions).toBe(0);
   });
 
   it("does not piggyback on unrelated agent heartbeat", async () => {
@@ -807,19 +808,23 @@ describe("GET /apps/search?sortBy=interactions", () => {
       }),
     });
 
-    // Send heartbeat with high interaction count
+    // Send heartbeat with appInteractions to increment the app's total_interactions
     const payload = await signedHeartbeat({
       address: highAddr,
       _account: highInteractionAccount,
-      telemetry: { tasksCompleted: 50, tasksFailed: 5 },
+      telemetry: {
+        tasksCompleted: 50,
+        tasksFailed: 5,
+        appInteractions: { "high-interact-app": 55 },
+      },
     });
     await request.post("/agents/heartbeat").send(payload);
 
     const res = await request.get("/apps/search?sortBy=interactions");
     expect(res.status).toBe(200);
     expect(res.body.apps.length).toBeGreaterThan(0);
 
-    // high-interact-app should be first since it has 55 interactions
+    // high-interact-app should be first since it has 55 interactions via appInteractions
     expect(res.body.apps[0].appId).toBe("high-interact-app");
   });
 });

directory/src/routes/agents.ts

@@ -282,14 +282,12 @@ agentsRouter.post("/heartbeat", heartbeatLimiter, async (req, res, next) => {
         last_refreshed: now,
         tasks_completed: newTasksCompleted,
         tasks_failed: newTasksFailed,
-        total_interactions: newTasksCompleted + newTasksFailed,
       };
 
       const appInput = toAppReputationInput({
         ...coordApp.get({ plain: true }),
         tasks_completed: newTasksCompleted,
         tasks_failed: newTasksFailed,
-        total_interactions: newTasksCompleted + newTasksFailed,
         created_at: coordApp.created_at ?? now,
       } as App);
 

directory/src/routes/apps.ts

@@ -37,9 +37,11 @@ appsRouter.post("/register", registrationLimiter, async (req, res, next) => {
     const body = appRegisterPayloadSchema.parse(req.body);
     const addr = body.address.toLowerCase();
     const manifest = body.manifest;
-    const coordinatorAddr = manifest.coordinatorAddress?.toLowerCase() || null;
-
-    const isCoordinated = !!manifest.coordinatorAddress;
+    const isCoordinated =
+      manifest.type === "coordinated" || !!manifest.coordinatorAddress;
+    const coordinatorAddr = isCoordinated
+      ? manifest.coordinatorAddress?.toLowerCase() || addr
+      : null;
 
     let app = await App.findByPk(body.appId);
 

openclaw/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@reef-protocol/reef-openclaw",
-  "version": "0.2.15",
+  "version": "0.2.17",
   "description": "Reef Protocol channel plugin for OpenClaw — receive and respond to A2A messages",
   "type": "module",
   "main": "dist/index.js",

package.json

@@ -32,5 +32,5 @@
     "typescript-eslint": "^8.56.0",
     "vitest": "^3.0.0"
   },
-  "version": "0.2.16"
+  "version": "0.2.17"
 }

protocol/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@reef-protocol/protocol",
-  "version": "0.2.16",
+  "version": "0.2.17",
   "description": "Shared message types, envelope codec, and validation for Reef Protocol",
   "type": "module",
   "main": "dist/index.js",