andrewkim316

# Clears positions or orders.  Must contain 1 argument: positions or orders


@app.route("/clear", methods=["POST"])
def clear_handler():
    args = request.form.get("text").split(" ")
    if(len(args) == 0):
        return WRONG_NUM_ARGS
    if(args[0] == "positions"):
        async def sub_clear_positions(api, request):

andrewkim316

# Gets basic account info.  Takes no arguments.


@app.route("/account_info", methods=["POST"])
def account_info_handler():
    args = request.form.get("text").split(" ")
    if(len(args) != 0 and not (len(args) == 1 and args[0].strip() == "")):
        return WRONG_NUM_ARGS
    try:
        account = api.get_account()

andrewkim316

# Gets Polygon price specified stock symbols.  Must include one or more
# arguments representing stock symbols. Must have live account to access.


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

andrewkim316

# Cancels most recent order.  Takes no arguments.


@app.route("/cancel_recent_order", methods=["POST"])
def cancel_recent_order_handler():
    args = request.form.get("text").split(" ")
    if(len(args) != 0 and not (len(args) == 1 and args[0].strip() == "")):
        return WRONG_NUM_ARGS
    try:
        orders = api.list_orders(status="open", limit=1)

andrewkim316

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

# Constants used throughout the script (names are self-explanatory). 
# Must hard code SLACK TOKEN, KEY_ID, SECRET_KEY, channel
WRONG_NUM_ARGS = "ERROR: Incorrect amount of args.  Action did not complete."
BAD_ARGS = "ERROR: Request error.  Action did not complete."

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:

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

# 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

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

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."