file.java

SANCHO

/*
 * Copyright (C) 2004-2005 Rutger M. Ovidius for use with the sancho project.
 * See LICENSE.txt for license information.
 */

package sancho.model.mldonkey;

import java.io.BufferedWriter;
import java.io.FileNotFoundException;
import java.io.FileWriter;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.Collections;
import java.util.HashSet;
import java.util.Iterator;
import java.util.Observable;
import java.util.Observer;
import java.util.Set;
import java.util.StringTokenizer;
import java.util.TreeSet;

import org.eclipse.swt.graphics.Image;
import org.eclipse.swt.graphics.ImageData;
import org.eclipse.swt.program.Program;

import sancho.core.CoreFactory;
import sancho.core.ICore;
import sancho.core.Sancho;
import sancho.model.mldonkey.enums.AbstractEnum;
import sancho.model.mldonkey.enums.EnumExtension;
import sancho.model.mldonkey.enums.EnumFileState;
import sancho.model.mldonkey.enums.EnumNetwork;
import sancho.model.mldonkey.enums.EnumPriority;
import sancho.model.mldonkey.utility.FileState;
import sancho.model.mldonkey.utility.Format;
import sancho.model.mldonkey.utility.MessageBuffer;
import sancho.model.mldonkey.utility.OpCodes;
import sancho.model.mldonkey.utility.UtilityFactory;
import sancho.utility.ObjectMap;
import sancho.utility.SwissArmy;
import sancho.utility.VersionInfo;
import sancho.view.preferences.PreferenceLoader;
import sancho.view.transfer.FileClient;
import sancho.view.utility.SResources;
import sancho.view.utility.ResourcesImageDescriptor;

public class File extends AObjectO implements Observer {
  private static final String RS_DEFAULT_ICON = "defprog";

  public static final int CHANGED_ACTIVE = 1;
  public static final int CHANGED_RAVAIL = 2;
  public static final int CHANGED_DOWNLOADED = 4;
  public static final int CHANGED_ETA = 8;
  public static final int CHANGED_LAST = 16;
  public static final int CHANGED_PERCENT = 32;
  public static final int CHANGED_RATE = 64;
  public static final int CHANGED_STATE = 128;
  public static final int CHANGED_NOT_INTERESTING = 256;
  public static final int CHANGED_SOURCES = 512;
  public static final int CHANGED_AVAIL = 1024;

  /*
   public static final String CHANGED_ACTIVE = "active";
   public static final String CHANGED_AVAIL = "avail";
   public static final String CHANGED_DOWNLOADED = "downloaded";
   public static final String CHANGED_ETA = "eta";
   public static final String CHANGED_LAST = "last";
   public static final String CHANGED_PERCENT = "percent";

   public static final String CHANGED_RATE = "rate";
   public static final String CHANGED_STATE = "state";
   public static final String CHANGED_NOT_INTERESTING = "not_interesting";
   public static final String[] ALL_PROPERTIES = {CHANGED_RATE, CHANGED_DOWNLOADED, CHANGED_PERCENT,
   CHANGED_AVAIL, CHANGED_ETA, CHANGED_LAST, CHANGED_ACTIVE};
   */

  protected static final Set dummySet = new TreeSet();

  private int changedBits;
  protected int activeSources;
  protected long age;
  protected long ageTS;
  protected String avail;
  protected int[] chunkAges;
  protected String chunks;
  protected ObjectMap clientWeakMap;
  protected String comment;
  protected long downloaded;
  protected String downloadedString;
  protected long etaSeconds;
  protected long eta2Seconds;
  protected String etaString;
  protected String eta2String;
  protected EnumExtension extensionEnum;
  protected Set fileClientSet;
  protected EnumFileState fileStateEnum;
  protected Format format;
  protected int id;
  protected int lastSeen;
  protected String md4;
  protected String name;
  protected String[] names;
  //  protected Network network;
  protected EnumNetwork networkEnum;
  protected int numChunks;
  protected int numClients;
  protected int numConnectedClients;
  protected int percent;
  protected int priority;
  protected EnumPriority priorityEnum;
  protected String programImageResString;
  protected float rate;
  protected int relativeAvail = 0;
  protected long size;
  protected int sources;

  protected FileState state;

  File(ICore core) {
    super(core);
    state = UtilityFactory.getFileState(core);
    format = UtilityFactory.getFormat(core);

    clientWeakMap = new ObjectMap(true);
  }

  protected Set getFileClientSet() {
    if (fileClientSet == null)
      fileClientSet = Collections.synchronizedSet(new HashSet());

    return fileClientSet;
  }

  public synchronized void addChangedBits(int i) {
    this.changedBits |= i;
  }

  public synchronized void removeChangedBits(int i) {
    this.changedBits &= ~i;
  }

  public synchronized int getChangedBits() {
    return this.changedBits;
  }

  public synchronized void clearChangedBits() {
    this.changedBits = 0;
  }

  public synchronized boolean hasChangedBit(int i) {
    return (this.changedBits & i) != 0;
  }

  protected void addFileClient(FileClient fileClient) {
    getFileClientSet().add(fileClient);
    addChangedBits(CHANGED_SOURCES);
    notifyChangedProperties();
  }

  public void addSource(Client client) {

    if (!this.clientWeakMap.contains(client)) {
      this.clientWeakMap.add(client);
      client.addObserver(this);

      addChangedBits(CHANGED_SOURCES);

      if (client.isTransferring()) {
        numConnectedClients++;
        setActiveSources(+1);
        if (findFileClient(client) == null) {
          addClientToFileClientSet(client);
        }

      } else if (client.isConnected())
        numConnectedClients++;

      notifyChangedProperties();
    }

  }

  public void addClientToFileClientSet(Client client) {
    FileClient fileClient = new FileClient(this, client);
    addFileClient(fileClient);
    core.getFileCollection().sendUpdate(fileClient);
  }

  protected void calcDownloadedString() {
    String oldStringDownloaded = getDownloadedString();
    this.downloadedString = SwissArmy.calcStringSize(this.getDownloaded());

    if (!oldStringDownloaded.equals(downloadedString))
      addChangedBits(CHANGED_DOWNLOADED);

    int oldPercent = this.percent;
    this.percent = getSize() > 0 ? (int) ((float) this.getDownloaded() / (float) this.getSize() * 100f) : 0;

    if (oldPercent != this.percent)
      addChangedBits(CHANGED_PERCENT);

  }

  protected void calcETA() {
    if (this.rate == 0)
      this.etaSeconds = Long.MAX_VALUE;
    else
      this.etaSeconds = (long) ((getSize() - getDownloaded()) / (this.getRate() + 1));

    String oldStringETA = getEtaString();

    EnumFileState thisState = getFileStateEnum();

    boolean eta2 = core.getFileCollection().eta2();

    if ((thisState == EnumFileState.QUEUED) || (thisState == EnumFileState.DOWNLOADED)
        || (thisState == EnumFileState.PAUSED)) {
      this.etaString = SResources.S_DASH;
      if (eta2) {
        this.eta2Seconds = Long.MAX_VALUE;
        this.eta2String = SResources.S_DASH;
      }
    } else {
      this.etaString = SwissArmy.calcStringOfSeconds(this.etaSeconds);

      if (eta2) {
        long dl = getDownloaded();
        long remain = getSize() - dl;

        if (dl == 0 || remain == 0 || getAge() == 0) {
          this.eta2String = SResources.S_DASH;
          this.eta2Seconds = Long.MAX_VALUE;
        } else {
          if (ageTS == 0)
            ageTS = System.currentTimeMillis();
          long realAge = getAge() + ((System.currentTimeMillis() - ageTS) / 1000);
          this.eta2Seconds = (remain * realAge) / dl;
          this.eta2String = SwissArmy.calcStringOfSeconds(eta2Seconds);
        }
      }
    }
    if (etaString.equals(SResources.S_ES))
      etaString = SResources.S_DASH;

    if (!oldStringETA.equals(etaString))
      addChangedBits(CHANGED_ETA);

  }

  public void connectAll() {
    core.send(OpCodes.S_CONNECT_ALL, new Integer(this.getId()));
  }

  public void dispose() {
    clientWeakMap.deleteObservers();
    deleteObservers();
  }

  public boolean equals(Object obj) {
    return (obj instanceof File && getId() == ((File) obj).getId());
  }

  public synchronized FileClient findFileClient(Client client) {
    for (Iterator i = getFileClientSet().iterator(); i.hasNext();) {
      FileClient fileClient = (FileClient) i.next();
      if (client == fileClient.getClient())
        return fileClient;
    }
    return null;
  }

  public synchronized int getActiveSources() {
    return activeSources;
  }

  public synchronized long getAge() {
    return age;
  }

  public synchronized String getAgeString() {
    return SwissArmy.calcStringOfSeconds((System.currentTimeMillis() / 1000) - this.getAge());
  }

  public Set getAllAvailNetworks() {
    return dummySet;
  }

  public synchronized String getAvail() {
    return avail;
  }

  public String getAvails(Network network) {
    return SResources.S_ES;
  }

  public synchronized int[] getChunkAges() {
    return chunkAges;
  }

  public synchronized String getChunks() {
    return chunks != null ? chunks : SResources.S_ES;
  }

  public ObjectMap getClientWeakMap() {
    return clientWeakMap;
  }

  public String getComment() {
    return SResources.S_ES;
  }

  public synchronized int getConnected() {
    return numConnectedClients;
  }

  public synchronized long getDownloaded() {
    return downloaded;
  }

  public synchronized String getDownloadedString() {
    return downloadedString != null ? downloadedString : SResources.S_ES;
  }

  public synchronized EnumNetwork getEnumNetwork() {
    return networkEnum;
  }

  public String getED2K() {
    return "ed2k://|file|" + this.getName() + "|" + this.getSize() + "|" + this.getMd4() + "|/";
  }

  public synchronized long getETA() {
    return etaSeconds;
  }

  public synchronized long getETA2() {
    return eta2Seconds;
  }

  public synchronized String getEtaString() {
    return etaString != null ? etaString : SResources.S_ES;
  }

  public synchronized String getEta2String() {
    return eta2String != null ? eta2String : SResources.S_ES;
  }

  public synchronized int getFileClientSetSize() {
    if (fileClientSet == null)
      return 0;

    return getFileClientSet().size();
  }

  public synchronized Object[] getFileClientSetArray() {
    return getFileClientSet().toArray();
  }

  public String getFileFormat() {
    int index = this.getName().lastIndexOf(".");

    if (index != -1)
      return this.getName().substring(index + 1).toLowerCase();
    else
      return SResources.S_ES;
  }

  public void getFileLocations() {
    core.send(OpCodes.S_GET_FILE_LOCATIONS, new Integer(this.getId()));
  }

  public synchronized EnumFileState getFileStateEnum() {
    return fileStateEnum;
  }

  public synchronized EnumExtension getFileType() {
    return extensionEnum != null ? extensionEnum : EnumExtension.UNKNOWN;
  }

  public Format getFormat() {
    return format;
  }

  public synchronized int getId() {
    return id;
  }

  public synchronized int getLastSeen() {
    return lastSeen;
  }

  public synchronized String getLastSeenString() {
    if (this.lastSeen == 8640000)
      return SResources.S_DASH;
    else
      return SwissArmy.calcStringOfSeconds(this.lastSeen);
  }

  public synchronized String getMd4() {
    return md4 != null ? md4 : SResources.S_ES;
  }

  public synchronized String getName() {
    return name != null ? name : SResources.S_ES;
  }

  public String[] getNames() {
    return names != null ? names : new String[0];
  }

  //  public Network getNetwork() {
  //    return network;
  //  }

  public synchronized int getNumChunks() {
    return numChunks;
  }

  public synchronized int getNumClients() {
    return numClients;
  }
  
  public synchronized int getNumSources() {
    return sources;
  }

  public synchronized int getPercent() {
    return percent;
  }

  public synchronized int getPriority() {
    return priority;
  }

  public synchronized AbstractEnum getPriorityEnum() {
    return priorityEnum;
  }

  public synchronized String getProgramImageString() {
    return programImageResString != null ? programImageResString : SResources.S_ES;
  }

  public synchronized float getRate() {
    return rate;
  }

  public synchronized String getRateString() {
    EnumFileState thisState = getFileStateEnum();

    if (thisState == EnumFileState.PAUSED || thisState == EnumFileState.QUEUED
        || thisState == EnumFileState.DOWNLOADED)
      return thisState.getName();
    else
      return getRate() == 0f ? SResources.S_DASH : String
          .valueOf((Math.round(10.0 * (getRate() / 1000f)) / 10.0));
  }

  public synchronized int getRelativeAvail() {
    return relativeAvail;
  }

  public synchronized String getRelativeAvailString() {
    return relativeAvail + SResources.S_PERCENT;
  }

  public synchronized long getSize() {
    return size;
  }

  public synchronized String getSizeString() {
    return SwissArmy.calcStringSize(this.getSize());
  }

  public int getSources() {
    // TODO: check mldonkey sources
    return clientWeakMap.size();
  }

  public String getSourcesString() {
    int s = getSources();

    if (s == 0)
      return SResources.S_DASH;
    else {
      int a = getActiveSources();
      return (a > 0 ? (s + SResources.S_OB + a + SResources.S_CB) : String.valueOf(s));
    }
  }

  public synchronized String getPercentString() {
    return getPercent() + SResources.S_PERCENT;
  }

  public synchronized String getPriorityString() {
    if (priority == 0)
      return priorityEnum.getName();
    else
      return priorityEnum.getName() + SResources.S_OB + priority + SResources.S_CB;
  }

  public boolean hasAvails() {
    return false;
  }

  public int hashCode() {
    return getId();