Fix examples

examples/email/scripts/email.sh

@@ -3,7 +3,7 @@ source scripts/assert.sh
 docker-compose -f resources/docker-compose.yml up &
 sleep 30s
 bal run imap_email_listener_tls.bal &
-sleep 10s
+sleep 20s
 response=$(bal run smtp_email_client_tls.bal 2>&1 | tail -n 1)
 assertNotEmpty "$response"
 assertEquals "$response" "Email sent successfully."

examples/ftp/scripts/ftp.sh

@@ -3,7 +3,7 @@ source scripts/assert.sh
 docker-compose -f resources/docker-compose.yml up &
 sleep 30s
 bal run sftp_listener_credentials_auth.bal &
-sleep 10s
+sleep 20s
 response=$(bal run sftp_client_credentials_auth.bal 2>&1 | tail -n 1)
 assertNotEmpty "$response"
 assertEquals "$response" "File: /upload/sample.txt"

examples/grpc/scripts/grpc.sh

@@ -7,7 +7,7 @@ bal grpc --input resources/grpc.proto --output client/
 
 bal build service
 bal run service/target/bin/service.jar &
-sleep 10s
+sleep 20s
 bal build client
 response=$(bal run client/target/bin/client.jar 2>&1 | tail -n 1)
 assertNotEmpty "$response"

examples/grpc/service/grpc_service_jwt_auth.bal

@@ -24,9 +24,8 @@ listener grpc:Listener securedEP = new (9090,
         }
     ]
 }
-@grpc:ServiceDescriptor {
-    descriptor: ROOT_DESCRIPTOR_GRPC,
-    descMap: getDescriptorMapGrpc()
+@grpc:Descriptor {
+    value: GRPC_DESC
 }
 isolated service "HelloWorld" on securedEP {
     isolated remote function hello() returns string {

examples/http/scripts/http.sh

@@ -1,7 +1,7 @@
 source scripts/assert.sh
 
 bal run http_service_jwt_auth.bal &
-sleep 10s
+sleep 20s
 response=$(bal run http_client_self_signed_jwt_auth.bal 2>&1 | tail -n 1)
 assertNotEmpty "$response"
 assertEquals "$response" "Hello, World!"

examples/kafka/scripts/kafka.sh

@@ -3,7 +3,7 @@ source scripts/assert.sh
 docker-compose -f resources/docker-compose.yml up &
 sleep 60s
 bal run kafka_consumer_sasl_plain_auth.bal &
-sleep 10s
+sleep 20s
 response=$(bal run kafka_producer_sasl_plain_auth.bal 2>&1 | tail -n 1)
 assertNotEmpty "$response"
 assertEquals "$response" "Message published successfully."

examples/nats/scripts/nats.sh

@@ -3,7 +3,7 @@ source scripts/assert.sh
 docker-compose -f resources/docker-compose.yml up &
 sleep 30s
 bal run nats_subscriber_credentials_auth.bal &
-sleep 10s
+sleep 20s
 response=$(bal run nats_publisher_credentials_auth.bal 2>&1 | tail -n 1)
 assertNotEmpty "$response"
 assertEquals "$response" "Message published successfully."

examples/rabbitmq/scripts/rabbitmq.sh

@@ -3,7 +3,7 @@ source scripts/assert.sh
 docker-compose -f resources/docker-compose.yml up &
 sleep 60s
 bal run rabbitmq_consumer_credentials_auth.bal &
-sleep 10s
+sleep 20s
 response=$(bal run rabbitmq_producer_credentials_auth.bal 2>&1 | tail -n 1)
 assertNotEmpty "$response"
 assertEquals "$response" "Message published successfully."

examples/stan/scripts/stan.sh

@@ -3,7 +3,7 @@ source scripts/assert.sh
 docker-compose -f resources/docker-compose.yml up &
 sleep 30s
 bal run stan_subscriber_credentials_auth.bal &
-sleep 10s
+sleep 20s
 response=$(bal run stan_publisher_credentials_auth.bal 2>&1 | tail -n 1)
 assertNotEmpty "$response"
 assertEquals "$response" "Message published successfully."

examples/tcp/scripts/tcp.sh

@@ -1,7 +1,7 @@
 source scripts/assert.sh
 
 bal run tcp_listener_tls.bal &
-sleep 10s
+sleep 20s
 response=$(bal run tcp_client_tls.bal 2>&1 | tail -n 1)
 assertNotEmpty "$response"
 assertEquals "$response" "Received message: Hello, World!"

examples/websocket/scripts/websocket.sh

@@ -1,7 +1,7 @@
 source scripts/assert.sh
 
 bal run websocket_service_jwt_auth.bal &
-sleep 10s
+sleep 20s
 response=$(bal run websocket_client_self_signed_jwt_auth.bal 2>&1 | tail -n 1)
 assertNotEmpty "$response"
 assertEquals "$response" "Hello, World!"

examples/websub/scripts/websub.sh

@@ -1,9 +1,9 @@
 source scripts/assert.sh
 
 bal run websub_hub_service_jwt_auth.bal &
-sleep 10s
+sleep 20s
 bal run websub_subscriber_service_jwt_auth.bal &
-sleep 10s
+sleep 20s
 response=$(bal run websub_publisher_client_jwt_auth.bal 2>&1 | tail -n 1)
 assertNotEmpty "$response"
 assertEquals "$response" "Publish update successful."

examples/websub/websub_hub_service_jwt_auth.bal

@@ -32,7 +32,7 @@ isolated service /websubhub on securedHub {
     isolated remote function onRegisterTopic(websubhub:TopicRegistration msg, http:Headers headers) returns websubhub:TopicRegistrationSuccess|websubhub:TopicRegistrationError {
         string? auth = doAuth(headers);
         if auth is string {
-            return error websubhub:TopicRegistrationError(auth);
+            return websubhub:TOPIC_REGISTRATION_ERROR;
         }
         log:printInfo("Registered topic: '" + msg.topic + "'.");
         websubhub:TopicRegistrationSuccess result = {
@@ -44,7 +44,7 @@ isolated service /websubhub on securedHub {
     isolated remote function onDeregisterTopic(websubhub:TopicDeregistration msg, http:Headers headers) returns websubhub:TopicDeregistrationSuccess|websubhub:TopicDeregistrationError {
         string? auth = doAuth(headers);
         if auth is string {
-            return error websubhub:TopicDeregistrationError(auth);
+            return websubhub:TOPIC_DEREGISTRATION_ERROR;
         }
         log:printInfo("Deregistered topic: '" + msg.topic + "'.");
         websubhub:TopicDeregistrationSuccess result = {
@@ -56,7 +56,7 @@ isolated service /websubhub on securedHub {
     isolated remote function onSubscription(websubhub:Subscription msg, http:Headers headers) returns websubhub:SubscriptionAccepted|websubhub:InternalSubscriptionError {
         string? auth = doAuth(headers);
         if auth is string {
-            return error websubhub:InternalSubscriptionError(auth);
+            return websubhub:INTERNAL_SUBSCRIPTION_ERROR;
         }
         log:printInfo("Subscription accepted for topic: '" + msg.hubTopic + "'.");
         websubhub:SubscriptionAccepted result = {
@@ -84,7 +84,7 @@ isolated service /websubhub on securedHub {
     isolated remote function onUpdateMessage(websubhub:UpdateMessage msg, http:Headers headers) returns websubhub:Acknowledgement|websubhub:UpdateMessageError {
         string? auth = doAuth(headers);
         if auth is string {
-            return error websubhub:UpdateMessageError(auth);
+            return websubhub:UPDATE_MESSAGE_ERROR;
         }
         log:printInfo("Message updated for message type: '" + msg.msgType.toString() + "', topic: '" + msg.hubTopic +
                         "', content-type: '" + msg.contentType + "', content: '" + msg.content.toString() + "'.");