puppet/example-config.json

@@ -10,5 +10,6 @@
 	"cycle_delay": 5000,
 	"use_xdotool": false,
 	"jiggle_delay": 20000,
-	"devtools": false
+	"devtools": false,
+	"timeZone": "Asia/Taipei"
 }

puppet/package.json

@@ -19,9 +19,10 @@
   },
   "dependencies": {
     "arg": "^4.1.3",
-    "chrono-node": "^2.1.7",
+    "chrono-node": "^2.3.8",
-    "systemd-daemon": "^1.1.2",
+    "dayjs": "^1.11.3",
-    "puppeteer": "9.1.1"
+    "puppeteer": "9.1.1",
+    "systemd-daemon": "^1.1.2"
   },
   "devDependencies": {
     "babel-eslint": "^10.1.0",

puppet/src/contentscript.js

@@ -22,6 +22,7 @@
  * @return {Promise<Date>}
  */
 window.__chronoParseDate = function (text, ref, option) {}
+window.__tryParseDateByTimeZone = function (text, ref, option) { }
 /**
  * @param {...string} text - The objects to log.
  * @return {Promise<void>}
@@ -143,7 +144,7 @@ class MautrixController {
 	 * @private
 	 */
 	async _tryParseDate(text, ref, option) {
-		const parsed = await window.__chronoParseDate(text, ref, option)
+		const parsed = await window.__tryParseDateByTimeZone(text, ref, option)
 		return parsed ? new Date(parsed) : null
 	}
 

puppet/src/main.js

@@ -42,7 +42,7 @@ MessagesPuppeteer.extensionDir = config.extension_dir || MessagesPuppeteer.exten
 MessagesPuppeteer.cycleDelay = config.cycle_delay || MessagesPuppeteer.cycleDelay
 MessagesPuppeteer.useXdotool = config.use_xdotool || MessagesPuppeteer.useXdotool
 MessagesPuppeteer.jiggleDelay = config.jiggle_delay || MessagesPuppeteer.jiggleDelay
-
+MessagesPuppeteer.timeZone = config.timeZone || MessagesPuppeteer.timeZone
 const api = new PuppetAPI(config.listen)
 
 function stop() {

puppet/src/puppet.js

@@ -22,6 +22,9 @@ import chrono from "chrono-node"
 
 import TaskQueue from "./taskqueue.js"
 import { sleep } from "./util.js"
+import dayjs from 'dayjs';
+import utc from 'dayjs/plugin/utc.js';
+import timezone from 'dayjs/plugin/timezone.js';
 
 export default class MessagesPuppeteer {
 	static profileDir = "./profiles"
@@ -34,7 +37,7 @@ export default class MessagesPuppeteer {
 	static viewport = { width: 960, height: 840 }
 	static url = undefined
 	static extensionDir = "extension_files"
-
+	static timeZone = "Asia/Taipei"
 	/**
 	 *
 	 * @param {string} id
@@ -79,7 +82,7 @@ export default class MessagesPuppeteer {
 		const args = [
 			`--disable-extensions-except=${MessagesPuppeteer.extensionDir}`,
 			`--load-extension=${MessagesPuppeteer.extensionDir}`,
-			`--window-size=${MessagesPuppeteer.viewport.width},${MessagesPuppeteer.viewport.height+120}`,
+			`--window-size=${MessagesPuppeteer.viewport.width},${MessagesPuppeteer.viewport.height + 120}`,
 		]
 		if (MessagesPuppeteer.noSandbox) {
 			args.push(`--no-sandbox`)
@@ -142,7 +145,7 @@ export default class MessagesPuppeteer {
 		await this.page.exposeFunction("__mautrixLoggedOut",
 			this._onLoggedOut.bind(this))
 		await this.page.exposeFunction("__chronoParseDate", chrono.parseDate)
-
+		await this.page.exposeFunction("__tryParseDateByTimeZone", this._tryParseDateByTimeZone.bind(this))
 		// NOTE Must *always* re-login on a browser session, so no need to check if already logged in
 		this.loginRunning = false
 		this.loginCancelled = false
@@ -150,6 +153,28 @@ export default class MessagesPuppeteer {
 		this.log("Startup complete")
 	}
 
+	async _tryParseDateByTimeZone(text, ref, option) {
+		const localTz = MessagesPuppeteer.timeZone // This is the ISO string
+		dayjs.extend(utc);
+		dayjs.extend(timezone);
+		const localTime = dayjs.tz(new Date(), localTz)
+		const localOffset = localTime.utcOffset() // returns in minutes
+	
+		const custom = chrono.casual.clone()
+		custom.refiners.push({
+		  refine: (results) => {
+			Array.from(results).forEach((result) => {
+			  // Returns the time with the offset in included (must use minutes)
+			  result.start.imply('timezoneOffset', localOffset)
+			  result.end && result.end.imply('timezoneOffset', localOffset)
+			})
+			return results
+		  }})
+		const parsed = custom.parseDate(text, ref, option)
+		this.log(`parsed ${parsed}`)
+		return parsed
+	}
+
 	async _preparePage(navigateTo) {
 		await this.page.bringToFront()
 		if (navigateTo) {
@@ -196,7 +221,7 @@ export default class MessagesPuppeteer {
 	 * @param {string} text                - The text to input.
 	 */
 	async _enterText(inputElement, text) {
-		await inputElement.click({clickCount: 3})
+		await inputElement.click({ clickCount: 3 })
 		await inputElement.type(text)
 	}
 
@@ -218,7 +243,7 @@ export default class MessagesPuppeteer {
 				const qrButton = await this.page.waitForSelector("#login_qr_btn")
 				await qrButton.click()
 
-			const qrElement = await this.page.waitForSelector("#login_qrcode_area div[title]", {visible: true})
+				const qrElement = await this.page.waitForSelector("#login_qrcode_area div[title]", { visible: true })
 				const currentQR = await this.page.evaluate(element => element.title, qrElement)
 				this._receiveQRChange(currentQR)
 
@@ -239,7 +264,7 @@ export default class MessagesPuppeteer {
 				const emailButton = await this.page.waitForSelector("#login_email_btn")
 				await emailButton.click()
 
-			await this.page.waitForSelector("#login_email_area", {visible: true})
+				await this.page.waitForSelector("#login_email_area", { visible: true })
 				this.login_email = login_data["email"]
 				this.login_password = login_data["password"]
 				await this._sendEmailCredentials()
@@ -280,12 +305,12 @@ export default class MessagesPuppeteer {
 		}
 
 		const result = await Promise.race([
-			() => this.page.waitForSelector("#mainApp:not(.MdNonDisp)", {timeout: 2000})
+			() => this.page.waitForSelector("#mainApp:not(.MdNonDisp)", { timeout: 2000 })
 				.then(value => {
 					loginSuccess = true
 					return value
 				}),
-			() => this.page.waitForSelector("#login_incorrect", {visible: true, timeout: 2000})
+			() => this.page.waitForSelector("#login_incorrect", { visible: true, timeout: 2000 })
 				.then(value => this.page.evaluate(element => element?.innerText, value)),
 			() => this._waitForLoginCancel(),
 		].map(promiseFn => cancelableResolve(promiseFn)))
@@ -320,7 +345,7 @@ export default class MessagesPuppeteer {
 						&& (text.endsWith("100%") || text.endsWith("NaN%"))
 					// TODO Sometimes it gets stuck at 99%...??
 				},
-				{timeout: 10000}, // Assume 10 seconds is long enough
+				{ timeout: 10000 }, // Assume 10 seconds is long enough
 				messageSyncElement)
 		} catch (err) {
 			//this._sendLoginFailure(`Failed to sync: ${err}`)
@@ -582,7 +607,7 @@ export default class MessagesPuppeteer {
 		// - the most recently-sent own message is not fully read
 		let chatIDToSync
 		for (let i = 0, n = chatList.length; i < n; i++) {
-			const chatListItem = chatList[(i+offset) % n]
+			const chatListItem = chatList[(i + offset) % n]
 
 			if (chatListItem.notificationCount > 0) {
 				// Chat has unread notifications, so don't view it
@@ -693,8 +718,8 @@ export default class MessagesPuppeteer {
 		await this._interactWithPage(async () => {
 			this.log("Opening settings view")
 			await this.page.click("button.mdGHD01SettingBtn")
-			await this.page.waitForSelector("#context_menu li#settings", {visible: true}).then(e => e.click())
+			await this.page.waitForSelector("#context_menu li#settings", { visible: true }).then(e => e.click())
-			await this.page.waitForSelector("#settings_contents", {visible: true})
+			await this.page.waitForSelector("#settings_contents", { visible: true })
 
 			this.log("Getting own profile info")
 			ownProfile = {
@@ -712,7 +737,7 @@ export default class MessagesPuppeteer {
 
 			const backSelector = "#label_setting button"
 			await this.page.click(backSelector)
-			await this.page.waitForSelector(backSelector, {visible: false})
+			await this.page.waitForSelector(backSelector, { visible: false })
 		})
 		return ownProfile
 	}
@@ -729,6 +754,41 @@ export default class MessagesPuppeteer {
 		return `#joined_group_list_body > li[data-chatid="${id}"]`
 	}
 
+	_contactCountSelector() {
+		return `#contact_wrap_friends .MdLFT04Head._contactlist_header span[id=contact_friend_count]`
+	}
+
+	async _getWholeContactResults(page, distance) {
+		await page.bringToFront()
+		await page.waitForSelector("#contact_wrap_friends > ul.MdCMN03List")
+		const contactTotalCount = 0
+		this.log(` distance  is  ${distance}`)
+		let incred = 0
+		const element = await page.$(this._contactCountSelector())
+		const foundContactCount = await element.evaluate(
+			element => {
+				return Number.parseInt(element?.innerText) || 0
+			})
+		this.log(` contact_friend_count  is  ${foundContactCount}`)
+		//infiniting contact  list scrolling
+		while (incred <= distance) {
+			if (foundContactCount <= contactTotalCount) {
+				return
+			}
+			incred += 100
+			this.log(`scrollPosition  at  ${incred}/${distance}`)
+			await page.evaluate(d => {
+				const scrollableSection = document.querySelector("#contact_mode_contact_list");
+				scrollableSection.scrollTop = 300 + scrollableSection.offsetHeight + d;
+			}, incred);
+
+		}
+		const $lis = await page.$$("#contact_wrap_friends > ul.MdCMN03List >li")
+		//lookup lazy loading count
+		const lis = $lis.slice(contactTotalCount, Math.Infinity)
+		contactTotalCount = $lis.length
+	}
+
 	async _switchChat(chatID, forceView = false) {
 		// TODO Allow passing in an element directly
 		this.log(`Switching to chat ${chatID}`)
@@ -777,7 +837,30 @@ export default class MessagesPuppeteer {
 					}
 					chatItem = await this.page.$(this._groupItemSelector(chatID))
 				} else {
+					needRealClick = true
+					const unselectedTabButton = await this.page.$(`#leftSide li[data-type=friends_list] > button:not(.ExSelected)`)
+					if (unselectedTabButton) {
+						switchedTabs = true
+						await unselectedTabButton.evaluate(e => e.click())
+						await this.page.waitForSelector("#wrap_contact_list > div.MdScroll")
+
+						let ulstyleheight = await this.page.evaluate(() => {
+							const ulList = document.querySelector('#contact_wrap_friends > ul.MdCMN03List')
+							return getComputedStyle(ulList).getPropertyValue("height")
+						})
+						const leg = parseInt(ulstyleheight, 10)
+						this.log(`found contact_wrap_friends height is ${leg}px`)
+						this.log(`starting to scroll to buttom`)
+						await this._getWholeContactResults(this.page, leg)
+
+						this.log(`finished to scroll to buttom`)
+					}
+					await this.page.waitForTimeout(300)
 					chatItem = await this.page.$(this._friendItemSelector(chatID))
+					this.log(`Chat ${chatID} not in recents list, so bot is creating a new chat`)
+					await this._interactWithPage(async () => {
+						await chatItem.click()
+					})
 				}
 
 				if (!chatItem) {
@@ -805,7 +888,7 @@ export default class MessagesPuppeteer {
 					this.log(`Waiting for chat header title to be "${chatName}"`)
 					await this.page.waitForFunction(
 						isCorrectChatVisible,
-						{polling: "mutation", timeout: 1000},
+						{ polling: "mutation", timeout: 1000 },
 						chatName)
 				})
 			if (switchedTabs) {
@@ -825,13 +908,13 @@ export default class MessagesPuppeteer {
 						this.log("Clicking chat header to show detail area")
 						await this.page.click("#_chat_header_area > .mdRGT04Link")
 						this.log("Waiting for detail area")
-						await this.page.waitForSelector("#_chat_detail_area > .mdRGT02Info", {timeout: 1000})
+						await this.page.waitForSelector("#_chat_detail_area > .mdRGT02Info", { timeout: 1000 })
 					})
 			})
 
 			this.log("Waiting for any item to appear in chat")
 			try {
-				await this.page.waitForSelector("#_chat_room_msg_list div", {timeout: 2000})
+				await this.page.waitForSelector("#_chat_room_msg_list div", { timeout: 2000 })
 
 				this.log("Waiting for chat to stabilize")
 				await this.page.evaluate(() => window.__mautrixController.waitForMessageListStability())
@@ -852,7 +935,7 @@ export default class MessagesPuppeteer {
 
 	async _getChatInfoUnsafe(chatID, forceView) {
 		// TODO Commonize this
-		let [isDirect, isGroup, isRoom] = [false,false,false]
+		let [isDirect, isGroup, isRoom] = [false, false, false]
 		switch (chatID.charAt(0)) {
 			case "u":
 				isDirect = true
@@ -924,7 +1007,7 @@ export default class MessagesPuppeteer {
 		for (const participant of participants) {
 			this.log(JSON.stringify(participant))
 		}
-		return {participants, ...chatListInfo}
+		return { participants, ...chatListInfo }
 	}
 
 	// TODO Catch "An error has occurred" dialog
@@ -951,7 +1034,7 @@ export default class MessagesPuppeteer {
 					await input.press("Enter")
 					await this.page.waitForFunction(
 						e => e.innerText == "",
-						{timeout: 500},
+						{ timeout: 500 },
 						input)
 				})
 		})
@@ -1043,14 +1126,14 @@ export default class MessagesPuppeteer {
 		// Sync receipts seen from newly-synced messages
 		// TODO When user leaves, clear the read-by count for the old number of other participants
 		let minCountToFind = 1
-		for (let i = messages.length-1; i >= 0; i--) {
+		for (let i = messages.length - 1; i >= 0; i--) {
 			const message = messages[i]
 			if (!message.is_outgoing) {
 				continue
 			}
 			const count = message.receipt_count
 			if (count >= minCountToFind && message.id > (receiptMap.get(count) || 0)) {
-				minCountToFind = count+1
+				minCountToFind = count + 1
 				receiptMap.set(count, message.id)
 			}
 			// TODO Early exit when count == num other participants
@@ -1182,7 +1265,7 @@ export default class MessagesPuppeteer {
 	}
 
 	async _syncChat(chatID) {
-		const {messages, receipts} = await this._getMessagesUnsafe(chatID)
+		const { messages, receipts } = await this._getMessagesUnsafe(chatID)
 
 		if (messages.length == 0) {
 			this.log("No new messages found in", chatID)
@@ -1219,7 +1302,7 @@ export default class MessagesPuppeteer {
 
 		this.log(`Received read receipt ${receipt_id} (since ${prevReceiptID}) for chat ${chat_id}`)
 		if (this.client) {
-			this.client.sendReceipt({chat_id: chat_id, id: receipt_id})
+			this.client.sendReceipt({ chat_id: chat_id, id: receipt_id })
 				.catch(err => this.error("Error handling read receipt:", err))
 		} else {
 			this.log("No client connected, not sending receipts")
@@ -1252,7 +1335,7 @@ export default class MessagesPuppeteer {
 				receipt.chat_id = chat_id
 				try {
 					await this.client.sendReceipt(receipt)
-				} catch(err) {
+				} catch (err) {
 					this.error("Error handling read receipt:", err)
 				}
 			}