grpc streaming server implementatio

wso2 · Nov 14, 2023 · 4ffb370 · 4ffb370
1 parent e1ad761
commit 4ffb370
Show file tree

Hide file tree

Showing 85 changed files with 5,393 additions and 5,388 deletions.
diff --git a/adapter/api/proto/wso2/discovery/apkmgt/application.proto b/adapter/api/proto/wso2/discovery/apkmgt/application.proto
diff --git a/adapter/api/proto/wso2/discovery/keymgt/key_manager_config.proto b/adapter/api/proto/wso2/discovery/keymgt/key_manager_config.proto
diff --git a/adapter/api/proto/wso2/discovery/keymgt/revoked_tokens.proto b/adapter/api/proto/wso2/discovery/keymgt/revoked_tokens.proto
diff --git a/adapter/api/proto/wso2/discovery/service/apkmgt/applicationds.proto b/adapter/api/proto/wso2/discovery/service/apkmgt/applicationds.proto
diff --git a/adapter/api/proto/wso2/discovery/service/apkmgt/eventds.proto b/adapter/api/proto/wso2/discovery/service/apkmgt/eventds.proto
@@ -0,0 +1,18 @@
+syntax = "proto3";
+
+package discovery.service.apkmgt;
+
+import "wso2/discovery/subscription/event.proto";
+option go_package = "github.com/wso2/apk/adapter/pkg/discovery/api/wso2/discovery/service/apkmgt";
+option java_package = "org.wso2.apk.enforcer.discovery.service.apkmgt";
+option java_outer_classname = "EventServiceProto";
+option java_multiple_files = true;
+option java_generic_services = true;
+
+// [#protodoc-title: EventStreamDS]
+service EventStreamService {
+    rpc StreamEvents (Request) returns (stream wso2.discovery.subscription.Event) {}
+  }
+message Request {
+    string event = 1;
+}
diff --git a/adapter/api/proto/wso2/discovery/service/keymgt/kmds.proto b/adapter/api/proto/wso2/discovery/service/keymgt/kmds.proto
diff --git a/adapter/api/proto/wso2/discovery/service/keymgt/rtds.proto b/adapter/api/proto/wso2/discovery/service/keymgt/rtds.proto
diff --git a/adapter/api/proto/wso2/discovery/service/subscription/app_key_mapping_ds.proto b/adapter/api/proto/wso2/discovery/service/subscription/app_key_mapping_ds.proto
diff --git a/adapter/api/proto/wso2/discovery/service/subscription/app_mapping_ds.proto b/adapter/api/proto/wso2/discovery/service/subscription/app_mapping_ds.proto
diff --git a/adapter/api/proto/wso2/discovery/service/subscription/app_policy_ds.proto b/adapter/api/proto/wso2/discovery/service/subscription/app_policy_ds.proto
diff --git a/adapter/api/proto/wso2/discovery/service/subscription/appds.proto b/adapter/api/proto/wso2/discovery/service/subscription/appds.proto
diff --git a/adapter/api/proto/wso2/discovery/service/subscription/sds.proto b/adapter/api/proto/wso2/discovery/service/subscription/sds.proto
diff --git a/adapter/api/proto/wso2/discovery/service/subscription/sub_policy_ds.proto b/adapter/api/proto/wso2/discovery/service/subscription/sub_policy_ds.proto
diff --git a/adapter/api/proto/wso2/discovery/subscription/application.proto b/adapter/api/proto/wso2/discovery/subscription/application.proto
@@ -18,7 +18,7 @@ syntax = "proto3";
 
 package wso2.discovery.subscription;
 
-option go_package = "github.com/envoyproxy/go-control-plane/wso2/discovery/subscription;subscription";
+option go_package = "github.com/wso2/apk/adapter/pkg/discovery/api/wso2/discovery/subscription";
 option java_package = "org.wso2.apk.enforcer.discovery.subscription";
 option java_outer_classname = "ApplicationProto";
 option java_multiple_files = true;
@@ -30,19 +30,6 @@ message Application {
     string uuid = 1;
     string name = 2;
     string owner = 3;
-    map<string, string> attributes = 4;
-}
-
-message SecuritySchemes { 
-    OAuth2 oAuth2 = 1;
-}
-
-message OAuth2 {
-    repeated Environment environments = 1;
-}
-
-message Environment {
-    string envID = 1;
-    string applicationIdentifier = 2;
-    string keyType = 3;
+    string organization = 4;
+    map<string, string> attributes = 5;
 }
diff --git a/adapter/api/proto/wso2/discovery/subscription/application_key_mapping.proto b/adapter/api/proto/wso2/discovery/subscription/application_key_mapping.proto
@@ -18,7 +18,7 @@ syntax = "proto3";
 
 package wso2.discovery.subscription;
 
-option go_package = "github.com/envoyproxy/go-control-plane/wso2/discovery/subscription;subscription";
+option go_package = "github.com/wso2/apk/adapter/pkg/discovery/api/wso2/discovery/subscription";
 option java_package = "org.wso2.apk.enforcer.discovery.subscription";
 option java_outer_classname = "ApplicationKeyMappingProto";
 option java_multiple_files = true;