Fix CI

Author: reitowo

proto/common.proto

@@ -0,0 +1,16 @@
+syntax = "proto3";
+
+package vts.server;
+
+message FrameFormatSetting {
+  int32 frameWidth = 1;
+  int32 frameHeight = 2;
+  int32 frameRate = 3;
+  int32 frameQuality = 4;
+}
+
+message ReqCommon {}
+
+message RspCommon {}
+
+message NotifyCommon {}

proto/relay.proto

@@ -0,0 +1,43 @@
+syntax = "proto3";
+import "common.proto";
+
+package vts.relay;
+
+message ReqRelayCreate {
+  int32 hours = 1;
+  int32 participants = 2;
+  optional string roomId = 3;
+  vts.server.FrameFormatSetting maxQuality = 4;
+  optional string coupon = 5;
+}
+
+message RspPrice {
+  float price = 1;
+}
+
+message RspBuyQrCode {
+  string code = 1;
+  string id = 2;
+}
+
+message ReqBuyStatus {
+  string id = 1;
+}
+
+message RspBuyStatus {
+  string status = 1;
+  string ip = 2;
+  string username = 3;
+  string password = 4;
+}
+
+message ReqRefund {
+  string id = 1;
+}
+
+service RelayService {
+  rpc QueryPrice(ReqRelayCreate) returns (RspPrice);
+  rpc StartBuyWeixin(ReqRelayCreate) returns (RspBuyQrCode);
+  rpc QueryStatus(ReqBuyStatus) returns (RspBuyStatus);
+  rpc Refund(ReqRefund) returns (vts.server.RspCommon);
+}

proto/vts.proto

@@ -0,0 +1,34 @@
+syntax = "proto3";
+
+package vts;
+
+enum VtsMsgType {
+    VTS_MSG_INVALID = 0;
+    VTS_MSG_AVFRAME = 1;
+    VTS_MSG_AVSTOP = 2;
+    VTS_MSG_HEARTBEAT = 3;
+}
+
+message AvPacket {
+  bytes data = 1;
+  int64 pts = 2;
+  int64 dts = 3;
+  int32 flags = 4;
+}
+
+message VtsAvFrame {
+  repeated AvPacket packets = 3;
+  int64 pts = 4;
+}
+
+message VtsMsg { 
+  VtsMsgType type = 2;
+  VtsAvFrame avFrame = 3;
+}
+
+message SmartBuf {
+  uint32 seq = 1;
+  uint32 part = 2;
+  uint32 total = 3;
+  bytes data = 4;
+}

proto/vts_server.proto

@@ -0,0 +1,128 @@
+syntax = "proto3";
+import "common.proto";
+
+package vts.server;
+
+message Peer {
+    string peerId = 1;
+    bool isServer = 2;
+    string nick = 3;
+    int64 rtt = 4;
+    int32 natType = 5;
+    int32 sortingOrder = 6;
+}
+
+message Sdp {
+    string sdp = 1;
+    string type = 2;
+    string fromPeerId = 3;
+    string toPeerId = 4;
+}
+
+message Candidate {
+    string candidate = 1;
+    string mid = 2;
+    string fromPeerId = 3;
+    string toPeerId = 4;
+}
+
+message ReqCreateRoom {
+    string peerId = 1;
+    FrameFormatSetting format = 2; 
+    string nick = 4;
+    string turn = 5;
+}
+
+message ReqJoinRoom {
+    string roomId = 1;
+    string peerId = 2;
+    string nick = 3;
+}
+
+message ReqNickname {
+    string nick = 2;
+}
+
+message ReqNatType {
+    int32 natType = 2;
+}
+
+message ReqRtt {
+    map<string, int64> rtt = 1;
+}
+
+message StatInfo {
+    int64 rtt = 1;
+    uint64 txBytes = 2;
+    uint64 rxBytes = 3;
+    uint64 txSpeed = 4;
+    uint64 rxSpeed = 5;
+}
+
+message ReqStat {
+    map<string, StatInfo> stats = 1;
+}
+
+message RspRoomInfo {
+    string roomId = 2;
+    FrameFormatSetting format = 3;
+    string hostPeerId = 4;
+    string turn = 5;
+}
+
+message TurnInfo {
+    string turn = 1;
+}
+
+message ReqShareInfo {
+    string gpu = 1;
+    string capture = 2;
+    bool start = 3;
+    bool isWireless = 4;
+    bool is2G4 = 5;
+}
+
+message ReqIdr {
+    string reason = 1;
+    uint64 timestamp = 2;
+    string peerId = 3;
+}
+
+message Notify {
+    oneof notify {
+        NotifyPeers peers = 2;
+        Sdp sdp = 3;
+        FrameFormatSetting frame = 4;
+        NotifyCommon roomDestroy = 5;
+        NotifyCommon forceIdr = 6;
+        Candidate candidate = 7;
+        TurnInfo turn = 8;
+    }
+} 
+
+message NotifyPeers {
+    repeated Peer peers = 1;
+}
+
+service RoomService {
+    rpc Hello(ReqCommon) returns (RspCommon);
+
+    rpc CreateRoom(ReqCreateRoom) returns (RspRoomInfo);
+    rpc JoinRoom(ReqJoinRoom) returns (RspRoomInfo);
+
+    rpc ReceiveNotify(ReqCommon) returns (stream Notify);
+
+    rpc SetSdp(Sdp) returns (RspCommon);
+    rpc SetFrameFormat(FrameFormatSetting) returns (RspCommon); 
+    rpc SetNickName(ReqNickname) returns (RspCommon);
+    rpc SetNatType(ReqNatType) returns (RspCommon);
+    rpc SetRtt(ReqRtt) returns (RspCommon);
+    rpc SetStat(ReqStat) returns (RspCommon);
+    rpc SetShareInfo(ReqShareInfo) returns (RspCommon);
+    rpc SetCandidate(Candidate) returns (RspCommon);
+    rpc SetTurn(TurnInfo) returns (RspCommon);
+    
+    rpc RequestIdr(ReqIdr) returns (RspCommon);
+
+    rpc Exit(ReqCommon) returns (RspCommon);
+}