vaultys/vaultysclaw/add-ws-message

{
  messageId: string;      // e.g. "memory-sync-1748700000000"
  type: WSMessageType;    // string literal from the union
  agentId?: string;       // sender's DID (set by the agent or control plane)
  payload: any;           // typed by convention via payload interface
  timestamp: string;      // ISO 8601
  signature?: string;     // ECDSA hex — only for critical messages
}

export type WSMessageType =
  | ... existing types ...
  | "my_new_type";   // ← add here

export interface WSMyNewTypePayload {
  // required fields
  sourceId: string;
  // optional fields
  metadata?: Record<string, unknown>;
}

case "my_new_type":
  this.handleMyNewType(message);
  break;

private handleMyNewType(message: WSMessage): void {
  const payload = message.payload as WSMyNewTypePayload;
  const agentId = message.agentId;
  // ... business logic ...
}

sendMyNewTypeTo(agentDid: string, data: WSMyNewTypePayload): boolean {
  const agent = this.agents.get(agentDid);
  if (!agent || !agent.sender.isOpen()) return false;
  this.sendMessage(agent.sender, {
    messageId: `my-new-type-${Date.now()}`,
    type: "my_new_type",
    agentId: agentDid,
    payload: data,
    timestamp: new Date().toISOString(),
  });
  return true;
}

case "my_new_type":
  this.handleMyNewType(message);
  break;

private handleMyNewType(message: WSMessage): void {
  const payload = message.payload as WSMyNewTypePayload;
  // ... react to the message ...
}
// If async:
case "my_new_type":
  this.handleMyNewType(message).catch((e) => this.log("error", "handleMyNewType error", e));
  break;

import { signMessage } from "@vaultysclaw/shared";
const payload = { ... };
const signature = await signMessage(JSON.stringify(payload), serverPrivateKey);
this.sendMessage(sender, { ..., payload, signature });

import { verifySignature } from "@vaultysclaw/shared";
private async handleMySignedType(message: WSMessage): Promise<void> {
  const isValid = await verifySignature(
    JSON.stringify(message.payload),
    message.signature!,
    this.controlPlanePublicKey,
  );
  if (!isValid) {
    this.log("error", "Invalid signature — rejecting my_signed_type message");
    return;
  }
  // ... proceed ...
}

case "my_new_type":
  if (this._status !== "connected") {
    this.log("warn", "Received my_new_type before auth — ignoring");
    return;
  }
  this.handleMyNewType(message);
  break;