1# Generated by the Protocol Buffers compiler. DO NOT EDIT!
  2# source: app/marznode/marznode.proto
  3# plugin: grpclib.plugin.main
  4import abc
  5import typing
  6
  7import grpclib.const
  8import grpclib.client
  9if typing.TYPE_CHECKING:
 10    import grpclib.server
 11
 12import app.marznode.marznode_pb2
 13
 14
 15class MarzServiceBase(abc.ABC):
 16
 17    @abc.abstractmethod
 18    async def SyncUsers(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.UserData, app.marznode.marznode_pb2.Empty]') -> None:
 19        pass
 20
 21    @abc.abstractmethod
 22    async def RepopulateUsers(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.UsersData, app.marznode.marznode_pb2.Empty]') -> None:
 23        pass
 24
 25    @abc.abstractmethod
 26    async def FetchInbounds(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.Empty, app.marznode.marznode_pb2.InboundsResponse]') -> None:
 27        pass
 28
 29    @abc.abstractmethod
 30    async def FetchUsersStats(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.Empty, app.marznode.marznode_pb2.UsersStats]') -> None:
 31        pass
 32
 33    @abc.abstractmethod
 34    async def FetchXrayConfig(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.Empty, app.marznode.marznode_pb2.XrayConfig]') -> None:
 35        pass
 36
 37    @abc.abstractmethod
 38    async def RestartXray(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.XrayConfig, app.marznode.marznode_pb2.InboundsResponse]') -> None:
 39        pass
 40
 41    @abc.abstractmethod
 42    async def StreamXrayLogs(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.XrayLogsRequest, app.marznode.marznode_pb2.LogLine]') -> None:
 43        pass
 44
 45    def __mapping__(self) -> typing.Dict[str, grpclib.const.Handler]:
 46        return {
 47            '/marznode.MarzService/SyncUsers': grpclib.const.Handler(
 48                self.SyncUsers,
 49                grpclib.const.Cardinality.STREAM_UNARY,
 50                app.marznode.marznode_pb2.UserData,
 51                app.marznode.marznode_pb2.Empty,
 52            ),
 53            '/marznode.MarzService/RepopulateUsers': grpclib.const.Handler(
 54                self.RepopulateUsers,
 55                grpclib.const.Cardinality.UNARY_UNARY,
 56                app.marznode.marznode_pb2.UsersData,
 57                app.marznode.marznode_pb2.Empty,
 58            ),
 59            '/marznode.MarzService/FetchInbounds': grpclib.const.Handler(
 60                self.FetchInbounds,
 61                grpclib.const.Cardinality.UNARY_UNARY,
 62                app.marznode.marznode_pb2.Empty,
 63                app.marznode.marznode_pb2.InboundsResponse,
 64            ),
 65            '/marznode.MarzService/FetchUsersStats': grpclib.const.Handler(
 66                self.FetchUsersStats,
 67                grpclib.const.Cardinality.UNARY_UNARY,
 68                app.marznode.marznode_pb2.Empty,
 69                app.marznode.marznode_pb2.UsersStats,
 70            ),
 71            '/marznode.MarzService/FetchXrayConfig': grpclib.const.Handler(
 72                self.FetchXrayConfig,
 73                grpclib.const.Cardinality.UNARY_UNARY,
 74                app.marznode.marznode_pb2.Empty,
 75                app.marznode.marznode_pb2.XrayConfig,
 76            ),
 77            '/marznode.MarzService/RestartXray': grpclib.const.Handler(
 78                self.RestartXray,
 79                grpclib.const.Cardinality.UNARY_UNARY,
 80                app.marznode.marznode_pb2.XrayConfig,
 81                app.marznode.marznode_pb2.InboundsResponse,
 82            ),
 83            '/marznode.MarzService/StreamXrayLogs': grpclib.const.Handler(
 84                self.StreamXrayLogs,
 85                grpclib.const.Cardinality.UNARY_STREAM,
 86                app.marznode.marznode_pb2.XrayLogsRequest,
 87                app.marznode.marznode_pb2.LogLine,
 88            ),
 89        }
 90
 91
 92class MarzServiceStub:
 93
 94    def __init__(self, channel: grpclib.client.Channel) -> None:
 95        self.SyncUsers = grpclib.client.StreamUnaryMethod(
 96            channel,
 97            '/marznode.MarzService/SyncUsers',
 98            app.marznode.marznode_pb2.UserData,
 99            app.marznode.marznode_pb2.Empty,
100        )
101        self.RepopulateUsers = grpclib.client.UnaryUnaryMethod(
102            channel,
103            '/marznode.MarzService/RepopulateUsers',
104            app.marznode.marznode_pb2.UsersData,
105            app.marznode.marznode_pb2.Empty,
106        )
107        self.FetchInbounds = grpclib.client.UnaryUnaryMethod(
108            channel,
109            '/marznode.MarzService/FetchInbounds',
110            app.marznode.marznode_pb2.Empty,
111            app.marznode.marznode_pb2.InboundsResponse,
112        )
113        self.FetchUsersStats = grpclib.client.UnaryUnaryMethod(
114            channel,
115            '/marznode.MarzService/FetchUsersStats',
116            app.marznode.marznode_pb2.Empty,
117            app.marznode.marznode_pb2.UsersStats,
118        )
119        self.FetchXrayConfig = grpclib.client.UnaryUnaryMethod(
120            channel,
121            '/marznode.MarzService/FetchXrayConfig',
122            app.marznode.marznode_pb2.Empty,
123            app.marznode.marznode_pb2.XrayConfig,
124        )
125        self.RestartXray = grpclib.client.UnaryUnaryMethod(
126            channel,
127            '/marznode.MarzService/RestartXray',
128            app.marznode.marznode_pb2.XrayConfig,
129            app.marznode.marznode_pb2.InboundsResponse,
130        )
131        self.StreamXrayLogs = grpclib.client.UnaryStreamMethod(
132            channel,
133            '/marznode.MarzService/StreamXrayLogs',
134            app.marznode.marznode_pb2.XrayLogsRequest,
135            app.marznode.marznode_pb2.LogLine,
136        )