<commit_before>package org.realityforge.replicant.example.client.net;

import com.google.gwt.core.client.GWT;
import com.google.gwt.http.client.Request;
import com.google.gwt.http.client.RequestBuilder;
import com.google.gwt.http.client.RequestCallback;
import com.google.gwt.http.client.RequestException;
import com.google.gwt.http.client.Response;
import com.google.gwt.user.client.Window;
import com.google.gwt.user.client.rpc.InvocationException;
import com.google.web.bindery.event.shared.EventBus;
import java.io.Serializable;
import java.util.Date;
import java.util.Map;
import java.util.logging.Level;
import javax.annotation.Nonnull;
import javax.annotation.Nullable;
import javax.inject.Inject;
import org.realityforge.gwt.datatypes.client.date.RDate;
import org.realityforge.replicant.client.ChangeMapper;
import org.realityforge.replicant.client.ChannelDescriptor;
import org.realityforge.replicant.client.EntityChangeBroker;
import org.realityforge.replicant.client.EntityRepository;
import org.realityforge.replicant.client.EntitySubscriptionManager;
import org.realityforge.replicant.client.json.gwt.ReplicantConfig;
import org.realityforge.replicant.client.transport.CacheService;
import org.realityforge.replicant.example.client.data_type.JsoRosterSubscriptionDTO;
import org.realityforge.replicant.example.client.data_type.RosterSubscriptionDTO;
import org.realityforge.replicant.example.client.event.SessionEstablishedEvent;
import org.realityforge.replicant.example.client.event.SystemErrorEvent;
import org.realityforge.replicant.example.client.service.internal.GwtSubscriptionService;
import org.realityforge.replicant.example.shared.net.TyrellReplicationGraph;

public class TyrellDataLoaderServiceImpl
  extends AbstractTyrellDataLoaderService
  implements DataLoaderService
{
  private final EventBus _eventBus;
  private final TyrellClientRouter _router;

  @Inject
  public TyrellDataLoaderServiceImpl( final TyrellChangeMapperImpl changeMapper,
                                      final EntityChangeBroker changeBroker,
                                      final EntityRepository repository,
                                      final CacheService cacheService,
                                      final EntitySubscriptionManager subscriptionManager,
                                      final GwtSubscriptionService subscriptionService,
                                      final ReplicantConfig replicantConfig,
                                      final EventBus eventBus,
                                      final TyrellClientRouter router )
  {
    super( changeMapper, changeBroker, repository, cacheService, subscriptionManager, replicantConfig, subscriptionService );
    _eventBus = eventBus;
    _router = router;
  }

  @Override
  public void connect()
  {
    final String url = GWT.getHostPageBaseURL() + "api/auth/token";
    final RequestBuilder rb = new RequestBuilder( RequestBuilder.GET, url );
    try
    {
      rb.sendRequest( "", new RequestCallback()<commit_msg>Whitespace<commit_after>package org.realityforge.replicant.example.client.net;

import com.google.gwt.core.client.GWT;
import com.google.gwt.http.client.Request;
import com.google.gwt.http.client.RequestBuilder;
import com.google.gwt.http.client.RequestCallback;
import com.google.gwt.http.client.RequestException;
import com.google.gwt.http.client.Response;
import com.google.gwt.user.client.Window;
import com.google.gwt.user.client.rpc.InvocationException;
import com.google.web.bindery.event.shared.EventBus;
import java.io.Serializable;
import java.util.Date;
import java.util.Map;
import java.util.logging.Level;
import javax.annotation.Nonnull;
import javax.annotation.Nullable;
import javax.inject.Inject;
import org.realityforge.gwt.datatypes.client.date.RDate;
import org.realityforge.replicant.client.ChangeMapper;
import org.realityforge.replicant.client.ChannelDescriptor;
import org.realityforge.replicant.client.EntityChangeBroker;
import org.realityforge.replicant.client.EntityRepository;
import org.realityforge.replicant.client.EntitySubscriptionManager;
import org.realityforge.replicant.client.json.gwt.ReplicantConfig;
import org.realityforge.replicant.client.transport.CacheService;
import org.realityforge.replicant.example.client.data_type.JsoRosterSubscriptionDTO;
import org.realityforge.replicant.example.client.data_type.RosterSubscriptionDTO;
import org.realityforge.replicant.example.client.event.SessionEstablishedEvent;
import org.realityforge.replicant.example.client.event.SystemErrorEvent;
import org.realityforge.replicant.example.client.service.internal.GwtSubscriptionService;
import org.realityforge.replicant.example.shared.net.TyrellReplicationGraph;

public class TyrellDataLoaderServiceImpl
  extends AbstractTyrellDataLoaderService
  implements DataLoaderService
{
  private final EventBus _eventBus;
  private final TyrellClientRouter _router;

  @Inject
  public TyrellDataLoaderServiceImpl( final TyrellChangeMapperImpl changeMapper,
                                      final EntityChangeBroker changeBroker,
                                      final EntityRepository repository,
                                      final CacheService cacheService,
                                      final EntitySubscriptionManager subscriptionManager,
                                      final GwtSubscriptionService subscriptionService,
                                      final ReplicantConfig replicantConfig,
                                      final EventBus eventBus,
                                      final TyrellClientRouter router )
  {
    super( changeMapper,
           changeBroker,
           repository,
           cacheService,
           subscriptionManager,
           replicantConfig,
           subscriptionService );
    _eventBus = eventBus;
    _router = router;
  }

  @Override
  public void connect()
  {
    final String url = GWT.getHostPageBaseURL() + "api/auth/token";
    final RequestBuilder rb = new RequestBuilder( RequestBuilder.GET, url );
    try
    {
      rb.sendRequest( "", new RequestCallback()
{'fraction_non_alphanumeric': 0.0758789860997547, 'fraction_numerical': 0.0, 'mean_word_length': 3.3968368080517615, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 16, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '22430', 'n_tokens_mistral': 1677, 'n_tokens_neox': 1653, 'n_words': 277}