Function createMultiParties

packages/partykit/facade/source.ts:137–252

(
  namespaces: Record<string, DurableObjectNamespace>,
  options: {
    host: string;
  }
)

// create a "multi-party" object that can be used to connect to other parties
function createMultiParties(
  namespaces: Record<string, DurableObjectNamespace>,
  options: {
    host: string;
  }
): Party.Room["context"]["parties"] {
  if (!parties) {
    parties = {};
    for (const [key, value] of Object.entries(namespaces)) {
      if (typeof value.idFromName === "function") {
        parties[key] ||= {
          get: (name: string): Party.Stub => {
            const docId = value.idFromName(name).toString();
            const id = value.idFromString(docId);
            const stub = value.get(id);
            return {
              fetch(
                pathOrInit?: string | RequestInit | Request,
                maybeInit?: RequestInit | Request
              ) {
                let path: RequestInfo | undefined;
                let init: RequestInit | Request | undefined;
                if (pathOrInit) {
                  if (typeof pathOrInit === "string") {
                    path = pathOrInit;
                    init = maybeInit;
                    if (path[0] !== "/") {
                      throw new Error("Path must start with /");
                    }
                    return stub.fetch(
                      `http://${options.host}/parties/${key}/${name}${path}`,
                      init
                    );
                  } else {
                    init = pathOrInit;
                    return stub.fetch(
                      `http://${options.host}/parties/${key}/${name}`,
                      init
                    );
                  }
                } else {
                  return stub.fetch(
                    `http://${options.host}/parties/${key}/${name}`
                  );
                }
              },
              connect: () => {
                return new WebSocket(
                  `ws://${options.host}/parties/${key}/${name}`
                );
              },
              async socket(
                pathOrInit?: string | RequestInit,
                maybeInit?: RequestInit
              ) {
                let res: Response;
                // This method is better because it doesn't go via the internet
                // and doesn't get 522/404/ get caught in CF firewall