diff options
author | George Hazan <ghazan@miranda.im> | 2018-08-08 21:26:04 +0300 |
---|---|---|
committer | George Hazan <ghazan@miranda.im> | 2018-08-08 21:26:04 +0300 |
commit | dedf4972424ff212ad9c930abb7c924188c51615 (patch) | |
tree | aa1868773d5b1b63f272004e176e1bad66a430d3 /plugins/Import | |
parent | 07ec5afdc9c5c027a438f378f5f208ffa9ebc1dd (diff) |
import from the json text file like
{
"history": [
{ "eventType":0, "timeStamp":98234, "flags":"m", "body":"boooo" },
{ "eventType":0, "timeStamp":98235, "flags":"r", "body":"moooo" }
]
}
Diffstat (limited to 'plugins/Import')
-rw-r--r-- | plugins/Import/src/main.cpp | 1 | ||||
-rw-r--r-- | plugins/Import/src/stdafx.h | 1 | ||||
-rw-r--r-- | plugins/Import/src/textjson.cpp | 175 |
3 files changed, 177 insertions, 0 deletions
diff --git a/plugins/Import/src/main.cpp b/plugins/Import/src/main.cpp index abb97ffd29..baeaad4e9a 100644 --- a/plugins/Import/src/main.cpp +++ b/plugins/Import/src/main.cpp @@ -178,5 +178,6 @@ int CMPlugin::Load() RegisterDbrw();
RegisterMContacts();
+ RegisterJson();
return 0;
}
diff --git a/plugins/Import/src/stdafx.h b/plugins/Import/src/stdafx.h index 4ded15ce5f..3d0f652e3c 100644 --- a/plugins/Import/src/stdafx.h +++ b/plugins/Import/src/stdafx.h @@ -105,3 +105,4 @@ HANDLE GetIconHandle(int iIconId); void RegisterIcons(void);
void RegisterMContacts();
+void RegisterJson();
diff --git a/plugins/Import/src/textjson.cpp b/plugins/Import/src/textjson.cpp new file mode 100644 index 0000000000..d964d56e81 --- /dev/null +++ b/plugins/Import/src/textjson.cpp @@ -0,0 +1,175 @@ +/* + +Import plugin for Miranda NG + +Copyright (c) 2012-18 Miranda NG team (https://miranda-ng.org) + +This program is free software; you can redistribute it and/or +modify it under the terms of the GNU General Public License +as published by the Free Software Foundation; either version 2 +of the License, or (at your option) any later version. + +This program is distributed in the hope that it will be useful, +but WITHOUT ANY WARRANTY; without even the implied warranty of +MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +GNU General Public License for more details. + +You should have received a copy of the GNU General Public License +along with this program; if not, write to the Free Software +Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. + +*/ + +#include "stdafx.h" + +#include <m_json.h> + +static int mc_makeDatabase(const wchar_t*) +{ + return 1; +} + +///////////////////////////////////////////////////////////////////////////////////////// +// JSON text driver, read-only + +class CDbxJson : public MDatabaseReadonly, public MZeroedObject +{ + JSONNode *m_root = nullptr; + LIST<JSONNode> m_events; + +public: + CDbxJson() : + m_events(100) + {} + + ~CDbxJson() + { + if (m_root != nullptr) + json_delete(m_root); + } + + void Load() + { + // json operates with the only contact with pseudo id=1 + m_cache->AddContactToCache(1); + } + + int Open(const wchar_t *profile) + { + HANDLE hFile = CreateFile(profile, GENERIC_READ, 0, 0, OPEN_ALWAYS, 0, 0); + if (hFile == INVALID_HANDLE_VALUE) + return EGROKPRF_CANTREAD; + + DWORD dwSize = GetFileSize(hFile, nullptr), dwRead; + ptrA szFile((char*)mir_alloc(dwSize + 1)); + BOOL r = ReadFile(hFile, szFile, dwSize, &dwRead, nullptr); + CloseHandle(hFile); + if (!r) + return EGROKPRF_CANTREAD; + + szFile[dwSize] = 0; + if ((m_root = json_parse(szFile)) == nullptr) + return EGROKPRF_DAMAGED; + + for (auto &it : m_root->at("history")) + m_events.insert(&it); + + return EGROKPRF_NOERROR; + } + + // mcontacts format always store history for one contact only + STDMETHODIMP_(LONG) GetContactCount(void) override + { + return 1; + } + + STDMETHODIMP_(LONG) GetEventCount(MCONTACT) override + { + return m_events.getCount(); + } + + STDMETHODIMP_(BOOL) GetEvent(MEVENT iEvent, DBEVENTINFO *dbei) override + { + JSONNode *node = m_events[iEvent - 1]; + if (node == nullptr) + return 0; + + dbei->eventType = (*node)["eventType"].as_int(); + dbei->timestamp = (*node)["timeStamp"].as_int(); + + dbei->flags = 0; + std::string szFlags = (*node)["flags"].as_string(); + for (auto &c : szFlags) + switch (c) { + case 'm': dbei->flags |= DBEF_SENT; break; + case 'r': dbei->flags |= DBEF_READ; break; + } + + std::string szBody = (*node)["body"].as_string(); + if (!szBody.empty()) { + dbei->flags |= DBEF_UTF; + dbei->cbBlob = (DWORD)szBody.size(); + dbei->pBlob = (PBYTE)mir_alloc(szBody.size() + 1); + strcpy((char*)dbei->pBlob, szBody.c_str()); + } + + return 0; + } + + STDMETHODIMP_(MEVENT) FindFirstEvent(MCONTACT) override + { + return 1; + } + + STDMETHODIMP_(MEVENT) FindNextEvent(MCONTACT, MEVENT iEvent) override + { + if (iEvent >= m_events.getCount()) + return 0; + + return iEvent+1; + } + + STDMETHODIMP_(MEVENT) FindLastEvent(MCONTACT) override + { + int numEvents = m_events.getCount(); + return numEvents ? numEvents-1 : 0; + } + + STDMETHODIMP_(MEVENT) FindPrevEvent(MCONTACT, MEVENT iEvent) override + { + if (iEvent <= 1) + return 0; + + return iEvent-1; + } +}; + +static int mc_grokHeader(const wchar_t *profile) +{ + return CDbxJson().Open(profile); +} + +static MDatabaseCommon* mc_load(const wchar_t *profile, BOOL) +{ + std::auto_ptr<CDbxJson> db(new CDbxJson()); + if (db->Open(profile)) + return nullptr; + + db->Load(); + return db.release(); +} + +static DATABASELINK dblink = +{ + 0, + "mcontacts", + L"mContacts file driver", + mc_makeDatabase, + mc_grokHeader, + mc_load +}; + +void RegisterJson() +{ + RegisterDatabasePlugin(&dblink); +} |