#pragma once

#define IMAGE_STORE_SIZE 256

#define MIN_TILE_SIZE 8
#define MAX_TILE_SIZE 32

#include "ofMain.h"
#include "ofxJSONElement.h"

long ofToLong(const string& intString);

class imageStore : public ofThread{

	public:

		float interval; //time between refreshes in seconds

		std::string instagram_url;
		ofxJSONElement response;
		std::map<std::string,ofImage> images;
		deque<std::string> to_update;

		imageStore(){
			instagram_url = "https://api.instagram.com/v1/tags/tycleeson/media/recent?client_id=c1d74d701fdf4ddd9f8d30ee9e8f944b";
			interval=5.00f;
		}

		void set_interval(float _interval){
			interval=_interval;
		}

		void start(){
            startThread(true, false);   // blocking, verbose
        }

        void stop(){
            stopThread();
        }

		//--------------------------
		void threadedFunction(){

			//1st get the pre-existing images

			ofDirectory image_path(ofToString(IMAGE_STORE_SIZE)+"/");
			cerr<<"image path: "<<image_path.getAbsolutePath()<<endl;
			if (image_path.exists()){
				image_path.listDir();
				cerr<<"image path found, "<<image_path.size()<<" images"<<endl;
				for (int i=0;i<image_path.size();i++){
					ofImage img;
					img.setUseTexture(false);
					img.loadImage(ofToString(IMAGE_STORE_SIZE)+"/"+image_path.getFiles()[i].getFileName());
					img.resize(MAX_TILE_SIZE,MAX_TILE_SIZE);
					if( lock() ){
						images[image_path.getFiles()[i].getBaseName()]=img;
						to_update.push_back(image_path.getFiles()[i].getBaseName());
						unlock();
					}
				}
			}
			else {
				cerr<<"creating image path"<<endl;
				image_path.create();
			}

			cout  << "Api: " << instagram_url<<endl;

			while( isThreadRunning() != 0 ){

				cout<<"."<<std::flush;
			
				if (!response.open(instagram_url)) {
					cout  << "Failed to parse JSON\n" << endl;
				}
				else {	//int numImages = MIN(5,response["data"].size());
					
					
					for(int i=0; i< response["data"].size(); i++) {
						//cout  << "response " <<response["data"][i]["caption"]["id"].asString()<< endl;
						
						if (images.find(response["data"][i]["caption"]["id"].asString())==images.end()){
							std::string url = response["data"][i]["images"]["standard_resolution"]["url"].asString();
							std::string id = response["data"][i]["caption"]["id"].asString();
							cout<<"fetching "<<id<<":"<<instagram_url<<endl;
							
							ofImage img;
							img.setUseTexture(false);
							img.loadImage(url);
							img.resize(IMAGE_STORE_SIZE,IMAGE_STORE_SIZE);
							img.saveImage(ofToString(IMAGE_STORE_SIZE)+"/"+id+".png");
							img.resize(MAX_TILE_SIZE,MAX_TILE_SIZE);
							if( lock() ){
								images[id]=img;
								to_update.push_back(id);
								unlock();
							}
						}
					}			
				}
				ofSleepMillis(interval * 1000);
			}
		}

		//--------------------------
		void draw(){
			if( lock() ){
				if (to_update.size()){
					std::string im = to_update.front();

					const ofPixels& pix = images[im].getPixelsRef();
					images[im].getTextureReference().allocate(
							 pix.getWidth()
							,pix.getHeight()
							,ofGetGlInternalFormat(pix)
					);
					
					images[im].setUseTexture(true);
					images[im].update();

					to_update.pop_front();

					int drawcount=0;
					for (map<string,ofImage>::iterator i=images.begin();i!=images.end();++i){
						if(i->second.isUsingTexture()){
							drawcount++;
						}
					}
					//cout<<"loaded "<<im<<" "<<ofToLong(im)%(long)(ofGetWidth()-images[im].getWidth()+1)<<","<<ofToLong(im)%(long)(ofGetHeight()-images[im].getHeight()+1)<<endl;
				}
				for (map<string,ofImage>::iterator i=images.begin();i!=images.end();++i){
					if(i->second.isUsingTexture()){
						i->second.draw(ofToLong(i->first)%(long)(ofGetWidth()-i->second.getWidth()+1),ofToLong(i->first)%(long)(ofGetHeight()-i->second.getHeight()+1));
					}
				}
				unlock();
			}
		}


};