package de.thesycon.usbiodemo.usbioapp;
import java.io.FileOutputStream;
import java.io.IOException;

import de.thesycon.usbio.UsbIoBuf;
import de.thesycon.usbio.UsbIoReader;
import de.thesycon.usbio.structs.USBIO_ISO_PACKET;
import de.thesycon.usbio.structs.USBIO_ISO_TRANSFER;

public class UsbIoRd extends UsbIoReader {

	protected PipeDialog mainFrame;
	protected FileOutputStream file;

	int PrintPos = 0;


	public UsbIoRd(PipeDialog mainFrame) {
		super();
		this.mainFrame = mainFrame;
	}

	public boolean openFile(String Filename)
	{
		boolean succ = false;
		try {
			if ( file == null ) {
				file = new FileOutputStream(Filename);
				if ( file != null ) {
					succ = true;
				}
			}
		}
		catch (IOException ex) {
			mainFrame.mainFrame.printOutput("Error open file\n");
		}
		return succ;
	}

	public void closeFile()
	{
		try {
			if ( file!=null ) {
				file.close();
				file = null;
			}
		}
		catch (IOException ex) {
			mainFrame.mainFrame.printOutput("Error close file\n");
		}
	}

	public void processBuffer(UsbIoBuf Buf) {
		Buf.NumberOfBytesToTransfer = Buf.Size;
		Buf.BytesTransferred = 0;
		Buf.OperationFinished = false;


		if ((mainFrame.mPipeInfo.PipeType & 3) == 1) {
			// iso
			int IsoHeaderSize = mainFrame.mIsoHeaderSize;
			int NbOfPackets = Integer.parseInt(mainFrame.mBufferPage.mNumberOfIsoPacketsPerBufferTF.getText());
			int IsoPacketSize = mainFrame.mPipeInfo.MaximumPacketSize;

			USBIO_ISO_TRANSFER iostrans = new USBIO_ISO_TRANSFER();

			iostrans.NumberOfPackets = NbOfPackets;
			iostrans.Flags= 0x30000;
			iostrans.StartFrame=0;
			iostrans.ErrorCount=0;
			System.arraycopy(iostrans.buildByteArray(),0,Buf.BufferMem,0,USBIO_ISO_TRANSFER.SIZE);
			USBIO_ISO_PACKET Packet = new USBIO_ISO_PACKET();
			int ofs = IsoHeaderSize;
			int pos = USBIO_ISO_TRANSFER.SIZE;

			for (int i=0;i<NbOfPackets;i++) {
				Packet.Offset = ofs;
				Packet.Length = IsoPacketSize;
				Packet.Status = 0;
				System.arraycopy(Packet.buildByteArray(),0,Buf.BufferMem,pos,USBIO_ISO_PACKET.SIZE);
				pos += USBIO_ISO_PACKET.SIZE;
				ofs += IsoPacketSize;
			}
		} else {
			// bulk or interrupt ...

		}
	}

	public void processData(UsbIoBuf Buf) {
		try {
			if (file != null) {
				if ((mainFrame.mPipeInfo.PipeType & 3 ) == 1) {
					// iso
					if (Buf.Status == 0 ) {
						mainFrame.mainFrame.printOutput("*");
						PrintPos++;
						if (PrintPos >= 32) {
							mainFrame.mainFrame.printOutput("\n");
							PrintPos=0;
						}
					}
					byte[] data = new byte[USBIO_ISO_TRANSFER.SIZE];
					byte[] packet = new byte[USBIO_ISO_PACKET.SIZE];
					System.arraycopy(Buf.BufferMem,0,data,0,USBIO_ISO_TRANSFER.SIZE);
					USBIO_ISO_TRANSFER trans = new USBIO_ISO_TRANSFER();
					USBIO_ISO_PACKET isopacket = new USBIO_ISO_PACKET();
					trans.parseByteArray(data);
					int pos = USBIO_ISO_TRANSFER.SIZE;

					for (int i=0;i<trans.NumberOfPackets;i++) {
						System.arraycopy(Buf.BufferMem,pos,packet,0,USBIO_ISO_PACKET.SIZE);
						isopacket.parseByteArray(packet);
						if (isopacket.Status != 0) {
							mainFrame.mainFrame.printError("",isopacket.Status);
						} else {
							file.write(Buf.BufferMem, isopacket.Offset, isopacket.Length);
						}
						pos += USBIO_ISO_PACKET.SIZE;
					}
				} else {
					// bulk or interrupt ...
					if ( Buf.Status == 0 ) {
						if (  Buf.BytesTransferred > 0 ) {
							if (file != null) {
								file.write(Buf.BufferMem, 0, Buf.BytesTransferred);
							}
						} else {
							// 0 packet
						}
					}
				}
			}
		}
		catch (IOException ex) {
			mainFrame.mainFrame.printOutput("Error write to file\n");
		}
	}

	public void bufErrorHandler(UsbIoBuf Buf) {
		if ( Buf.Status != USBIO_ERR_SUCCESS ) {
			// print error
			// suppress CANCELED because it is caused by ABORT_PIPE
			if ( Buf.Status != USBIO_ERR_CANCELED ) {
				mainFrame.mainFrame.printError("Buf Error: ",Buf.Status);
			}
		}
	}

	// virtual function, called in the context of worker thread
	public void onThreadExit()
	{
		mainFrame.mainFrame.printOutput("Worker-thread terminated.\n");
		closeFile();
		// notify owning dialog, should be the last call
		mainFrame.onThreadExit();
	}
}