@ -1,4 +1,5 @@
import AbortController from 'abort-controller' ;
import { getConversationController } from '../../../conversations' ;
import { OpenGroupRequestCommonType } from '../opengroupV2/ApiUtil' ;
import { getOpenGroupV2ConversationId } from '../utils/OpenGroupUtils' ;
import {
@ -7,7 +8,6 @@ import {
OpenGroupBatchRow ,
sogsBatchSend ,
} from './sogsV3BatchPoll' ;
import { getConversationController } from '../../../conversations' ;
type OpenGroupClearInboxResponse = {
deleted : number ;
@ -21,42 +21,40 @@ export const clearInbox = async (roomInfos: OpenGroupRequestCommonType): Promise
if ( ! conversation ) {
throw new Error ( ` clearInbox Matching conversation not found in db ${ conversationId } ` ) ;
} else {
const options : Array < OpenGroupBatchRow > = [
{
type : 'inbox' ,
inbox : {
type : 'delete' ,
} ,
}
const options : Array < OpenGroupBatchRow > = [
{
type : 'inbox' ,
inbox : {
type : 'delete' ,
} ,
] ;
} ,
] ;
const result = await sogsBatchSend (
roomInfos . serverUrl ,
new Set ( [ roomInfos . roomId ] ) ,
new AbortController ( ) . signal ,
options ,
'batch'
) ;
const result = await sogsBatchSend (
roomInfos . serverUrl ,
new Set ( [ roomInfos . roomId ] ) ,
new AbortController ( ) . signal ,
options ,
'batch'
) ;
if ( ! result ) {
throw new Error ( ` Could not clearInbox, res is invalid for ${ conversationId } ` ) ;
}
if ( ! result ) {
throw new Error ( ` Could not clearInbox, res is invalid for ${ conversationId } ` ) ;
}
const rawMessage =
( result . body && ( result . body [ 0 ] . body as OpenGroupClearInboxResponse ) ) || null ;
if ( ! rawMessage ) {
throw new Error ( ` clearInbox parsing failed for ${ conversationId } ` ) ;
}
const rawMessage = ( result . body && ( result . body [ 0 ] . body as OpenGroupClearInboxResponse ) ) || null ;
if ( ! rawMessage ) {
throw new Error ( ` clearInbox parsing failed for ${ conversationId } ` ) ;
}
try {
if ( batchGlobalIsSuccess ( result ) && batchFirstSubIsSuccess ( result ) ) {
success = true ;
window . log . info ( ` clearInbox ${ rawMessage . deleted } messages deleted for ${ conversationId } ` ) ;
}
} catch ( e ) {
window ? . log ? . error ( ` clearInbox Can't decode JSON body for ${ conversationId } ` ) ;
try {
if ( batchGlobalIsSuccess ( result ) && batchFirstSubIsSuccess ( result ) ) {
success = true ;
window . log . info ( ` clearInbox ${ rawMessage . deleted } messages deleted for ${ conversationId } ` ) ;
}
} catch ( e ) {
window ? . log ? . error ( ` clearInbox Can't decode JSON body for ${ conversationId } ` ) ;
}
if ( ! success ) {