it_bus/stream_transformer.h

#ifndef _STRING_TEMPLATE_PROCESSOR_H_
#define _STRING_TEMPLATE_PROCESSOR_H_

//
//      Copyright (c) 2002 IONA Technologies PLC. All Rights Reserved.
// 
//

#include <it_dsa/vector.h>
#include <it_bus/string_map.h>
#include <it_bus/types.h>
#include <it_bus/binary_buffer.h>
#include <it_bus/exception.h>

namespace IT_Bus
{
        class IT_AFC_API StreamTransformerException :
            public Exception
        {
          public:
            StreamTransformerException(
                const char * desc1 = 0,
                const char * desc2 = 0,
                const char * desc3 = 0,
                const char * desc4 = 0,
                const char * desc5 = 0,
                const char * desc6 = 0
            );

            StreamTransformerException(
                IT_ULong error_code, 
                const char * desc1 = 0,
                const char * desc2 = 0,
                const char * desc3 = 0,
                const char * desc4 = 0,
                const char * desc5 = 0,
                const char * desc6 = 0
            );

            virtual ~StreamTransformerException();

            virtual Exception*
            clone() const;
        
            virtual void
            rethrow() const;
        };


        class IT_AFC_API StreamTransformer;

        class IT_AFC_API KeywordTransformer
        {
        public:
            KeywordTransformer();

            KeywordTransformer(
                 const KeywordTransformer&
            );

            virtual
            ~KeywordTransformer();

            virtual
            void
            transform(
                StreamTransformer&,
                BinaryBuffer&
            ) throw((IT_Bus::StreamTransformerException)) = 0;
        };

        class IT_AFC_API StreamTransformer
        {
          typedef IT_Pair<char, char>                 DelimPairType;
          typedef IT_Vector<DelimPairType>            DelimPairVectorType;
          typedef StringMap<KeywordTransformer*>      KeywordTransformerMapType;

        public:
            StreamTransformer();

            virtual
            ~StreamTransformer();

            void
            register_keyword(
                const String&,
                KeywordTransformer*
            );

            void
            register_delimiters(
                char,
                char
            );

            void
            transform(
                const BinaryBuffer&,
                BinaryBuffer&
            ) throw((IT_Bus::StreamTransformerException));

            void
            transform(
                const String&,
                String&
            ) throw((IT_Bus::StreamTransformerException));


        protected:
            int
            get_next_token(
                String&, 
                const BinaryBuffer&
            );

            KeywordTransformerMapType                       m_transformer_map;
            DelimPairVectorType                             m_delims;
            int                                             m_iter;
        };

        class IT_AFC_API FilenameTransformer : public StreamTransformer
        {
        public:
            FilenameTransformer();

            virtual
            ~FilenameTransformer();
        };

        class IT_AFC_API KeywordTransformer_PID : public KeywordTransformer
        {
        public:
            KeywordTransformer_PID();

            KeywordTransformer_PID(
                 const KeywordTransformer_PID&
            );

            virtual
            ~KeywordTransformer_PID();

            virtual
            void
            transform(
                StreamTransformer&,
                BinaryBuffer&
            ) throw((IT_Bus::StreamTransformerException));
        };
}

#endif // #define _STRING_TEMPLATE_PROCESSOR_H_

---