.pragma library
.import QtQuick.LocalStorage 2.0 as Sql
.import "qrc:/js/helper.js" as Helperjs

function requestFriends(login,database,rootwindow,callback){
//    return array of friends
   Helperjs.friendicaRequest(login,"/api/statuses/friends", rootwindow,function (obj){
       var friends=JSON.parse(obj);
          for (var i=0;i<friends.length;i++){ friends[i].isFriend=1}
       callback(friends)
});
}

function requestGroups(login,database,rootwindow,callback){
   // retrieve, save and return groups, currently not implemented
Helperjs.friendicaRequest(login,"/api/friendica/group_show",rootwindow, function (obj){
       var groups=JSON.parse(obj);
       for (var i=0;i<groups.length;i++){
          updateGroupInDB(login,database,groups[i])
        }
   Helperjs.readData(database,"groups",callback)
});}

function getFriendsTimeline(login,database,contacts,rootwindow,callback){// retrieve and return timeline since last news, return contacts which are not friends for update (friends can be updated in Friendstab)
    var db=Sql.LocalStorage.openDatabaseSync(database[0],database[1],database[2],database[3]);
    var parameter = "";
    db.transaction( function(tx) {
            var result = tx.executeSql('SELECT status_id from news WHERE username="'+login.username+'" ORDER BY status_id  DESC LIMIT 1'); // check for last news id
            try{parameter="&since_id="+result.rows.item(0).status_id;}catch(e){};})
            var newContacts=[];
            Helperjs.friendicaRequest(login,"/api/statuses/friends_timeline"+parameter, rootwindow,function (obj){
                  var news=JSON.parse(obj);
                 for (var i=0;i<news.length;i++){
                     if(contacts.indexOf(news[i].user.id)==-1 &&  !(inArray(newContacts,"id",news[i].user.id))){
                        news[i].user.isFriend=0;
                         newContacts.push(news[i].user);
                  }}
    callback(news,newContacts)
})}

function storeNews(login,database,news,rootwindow,callback){
// save news after contacts download, call next function
    var db=Sql.LocalStorage.openDatabaseSync(database[0],database[1],database[2],database[3]);
    for (var i=0;i<news.length;i++){
                    var ausdruck=news[i];
                     print('store news data for ' + news[i].id);
                    db.transaction( function(tx) {
                        var result = tx.executeSql('SELECT * from news where status_id = "'+news[i].id+'"'); // check for news id
                         if(result.rows.length === 1) {// use update
                             print(news[i].id +' exists, update it')
                            result = tx.executeSql('UPDATE news SET username="'+login.username+'", messagetype=0, text="'+Qt.btoa(news[i].text)+'", truncated="'+news[i].truncated+'", created_at="'+Date.parse(cleanDate(news[i].created_at))+'", in_reply_to_status_id="'+news[i].in_reply_to_status_id+'", source="'+news[i].source+'", status_id="'+news[i].id+'", in_reply_to_user_id="'+news[i].in_reply_to_user_id+'", geo="'+news[i].geo+'", favorited="'+news[i].favorited+'", uid="'+news[i].user.id+'", statusnet_html="'+Qt.btoa(news[i].status_html)+'", statusnet_conversation_id="'+news[i].statusnet_conversation_id+'", attachments="'+news[i].attachments+'" where status_id="'+news[i].status_id+'"');
                } else {// use insert
                            result = tx.executeSql('INSERT INTO news VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)', [login.username,0,Qt.btoa(news[i].text),news[i].truncated,Date.parse(cleanDate(news[i].created_at)), news[i].in_reply_to_status_id, news[i].source, news[i].id,news[i].in_reply_to_user_id,news[i].geo,news[i].favorited, news[i].user.id,Qt.btoa(news[i].statusnet_html),news[i].statusnet_conversation_id, news[i].attachments,0,0,0])}})

                  }
      getDirectMessage(login,database,rootwindow,callback)
}

function getDirectMessage(login,database,rootwindow,callback){
    var db=Sql.LocalStorage.openDatabaseSync(database[0],database[1],database[2],database[3]);
    Helperjs.friendicaRequest(login,"/api/direct_messages/all",rootwindow, function (obj){
        var messages=JSON.parse(obj);
       for (var i=0;i<messages.length;i++){
//           print('store message data for '+JSON.stringify(messages[i]));
            db.transaction( function(tx) {
             var result = tx.executeSql('SELECT * from news where status_id = "'+messages[i].id+'"'); // check for news id
             if(result.rows.length === 1) {// use update
                print(messages[i].id +' exists, update it')
                result = tx.executeSql('UPDATE news SET username="'+login.username+'", messagetype=1, text="'+Qt.btoa(messages[i].text)+'", created_at="'+Date.parse(cleanDate(messages[i].created_at))+'", in_reply_to_status_id="", source="Friendica", status_id="'+messages[i].id+'", in_reply_to_user_id="", geo="", favorited="", uid="'+messages[i].sender.id+'", statusnet_html="'+Qt.btoa(messages[i].text)+'", statusnet_conversation_id="", attachments="'+messages[i].attachments+'" where status_id="'+messages[i].status_id+'"');
            } else {// use insert
                result = tx.executeSql('INSERT INTO news VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)', [login.username,1,Qt.btoa(messages[i].text),0,Date.parse(cleanDate(messages[i].created_at)),, "Friendica", messages[i].id,,,, messages[i].sender.id,Qt.btoa(messages[i].text),,,0,0,0])}
            });
       }
   })
    getNotifications(login,database,rootwindow,callback)
}

function getNotifications(login,database,rootwindow,callback){
   Helperjs.friendicaRequest(login,"/api/friendica/notifications", rootwindow,function (obj){
        var messages=JSON.parse(obj);
       for (var i=0;i<messages.length;i++){
           var db=Sql.LocalStorage.openDatabaseSync(database[0],database[1],database[2],database[3]);
            //print('store message data for '+JSON.stringify(messages[i]));
            db.transaction( function(tx) {
             var result = tx.executeSql('SELECT * from news where status_id = "'+messages[i].id+'"'); // check for news id
             if(result.rows.length === 1) {// use update
                print(messages[i].id +' exists, update it')
                result = tx.executeSql('UPDATE news SET username="'+login.username+'", messagetype=1, text="'+Qt.btoa(messages[i].text)+'", truncated="'+messages[i].truncated+'", created_at="'+Date.parse(cleanDate(messages[i].created_at))+'", in_reply_to_status_id="", source="'+messages[i].source+'", status_id="'+messages[i].id+'", in_reply_to_user_id="", geo="'+messages[i].geo+'", favorited="", uid="'+messages[i].sender.id+'", statusnet_html="'+Qt.btoa(messages[i].text)+'", statusnet_conversation_id="", attachments="'+messages[i].attachments+'" where status_id="'+messages[i].status_id+'"');
            } else {// use insert
                result = tx.executeSql('INSERT INTO news VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)', [login.username,2,Qt.btoa(messages[i].msg_html),,Date.parse(cleanDate(messages[i].timestamp)),, messages[i].source, messages[i].id,,,, messages[i].sender.id,Qt.btoa(messages[i].msg_html),, messages[i].attachments],0,0,0)}});
       }
   })
   newsfromdb(database,login.username,callback)
}

function newsfromdb(database,username,callback,contact,stop_time){
// return news before stop_time (used by More button), in brackets of 20 entries, or by specified contact
var db=Sql.LocalStorage.openDatabaseSync(database[0],database[1],database[2],database[3]);
db.transaction( function(tx) {
     if (!stop_time){var stop="";
         try{var rs = tx.executeSql('select created_at from news WHERE username="'+username+'" ORDER BY created_at DESC LIMIT 1');
          stop="<="+rs.rows.item(0).created_at}catch(e){stop="<99999999999999"}}
     else{var stop="<"+stop_time}
     var contactfilter="";if(contact){contactfilter=" AND uid='"+contact+"'"}
   var newsrs=tx.executeSql('select * from news WHERE username="'+username+'" AND created_at'+stop+contactfilter+' ORDER BY created_at DESC LIMIT 20');
   var newsArray=[];
   for(var i = 0; i < newsrs.rows.length; i++) {
      newsArray.push(newsrs.rows.item(i));
      Helperjs.readData(database,"contacts",function(userdata){
          newsArray[i].user=userdata[0];
          },"id",newsArray[i].uid);
      if(newsArray[i].in_reply_to_user_id){
          Helperjs.readData(database,"contacts",function(replytodata){
            newsArray[i].reply_user=replytodata[0];
            },"id",newsArray[i].in_reply_to_user_id)
      }
    }
  callback(newsArray)});
}

function deleteNews(login,database,newsid,rootwindow,callback){
   Helperjs.friendicaRequest(login,"/api/statuses/destroy?id="+newsid, rootwindow,function (obj){
        var news=JSON.parse(obj);
        var db=Sql.LocalStorage.openDatabaseSync(database[0],database[1],database[2],database[3]);
        print('delete news data for ' + newsid);
         db.transaction( function(tx) {var result = tx.executeSql('DELETE from news where status_id ='+newsid); // delete news id
            Helperjs.showMessage("Delete",result,rootwindow)});
   })}

function retweetNews(login,database,newsid,rootwindow,callback){
   Helperjs.friendicaRequest(login,"/api/statuses/retweet?id="+newsid, rootwindow,function (obj){
        var answer=JSON.parse(obj);
        Helperjs.showMessage("Repost",answer,rootwindow);
   })}

function favorite(login,favorite,newsid,rootwindow){
// toggle favorites 
 if(favorite){  Helperjs.friendicaRequest(login,"/api/favorites/create?id="+newsid, rootwindow,function (obj){
        var news=JSON.parse(obj);
   })}
    else {Helperjs.friendicaRequest(login,"/api/favorites/destroy?id="+newsid, rootwindow,function (obj){
        var news=JSON.parse(obj);
   })}
}

function  likerequest(login,database,toggle,verb,newsid,rootwindow,callback){ // not tested
Helperjs.friendicaRequest(login,"/api/friendica/activity/"+verb+"?id="+newsid, rootwindow,function (obj){
         var likeReturn=JSON.parse(obj);
         if (likeReturn=="OK"){
            var db=Sql.LocalStorage.openDatabaseSync(database[0],database[1],database[2],database[3]);
            db.transaction( function(tx) {var result = tx.executeSql('UPDATE news SET '+verb+'d ='+toggle+' where status_id ='+newsid);
            callback();
   })}})
}

function like(login,database,toggle,verb,newsid,rootwindow,callback){
 if(verb=="like"&& toggle==1){
     likerequest(login,database,1,"like",newsid,rootwindow,callback);
     likerequest(login,database,0,"undislike",newsid,rootwindow);}
if(verb=="dislike"&& toggle==1){
     likerequest(login,database,1,"dislike",newsid,rootwindow,callback);
     likerequest(login,database,0,"unlike",newsid,rootwindow);}
if(toggle==0){
     likerequest(login,database,0,"un"+verb,newsid,rootwindow,callback);}
}

function attend(login,database,attend,newsid,rootwindow,callback){
        Helperjs.friendicaRequest(login,"/api/friendica/activity/attend"+attend+"?id="+newsid, rootwindow,function (obj){
            var attendReturn=JSON.parse(obj);
//            print("attend: "+obj);
            //if (attendReturn=="OK")
            {
                var db=Sql.LocalStorage.openDatabaseSync(database[0],database[1],database[2],database[3]);
                db.transaction( function(tx) {var result = tx.executeSql('UPDATE news SET attend="+attend+" where status_id ='+newsid);
                callback();
 })}})}

function requestConversation(login,database,newsid,rootwindow,callback){
    Helperjs.friendicaRequest(login,"/api/conversation/show?id="+newsid,rootwindow, function (obj){
   print(obj+JSON.stringify(obj));
       var news=JSON.parse(obj);
for (var i=0;i<news.length;i++){
    var db=Sql.LocalStorage.openDatabaseSync(database[0],database[1],database[2],database[3]);
    print('store news data for ' + news[i].id);
    db.transaction( function(tx) {
     var result = tx.executeSql('SELECT * from news where status_id = "'+news[i].id+'"'); // check for news id
     if(result.rows.length === 1) {// use update
        print(news[i].id +' exists, update it')
        result = tx.executeSql('UPDATE news SET username="'+login.username+'", messagetype=0, text="'+Qt.btoa(news[i].text)+'", truncated="'+news[i].truncated+'", created_at="'+Date.parse(cleanDate(news[i].created_at))+'", in_reply_to_status_id="'+news[i].in_reply_to_status_id+'", source="'+news[i].source+'", status_id="'+news[i].id+'", in_reply_to_user_id="'+news[i].in_reply_to_user_id+'", geo="'+news[i].geo+'", favorited="'+news[i].favorited+'", uid="'+news[i].user.id+'", statusnet_html="'+Qt.btoa(news[i].status_html)+'", statusnet_conversation_id="'+news[i].statusnet_conversation_id+'", attachments="'+news[i].attachments+'" where status_id="'+news[i].status_id+'"');
    } else {// use insert
        result = tx.executeSql('INSERT INTO news VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)', [login.username,0,Qt.btoa(news[i].text),news[i].truncated,Date.parse(cleanDate(news[i].created_at)), news[i].in_reply_to_status_id, news[i].source, news[i].id,news[i].in_reply_to_user_id,news[i].geo,news[i].favorited, news[i].user.id,Qt.btoa(news[i].statusnet_html),news[i].statusnet_conversation_id, news[i].attachments,0,0,0]);
 }});
    if(news[i].user.following!=true){
   updateContactInDB(login,database,rootwindow,news[i].user)}
}
 callback();
    }
    );}

function conversationfromdb(database,user,conversationId,callback){
var db=Sql.LocalStorage.openDatabaseSync(database[0],database[1],database[2],database[3]);
db.transaction( function(tx) {
    print('select * from news WHERE statusnet_conversation_id='+conversationId+' ORDER BY status_id DESC');
     var newsrs=tx.executeSql('select * from news WHERE statusnet_conversation_id='+conversationId+' ORDER BY status_id DESC');
var newsArray=[];
  for(var i = 0; i < newsrs.rows.length; i++) {
        newsArray.push(newsrs.rows.item(i))
      Helperjs.readData(database,"contacts",function(userdata){
          newsArray[i].user=userdata[0];
          },"id",newsArray[i].uid);
     }
     callback(newsArray);
 });}

function inArray(list, prop, val) {
    if (list.length > 0 ) {
        for (var i in list) { if (list[i][prop] === val) {
                return true;
            }
        }
    } return false;
}

function cleanDate(date){
var cleanedDate= date.slice(0,3)+", "+date.slice(8,11)+date.slice(4,7)+date.slice(25,30)+date.slice(10,25);
return cleanedDate
}