From 002652dfba97993283f544194f6837abe5955257 Mon Sep 17 00:00:00 2001 From: Kirill Volinsky Date: Sat, 13 Oct 2012 09:34:35 +0000 Subject: Omegle: folders restructurization git-svn-id: http://svn.miranda-ng.org/main/trunk@1903 1316c22d-e87f-b044-9b9b-93d7a3e3ba9c --- protocols/Omegle/src/process.cpp | 77 ++++++++++++++++++++++++++++++++++++++++ 1 file changed, 77 insertions(+) create mode 100644 protocols/Omegle/src/process.cpp (limited to 'protocols/Omegle/src/process.cpp') diff --git a/protocols/Omegle/src/process.cpp b/protocols/Omegle/src/process.cpp new file mode 100644 index 0000000000..eb707373ec --- /dev/null +++ b/protocols/Omegle/src/process.cpp @@ -0,0 +1,77 @@ +/* + +Omegle plugin for Miranda Instant Messenger +_____________________________________________ + +Copyright © 2011-12 Robert Pösel + +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, see . + +*/ + +#include "common.h" + +void OmegleProto::ProcessEvents( void* data ) +{ + if ( data == NULL ) + return; + + std::string* resp = (std::string*)data; + + if ( isOffline() ) + goto exit; + + LOG("***** Starting processing messages"); + + CODE_BLOCK_TRY + + std::vector< Omegle_message* > messages; + + Omegle_json_parser* p = new Omegle_json_parser( this ); + p->parse_messages( data, &messages ); + delete p; + + for(std::vector::size_type i=0; imessage_text.c_str()); + +/* + PROTORECVEVENT recv = {}; + CCSDATA ccs = {}; + + recv.flags = PREF_UTF; + recv.szMessage = const_cast(messages[i]->message_text.c_str()); + recv.timestamp = static_cast(messages[i]->time); + + ccs.hContact = hContact; + ccs.szProtoService = PSR_MESSAGE; + ccs.wParam = ID_STATUS_ONLINE; + ccs.lParam = reinterpret_cast(&recv); + CallService(MS_PROTO_CHAINRECV,0,reinterpret_cast(&ccs));*/ + + delete messages[i]; + } + messages.clear(); + + LOG("***** Messages processed"); + + CODE_BLOCK_CATCH + + LOG("***** Error processing messages: %s", e.what()); + + CODE_BLOCK_END + +exit: + delete resp; +} -- cgit v1.2.3