Add Skill handle of CloudAdapter

libraries/bot-builder/src/main/java/com/microsoft/bot/builder/skills/CloudSkillHandler.java

@@ -0,0 +1,151 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.microsoft.bot.builder.skills;
+
+import com.microsoft.bot.builder.Bot;
+import com.microsoft.bot.builder.BotAdapter;
+import com.microsoft.bot.builder.CloudChannelServiceHandler;
+import com.microsoft.bot.connector.authentication.BotFrameworkAuthentication;
+import com.microsoft.bot.connector.authentication.ClaimsIdentity;
+import com.microsoft.bot.schema.Activity;
+import com.microsoft.bot.schema.ResourceResponse;
+
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * A Bot Framework Handler for skills.
+ */
+public class CloudSkillHandler extends CloudChannelServiceHandler {
+
+    // The skill conversation reference.
+    public static final String SKILL_CONVERSATION_REFERENCE_KEY =
+        "com.microsoft.bot.builder.skills.SkillConversationReference";
+
+    // Delegate that implements actual logic
+    private final SkillHandlerImpl inner;
+
+    /**
+     * Initializes a new instance of the {@link CloudSkillHandler} class using BotFrameworkAuth.
+     * @param adapter An instance of the {@link BotAdapter} that will handle the request.
+     * @param bot The {@link Bot} instance.
+     * @param conversationIdFactory A {@link SkillConversationIdFactoryBase} to unpack the conversation ID and map it
+     *                              to the calling bot.
+     * @param auth Bot Framework Authentication to use.
+     */
+    public CloudSkillHandler(
+        BotAdapter adapter,
+        Bot bot,
+        SkillConversationIdFactoryBase conversationIdFactory,
+        BotFrameworkAuthentication auth) {
+        super(auth);
+
+        if (adapter == null) {
+            throw new IllegalArgumentException("adapter cannot be null");
+        }
+
+        if (bot == null) {
+            throw new IllegalArgumentException("bot cannot be null");
+        }
+
+        if (conversationIdFactory == null) {
+            throw new IllegalArgumentException("conversationIdFactory cannot be null");
+        }
+
+        inner = new SkillHandlerImpl(
+            SKILL_CONVERSATION_REFERENCE_KEY,
+            adapter,
+            bot,
+            conversationIdFactory,
+            auth::getOriginatingAudience);
+    }
+
+    /**
+     * sendToConversation() API for Skill.
+     *
+     * This method allows you to send an activity to the end of a conversation.
+     *
+     *  This is slightly different from replyToActivity().
+     *  * sendToConversation(conversationId) - will append the activity to the end
+     *  of the conversation according to the timestamp or semantics of the channel.
+     *  * replyToActivity(conversationId,ActivityId) - adds the activity as a reply
+     *  to another activity, if the channel supports it. If the channel does not
+     *  support nested replies, ReplyToActivity falls back to sendToConversation.
+     *
+     * Use replyToActivity when replying to a specific activity in the
+     * conversation.
+     *
+     * Use sendToConversation in all other cases.
+     *
+     * @param claimsIdentity  claimsIdentity for the bot, should have
+     *                        AudienceClaim, AppIdClaim and ServiceUrlClaim.
+     * @param conversationId  conversationId.
+     * @param activity        Activity to send.
+     *
+     * @return Task for a resource response.
+     */
+    @Override
+    protected CompletableFuture<ResourceResponse> onSendToConversation(
+        ClaimsIdentity claimsIdentity,
+        String conversationId,
+        Activity activity) {
+        return inner.onSendToConversation(claimsIdentity, conversationId, activity);
+    }
+
+    /**
+     * replyToActivity() API for Skill.
+     *
+     * This method allows you to reply to an activity.
+     *
+     * This is slightly different from sendToConversation().
+     * * SendToConversation(conversationId) - will append the activity to the end
+     * of the conversation according to the timestamp or semantics of the channel.
+     * * ReplyToActivity(conversationId,ActivityId) - adds the activity as a reply
+     * to another activity, if the channel supports it. If the channel does not
+     * support nested replies, ReplyToActivity falls back to SendToConversation.
+     *
+     * Use ReplyToActivity when replying to a specific activity in the
+     * conversation.
+     *
+     * Use sendToConversation in all other cases.
+     *
+     * @param claimsIdentity  claimsIdentity for the bot, should have
+     *                        AudienceClaim, AppIdClaim and ServiceUrlClaim.
+     * @param conversationId  Conversation ID.
+     * @param activityId      activityId the reply is to (OPTIONAL).
+     * @param activity        Activity to send.
+     *
+     * @return Task for a resource response.
+     */
+    @Override
+    protected CompletableFuture<ResourceResponse> onReplyToActivity(
+        ClaimsIdentity claimsIdentity,
+        String conversationId,
+        String activityId,
+        Activity activity) {
+        return inner.onReplyToActivity(claimsIdentity, conversationId, activityId, activity);
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    @Override
+    protected CompletableFuture<Void> onDeleteActivity(
+        ClaimsIdentity claimsIdentity,
+        String conversationId,
+        String activityId) {
+        return inner.onDeleteActivity(claimsIdentity, conversationId, activityId);
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    @Override
+    protected CompletableFuture<ResourceResponse> onUpdateActivity(
+        ClaimsIdentity claimsIdentity,
+        String conversationId,
+        String activityId,
+        Activity activity) {
+        return inner.onUpdateActivity(claimsIdentity, conversationId, activityId, activity);
+    }
+}