Method createConnection

packages/core/src/api/sync/index.ts:479–592

(options: SyncOptions)

  }

  private async createConnection(options: SyncOptions) {
    if (this.connection) return;

    const { HubConnectionBuilder, HttpTransportType, JsonHubProtocol } =
      await import("@microsoft/signalr");

    const tokenManager = new TokenManager(this.db.kv, this.db.eventManager);
    this.connection = new HubConnectionBuilder()
      .withUrl(`${Constants.API_HOST}/hubs/sync/v2`, {
        accessTokenFactory: async () => {
          const token = await tokenManager.getAccessToken();
          if (!token) throw new Error("Failed to get access token.");
          return token;
        },
        skipNegotiation: true,
        transport: HttpTransportType.WebSockets,
        logger: {
          log: (level, message) => {
            const scopedLogger = logger.scope("SignalR::SyncHub");
            switch (level) {
              case LogLevel.Critical:
                return scopedLogger.fatal(new Error(message));
              case LogLevel.Error: {
                this.db.eventManager.publish(EVENTS.syncAborted, message);
                return scopedLogger.error(new Error(message));
              }
              case LogLevel.Warning:
                return scopedLogger.warn(message);
            }
          }
        }
      })
      .withHubProtocol(new JsonHubProtocol())
      .build();
    this.connection.serverTimeoutInMilliseconds = 60 * 1000 * 5;
    this.connection.on("PushCompletedV2", (deviceId: string) =>
      this.onPushCompleted(deviceId)
    );
    this.connection.on("SendVaultKey", async (vaultKey) => {
      if (this.connection?.state !== HubConnectionState.Connected) return false;

      if (
        vaultKey &&
        vaultKey.cipher !== null &&
        vaultKey.iv !== null &&
        vaultKey.salt !== null &&
        vaultKey.length > 0
      ) {
        const vault = await this.db.vaults.default();
        if (!vault)
          await migrateVaultKey(
            this.db,
            vaultKey,
            5.9,
            CURRENT_DATABASE_VERSION
          );
      }