fix(types): resolve all TypeScript compilation errors from non-null

fix(types): resolve all TypeScript compilation errors from non-null

src/Socket/chats.ts

@@ -886,8 +886,8 @@ export const makeChatsSocket = (config: SocketConfig) => {
 			const { onMutation } = newAppStateChunkHandler(false)
 			const { mutationMap } = await decodePatches(
 				name,
-				[{ ...encodeResult?.patch, version: { version: encodeResult?.state?.version } }],
+				[{ ...encodeResult!.patch, version: { version: encodeResult!.state.version } }],
-				initial ?? { version: 0, hash: Buffer.alloc(0), indexValueMap: {} },
+				initial!,
 				getAppStateSyncKey,
 				config.options,
 				undefined,

src/Socket/groups.ts

@@ -316,7 +316,7 @@ export const extractGroupMetadata = (result: BinaryNode) => {
 		descId = descChild.attrs.id
 	}
 
-	const groupId = (group.attrs.id ?? '').includes('@') ? group.attrs.id : jidEncode(group.attrs.id ?? '', 'g.us')
+	const groupId = (group.attrs.id ?? '').includes('@') ? (group.attrs.id ?? '') : jidEncode(group.attrs.id ?? '', 'g.us')
 	const eph = getBinaryNodeChild(group, 'ephemeral')?.attrs.expiration
 	const memberAddMode = getBinaryNodeChildString(group, 'member_add_mode') === 'all_member_add'
 	const metadata: GroupMetadata = {
@@ -326,9 +326,9 @@ export const extractGroupMetadata = (result: BinaryNode) => {
 		subject: group.attrs.subject ?? '',
 		subjectOwner: group.attrs.s_o,
 		subjectOwnerPn: group.attrs.s_o_pn,
-		subjectTime: +group.attrs.s_t ?? '0',
+		subjectTime: +(group.attrs.s_t ?? '0'),
 		size: group.attrs.size ? +group.attrs.size : getBinaryNodeChildren(group, 'participant').length,
-		creation: +group.attrs.creation ?? '0',
+		creation: +(group.attrs.creation ?? '0'),
 		owner: group.attrs.creator ? jidNormalizedUser(group.attrs.creator) : undefined,
 		ownerPn: group.attrs.creator_pn ? jidNormalizedUser(group.attrs.creator_pn) : undefined,
 		owner_country_code: group.attrs.creator_country_code,

src/Socket/messages-recv.ts

@@ -156,16 +156,17 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
 			throw new Boom('Not authenticated')
 		}
 
-		if (await placeholderResendCache.get(messageKey?.id)) {
+		const msgId = messageKey?.id ?? ''
+		if (await placeholderResendCache.get(msgId)) {
 			logger.debug({ messageKey }, 'already requested resend')
 			return
 		} else {
-			await placeholderResendCache.set(messageKey?.id, true)
+			await placeholderResendCache.set(msgId, true)
 		}
 
 		await delay(2000)
 
-		if (!(await placeholderResendCache.get(messageKey?.id))) {
+		if (!(await placeholderResendCache.get(msgId))) {
 			logger.debug({ messageKey }, 'message received while resend requested')
 			return 'RESOLVED'
 		}
@@ -180,9 +181,9 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
 		}
 
 		setTimeout(async () => {
-			if (await placeholderResendCache.get(messageKey?.id)) {
+			if (await placeholderResendCache.get(msgId)) {
 				logger.debug({ messageKey }, 'PDO message without response after 8 seconds. Phone possibly offline')
-				await placeholderResendCache.del(messageKey?.id)
+				await placeholderResendCache.del(msgId)
 			}
 		}, 8_000)
 

src/Socket/socket.ts

@@ -552,11 +552,7 @@ export const makeSocket = (config: SocketConfig) => {
 		})
 
 		if (sendMsg) {
-			if (!onClose) {
+				sendRawMessage(sendMsg).catch(onClose!)
-				throw new Error('onClose handler not initialized')
-			}
-
-			sendRawMessage(sendMsg).catch(onClose)
 		}
 
 		return result

src/Utils/event-buffer.ts

@@ -1265,7 +1265,7 @@ function consolidateEvents(data: BufferedEventData) {
 
 	const messageUpsertList = Object.values(data.messageUpserts)
 	if (messageUpsertList.length) {
-		const type = messageUpsertList[0]?.type
+		const type = messageUpsertList[0]?.type ?? 'notify'
 		map['messages.upsert'] = {
 			messages: messageUpsertList.map(m => m.message),
 			type

src/Utils/messages.ts

@@ -264,9 +264,11 @@ export const prepareWAMessageMedia = async (
 					throw new Boom('Missing file path for processing')
 				}
 
+				const filePath = originalFilePath!
+
 				if (requiresThumbnailComputation) {
 					const { thumbnail, originalImageDimensions } = await generateThumbnail(
-						originalFilePath,
+						filePath,
 						mediaType as 'image' | 'video',
 						options
 					)
@@ -281,12 +283,12 @@ export const prepareWAMessageMedia = async (
 				}
 
 				if (requiresDurationComputation) {
-					uploadData.seconds = await getAudioDuration(originalFilePath)
+					uploadData.seconds = await getAudioDuration(filePath)
 					logger?.debug('computed audio duration')
 				}
 
 				if (requiresWaveformProcessing) {
-					uploadData.waveform = await getAudioWaveform(originalFilePath, logger)
+					uploadData.waveform = await getAudioWaveform(filePath, logger)
 					logger?.debug('processed waveform')
 				}
 
@@ -1767,7 +1769,7 @@ export const generateWAMessageFromContent = (
 
 		const innerContent = innerMessage[key as Exclude<keyof proto.IMessage, 'conversation'>]
 		const contextInfo: proto.IContextInfo =
-			(innerContent && 'contextInfo' in innerContent && innerMessage[key as Exclude<keyof proto.IMessage, 'conversation'>]?.contextInfo) || {}
+			(innerContent && typeof innerContent === 'object' && 'contextInfo' in innerContent && (innerContent as Record<string, unknown>).contextInfo as proto.IContextInfo) || {}
 		contextInfo.participant = jidNormalizedUser(participant ?? '')
 		contextInfo.stanzaId = quoted.key.id
 		contextInfo.quotedMessage = quotedMsg

src/Utils/noise-handler.ts

@@ -150,7 +150,7 @@ export const makeNoiseHandler = ({
 		while (true) {
 			if (inBytes.length < 3) return
 
-			size = (inBytes[0] << 16) | (inBytes[1] << 8) | inBytes[2]
+			size = (inBytes[0]! << 16) | (inBytes[1]! << 8) | inBytes[2]!
 
 			if (inBytes.length < size + 3) return