Implement Alexa Shopping Actions in Your Skill

/**
 * Handler for RecommendAndAddToCart intent.
 */
const RecommendAndAddToCartHandler = {
	canHandle(handlerInput) {
		const request = handlerInput.requestEnvelope.request;
		return request.type === 'IntentRequest' &&
			(request.intent.name === 'RecommendAndAddToCart');
	},
	handle(handlerInput) {
		console.log("AmazoRecommendAndAddToCartreceived.");

		const speechText = "<Product intro>" +
			" Would you like to add this to your cart on Amazon?"

		return handlerInput.responseBuilder
			.speak(speechText)
			.reprompt(speechText)
			.getResponse();
	}
};

/**
 * Handler for YesIntent and NoIntent.
 */
const YesAndNoIntentHandler = {
	canHandle(handlerInput) {
		const request = handlerInput.requestEnvelope.request;
		return request.type === 'IntentRequest' &&
			(request.intent.name === 'AMAZON.YesIntent' ||
				request.intent.name === 'AMAZON.NoIntent');
	},
	handle(handlerInput) {
		const intentName = handlerInput.requestEnvelope.request.intent.name;
		console.log("User said : " + intentName);

		if (intentName === 'AMAZON.YesIntent') {
			var actionText = "Staging item with Amazon"
			let actionTask = {
				'type': 'Connections.StartConnection',
				'uri': 'connection://AMAZON.AddToShoppingCart/1',
				'input': {
					'products': [{
						'asin': 'ASN1'
					}]
				},
				'token': 'AddToShoppingCartToken'
			};

			return handlerInput.responseBuilder
				.speak(actionText)
				.addDirective(actionTask)
				.getResponse();
		}

		const speechText = "All right. Please come back if you need more product recommendations."

		return handlerInput.responseBuilder
			.speak(speechText)
			.getResponse();
	}
};

/**
 * Handler for SessionResumedRequest.
 */
const SessionResumedRequestHandler = {
    canHandle(handlerInput) {
        const request = handlerInput.requestEnvelope.request;
        return request.type === 'SessionResumedRequest';
    },
    handle(handlerInput) {

        // Session attributes and ID are same as previous IntentRequest
        const sessionAttributes = handlerInput.attributesManager.getSessionAttributes();
        console.log("sessionAttributes : " + JSON.stringify(sessionAttributes));
        const token = handlerInput.requestEnvelope.request.cause.token;

        let request = handlerInput.requestEnvelope.request;
        let speechText = "Sorry, I had trouble doing what you asked. Please try again.";

        if (request.cause) {
             const token = request.cause.token;
             const status = request.cause.status;
             const code = status.code;
             const message = status.message;
             const payload = request.cause.result;

             console.info(`[Shopping Response] ${JSON.stringify(request)}`);
             console.info(`[INFO] Shopping Action Result: Code - ${code}, Message - ${message}, Payload - ${payload}`);

             switch(code) {
                 case '200':
                     if (typeof payload !== "undefined") {
                         if (payload.code === "AlexaShopping.RetryLaterError") {
                             speechText =  "Looks like there was an issue. Let's get back to the skill.";
                         } else if (payload.code === "AlexaShopping.AssociatesInvalidInputError" && token === "AddToShoppingCartToken"){
                             console.info(`[INFO] Shopping Action had an issue while performing Associates attribution. ${payload.message}`);
                             speechText = "Thank you for shopping with Alexa.";
                         } else {
                             speechText = "I'm sorry, shopping indicated an issue while performing your request. Please try again later.";
                             console.info(`[INFO] Shopping Action had an issue while performing the request. ${payload.message}`);
                        }
                    } else if (token === "AddToShoppingCartToken") {
                        console.info(`[INFO] Shopping Action: Add to cart action was a success for ${token}.`);
                        speechText = "Thank you for shopping with Alexa.";
                    }
            break;
            default :
                console.info(`[INFO] Shopping Action: There was a problem performing the shopping action.`);
                speechText = "There was a problem adding the item to your cart.";
            }
        }

        return handlerInput.responseBuilder.speak(speechText).getResponse();
    },
};

/**
 * Handler for RecommendAndAddToList intent.
 */
const RecommendAndAddToListHandler = {
	canHandle(handlerInput) {
		const request = handlerInput.requestEnvelope.request;
		return request.type === 'IntentRequest' &&
			(request.intent.name === 'RecommendAndAddToList');
	},
	handle(handlerInput) {
		console.log("AmazoRecommendAndAddToList received.");

		const speechText = "<Product intro>" +
			" Would you like to add this to your wish list on Amazon?"

		return handlerInput.responseBuilder
			.speak(speechText)
			.reprompt(speechText)
			.getResponse();
	}
};

/**
 * Handler for YesIntent and NoIntent.
 */
const YesAndNoIntentHandler = {
	canHandle(handlerInput) {
		const request = handlerInput.requestEnvelope.request;
		return request.type === 'IntentRequest' &&
			(request.intent.name === 'AMAZON.YesIntent' ||
				request.intent.name === 'AMAZON.NoIntent');
	},
	handle(handlerInput) {
		const intentName = handlerInput.requestEnvelope.request.intent.name;
		console.log("User said : " + intentName);

		if (intentName === 'AMAZON.YesIntent') {
			var actionText = "Staging item with Amazon"
			let actionTask = {
				'type': 'Connections.StartConnection',
				'uri': 'connection://AMAZON.AddToList/1',
				'input': {
					'products': [{
						'asin': 'ASN1'
					}],
					"listType": "WISHLIST"
				},
				'token': 'AddToListToken'
			};

			return handlerInput.responseBuilder
				.speak(actionText)
				.addDirective(actionTask)
				.getResponse();
		}

		const speechText = "All right. Please come back if you need more product recommendations."

		return handlerInput.responseBuilder
			.speak(speechText)
			.getResponse();
	}
};

/**
 * Handler for SessionResumedRequest.
 */
const SessionResumedRequestHandler = {
    canHandle(handlerInput) {
        const request = handlerInput.requestEnvelope.request;
        return request.type === 'SessionResumedRequest';
    },
    handle(handlerInput) {

        // Session attributes and ID are same as previous IntentRequest
        const sessionAttributes = handlerInput.attributesManager.getSessionAttributes();
        console.log("sessionAttributes : " + JSON.stringify(sessionAttributes));
        const token = handlerInput.requestEnvelope.request.cause.token;

        let request = handlerInput.requestEnvelope.request;
        let speechText = "Sorry, I had trouble doing what you asked. Please try again.";

        if (request.cause) {
             const token = request.cause.token;
             const status = request.cause.status;
             const code = status.code;
             const message = status.message;
             const payload = request.cause.result;

             console.info(`[Add to List Response] ${JSON.stringify(request)}`);
             console.info(`[INFO] Shopping Action Result: Code - ${code}, Message - ${message}, Payload - ${payload}`);

             switch(code) {
                 case '200':
                     if (typeof payload !== "undefined") {
                         if (payload.code === "AlexaShopping.RetryLaterError") {
                             speechText =  "Looks like there was an issue. Let's get back to the skill.";
                         } else {
                             speechText = "I'm sorry, shopping indicated an issue while performing your request. Please try again later.";
                             console.info(`[INFO] Shopping Action had an issue while performing the request. ${payload.message}`);
                        }
                    } else if (token === "AddToListToken") {
                        console.info(`[INFO] Shopping Action: Add to list action was a success for ${token}.`);
                        speechText = "Thank you for shopping with Alexa.";
                    }
            break;
            default :
                console.info(`[INFO] Shopping Action: There was a problem performing the shopping action.`);
                speechText = "There was a problem adding the item to your  list.";
            }
        }

        return handlerInput.responseBuilder.speak(speechText).getResponse();
    },
};

/**
 * Handler for RecommendAndShopForProducts intent.
 */
const RecommendAndShopForProductsHandler = {
    canHandle(handlerInput) {
        const request = handlerInput.requestEnvelope.request;
        return request.type === 'IntentRequest'
            && (request.intent.name === 'RecommendAndShopForProducts');
    },
    handle(handlerInput) {
        console.log("RecommendAndShopForProducts received.");

        const speechText = "<Product intro>" +
        " Would you like to know how to purchase this on Amazon?"

        return handlerInput.responseBuilder
            .speak(speechText)
            .reprompt(speechText)
            .getResponse();
        }
};

/**
 * Handler for YesIntent and NoIntent.
 */
const YesAndNoIntentHandler = {
    canHandle(handlerInput) {
        const request = handlerInput.requestEnvelope.request;
        return request.type === 'IntentRequest'
            && (request.intent.name === 'AMAZON.YesIntent'
                || request.intent.name === 'AMAZON.NoIntent');
    },
    handle(handlerInput) {
        const intentName = handlerInput.requestEnvelope.request.intent.name;
        console.log("User said : " + intentName);

        if (intentName === 'AMAZON.YesIntent') {
            var actionText = "Staging item with Amazon"
            let actionTask = {
              'type': 'Connections.StartConnection',
              'uri': 'connection://AMAZON.BuyShoppingProducts/1',
              'input': {
                   'products' : [
                     {
                       'asin' : 'ASN1'
                     }
                   ]
                },
              'token': 'PurchaseProductToken'
          };

            return handlerInput.responseBuilder
            .speak(actionText)
            .addDirective(actionTask)
            .getResponse();
        }

        const speechText = "All right. Please come back if " +
                              "you need more product recommendations."

        return handlerInput.responseBuilder
            .speak(speechText)
            .getResponse();
        }
};

/**
 * Handler for SessionResumedRequest.
 */
const SessionResumedRequestHandler = {
	canHandle(handlerInput) {
		const request = handlerInput.requestEnvelope.request;
		return request.type === 'SessionResumedRequest';
	},
	handle(handlerInput) {

		// Session attributes and ID are same as previous IntentRequest
		const sessionAttributes = handlerInput.attributesManager.getSessionAttributes();
		console.log("sessionAttributes : " + JSON.stringify(sessionAttributes));
		const token = handlerInput.requestEnvelope.request.cause.token;

		let request = handlerInput.requestEnvelope.request;
		let speechText = "Sorry, I had trouble doing what you asked. Please try again.";

		if (request.cause) {
			const token = request.cause.token;
			const status = request.cause.status;
			const code = status.code;
			const message = status.message;
			const payload = request.cause.result;

			console.info(`[Shopping Response] ${JSON.stringify(request)}`);
			console.info(`[INFO] Shopping Action Result: Code - ${code}, Message - ${message}, Payload - ${payload}`);

			switch (code) {
				case '200':
					if (typeof payload !== "undefined") {
						if (payload.code === "AlexaShopping.RetryLaterError") {
							speechText = "Looks like there was an issue. Let's get back to the skill.";
						} else if (payload.code === "AlexaShopping.AssociatesInvalidInputError" && token === "PurchaseProductToken") {
							console.info(`[INFO] Shopping Action had an issue while performing Associates attribution. ${payload.message}`);
							speechText = "Thank you for shopping with Alexa.";
						} else {
							speechText = "I'm sorry, shopping indicated an issue while performing your request. Please try again later.";
							console.info(`[INFO] Shopping Action had an issue while performing the request. ${payload.message}`);
						}
					} else if (token === "PurchaseProductToken") {
						console.info(`[INFO] Shopping Action: Buy action was a success for ${token}.`);
						speechText = "Thank you for shopping with Alexa.";
					}
					break;
				default:
					console.info(`[INFO] Shopping Action: There was a problem performing the shopping action.`);
					speechText = "I'm sorry, shopping indicated an issue while performing your request. Please try again later.";
			}
		}

		return handlerInput.responseBuilder
			.speak(speechText)
			.getResponse();
	},
};

/**
* Handler for RecommendProducts intent.
*/
const RecommendProductsHandler = {
     canHandle(handlerInput) {
         const request = handlerInput.requestEnvelope.request;
         return request.type === 'IntentRequest'
             && (request.intent.name === 'RecommendProducts');
     },
     handle(handlerInput) {
         console.log("RecommendProducts received.");

         const speechText = "<Product intro>" +
         " Would you like hear more?"

         return handlerInput.responseBuilder
             .speak(speechText)
             .reprompt(speechText)
             .getResponse();
         }
};

/**
* Handler for YesIntent and NoIntent.
*/
const YesAndNoIntentHandler = {
     canHandle(handlerInput) {
         const request = handlerInput.requestEnvelope.request;
         return request.type === 'IntentRequest'
             && (request.intent.name === 'AMAZON.YesIntent'
                 || request.intent.name === 'AMAZON.NoIntent');
     },
     handle(handlerInput) {
         const intentName = handlerInput.requestEnvelope.request.intent.name;
         console.log("User said : " + intentName);

         if (intentName === 'AMAZON.YesIntent') {
             var actionText = "Transferring product recommendations to Alexa"
             let actionTask = {
               'type': 'Connections.StartConnection',
               'uri': 'connection://AMAZON.RecommendShoppingProducts/1',
               'input': {
                    'products' : [
                      {
                        'asin' : 'ASN1'
                    },
                    {
                      'asin' : 'ASN2'
                    }
                  ]
                 },
               'token': 'RecommendProducts',
               'onCompletion': 'SEND_ERRORS_ONLY'
           };

             return handlerInput.responseBuilder
             .speak(actionText)
             .addDirective(actionTask)
             .withShouldEndSession(true)
             .getResponse();
         }

         const speechText = "All right. Please come back if you need more product recommendations."

         return handlerInput.responseBuilder
             .speak(speechText)
             .getResponse();
         }
};