Merge branch 'master' into stable

.travis.yml

@@ -1,9 +1,8 @@
 language: java
-jdk:
-  - oraclejdk8
-  - oraclejdk9
-  - openjdk7
 
+branches:
+  only:
+    - master
 before_cache:
   - rm -f  $HOME/.gradle/caches/modules-2/modules-2.lock
   - rm -fr $HOME/.gradle/caches/*/plugin-resolution/

Dockerfile

@@ -1,6 +1,6 @@
 FROM openjdk:8
 
-ENV JAR_VERSION 1.1.1
+ENV JAR_VERSION 1.1.2
 ENV JAR_DOWNLOAD_URL https://github.com/fabianonline/telegram_backup/releases/download/${JAR_VERSION}/telegram_backup.jar
 
 RUN apt-get update -y && apt-get install -y curl && \

src/main/kotlin/de/fabianonline/telegram_backup/CommandLineController.kt

@@ -143,6 +143,8 @@ class CommandLineController {
 		} catch (e: Exception) {
 			e.printStackTrace()
 			logger.error("Exception caught!", e)
+			// If we encountered an exception, we definitely don't want to start the daemon mode now.
+			CommandLineOptions.cmd_daemon = false
 		} finally {
 			if (CommandLineOptions.cmd_daemon) {
 				handler.activate()

src/main/kotlin/de/fabianonline/telegram_backup/Config.kt

@@ -46,7 +46,7 @@ object Config {
 	
 	var DEFAULT_PAGINATION = 5_000
 
-	val SECRET_GMAPS = "AI" + "za" + "SyD_2" + "c0DKsfCXqgG" + "z0Sip7KHsBCU-paBfeJk"
+	val SECRET_GMAPS = "AI" + "za" + "SyD_" + "c0DKsfCXqgG" + "z0Sip7KHsBCU-paBfeJk"
 	
 	init {
 		val p = Properties()

src/main/kotlin/de/fabianonline/telegram_backup/DatabaseUpdates.kt

@@ -381,21 +381,30 @@ internal class DB_Update_9(conn: Connection, db: Database) : DatabaseUpdate(conn
 	override fun _doUpdate() {
 		val logger = LoggerFactory.getLogger(DB_Update_9::class.java)
 		println("    Updating supergroup channel message data (this might take some time)...")
-		val rs = stmt.executeQuery("SELECT id, data, source_id FROM messages WHERE source_type='channel' and sender_id IS NULL and api_layer=53")
-		val messages = TLVector<TLAbsMessage>()
-		val messages_to_delete = mutableListOf<Int>()
+		val count = db.queryInt("SELECT COUNT(*) FROM messages WHERE source_type='channel' and sender_id IS NULL and api_layer=53")
+		logger.debug("Found $count candidates for conversion")
+		val limit = 5000
+		var offset = 0
 		var i = 0
-		while (rs.next()) {
-			i++
-			val msg = Database.bytesToTLMessage(rs.getBytes(2))
-			if (msg!!.getFromId() != null) {
-				messages.add(msg)
-				messages_to_delete.add(rs.getInt(1))
+		while (offset + 1 < count) {
+			logger.debug("Querying with limit $limit and offset $offset")
+			val rs = stmt.executeQuery("SELECT id, data, source_id FROM messages WHERE source_type='channel' and sender_id IS NULL and api_layer=53 LIMIT ${limit} OFFSET ${offset}")
+			val messages = TLVector<TLAbsMessage>()
+			val messages_to_delete = mutableListOf<Int>()
+			while (rs.next()) {
+				val msg = Database.bytesToTLMessage(rs.getBytes(2))
+				if (msg!!.getFromId() != null) {
+					i++
+					messages.add(msg)
+					messages_to_delete.add(rs.getInt(1))
+				}
 			}
+			db.saveMessages(messages, api_layer=53, source_type=MessageSource.SUPERGROUP)
+			execute("DELETE FROM messages WHERE id IN (" + messages_to_delete.joinToString() + ")")
+			
+			offset += limit
 		}
-		logger.info("Converted ${messages.size} of ${i} messages.")
-		db.saveMessages(messages, api_layer=53, source_type=MessageSource.SUPERGROUP)
-		execute("DELETE FROM messages WHERE id IN (" + messages_to_delete.joinToString() + ")")
+		logger.info("Converted ${i} of ${count} messages.")
 		println("    Cleaning up the database (this might also take some time, sorry)...")
 		execute("VACUUM")
 	}