opensync-plugin-0.4x/src/environment.cc

   1 //
   2 // \file        environment.cc
   3 //              Container / environment class for the sync module.
   4 //
   5
   6 /*
   7     Copyright (C) 2006-2012, Net Direct Inc. (http://www.netdirect.ca/)
   8
   9     This program is free software; you can redistribute it and/or modify
  10     it under the terms of the GNU General Public License as published by
  11     the Free Software Foundation; either version 2 of the License, or
  12     (at your option) any later version.
  13
  14     This program is distributed in the hope that it will be useful,
  15     but WITHOUT ANY WARRANTY; without even the implied warranty of
  16     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
  17
  18     See the GNU General Public License in the COPYING file at the
  19     root directory of this project for more details.
  20 */
  21
  22 #include <opensync/opensync.h>
  23 #include <opensync/opensync-data.h>
  24 #include <opensync/opensync-format.h>
  25 #include <opensync/opensync-plugin.h>
  26 #include <opensync/opensync-helper.h>
  27 #include <opensync/opensync-version.h>
  28
  29 #include "environment.h"
  30 #include "trace.h"
  31 #include <glib.h>
  32 #include <string>
  33 #include <fstream>
  34 #include <sstream>
  35 #include <iomanip>
  36 #include <string.h>
  37 #include <unistd.h>
  38
  39 using namespace Barry;
  40
  41 //////////////////////////////////////////////////////////////////////////////
  42 // DatabaseSyncState
  43
  44 DatabaseSyncState::DatabaseSyncState(OSyncPluginInfo *info, const char *description)
  45         : m_dbId(0),
  46         m_Sync(false),
  47         m_Desc(description)
  48 {
  49 }
  50
  51 DatabaseSyncState::~DatabaseSyncState()
  52 {
  53 }
  54
  55 //
  56 // Map2Uid
  57 //
  58 /// Converts record ID to string, since opensync 0.4x keeps the
  59 /// same UID as we give it.
  60 ///
  61 std::string DatabaseSyncState::Map2Uid(uint32_t recordId) const
  62 {
  63         std::ostringstream oss;
  64         oss << std::dec << recordId;
  65         return oss.str();
  66 }
  67
  68
  69
  70 //////////////////////////////////////////////////////////////////////////////
  71 // BarryEnvironment Public API
  72
  73 BarryEnvironment::BarryEnvironment(OSyncPluginInfo *info):
  74         info(info),
  75         m_pin(-1),
  76         m_DebugMode(false),
  77         m_CalendarSync(info, "calendar"),
  78         m_ContactsSync(info, "contacts"),
  79         m_JournalSync(info, "note"),
  80         m_TodoSync(info, "todo")
  81 {
  82 }
  83
  84 BarryEnvironment::~BarryEnvironment()
  85 {
  86 }
  87
  88 void BarryEnvironment::DoConnect()
  89 {
  90         if( !m_con.get() )
  91                 throw std::logic_error("Tried to use empty Connector");
  92
  93         m_con->Connect();
  94
  95         // Save the DBIDs and DBNames of the databases we will work with
  96         if( m_CalendarSync.m_Sync ) {
  97                 m_CalendarSync.m_dbName = Barry::Calendar::GetDBName();
  98                 m_CalendarSync.m_dbId = m_con->GetDesktop().GetDBID(Barry::Calendar::GetDBName());
  99         }
 100
 101         if( m_ContactsSync.m_Sync ) {
 102                 m_ContactsSync.m_dbName = Barry::Contact::GetDBName();
 103                 m_ContactsSync.m_dbId = m_con->GetDesktop().GetDBID(Barry::Contact::GetDBName());
 104         }
 105
 106         if( m_JournalSync.m_Sync ) {
 107                 m_JournalSync.m_dbName = Barry::Memo::GetDBName();
 108                 m_JournalSync.m_dbId = m_con->GetDesktop().GetDBID(Barry::Memo::GetDBName());
 109         }
 110
 111         if( m_TodoSync.m_Sync ) {
 112                 m_TodoSync.m_dbName = Barry::Task::GetDBName();
 113                 m_TodoSync.m_dbId = m_con->GetDesktop().GetDBID(Barry::Task::GetDBName());
 114         }
 115 }
 116
 117 void BarryEnvironment::SetPassword(const std::string &password)
 118 {
 119         m_password = password;
 120         if( m_con.get() )
 121                 m_con->SetPassword(password.c_str());
 122 }
 123
 124 void BarryEnvironment::Connect(const Barry::ProbeResult &result)
 125 {
 126         m_con.reset(new DesktopConnector(m_password.c_str(), "UTF-8", result));
 127         DoConnect();
 128 }
 129
 130 void BarryEnvironment::Reconnect()
 131 {
 132         m_con->Reconnect(2);
 133 }
 134
 135 void BarryEnvironment::Disconnect()
 136 {
 137         m_con->Disconnect();
 138 }
 139
 140 bool BarryEnvironment::isConnected()
 141 {
 142         return m_con.get() && m_con->IsConnected();
 143 }
 144
 145 void BarryEnvironment::ReconnectForDirtyFlags()
 146 {
 147         m_con->ReconnectForDirtyFlags();
 148 }
 149
 150 void BarryEnvironment::RequireDirtyReconnect()
 151 {
 152         m_con->RequireDirtyReconnect();
 153 }
 154
 155 void BarryEnvironment::ClearDirtyFlags(Barry::RecordStateTable &table,
 156                                 const std::string &dbname)
 157 {
 158         Trace trace("ClearDirtyFlags");
 159
 160         unsigned int dbId = m_con->GetDesktop().GetDBID(dbname);
 161
 162         Barry::RecordStateTable::StateMapType::const_iterator i = table.StateMap.begin();
 163         for( ; i != table.StateMap.end(); ++i ) {
 164                 if( i->second.Dirty ) {
 165                         trace.logf("Clearing dirty flag for db %u, index %u",
 166                                 dbId, i->first);
 167                         m_con->GetDesktop().ClearDirty(dbId, i->first);
 168                 }
 169         }
 170 }
 171
 172 void BarryEnvironment::ClearCalendarDirtyFlags()
 173 {
 174         Trace trace("ClearCalendarDirtyFlags");
 175         ClearDirtyFlags(m_CalendarSync.m_Table, Barry::Calendar::GetDBName());
 176 }
 177
 178 void BarryEnvironment::ClearContactsDirtyFlags()
 179 {
 180         Trace trace("ClearContactsDirtyFlags");
 181         ClearDirtyFlags(m_ContactsSync.m_Table, Barry::Contact::GetDBName());
 182 }
 183
 184 void BarryEnvironment::ClearJournalDirtyFlags()
 185 {
 186         Trace trace("ClearJournalDirtyFlags");
 187         ClearDirtyFlags(m_JournalSync.m_Table, Barry::Memo::GetDBName());
 188 }
 189
 190 void BarryEnvironment::ClearTodoDirtyFlags()
 191 {
 192         Trace trace("ClearTodoDirtyFlags");
 193         ClearDirtyFlags(m_TodoSync.m_Table, Barry::Task::GetDBName());
 194 }
 195
 196 DatabaseSyncState* BarryEnvironment::GetSyncObject(OSyncChange *change)
 197 {
 198         Trace trace("BarryEnvironment::GetSyncObject()");
 199
 200         const char *name = osync_change_get_objtype(change);
 201
 202         trace.logf("osync_change_get_objtype returns %s", name);
 203
 204         if( strcmp(name, "event") == 0 ) {
 205                 trace.log("return calendar object");
 206
 207                 return &m_CalendarSync;
 208         }
 209         else if( strcmp(name, "contact") == 0 ) {
 210                 trace.log("return contact object");
 211
 212                 return &m_ContactsSync;
 213         }
 214         else if( strcmp(name, "note") == 0 ) {
 215                 trace.log("return journal object");
 216
 217                 return &m_JournalSync;
 218         }
 219         else if( strcmp(name, "todo") == 0 ) {
 220                 trace.log("return todo object");
 221
 222                 return &m_TodoSync;
 223         }
 224
 225         trace.log("return none");
 226
 227         return 0;
 228 }
 229