// $Id$
// 
// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License. You may obtain a copy of the License at
// 
//   http://www.apache.org/licenses/LICENSE-2.0
// 
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied. See the License for the
// specific language governing permissions and limitations
// under the License.
// 
namespace Org.Apache.Etch.Bindings.Csharp.Transport
{
    //[TestFixture]
    //public class TestDefaultDeliveryService
    //{
    //    private DefaultDeliveryService<MyStub> svc;

    //    private MyStub ms;

    //    private readonly ValueFactory vf = new MyValueFactory();

    //    private Message msg;

    //    private MyDataSource ds = new MyDataSource();

    //    XType mt_add = new XType( "add" );
    //    XType mt_add_result = new XType( "add_result" );
    //    Field mf_x = new Field( "x" );
    //    Field mf_y = new Field( "y" );
    //    Field mf_result = new Field( "result" );

    //    public Message ConstructSimpleMessage()
    //    {   
    //        return new Message( MyValueFactory.mt_function, vf );
            
    //    }

    //    public Message ConstructAddMessage() 
    //    {

    //        msg = new Message( MyValueFactory.mt_add, vf );
    //        msg.Add( MyValueFactory.mf_x, 4 );
    //        msg.Add( MyValueFactory.mf_y, 5 );
    		
    //        return msg;
    //    }

    //    /// <summary>
    //    /// Setup method to be called before every test.
    //    /// </summary>
    //    [SetUp]
    //    public void Setup()
    //    {
    //        ms = new MyStub( null, null );

    //        DefaultDeliveryService<MyStub> dds = new MyDefaultDeliveryService( ms );

    //        svc = DefaultDeliveryService<MyStub>.SetUp( dds, ds, vf );
    //    }

    //    //[Test]
    //    //public void Up()
    //    //{
    //    //    Setup();
    //    //    svc.Up( new MailboxManager( svc, 0 ) );
    //    //    Assert.AreEqual( ms.what, What.MYSTUBCREATED );
    //    //}

    //    //[Test]
    //    //public void Down()
    //    //{
    //    //    Setup();
    //    //    svc.Up( new MailboxManager( svc, 0 ) );
    //    //    svc.Down( new MailboxManager( svc, 0 ) );
    //    //    Assert.AreEqual( ms.what, What.MYSTUBMESSAGE );
    //    //}

    //    [Test]
    //    public void ShutdownOutput()
    //    {
    //        svc.TransportControl( TransportConsts.STOP, null );
    //        Assert.AreEqual( ds.what, What.MYDATASOURCESHUTDOWNOUTPUT );
    //    }

    //    [Test]
    //    public void Message()
    //    {
    //        svc.SessionNotify( SessionConsts.UP );
    //        svc.Message( null, ConstructSimpleMessage() );
    //        Assert.AreEqual( ms.what, What.MYSTUBMESSAGE );
    //    }

    //    [Test]
    //    public void Send()
    //    {
    //        svc.Send( ConstructSimpleMessage() );
    //        Assert.AreEqual( ds.what, What.MYDATASOURCEDATA );
    //    }

    //    [Test]
    //    public void Call()
    //    {
    //        try
    //        {
    //            svc.EndCall( svc.BeginCall( ConstructAddMessage() ), mt_add_result,
    //                mf_result, 1 );
    //        }
    //        catch ( Exception )
    //        {
    //            Assert.AreEqual( ds.what, What.MYDATASOURCEDATA );
    //        }
    //    }

    //    public class MyDefaultDeliveryService : DefaultDeliveryService<MyStub>
    //    {
    //        private MyStub ms;

    //        public MyDefaultDeliveryService( MyStub ms )
    //        {
    //            this.ms = ms;
    //        }

    //        protected override MyStub NewStub( MailboxMessageSource src )
    //        {
    //            return ms;
    //        }

    //        public override string ToString()
    //        {
    //            return "MyDefaultDeliveryService testing";
    //        }
    //    }

    //    public enum What
    //    {
    //        MYSTUBCREATED,
    //        MYSTUBMESSAGE,
    //        MYDATASOURCESHUTDOWNOUTPUT,
    //        MYDATASOURCEDATA
    //    };

    //    public class MyDataSource : DataSource
    //    {
    //        public Enum what;

    //        #region DataSource Members

    //        public void Data( Who recipient, FlexBuffer buf )
    //        {
    //            what = What.MYDATASOURCEDATA;
    //        }

    //        #endregion


    //        #region Source Members

    //        public object GetHandler()
    //        {
    //            return null;
    //        }

    //        public void SetHandler( object handler )
    //        {
    //            // nothing to do. 
    //        }

    //        #endregion

    //        #region Transport Members

    //        public object TransportQuery( object query )
    //        {
    //            return null;
    //        }

    //        public void TransportControl( object control, object value )
    //        {
    //            if ( control.Equals( TransportConsts.STOP ) )
    //                what = What.MYDATASOURCESHUTDOWNOUTPUT;
    //        }

    //        public void TransportNotify( object eventObj )
    //        {
    //            // ignore
    //        }

    //        #endregion
    //    }

    //    public class MyStub : StubBase
    //    {
    //        public Enum what;

    //        public MyStub( MessageSource src, Object obj ) : base ( src, obj, null, null )
    //        {
    //            what = What.MYSTUBCREATED;
    //        }

    //        public override bool Message( Who sender, Message msg )
    //        {
    //            what = What.MYSTUBMESSAGE;
    //            return true;
    //        }
    //    }

    //    public class MyValueFactory : DefaultValueFactory
    //    {
    //        private readonly static TypeMap types = new TypeMap();

    //        private readonly static FieldMap fields = new FieldMap();

    //        private readonly static Class2TypeMap class2type = 
    //            new Class2TypeMap();

    //        public readonly static XType mt_function = types.Get( "function" );

    //        public readonly static XType mt_add = types.Get( "add" );

    //        public readonly static XType mt_add_result = types.Get( "add_result" );

    //        public readonly static Field mf_x = fields.Get( "x" );

    //        public readonly static Field mf_y = fields.Get( "y" );

    //        public readonly static Field mf_result = fields.Get( "xresult" );

    //        static MyValueFactory()
    //        {
    //            DefaultValueFactory.Init( types, fields, class2type );

    //            mt_function.PutValidator( DefaultValueFactory._mf__messageId, Validator_long.Get( 0 ) );

    //            mt_add.PutValidator( mf_x, Validator_int.Get( 0 ) );
    //            mt_add.PutValidator( mf_y, Validator_int.Get( 0 ) );
    //            mt_add.PutValidator( DefaultValueFactory._mf__messageId, Validator_long.Get( 0 ) );

    //            mt_add_result.PutValidator( mf_result, Validator_int.Get( 0 ) );
    //            mt_add_result.PutValidator( DefaultValueFactory._mf__messageId, Validator_long.Get( 0 ) );
    //            mt_add_result.PutValidator( DefaultValueFactory._mf__inReplyTo, Validator_long.Get( 0 ) );
    //        }

    //        public override XType GetType( int? id )
    //        {
    //            return types.Get( id );
    //        }

    //        public override XType GetType( string name )
    //        {
    //            return types.Get( name );
    //        }

    //        public override ICollection<XType> GetTypes()
    //        {
    //            return types.Values();
    //        }

    //        public override Field GetField( int? id )
    //        {
    //            return fields.Get( id );
    //        }

    //        public override Field GetField( string name )
    //        {
    //            return fields.Get( name );
    //        }

    //        public override ICollection<Field> GetFields()
    //        {
    //            return fields.Values();
    //        }

    //        public override StructValue ExportCustomValue( Object value )
    //        {
    //            return ExportCustomValue( this, class2type, value );
    //        }

    //        public override XType GetCustomStructType( Type c )
    //        {
    //            return class2type.Get( c );
    //        }
    //    }
    //}
}