andrewkim316

const StopLimitOrderIntentHandler = {
  // Triggers when user wants to execute a stop limit order
  canHandle(handlerInput) {
    return Alexa.getRequestType(handlerInput.requestEnvelope) === 'IntentRequest' 
      && Alexa.getIntentName(handlerInput.requestEnvelope) === 'StopLimitOrderIntent';
  },
  async handle(handlerInput) {
    // Get user inputs and declare the Alpaca object
    const slots = handlerInput.requestEnvelope.request.intent.slots;
    const api = new Alpaca({

andrewkim316

const Alexa = require('ask-sdk-core');
const Alpaca = require('@alpacahq/alpaca-trade-api');

const keyId = "KEY_ID_HERE";
const secretKey = "SECRET_KEY_HERE";

andrewkim316

    asyncio.run(sub_order(api, request, args))
    return ""


# Run on local port 3000
if __name__ == "__main__":
    app.run(port=3000)

andrewkim316

    async def sub_order(api, request, args):
        order_type = args[0].lower()
        if order_type == "market":
            if len(args) < 5:
                reply_private(request, WRONG_NUM_ARGS)
                return
            try:
                side = args[1]
                qty = args[2]
                symbol = args[3].upper()

andrewkim316

@app.route("/order", methods=["POST"])
def order_handler():
    '''Execute an order.  Must contain 5 arguments: type, symbol,
       quantity, side, time in force
    '''
    args = request.form.get("text").split(" ")
    if len(args) == 0:
        return WRONG_NUM_ARGS

andrewkim316

from flask import Flask, request
import alpaca_trade_api as tradeapi
import requests
import asyncio
import json
import os


# Constants used throughout the script (names are self-explanatory)
WRONG_NUM_ARGS = "ERROR: Incorrect amount of args.  Action did not complete."

andrewkim316

const MarketOrderIntentHandler = {
  // Triggers when user invokes a market order
  canHandle(handlerInput) {
    return Alexa.getRequestType(handlerInput.requestEnvelope) === 'IntentRequest' 
      && Alexa.getIntentName(handlerInput.requestEnvelope) === 'MarketOrderIntent';
  },
  async handle(handlerInput) {
    // Get user inputs and declare the Alpaca object
    const slots = handlerInput.requestEnvelope.request.intent.slots;
    const api = new Alpaca({

andrewkim316

# Stream listeners


@conn.on(r'trade_updates')
async def trade_updates_handler(conn, chan, data):
    if data.event == "new":
        return ""
    elif data.event == "fill" or data.event == "partial_fill":
        text = f'*Event*: {data.event}, {data.order["type"]} order of | {data.order["side"]} {data.order["qty"]} {data.order["symbol"]} {data.order["time_in_force"]} | {data.event} at {data.price}'
    else:

andrewkim316

# Unsubsribe to streaming channel(s).  Must contain one or more arguments
# representing streams you want to disconnect to.


@app.route("/unsubscribe_streaming", methods=["POST"])
def unsubscribe_handler():
    args = request.form.get("text").split(" ")
    if len(args) == 1 and args[0].strip() == "":
        return BAD_ARGS
    try:

andrewkim316

# Subscribe to streaming channel(s).  Must contain one or more arguments
# representing streams you want to connect to.


@app.route("/subscribe_streaming", methods=["POST"])
def stream_data_handler():
    args = request.form.get("text").split(" ")
    if len(args) == 1 and args[0].strip() == "":
        return BAD_ARGS
    try: