Amazon Pricing Notifier

// Code for particle servo control

/*
 * Project Ambient
 * Description: Detects amazon price changes and opens a treasure box
 * Author: Samuel Lee, Ryan Stinebaugh, Kami Chin
 * Date:
 */

int servo_pin_1 = D0;
int servo_pin_2 = D1 ;
int device_on = HIGH ;
int box_open = 0 ; //should be closed in natural state
Servo myServo1 ;
Servo myServo2 ;


//function will be exposed to cloud. args not used
//called when wave is to be performed
int servoWave(String args) {
  //perform wave
  if(device_on == LOW) {
    return 0 ;
  }
  const int leftAngle = 0 ;
  const int rightAngle = 100 ;
  const int delayPeriod = 500 ;
  int numWaves = 4 ;
  for(int w =0; w < numWaves ; w++) {
    if(w%2) {
      //odd iteration
      myServo1.write(leftAngle)  ;
    }
    else {
      myServo1.write(rightAngle) ;
    }
    delay(delayPeriod) ;
  }
  //reset position
  myServo1.write(leftAngle) ;
  delay(delayPeriod) ;
  return 1;
}

//called asynchronously
int servoOpenBox(String args) {
  if(device_on == LOW || box_open) {
    return 0 ;
  }
  const int closedAngle = 0 ;
  const int openAngle = 100 ;
  const int delayPeriod = 3000 ;
  //assumes closed
  myServo1.write(openAngle) ;
  myServo2.write(openAngle) ;
  box_open = 1 ; //signal box is open
  delay(delayPeriod) ;
  //reset position
  myServo1.write(closedAngle) ;
  myServo2.write(closedAngle) ;
  box_open = 0 ; //closed box
  return 1;

}


// setup() runs once, when the device is first turned on.
void setup() {
  // Put initialization like pinMode and begin functions here.
  myServo1.attach(servo_pin_1);
  myServo2.attach(servo_pin_2);
  //ensure it's at 0 position
  myServo1.write(0) ;
  myServo2.write(0) ;
  //test servo
  myServo1.write(100) ;
  myServo2.write(100) ;
  delay(500) ;
  myServo1.write(0) ;
  myServo2.write(0) ;
  Particle.function("servoWave", servoWave) ;
  Particle.function("servoOpenBox", servoOpenBox) ;

}

//main logic controlled by external server
void loop() {
  //TODO add logic to change device_on based on digital input
}

from amazon.api import AmazonAPI
import time,  threading
import requests

access_key = "YOUR AMAZON PRODUCT ADVERTISING ACCESS KEY" 
secret_key = "YOUR AMAZON PRODUCT ADVERTISING SECRET KEY" 
associate_id = "YOUR AMAZON PRODUCT ADVERTISING ASSOCIATE ID"
amazon = AmazonAPI(access_key, secret_key, associate_id, region="US")

device_id = "YOUR PARTICLE DEVICE ID"
particle_access_token = "YOUR PARTICLE ACCESS TOKEN"
check_freq = 60 # in seconds
item_id = 'AMAZON PRODUCT ID FOR DESIRED PRODUCT TO PURCHASE'
item_price = 59.99 # set this to the current market price for the item 
target_price = 47.99 # set this to desired purchase price



def servoOpenBox():
	global device_id, particle_access_token
	url = "https://api.particle.io/v1/devices/{}/{}".format(device_id, "servoOpenBox")
	res = requests.post(url, data={"arg":"", "access_token":particle_access_token})
	if res.status_code != requests.codes.ok:
		print "Bad POST request. Error {}".format(res.status_code)
	else:
		# print  "Good Request"
		print ""  


def alertPriceDrop():
	if item_price <= target_price:
		# servoWave()
		print "Price Dropped Target = {} Current = {}".format(target_price, item_price)
		servoOpenBox()

def update_price():
	global check_freq, item_price, item_id, amazon
	print time.ctime()
	item = amazon.lookup(ItemId=item_id)
	item_price = float(item.price_and_currency[0])
	alertPriceDrop()


# for simulation purposes
def simulate_update_price():
	global item_price, target_price
	# simulate_check_freq = 10 #in seconds
	high_price = 59.99
	low_price = target_price
	if item_price <= low_price:
		item_price = high_price
	else:
		item_price = low_price
	alertPriceDrop() 
	# threading.Timer(simulate_check_freq, simulate_update_price).start()


class UpdateThread(threading.Thread):
	def __init__(self, update_func, period):
		threading.Thread.__init__(self)
		self.update = update_func
		self.period = period
		self.event = threading.Event()

	def stop(self):
		self.event.set()

	def run(self):
		while not self.event.wait(self.period):
			self.update()


def setup():
	global amazon, item_id
	item = amazon.lookup(ItemId=item_id)
	# print "{}".format("abc")
	print "Name = {}, price = {}".format(item.title, item.price_and_currency)
	item_price = float(item.price_and_currency[0])
	print item_price


def run():
	setup()
	updateThread = UpdateThread(update_price, check_freq)
	updateThread.start()
	while 1:
		cmd = raw_input()
		if cmd == "stop":
			print "stopping..."
			updateThread.stop()
			break
	return




if __name__ == "__main__":
	run()