anchor.diff:      pong.
   
   migrate_all() ->
  +    migrate_all(mover_phase_1_migration_callback).
  +
  +migrate_all(CallbackMod) ->
       % Disable sleep  - for OPC migrations, we are guaranteed no in-flight traffic.
       application:set_env(mover, sleep_time, 0),
   
  
positive.code: %% This functionality used to be in moser_state_tracker but was removed
  %% in order to avoid any inadvertent possibility of rebuilding org state
  %% table after org creation was cut over to sql in production.
  capture_org_state() ->
      Info = mover_manager:get_account_dets(),
      moser_state_tracker:capture_full_org_state_list(Info, mover_phase_1_migration_callback:migration_type()).
  
negative.code: partition({Org, {error, org_reset_failed}}, {RF, MF, S}) ->
      {[binary_to_list(Org) | RF], MF, S}.
  
  org_list(CallbackMod) ->
      moser_state_tracker:unmigrated_orgs(CallbackMod:migration_type()).
  
  %% We'll migrate each org  individually so that we are
  %% able to reply with details for each org.
  migrate_next([], Acc, _) ->
      Acc;
  migrate_next([Org|Rest], Acc, CallbackMod) ->
      lager:info([{org_name, Org}], "Requesting migration: ~p~n"),
      case reset_org(Org, CallbackMod) of
          ok ->
              do_migrate(Org, Rest, Acc, CallbackMod);
          Reason ->
              migrate_next(Rest, [{Org, Reason} | Acc], CallbackMod)
      end.
  
  %% An org reset can fail for a number of valid reasons. When we are following the flow
  %% of interactively resetting multiple orgs then continuing, it makes sense to abort up front.
  %% However, in an unattended migration, we'll capture any error and just note that we can't reset the org,
  %% so that we can move on to the next org.
  reset_org(OrgName, CallbackMod) ->
      try
          mover_util:reset_org(OrgName, CallbackMod:migration_type()),
          ok
      catch
          % Note that details are already captured in the error log - we'll
  