Interface MasterProxy

public interface MasterProxy
The Interface MasterProxy.

  • Method Details

    • shutdown

      void shutdown()
      Shutdown.

    • updateDataTransfers

      void updateDataTransfers(DataTransfer[] transfers) throws Exception
      Update data transfers.
      Parameters:
      transfers - the transfers
      Throws:
      Exception - the exception

    • updateDownloadProgress

      DownloadProgress[] updateDownloadProgress(DownloadProgress[] progress) throws Exception
      Update download progress.
      Parameters:
      progress - the progress
      Returns:
      the list of DownloadProgress to interrupt (not found on the MasterServer)
      Throws:
      Exception - the exception

    • proxyHostIsAlive

      long proxyHostIsAlive(String name) throws Exception
      Proxy host is alive.
      Parameters:
      name - the name
      Returns:
      the long
      Throws:
      Exception - the exception

    • updateData

      void updateData(Host host) throws Exception
      Update data.
      Parameters:
      host - the host
      Throws:
      Exception - the exception

    • updateData

      void updateData(String hostId, String data) throws Exception
      Update data.
      Parameters:
      hostId - the host id
      data - the host data
      Throws:
      Exception - the exception

    • updateLocation

      void updateLocation(Host host) throws Exception
      Update location.
      Parameters:
      host - the host
      Throws:
      Exception - the exception

    • sendMessage

      void sendMessage(String name, String service, int status, String message) throws Exception
      Sends the message.
      Parameters:
      name - the name
      service - the service
      status - the status
      message - the message
      Throws:
      Exception - the exception

    • getDataFileAccessInterface

      DataAccessInterface getDataFileAccessInterface() throws Exception
      Gets the data file access interface.
      Returns:
      the data file access interface
      Throws:
      Exception - the exception

    • getDestination

      Destination getDestination(String name) throws Exception
      Gets the destination.
      Parameters:
      name - the name
      Returns:
      the destination
      Throws:
      Exception - the exception

    • isValidDataFile

      boolean isValidDataFile(long dataFileId) throws Exception
      Checks if is valid data file.
      Parameters:
      dataFileId - the data file id
      Returns:
      true, if is valid data file
      Throws:
      Exception - the exception

    • getIncomingProfile

      IncomingProfile getIncomingProfile(String incomingUser, String incomingPassword, String from) throws Exception
      Gets the incoming profile.
      Parameters:
      incomingUser - the incoming user
      incomingPassword - the incoming password
      from - the from
      Returns:
      the incoming profile
      Throws:
      Exception - the exception

    • getIncomingProfileNoAuth

      IncomingProfile getIncomingProfileNoAuth(String incomingUser) throws Exception
      Returns a fresh IncomingProfile for an already-authenticated user, without re-running credential validation, TOTP, connection-count checks, or last-login updates. Used to refresh user settings (e.g. portal.color, portal.maxConnections) from INU_DATA for an existing portal session.
      Parameters:
      incomingUser - the incoming user id
      Returns:
      the incoming profile
      Throws:
      Exception - the exception

    • isSubscriberActive

      boolean isSubscriberActive(long psbId) throws Exception
      Check whether a specific portal subscriber is still active. Lightweight single-row lookup by primary key — used on cookie re-auth to detect deactivated subscribers without a full password re-validation round-trip.
      Parameters:
      psbId - the PortalSubscriber primary key
      Returns:
      true if the subscriber exists and is active
      Throws:
      Exception - the exception

    • findSubscriberIdByPassword

      long findSubscriberIdByPassword(String inuId, String password) throws Exception
      Find the PSB_ID of the active subscriber matching the given password for the given IncomingUser. Returns -1 if not found.
      Parameters:
      inuId - the IncomingUser login
      password - the subscriber password
      Returns:
      the subscriber's PSB_ID, or -1 if not found
      Throws:
      Exception - the exception

    • getPortalSubscriberEmail

      String getPortalSubscriberEmail(long psbId) throws Exception
      Get the email address of the portal subscriber with the given PSB_ID. Returns an empty string if the subscriber does not exist or has no email recorded.
      Parameters:
      psbId - the portal subscriber PSB_ID
      Returns:
      the subscriber email, or an empty string if not found
      Throws:
      Exception - the exception

    • releaseConnectionSlot

      void releaseConnectionSlot(String incomingUser) throws Exception
      Releases a pending connection slot for the given user.
      Parameters:
      incomingUser - the incoming user id
      Throws:
      Exception - the exception

    • resolvePortalSessionAcrossMovers

      String resolvePortalSessionAcrossMovers(String token, String excludeMoverName) throws Exception
      Ask the Master to locate a portal session token on any currently connected data mover other than the requesting one. Used after a load-balancer failover to migrate a session from one mover to another without forcing the user to re-authenticate.
      Parameters:
      token - the portal session token to search for
      excludeMoverName - the name of the calling mover (excluded from the search to avoid a self-lookup round-trip)
      Returns:
      the serialised session entry (tab-separated user\tsubscriberId\tsubscriberEmail\texpiryEpochMs), or null if the token is not found on any other mover
      Throws:
      Exception - the exception

    • invalidatePortalSessionAcrossMovers

      void invalidatePortalSessionAcrossMovers(String token, String excludeMoverName) throws Exception
      Broadcast a portal session token invalidation to all connected data movers except the calling one. Used after user-initiated logout to evict imported tokens from any mover that received the token via cross-mover migration.
      Parameters:
      token - the portal session token to invalidate
      excludeMoverName - the name of the calling mover (already invalidated locally)
      Throws:
      Exception - the exception

    • getECauthToken

      ECauthToken getECauthToken(String user) throws Exception
      Gets the ecauth token.
      Parameters:
      user - the user
      Returns:
      the ecauth token
      Throws:
      Exception - the exception