/*
 * Copyright 2017, Adrien Destugues, pulkomandy@pulkomandy.tk
 * Distributed under terms of the MIT license.
 */


#include "FileSender.h"

#include "SerialApp.h"

#include <DataIO.h>
#include <Message.h>
#include <SerialPort.h>


FileSender::~FileSender()
{
}


RawSender::RawSender(BDataIO* source, BSerialPort* sink, BHandler* listener)
{
	// FIXME doing this all here in the constructor is not good. We need to
	// do things asynchronously instead so as not to lock the application
	// thread.
	off_t sourceSize;
	off_t position;

	BPositionIO* pos = dynamic_cast<BPositionIO*>(source);
	if (pos)
		pos->GetSize(&sourceSize);
	else
		sourceSize = 0;
	position = 0;

	BMessenger messenger(listener);

	uint8_t buffer[256];
	for (;;) {
		ssize_t s = source->Read(&buffer, sizeof(buffer));
		if (s <= 0)
			return;

		sink->Write(buffer, s);
		position += s;

		BMessage msg(kMsgProgress);
		msg.AddInt32("pos", position);
		msg.AddInt32("size", sourceSize);
		msg.AddString("info", "Sending" B_UTF8_ELLIPSIS);
		messenger.SendMessage(&msg);

		//usleep(20000);
	}
}


RawSender::~RawSender()
{
}


bool
RawSender::BytesReceived(const uint8_t* data, size_t length)
{
	// Nothing to do with received bytes, this protocol has no kind of
	// acknowledgement from remote side.
	return true;
}