src/sapi/com.hpp - master - gozaltech/RHVoice2

src/sapi/com.hpp
376 строк8 KB
KOLANICH
Replace some http:// links to https:// (#277)
13 май 2021, 23:10
13 май 2021, 23:100f48e8f
/* Copyright (C) 2012  Olga Yakovleva <yakovleva.o.v@gmail.com> */

/* This program is free software: you can redistribute it and/or modify */
/* it under the terms of the GNU Lesser General Public License as published by */
/* the Free Software Foundation, either version 2.1 of the License, or */
/* (at your option) any later version. */

/* 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 Lesser General Public License for more details. */

/* You should have received a copy of the GNU Lesser General Public License */
/* along with this program.  If not, see <https://www.gnu.org/licenses/>. */

#ifndef RHVOICE_SAPI_COM_HPP
#define RHVOICE_SAPI_COM_HPP

#include <vector>
#include <string>
#include <memory>
#include <new>
#include <stdexcept>
#include <windows.h>
#include <comdef.h>

#include "registry.hpp"
#include "utils.hpp"

namespace RHVoice
{
  namespace com
  {
    wchar_t* strdup(const std::wstring& s);

    template<class T>
    std::wstring clsid_as_string()
    {
      utils::out_ptr<wchar_t> p(CoTaskMemFree);
      HRESULT hr=StringFromCLSID(__uuidof(T),p.address());
      if(FAILED(hr))
        throw _com_error(hr);
      std::wstring s(p.get());
      return s;
    }

    class object_counter
    {
    public:
      static void increment()
      {
        InterlockedIncrement(&count);
      }

      static void decrement()
      {
        InterlockedDecrement(&count);
      }

      static bool is_zero()
      {
        return (InterlockedCompareExchange(&count,0,0)==0);
      }

    private:
      static volatile long count;
    };

    template<class I,class O>
    inline void* try_interface(O* ptr,REFIID riid)
    {
      return (IsEqualIID(riid,__uuidof(I))?static_cast<I*>(ptr):0);
    }

    template<class I,class O>
    inline void* try_primary_interface(O* ptr,REFIID riid)
    {
      if(IsEqualIID(riid,__uuidof(IUnknown)))
        return static_cast<IUnknown*>(static_cast<I*>(ptr));
      else if(IsEqualIID(riid,__uuidof(I)))
        return static_cast<I*>(ptr);
      else
        return 0;
    }

    template<class T>
    class object;

    template <class T>
    class IUnknownImpl: public T
    {
      friend class object<T>;
    private:
      IUnknownImpl():
        ref_count(1)
      {
      }

      template<typename A>
      explicit IUnknownImpl(const A& arg):
        T(arg),
        ref_count(1)
      {
      }

      ~IUnknownImpl()
      {
        object_counter::decrement();
      }

      volatile long ref_count;

    public:
      STDMETHOD_(ULONG,AddRef)();
      STDMETHOD_(ULONG,Release)();
      STDMETHOD(QueryInterface)(REFIID riid,void** ppv);
    };

    template<class T>
    STDMETHODIMP_(ULONG) IUnknownImpl<T>::AddRef()
    {
      return InterlockedIncrement(&ref_count);
    }

    template<class T>
    STDMETHODIMP_(ULONG) IUnknownImpl<T>::Release()
    {
      long count=InterlockedDecrement(&ref_count);
      if(count==0)
        delete this;
      return count;
    }

    template<class T>
    STDMETHODIMP IUnknownImpl<T>::QueryInterface(REFIID riid,void** ppv)
    {
      if(ppv==0)
        return E_POINTER;
      void* pv=this->get_interface(riid);
      *ppv=pv;
      if(pv==0)
        return E_NOINTERFACE;
      else
        {
          AddRef();
          return S_OK;
        }
    }

    template<class T>
    class object
    {
    public:
      object():
        impl(new IUnknownImpl<T>)
      {
        object_counter::increment();
      }

      template<typename A>
      object(const A& arg):
        impl(new IUnknownImpl<T>(arg))
      {
        object_counter::increment();
      }

      ~object()
      {
        impl->Release();
      }

      IUnknownImpl<T>* operator->() const
      {
        return impl;
      }

    private:
      object(const object&);
      object& operator=(const object&);

      IUnknownImpl<T>* impl;
    };

    template<class I>
    class interface_ptr
    {
    public:
      interface_ptr():
        ptr(0)
      {
      }

      template<class T>
      explicit interface_ptr(object<T>& obj)
      {
        if(FAILED(obj->QueryInterface(__uuidof(I),reinterpret_cast<void**>(&ptr))))
          throw std::invalid_argument("Unsupported interface");
      }

      interface_ptr(const interface_ptr& other):
        ptr(other.ptr)
      {
        if(ptr)
        ptr->AddRef();
      }

      interface_ptr& operator=(const interface_ptr& other)
      {
        if(other.ptr)
          other.ptr->AddRef();
        release();
        ptr=other.ptr;
      }

      ~interface_ptr()
      {
        release();
      }

      I* get(bool add_ref=true)
      {
        if(ptr&&add_ref)
          ptr->AddRef();
        return ptr;
      }

    private:
      void release()
      {
        if(ptr)
          {
            ptr->Release();
            ptr=0;
          }
      }

      I* ptr;
    };

    template<class T>
    class IClassFactoryImpl: public IClassFactory
    {
    protected:
      void* get_interface(REFIID riid)
      {
        return try_primary_interface<IClassFactory>(this,riid);
      }

    public:
      STDMETHOD(CreateInstance)(IUnknown* pUnkOuter,REFIID riid,void** ppvect);
      STDMETHOD(LockServer)(BOOL fLock);
    };

    template<class T>
    STDMETHODIMP IClassFactoryImpl<T>::CreateInstance(IUnknown* pUnkOuter,REFIID riid,void** ppv)
    {
      if(pUnkOuter!=0)
        return CLASS_E_NOAGGREGATION;
      if(ppv==0)
        return E_POINTER;
      *ppv=0;
      try
        {
          object<T> obj;
          return obj->QueryInterface(riid,ppv);
        }
      catch(const std::bad_alloc& e)
        {
          return E_OUTOFMEMORY;
        }
      catch(...)
        {
          return E_UNEXPECTED;
        }
    }

    template<class T>
    STDMETHODIMP IClassFactoryImpl<T>::LockServer(BOOL fLock)
    {
      if(fLock)
        object_counter::increment();
      else
        object_counter::decrement();
      return S_OK;
    }

    class class_object_factory
    {
    public:
      class_object_factory()
      {
      }

      template<class T> void register_class()
      {
        creators.push_back(creator_ptr(new concrete_creator<T>()));
      }

      HRESULT create(REFCLSID rclsid,REFIID riid,void** ppv) const;

    private:
      class_object_factory(const class_object_factory&);
      class_object_factory& operator=(const class_object_factory&);

      class creator
      {
      public:
        virtual ~creator()
        {
        }

        virtual bool matches(REFCLSID rclsid) const=0;
        virtual HRESULT create(REFIID riid,void** ppv) const=0;
      };

      typedef std::shared_ptr<creator> creator_ptr;

      template<class T>
      class concrete_creator: public creator
      {
      public:
        bool matches(REFCLSID rclsid) const;
        HRESULT create(REFIID riid,void** ppv) const;
      };

      std::vector<creator_ptr> creators;
    };

    template<class T>
    bool class_object_factory::concrete_creator<T>::matches(REFCLSID rclsid) const
    {
      return IsEqualCLSID(rclsid,__uuidof(T));
    }

    template<class T>
    HRESULT class_object_factory::concrete_creator<T>::create(REFIID riid,void** ppv) const
    {
      object<IClassFactoryImpl<T> > obj;
      return obj->QueryInterface(riid,ppv);
    }

    class class_registrar
    {
    public:
      explicit class_registrar(HINSTANCE dll_handle);
      template<class T> void register_class();
      template<class T> void unregister_class();

    private:
      class_registrar(const class_registrar&);
      class_registrar& operator=(const class_registrar&);

      std::wstring dll_path;
      static const std::wstring clsid_key_path;
    };

    template<class T> void class_registrar::register_class()
    {
      registry::key clsid_key(HKEY_LOCAL_MACHINE,clsid_key_path,KEY_CREATE_SUB_KEY);
      registry::key clsid_subkey(clsid_key,clsid_as_string<T>(),KEY_CREATE_SUB_KEY,true);
      registry::key server_subkey(clsid_subkey,L"InProcServer32",KEY_SET_VALUE,true);
      server_subkey.set(dll_path);
      server_subkey.set(L"ThreadingModel",L"Both");
    }

    template<class T> void class_registrar::unregister_class()
    {
      std::wstring str_clsid(clsid_as_string<T>());
      registry::key clsid_key(HKEY_LOCAL_MACHINE,clsid_key_path);
      registry::key clsid_subkey(clsid_key,str_clsid);
      clsid_subkey.delete_subkey(L"InProcServer32");
      clsid_key.delete_subkey(str_clsid);
    }
  }
}
#endif