#pragma once


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

long ofToLong(const string& intString);

class instagramLoader : public ofThread{

	public:

		float interval; //time between refreshes in seconds

	    int count;  // threaded fucntions that share data need to use lock (mutex)
	                // and unlock in order to write to that data
	                // otherwise it's possible to get crashes.
	                //
	                // also no opengl specific stuff will work in a thread...
	                // threads can't create textures, or draw stuff on the screen
	                // since opengl is single thread safe

		//--------------------------
		std::string url;
		ofxJSONElement response;
		std::map<std::string,ofImage> images;
		deque<std::string> to_update;

		instagramLoader(){
			count = 0;
			url = "https://api.instagram.com/v1/tags/tycleeson/media/recent?client_id=c1d74d701fdf4ddd9f8d30ee9e8f944b";
		}

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

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

        void stop(){
            stopThread();
        }

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

			cout  << "Api: " << url<<endl;

			while( isThreadRunning() != 0 ){

				cout<<"."<<std::flush;
			
				if (!response.open(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<<":"<<url<<endl;
							
							ofImage img;
							img.setUseTexture(false);
							img.loadImage(url);
							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();
			}
		}


};

class exampleApp : public ofBaseApp {
public:
    void setup();
    void update();
    void draw();
    instagramLoader loader;
    
};