Marketplace assistant

components/apimgt/org.wso2.carbon.apimgt.api/src/main/java/org/wso2/carbon/apimgt/api/ExceptionCodes.java

@@ -548,7 +548,10 @@ public enum ExceptionCodes implements ErrorHandler {
     KEY_MANAGER_RESTRICTED_FOR_USER(902013, "Unauthorized Access to Key Manager", 403, "Key Manager is Restricted for this user"),
     // Admin portal get apis and api provider change related errors
     CHANGE_API_PROVIDER_FAILED(903011, "Error while changing the API provider", 500, "Error while changing the API provider in the registry or DB"),
-    GET_SEARCH_APIS_IN_ADMIN_FAILED(903012, "Error while getting the apis", 500, "Error while getting/searching the apis from registry");
+    GET_SEARCH_APIS_IN_ADMIN_FAILED(903012, "Error while getting the apis", 500, "Error while getting/searching the apis from registry"),
+
+    // AI service invocation related exceptions
+    INVALID_RESPONSE_FROM_AI_SERVICE(903100, "Invalid response from AI service", 500, "Error while invoking AI service. %s", false);
 
     private final long errorCode;
     private final String errorMessage;

components/apimgt/org.wso2.carbon.apimgt.impl/src/main/java/org/wso2/carbon/apimgt/impl/APIConstants.java

@@ -501,6 +501,23 @@ public final class APIConstants {
     public static final String DIGEST = "x5t#S256";
     public static final String CNF = "cnf";
 
+    // Constants related to AI features: API chat and Marketplace Assistant
+    public static final String API_CHAT =  "APIChat.";
+    public static final String API_CHAT_ENABLED = API_CHAT + "Enabled";
+    public static final String API_CHAT_AUTH_TOKEN = API_CHAT + "AuthToken";
+    public static final String API_CHAT_ENDPOINT = API_CHAT + "Endpoint";
+    public static final String API_CHAT_PREPARE_RESOURCE = "/prepare"; // "/api-chat/prepare"
+    public static final String API_CHAT_EXECUTE_RESOURCE = "/chat"; // "/api-chat/chat"
+    public static final String MARKETPLACE_ASSISTANT =  "MarketplaceAssistant";
+    public static final String MARKETPLACE_ASSISTANT_ENABLED = "Enabled";
+    public static final String MARKETPLACE_ASSISTANT_AUTH_TOKEN = "AuthToken";
+    public static final String MARKETPLACE_ASSISTANT_ENDPOINT = "Endpoint";
+    public static final String MARKETPLACE_ASSISTANT_CHAT_RESOURCE = "ChatResource";
+    public static final String MARKETPLACE_ASSISTANT_PUBLISH_API_RESOURCE = "ApiPublishResource";
+    public static final String MARKETPLACE_ASSISTANT_DELETE_API_RESOURCE = "ApiDeleteResource";
+    public static final String MARKETPLACE_ASSISTANT_API_COUNT_RESOURCE =  "ApiCountResource";
+
+
     //documentation rxt
 
     public static final String DOC_NAME = "overview_name";
@@ -1677,6 +1694,33 @@ private ConfigParameters() {
     public static final String API_DATA_SANDBOX_ENDPOINTS = "sandbox_endpoints";
     public static final String API_DATA_URL = "url";
     public static final String API_UUID = "apiUUID";
+    public static final String UUID = "uuid";
+    public static final String API_SPEC_TYPE = "api_type";
+    public static final String API_SPEC_NAME = "api_name";
+    public static final String TENANT_DOMAIN = "tenant_domain";
+    public static final String QUERY = "query";
+    public static final String HISTORY = "history";
+    public static final String VERSION = "version";
+    public static final String DESCRIPTION = "description";
+
+    public static final String DEMOTE_TO_CREATED= "Demote to Created";
+    public static final String BLOCK = "Block";
+    public static final String DEPRECATE = "Deprecate";
+    public static final String PUBLISH = "Publish";
+    public static final String DEPLOY_AS_A_PROTOTYPE = "Deploy as a Prototype";
+    public static final String REPUBLISH = "Re-Publish";
+
+    public static final String API_SPEC_TYPE_REST = "api_spec";
+    public static final String API_SPEC_TYPE_GRAPHQL = "sdl_schema";
+    public static final String API_SPEC_TYPE_ASYNC = "async_spec";
+    public static final String API_TYPE_HTTP = "HTTP";
+    public static final String API_TYPE_WEBHOOK = "WEBHOOK";
+
+    public static final String API_TYPE_REST = "REST";
+
+    public static final String API_TYPE_GRAPHQL = "GRAPHQL";
+    public static final String API_TYPE_ASYNC = "ASYNC";
+
 
     public static final String TRANSPORT_URL_IN = "TransportInURL";
 

components/apimgt/org.wso2.carbon.apimgt.impl/src/main/java/org/wso2/carbon/apimgt/impl/APIManagerConfiguration.java

@@ -38,6 +38,7 @@
 import org.wso2.carbon.apimgt.common.gateway.dto.JWKSConfigurationDTO;
 import org.wso2.carbon.apimgt.common.gateway.dto.TokenIssuerDto;
 import org.wso2.carbon.apimgt.common.gateway.extensionlistener.ExtensionListener;
+import org.wso2.carbon.apimgt.impl.ai.MarketplaceAssistantConfigurationDto;
 import org.wso2.carbon.apimgt.impl.dto.EventHubConfigurationDto;
 import org.wso2.carbon.apimgt.impl.dto.ExtendedJWTConfigurationDto;
 import org.wso2.carbon.apimgt.impl.dto.GatewayArtifactSynchronizerProperties;
@@ -116,6 +117,7 @@
     private boolean initialized;
     private ThrottleProperties throttleProperties = new ThrottleProperties();
     private ExtendedJWTConfigurationDto jwtConfigurationDto = new ExtendedJWTConfigurationDto();
+    private static MarketplaceAssistantConfigurationDto marketplaceAssistantConfigurationDto = new MarketplaceAssistantConfigurationDto();
     private WorkflowProperties workflowProperties = new WorkflowProperties();
     private Map<String, Environment> apiGatewayEnvironments = new LinkedHashMap<String, Environment>();
     private static Properties realtimeNotifierProperties;
@@ -169,6 +171,11 @@
         return monetizationConfigurationDto;
     }
 
+    public MarketplaceAssistantConfigurationDto getMarketplaceAssistantConfigurationDto() {
+
+        return marketplaceAssistantConfigurationDto;
+    }
+
     public Map<String, Map<String, String>> getLoginConfiguration() {
 
         return loginConfiguration;
@@ -624,6 +631,8 @@
                     jsonObject.put(APIConstants.CustomPropertyAttributes.REQUIRED, isRequired);
                     customProperties.add(jsonObject);
                 }
+            } else if (APIConstants.MARKETPLACE_ASSISTANT.equals(localName)) {
+                setMarketplaceAssistantConfiguration(element);
             }
             readChildElements(element, nameStack);
             nameStack.pop();
@@ -1692,6 +1701,48 @@
         }
     }
 
+    public void setMarketplaceAssistantConfiguration(OMElement omElement){
+        OMElement marketplaceAssistantEnableElement =
+                omElement.getFirstChildWithName(new QName(APIConstants.MARKETPLACE_ASSISTANT_ENABLED));
+        if (marketplaceAssistantEnableElement != null) {
+            marketplaceAssistantConfigurationDto.setEnabled(Boolean.parseBoolean(marketplaceAssistantEnableElement.getText()));
+        }
+        if (marketplaceAssistantConfigurationDto.isEnabled()) {
+            OMElement marketplaceAssistantEndpoint =
+                    omElement.getFirstChildWithName(new QName(APIConstants.MARKETPLACE_ASSISTANT_ENDPOINT));
+            if (marketplaceAssistantEndpoint != null) {
+                marketplaceAssistantConfigurationDto.setEndpoint(marketplaceAssistantEndpoint.getText());
+            }
+            OMElement marketplaceAssistantToken =
+                    omElement.getFirstChildWithName(new QName(APIConstants.MARKETPLACE_ASSISTANT_AUTH_TOKEN));
+
+            if (marketplaceAssistantToken != null) {
+                String AccessToken = MiscellaneousUtil.resolve(marketplaceAssistantToken, secretResolver);
+                marketplaceAssistantConfigurationDto.setAccessToken(AccessToken);
+            }
+            OMElement marketplaceAssistantApiCountResource =
+                    omElement.getFirstChildWithName(new QName(APIConstants.MARKETPLACE_ASSISTANT_API_COUNT_RESOURCE));
+            if (marketplaceAssistantApiCountResource != null) {
+                marketplaceAssistantConfigurationDto.setApiCountResource(marketplaceAssistantApiCountResource.getText());
+            }
+            OMElement marketplaceAssistantApiDeleteResource =
+                    omElement.getFirstChildWithName(new QName(APIConstants.MARKETPLACE_ASSISTANT_DELETE_API_RESOURCE));
+            if (marketplaceAssistantApiDeleteResource != null) {
+                marketplaceAssistantConfigurationDto.setApiDeleteResource(marketplaceAssistantApiDeleteResource.getText());
+            }
+            OMElement marketplaceAssistantApiPublishResource =
+                    omElement.getFirstChildWithName(new QName(APIConstants.MARKETPLACE_ASSISTANT_PUBLISH_API_RESOURCE));
+            if (marketplaceAssistantApiPublishResource != null) {
+                marketplaceAssistantConfigurationDto.setApiPublishResource(marketplaceAssistantApiPublishResource.getText());
+            }
+            OMElement marketplaceAssistantChatResource =
+                    omElement.getFirstChildWithName(new QName(APIConstants.MARKETPLACE_ASSISTANT_CHAT_RESOURCE));
+            if (marketplaceAssistantChatResource != null) {
+                marketplaceAssistantConfigurationDto.setChatResource(marketplaceAssistantChatResource.getText());
+            }
+        }
+    }
+
     public ThrottleProperties getThrottleProperties() {
 
         return throttleProperties;

components/apimgt/org.wso2.carbon.apimgt.impl/src/main/java/org/wso2/carbon/apimgt/impl/APIProviderImpl.java

@@ -2336,7 +2336,7 @@ public void deleteAPI(String apiUuid, String organization) throws APIManagementE
                     APIConstants.EventType.API_DELETE.name(), tenantId, organization, api.getId().getApiName(), apiId,
                     api.getUuid(), api.getId().getVersion(), api.getType(), api.getContext(),
                     APIUtil.replaceEmailDomainBack(api.getId().getProviderName()),
-                    api.getStatus(), api.getApiSecurity());
+                    api.getStatus(), api.getApiSecurity(), api.getStatus(), api.getVisibility());
             APIUtil.sendNotification(apiEvent, APIConstants.NotifierType.API.name());
         } else {
             log.debug("Event has not published to gateways due to API id has failed to retrieve from DB for API "

components/apimgt/org.wso2.carbon.apimgt.impl/src/main/java/org/wso2/carbon/apimgt/impl/ai/MarketplaceAssistantConfigurationDto.java

@@ -0,0 +1,72 @@
+package org.wso2.carbon.apimgt.impl.ai;
+
+public class MarketplaceAssistantConfigurationDto {
+
+    private String AccessToken;
+    private String Endpoint;
+    private String ApiPublishResource;
+    private String ChatResource;
+    private String ApiDeleteResource;
+    private String ApiCountResource;
+    private boolean isEnabled;
+
+
+
+    public String getAccessToken() {
+        return AccessToken;
+    }
+
+    public void setAccessToken(String AccessToken) {
+        this.AccessToken = AccessToken;
+    }
+
+    public String getEndpoint() {
+        return Endpoint;
+    }
+
+    public void setEndpoint(String Endpoint) {
+        this.Endpoint = Endpoint;
+    }
+
+    public String getApiPublishResource() {
+        return ApiPublishResource;
+    }
+
+    public void setApiPublishResource(String ApiPublishResource) {
+        this.ApiPublishResource = ApiPublishResource;
+    }
+
+    public String getChatResource() {
+        return ChatResource;
+    }
+
+    public void setChatResource(String ChatResource) {
+        this.ChatResource = ChatResource;
+    }
+
+    public String getApiDeleteResource() {
+        return ApiDeleteResource;
+    }
+
+    public void setApiDeleteResource(String ApiDeleteResource) {
+        this.ApiDeleteResource = ApiDeleteResource;
+    }
+
+    public String getApiCountResource() {
+        return ApiCountResource;
+    }
+
+    public void setApiCountResource(String ApiCountResource) {
+        this.ApiCountResource = ApiCountResource;
+    }
+
+    public boolean isEnabled() {
+        return isEnabled;
+    }
+
+    public void setEnabled(boolean Enabled) {
+        this.isEnabled = Enabled;
+    }
+
+
+}

components/apimgt/org.wso2.carbon.apimgt.impl/src/main/java/org/wso2/carbon/apimgt/impl/internal/APIManagerComponent.java

@@ -89,6 +89,7 @@
 import org.wso2.carbon.apimgt.impl.notifier.ScopesNotifier;
 import org.wso2.carbon.apimgt.impl.notifier.SubscriptionsNotifier;
 import org.wso2.carbon.apimgt.impl.notifier.KeyTemplateNotifier;
+import org.wso2.carbon.apimgt.impl.notifier.MarketplaceAssistantApiPublisherNotifier;
 import org.wso2.carbon.apimgt.impl.observers.APIStatusObserverList;
 import org.wso2.carbon.apimgt.impl.observers.CommonConfigDeployer;
 import org.wso2.carbon.apimgt.impl.observers.KeyMgtConfigDeployer;
@@ -201,6 +202,8 @@
             String tenantDomain = PrivilegedCarbonContext.getThreadLocalCarbonContext().getTenantDomain();
             configuration.load(filePath);
 
+            boolean isMarketplaceAssistantEnabled = configuration.getMarketplaceAssistantConfigurationDto().isEnabled();
+
             //Registering Notifiers
             bundleContext.registerService(Notifier.class.getName(), new SubscriptionsNotifier(), null);
             bundleContext.registerService(Notifier.class.getName(), new ApisNotifier(), null);
@@ -216,6 +219,9 @@
             bundleContext.registerService(Notifier.class.getName(),new KeyTemplateNotifier(), null);
             bundleContext.registerService(Notifier.class.getName(), new CorrelationConfigNotifier(), null);
             bundleContext.registerService(Notifier.class.getName(), new GatewayPolicyNotifier(), null);
+            if (isMarketplaceAssistantEnabled) {
+                bundleContext.registerService(Notifier.class.getName(), new MarketplaceAssistantApiPublisherNotifier(), null);
+            }
             APIManagerConfigurationServiceImpl configurationService = new APIManagerConfigurationServiceImpl(configuration);
             ServiceReferenceHolder.getInstance().setAPIManagerConfigurationService(configurationService);
             APIMgtDBUtil.initialize();