devGrpcClient.h 2.9 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576
  1. #include <iostream>
  2. #include <memory>
  3. #include <string>
  4. #include <fstream>
  5. #include <sstream>
  6. std::string LoadStringFromFile(std::string path) {
  7. std::ifstream file(path);
  8. if (!file.is_open()) {
  9. std::cout << "Failed to open " << path << std::endl;
  10. abort();
  11. }
  12. std::stringstream sstr;
  13. sstr << file.rdbuf();
  14. return sstr.str();
  15. }
  16. #define GRPC_DEVICE_EXPORTS
  17. #define GRPC_DEVICE_API
  18. class GrpcDeviceClient {
  19. public:
  20. GrpcDeviceClient() {}
  21. virtual ~GrpcDeviceClient() {}
  22. virtual int OpenDevice(string devUri, string group) = 0;
  23. virtual int CloseDevice() = 0;
  24. virtual string GetDeviceTarget() = 0;
  25. virtual int GetClientStatus() = 0;
  26. virtual string GetOpendDeviceResource() = 0;
  27. //同步接口
  28. virtual int Get(string devResource, string& devRes, string &calResMsg, string devUri = "",
  29. string calSection = "", string calClientID = "") = 0;
  30. virtual int Set(string devResource, string reqParams, string& devRes, string& calResMsg,
  31. string devUri = "", string calSection = "",
  32. string calClientID = "") = 0;
  33. virtual int Update(string devResource, string reqParams, string& devRes, string& calResMsg,
  34. string devUri = "", string calSection = "",
  35. string calClientID = "") = 0;
  36. virtual int Add(string devResource, string reqParams, string& devRes, string& calResMsg,
  37. string devUri = "", string calSection = "",
  38. string calClientID = "") = 0;
  39. virtual int Del(string devResource, string reqParams, string& devRes, string& calResMsg,
  40. string devUri = "", string calSection = "",
  41. string calClientID = "") = 0;
  42. virtual int Action(string devResource, string reqParams, string& devRes, string& calResMsg,
  43. string devUri = "", string calSection = "",
  44. string calClientID = "") = 0;
  45. virtual int Message(string devResource, string reqParams, string& devRes, string& calResMsg,
  46. string devUri = "", string calSection = "",
  47. string calClientID = "") = 0;
  48. virtual int BeginAyncWait() = 0;
  49. virtual void WaitAllComplete() = 0;
  50. virtual int GetAsyncResult(int idx, string& devResource, string& devRes, string& calResMsg) = 0;
  51. virtual void EndAync() = 0;
  52. virtual int AsyncAction(string devResource, string reqParams,
  53. string devUri = "", string calSection = "",
  54. string calClientID = "") = 0;
  55. virtual int AsyncMessage(string devResource, string reqParams,
  56. string devUri = "", string calSection = "",
  57. string calClientID = "") = 0;
  58. };
  59. GRPC_DEVICE_API GrpcDeviceClient* CreateClient(const char* pszDeviceServerTarget);
  60. GRPC_DEVICE_API void FreeClient(GrpcDeviceClient* pClient);