coprocess: reimplement gateway bindings using ctypes

coprocess/python/dispatcher.py

@@ -6,11 +6,12 @@
 from tyk.object import TykCoProcessObject
 from tyk.event import TykEvent
 
-# from gateway import TykGateway as tyk
+# TODO: handle exceptions here
+from gateway import TykGateway as tyk
 
 import sys
 def except_hook(type, value, traceback):
-    # tyk.log_error("{0}".format(value))
+    tyk.log_error("{0}".format(value))
     pass
 
 sys.excepthook = except_hook
@@ -19,7 +20,7 @@ class TykDispatcher:
     '''A simple dispatcher'''
 
     def __init__(self, bundle_root_path):
-        # tyk.log("Initializing dispatcher", "info")
+        tyk.log("Initializing dispatcher", "info")
         self.bundle_root_path = bundle_root_path
         self.bundles = []
         self.hook_table = {}
@@ -89,5 +90,5 @@ def dispatch_event(self, event_json):
             raise Exception("Couldn't dispatch '{0}' event: {1}", event.handler_name, e)
 
     def reload(self):
-        # tyk.log("Reloading event handlers and middlewares.", "info")
+        tyk.log("Reloading event handlers and middlewares.", "info")
         pass

coprocess/python/tyk/gateway.py

@@ -0,0 +1,33 @@
+import ctypes
+parent = ctypes.cdll.LoadLibrary(None)
+
+parent.TykGetData.argtypes = [ctypes.c_char_p]
+parent.TykGetData.restype = ctypes.c_char_p
+
+parent.TykStoreData.argtypes = [ctypes.c_char_p, ctypes.c_char_p, ctypes.c_int]
+
+class TykGateway():
+    def log(message, level):
+        message_p = ctypes.c_char_p(bytes(message, "utf-8"))
+        level_p = ctypes.c_char_p(bytes(level, "utf-8"))
+        parent.CoProcessLog(message_p, level_p)
+
+    def log_error(message):
+        message_p = ctypes.c_char_p(bytes(message, "utf-8"))
+        level_p = ctypes.c_char_p(bytes("error", "utf-8"))
+        parent.CoProcessLog(message_p, level_p)
+
+    def get_data(key):
+        key_p = ctypes.c_char_p(bytes(key, "utf-8"))
+        return parent.TykGetData(key_p)
+
+    def store_data(key, value, ttl):
+        key_p = ctypes.c_char_p(bytes(key, "utf-8"))
+        value_p = ctypes.c_char_p(bytes(value, "utf-8"))
+        ttl_int = ctypes.c_int(ttl)
+        parent.TykStoreData(key_p, value_p, ttl_int)
+
+    def trigger_event(name, payload):
+        name_p = ctypes.c_char_p(bytes(name, "utf-8"))
+        payload_p = ctypes.c_char_p(bytes(payload, "utf-8"))
+        parent.TykTriggerEvent(name_p, payload_p)

coprocess/python/tyk/middleware.py

@@ -7,13 +7,13 @@
 
 import tyk.decorators as decorators
 from tyk.loader import MiddlewareLoader
-# from gateway import TykGateway as tyk
+from gateway import TykGateway as tyk
 
 HandlerDecorators = list( map( lambda m: m[1], inspect.getmembers(decorators, inspect.isclass) ) )
 
 class TykMiddleware:
     def __init__(self, filepath, bundle_root_path=None):
-        # tyk.log( "Loading module: '{0}'".format(filepath), "info")
+        tyk.log( "Loading module: '{0}'".format(filepath), "info")
         self.filepath = filepath
         self.handlers = {}
 
@@ -42,7 +42,7 @@ def __init__(self, filepath, bundle_root_path=None):
             self.register_handlers()
             self.cleanup()
         except Exception as e:
-            # tyk.log_error("Middleware initialization error: {0}".format(e))
+            tyk.log_error("Middleware initialization error: {0}".format(e))
             pass
 
     def register_handlers(self):
@@ -64,7 +64,7 @@ def build_hooks_and_event_handlers(self):
             for handler in self.handlers[hook_type]:
                 handler.middleware = self
                 hooks[handler.name] = handler
-                # tyk.log("Loading hook '{0}' ({1})".format(handler.name, self.filepath), "debug")
+                tyk.log("Loading hook '{0}' ({1})".format(handler.name, self.filepath), "debug")
         return hooks
 
     def cleanup(self):

gateway/coprocess_api.go

@@ -1,6 +1,3 @@
-// +build coprocess
-// +build !grpc
-
 package gateway
 
 import "C"