old version

git-svn-id: http://svn.miranda-ng.org/main/trunk@16458 1316c22d-e87f-b044-9b9b-93d7a3e3ba9c

1 files changed, 0 insertions, 1829 deletions

diff --git a/protocols/Telegram/tgl/binlog.c b/protocols/Telegram/tgl/binlog.c
deleted file mode 100644
index ed5d514abf..0000000000
--- a/protocols/Telegram/tgl/binlog.c
+++ /dev/null
@@ -1,1829 +0,0 @@
-/* 
-    This file is part of tgl-library
-
-    This library is free software; you can redistribute it and/or
-    modify it under the terms of the GNU Lesser General Public
-    License as published by the Free Software Foundation; either
-    version 2.1 of the License, or (at your option) any later version.
-
-    This library 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
-    Lesser General Public License for more details.
-
-    You should have received a copy of the GNU Lesser General Public
-    License along with this library; if not, write to the Free Software
-    Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
-
-    Copyright Vitaly Valtman 2013-2015
-*/
-
-#ifdef HAVE_CONFIG_H
-#  include "config.h"
-#endif
-
-#if defined(WIN32) || defined(_WIN32)
-#include <stdint.h>
-#include <string.h>
-#include <fcntl.h>
-#define WIN32_LEAN_AND_MEAN
-#include <windows.h>
-#undef WIN32_LEAN_AND_MEAN
-#include <io.h>
-#include <sys/locking.h>
-#else
-#include <unistd.h>
-#include <sys/file.h>
-#endif
-#include <sys/types.h>
-#include <sys/stat.h>
-#include <stdlib.h>
-#include <fcntl.h>
-#include <errno.h>
-#include <stdio.h>
-#include <string.h>
-#include <assert.h>
-#include <openssl/bn.h>
-
-#include "tgl-binlog.h"
-#include "mtproto-common.h"
-//#include "net.h"
-#include "mtproto-client.h"
-#include "mtproto-utils.h"
-
-#include "tgl.h"
-#include "auto.h"
-#include "auto/auto-types.h"
-#include "auto/auto-skip.h"
-#include "auto/auto-store-ds.h"
-#include "auto/auto-fetch-ds.h"
-#include "auto/auto-free-ds.h"
-
-#include "tgl-structures.h"
-#include "tgl-methods-in.h"
-
-#include <openssl/sha.h>
-
-#define BINLOG_BUFFER_SIZE (1 << 20)
-static int binlog_buffer[BINLOG_BUFFER_SIZE];
-static int *rptr;
-static int *wptr;
-//static int TLS->binlog_fd;
-static int in_replay_log; // should be used ONLY for DEBUG
-
-
-#define MAX_LOG_EVENT_SIZE (1 << 17)
-
-char *get_binlog_file_name (void);
-
-static void *alloc_log_event (int l) {
-  return binlog_buffer;
-}
-
-static int mystreq1 (const char *a, const char *b, int l) {
-  if ((int)strlen (a) != l) { return 1; }
-  return memcmp (a, b, l);
-}
-
-static long long binlog_pos;
-
-static int fetch_comb_binlog_start (struct tgl_state *TLS, void *extra) {
-  return 0;
-}
-
-/* {{{  DC option */
-static int fetch_comb_binlog_dc_option (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  vlogprintf (E_NOTICE, "DC%d '%.*s' update: %.*s:%d\n", 
-    DS_LVAL (DS_U->dc), 
-    DS_RSTR (DS_U->name), 
-    DS_RSTR (DS_U->ip), 
-    DS_LVAL (DS_U->port)
-  );
-
-  tglmp_alloc_dc (TLS,
-    0,
-    DS_LVAL (DS_U->dc), 
-    DS_STR_DUP (DS_U->ip), 
-    DS_LVAL (DS_U->port)
-  );
-  return 0;
-}
-
-static int fetch_comb_binlog_dc_option_new (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  vlogprintf (E_NOTICE, "DC%d '%.*s' update: %.*s:%d\n", 
-    DS_LVAL (DS_U->dc), 
-    DS_RSTR (DS_U->name), 
-    DS_RSTR (DS_U->ip), 
-    DS_LVAL (DS_U->port)
-  );
-
-  tglmp_alloc_dc (TLS,
-    DS_LVAL (DS_U->flags), 
-    DS_LVAL (DS_U->dc), 
-    DS_STR_DUP (DS_U->ip), 
-    DS_LVAL (DS_U->port)
-  );
-  return 0;
-}
-/* }}} */
-
-/* {{{ Auth key */
-static int fetch_comb_binlog_auth_key (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  int num = DS_LVAL (DS_U->dc);
-  assert (num > 0 && num <= MAX_DC_ID);
-  assert (TLS->DC_list[num]);
-
-  tglf_fetch_int_tuple ((void *)TLS->DC_list[num]->auth_key, DS_U->key->key, 64);
-  
-  static unsigned char sha1_buffer[20];
-  SHA1 ((void *)TLS->DC_list[num]->auth_key, 256, sha1_buffer);
-  TLS->DC_list[num]->auth_key_id = *(long long *)(sha1_buffer + 12);
-
-  TLS->DC_list[num]->flags |= TGLDCF_AUTHORIZED;
-  return 0;
-}
-/* }}} */
-
-/* {{{ Default dc */
-static int fetch_comb_binlog_default_dc (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  int num = DS_LVAL (DS_U->dc);
-  assert (num > 0 && num <= MAX_DC_ID);
-  TLS->DC_working = TLS->DC_list[num];
-  TLS->dc_working_num = num;
-  return 0;
-}
-/* }}} */
-
-/* {{{ DC signed */
-static int fetch_comb_binlog_dc_signed (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  int num = DS_LVAL (DS_U->dc);
-  assert (num > 0 && num <= MAX_DC_ID);
-  assert (TLS->DC_list[num]);
-  TLS->DC_list[num]->flags |= TGLDCF_LOGGED_IN;
-  return 0;
-}
-/* }}} */
-
-/* {{{ our user_id */
-static int fetch_comb_binlog_our_id (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  TLS->our_id = DS_LVAL (DS_U->id);
-  assert (TLS->our_id > 0);
-  if (TLS->callback.our_id) {
-    TLS->callback.our_id (TLS, TLS->our_id);
-  }
-  return 0;
-}
-/* }}} */
-     
-/* {{{ Set DH params */
-static int fetch_comb_binlog_set_dh_params (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  if (TLS->encr_prime) { tfree (TLS->encr_prime, 256); BN_free (TLS->encr_prime_bn); }
-
-  TLS->encr_root = DS_LVAL (DS_U->root);
-  TLS->encr_prime = talloc (256);
-  tglf_fetch_int_tuple ((void *)TLS->encr_prime, DS_U->prime->key, 64);
-
-  TLS->encr_prime_bn = BN_new ();
-  BN_bin2bn ((void *)TLS->encr_prime, 256, TLS->encr_prime_bn);
-  TLS->encr_param_version = DS_LVAL (DS_U->version);
-    
-  assert (tglmp_check_DH_params (TLS, TLS->encr_prime_bn, TLS->encr_root) >= 0);
-
-  return 0;
-}
-/* }}} */
-
-/* {{{ Set pts, qts, date, seq */
-static int fetch_comb_binlog_set_pts (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  TLS->pts = DS_LVAL (DS_U->pts);
-  return 0;
-}
-
-static int fetch_comb_binlog_set_qts (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  TLS->qts = DS_LVAL (DS_U->qts);
-  return 0;
-}
-
-static int fetch_comb_binlog_set_date (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  TLS->date = DS_LVAL (DS_U->date);
-  return 0;
-}
-
-static int fetch_comb_binlog_set_seq (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  TLS->seq = DS_LVAL (DS_U->seq);
-  return 0;
-}
-/* }}} */
-
-/* {{{ delete user */
-static int fetch_comb_binlog_user_delete (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  tgl_peer_id_t id = TGL_MK_USER (DS_LVAL (DS_U->id));
-  tgl_peer_t *U = tgl_peer_get (TLS, id);
-  assert (U);
-  U->flags |= TGLUF_DELETED;
-  
-  if (TLS->callback.user_update) {
-    TLS->callback.user_update (TLS, (void *)U, TGL_UPDATE_DELETED);
-  }
-  return 0;
-}
-/* }}} */
-
-/* {{{ delete secret chat */
-static int fetch_comb_binlog_encr_chat_delete (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  tgl_peer_id_t id = TGL_MK_ENCR_CHAT (DS_LVAL (DS_U->id));
-  tgl_peer_t *_U = tgl_peer_get (TLS, id);
-  assert (_U);
-  struct tgl_secret_chat *U = &_U->encr_chat;
-  memset (U->key, 0, sizeof (U->key));
-  U->flags |= TGLPF_DELETED;
-  U->state = sc_deleted;
-  if (U->g_key) {
-    tfree_secure (U->g_key, 256);
-    U->g_key = 0;
-  }
-  
-  if (TLS->callback.secret_chat_update) {
-    TLS->callback.secret_chat_update (TLS, U, TGL_UPDATE_DELETED);
-  }
-  return 0;
-}
-/* }}} */
-
-static int fetch_comb_binlog_user_new (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  tgl_peer_id_t id = TGL_MK_USER (DS_LVAL (DS_U->id));
-  tgl_peer_t *_U = tgl_peer_get (TLS, id);
-
-  int flags = DS_LVAL (DS_U->flags);
-
-  unsigned updates = 0;
-
-  if (flags & TGLPF_CREATE) {
-    if (!_U) {
-      _U = talloc0 (sizeof (*_U));
-      _U->id = id;
-      tglp_insert_encrypted_chat (TLS, _U);
-    } else {
-      assert (!(_U->flags & TGLPF_CREATED));
-    }
-    updates |= TGL_UPDATE_CREATED;
-  } else {
-    assert (_U->flags & TGLPF_CREATED);
-  }
-
-  struct tgl_user *U = (void *)_U;
-  
-  if ((flags & 0xff) != (U->flags & 0xff)) {
-    updates |= TGL_UPDATE_FLAGS;
-  }
-  U->flags = flags & 0xffff;
-
-  if (DS_U->access_hash) {
-    U->access_hash = DS_LVAL (DS_U->access_hash);
-    updates |= TGL_UPDATE_ACCESS_HASH;
-  }
-
-  if (DS_U->first_name) {
-    if (U->first_name) {
-      tfree_str (U->first_name);
-    }
-    U->first_name = DS_STR_DUP (DS_U->first_name);
-    if (U->last_name) {
-      tfree_str (U->last_name);
-    }
-    U->last_name = DS_STR_DUP (DS_U->last_name);
-
-    updates |= TGL_UPDATE_NAME;
-
-    if (U->print_name) { 
-      tglp_peer_delete_name (TLS, (void *)U);
-      tfree_str (U->print_name); 
-    }
-    U->print_name = TLS->callback.create_print_name (TLS, U->id, U->first_name, U->last_name, 0, 0);
-    tglp_peer_insert_name (TLS, (void *)U);
-  }
-
-  if (DS_U->phone) {
-    if (U->phone) {
-      tfree_str (U->phone);
-    }
-    U->phone = DS_STR_DUP (DS_U->phone);
-    updates |= TGL_UPDATE_PHONE;
-  }
-
-  if (DS_U->username) {
-    if (U->username) {
-      tfree_str (U->username);
-    }
-    U->username = DS_STR_DUP (DS_U->username);
-    updates |= TGL_UPDATE_USERNAME;
-  }
-
-  if (DS_U->photo) {
-    if (U->photo) {
-      tgls_free_photo (TLS, U->photo);
-    }
-    U->photo = tglf_fetch_alloc_photo_new (TLS, DS_U->photo);
-    U->flags |= TGLUF_HAS_PHOTO;
-    //updates |= TGL_UPDATE_PHOTO;
-  }
-
-  if (DS_U->user_photo) {
-    U->photo_id = DS_LVAL (DS_U->user_photo->photo_id);
-    tglf_fetch_file_location_new (TLS, &U->photo_big, DS_U->user_photo->photo_big);
-    tglf_fetch_file_location_new (TLS, &U->photo_small, DS_U->user_photo->photo_small);
-    updates |= TGL_UPDATE_PHOTO;
-  }
-
-  if (DS_U->real_first_name) {
-    if (U->real_first_name) {
-      tfree_str (U->real_first_name);
-    }
-    U->real_first_name = DS_STR_DUP (DS_U->real_first_name);
-    if (U->real_last_name) {
-      tfree_str (U->real_last_name);
-    }
-    U->real_last_name = DS_STR_DUP (DS_U->real_last_name);
-
-    updates |= TGL_UPDATE_REAL_NAME;
-  }
- 
-  if (DS_U->last_read_in) {
-    U->last_read_in = DS_LVAL (DS_U->last_read_in);
-    tgls_messages_mark_read (TLS, U->last, 0, U->last_read_in);
-  }
- 
-  if (DS_U->last_read_out) {
-    U->last_read_out = DS_LVAL (DS_U->last_read_out);
-    tgls_messages_mark_read (TLS, U->last, TGLMF_OUT, U->last_read_out);
-  }
-
-  if (DS_U->bot_info) {
-    if (U->bot_info) {
-      tgls_free_bot_info (TLS, U->bot_info);
-    }
-    U->bot_info = tglf_fetch_alloc_bot_info (TLS, DS_U->bot_info);
-  }
-
-  if (TLS->callback.user_update && updates) {
-    TLS->callback.user_update (TLS, U, updates);
-  }
-  
-  return 0;
-}
-
-static int fetch_comb_binlog_encr_chat_new (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  tgl_peer_id_t id = TGL_MK_ENCR_CHAT (DS_LVAL (DS_U->id));
-  tgl_peer_t *_U = tgl_peer_get (TLS, id);
-
-  int flags = DS_LVAL (DS_U->flags);
-
-  unsigned updates = 0;
-
-  if (flags & TGLPF_CREATE) {
-    if (!_U) {
-      _U = talloc0 (sizeof (*_U));
-      _U->id = id;
-      tglp_insert_encrypted_chat (TLS, _U);
-    } else {
-      assert (!(_U->flags & TGLPF_CREATED));
-    }
-    updates |= TGL_UPDATE_CREATED;
-  } else {
-    assert (_U->flags & TGLPF_CREATED);
-  }
-
-  struct tgl_secret_chat *U = (void *)_U;
-  
-  if ((flags & 0xff) != (U->flags & 0xff)) {
-    updates |= TGL_UPDATE_FLAGS;
-  }
-  U->flags = flags & 0xffff;
-
-  if (DS_U->access_hash) {
-    U->access_hash = DS_LVAL (DS_U->access_hash);
-    updates |= TGL_UPDATE_ACCESS_HASH;
-  }
-
-  if (DS_U->date) {
-    U->date = DS_LVAL (DS_U->date);
-  }
-
-  if (DS_U->admin) {
-    U->admin_id = DS_LVAL (DS_U->admin);
-  }
-
-  if (DS_U->user_id) {
-    U->user_id = DS_LVAL (DS_U->user_id);
-  }
-
-  if (DS_U->key_fingerprint) {
-    U->key_fingerprint = DS_LVAL (DS_U->key_fingerprint);
-  }
-
-  if (DS_U->in_seq_no) {
-    U->in_seq_no = DS_LVAL (DS_U->in_seq_no);
-    U->out_seq_no = DS_LVAL (DS_U->out_seq_no);
-    U->last_in_seq_no = DS_LVAL (DS_U->last_in_seq_no);
-  }
-
-  tgl_peer_t *Us = tgl_peer_get (TLS, TGL_MK_USER (U->user_id));
-  
-  if (!U->print_name) {
-    if (Us) {
-      U->print_name = TLS->callback.create_print_name (TLS, id, "!", Us->user.first_name, Us->user.last_name, 0);
-    } else {
-      static char buf[100];
-      tsnprintf (buf, 99, "user#%d", U->user_id);
-      U->print_name = TLS->callback.create_print_name (TLS, id, "!", buf, 0, 0);
-    }
-    tglp_peer_insert_name (TLS, (void *)U);
-  }
-
-  if (DS_U->g_key) {
-    if (!U->g_key)  {
-      U->g_key = talloc (256);
-    }
-    tglf_fetch_int_tuple ((void *)U->g_key, DS_U->g_key->key, 64);
-  }
-
-  if (DS_U->key) {
-    tglf_fetch_int_tuple (U->key, DS_U->key->key, 64);
-  }
-
-  if (DS_U->state) {
-    if (U->state == sc_waiting && DS_LVAL (DS_U->state) == sc_ok) {
-      tgl_do_create_keys_end (TLS, U);
-    }
-    if ((int)U->state != DS_LVAL (DS_U->state)) {
-      switch (DS_LVAL (DS_U->state)) {
-      case sc_request:
-        updates |= TGL_UPDATE_REQUESTED;
-        break;
-      case sc_ok:
-        updates |= TGL_UPDATE_WORKING;
-        vlogprintf (E_WARNING, "Secret chat in ok state\n");
-        break;
-      default:
-        break;
-      } 
-    }
-    U->state = DS_LVAL (DS_U->state);
-  }
-  
-  if (TLS->callback.secret_chat_update && updates) {
-    TLS->callback.secret_chat_update (TLS, U, updates);
-  }
-  
-  return 0;
-}
-
-static int fetch_comb_binlog_chat_new (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  tgl_peer_id_t id = TGL_MK_CHAT (DS_LVAL (DS_U->id));
-  tgl_peer_t *_U = tgl_peer_get (TLS, id);
-
-  int flags = DS_LVAL (DS_U->flags);
-
-  unsigned updates = 0;
-
-  if (flags & (1 << 16)) {
-    if (!_U) {
-      _U = talloc0 (sizeof (*_U));
-      _U->id = id;
-      tglp_insert_chat (TLS, _U);
-    } else {
-      assert (!(_U->flags & TGLPF_CREATED));
-    }
-    updates |= TGL_UPDATE_CREATED;
-  } else {
-    assert (_U->flags & TGLPF_CREATED);
-  }
-  
-  struct tgl_chat *C = &_U->chat;
-  
-  if ((flags & 0xff) != (C->flags & 0xff)) {
-    updates |= TGL_UPDATE_FLAGS;
-  }
-  C->flags = flags & 0xffff;
-
-  if (DS_U->title) {
-    if (C->title) {
-      tfree_str (C->title);
-    }
-    C->title = DS_STR_DUP (DS_U->title);
-
-    if (C->print_title) { 
-      tglp_peer_delete_name (TLS, (void *)C);
-      tfree_str (C->print_title); 
-    }
-    C->print_title = TLS->callback.create_print_name (TLS, C->id, C->title, 0, 0, 0);
-    tglp_peer_insert_name (TLS, (void *)C);
-    
-    updates |= TGL_UPDATE_TITLE;
-  }
-  
-  if (DS_U->user_num) {
-    C->users_num = DS_LVAL (DS_U->user_num);
-  }
-  
-  if (DS_U->date) {
-    C->date = DS_LVAL (DS_U->date);
-  }
-
-  if (DS_U->chat_photo) {
-    tglf_fetch_file_location_new (TLS, &C->photo_big, DS_U->chat_photo->photo_big);
-    tglf_fetch_file_location_new (TLS, &C->photo_small, DS_U->chat_photo->photo_small);
-    updates |= TGL_UPDATE_PHOTO;
-  }
-
-  if (DS_U->photo) {
-    if (C->photo) {
-      tgls_free_photo (TLS, C->photo);
-    }
-    C->photo = tglf_fetch_alloc_photo_new (TLS, DS_U->photo);
-    C->flags |= TGLPF_HAS_PHOTO;
-    updates |= TGL_UPDATE_PHOTO;
-  }
-
-  if (DS_U->admin) {
-    C->admin_id = DS_LVAL (DS_U->admin);
-    updates |= TGL_UPDATE_ADMIN;
-  }
-
-  if (DS_U->version) {
-    C->version = DS_LVAL (DS_U->version);
-  
-    if (C->user_list) { tfree (C->user_list, 12 * C->user_list_size); }
-
-    C->user_list_size = DS_LVAL (DS_U->participants->cnt);
-    C->user_list = talloc (12 * C->user_list_size);
-
-    int i;
-    for (i = 0; i < C->user_list_size; i++) {
-      C->user_list[i].user_id = DS_LVAL (DS_U->participants->data[i]->user_id);
-      C->user_list[i].inviter_id = DS_LVAL (DS_U->participants->data[i]->inviter_id);
-      C->user_list[i].date = DS_LVAL (DS_U->participants->data[i]->date);
-    }
-
-    updates |= TGL_UPDATE_MEMBERS;
-  }
- 
-  if (DS_U->last_read_in) {
-    C->last_read_in = DS_LVAL (DS_U->last_read_in);
-    tgls_messages_mark_read (TLS, C->last, 0, C->last_read_in);
-  }
- 
-  if (DS_U->last_read_out) {
-    C->last_read_out = DS_LVAL (DS_U->last_read_out);
-    tgls_messages_mark_read (TLS, C->last, TGLMF_OUT, C->last_read_out);
-  }
-
-      
-  if (TLS->callback.chat_update && updates) {
-    TLS->callback.chat_update (TLS, C, updates);
-  }
-  return 0;
-}
-
-static int fetch_comb_binlog_chat_add_participant (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  tgl_peer_id_t id = TGL_MK_CHAT (DS_LVAL (DS_U->id));
-  tgl_peer_t *_C = tgl_peer_get (TLS, id);
-  assert (_C && (_C->flags & TGLPF_CREATED));
-  struct tgl_chat *C = &_C->chat;
-
-  int version = DS_LVAL (DS_U->version);
-  int user = DS_LVAL (DS_U->user_id);
-  int inviter = DS_LVAL (DS_U->inviter_id);
-  int date = DS_LVAL (DS_U->date);
-
-
-  if (C->user_list_version > version) { return 0; }
-
-  int i;
-  for (i = 0; i < C->user_list_size; i++) {
-    if (C->user_list[i].user_id == user) { 
-      return 0;
-    }
-  }
-
-  C->user_list_size ++;
-  C->user_list = trealloc (C->user_list, 12 * C->user_list_size - 12, 12 * C->user_list_size);
-  C->user_list[C->user_list_size - 1].user_id = user;
-  C->user_list[C->user_list_size - 1].inviter_id = inviter;
-  C->user_list[C->user_list_size - 1].date = date;
-  C->user_list_version = version;
-  
-  if (TLS->callback.chat_update) {
-    TLS->callback.chat_update (TLS, C, TGL_UPDATE_MEMBERS);
-  }
-  return 0;
-}
-
-static int fetch_comb_binlog_chat_del_participant (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  tgl_peer_id_t id = TGL_MK_CHAT (DS_LVAL (DS_U->id));
-  tgl_peer_t *_C = tgl_peer_get (TLS, id);
-  assert (_C && (_C->flags & TGLPF_CREATED));
-  struct tgl_chat *C = &_C->chat;
-  
-  int version = DS_LVAL (DS_U->version);
-  int user = DS_LVAL (DS_U->user_id);
-  if (C->user_list_version > version) { return 0; }
-      
-  int i;
-  for (i = 0; i < C->user_list_size; i++) {
-    if (C->user_list[i].user_id == user) {
-      struct tgl_chat_user t;
-      t = C->user_list[i];
-      C->user_list[i] = C->user_list[C->user_list_size - 1];
-      C->user_list[C->user_list_size - 1] = t;
-    }
-  }
-  if (C->user_list[C->user_list_size - 1].user_id != user) { return 0; }
-
-  assert (C->user_list[C->user_list_size - 1].user_id == user);
-  C->user_list_size --;
-  C->user_list = trealloc (C->user_list, 12 * C->user_list_size + 12, 12 * C->user_list_size);
-  C->user_list_version = version;
-  
-  if (TLS->callback.chat_update) {
-    TLS->callback.chat_update (TLS, C, TGL_UPDATE_MEMBERS);
-  }
-  return 0;
-}
-
-static int fetch_comb_binlog_message_new (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  struct tgl_message *M = tgl_message_get (TLS, DS_LVAL (DS_U->lid));
-  int flags = DS_LVAL (DS_U->flags);
-
-  if (flags & (1 << 16)) {
-    if (!M) {
-      M = tglm_message_alloc (TLS, DS_LVAL (DS_U->lid));
-    }
-    assert (!(M->flags & TGLMF_CREATED));
-  } else {
-    assert (M->flags & TGLMF_CREATED);
-  }
-
-  assert (flags & TGLMF_CREATED);
-  assert (!(M->flags & TGLMF_ENCRYPTED));
-  assert (!(flags & TGLMF_ENCRYPTED));
-
-  if ((M->flags & TGLMF_PENDING) && !(flags & TGLMF_PENDING)){
-    tglm_message_remove_unsent (TLS, M);
-  }
-  if (!(M->flags & TGLMF_PENDING) && (flags & TGLMF_PENDING)){
-    tglm_message_insert_unsent (TLS, M);
-  }
-
-  if ((M->flags & TGLMF_UNREAD) && !(flags & TGLMF_UNREAD)) {
-    M->flags = (flags & 0xffff) | TGLMF_UNREAD;
-  } else {
-    M->flags = (flags & 0xffff);
-  }
- 
-  if (DS_U->from_id) {
-    M->from_id = TGL_MK_USER (DS_LVAL (DS_U->from_id));
-  }
-  if (DS_U->to_type) {  
-    assert (flags & 0x10000);
-    M->to_id = tgl_set_peer_id (DS_LVAL (DS_U->to_type), DS_LVAL (DS_U->to_id));
-    assert (DS_LVAL (DS_U->to_type) != TGL_PEER_ENCR_CHAT);
-  }
-
-  if (DS_U->date) {
-    M->date = DS_LVAL (DS_U->date);
-  }
-  
-  if (DS_U->fwd_from_id) {
-    M->fwd_from_id = TGL_MK_USER (DS_LVAL (DS_U->fwd_from_id));
-    M->fwd_date = DS_LVAL (DS_U->fwd_date);
-  }
-  
-  if (DS_U->action) {
-    tglf_fetch_message_action_new (TLS, &M->action, DS_U->action);
-    M->flags |= TGLMF_SERVICE;
-  } 
-
-  if (DS_U->message) {
-    M->message_len = DS_U->message->len;
-    M->message = DS_STR_DUP (DS_U->message);
-    assert (!(M->flags & TGLMF_SERVICE));
-  }
-
-  if (DS_U->media) {
-    tglf_fetch_message_media_new (TLS, &M->media, DS_U->media);
-    assert (!(M->flags & TGLMF_SERVICE));
-  }
-
-  if (DS_U->reply_id) {
-    M->reply_id = DS_LVAL (DS_U->reply_id);
-  }
-
-  if (flags & 0x10000) {
-    tglm_message_insert (TLS, M);
-  }
-
-  if (!(flags & TGLMF_UNREAD) && (M->flags & TGLMF_UNREAD)) {
-    tgls_messages_mark_read (TLS, M, M->flags & TGLMF_OUT, M->id);
-  }
-
-  if (DS_U->reply_markup) {
-    M->reply_markup = tglf_fetch_alloc_reply_markup (TLS, M->next, DS_U->reply_markup);
-  }
-  return 0;
-}
-
-static int fetch_comb_binlog_message_encr_new (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  struct tgl_message *M = tgl_message_get (TLS, DS_LVAL (DS_U->lid));
-  int flags = DS_LVAL (DS_U->flags);
-
-  if (flags & (1 << 16)) {
-    if (!M) {
-      M = tglm_message_alloc (TLS, DS_LVAL (DS_U->lid));
-    } else {
-      assert (!(M->flags & TGLMF_CREATED));
-    }
-    assert (!(M->flags & TGLMF_CREATED));
-  } else {
-    assert (M->flags & TGLMF_CREATED);
-  }
-
-  assert (flags & TGLMF_CREATED);
-  assert (flags & TGLMF_ENCRYPTED);
-
-  if ((M->flags & TGLMF_PENDING) && !(flags & TGLMF_PENDING)){
-    tglm_message_remove_unsent (TLS, M);
-  }
-  if (!(M->flags & TGLMF_PENDING) && (flags & TGLMF_PENDING)){
-    tglm_message_insert_unsent (TLS, M);
-  }
-
-  M->flags = flags & 0xffff;
- 
-  if (DS_U->from_id) {
-    M->from_id = TGL_MK_USER (DS_LVAL (DS_U->from_id));
-  }
-  if (DS_U->to_type) {  
-    assert (flags & 0x10000);
-    M->to_id = tgl_set_peer_id (DS_LVAL (DS_U->to_type), DS_LVAL (DS_U->to_id));
-  }
-
-  if (DS_U->date) {
-    M->date = DS_LVAL (DS_U->date);
-  }
-
-  struct tgl_secret_chat *E = (void *)tgl_peer_get (TLS, M->to_id);
-  assert (E);
-
-  if (DS_U->message) {
-    M->message_len = DS_U->message->len;
-    M->message = DS_STR_DUP (DS_U->message);
-    assert (!(M->flags & TGLMF_SERVICE));
-  }
-
-  if (DS_U->encr_media) {
-    tglf_fetch_message_media_encrypted_new (TLS, &M->media, DS_U->encr_media);
-    assert (!(M->flags & TGLMF_SERVICE));
-  }
-
-  if (DS_U->encr_action) {
-    tglf_fetch_message_action_encrypted_new (TLS, &M->action, DS_U->encr_action);
-    M->flags |= TGLMF_SERVICE;
-  }
-
-  if (DS_U->file) {
-    tglf_fetch_encrypted_message_file_new (TLS, &M->media, DS_U->file);
-    assert (!(M->flags & TGLMF_SERVICE));
-  }
-
-  if (DS_U->encr_action && !(M->flags & TGLMF_OUT) && M->action.type == tgl_message_action_notify_layer) {
-    E->layer = M->action.layer;
-  }
-
-  if ((flags & TGLMF_CREATE) && (flags & TGLMF_OUT)) {
-    E->out_seq_no ++;
-  }
-
-  if (flags & 0x10000) {
-    tglm_message_insert (TLS, M);
-  }
-  return 0;
-}
-
-static int fetch_comb_binlog_set_msg_id (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  struct tgl_message *M = tgl_message_get (TLS, DS_LVAL (DS_U->old_id));
-  assert (M);
-  if (M->flags & TGLMF_PENDING) {
-    tglm_message_remove_unsent (TLS, M);
-    M->flags &= ~TGLMF_PENDING;
-  }
-  
-  tglm_message_remove_tree (TLS, M);
-  tglm_message_del_peer (TLS, M);
-  
-  M->id = DS_LVAL (DS_U->new_id);
-  if (tgl_message_get (TLS, M->id)) {
-    tglm_message_del_use (TLS, M);
-    tgls_free_message (TLS, M);
-  } else {
-    tglm_message_insert_tree (TLS, M);
-    tglm_message_add_peer (TLS, M);
-  }
-  return 0;
-}
-
-static int fetch_comb_binlog_message_delete (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  struct tgl_message *M = tgl_message_get (TLS, DS_LVAL (DS_U->lid));
-  assert (M);
-  if (M->flags & TGLMF_PENDING) {
-    tglm_message_remove_unsent (TLS, M);
-    M->flags &= ~TGLMF_PENDING;
-  }
-  tglm_message_remove_tree (TLS, M);
-  tglm_message_del_peer (TLS, M);
-  tglm_message_del_use (TLS, M);
-  tgls_free_message (TLS, M);
-  return 0;
-}
-
-static int fetch_comb_binlog_msg_update (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  struct tgl_message *M = tgl_message_get (TLS, DS_LVAL (DS_U->lid));
-  if (!M) { return 0; }
-  assert (M);
-  
-  if (!(M->flags & TGLMF_ENCRYPTED)) {
-    if (TLS->max_msg_id < M->id) {
-      TLS->max_msg_id = M->id;
-    }
-  }
-
-  if (TLS->callback.msg_receive) {
-    TLS->callback.msg_receive (TLS, M);
-  }
-  return 0;
-}
-
-static int fetch_comb_binlog_reset_authorization (struct tgl_state *TLS, void *extra) {
-  int i;
-  for (i = 0; i <= TLS->max_dc_num; i++) if (TLS->DC_list[i]) {
-    struct tgl_dc *D = TLS->DC_list[i];
-    D->flags = 0;
-    D->state = st_init;
-    D->auth_key_id = D->temp_auth_key_id = 0;
-  }
-  TLS->seq = 0;
-  TLS->qts = 0;
-  return 0;
-}
-
-static int fetch_comb_binlog_encr_chat_exchange_new (struct tgl_state *TLS, struct tl_ds_binlog_update *DS_U) {
-  tgl_peer_t *P = tgl_peer_get (TLS, TGL_MK_ENCR_CHAT (DS_LVAL (DS_U->id)));
-  assert (P);
-  if (DS_U->state) {
-    P->encr_chat.exchange_state = DS_LVAL (DS_U->state);
-  }
-  if (DS_U->exchange_id) {
-    P->encr_chat.exchange_id = DS_LVAL (DS_U->exchange_id);
-  }
-
-  static unsigned char sha_buffer[20];
-  switch (P->encr_chat.exchange_state) {
-  case tgl_sce_requested:
-    tglf_fetch_int_tuple (P->encr_chat.exchange_key, DS_U->key->key, 64);
-    break;
-  case tgl_sce_accepted:
-    tglf_fetch_int_tuple (P->encr_chat.exchange_key, DS_U->key->key, 64);
-  
-    SHA1 ((unsigned char *)P->encr_chat.exchange_key, 256, sha_buffer);
-    P->encr_chat.exchange_key_fingerprint = *(long long *)(sha_buffer + 12);
-    break;
-  case tgl_sce_committed:
-    memcpy (P->encr_chat.exchange_key, P->encr_chat.key, 256);
-    P->encr_chat.exchange_key_fingerprint = P->encr_chat.key_fingerprint;
-
-    tglf_fetch_int_tuple (P->encr_chat.key, DS_U->key->key, 64);
-  
-    SHA1 ((unsigned char *)P->encr_chat.key, 256, sha_buffer);
-    P->encr_chat.key_fingerprint = *(long long *)(sha_buffer + 12);
-    break;
-  case tgl_sce_confirmed:
-    P->encr_chat.exchange_state = tgl_sce_none;
-    if (P->encr_chat.exchange_state != tgl_sce_committed) {
-      memcpy (P->encr_chat.key, P->encr_chat.exchange_key, 256);
-      P->encr_chat.key_fingerprint = P->encr_chat.exchange_key_fingerprint;
-    }
-    break;
-  case tgl_sce_aborted:
-    P->encr_chat.exchange_state = tgl_sce_none;
-    if (P->encr_chat.exchange_state == tgl_sce_committed) {
-      memcpy (P->encr_chat.key, P->encr_chat.exchange_key, 256);
-      P->encr_chat.key_fingerprint = P->encr_chat.exchange_key_fingerprint;
-    }
-    break;
-  default:
-    assert (0);
-  }
-  return 0;
-}
-
-#define FETCH_COMBINATOR_FUNCTION(NAME) \
-  case CODE_ ## NAME:\
-    ok = fetch_comb_ ## NAME (TLS, DS_U); \
-    break; \
-    
-
-static void replay_log_event (struct tgl_state *TLS) {
-  assert (rptr < wptr);
-  int op = *rptr;
-
-  vlogprintf (E_DEBUG, "replay_log_event: log_pos=%"_PRINTF_INT64_"d, op=0x%08x\n", binlog_pos, op);
-
-  in_ptr = rptr;
-  in_end = wptr;
-  if (skip_type_any (TYPE_TO_PARAM (binlog_update)) < 0) {
-    vlogprintf (E_ERROR, "Can not replay at %"_PRINTF_INT64_"d (magic = 0x%08x)\n", binlog_pos, *rptr);
-    assert (0);
-  }
-  int *end = in_ptr;
-  in_end = in_ptr;
-  in_ptr = rptr;
-  struct tl_ds_binlog_update *DS_U = fetch_ds_type_binlog_update (TYPE_TO_PARAM (binlog_update));
-  assert (in_ptr == end);
-
-  int ok = -1;
-
-  switch (op) {
-  FETCH_COMBINATOR_FUNCTION (binlog_start)
-  FETCH_COMBINATOR_FUNCTION (binlog_dc_option)
-  FETCH_COMBINATOR_FUNCTION (binlog_dc_option_new)
-  FETCH_COMBINATOR_FUNCTION (binlog_auth_key)
-  FETCH_COMBINATOR_FUNCTION (binlog_default_dc)
-  FETCH_COMBINATOR_FUNCTION (binlog_dc_signed)
-  
-  FETCH_COMBINATOR_FUNCTION (binlog_our_id)
-
-  FETCH_COMBINATOR_FUNCTION (binlog_set_dh_params)
-  FETCH_COMBINATOR_FUNCTION (binlog_set_pts)
-  FETCH_COMBINATOR_FUNCTION (binlog_set_qts)
-  FETCH_COMBINATOR_FUNCTION (binlog_set_date)
-  FETCH_COMBINATOR_FUNCTION (binlog_set_seq)
-
-  FETCH_COMBINATOR_FUNCTION (binlog_user_new)
-  FETCH_COMBINATOR_FUNCTION (binlog_user_delete)
-
-  FETCH_COMBINATOR_FUNCTION (binlog_chat_new)
-  //FETCH_COMBINATOR_FUNCTION (binlog_chat_delete)
-
-  FETCH_COMBINATOR_FUNCTION (binlog_encr_chat_new)
-  FETCH_COMBINATOR_FUNCTION (binlog_encr_chat_delete)
-  FETCH_COMBINATOR_FUNCTION (binlog_chat_add_participant)
-  FETCH_COMBINATOR_FUNCTION (binlog_chat_del_participant)
-
-  FETCH_COMBINATOR_FUNCTION (binlog_message_new)
-  FETCH_COMBINATOR_FUNCTION (binlog_message_encr_new)
-  FETCH_COMBINATOR_FUNCTION (binlog_message_delete)
-  FETCH_COMBINATOR_FUNCTION (binlog_set_msg_id)
-
-  FETCH_COMBINATOR_FUNCTION (binlog_encr_chat_exchange_new)
-  
-  FETCH_COMBINATOR_FUNCTION (binlog_msg_update)
-  FETCH_COMBINATOR_FUNCTION (binlog_reset_authorization)
-  default:
-    vlogprintf (E_ERROR, "Unknown op 0x%08x\n", op);
-    assert (0);
-  }
-  assert (ok >= 0);
-
-  free_ds_type_binlog_update (DS_U, TYPE_TO_PARAM (binlog_update));
-  assert (in_ptr == end);
-  //assert (in_ptr == in_end);
-  binlog_pos += (in_ptr - rptr) * 4;
-  rptr = in_ptr;
-}
-
-static void create_new_binlog (struct tgl_state *TLS) {
-  clear_packet ();
-  //static int s[1000];
-
-  //packet_ptr = s;
-  out_int (CODE_binlog_start);
-  if (TLS->test_mode) {
-    out_int (CODE_binlog_dc_option);
-    out_int (1);
-    out_string ("");
-    out_string (TG_SERVER_TEST_1);
-    out_int (443);
-    out_int (CODE_binlog_dc_option);
-    out_int (2);
-    out_string ("");
-    out_string (TG_SERVER_TEST_2);
-    out_int (443);
-    out_int (CODE_binlog_dc_option);
-    out_int (3);
-    out_string ("");
-    out_string (TG_SERVER_TEST_3);
-    out_int (443);
-    out_int (CODE_binlog_default_dc);
-    out_int (2);
-  } else {
-    out_int (CODE_binlog_dc_option);
-    out_int (1);
-    out_string ("");
-    out_string (TG_SERVER_1);
-    out_int (443);
-    out_int (CODE_binlog_dc_option);
-    out_int (2);
-    out_string ("");
-    out_string (TG_SERVER_2);
-    out_int (443);
-    out_int (CODE_binlog_dc_option);
-    out_int (3);
-    out_string ("");
-    out_string (TG_SERVER_3);
-    out_int (443);
-    out_int (CODE_binlog_dc_option);
-    out_int (4);
-    out_string ("");
-    out_string (TG_SERVER_4);
-    out_int (443);
-    out_int (CODE_binlog_dc_option);
-    out_int (5);
-    out_string ("");
-    out_string (TG_SERVER_5);
-    out_int (443);
-    out_int (CODE_binlog_default_dc);
-    out_int (2);
-  }
-  
-#if defined(_MSC_VER) && _MSC_VER >= 1400
-  int fd = 0;
-  if(_sopen_s (&fd, TLS->binlog_name, _O_WRONLY | _O_EXCL | _O_CREAT, _SH_DENYNO, _S_IREAD | _S_IWRITE) != 0 ) {
-#else
-  int fd = open (TLS->binlog_name, O_WRONLY | O_EXCL | O_CREAT, 0600);
-  if (fd < 0) {
-#endif
-    perror ("Write new binlog");
-    exit (2);
-  }
-  assert (write (fd, packet_buffer, (packet_ptr - packet_buffer) * 4) == (packet_ptr - packet_buffer) * 4);
-  close (fd);
-}
-
-
-void tgl_replay_log (struct tgl_state *TLS) {
-  if (!TLS->binlog_enabled) { return; }
-#if defined(WIN32) || defined(_WIN32)
-  if (INVALID_FILE_ATTRIBUTES == GetFileAttributesA (TLS->binlog_name) && GetLastError () == ERROR_FILE_NOT_FOUND) {
-#else
-  if (access (TLS->binlog_name, F_OK) < 0) {
-#endif
-    printf ("No binlog found. Creating new one\n");
-    create_new_binlog (TLS);
-  }
-#if defined(_MSC_VER) && _MSC_VER >= 1400
-  int fd = 0;
-  if (_sopen_s(&fd, TLS->binlog_name, _O_RDONLY | _O_BINARY, _SH_DENYNO, _S_IREAD | _S_IWRITE) != 0) {
-#elif defined(WIN32) || defined(_WIN32)
-  int fd = open (TLS->binlog_name, O_RDONLY | O_BINARY);
-  if (fd < 0) {
-#else
-  int fd = open (TLS->binlog_name, O_RDONLY);
-  if (fd < 0) {
-#endif
-    perror ("binlog open");
-    exit (2);
-  }
-  int end = 0;
-  in_replay_log = 1;
-  while (1) {
-    if (!end && wptr - rptr < MAX_LOG_EVENT_SIZE / 4) {
-      if (wptr == rptr) {
-        wptr = rptr = binlog_buffer;
-      } else {
-        int x = wptr - rptr;
-        memcpy (binlog_buffer, rptr, 4 * x);
-        wptr -= (rptr - binlog_buffer);
-        rptr = binlog_buffer;
-      }
-      int l = (binlog_buffer + BINLOG_BUFFER_SIZE - wptr) * 4;
-      int k = read (fd, wptr, l);
-      if (k < 0) {
-        perror ("read binlog");
-        exit (2);
-      }
-      assert (!(k & 3));
-      if (k < l) { 
-        end = 1;
-      }
-      wptr += (k / 4);
-    }
-    if (wptr == rptr) { break; }
-    replay_log_event (TLS);
-  }
-  in_replay_log = 0;
-  close (fd);
-}
-
-//static int b_packet_buffer[PACKET_BUFFER_SIZE];
-
-void tgl_reopen_binlog_for_writing (struct tgl_state *TLS) {
-#if defined(_MSC_VER) && _MSC_VER >= 1400
-  if (_sopen_s (&TLS->binlog_fd, TLS->binlog_name, _O_WRONLY | _O_BINARY, _SH_DENYNO, _S_IREAD | _S_IWRITE) != 0) {
-#elif defined(WIN32) || defined(_WIN32)
-  TLS->binlog_fd = open (TLS->binlog_name, O_WRONLY | _O_BINARY);
-  if (TLS->binlog_fd < 0) {
-#else
-  TLS->binlog_fd = open (TLS->binlog_name, O_WRONLY);
-  if (TLS->binlog_fd < 0) {
-#endif
-    perror ("binlog open");
-    exit (2);
-  }
-  
-  assert (lseek (TLS->binlog_fd, binlog_pos, SEEK_SET) == binlog_pos);
-#if defined(WIN32) || defined(_WIN32)
-  HANDLE h = INVALID_HANDLE_VALUE;
-  DWORD size_lower, size_upper;
-  DWORD err = 0;
-  OVERLAPPED ovlp;
-  int flags = 0;
-
-  h = (HANDLE)_get_osfhandle(TLS->binlog_fd);
-  if (h == INVALID_HANDLE_VALUE) {
-    errno = EBADF;
-    goto error;
-  }
-
-  size_lower = GetFileSize (h, &size_upper);
-  if (size_lower == INVALID_FILE_SIZE) {
-    goto get_err;
-  }
-
-  memset (&ovlp, 0, sizeof ovlp);
-  flags |= LOCKFILE_EXCLUSIVE_LOCK | LOCKFILE_FAIL_IMMEDIATELY;
-
-  if (!LockFileEx (h, flags, 0, size_lower, size_upper, &ovlp)) {
-    goto get_err;
-  }
-  return;
-
-error:
-  perror ("get lock");
-  exit(2);
-
-get_err:
-  err = GetLastError();
-  switch (err)
-  {
-  case ERROR_LOCK_VIOLATION:
-	  errno = EAGAIN;
-	  break;
-  case ERROR_NOT_ENOUGH_MEMORY:
-	  errno = ENOMEM;
-	  break;
-  case ERROR_BAD_COMMAND:
-	  errno = EINVAL;
-	  break;
-  default:
-	  errno = err;
-  }
-  goto error;
-#else
-  if (flock (TLS->binlog_fd, LOCK_EX | LOCK_NB) < 0) {
-    perror ("get lock");
-    exit (2);
-  } 
-#endif
-}
-
-static void add_log_event (struct tgl_state *TLS, const int *data, int len) {
-  vlogprintf (E_DEBUG, "Add log event: magic = 0x%08x, len = %d\n", data[0], len);
-  assert (!(len & 3));
-  int *ev = talloc (len);
-  memcpy (ev, data, len);
-  rptr = (void *)ev;
-  wptr = rptr + (len / 4);
-  int *in = in_ptr;
-  int *end = in_end;
-  replay_log_event (TLS);
-  if (rptr != wptr) {
-    vlogprintf (E_ERROR, "Unread %"_PRINTF_INT64_"d ints. Len = %d\n", (long long)(wptr - rptr), len);
-    assert (rptr == wptr);
-  }
-  if (TLS->binlog_enabled) {
-    assert (TLS->binlog_fd > 0);
-    assert (write (TLS->binlog_fd, ev, len) == len);
-  }
-  tfree (ev, len);
-  in_ptr = in;
-  in_end = end;
-}
-
-void bl_do_dc_option_new (struct tgl_state *TLS, int flags, int id, const char *name, int l1, const char *ip, int l2, int port) {
-  struct tgl_dc *DC = TLS->DC_list[id];
-
-  if (DC) {
-    struct tgl_dc_option *O = DC->options[flags & 3];
-    while (O) {
-      if (!strncmp (O->ip, ip, l2)) {
-        return;
-      }
-      O = O->next;
-    }
-  }
-
-  clear_packet ();
-  out_int (CODE_binlog_dc_option_new);
-  out_int (flags);
-  out_int (id);
-
-  out_cstring (name, l1);
-  out_cstring (ip, l2);
-  out_int (port);
-
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_dc_option (struct tgl_state *TLS, int id, const char *name, int l1, const char *ip, int l2, int port) {
-  bl_do_dc_option_new (TLS, 0, id, name, l1, ip, l2, port);
-}
-
-void bl_do_set_working_dc (struct tgl_state *TLS, int num) {
-  int *ev = alloc_log_event (8);
-  ev[0] = CODE_binlog_default_dc;
-  ev[1] = num;
-  add_log_event (TLS, ev, 8);
-}
-
-void bl_do_dc_signed (struct tgl_state *TLS, int id) {
-  clear_packet ();
-  out_int (CODE_binlog_dc_signed);
-  out_int (id);  
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_set_our_id (struct tgl_state *TLS, int id) {
-  if (TLS->our_id) {
-    assert (TLS->our_id == id);
-    return;
-  }
-
-  clear_packet ();
-  out_int (CODE_binlog_our_id);
-  out_int (id);  
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_set_dh_params (struct tgl_state *TLS, int root, unsigned char prime[], int version) {
-  clear_packet ();
-  out_int (CODE_binlog_set_dh_params);
-  out_int (root);
-  out_ints ((void *)prime, 64);
-  out_int (version);
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_set_pts (struct tgl_state *TLS, int pts) {
-  if (TLS->locks & TGL_LOCK_DIFF) { return; }
-  if (pts <= TLS->pts) { return; }
-  
-  clear_packet ();
-  out_int (CODE_binlog_set_pts);
-  out_int (pts);
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_set_qts (struct tgl_state *TLS, int qts) {
-  if (TLS->locks & TGL_LOCK_DIFF) { return; }
-  if (qts <= TLS->qts) { return; }
-  
-  clear_packet ();
-  out_int (CODE_binlog_set_qts);
-  out_int (qts);
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_set_date (struct tgl_state *TLS, int date) {
-  if (TLS->locks & TGL_LOCK_DIFF) { return; }
-  if (date <= TLS->date) { return; }
-  
-  clear_packet ();
-  out_int (CODE_binlog_set_date);
-  out_int (date);
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_set_seq (struct tgl_state *TLS, int seq) {
-  if (TLS->locks & TGL_LOCK_DIFF) { return; }
-  if (seq <= TLS->seq) { return; }
-  
-  clear_packet ();
-  out_int (CODE_binlog_set_seq);
-  out_int (seq);
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_set_msg_id (struct tgl_state *TLS, struct tgl_message *M, int id) {
-  if (M->id == id) { return; }
-  
-  clear_packet ();
-  out_int (CODE_binlog_set_msg_id);
-  out_long (M->id);
-  out_int (id);
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_user_delete (struct tgl_state *TLS, struct tgl_user *U) {
-  if (U->flags & TGLUF_DELETED) { return; }
-
-  clear_packet ();
-  out_int (CODE_binlog_user_delete);
-  out_int (tgl_get_peer_id (U->id));
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_encr_chat_delete (struct tgl_state *TLS, struct tgl_secret_chat *U) {
-  if (!(U->flags & TGLPF_CREATED) || U->state == sc_deleted || U->state == sc_none) { return; }
-  
-  clear_packet ();
-  out_int (CODE_binlog_encr_chat_delete);
-  out_int (tgl_get_peer_id (U->id));
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_chat_add_user (struct tgl_state *TLS, struct tgl_chat *C, int version, int user, int inviter, int date) {
-  if (C->user_list_version >= version || !C->user_list_version) { return; }
-
-  clear_packet ();
-  out_int (CODE_binlog_chat_add_participant);
-  out_int (tgl_get_peer_id (C->id));
-  out_int (version);
-  out_int (user);
-  out_int (inviter);
-  out_int (date);
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_chat_del_user (struct tgl_state *TLS, struct tgl_chat *C, int version, int user) {
-  if (C->user_list_version >= version || !C->user_list_version) { return; }
-
-  clear_packet ();
-  out_int (CODE_binlog_chat_del_participant);
-  out_int (tgl_get_peer_id (C->id));
-  out_int (version);
-  out_int (user);
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_create_message_new (struct tgl_state *TLS, long long id, int *from_id, int *to_type, int *to_id, int *fwd_from_id, int *fwd_date, int *date, const char *message, int message_len, struct tl_ds_message_media *media, struct tl_ds_message_action *action, int *reply_id, struct tl_ds_reply_markup *reply_markup, int flags) {
-  clear_packet ();
-  assert (!(flags & 0xfffe0000));
-
-  out_int (CODE_binlog_message_new);
-  int *flags_p = packet_ptr;
-  out_int (flags);
-  assert (*flags_p == flags);
-
-  out_long (id);
-  
-  if (from_id) {
-    assert (to_type);
-    assert (to_id);
-    (*flags_p) |= (1 << 17);
-    out_int (*from_id);
-    out_int (*to_type);
-    out_int (*to_id);
-  }
-
-  if (fwd_from_id) {
-    assert (fwd_date);
-    (*flags_p) |= (1 << 18);
-    out_int (*fwd_from_id);
-    out_int (*fwd_date);
-  }
-  
-  if (date) {
-    (*flags_p) |= (1 << 19);
-    out_int (*date);
-  }
-
-  if (message) {
-    (*flags_p) |= (1 << 20);
-    out_cstring (message, message_len);
-  }
-
-  if (media) {
-    (*flags_p) |= (1 << 21);
-    store_ds_type_message_media (media, TYPE_TO_PARAM (message_media));
-  }
-
-  if (action) {
-    (*flags_p) |= (1 << 22);
-
-    store_ds_type_message_action (action, TYPE_TO_PARAM (message_action));
-  }
-
-  if (reply_id) {
-    (*flags_p) |= (1 << 23);
-    out_int (*reply_id);
-  }
-
-  if (reply_markup) {
-    (*flags_p) |= (1 << 24);
-    store_ds_type_reply_markup (reply_markup, TYPE_TO_PARAM (reply_markup));
-  }
-
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_create_message_encr_new (struct tgl_state *TLS, long long id, int *from_id, int *to_type, int *to_id, int *date, const char *message, int message_len, struct tl_ds_decrypted_message_media *media, struct tl_ds_decrypted_message_action *action, struct tl_ds_encrypted_file *file, int flags) {
-  clear_packet ();
-  assert (!(flags & 0xfffe0000));
-
-  out_int (CODE_binlog_message_encr_new);
-  int *flags_p = packet_ptr;
-  out_int (flags);
-  assert (flags & TGLMF_ENCRYPTED);
-  assert (*flags_p == flags);
-
-  out_long (id);
-  
-  if (from_id) {
-    assert (to_id);
-    assert (to_type);
-    (*flags_p) |= (1 << 17);
-    out_int (*from_id);
-    out_int (*to_type);
-    out_int (*to_id);
-  }
-
-  if (date) {
-    (*flags_p) |= (1 << 19);
-    out_int (*date);
-  }
-  
-  if (message) {
-    (*flags_p) |= (1 << 20);
-    out_cstring (message, message_len);
-  }
-
-  if (media) {
-    (*flags_p) |= (1 << 21);
-    store_ds_type_decrypted_message_media (media, TYPE_TO_PARAM (decrypted_message_media));
-  }
-
-  if (action) {
-    (*flags_p) |= (1 << 22);
-    store_ds_type_decrypted_message_action (action, TYPE_TO_PARAM (decrypted_message_action));
-  }
-  
-  if (file) {
-    (*flags_p) |= (1 << 23);
-    store_ds_type_encrypted_file (file, TYPE_TO_PARAM (encrypted_file));
-  }
-
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_message_delete (struct tgl_state *TLS, struct tgl_message *M) {
-  clear_packet ();
-  out_int (CODE_binlog_message_delete);
-  out_long (M->id);
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_msg_update (struct tgl_state *TLS, long long id) {
-  clear_packet ();
-  out_int (CODE_binlog_msg_update);
-  out_long (id);
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_reset_authorization (struct tgl_state *TLS)  {
-  clear_packet ();
-  out_int (CODE_binlog_reset_authorization);
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_encr_chat_exchange_new (struct tgl_state *TLS, struct tgl_secret_chat *E, long long *exchange_id, const void *key, int *state) {
-  clear_packet ();
-  
-  out_int (CODE_binlog_encr_chat_exchange_new);
-  out_int (tgl_get_peer_id (E->id));
-
-  int *flags_p = packet_ptr;
-  out_int (0);
-  
-  if (exchange_id) {
-    *flags_p |= (1 << 17);
-    out_long (*exchange_id);
-  }
-
-  if (key) {
-    *flags_p |= (1 << 18);
-    out_ints ((void *)key, 64);
-  }
-
-  if (state) {
-    *flags_p |= (1 << 19);
-    out_int (*state);
-  }
-  add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-}
-
-void bl_do_set_auth_key (struct tgl_state *TLS, int num, unsigned char *buf) {
-  int *ev = alloc_log_event (8 + 8 + 256);
-  ev[0] = CODE_binlog_auth_key;
-  ev[1] = num;
-  //*(long long *)(ev + 2) = fingerprint;
-  memcpy (ev + 2, buf, 256);
-  add_log_event (TLS, ev, 8 + 256);
-}
-
-void bl_do_user_new (struct tgl_state *TLS, int id, long long *access_hash, const char *first_name, int first_name_len, const char *last_name, int last_name_len, const char *phone, int phone_len, const char *username, int username_len, struct tl_ds_photo *photo, const char *real_first_name, int real_first_name_len, const char *real_last_name, int real_last_name_len, struct tl_ds_user_profile_photo *profile_photo, int *last_read_in, int *last_read_out, struct tl_ds_bot_info *bot_info, int flags) {
-  tgl_peer_t *PP = tgl_peer_get (TLS, TGL_MK_USER (id));
-  struct tgl_user *P = &PP->user;
-
-  if (flags == TGL_FLAGS_UNCHANGED) {
-    flags = P->flags & 0xffff;
-  }
-
-  clear_packet ();
-  out_int (CODE_binlog_user_new);
-  
-  int *flags_p = packet_ptr;
-  
-  assert (!(flags & 0xfffe0000));
-  out_int (flags);
-  out_int (id);
- 
-  if (access_hash) {
-    if (!P || P->access_hash != *access_hash) {
-      out_long (*access_hash);
-      (*flags_p) |= (1 << 17);
-    }
-  }
- 
-  if (first_name) {
-    if (!P || !P->first_name || !P->last_name || mystreq1 (P->first_name, first_name, first_name_len) || mystreq1 (P->last_name, last_name, last_name_len)) {
-      out_cstring (first_name, first_name_len);
-      out_cstring (last_name, last_name_len);
-      
-      (*flags_p) |= (1 << 18);
-    }
-  }
-
-  if (phone) {
-    if (!P || !P->phone || mystreq1 (P->phone, phone, phone_len)) {
-      out_cstring (phone, phone_len);
-      (*flags_p) |= (1 << 19);
-    }
-  }
-
-  if (username) {
-    if (!P || !P->username || mystreq1 (P->username, username, username_len)) {
-      out_cstring (username, username_len);
-      (*flags_p) |= (1 << 20);
-    }
-  }
-
-  if (photo) {
-    if (!P || !P->photo || P->photo->id != DS_LVAL (photo->id)) {
-      store_ds_type_photo (photo, TYPE_TO_PARAM (photo));
-      (*flags_p) |= (1 << 21);
-    }
-  }
-
-  if (real_first_name) {
-    assert (real_last_name);
-    if (!P || !P->real_first_name || !P->real_last_name || mystreq1 (P->real_first_name, real_first_name, real_first_name_len) || mystreq1 (P->real_last_name, real_last_name, real_last_name_len)) {
-      out_cstring (real_first_name, real_first_name_len);
-      out_cstring (real_last_name, real_last_name_len);
-      
-      (*flags_p) |= (1 << 22);
-    }
-  }
-
-  if (profile_photo) {
-    if (!P || P->photo_id != DS_LVAL (profile_photo->photo_id)) {
-      store_ds_type_user_profile_photo (profile_photo, TYPE_TO_PARAM (user_profile_photo));
-      (*flags_p) |= (1 << 23);
-    }
-  }
-
-  if (last_read_in) {
-    if (!P || P->last_read_in < *last_read_in) {
-      out_int (*last_read_in);
-      (*flags_p) |= (1 << 24);
-    }
-  }
-
-  if (last_read_out) {
-    if (!P || P->last_read_out < *last_read_out) {
-      out_int (*last_read_out);
-      (*flags_p) |= (1 << 25);
-    }
-  }
-
-  if (bot_info) {
-    if (!P || !P->bot_info || P->bot_info->version != DS_LVAL (bot_info->version)) {
-      store_ds_type_bot_info (bot_info, TYPE_TO_PARAM (bot_info));
-      (*flags_p) |= (1 << 26);
-    }
-  }
-  
-  if (((*flags_p) & 0xffff0000) || !P || (P->flags & 0xffff) != flags) {
-    add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-  }
-}
-
-void bl_do_chat_new (struct tgl_state *TLS, int id, const char *title, int title_len, int *user_num, int *date, int *version, struct tl_ds_vector *participants, struct tl_ds_chat_photo *chat_photo, struct tl_ds_photo *photo, int *admin, int *last_read_in, int *last_read_out, int flags) {
-  tgl_peer_t *PP = tgl_peer_get (TLS, TGL_MK_CHAT (id));
-  struct tgl_chat *P = &PP->chat;
-
-  if (flags == TGL_FLAGS_UNCHANGED) {
-    flags = P ? (P->flags & 0xffff) : 0;
-  }
-
-  clear_packet ();
-  out_int (CODE_binlog_chat_new);
-  
-  int *flags_p = packet_ptr;
-  
-  assert (!(flags & 0xfffe0000));
-  out_int (flags);
-  out_int (id);
-
-  if (title) {
-    if (!P || !P->title || mystreq1 (P->title, title, title_len)) {
-      out_cstring (title, title_len);
-      (*flags_p) |= (1 << 17);
-    }
-  }
-
-  if (user_num) {
-    if (!P || P->users_num != *user_num) {
-      out_int (*user_num);
-      (*flags_p) |= (1 << 18);
-    }
-  }
-
-  if (date) {
-    if (!P || P->date != *date) {
-      out_int (*date);
-      (*flags_p) |= (1 << 19);
-    }
-  }
-
-  if (version) {
-    assert (participants);
-    if (!P || *version != P->version) {
-      out_int (*version);
-      store_ds_type_vector (participants, TYPE_TO_PARAM_1 (vector, TYPE_TO_PARAM (chat_participant)));
-      (*flags_p) |= (1 << 20);
-    }
-  }
-
-  if (chat_photo && chat_photo->photo_big) {
-    if (!P || DS_LVAL (chat_photo->photo_big->secret) != P->photo_big.secret) {
-      store_ds_type_chat_photo (chat_photo, TYPE_TO_PARAM (chat_photo));
-      (*flags_p) |= (1 << 21);
-    }
-  }
-
-  if (photo) {
-    if (!P || !P->photo || P->photo->id != DS_LVAL (photo->id)) {
-      store_ds_type_photo (photo, TYPE_TO_PARAM (photo));
-      (*flags_p) |= (1 << 22);
-    }
-  }
-
-  if (admin) {
-    if (!P || P->admin_id != *admin) {
-      out_int (*admin);
-      (*flags_p) |= (1 << 23);
-    }
-  }
-
-  if (last_read_in) {
-    if (!P || P->last_read_in < *last_read_in) {
-      out_int (*last_read_in);
-      (*flags_p) |= (1 << 24);
-    }
-  }
-
-  if (last_read_out) {
-    if (!P || P->last_read_out < *last_read_out) {
-      out_int (*last_read_out);
-      (*flags_p) |= (1 << 25);
-    }
-  }
-  
-  if (((*flags_p) & 0xffff0000) || !P || (P->flags & 0xffff) != flags)   {
-    add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-  }
-}
-
-void bl_do_encr_chat_new (struct tgl_state *TLS, int id, long long *access_hash, int *date, int *admin, int *user_id, void *key, void *g_key, void *first_key_id, int *state, int *ttl, int *layer, int *in_seq_no, int *last_in_seq_no, int *out_seq_no, long long *key_fingerprint, int flags) {
-  tgl_peer_t *PP = tgl_peer_get (TLS, TGL_MK_ENCR_CHAT (id));
-  struct tgl_secret_chat *P = PP ? &PP->encr_chat : NULL;
-
-  if (flags == TGL_FLAGS_UNCHANGED) {
-    flags = P->flags & 0xffff;
-  }
-
-  clear_packet ();
-  out_int (CODE_binlog_encr_chat_new);
-  
-  int *flags_p = packet_ptr;
-  
-  assert (!(flags & 0xfffe0000));
-  out_int (flags);
-  out_int (id);
-
-  if (access_hash) {
-    if (!P || P->access_hash != *access_hash) {
-      out_long (*access_hash);
-      (*flags_p) |= (1 << 17);
-    }
-  }
-
-  if (date) {
-    if (!P || P->date != *date) {
-      out_int (*date);
-      (*flags_p) |= (1 << 18);
-    }
-  }
-
-  if (admin) {
-    if (!P || P->admin_id != *admin) {
-      out_int (*admin);
-      (*flags_p) |= (1 << 19);
-    }
-  }
-
-  if (user_id) {
-    if (!P || P->user_id != *user_id) {
-      out_int (*user_id);
-      (*flags_p) |= (1 << 20);
-    }
-  }
-
-  if (key) {
-    if (!P || memcmp (P->key, key, 256)) {
-      out_ints (key, 64);
-      (*flags_p) |= (1 << 21);
-    }
-  }
-
-  if (g_key) {
-    if (!P || !P->g_key || memcmp (P->g_key, g_key, 256)) {
-      out_ints (g_key, 64);
-      (*flags_p) |= (1 << 22);
-    }
-  }
-
-  if (state) {
-    if (!P || (int)P->state != *state) {
-      out_int (*state);
-      (*flags_p) |= (1 << 23);
-    }
-  }
-
-  if (ttl) {
-    if (!P || P->ttl != *ttl) {
-      out_int (*ttl);
-      (*flags_p) |= (1 << 24);
-    }
-  }
-
-  if (layer) {
-    if (!P || P->layer != *layer) {
-      out_int (*layer);
-      (*flags_p) |= (1 << 25);
-    }
-  }
-
-  if (in_seq_no || last_in_seq_no || out_seq_no) {
-    if (!P || (in_seq_no && P->in_seq_no != *in_seq_no) ||
-              (out_seq_no && P->out_seq_no != *out_seq_no) || 
-              (last_in_seq_no && P->last_in_seq_no != *last_in_seq_no)) {
-      
-      out_int (in_seq_no ? *in_seq_no : P ? P->in_seq_no : 0);
-      out_int (last_in_seq_no ? *last_in_seq_no : P ? P->last_in_seq_no : 0);
-      out_int (out_seq_no ? *out_seq_no : P ? P->out_seq_no : 0);
-      (*flags_p) |= (1 << 26);
-    }
-  }
-
-  if (key_fingerprint) {
-    if (!P || P->key_fingerprint != *key_fingerprint) {
-      out_long (*key_fingerprint);
-      (*flags_p) |= (1 << 27);
-    }
-  }
- 
-  if (((*flags_p) & 0xffff0000) || !P || (P->flags & 0xffff) != flags)   {
-    add_log_event (TLS, packet_buffer, 4 * (packet_ptr - packet_buffer));
-  }
-}