Interfaces.cs

using MyCaffe.basecode;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Runtime.Serialization;
using System.ServiceModel;
using System.Text;
using System.Threading.Tasks;
 
namespace MyCaffe.db.stream
{
#pragma warning disable 1591
 
    [ServiceContract]
    public interface IXStreamDatabaseEvent 
    {
        [OperationContract(IsOneWay = false)]
        void OnResult(string strMsg, double dfProgress);
 
        [OperationContract(IsOneWay = false)]
        void OnError(StreamDatabaseErrorData err);
    }
 
#pragma warning restore 1591
 
    [Serializable]
    [DataContract]
    public enum QUERY_TYPE
    {
        GENERAL,
        SYNCHRONIZED
    }
 
    [ServiceContract(CallbackContract = typeof(IXStreamDatabaseEvent), SessionMode = SessionMode.Required)]
    public interface IXStreamDatabase
    {
        [OperationContract(IsOneWay = false)]
        void Initialize(QUERY_TYPE qt, string strSchema);
 
        [OperationContract(IsOneWay = false)]
        void Shutdown();
 
        [OperationContract(IsOneWay = false)]
        void Reset(int nStartOffset = 0);
 
        [OperationContract(IsOneWay = false)]
        SimpleDatum Query(int nWait = 1000);
 
        [OperationContract(IsOneWay = false)]
        int[] QuerySize();
 
        [OperationContract(IsOneWay = false)]
        Dictionary<string, float> QueryInfo();
    }
 
#pragma warning disable 1591
 
    public interface IXQuery 
    {
        void AddDirectQuery(IXCustomQuery iqry);
        void Reset(int nStartOffset);
        void Shutdown();
        List<int> GetQuerySize();
        SimpleDatum Query(int nWait);
        byte[] ConvertOutput(float[] rg, out string type);
        Dictionary<string, float> QueryInfo();
    }
 
#pragma warning restore 1591
 
    public enum CUSTOM_QUERY_TYPE
    {
        BYTE,
        REAL_FLOAT,
        REAL_DOUBLE,
        TIME
    }
 
 
    public interface IXCustomQuery
    {
        CUSTOM_QUERY_TYPE QueryType { get; }
        string Name { get; }
        int FieldCount { get; }
        void Open();
        void Close();
        List<int> GetQuerySize();
        double[] QueryByTime(DateTime dt, TimeSpan ts, int nCount);
        byte[] QueryBytes();
        List<double[]> QueryRealD();
        List<float[]> QueryRealF();
        Dictionary<string, float> QueryInfo();
        IXCustomQuery Clone(string strParam);
        void Reset();
        byte[] ConvertOutput(float[] rg, out string strType);
    }
 
    public class ParamPacker
    {
        public static string Pack(string str)
        {
            str = Utility.Replace(str, ';', '|');
            return Utility.Replace(str, '=', '~');
        }
 
        public static string UnPack(string str)
        {
            str = Utility.Replace(str, '|', ';');
            return Utility.Replace(str, '~', '=');
        }
    }
 
#pragma warning disable 1591
 
    [DataContract]
    public class StreamDatabaseErrorData 
    {
        [DataMember]
        public bool Result { get; set; }
        [DataMember]
        public string ErrorMessage { get; set; }
        [DataMember]
        public string ErrorDetails { get; set; }
    }
 
#pragma warning restore 1591
}