online fix

airdrop/airdrop_server.py

@@ -8,7 +8,7 @@
     PointsRecord,
     ProjectInterAction
 )
-from services.savour_rpc import airdrop_pb2_grpc, common_pb2, airdrop_pb2
+from services.savour_rpc import airdrop_pb2_grpc, airdrop_pb2
 from django.conf import settings
 
 tz = pytz.timezone(settings.TIME_ZONE)
@@ -51,7 +51,7 @@ def submitDppLinkPoints(self, request, context) -> airdrop_pb2.DppLinkPointsRep:
                     airdrop_user = airdrop_tmp_user
                 else:
                     return airdrop_pb2.DppLinkPointsRep(
-                        code=common_pb2.SUCCESS,
+                        code=200,
                         msg="already arrive to daily or max points",
                     )
             else:
@@ -67,6 +67,6 @@ def submitDppLinkPoints(self, request, context) -> airdrop_pb2.DppLinkPointsRep:
                 points=projectInteraction.once_points
             )
             return airdrop_pb2.DppLinkPointsRep(
-                code=common_pb2.SUCCESS,
+                code=200,
                 msg="submit dapplink points success",
             )

services/airdrop_client.py

@@ -14,10 +14,12 @@ def __init__(self):
         self.stub = airdrop_pb2_grpc.AirdropServiceStub(channel)
 
     def submit_dapplink_points(self, type: int, consumer_token: str = None) -> airdrop_pb2.DppLinkPointsRep:
-        return self.stub.submitDppLinkPoints(
+        ret_value = self.stub.submitDppLinkPoints(
             airdrop_pb2.DppLinkPointsReq(
                 consumer_token=consumer_token,
-                type="1",
+                type="0",
                 address="0xf6f75BF38ED11F984Ac195e8b8a61Df73bA48892"
             )
         )
+        print("ret===", ret_value.code, ret_value.msg)
+        return ret_value

services/savour_rpc/airdrop_grpc.py

@@ -0,0 +1,40 @@
+# Generated by the Protocol Buffers compiler. DO NOT EDIT!
+# source: savour_rpc/airdrop.proto
+# plugin: grpclib.plugin.main
+import abc
+import typing
+
+import grpclib.const
+import grpclib.client
+if typing.TYPE_CHECKING:
+    import grpclib.server
+
+from services.savour_rpc import airdrop_pb2
+
+
+class AirdropServiceBase(abc.ABC):
+
+    @abc.abstractmethod
+    async def submitDppLinkPoints(self, stream: 'grpclib.server.Stream[savour_rpc.airdrop_pb2.DppLinkPointsReq, savour_rpc.airdrop_pb2.DppLinkPointsRep]') -> None:
+        pass
+
+    def __mapping__(self) -> typing.Dict[str, grpclib.const.Handler]:
+        return {
+            '/services.savour_rpc.airdrop.AirdropService/submitDppLinkPoints': grpclib.const.Handler(
+                self.submitDppLinkPoints,
+                grpclib.const.Cardinality.UNARY_UNARY,
+                airdrop_pb2.DppLinkPointsReq,
+                airdrop_pb2.DppLinkPointsRep,
+            ),
+        }
+
+
+class AirdropServiceStub:
+
+    def __init__(self, channel: grpclib.client.Channel) -> None:
+        self.submitDppLinkPoints = grpclib.client.UnaryUnaryMethod(
+            channel,
+            '/services.savour_rpc.airdrop.AirdropService/submitDppLinkPoints',
+            airdrop_pb2.DppLinkPointsReq,
+            airdrop_pb2.DppLinkPointsRep,
+        )

services/savour_rpc/airdrop_pb2_grpc.py

@@ -2,7 +2,7 @@
 """Client and server classes corresponding to protobuf-defined services."""
 import grpc
 
-from services.savour_rpc import airdrop_pb2 as savourrpc_dot_airdrop__pb2
+from services.savour_rpc import airdrop_pb2 as savour__rpc_dot_airdrop__pb2
 
 
 class AirdropServiceStub(object):
@@ -15,9 +15,9 @@ def __init__(self, channel):
             channel: A grpc.Channel.
         """
         self.submitDppLinkPoints = channel.unary_unary(
-                '/savourrpc.airdrop.AirdropService/submitDppLinkPoints',
-                request_serializer=savourrpc_dot_airdrop__pb2.DppLinkPointsReq.SerializeToString,
-                response_deserializer=savourrpc_dot_airdrop__pb2.DppLinkPointsRep.FromString,
+                '/services.savour_rpc.airdrop.AirdropService/submitDppLinkPoints',
+                request_serializer=savour__rpc_dot_airdrop__pb2.DppLinkPointsReq.SerializeToString,
+                response_deserializer=savour__rpc_dot_airdrop__pb2.DppLinkPointsRep.FromString,
                 )
 
 
@@ -35,12 +35,12 @@ def add_AirdropServiceServicer_to_server(servicer, server):
     rpc_method_handlers = {
             'submitDppLinkPoints': grpc.unary_unary_rpc_method_handler(
                     servicer.submitDppLinkPoints,
-                    request_deserializer=savourrpc_dot_airdrop__pb2.DppLinkPointsReq.FromString,
-                    response_serializer=savourrpc_dot_airdrop__pb2.DppLinkPointsRep.SerializeToString,
+                    request_deserializer=savour__rpc_dot_airdrop__pb2.DppLinkPointsReq.FromString,
+                    response_serializer=savour__rpc_dot_airdrop__pb2.DppLinkPointsRep.SerializeToString,
             ),
     }
     generic_handler = grpc.method_handlers_generic_handler(
-            'savourrpc.airdrop.AirdropService', rpc_method_handlers)
+            'services.savour_rpc.airdrop.AirdropService', rpc_method_handlers)
     server.add_generic_rpc_handlers((generic_handler,))
 
 
@@ -59,8 +59,8 @@ def submitDppLinkPoints(request,
             wait_for_ready=None,
             timeout=None,
             metadata=None):
-        return grpc.experimental.unary_unary(request, target, '/savourrpc.airdrop.AirdropService/submitDppLinkPoints',
-            savourrpc_dot_airdrop__pb2.DppLinkPointsReq.SerializeToString,
-            savourrpc_dot_airdrop__pb2.DppLinkPointsRep.FromString,
+        return grpc.experimental.unary_unary(request, target, '/services.savour_rpc.airdrop.AirdropService/submitDppLinkPoints',
+            savour__rpc_dot_airdrop__pb2.DppLinkPointsReq.SerializeToString,
+            savour__rpc_dot_airdrop__pb2.DppLinkPointsRep.FromString,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)