//OpenSCADA module Special.FLibSYS file: io.cpp
/***************************************************************************
 *   Copyright (C) 2013-2022 by Roman Savochenko, <roman@oscada.org>       *
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; version 2 of the License.               *
 *                                                                         *
 *   This program is distributed in the hope that it will be useful,       *
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
 *   GNU General Public License for more details.                          *
 *                                                                         *
 *   You should have received a copy of the GNU General Public License     *
 *   along with this program; if not, write to the                         *
 *   Free Software Foundation, Inc.,                                       *
 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
 ***************************************************************************/

#include <errno.h>

#include "io.h"

using namespace FLibSYS;

//*************************************************
//* IOObj object (stream, file)                   *
//*************************************************
IOObj::IOObj( const string &nm, const string &perm, const string &mFormat, const string &ienc ) : fhd(NULL), pos(0)
{
    open(nm, perm, mFormat, ienc);
    if(mess_lev() == TMess::Debug) SYS->cntrIter(objName(), 1);
}

IOObj::~IOObj( )
{
    close();
    if(mess_lev() == TMess::Debug) SYS->cntrIter(objName(), -1);
}

void IOObj::open( const string &nm, const string &perm, const string &imFormat, const string &ienc )
{
    //Try for file open
    close();
    if(perm.size()) fhd = fopen(nm.c_str(), perm.c_str());
    else { str = nm; pos = 0; }
    mFormat = imFormat;
    strEnc = ienc;
}

void IOObj::close( )
{
    if(fhd && fclose(fhd) != 0)
	mess_warning("IOObj", _("Closing the file %p error '%s (%d)'!"), fhd, strerror(errno), errno);
    fhd = NULL;
    str = ""; pos = 0;
}

TVariant IOObj::propGet( const string &id )
{
    if(id == "length") {
	if(!fhd) return (int64_t)str.size();
	pos = ftell(fhd);
	fseek(fhd, 0, SEEK_END);
	int64_t end = ftell(fhd);
	fseek(fhd, pos, SEEK_SET);
	return end;
    }
    if(id == "pos")		return fhd ? (int64_t)ftell(fhd) : (int64_t)pos;
    if(id == "string")		return str;
    if(id == "mFormat")		return mFormat;
    if(id == "stringEncode")	return strEnc;

    throw TError("IOObj", _("Properties are not supported by the object."));
}

void IOObj::propSet( const string &id, TVariant val )
{
    if(id == "pos") {
	if(fhd)	fseek(fhd, pos, SEEK_CUR);
	else pos = vmin((int)str.size(),vmax(0,val.getI()));
    }
    else if(id == "string" && !fhd)	{ str = val.getS(); pos = 0; }
    else if(id == "mFormat")		mFormat = val.getS();
    else if(id == "stringEncode")	strEnc = val.getS();
    else throw TError("IOObj", _("Properties are not supported by the object."));
}

TVariant IOObj::funcCall( const string &id, vector<TVariant> &prms )
{
    bool sec1 = false;
    // bool open(string name = "", string accs = "", string mFormat = "n", string enc = "") -
    //          Open for new stream by string or file <name>.
    //  name - file name or string content
    //  perm - file permition access (''-string stream;'r[+]'-read;'w[+]'-write from zero;'a[+]'-append;...)
    //  machineFmt - machine format (native(n), ieee-be(b), ieee-le(l))
    //  enc - encoding for chars
    if(id == "open" && prms.size() >= 1) {
	open(prms[0].getS(), ((prms.size() >= 2)?prms[1].getS():""),
	    ((prms.size() >= 3)?prms[2].getS():"n"), ((prms.size() >= 4)?prms[3].getS():""));
	return true;
    }
    // bool close() - Close current stream.
    if(id == "close") { close(); return true; }
    // {string|int|real|Array[int|real]} read(string valType = "char", int cnt = -1, string mFormatEnc = "n|NoEnc") -
    //		Read value <valType> in <cnt> for machine format or string encodeIn <mFormatEnc>.
    //	valType - value type (char,int,float,real*4,...)
    //	cnt - values by data type counter; for no strings and multiply counter used Array as result (-1 up to end);
    //	mFormatEnc - machine format (native(n), ieee-be(b), ieee-le(l)) or encodeIn for string
    if(id == "read") {
	TpDescr &tpD = getTp((prms.size()>=1) ? prms[0].getS() : "char");
	long cnt = (prms.size()>=2) ? prms[1].getI() : -1;
	if(!cnt) return false;

	//Char stream
	if(tpD.ch) {
	    string rez, inCd = (prms.size()>=3) ? prms[2].getS() : strEnc;
	    if(!fhd) {
		rez = str.substr(pos, vmax(0,vmin(str.size()-pos,(cnt<0)?str.size():cnt)));
		pos = vmin(str.size(), pos+cnt);
	    }
	    else {
		char buf[prmStrBuf_SZ];
		if(cnt < 0) cnt = limUserFile_SZ;
		for(int r_cnt = 0; (r_cnt=fread(buf,1,vmin(sizeof(buf),cnt-rez.size()),fhd)); )
		    rez.append(buf, r_cnt);
	    }
	    if(inCd.size()) rez = Mess->codeConvIn(inCd, rez);
	    return rez;
	}
	//Integer
	else if(!tpD.real) {
	    TArrayObj *ao = NULL;
	    int64_t rez = 0;
	    string mach = (prms.size()>=3) ? prms[2].getS() : mFormat;
	    if(mach.empty()) mach = "n";
	    // From string stream
	    if(!fhd) {
		if(cnt != 1) ao = new TArrayObj();
		for(long i_cnt = 0; (cnt < 0 || i_cnt < cnt) && (pos+tpD.szBt) <= str.size(); i_cnt++) {
		    switch(tpD.szBt) {
			case 1:	rez = tpD.sign ? (int8_t)str[pos] : (uint8_t)str[pos];	break;
			case 2: {
			    uint16_t v = TSYS::getUnalign16(str.data()+pos);
			    switch(mach[0]) {
				case 'l': v = TSYS::i16_LE(v);	break;
				case 'b': v = TSYS::i16_BE(v);	break;
			    }
			    rez = tpD.sign ? (int16_t)v : v;
			    break;
			}
			case 4: {
			    uint32_t v = TSYS::getUnalign32(str.data()+pos);
			    switch(mach[0]) {
				case 'l': v = TSYS::i32_LE(v);	break;
				case 'b': v = TSYS::i32_BE(v);	break;
			    }
			    rez = tpD.sign ? (int32_t)v : v;
			    break;
			}
			case 8: {
			    uint64_t v = TSYS::getUnalign64(str.data()+pos);
			    switch(mach[0]) {
				case 'l': v = TSYS::i64_LE(v);	break;
				case 'b': v = TSYS::i64_BE(v);	break;
			    }
			    rez = tpD.sign ? (int64_t)v : v;
			    break;
			}
		    }
		    pos += tpD.szBt;	//Before return!
		    if(!ao) return rez;
		    ao->arSet(i_cnt, rez);
		}
		if(ao) return ao;
		return (int64_t)EVAL_INT;
	    }
	    // From file
	    char buf[prmStrBuf_SZ];
	    if(cnt != 1) ao = new TArrayObj();
	    if(cnt < 0) cnt = limUserFile_SZ/tpD.szBt;
	    for(long r_cnt = 0, r_full = 0, i_cnt = 0; (r_cnt=fread(buf,1,vmin((long)sizeof(buf),cnt*tpD.szBt-r_full),fhd)) > 0; r_full += r_cnt)
		for(unsigned iPos = 0; (iPos+tpD.szBt) <= r_cnt; iPos += tpD.szBt, i_cnt++) {
		    switch(tpD.szBt) {
			case 1:	rez = tpD.sign ? (int8_t)buf[iPos] : (uint8_t)buf[iPos];	break;
			case 2: {
			    uint16_t v = *(uint16_t*)(buf+iPos);
			    switch(mach[0]) {
				case 'l': v = TSYS::i16_LE(v);	break;
				case 'b': v = TSYS::i16_BE(v);	break;
			    }
			    rez = tpD.sign ? (int16_t)v : v;
			    break;
			}
			case 4: {
			    uint32_t v = *(uint32_t*)(buf+iPos);
			    switch(mach[0]) {
				case 'l': v = TSYS::i32_LE(v);	break;
				case 'b': v = TSYS::i32_BE(v);	break;
			    }
			    rez = tpD.sign ? (int32_t)v : v;
			    break;
			}
			case 8: {
			    uint64_t v = *(uint64_t*)(buf+iPos);
			    switch(mach[0]) {
				case 'l': v = TSYS::i64_LE(v);	break;
				case 'b': v = TSYS::i64_BE(v);	break;
			    }
			    rez = tpD.sign ? (int64_t)v : v;
			    break;
			}
		    }
		    if(!ao) return rez;
		    ao->arSet(i_cnt, rez);
		}
	    if(ao) return ao;
	    return (int64_t)EVAL_INT;
	}
	//Real
	else {
	    TArrayObj *ao = NULL;
	    double rez = 0;
	    string mach = (prms.size()>=3) ? prms[2].getS() : mFormat;
	    if(mach.empty()) mach = "n";
	    // From string stream
	    if(!fhd) {
		if(cnt != 1) ao = new TArrayObj();
		for(long i_cnt = 0; (cnt < 0 || i_cnt < cnt) && (pos+tpD.szBt) <= str.size(); i_cnt++) {
		    switch(tpD.szBt) {
			case 4: {
			    float v = TSYS::getUnalignFloat(str.data()+pos);
			    switch(mach[0]) {
				case 'l': *((int32_t*)&v) = TSYS::i32_LE(*((int32_t*)&v));	break;
					//v = TSYS::floatLErev(v);	break;
				case 'b': *((int32_t*)&v) = TSYS::i32_BE(*((int32_t*)&v));	break;
					//v = TSYS::floatBErev(v);	break;
			    }
			    rez = v;
			    break;
			}
			case 8: {
			    rez = TSYS::getUnalignDbl(str.data()+pos);
			    switch(mach[0]) {
				case 'l': *((int64_t*)&rez) = TSYS::i64_LE(*((int64_t*)&rez));	break;
					//rez = TSYS::doubleLErev(rez);	break;
				case 'b': *((int64_t*)&rez) = TSYS::i64_BE(*((int64_t*)&rez));	break;
					//rez = TSYS::doubleBErev(rez);	break;
			    }
			    break;
			}
		    }
		    pos += tpD.szBt;	//Before return!
		    if(!ao) return rez;
		    ao->arSet(i_cnt, rez);
		}
		if(ao) return ao;
		return EVAL_REAL;
	    }
	    // From file
	    char buf[prmStrBuf_SZ];
	    if(cnt != 1) ao = new TArrayObj();
	    if(cnt < 0) cnt = limUserFile_SZ/tpD.szBt;
	    for(int r_cnt = 0, r_full = 0, i_cnt = 0; (r_cnt=fread(buf,1,vmin((long)sizeof(buf),cnt*tpD.szBt-r_full),fhd)); r_full += r_cnt)
	    {
		for(unsigned iPos = 0; (int)iPos <= (r_cnt-tpD.szBt); iPos += tpD.szBt, i_cnt++) {
		    switch(tpD.szBt) {
			case 4: {
			    float v = *(float*)(buf+iPos);
			    switch(mach[0]) {
				case 'l': *((int32_t*)&v) = TSYS::i32_LE(*((int32_t*)&v));	break;
					//v = TSYS::floatLErev(v);	break;
				case 'b': *((int32_t*)&v) = TSYS::i32_BE(*((int32_t*)&v));	break;
					//v = TSYS::floatBErev(v);	break;
			    }
			    rez = v;
			    break;
			}
			case 8: {
			    rez = *(double*)(buf+iPos);
			    switch(mach[0]) {
				case 'l': *((int64_t*)&rez) = TSYS::i64_LE(*((int64_t*)&rez));	break;
					//rez = TSYS::doubleLErev(rez);	break;
				case 'b': *((int64_t*)&rez) = TSYS::i64_BE(*((int64_t*)&rez));	break;
					//rez = TSYS::doubleBErev(rez);	break;
			    }
			    break;
			}
		    }
		    if(!ao) return rez;
		    ao->arSet(i_cnt, rez);
		}
	    }
	    if(ao) return ao;
	    return EVAL_REAL;
	}

	return false;
    }
    // {int|IO} {write|wr}({string|int|real|Array} vals, string valType = "char", string mFormatEnc = "n|NoEnc", int cnt = 1) -
    //		Write value[s] <vals> for type <valType> for machine format or string encodeIn <mFormatEnc>,
    //		and scalar values repeat for <cnt>.
    //	vals - single value or values array for write;
    //	valType - value type (char,int,float,real*4,...)
    //	mFormatEnc - machine format (native(n), ieee-be(b), ieee-le(l)) or encodeIn for string
    //	cnt - integer and real types write multiple count
    if((id == "write" || (sec1=(id=="wr"))) && prms.size() >= 1) {
	TVariant &vals = prms[0];
	TpDescr &tpD = getTp((prms.size()>=2) ? prms[1].getS() : "char");
	int64_t rez = 0;
	//?!?! Check for the real data type

	//Char stream
	if(tpD.ch && vals.type() == TVariant::String) {
	    string outCd = (prms.size()>=3) ? prms[2].getS() : strEnc;
	    string sval = outCd.size() ? Mess->codeConvOut(outCd, prms[0].getS()) : prms[0].getS();
	    if(!fhd) {
		if(pos >= str.size()) str.append(sval);
		else str.replace(pos, vmax(0,vmin(str.size()-pos,sval.size())), sval);
		pos += sval.size();
		if(sec1) return this;
		return (int64_t)sval.size();
	    }
	    rez = (int64_t)fwrite(sval.data(), 1, sval.size(), fhd);
	    if(sec1) return this;
	    return rez;
	}

	bool isSingle = false;
	int cntr = (prms.size() < 4) ? 1 : prms[3].getI();
	TArrayObj *ai = NULL;
	if(vals.type() == TVariant::Object && !AutoHD<TArrayObj>(vals.getO()).freeStat()) ai = (TArrayObj*)&vals.getO().at();
	else {
	    ai = new TArrayObj();
	    for(int i_c = 0; i_c < cntr; i_c++) ai->arSet(i_c, vals);
	    isSingle = true;
	}
	string mach = (prms.size() >= 3) ? prms[2].getS() : mFormat;
	if(mach.empty()) mach = "n";

	//Integer
	if(!tpD.real) {
	    // To string stream
	    if(!fhd) {
		switch(tpD.szBt) {
		    case 1: {
			uint8_t v = 0;
			for(unsigned iA = 0; iA < ai->arSize(); iA++, pos += sizeof(v)) {
			    v = ai->arGet(iA).getI();
			    if(pos >= str.size()) str.append((char*)&v,sizeof(v));
			    else str.replace(pos, vmax(0,vmin(str.size()-pos,sizeof(v))), (char*)&v,sizeof(v));
			}
			break;
		    }
		    case 2: {
			uint16_t v = 0;
			for(unsigned iA = 0; iA < ai->arSize(); iA++, pos += sizeof(v)) {
			    v = ai->arGet(iA).getI();
			    switch(mach[0]) {
				case 'l': v = TSYS::i16_LE(v);	break;
				case 'b': v = TSYS::i16_BE(v);	break;
			    }
			    if(pos >= str.size()) str.append((char*)&v,sizeof(v));
			    else str.replace(pos, vmax(0,vmin(str.size()-pos,sizeof(v))), (char*)&v,sizeof(v));
			}
			break;
		    }
		    case 4: {
			uint32_t v = 0;
			for(unsigned iA = 0; iA < ai->arSize(); iA++, pos += sizeof(v)) {
			    v = ai->arGet(iA).getI();
			    switch(mach[0]) {
				case 'l': v = TSYS::i32_LE(v);	break;
				case 'b': v = TSYS::i32_BE(v);	break;
			    }
			    if(pos >= str.size()) str.append((char*)&v,sizeof(v));
			    else str.replace(pos, vmax(0,vmin(str.size()-pos,sizeof(v))), (char*)&v,sizeof(v));
			}
			break;
		    }
		    case 8: {
			uint64_t v = 0;
			for(unsigned iA = 0; iA < ai->arSize(); iA++, pos += sizeof(v)) {
			    v = ai->arGet(iA).getI();
			    switch(mach[0]) {
				case 'l': v = TSYS::i64_LE(v);	break;
				case 'b': v = TSYS::i64_BE(v);	break;
			    }
			    if(pos >= str.size()) str.append((char*)&v,sizeof(v));
			    else str.replace(pos, vmax(0,vmin(str.size()-pos,sizeof(v))), (char*)&v,sizeof(v));
			}
			break;
		    }
		}
		rez = ai->arSize()*tpD.szBt;
	    }
	    else // To file
		switch(tpD.szBt) {
		    case 1: {
			uint8_t v = 0;
			for(unsigned iA = 0; iA < ai->arSize(); iA++) {
			    v = ai->arGet(iA).getI();
			    rez += (int64_t)fwrite((char*)&v, 1, sizeof(v), fhd);
			}
			break;
		    }
		    case 2: {
			uint16_t v = 0;
			for(unsigned iA = 0; iA < ai->arSize(); iA++) {
			    v = ai->arGet(iA).getI();
			    switch(mach[0]) {
				case 'l': v = TSYS::i16_LE(v);	break;
				case 'b': v = TSYS::i16_BE(v);	break;
			    }
			    rez += (int64_t)fwrite((char*)&v, 1, sizeof(v), fhd);
			}
			break;
		    }
		    case 4: {
			uint32_t v = 0;
			for(unsigned iA = 0; iA < ai->arSize(); iA++) {
			    v = ai->arGet(iA).getI();
			    switch(mach[0]) {
				case 'l': v = TSYS::i32_LE(v);	break;
				case 'b': v = TSYS::i32_BE(v);	break;
			    }
			    rez += (int64_t)fwrite((char*)&v, 1, sizeof(v), fhd);
			}
			break;
		    }
		    case 8: {
			uint64_t v = 0;
			for(unsigned iA = 0; iA < ai->arSize(); iA++) {
			    v = ai->arGet(iA).getI();
			    switch(mach[0]) {
				case 'l': v = TSYS::i64_LE(v);	break;
				case 'b': v = TSYS::i64_BE(v);	break;
			    }
			    rez += (int64_t)fwrite((char*)&v, 1, sizeof(v), fhd);
			}
			break;
		    }
		}
	    if(isSingle) delete ai;
	    if(sec1) return this;
	    return rez;
	}
	//Real
	// To string stream
	if(!fhd) {
	    switch(tpD.szBt) {
		case 4: {
		    float v = 0;
		    for(unsigned iA = 0; iA < ai->arSize(); iA++, pos += sizeof(v)) {
			v = ai->arGet(iA).getR();
			switch(mach[0]) {
			    case 'l': *((int32_t*)&v) = TSYS::i32_LE(*((int32_t*)&v));	break;
					//v = TSYS::floatLE(v);	break;
			    case 'b': *((int32_t*)&v) = TSYS::i32_BE(*((int32_t*)&v));	break;
					//v = TSYS::floatBE(v);	break;
			}
			if(pos >= str.size()) str.append((char*)&v,sizeof(v));
			else str.replace(pos, vmax(0,vmin(str.size()-pos,sizeof(v))), (char*)&v,sizeof(v));
		    }
		    break;
		}
		case 8: {
		    double v = 0;
		    for(unsigned iA = 0; iA < ai->arSize(); iA++, pos += sizeof(v)) {
			v = ai->arGet(iA).getR();
			switch(mach[0]) {
			    case 'l': *((int64_t*)&v) = TSYS::i64_LE(*((int64_t*)&v));	break;
					//v = TSYS::doubleLE(v);	break;
			    case 'b': *((int64_t*)&v) = TSYS::i64_BE(*((int64_t*)&v));	break;
					//v = TSYS::doubleBE(v);	break;
			}
			if(pos >= str.size()) str.append((char*)&v, sizeof(v));
			else str.replace(pos, vmax(0,vmin(str.size()-pos,sizeof(v))), (char*)&v,sizeof(v));
		    }
		    break;
		}
	    }
	    rez = ai->arSize()*tpD.szBt;
	}
	else // To file
	    switch(tpD.szBt) {
		case 4: {
		    float v = 0;
		    for(unsigned iA = 0; iA < ai->arSize(); iA++) {
			v = ai->arGet(iA).getR();
			switch(mach[0]) {
			    case 'l': *((int32_t*)&v) = TSYS::i32_LE(*((int32_t*)&v));	break;
					//v = TSYS::floatLE(v);	break;
			    case 'b': *((int32_t*)&v) = TSYS::i32_BE(*((int32_t*)&v));	break;
					//v = TSYS::floatBE(v);	break;
			}
			rez += (int64_t)fwrite((char*)&v, 1, sizeof(v), fhd);
		    }
		    break;
		}
		case 8: {
		    double v = 0;
		    for(unsigned iA = 0; iA < ai->arSize(); iA++) {
			v = ai->arGet(iA).getR();
			switch(mach[0]) {
			    case 'l': *((int64_t*)&v) = TSYS::i64_LE(*((int64_t*)&v));	break;
					//v = TSYS::doubleLE(v);	break;
			    case 'b': *((int64_t*)&v) = TSYS::i64_BE(*((int64_t*)&v));	break;
					//v = TSYS::doubleBE(v);	break;
			}
			rez += (int64_t)fwrite((char*)&v, 1, sizeof(v), fhd);
		    }
		    break;
		}
	    }
	if(isSingle) delete ai;
	if(sec1) return this;
	return rez;
    }

    throw TError("IOObj",_("Error the function '%s' or missing its parameters."),id.c_str());
}

IOObj::TpDescr &IOObj::getTp( const string &dtT )
{
    //Init data types
    if(dTPs.empty()) {
	dTPs[""] = TpDescr(1, false, true, true);

	dTPs["uchar"] = dTPs["unsigned char"] = TpDescr(1, false, false, true);
	dTPs["uint8"] = TpDescr(1);
	dTPs["uint16"] = dTPs["ushort"] = TpDescr(2);
	dTPs["uint32"] = dTPs["uint"] = dTPs["ulong"] = TpDescr(4);
	dTPs["uint64"] = TpDescr(8);

	dTPs["char"] = dTPs["schar"] = dTPs["signed char"] = TpDescr(1, false, true, true);
	dTPs["int8"] = dTPs["integer*1"] = TpDescr(1, false, true);
	dTPs["int16"] = dTPs["short"] = dTPs["integer*2"] = TpDescr(2, false, true);
	dTPs["int32"] = dTPs["int"] = dTPs["long"] = dTPs["integer*4"] = dTPs["integer"] = TpDescr(4, false, true);
	dTPs["int64"] = dTPs["integer*8"] = TpDescr(8, false, true);
	dTPs["float"] = dTPs["float32"] = dTPs["single"] = dTPs["real*4"] = TpDescr(4, true);
	dTPs["double"] = dTPs["float64"] = dTPs["real*8"] = dTPs["real"] = TpDescr(8, true);
    }

    return (dTPs.find(dtT) != dTPs.end()) ? dTPs[dtT] : dTPs[""];
}