MCPcopy
hub / github.com/aspen-cloud/triplit / sendMessage

Method sendMessage

packages/client/src/sync-engine.ts:1222–1235  ·  view source on GitHub ↗
(message: ClientSyncMessage)

Source from the content-addressed store, hash-verified

1220 }
1221
1222 private sendMessage(message: ClientSyncMessage) {
1223 // TODO: it might be safe to prevent sending some messages if the server hasnt indicated its ready yet
1224 // Allowed messages might include token exchange info and schema exchange info
1225 const didSend = this.transport.sendMessage(message);
1226
1227 if (didSend) {
1228 this.logger.debug('sent', message);
1229 for (const handler of this.messageSentSubscribers) {
1230 handler(message);
1231 }
1232 }
1233
1234 return didSend;
1235 }
1236
1237 /**
1238 * Sets up a listener for connection status changes

Callers 5

pingMethod · 0.95
sendChangesMethod · 0.95
connectQueryMethod · 0.95
disconnectQueryMethod · 0.95
onMessageHandlerMethod · 0.95

Calls 3

handlerFunction · 0.85
sendMessageMethod · 0.65
debugMethod · 0.45

Tested by

no test coverage detected