git.sesse.net Git - casparcg/blob - protocol/amcp/AMCPProtocolStrategy.h

   1 /*
   2 * Copyright (c) 2011 Sveriges Television AB <info@casparcg.com>
   3 *
   4 * This file is part of CasparCG (www.casparcg.com).
   5 *
   6 * CasparCG is free software: you can redistribute it and/or modify
   7 * it under the terms of the GNU General Public License as published by
   8 * the Free Software Foundation, either version 3 of the License, or
   9 * (at your option) any later version.
  10 *
  11 * CasparCG is distributed in the hope that it will be useful,
  12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14 * GNU General Public License for more details.
  15 *
  16 * You should have received a copy of the GNU General Public License
  17 * along with CasparCG. If not, see <http://www.gnu.org/licenses/>.
  18 *
  19 * Author: Nicklas P Andersson
  20 */
  21
  22 #pragma once
  23
  24 #include "../util/protocolstrategy.h"
  25 #include <core/video_channel.h>
  26
  27 #include "AMCPCommand.h"
  28 #include "AMCPCommandQueue.h"
  29
  30 #include <boost/noncopyable.hpp>
  31
  32 #include <string>
  33
  34 namespace caspar { namespace protocol { namespace amcp {
  35
  36 class AMCPProtocolStrategy : public IO::IProtocolStrategy, boost::noncopyable
  37 {
  38         enum MessageParserState {
  39                 New = 0,
  40                 GetSwitch,
  41                 GetCommand,
  42                 GetParameters,
  43                 GetChannel,
  44                 Done
  45         };
  46
  47         AMCPProtocolStrategy(const AMCPProtocolStrategy&);
  48         AMCPProtocolStrategy& operator=(const AMCPProtocolStrategy&);
  49
  50 public:
  51         AMCPProtocolStrategy(const std::vector<spl::shared_ptr<core::video_channel>>& channels);
  52         virtual ~AMCPProtocolStrategy();
  53
  54         virtual void Parse(const TCHAR* pData, int charCount, IO::ClientInfoPtr pClientInfo);
  55         virtual std::string GetCodepage() {
  56                 return "UTF-8";
  57         }
  58
  59         AMCPCommandPtr InterpretCommandString(const std::wstring& str, MessageParserState* pOutState=0);
  60
  61 private:
  62         friend class AMCPCommand;
  63
  64         void ProcessMessage(const std::wstring& message, IO::ClientInfoPtr& pClientInfo);
  65         std::size_t TokenizeMessage(const std::wstring& message, std::vector<std::wstring>* pTokenVector);
  66         AMCPCommandPtr CommandFactory(const std::wstring& str);
  67
  68         bool QueueCommand(AMCPCommandPtr);
  69
  70         std::vector<spl::shared_ptr<core::video_channel>> channels_;
  71         std::vector<AMCPCommandQueuePtr> commandQueues_;
  72         static const std::wstring MessageDelimiter;
  73 };
  74
  75 }}}