MeshServices methods

registerService(serviceId: string, version: string, capabilities: Record<string, string> = {}): Promise<void>

unregisterService(serviceId: string): Promise<boolean>

discoverServices(serviceId?: string): Promise<string>

sendServiceRequest(provider: string, serviceId: string, method: string, body: string): Promise<string>

respondToServiceRequest(requestId: string, requester: string, serviceId: string, status: string, body: string): Promise<string>

subscribeService(provider: string, serviceId: string, topic: string, mode: SubscriptionMode = 'latest', params: string = '', keys: string[] = []): Promise<string>

unsubscribeService(subId: string): Promise<boolean>

resyncServiceSubscription(subId: string): Promise<void>

serviceSubscriptions(): Promise<ServiceSubscriptionInfo[]>

setServiceSubscriptionPolicy(serviceId: string, policy: SubscriptionPolicy): Promise<void>

acceptServiceSubscription(subId: string): Promise<void>

rejectServiceSubscription(subId: string, reason: string = ''): Promise<void>

endServiceSubscription(subId: string, reason: string = ''): Promise<void>

publishServiceUpdate(serviceId: string, topic: string, body: string, key?: string): Promise<ServicePublishReport>

setServiceTopicCheckpoint(serviceId: string, topic: string, body: string): Promise<void>

clearServiceTopic(serviceId: string, topic: string): Promise<void>

serviceSubscribers(serviceId?: string): Promise<ServiceSubscriberInfo[]>

export type SubscriptionMode = 'latest' | 'log';

export interface ServiceSubscriptionInfo {
  subId: string;
  provider: string;
  serviceId: string;
  topic: string;
  mode: SubscriptionMode;
  state: 'pending' | 'active' | 'paused' | 'ended';
  keys: string[];
  topics: string[];
}

export type SubscriptionPolicy =
  | { kind: 'restricted' }
  | { kind: 'accept_all' }
  | {
      kind: 'rules';
      allowPeers?: string[];
      allowGroups?: string[];
      fallback?: 'ask' | 'reject';
    };

export interface ServicePublishReport {
  subscribers: number;
  sentLive: number;
  queued: number;
  coalesced: number;
  failed: number;
}

export interface ServiceSubscriberInfo {
  subId: string;
  subscriber: string;
  serviceId: string;
  topic: string;
  mode: SubscriptionMode;
  state: 'pending' | 'active';
  params: string;
  keys: string[];
}