#include"define.h"
#include<iostream>
#include"cinterface.h"
#include<malloc.h>
#include<mutex>
#include<queue>
#include<Windows.h>
void free_all(void* str) {
    delete str;
}
void freewstringlist(wchar_t** strlist, int num) {
    for (int i = 0; i < num; i++) {
        delete strlist[i];
    }
    delete strlist;
}
void freestringlist(char** strlist, int num) {
    for (int i = 0; i < num; i++) {
        delete strlist[i];
    }
    delete strlist;
}
 
int* vecint2c(std::vector<int>& vs) {
    int* argv = new int [vs.size() + 1];

    for (size_t i = 0; i < vs.size(); i++) {
        argv[i] = vs[i]; 
    }
    return argv;
}

char** vecstr2c(std::vector<std::string>& vs) {
    char** argv = new char* [vs.size() + 1];

    for (size_t i = 0; i < vs.size(); i++) {
        argv[i] = new char[vs[i].size() + 1];
        strcpy_s(argv[i], vs[i].size()+1, vs[i].c_str());
        argv[i][vs[i].size()] = 0;
    }
    return argv;
}


wchar_t** vecwstr2c(std::vector<std::wstring>& vs) {
    wchar_t** argv = new wchar_t* [vs.size() + 1];

    for (size_t i = 0; i < vs.size(); i++) {
        argv[i] = new wchar_t[vs[i].size() + 1];
        wcscpy_s(argv[i], vs[i].size()+1, vs[i].c_str());
        argv[i][vs[i].size()] = 0;
    }
    return argv;
}

struct MemoryStruct {
  char *memory;
  size_t size;
};
size_t WriteMemoryCallback(void *contents, size_t size, size_t nmemb, void *userp){
  size_t realsize = size * nmemb;
  struct MemoryStruct *mem = (struct MemoryStruct *)userp;

  char *ptr;
  if(mem->memory)
    ptr=(char*)realloc(mem->memory, mem->size + realsize + 1);
  else
    ptr=(char*)malloc( mem->size + realsize + 1);
  if(!ptr) {
    /* out of memory! */
    printf("not enough memory (realloc returned NULL)\n");
    return 0;
  }

  mem->memory = ptr;
  memcpy(&(mem->memory[mem->size]), contents, realsize);
  mem->size += realsize;
  mem->memory[mem->size] = 0;

  return realsize;
}
void c_free(void* ptr){
    free(ptr);
}

class lockedqueue{
  std::mutex lock;
  std::queue<std::string>data;
  HANDLE hsema;
  public:
  lockedqueue(){
    hsema=CreateSemaphore(NULL,0,65535,NULL);
  }
  ~lockedqueue(){
    CloseHandle(hsema);
  }
  void push(std::string&& _){
    std::lock_guard _l(lock);
    data.push(std::move(_));
    ReleaseSemaphore(hsema,1,NULL);
  }
  std::string pop(){
    WaitForSingleObject(hsema,INFINITE);
    std::lock_guard _l(lock);
    auto _=data.front();
    data.pop();
    return _;
  }
  bool empty(){
    std::lock_guard _l(lock);
    return data.empty();
  }
};
void* lockedqueuecreate(){
  return new lockedqueue();
}
void lockedqueuefree(void* q){
  delete reinterpret_cast<lockedqueue*>(q);
}
void* lockedqueueget(void* q,size_t* l){
  auto data=reinterpret_cast<lockedqueue*>(q)->pop();
  auto datastatic=new char[data.size()];
  memcpy(datastatic,data.data(),data.size());
  *l=data.size();
  return datastatic;
}
void lockedqueuepush(void* q,size_t l,void*ptr){
  reinterpret_cast<lockedqueue*>(q)->push(std::string((char*)ptr,l));
}
bool lockedqueueempty(void* q){
  return reinterpret_cast<lockedqueue*>(q)->empty();
}

size_t WriteMemoryToQueue(void *contents, size_t size, size_t nmemb, void *userp){
  size_t realsize = size * nmemb;
  auto queue=reinterpret_cast<lockedqueue*>(userp);
  queue->push(std::string((char*)contents,realsize));
  return realsize;
}