Function createPayloads

src/synchronizers/common.ts:120–149

(
  toClientId: IdOrNull,
  requestId: IdOrNull,
  message: Message,
  body: any,
  fragmentSize?: number,
)

  clientId + MESSAGE_SEPARATOR + remainder;

export const createPayloads = (
  toClientId: IdOrNull,
  requestId: IdOrNull,
  message: Message,
  body: any,
  fragmentSize?: number,
): string[] => {
  const clientId = toClientId ?? EMPTY_STRING;
  const remainder = jsonStringWithUndefined([requestId, message, body]);
  const maxFragmentSize = mathFloor(fragmentSize ?? 0);
  if (
    isUndefined(fragmentSize) ||
    maxFragmentSize < 1 ||
    size(remainder) <= maxFragmentSize
  ) {
    return [createRawPayload(clientId, remainder)];
  }
  const fragments = strMatch(
    remainder,
    new RegExp(`.{1,${maxFragmentSize}}`, 'g'),
  );
  const total = size(fragments ?? []);
  const messageId = getUniqueId();
  return arrayMap(fragments ?? [], (fragment, index) =>
    createRawPayload(
      clientId,
      arrayJoin([messageId, index, total, fragment], MESSAGE_SEPARATOR),
    ),
  );
};