feat: client access functionality (sourceplusplus/sourceplusplus#504)

Author: BFergerson

control/src/main/kotlin/spp/probe/ProbeConfiguration.kt

@@ -141,6 +141,19 @@ object ProbeConfiguration {
             arrayOf("skywalking.plugin.toolkit.log.transmit_formatted", "false"),
             sppSettings.find { it[0] == "spp.platform_host" }?.let {
                 arrayOf("skywalking.collector.backend_service", it[1] + ":11800")
+            },
+            getJsonObject("authentication")?.let {
+                val clientId = it.getString("client_id")
+                val clientSecret = it.getString("client_secret")
+                val tenantId = it.getString("tenant_id")
+                val authToken = "$clientId:$clientSecret".let {
+                    if (tenantId != null) {
+                        "$it:$tenantId"
+                    } else {
+                        it
+                    }
+                }
+                arrayOf("skywalking.agent.authentication", authToken)
             }
         ).filterNotNull().toMutableSet()
     }

control/src/main/kotlin/spp/probe/SourceProbe.kt

@@ -202,7 +202,9 @@ object SourceProbe {
             }
             socket.result().closeHandler {
                 connected.set(false)
-                connectToPlatform()
+                vertx!!.setTimer(5000) {
+                    connectToPlatform()
+                }
             }
 
             //handle platform messages
@@ -242,6 +244,16 @@ object SourceProbe {
                             frame.getValue("body")
                         )
                     }
+                } else if ("err" == frame.getString("type")) {
+                    val errorMessage = frame.getString("message")
+                    if (ProbeConfiguration.isNotQuite) {
+                        if (errorMessage == "blocked by bridgeEvent handler") {
+                            System.err.println("Probe authentication failed")
+                        } else {
+                            System.err.println(frame.getString("message"))
+                        }
+                    }
+                    disconnectFromPlatform()
                 } else {
                     throw UnsupportedOperationException(frame.toString())
                 }