✅ تست Read-Only با گزارش سبک
این نسخه فقط ساختار عمومی Web Rubika را بررسی میکند.
| Web Rubika | 200 |
|---|---|
| JS پیدا شده | 7 |
| JS موفق | 7 |
| JS ناموفق | 0 |
t.hole.items||[]).length-1;i>=0;i--){const e=t.hole.items[i];if(e.author_object_guid==this.me.user_guid)return e.time}}clearHistory(e){const t=this.getConv(e,!0);t.messages={},t.hole.items=[],this.onReadyChanged.next({object_guid:e,action:jm.Renew})}getMessagesFromMiddle(e){const t=this.getConv(e.object_guid,!0),i=this.getHole(t,e.filter_type);this.setHoleFilterType(i,e.filter_type),this.checkSyncedMinMax(t,i);const n=i.items.length,s=i.items.findIndex(t=>toInt(t.message_id)>=toInt(e.middle_message_id));let r,a;s<0?(r=n-e.limit>0?n-e.limit:0,a=r+e.limit):(a=s+e.limit-toInt(.3*e.limit),a=a>n-1?n:a+1,r=a-e.limit>0?a-e.limit:0);const o=i.items.slice(r,a),c=this.getReferedMessageIds(o);return toInt(e.pin_mid||0)&&c.push(e.pin_mid),this.getIfNotExist(t,c),t.related&&(o.findIndex(e=>e.message_id===t.related.message_id),o.push(t.related.msg)),{messages:o,reachstart:i.reachstart&&r<=0,reachend:i.reachend&&a>=n-1}}getMessages(e,t){return gh(this,void 0,voitReferedMessageIds(o);return toInt(e.pin_mid||0)&&c.push(e.pin_mid),this.getIfNotExist(t,c),t.related&&(o.findIndex(e=>e.message_id===t.related.message_id),o.push(t.related.msg)),{messages:o,reachstart:i.reachstart&&r<=0,reachend:i.reachend&&a>=n-1}}getMessages(e,t){return gh(this,void 0,void 0,(function*(){try{e.limit=e.limit||20;const i=this.getConv(e.object_guid,!0),n=this.getHole(i,e.filter_type);this.setHoleFilterType(n,e.filter_type);let s=this.getMessageSlice(i,n,e);return e.limit===s.messages.length?s:(this.checkSyncedMinMax(i,n),s=this.getMessageSlice(i,n,e),s.messages.length>0?s:"FromMax"===e.sort&&n.reachstart||"FromMin"===e.sort&&n.reachend?{messages:[],has_continue:!1}:((yield this.getAndSyncMessages(i,{object_guid:e.object_guid,sort:e.sort,filter_type:e.filter_type},t)).length>0&&this.resort(i,n),this.getMessageSlice(i,n,e)))}catch(i){throw i}}))}getMessagesUpdate(e,t){return gh(this,void 0,void 0,(function*(){try{const i=this.getConeachstart&&r<=0,reachend:i.reachend&&a>=n-1}}getMessages(e,t){return gh(this,void 0,void 0,(function*(){try{e.limit=e.limit||20;const i=this.getConv(e.object_guid,!0),n=this.getHole(i,e.filter_type);this.setHoleFilterType(n,e.filter_type);let s=this.getMessageSlice(i,n,e);return e.limit===s.messages.length?s:(this.checkSyncedMinMax(i,n),s=this.getMessageSlice(i,n,e),s.messages.length>0?s:"FromMax"===e.sort&&n.reachstart||"FromMin"===e.sort&&n.reachend?{messages:[],has_continue:!1}:((yield this.getAndSyncMessages(i,{object_guid:e.object_guid,sort:e.sort,filter_type:e.filter_type},t)).length>0&&this.resort(i,n),this.getMessageSlice(i,n,e)))}catch(i){throw i}}))}getMessagesUpdate(e,t){return gh(this,void 0,void 0,(function*(){try{const i=this.getConv(e);if(!i||!i.hole.state)return!1;const n=yield this.dcService.getResponsePost({method:"getMessagesUpdates",model:{object_guid:e,state:i.hole.state}}).success(t);return"OldState"===n.status?(this.resetCon>=0;n--){var i=t.hole.items[n];if(i.author_object_guid==this.me.user_guid)return i.time}}},{key:"clearHistory",value:function(e){var t=this.getConv(e,!0);t.messages={},t.hole.items=[],this.onReadyChanged.next({object_guid:e,action:qv.Renew})}},{key:"getMessagesFromMiddle",value:function(e){var t=this.getConv(e.object_guid,!0),n=this.getHole(t,e.filter_type);this.setHoleFilterType(n,e.filter_type),this.checkSyncedMinMax(t,n);var i,r,s=n.items.length,a=n.items.findIndex((function(t){return toInt(t.message_id)>=toInt(e.middle_message_id)}));a<0?r=(i=s-e.limit>0?s-e.limit:0)+e.limit:i=(r=(r=a+e.limit-toInt(.3*e.limit))>s-1?s:r+1)-e.limit>0?r-e.limit:0;var o=n.items.slice(i,r),c=this.getReferedMessageIds(o);return toInt(e.pin_mid||0)&&c.push(e.pin_mid),this.getIfNotExist(t,c),t.related&&(o.findIndex((function(e){return e.message_id===t.related.message_id})),o.push(t.related.msg)),{messages:o,reachstart:n.reachstart&&i<=0,reachend:n.reachend&&r>=s-1}}},n toInt(e.pin_mid||0)&&c.push(e.pin_mid),this.getIfNotExist(t,c),t.related&&(o.findIndex((function(e){return e.message_id===t.related.message_id})),o.push(t.related.msg)),{messages:o,reachstart:n.reachstart&&i<=0,reachend:n.reachend&&r>=s-1}}},{key:"getMessages",value:function(e,t){return gl(this,void 0,void 0,regeneratorRuntime.mark((function n(){var i,r,s;return regeneratorRuntime.wrap((function(n){for(;;)switch(n.prev=n.next){case 0:if(n.prev=0,e.limit=e.limit||20,i=this.getConv(e.object_guid,!0),r=this.getHole(i,e.filter_type),this.setHoleFilterType(r,e.filter_type),s=this.getMessageSlice(i,r,e),e.limit!==s.messages.length){n.next=9;break}n.t0=s,n.next=28;break;case 9:if(this.checkSyncedMinMax(i,r),!((s=this.getMessageSlice(i,r,e)).messages.length>0)){n.next=15;break}n.t1=s,n.next=27;break;case 15:if(!("FromMax"===e.sort&&r.reachstart||"FromMin"===e.sort&&r.reachend)){n.next=19;break}n.t2={messages:[],has_continue:!1},n.next=26;break;case 19:re_search")).message_ids}catch(i){throw i}}))}searchGlobalMessage(e,t){return gh(this,void 0,void 0,(function*(){try{return yield this.dcService.getResponsePost({method:"searchGlobalMessages",model:e}).success(t,"message_search")}catch(i){throw i}}))}getMessagesById(e,t){return gh(this,void 0,void 0,(function*(){try{const i=this.getConv(e,!0),n={},s=[];if((t||[]).forEach(e=>{i.messages[e]?n[e]=i.messages[e]:s.push(e)}),s.length>0){const e=yield this.dcService.getResponsePost({method:"getMessagesByID",model:{object_guid:i.object_guid,message_ids:s}}).success();(e.messages||[]).length>0&&e.messages.forEach(e=>{n[e.message_id]=e})}return t.map(e=>n[e])}catch(i){throw i}}))}reportObject(e){return gh(this,void 0,void 0,(function*(){try{return yield this.dcService.getResponsePost({method:"reportObject",model:e}).success()}catch(t){throw t}}))}isHiddenPin(e,t){return this.hidden_pinned[e]==t}hidePin(e,t){this.hidden_pinned[e]=t,this.storageService.set({hiddenthrow i}}))}getMessagesById(e,t){return gh(this,void 0,void 0,(function*(){try{const i=this.getConv(e,!0),n={},s=[];if((t||[]).forEach(e=>{i.messages[e]?n[e]=i.messages[e]:s.push(e)}),s.length>0){const e=yield this.dcService.getResponsePost({method:"getMessagesByID",model:{object_guid:i.object_guid,message_ids:s}}).success();(e.messages||[]).length>0&&e.messages.forEach(e=>{n[e.message_id]=e})}return t.map(e=>n[e])}catch(i){throw i}}))}reportObject(e){return gh(this,void 0,void 0,(function*(){try{return yield this.dcService.getResponsePost({method:"reportObject",model:e}).success()}catch(t){throw t}}))}isHiddenPin(e,t){return this.hidden_pinned[e]==t}hidePin(e,t){this.hidden_pinned[e]=t,this.storageService.set({hidden_pinned:this.hidden_pinned})}sendWalletTransfer(e){return gh(this,void 0,void 0,(function*(){try{const t=this.getConv(e.object_guid,!0);e.rnd=this.newRnd();const i=yield this.dcService.getResponsePost({method:"sendWalletTransferMessage",m]).filter(e=>e).forEach(t=>{!e.messages[t]&&n.indexOf(t)<0?n.push(t):i.push(t)}),i.length>0&&this.messageEvent.emit({object_guid:e.object_guid,action:Im.Loaded,message_ids:i}),0===n.length)return;const s=yield this.dcService.getResponsePost({method:"getMessagesByID",model:{object_guid:e.object_guid,message_ids:n}}).success();s.messages.length>0&&(this.syncMessages(e,s.messages),this.messageEvent.emit({object_guid:e.object_guid,action:Im.Loaded,message_ids:s.messages.map(e=>e.message_id)}));const r=n.filter(e=>s.messages.findIndex(t=>t.message_id==e)<0);(r||[]).length>0&&(this.addedToDeleted(e,r),this.messageEvent.emit({object_guid:e.object_guid,action:Im.Deleted,message_ids:r}))}catch(i){throw i}}))}addedToDeleted(e,t){e.deleted||(e.deleted={}),t.forEach(t=>{e.deleted[t+""]=!0})}checkRelatedObjects(e){return gh(this,void 0,void 0,(function*(){try{const t=yield this.getRelatedObjects(e.object_guid);if((t.related_objects||[]).length>0){const i=this.getC=3,this.dcService.getResponsePost({method:"searchGlobalMessages",model:e}).success(t,"message_search");case 3:return n.abrupt("return",n.sent);case 6:throw n.prev=6,n.t0=n.catch(0),n.t0;case 9:case"end":return n.stop()}}),n,this,[[0,6]])})))}},{key:"getMessagesById",value:function(e,t){return gl(this,void 0,void 0,regeneratorRuntime.mark((function n(){var i,r,s,a;return regeneratorRuntime.wrap((function(n){for(;;)switch(n.prev=n.next){case 0:if(n.prev=0,i=this.getConv(e,!0),r={},s=[],(t||[]).forEach((function(e){i.messages[e]?r[e]=i.messages[e]:s.push(e)})),!(s.length>0)){n.next=7;break}return n.next=5,this.dcService.getResponsePost({method:"getMessagesByID",model:{object_guid:i.object_guid,message_ids:s}}).success();case 5:((a=n.sent).messages||[]).length>0&&a.messages.forEach((function(e){r[e.message_id]=e}));case 7:return n.abrupt("return",t.map((function(e){return r[e]})));case 10:throw n.prev=10,n.t0=n.catch(0),n.t0;case 13:case"end":return n.stonction(n){for(;;)switch(n.prev=n.next){case 0:if(n.prev=0,i=this.getConv(e,!0),r={},s=[],(t||[]).forEach((function(e){i.messages[e]?r[e]=i.messages[e]:s.push(e)})),!(s.length>0)){n.next=7;break}return n.next=5,this.dcService.getResponsePost({method:"getMessagesByID",model:{object_guid:i.object_guid,message_ids:s}}).success();case 5:((a=n.sent).messages||[]).length>0&&a.messages.forEach((function(e){r[e.message_id]=e}));case 7:return n.abrupt("return",t.map((function(e){return r[e]})));case 10:throw n.prev=10,n.t0=n.catch(0),n.t0;case 13:case"end":return n.stop()}}),n,this,[[0,10]])})))}},{key:"reportObject",value:function(e){return gl(this,void 0,void 0,regeneratorRuntime.mark((function t(){return regeneratorRuntime.wrap((function(t){for(;;)switch(t.prev=t.next){case 0:return t.prev=0,t.next=3,this.dcService.getResponsePost({method:"reportObject",model:e}).success();case 3:return t.abrupt("return",t.sent);case 6:throw t.prev=6,t.t0=t.catch(0),t.t0;casice.getResponsePost({method:"getRelatedObjects",model:{object_guid:e,start_id:t}}).success()}catch(i){throw i}}))}getAndSyncMessagesInterval(e,t,i,n){return gh(this,void 0,void 0,(function*(){try{const s=yield this.dcService.getResponsePost({method:"getMessagesInterval",model:{object_guid:i.object_guid,middle_message_id:i.middle_message_id,filter_type:i.filter_type}}).success(n),r=s.messages||[];if(this.syncMessages(e,r,!0),yield this.syncAbsObjects(s.messages),!s.new_min_id){const t=toInt((r[r.length-1]||{}).message_id);s.new_min_id=Math.max(t,toInt(e.last_mid))+""}s.old_max_id||(s.old_max_id="1");const a=this.getHole(e,i.filter_type);this.updateMinMax(a,{new_min_id:s.old_max_id,new_max_id:s.new_min_id,reachstart:!s.old_has_continue,reachend:!s.new_has_continue,state:s.state}),this.checkSyncedMinMax(e,a),this.onReadyChanged.next({object_guid:i.object_guid,action:t,message_id:i.middle_message_id})}catch(s){throw s}}))}getMessageSlice(e,t,i){const n="FromM",value:function(e,t,n,i){return gl(this,void 0,void 0,regeneratorRuntime.mark((function r(){var s,a,o,c;return regeneratorRuntime.wrap((function(r){for(;;)switch(r.prev=r.next){case 0:return r.prev=0,r.next=3,this.dcService.getResponsePost({method:"getMessagesInterval",model:{object_guid:n.object_guid,middle_message_id:n.middle_message_id,filter_type:n.filter_type}}).success(i);case 3:return s=r.sent,a=s.messages||[],this.syncMessages(e,a,!0),r.next=8,this.syncAbsObjects(s.messages);case 8:if(s.new_min_id){r.next=11;break}o=toInt((a[a.length-1]||{}).message_id),s.new_min_id=Math.max(o,toInt(e.last_mid))+"";case 11:s.old_max_id||(s.old_max_id="1"),c=this.getHole(e,n.filter_type),this.updateMinMax(c,{new_min_id:s.old_max_id,new_max_id:s.new_min_id,reachstart:!s.old_has_continue,reachend:!s.new_has_continue,state:s.state}),this.checkSyncedMinMax(e,c),this.onReadyChanged.next({object_guid:n.object_guid,action:t,message_id:n.middle_message_id}),r.next=19;breah>0&&this.resort(i,n),this.getMessageSlice(i,n,e)))}catch(i){throw i}}))}getMessagesUpdate(e,t){return gh(this,void 0,void 0,(function*(){try{const i=this.getConv(e);if(!i||!i.hole.state)return!1;const n=yield this.dcService.getResponsePost({method:"getMessagesUpdates",model:{object_guid:e,state:i.hole.state}}).success(t);return"OldState"===n.status?(this.resetConv(i),void this.onReadyChanged.next({object_guid:e,action:jm.Renew})):(i.hole.state=n.new_state,n.updated_messages.forEach(e=>{this.updateMessage(i,e)}),!0)}catch(i){throw i}}))}getMessageById(e,t){const i=this.getConv(e);if(i)return i.messages[t]}checkReachend(e){e.forEach(e=>{const t=this.getConv(e.object_guid);t&&t.hole.max_id&&t.hole.max_id<toInt(e.last_message_id)&&(t.hole.reachend=!1)})}getFileMessages(e,t){const i=this.getConv(e);let n=i.media_hole.items;return n=n.length>0?n:i.hole.items,n.filter(e=>e.file_inline&&e.file_inline.type===t)}getNextPrevVoiceMessage(e,t,i){const n=this.getConv{var i,r,s=this;return regeneratorRuntime.wrap((function(n){for(;;)switch(n.prev=n.next){case 0:if(n.prev=0,(i=this.getConv(e))&&i.hole.state){n.next=4;break}return n.abrupt("return",!1);case 4:return n.next=6,this.dcService.getResponsePost({method:"getMessagesUpdates",model:{object_guid:e,state:i.hole.state}}).success(t);case 6:return r=n.sent,n.abrupt("return","OldState"===r.status?(this.resetConv(i),void this.onReadyChanged.next({object_guid:e,action:qv.Renew})):(i.hole.state=r.new_state,r.updated_messages.forEach((function(e){s.updateMessage(i,e)})),!0));case 10:throw n.prev=10,n.t0=n.catch(0),n.t0;case 13:case"end":return n.stop()}}),n,this,[[0,10]])})))}},{key:"getMessageById",value:function(e,t){var n=this.getConv(e);if(n)return n.messages[t]}},{key:"checkReachend",value:function(e){var t=this;e.forEach((function(e){var n=t.getConv(e.object_guid);n&&n.hole.max_id&&n.hole.max_id<toInt(e.last_message_id)&&(n.hole.reachend=!1)}))}},{key:"getFileMessa,this.chatsEvent.fire({action:mu.Init})):this.reloadChats()})}loadMore(e,t,i,n,s){return gh(this,void 0,void 0,(function*(){try{let r=this.getSliceFromLocal(e,t,i,n,s);return r.length<t&&this.chatState.has_continue&&!this.reloadingChats&&(yield this.getChats(this.chatState.start_id),r=this.getSliceFromLocal(e,t,i,n,s)),{chats:r,reachend:!this.chatState.has_continue&&e+t>=this.store.length}}catch(r){throw r}}))}getLatestArchivedChats(){return this.store.filter(e=>e.is_archived).slice(0,5)}chatIsEmpty(){return 0==(this.store||[]).length}setActionChat(e,t,i){return gh(this,void 0,void 0,(function*(){try{const n=yield this.dcService.getResponsePost({method:"setActionChat",model:{object_guid:e,action:t,duration:i}}).success();this.updateChat(n.chat_update,!0)}catch(n){throw n}}))}seenChatQ(e,t){if(e){const i=this.getChatObject(e);if(!i||i.last_seen_my_mid.compare(t)>0)return;const n=this.seenQ[e];(!n||n.compare(t)<0)&&(this.seenQ[e]=t)}this.containCe.object_guid));return e.sort((e,t)=>{if(i.has(e.object_guid)!==i.has(t.object_guid))return i.has(e.object_guid)?-1:1;const n=Number(e.time_string)||0,s=Number(t.time_string)||0;return n!==s?s-n:(t.time_string||"").localeCompare(e.time_string||"")})}getChatsUnreadStatus(e){let t=this.store||[];if(0===t.length)return{count:0};e&&(t=t.filter(t=>(this.includeType(e.include_chat_types,t)||this.hasObject(e.include_objects,t))&&!this.excludeType(e.exclude_chat_types,t)&&!this.hasObject(e.exclude_objects,t)));const i=t.filter(e=>e.count_unseen>0&&e.last_message_id!=e.last_seen_my_mid);return{count:i.length,muted:0==i.filter(e=>!e.is_mute).length}}hasObject(e,t){return(e||[]).findIndex(e=>e.object_guid==t.object_guid&&e.type==t.abs_object.type)>-1}includeType(e,t){if(e)switch(t.abs_object.type){case cu.Bot:return e.indexOf(km.Bots)>-1;case cu.Group:return e.indexOf(km.Groups)>-1;case cu.Service:return e.indexOf(km.Services)>-1;case cu.Channel:return e.e]),this.syncChanges([e],[],!1))}changedChat(e){const t=this.getChat(e);t&&this.chatsEvent.fire({action:mu.Update,chats:[t]})}getChatById(e){return gh(this,void 0,void 0,(function*(){try{const t=this.getChatObject(e);if(t)return t;const i=yield this.getChatsById([e]);return i&&i[0]}catch(t){throw t}}))}getOrCreateChat(e){return this.getChatObject(e)||{object_guid:e,abs_object:{object_guid:e,type:this.getType(e)}}}resetChatObject(e){return this.getChatObject(e.object_guid)||e}getChatObject(e){let t=this.getChat(e)||this.notExistChats[e];if(!t){const i=this.contactService.getContact(e);i&&(t={object_guid:i.object_guid,type:i.type,abs_object:i})}return t}deleteChatHistory(e){return gh(this,void 0,void 0,(function*(){try{const t=this.convService.getLastMessageId(e);if(!t)return;const i=yield this.dcService.getResponsePost({method:"deleteChatHistory",model:{object_guid:e,last_message_id:t}}).success();this.convService.clearHistory(e),this.updateChatn s(){var a;return regeneratorRuntime.wrap((function(s){for(;;)switch(s.prev=s.next){case 0:if(s.prev=0,a=this.getSliceFromLocal(e,t,n,i,r),s.t0=a.length<t&&this.chatState.has_continue&&!this.reloadingChats,!s.t0){s.next=7;break}return s.next=6,this.getChats(this.chatState.start_id);case 6:a=this.getSliceFromLocal(e,t,n,i,r);case 7:return s.abrupt("return",{chats:a,reachend:!this.chatState.has_continue&&e+t>=this.store.length});case 10:throw s.prev=10,s.t1=s.catch(0),s.t1;case 13:case"end":return s.stop()}}),s,this,[[0,10]])})))}},{key:"getLatestArchivedChats",value:function(){return this.store.filter((function(e){return e.is_archived})).slice(0,5)}},{key:"chatIsEmpty",value:function(){return 0==(this.store||[]).length}},{key:"setActionChat",value:function(e,t,n){return gl(this,void 0,void 0,regeneratorRuntime.mark((function i(){var r;return regeneratorRuntime.wrap((function(i){for(;;)switch(i.prev=i.next){case 0:return i.prev=0,i.next=3,this.d);return e.sort((function(e,t){if(n.has(e.object_guid)!==n.has(t.object_guid))return n.has(e.object_guid)?-1:1;var i=Number(e.time_string)||0,r=Number(t.time_string)||0;return i!==r?r-i:(t.time_string||"").localeCompare(e.time_string||"")}))}},{key:"getChatsUnreadStatus",value:function(e){var t=this,n=this.store||[];if(0===n.length)return{count:0};e&&(n=n.filter((function(n){return(t.includeType(e.include_chat_types,n)||t.hasObject(e.include_objects,n))&&!t.excludeType(e.exclude_chat_types,n)&&!t.hasObject(e.exclude_objects,n)})));var i=n.filter((function(e){return e.count_unseen>0&&e.last_message_id!=e.last_seen_my_mid}));return{count:i.length,muted:0==i.filter((function(e){return!e.is_mute})).length}}},{key:"hasObject",value:function(e,t){return(e||[]).findIndex((function(e){return e.object_guid==t.object_guid&&e.type==t.abs_object.type}))>-1}},{key:"includeType",value:function(e,t){if(e)switch(t.abs_object.type){case zd.Bot:return e.indexOf(e_string.localeCompare(e.time_string)}getChatUpdates(){return gh(this,void 0,void 0,(function*(){if(this.reloadingChats)this.nextUpdate();else try{this.appService.emitLoading(Fp.TryUpdatingChats);const e=yield this.dcService.getResponsePost({method:"getChatsUpdates",model:{state:this.chatState.state}}).success();this.appService.emitLoading(Fp.Loaded),e.status===pu.OldState?(this.getChatsRequest&&this.getChatsRequest.cancel(),this.reloadChats()):(this.convService.checkReachend(e.chats),this.chatState.state=e.new_state,this.syncChanges(e.chats,e.deleted_chats,!0)),this.nextUpdate()}catch(e){this.appService.emitLoading(Fp.Failed),this.nextUpdate()}}))}syncChanges(e,t,i){const n=t||[],s=e||[];n.length>0&&n.forEach(e=>{this.removeFromStore(e)}),this.syncAbsObject(s);const r={action:mu.Update,deleted_chats:n,chats:this.sortChats(s)};i&&this.saveChangesWithDelay().then(()=>{this.saveState()}).catch(e=>{console.log("storage",e)}),s.length+n.length>0&&this.cha.wrap((function(e){for(;;)switch(e.prev=e.next){case 0:if(!this.reloadingChats){e.next=4;break}this.nextUpdate(),e.next=15;break;case 4:return e.prev=4,this.appService.emitLoading(Ep.TryUpdatingChats),e.next=8,this.dcService.getResponsePost({method:"getChatsUpdates",model:{state:this.chatState.state}}).success();case 8:t=e.sent,this.appService.emitLoading(Ep.Loaded),t.status===Wd.OldState?(this.getChatsRequest&&this.getChatsRequest.cancel(),this.reloadChats()):(this.convService.checkReachend(t.chats),this.chatState.state=t.new_state,this.syncChanges(t.chats,t.deleted_chats,!0)),this.nextUpdate(),e.next=15;break;case 12:e.prev=12,e.t0=e.catch(4),this.appService.emitLoading(Ep.Failed),this.nextUpdate();case 15:case"end":return e.stop()}}),e,this,[[4,12]])})))}},{key:"syncChanges",value:function(e,t,n){var i=this,r=t||[],s=e||[];r.length>0&&r.forEach((function(e){i.removeFromStore(e)})),this.syncAbsObject(s);var a={action:Kd.Update,deleted_chats:r,chats:rn new(t||e)(Ke(Cm),Ke(n_),Ke(Lm),Ke(Zp))},e.\u0275prov=de({token:e,factory:e.\u0275fac}),e})(),B_=(()=>{class e{constructor(e,t,i,n,s,r){this.dcService=e,this.chatService=t,this.convService=i,this.absService=n,this.broadcastEvent=s,this.vcService=r}getChannelInfo(e,t){return gh(this,void 0,void 0,(function*(){try{const i=yield this.dcService.getResponsePost({method:"getChannelInfo",model:{channel_guid:e}}).success(t);return this.chatService.syncChat(i.chat),this.absService.syncObjectInfo(i.channel,cu.Channel),i}catch(i){throw i}}))}editChannelInfo(e){return gh(this,void 0,void 0,(function*(){try{const t=yield this.dcService.getResponsePost({method:"editChannelInfo",model:e}).success();this.absService.syncObjectInfo(t.channel,cu.Channel),this.chatService.updateChat(t.chat_update,!0),this.convService.updateMessageByGuid(e.object_guid,t.message_update),this.broadcastEvent.emit("update_channel",t.channel)}catch(t){throw t}}))}addChannelMembers(e,t){retuctor(e,t,i,n,s,r){this.dcService=e,this.chatService=t,this.convService=i,this.absService=n,this.broadcastEvent=s,this.vcService=r}getChannelInfo(e,t){return gh(this,void 0,void 0,(function*(){try{const i=yield this.dcService.getResponsePost({method:"getChannelInfo",model:{channel_guid:e}}).success(t);return this.chatService.syncChat(i.chat),this.absService.syncObjectInfo(i.channel,cu.Channel),i}catch(i){throw i}}))}editChannelInfo(e){return gh(this,void 0,void 0,(function*(){try{const t=yield this.dcService.getResponsePost({method:"editChannelInfo",model:e}).success();this.absService.syncObjectInfo(t.channel,cu.Channel),this.chatService.updateChat(t.chat_update,!0),this.convService.updateMessageByGuid(e.object_guid,t.message_update),this.broadcastEvent.emit("update_channel",t.channel)}catch(t){throw t}}))}addChannelMembers(e,t){return gh(this,void 0,void 0,(function*(){try{const i=yield this.dcService.getResponsePost({method:"addChannelMembers",modelonent:"BotMapComponent",onClose:i=>{i?e(i.location):t(!1)}})})}getObjectInfo(e,t){return gh(this,void 0,void 0,(function*(){try{let i;switch(e){case cu.Group:i=yield this.groupService.getGroupInfo(t);break;case cu.Channel:i=yield this.channelService.getChannelInfo(t);break;case cu.User:i=yield this.userService.getUserInfo(t);break;case cu.Bot:i=yield this.botService.getBotInfo(t);break;case cu.Service:i=yield this.botService.getServiceInfo(t)}return i}catch(i){throw i}}))}openToast(e,t){e&&e.text&&(e.delay||(e.delay=3e3),this.pageService.openPage({type:yh.Toast,id:t||"toast",model:e,onClose:()=>{}}))}openReportMessage(e){this.pageService.openPage({type:yh.Popup,dynamicComponent:"ReportMessagComponent",id:"modal-report-"+(e.confirm?"confirm":""),cssClass:"popup-peer popup-report-messages",model:e})}openExternalDevice(e,t){this.pageService.openPage({type:yh.Popup,dynamicComponent:"ExternalDeviceComponent",id:"modal-external-device",cssClass:"popup-peerv=fe({token:U_,factory:U_.\u0275fac}),U_),eb=((Y_=function(){function e(t,n,i,r,s,a){_classCallCheck(this,e),this.dcService=t,this.chatService=n,this.convService=i,this.absService=r,this.broadcastEvent=s,this.vcService=a}return _createClass(e,[{key:"getChannelInfo",value:function(e,t){return gl(this,void 0,void 0,regeneratorRuntime.mark((function n(){var i;return regeneratorRuntime.wrap((function(n){for(;;)switch(n.prev=n.next){case 0:return n.prev=0,n.next=3,this.dcService.getResponsePost({method:"getChannelInfo",model:{channel_guid:e}}).success(t);case 3:return i=n.sent,n.abrupt("return",(this.chatService.syncChat(i.chat),this.absService.syncObjectInfo(i.channel,zd.Channel),i));case 7:throw n.prev=7,n.t0=n.catch(0),n.t0;case 10:case"end":return n.stop()}}),n,this,[[0,7]])})))}},{key:"editChannelInfo",value:function(e){return gl(this,void 0,void 0,regeneratorRuntime.mark((function t(){var n;return regeneratorRuntime.wrap((function(t){for(;;)switch(thannelInfo",value:function(e,t){return gl(this,void 0,void 0,regeneratorRuntime.mark((function n(){var i;return regeneratorRuntime.wrap((function(n){for(;;)switch(n.prev=n.next){case 0:return n.prev=0,n.next=3,this.dcService.getResponsePost({method:"getChannelInfo",model:{channel_guid:e}}).success(t);case 3:return i=n.sent,n.abrupt("return",(this.chatService.syncChat(i.chat),this.absService.syncObjectInfo(i.channel,zd.Channel),i));case 7:throw n.prev=7,n.t0=n.catch(0),n.t0;case 10:case"end":return n.stop()}}),n,this,[[0,7]])})))}},{key:"editChannelInfo",value:function(e){return gl(this,void 0,void 0,regeneratorRuntime.mark((function t(){var n;return regeneratorRuntime.wrap((function(t){for(;;)switch(t.prev=t.next){case 0:return t.prev=0,t.next=3,this.dcService.getResponsePost({method:"editChannelInfo",model:e}).success();case 3:n=t.sent,this.absService.syncObjectInfo(n.channel,zd.Channel),this.chatService.updateChat(n.chat_update,!0),this.convServiceess();this.convService.clearHistory(e),this.updateChat(i.chat_update)}catch(t){throw t}}))}getChatByUsername(e){return gh(this,void 0,void 0,(function*(){try{if(e.length<4)throw"INVALID_USERNAME";const t=yield this.dcService.getResponsePost({method:"getObjectByUsername",model:{username:e}}).success();if(!t.exist)throw"error_modal_username_not_found_description";return t.chat}catch(t){throw t}}))}updateActivities(e){}updateChat(e,t){e&&this.updateChats([e],t)}updateDrafts(e){if(!e)return;const t=e.filter(e=>"Delete"===e.action).map(e=>e.draft_message.chat_object_guid);this.draftService.removeDraft(t),this.draftService.saveDraft(e.filter(e=>"New"===e.action).map(e=>e.draft_message)),this.notifyDrafts(e.map(e=>e.draft_message))}updateChats(e,t){const i=e.filter(e=>e.action===lu.Delete).map(e=>e.object_guid),n=e.filter(e=>e.action===lu.New).map(e=>e.chat),s=[];e.filter(e=>e.action===lu.Edit).forEach(e=>{const t=this.getAndUpdate(e);t?n.push(t):s.push(e.objecteneratorRuntime.mark((function t(){var n;return regeneratorRuntime.wrap((function(t){for(;;)switch(t.prev=t.next){case 0:if(t.prev=0,!(e.length<4)){t.next=3;break}throw"INVALID_USERNAME";case 3:return t.next=5,this.dcService.getResponsePost({method:"getObjectByUsername",model:{username:e}}).success();case 5:if((n=t.sent).exist){t.next=8;break}throw"error_modal_username_not_found_description";case 8:return t.abrupt("return",n.chat);case 11:throw t.prev=11,t.t0=t.catch(0),t.t0;case 14:case"end":return t.stop()}}),t,this,[[0,11]])})))}},{key:"updateActivities",value:function(e){}},{key:"updateChat",value:function(e,t){e&&this.updateChats([e],t)}},{key:"updateDrafts",value:function(e){if(e){var t=e.filter((function(e){return"Delete"===e.action})).map((function(e){return e.draft_message.chat_object_guid}));this.draftService.removeDraft(t),this.draftService.saveDraft(e.filter((function(e){return"New"===e.action})).map((function(e){return e.draft_message}))),thi
ks[i]={buffer:l,codec:n,id:a.id,container:a.container,levelCodec:a.levelCodec}}catch(e){u.b.error("error while trying to add sourceBuffer:"+e.message),this.hls.trigger(d.a.ERROR,{type:o.b.MEDIA_ERROR,details:o.a.BUFFER_ADD_CODEC_ERROR,fatal:!1,err:e,mimeType:s})}}this.hls.trigger(d.a.BUFFER_CREATED,{tracks:this.tracks})},a.onBufferAppending=function(e){this._needsFlush||(this.segments?this.segments.push(e):this.segments=[e],this.doAppending())},a.onBufferEos=function(e){for(var t in this.sourceBuffer)if(!e.type||e.type===t){var r=this.sourceBuffer[t];r&&!r.ended&&(r.ended=!0,u.b.log(t+" sourceBuffer now EOS"))}this.checkEos()},a.checkEos=function(){var e=this.sourceBuffer,t=this.mediaSource;if(t&&"open"===t.readyState){for(var r in e){var i=e[r];if(i){if(!i.ended)return;if(i.updating)return void(this._needsEos=!0)}}u.b.log("all media data are available, signal endOfStream() to MediaSource and stop loading fragment");try{t.endOfStream()}catcse()+" "]||[]).concat(t[2]);t=a[e.toLowerCase()+" "]}return null==t?null:t.join(", ")},getAllResponseHeaders:function(){return l?r:null},setRequestHeader:function(e,t){return null==l&&(e=w[e.toLowerCase()]=w[e.toLowerCase()]||e,y[e]=t),this},overrideMimeType:function(e){return null==l&&(p.mimeType=e),this},statusCode:function(e){var t;if(e)if(l)k.always(e[k.status]);else for(t in e)v[t]=[v[t],e[t]];return this},abort:function(e){var t=e||S;return n&&n.abort(t),x(0,t),this}};if(m.promise(k),p.url=((e||p.url||kt.href)+"").replace(Ft,kt.protocol+"//"),p.type=t.method||t.type||p.method||p.type,p.dataTypes=(p.dataType||"*").toLowerCase().match(F)||[""],null==p.crossDomain){c=b.createElement("a");try{c.href=p.url,c.href=c.href,p.crossDomain=Ht.protocol+"//"+Ht.host!=c.protocol+"//"+c.host}catch(M){p.crossDomain=!0}}if(p.data&&p.processData&&"string"!=typeof p.data&&(p.data=C.param(p.data,p.traditional)),Ut(Nt,p,t,k),l)return k;for(d in(h=C.event&rCase()+" "]}return null==t?null:t.join(", ")},getAllResponseHeaders:function(){return l?r:null},setRequestHeader:function(e,t){return null==l&&(e=w[e.toLowerCase()]=w[e.toLowerCase()]||e,y[e]=t),this},overrideMimeType:function(e){return null==l&&(p.mimeType=e),this},statusCode:function(e){var t;if(e)if(l)k.always(e[k.status]);else for(t in e)v[t]=[v[t],e[t]];return this},abort:function(e){var t=e||S;return n&&n.abort(t),x(0,t),this}};if(m.promise(k),p.url=((e||p.url||kt.href)+"").replace(Ft,kt.protocol+"//"),p.type=t.method||t.type||p.method||p.type,p.dataTypes=(p.dataType||"*").toLowerCase().match(F)||[""],null==p.crossDomain){c=b.createElement("a");try{c.href=p.url,c.href=c.href,p.crossDomain=Ht.protocol+"//"+Ht.host!=c.protocol+"//"+c.host}catch(M){p.crossDomain=!0}}if(p.data&&p.processData&&"string"!=typeof p.data&&(p.data=C.param(p.data,p.traditional)),Ut(Nt,p,t,k),l)return k;for(d in(h=C.event&&p.global)&&0==C.active++&&C.event.trigg128&&e[t+9]<128},e.isFooter=function(e,t){return t+10<=e.length&&51===e[t]&&68===e[t+1]&&73===e[t+2]&&e[t+3]<255&&e[t+4]<255&&e[t+6]<128&&e[t+7]<128&&e[t+8]<128&&e[t+9]<128},e.getID3Data=function(t,r){for(var i=r,a=0;e.isHeader(t,r);)a+=10,a+=e._readSize(t,r+6),e.isFooter(t,r+10)&&(a+=10),r+=a;if(a>0)return t.subarray(i,i+a)},e._readSize=function(e,t){var r=0;return r=(127&e[t])<<21,r|=(127&e[t+1])<<14,(r|=(127&e[t+2])<<7)|127&e[t+3]},e.getTimeStamp=function(t){for(var r=e.getID3Frames(t),i=0;i<r.length;i++){var a=r[i];if(e.isTimeStampFrame(a))return e._readTimeStamp(a)}},e.isTimeStampFrame=function(e){return e&&"PRIV"===e.key&&"com.apple.streaming.transportStreamTimestamp"===e.info},e._getFrameData=function(t){var r=String.fromCharCode(t[0],t[1],t[2],t[3]),i=e._readSize(t,4);return{type:r,size:i,data:t.subarray(10,10+i)}},e.getID3Frames=function(t){for(var r=0,i=[];e.isHeader(t,r);){for(var a=e._readSize(t,r+6),n=(r+=10)+a;r+8<n;){var s=e.1]&&73===e[t+2]&&e[t+3]<255&&e[t+4]<255&&e[t+6]<128&&e[t+7]<128&&e[t+8]<128&&e[t+9]<128},e.getID3Data=function(t,r){for(var i=r,a=0;e.isHeader(t,r);)a+=10,a+=e._readSize(t,r+6),e.isFooter(t,r+10)&&(a+=10),r+=a;if(a>0)return t.subarray(i,i+a)},e._readSize=function(e,t){var r=0;return r=(127&e[t])<<21,r|=(127&e[t+1])<<14,(r|=(127&e[t+2])<<7)|127&e[t+3]},e.getTimeStamp=function(t){for(var r=e.getID3Frames(t),i=0;i<r.length;i++){var a=r[i];if(e.isTimeStampFrame(a))return e._readTimeStamp(a)}},e.isTimeStampFrame=function(e){return e&&"PRIV"===e.key&&"com.apple.streaming.transportStreamTimestamp"===e.info},e._getFrameData=function(t){var r=String.fromCharCode(t[0],t[1],t[2],t[3]),i=e._readSize(t,4);return{type:r,size:i,data:t.subarray(10,10+i)}},e.getID3Frames=function(t){for(var r=0,i=[];e.isHeader(t,r);){for(var a=e._readSize(t,r+6),n=(r+=10)+a;r+8<n;){var s=e._getFrameData(t.subarray(r)),o=e._decodeFrame(s);o&&i.push(o),r+=s.size+10}e.isFooter(e.isTimeStampFrame(a))return e._readTimeStamp(a)}},e.isTimeStampFrame=function(e){return e&&"PRIV"===e.key&&"com.apple.streaming.transportStreamTimestamp"===e.info},e._getFrameData=function(t){var r=String.fromCharCode(t[0],t[1],t[2],t[3]),i=e._readSize(t,4);return{type:r,size:i,data:t.subarray(10,10+i)}},e.getID3Frames=function(t){for(var r=0,i=[];e.isHeader(t,r);){for(var a=e._readSize(t,r+6),n=(r+=10)+a;r+8<n;){var s=e._getFrameData(t.subarray(r)),o=e._decodeFrame(s);o&&i.push(o),r+=s.size+10}e.isFooter(t,r)&&(r+=10)}return i},e._decodeFrame=function(t){return"PRIV"===t.type?e._decodePrivFrame(t):"W"===t.type[0]?e._decodeURLFrame(t):e._decodeTextFrame(t)},e._readTimeStamp=function(e){if(8===e.data.byteLength){var t=new Uint8Array(e.data),r=(t[4]<<23)+(t[5]<<15)+(t[6]<<7)+t[7];return r/=45,1&t[3]&&(r+=47721858.84),Math.round(r)}},e._decodePrivFrame=function(t){if(!(t.size<2)){var r=e._utf8ArrayToStr(t.data,!0),i=new Uint8Array(t.data.subase 8:E=[32,11];break;case 9:E=[80,33];break;case 10:E=[18,11];break;case 11:E=[15,11];break;case 12:E=[64,33];break;case 13:E=[160,99];break;case 14:E=[4,3];break;case 15:E=[3,2];break;case 16:E=[2,1];break;case 255:E=[c()<<8|c(),c()<<8|c()]}return{width:Math.ceil(16*(r+1)-2*o-2*l),height:(2-a)*(i+1)*16-(a?2:4)*(d+u),pixelRatio:E}},t.readSliceType=function(){return this.readUByte(),this.readUEG(),this.readUEG()},e}(),_=function(){function e(e,t,r,i){this.decryptdata=r,this.discardEPB=i,this.decrypter=new n.a(e,t,{removePKCS7Padding:!1})}var t=e.prototype;return t.decryptBuffer=function(e,t){this.decrypter.decrypt(e,this.decryptdata.key.buffer,this.decryptdata.iv.buffer,t)},t.decryptAacSample=function(e,t,r,i){var a=e[t].unit,n=a.subarray(16,a.length-a.length%16),s=n.buffer.slice(n.byteOffset,n.byteOffset+n.length),o=this;this.decryptBuffer(s,(function(n){n=new Uint8Array(n),a.set(n,16),i||o.decryptAacSamples(e,t+1,r)}))},t.decryptAacSamplesmpleInOrder(n._txtTrack.samples,{pts:e.pts,payloadType:f,uuid:E.join(""),userDataBytes:R,userData:Object(m.b)(R.buffer)})}}else if(g<r.bytesAvailable)for(a=0;a<g;a++)r.readUByte()}break;case 7:if(i=!0,d=!0,!s.sps){var A=(r=new S(t.data)).readSPS();s.width=A.width,s.height=A.height,s.pixelRatio=A.pixelRatio,s.sps=[t.data],s.duration=n._duration;var k=t.data.subarray(1,4),w="avc1.";for(a=0;a<3;a++){var L=k[a].toString(16);L.length<2&&(L="0"+L),w+=L}s.codec=w}break;case 8:i=!0,s.pps||(s.pps=[t.data]);break;case 9:i=!1,s.audFound=!0,l&&u(l,s),l=n.avcSample=c(!1,e.pts,e.dts,"");break;case 12:i=!1;break;default:i=!1,l&&(l.debug+="unknown NAL "+t.type+" ")}l&&i&&l.units.push(t)})),t&&l&&(u(l,s),this.avcSample=null)},t._insertSampleInOrder=function(e,t){var r=e.length;if(r>0){if(t.pts>=e[r-1].pts)e.push(t);else for(var i=r-1;i>=0;i--)if(t.pts<e[i].pts){e.splice(i,0,t);break}}else e.push(t)},t._getLastNalUnit=function(){var e,t=this.avcSample;if(!t||der(n._txtTrack.samples,{pts:e.pts,payloadType:f,uuid:E.join(""),userDataBytes:R,userData:Object(m.b)(R.buffer)})}}else if(g<r.bytesAvailable)for(a=0;a<g;a++)r.readUByte()}break;case 7:if(i=!0,d=!0,!s.sps){var A=(r=new S(t.data)).readSPS();s.width=A.width,s.height=A.height,s.pixelRatio=A.pixelRatio,s.sps=[t.data],s.duration=n._duration;var k=t.data.subarray(1,4),w="avc1.";for(a=0;a<3;a++){var L=k[a].toString(16);L.length<2&&(L="0"+L),w+=L}s.codec=w}break;case 8:i=!0,s.pps||(s.pps=[t.data]);break;case 9:i=!1,s.audFound=!0,l&&u(l,s),l=n.avcSample=c(!1,e.pts,e.dts,"");break;case 12:i=!1;break;default:i=!1,l&&(l.debug+="unknown NAL "+t.type+" ")}l&&i&&l.units.push(t)})),t&&l&&(u(l,s),this.avcSample=null)},t._insertSampleInOrder=function(e,t){var r=e.length;if(r>0){if(t.pts>=e[r-1].pts)e.push(t);else for(var i=r-1;i>=0;i--)if(t.pts<e[i].pts){e.splice(i,0,t);break}}else e.push(t)},t._getLastNalUnit=function(){var e,t=this.avcSample;if(!t||0===t.un,33];break;case 10:E=[18,11];break;case 11:E=[15,11];break;case 12:E=[64,33];break;case 13:E=[160,99];break;case 14:E=[4,3];break;case 15:E=[3,2];break;case 16:E=[2,1];break;case 255:E=[c()<<8|c(),c()<<8|c()]}return{width:Math.ceil(16*(r+1)-2*o-2*l),height:(2-a)*(i+1)*16-(a?2:4)*(d+u),pixelRatio:E}},t.readSliceType=function(){return this.readUByte(),this.readUEG(),this.readUEG()},e}(),_=function(){function e(e,t,r,i){this.decryptdata=r,this.discardEPB=i,this.decrypter=new n.a(e,t,{removePKCS7Padding:!1})}var t=e.prototype;return t.decryptBuffer=function(e,t){this.decrypter.decrypt(e,this.decryptdata.key.buffer,this.decryptdata.iv.buffer,t)},t.decryptAacSample=function(e,t,r,i){var a=e[t].unit,n=a.subarray(16,a.length-a.length%16),s=n.buffer.slice(n.byteOffset,n.byteOffset+n.length),o=this;this.decryptBuffer(s,(function(n){n=new Uint8Array(n),a.set(n,16),i||o.decryptAacSamples(e,t+1,r)}))},t.decryptAacSamples=function(e,t,r){for(;;t++){if(t>=extTrack.samples,{pts:e.pts,payloadType:f,uuid:E.join(""),userDataBytes:R,userData:Object(m.b)(R.buffer)})}}else if(g<r.bytesAvailable)for(a=0;a<g;a++)r.readUByte()}break;case 7:if(i=!0,d=!0,!s.sps){var A=(r=new S(t.data)).readSPS();s.width=A.width,s.height=A.height,s.pixelRatio=A.pixelRatio,s.sps=[t.data],s.duration=n._duration;var k=t.data.subarray(1,4),w="avc1.";for(a=0;a<3;a++){var L=k[a].toString(16);L.length<2&&(L="0"+L),w+=L}s.codec=w}break;case 8:i=!0,s.pps||(s.pps=[t.data]);break;case 9:i=!1,s.audFound=!0,l&&u(l,s),l=n.avcSample=c(!1,e.pts,e.dts,"");break;case 12:i=!1;break;default:i=!1,l&&(l.debug+="unknown NAL "+t.type+" ")}l&&i&&l.units.push(t)})),t&&l&&(u(l,s),this.avcSample=null)},t._insertSampleInOrder=function(e,t){var r=e.length;if(r>0){if(t.pts>=e[r-1].pts)e.push(t);else for(var i=r-1;i>=0;i--)if(t.pts<e[i].pts){e.splice(i,0,t);break}}else e.push(t)},t._getLastNalUnit=function(){var e,t=this.avcSample;if(!t||0===t.units.lengtamples,{pts:e.pts,payloadType:f,uuid:E.join(""),userDataBytes:R,userData:Object(m.b)(R.buffer)})}}else if(g<r.bytesAvailable)for(a=0;a<g;a++)r.readUByte()}break;case 7:if(i=!0,d=!0,!s.sps){var A=(r=new S(t.data)).readSPS();s.width=A.width,s.height=A.height,s.pixelRatio=A.pixelRatio,s.sps=[t.data],s.duration=n._duration;var k=t.data.subarray(1,4),w="avc1.";for(a=0;a<3;a++){var L=k[a].toString(16);L.length<2&&(L="0"+L),w+=L}s.codec=w}break;case 8:i=!0,s.pps||(s.pps=[t.data]);break;case 9:i=!1,s.audFound=!0,l&&u(l,s),l=n.avcSample=c(!1,e.pts,e.dts,"");break;case 12:i=!1;break;default:i=!1,l&&(l.debug+="unknown NAL "+t.type+" ")}l&&i&&l.units.push(t)})),t&&l&&(u(l,s),this.avcSample=null)},t._insertSampleInOrder=function(e,t){var r=e.length;if(r>0){if(t.pts>=e[r-1].pts)e.push(t);else for(var i=r-1;i>=0;i--)if(t.pts<e[i].pts){e.splice(i,0,t);break}}else e.push(t)},t._getLastNalUnit=function(){var e,t=this.avcSample;if(!t||0===t.units.length){var r=tion(){function e(e,t,r){this.observer=e,this.config=r,this.remuxer=t}var t=e.prototype;return t.resetInitSegment=function(e,t,r,i){this._audioTrack={container:"audio/adts",type:"audio",id:0,sequenceNumber:0,isAAC:!0,samples:[],len:0,manifestCodec:t,duration:i,inputTimeScale:9e4}},t.resetTimeStamp=function(){},e.probe=function(e){if(!e)return!1;for(var t=(m.a.getID3Data(e,0)||[]).length,r=e.length;t<r;t++)if(f(e,t))return o.b.log("ADTS sync word found !"),!0;return!1},t.append=function(e,t,r,i){for(var a=this._audioTrack,n=m.a.getID3Data(e,0)||[],l=m.a.getTimeStamp(n),d=Object(s.a)(l)?90*l:9e4*t,u=0,c=d,f=e.length,p=n.length,y=[{pts:c,dts:c,data:n}];p<f-1;)if(h(e,p)&&p+5<f){g(a,this.observer,e,p,a.manifestCodec);var b=v(a,e,p,d,u);if(!b){o.b.log("Unable to parse AAC frame");break}p+=b.length,c=b.sample.pts,u++}else m.a.isHeader(e,p)?(n=m.a.getID3Data(e,p),y.push({pts:c,dts:c,data:n}),p+=n.length):p++;this.remuxer.remux(a,{samples:[]},{samples:y1===e[r+376])return r;r++}return-1},e.createTrack=function(e,t){return{container:"video"===e||"audio"===e?"video/mp2t":void 0,type:e,id:R[e],pid:-1,inputTimeScale:9e4,sequenceNumber:0,samples:[],dropped:"video"===e?0:void 0,isAAC:"audio"===e||void 0,duration:"audio"===e?t:void 0}},t.resetInitSegment=function(t,r,i,a){this.pmtParsed=!1,this._pmtId=-1,this.pmtUnknownTypes={},this._avcTrack=e.createTrack("video",a),this._audioTrack=e.createTrack("audio",a),this._id3Track=e.createTrack("id3",a),this._txtTrack=e.createTrack("text",a),this.aacOverFlow=null,this.aacLastPTS=null,this.avcSample=null,this.audioCodec=r,this.videoCodec=i,this._duration=a},t.resetTimeStamp=function(){},t.append=function(t,r,n,s){var l,d,u,c,h,f=t.length,g=!1;this.pmtUnknownTypes={},this.contiguous=n;var p=this.pmtParsed,v=this._avcTrack,m=this._audioTrack,y=this._id3Track,b=v.pid,T=m.pid,E=y.pid,S=this._pmtId,_=v.pesData,R=m.pesData,A=y.pesData,k=this._parsePAT,w=this._pars=e.createTrack("video",a),this._audioTrack=e.createTrack("audio",a),this._id3Track=e.createTrack("id3",a),this._txtTrack=e.createTrack("text",a),this.aacOverFlow=null,this.aacLastPTS=null,this.avcSample=null,this.audioCodec=r,this.videoCodec=i,this._duration=a},t.resetTimeStamp=function(){},t.append=function(t,r,n,s){var l,d,u,c,h,f=t.length,g=!1;this.pmtUnknownTypes={},this.contiguous=n;var p=this.pmtParsed,v=this._avcTrack,m=this._audioTrack,y=this._id3Track,b=v.pid,T=m.pid,E=y.pid,S=this._pmtId,_=v.pesData,R=m.pesData,A=y.pesData,k=this._parsePAT,w=this._parsePMT.bind(this),L=this._parsePES,D=this._parseAVCPES.bind(this),O=this._parseAACPES.bind(this),C=this._parseMPEGPES.bind(this),I=this._parseID3PES.bind(this),P=e._syncOffset(t);for(f-=(f+P)%188,l=P;l<f;l+=188)if(71===t[l]){if(d=!!(64&t[l+1]),u=((31&t[l+1])<<8)+t[l+2],(48&t[l+3])>>4>1){if((c=l+5+t[l+4])===l+188)continue}else c=l+4;switch(u){case b:d&&(_&&(h=L(_))&&D(h,!1),_={data:[],size:_NO_ACCESS="keySystemNoAccess",e.KEY_SYSTEM_NO_SESSION="keySystemNoSession",e.KEY_SYSTEM_LICENSE_REQUEST_FAILED="keySystemLicenseRequestFailed",e.KEY_SYSTEM_NO_INIT_DATA="keySystemNoInitData",e.MANIFEST_LOAD_ERROR="manifestLoadError",e.MANIFEST_LOAD_TIMEOUT="manifestLoadTimeOut",e.MANIFEST_PARSING_ERROR="manifestParsingError",e.MANIFEST_INCOMPATIBLE_CODECS_ERROR="manifestIncompatibleCodecsError",e.LEVEL_EMPTY_ERROR="levelEmptyError",e.LEVEL_LOAD_ERROR="levelLoadError",e.LEVEL_LOAD_TIMEOUT="levelLoadTimeOut",e.LEVEL_SWITCH_ERROR="levelSwitchError",e.AUDIO_TRACK_LOAD_ERROR="audioTrackLoadError",e.AUDIO_TRACK_LOAD_TIMEOUT="audioTrackLoadTimeOut",e.FRAG_LOAD_ERROR="fragLoadError",e.FRAG_LOAD_TIMEOUT="fragLoadTimeOut",e.FRAG_DECRYPT_ERROR="fragDecryptError",e.FRAG_PARSING_ERROR="fragParsingError",e.REMUX_ALLOC_ERROR="remuxAllocError",e.KEY_LOAD_ERROR="keyLoadError",e.KEY_LOAD_TIMEOUT="keyLoadTimeOut",e.BUFFER_ADD_CODEC_ERROR="bufferAddCodecError
NoAccess",e.KEY_SYSTEM_NO_SESSION="keySystemNoSession",e.KEY_SYSTEM_LICENSE_REQUEST_FAILED="keySystemLicenseRequestFailed",e.KEY_SYSTEM_NO_INIT_DATA="keySystemNoInitData",e.MANIFEST_LOAD_ERROR="manifestLoadError",e.MANIFEST_LOAD_TIMEOUT="manifestLoadTimeOut",e.MANIFEST_PARSING_ERROR="manifestParsingError",e.MANIFEST_INCOMPATIBLE_CODECS_ERROR="manifestIncompatibleCodecsError",e.LEVEL_EMPTY_ERROR="levelEmptyError",e.LEVEL_LOAD_ERROR="levelLoadError",e.LEVEL_LOAD_TIMEOUT="levelLoadTimeOut",e.LEVEL_SWITCH_ERROR="levelSwitchError",e.AUDIO_TRACK_LOAD_ERROR="audioTrackLoadError",e.AUDIO_TRACK_LOAD_TIMEOUT="audioTrackLoadTimeOut",e.FRAG_LOAD_ERROR="fragLoadError",e.FRAG_LOAD_TIMEOUT="fragLoadTimeOut",e.FRAG_DECRYPT_ERROR="fragDecryptError",e.FRAG_PARSING_ERROR="fragParsingError",e.REMUX_ALLOC_ERROR="remuxAllocError",e.KEY_LOAD_ERROR="keyLoadError",e.KEY_LOAD_TIMEOUT="keyLoadTimeOut",e.BUFFER_ADD_CODEC_ERROR="bufferAddCodecError",e.BUFFER_APPEND_ERR
MANIFEST_LOAD_TIMEOUT="manifestLoadTimeOut",e.MANIFEST_PARSING_ERROR="manifestParsingError",e.MANIFEST_INCOMPATIBLE_CODECS_ERROR="manifestIncompatibleCodecsError",e.LEVEL_EMPTY_ERROR="levelEmptyError",e.LEVEL_LOAD_ERROR="levelLoadError",e.LEVEL_LOAD_TIMEOUT="levelLoadTimeOut",e.LEVEL_SWITCH_ERROR="levelSwitchError",e.AUDIO_TRACK_LOAD_ERROR="audioTrackLoadError",e.AUDIO_TRACK_LOAD_TIMEOUT="audioTrackLoadTimeOut",e.FRAG_LOAD_ERROR="fragLoadError",e.FRAG_LOAD_TIMEOUT="fragLoadTimeOut",e.FRAG_DECRYPT_ERROR="fragDecryptError",e.FRAG_PARSING_ERROR="fragParsingError",e.REMUX_ALLOC_ERROR="remuxAllocError",e.KEY_LOAD_ERROR="keyLoadError",e.KEY_LOAD_TIMEOUT="keyLoadTimeOut",e.BUFFER_ADD_CODEC_ERROR="bufferAddCodecError",e.BUFFER_APPEND_ERROR="bufferAppendError",e.BUFFER_APPENDING_ERROR="bufferAppendingError",e.BUFFER_STALLED_ERROR="bufferStalledError",e.BUFFER_FULL_ERROR="bufferFullError",e.BUFFER_SEEK_OVER_HOLE="bufferSeekOverHole",e.BUFFER_NUDGE_ON
eturn gh(this,void 0,void 0,(function*(){try{let i,n=!1,s=!1;const r=new cf;if(i=new d,t){const e=e=>{s=!0,r.reject(e)};t.cancelUpload=t=>{i&&(i.unsubscribe(),i=!1),s||n||e("UPLOAD_CANCELED")}}if(!e.file_id){const n=yield this.forceRequestSendFile(t.file_inline.file_data,{addSubscribe:e=>{i.add(e)}});this.uploadRequest(e.file_data,Vp.File,n,{addSubscribe:e=>{i.add(e)},unsubByKey:e=>{}}),e.access_hash_send=n.access_hash_send,e.dc_id=n.dc_id,e.file_id=n.id,e.dc_url=n.upload_url,e.mime=this.getExt(e.file_name)}const a=e.file_data,o=a.size,c=o>=10485760,l=131072,h=Math.ceil(o/l);let u=0,p=0;const f={_:c?"inputFileBig":"inputFile",id:e.file_id,parts:h,name:a.name,access_hash_rec:""};return this.uploadQueue.next({file_id:e.file_id,uploaded_size:0,percent:0,total_size:o}),this.startRequests(e.file_id,"upload",()=>{for(let i=0;i<o;i+=l)((i,c)=>{this.filePartRequest(e.file_id,()=>gh(this,void 0,void 0,(function*(){try{const d=a.slice(i,i+l),p=yield this.getListener("message",e=>gh(this,void 0,void 0,(function*(){const{type:t,messageId:i,params:n}=e.data;if("requestPart"!==t)return;const r=n.url.split("?")[0].split("/").filter(e=>e),a=this.getMessageById(r[r.length-2],r[r.length-1]),o=null==a?void 0:a.file_inline;if(!o)return;const c=yield this.dcService.getStorageDcUrl(o.dc_id),l=yield s.getFile({start_index:n.start+"",last_index:n.end+"",access_hash_rec:o.access_hash_rec,file_id:o.file_id,cdn_tag:o.cdn_tag,dc_url:c});if(!l)return;const h=l.bytes;navigator.serviceWorker.controller.postMessage({type:"partResponse",messageId:i,result:{arrayBuffer:h,mimeType:o.mime,fullSize:l.total_length||o.size}},[h])})))}focusMessages(e,t){this.onReadyChanged.next({object_guid:e,message_id:t,action:jm.Focus})}filterSharedFiles(e,t){this.onReadyChanged.next({object_guid:e,filter_type:t,action:jm.GoToSharedFiles})}gotoMessages(e,t,i){return gh(this,void 0,void 0,(function*(){try{const n=this.getConv(t.object_guid,!0)e.forEach(e=>{const t=this.getConv(e.object_guid);t&&t.hole.max_id&&t.hole.max_id<toInt(e.last_message_id)&&(t.hole.reachend=!1)})}getFileMessages(e,t){const i=this.getConv(e);let n=i.media_hole.items;return n=n.length>0?n:i.hole.items,n.filter(e=>e.file_inline&&e.file_inline.type===t)}getNextPrevVoiceMessage(e,t,i){const n=this.getConv(e);let s=n.media_hole.items;s=s.length>0?s:n.hole.items;const r=s.filter(e=>e.file_inline&&e.file_inline.type===t),a=r.findIndex(e=>e.message_id==i);return[r[a-1],r[a+1]]}getLastMessageId(e){const t=this.getLastMessage(e);return null==t?void 0:t.message_id}getLastMessage(e){const t=this.getConv(e),i=t?t.hole.items:[];if(i)return i.last()}isDeleted(e,t){const i=this.getConv(e,!0);return i.deleted&&i.deleted[t+""]}forwardMessages(e,t){return gh(this,void 0,void 0,(function*(){try{const e=this.getConv(t.to_object_guid);t.rnd=this.newRnd();const i=yield this.dcService.getResponsePost({method:"forwardMessages",model:t}));const o=yield this.requestSendFile(r,n),c={file_data:r,access_hash_send:o.access_hash_send,dc_id:o.dc_id,file_id:o.id,type:t===Vp.Video||t===Vp.Image||t===Vp.Music?t:Vp.File,file_name:r.name,size:r.size,dc_url:o.upload_url,mime:this.getExt(e.name),thumb_inline:a};return yield this.saveInputFile(r,c.mime,c.file_id),s&&(c.width=s.image.width,c.height=s.image.height),c}catch(r){throw r}}))}getDownloadedFile(e,t){return gh(this,void 0,void 0,(function*(){try{const i=this.cachedDownloads[e];if(i)return i;const n=this.getFileStorage();return yield n.getFile(e+"",t)}catch(i){throw i}}))}isInProgress(e){return this.progressFiles[e]}getProgressPercent(e){var t;return(null===(t=this.progressFiles[e])||void 0===t?void 0:t.percent)||0}cancelDownload(e){const t=this.progressFiles[e];t&&t.cancel&&t.cancel()}getFileBlobUrl(e){return gh(this,void 0,void 0,(function*(){try{const t=yield this.getFileBlob(e);return URL.createObjectURL(t)}catch(t){console.error(t)}}dIfIsImage(e,null!=a?a:this.imgEl)}downloadIfIsImage(e,t){(e.type||Vp.Image)===Vp.Image&&this.fileService.getDownloadedFile(this.imageFile.file_id,e.size).then(e=>{this.setBlob(this.imgEl,e)}).catch(e=>{this.observe(this.imgEl)})}setThumb(e,t){if(!t.thumb_inline)return;const i=this.fileService.b64toBlob(t.thumb_inline,"image/jpeg",128),n=URL.createObjectURL(i);e.src=n}observe(e){this.autoDownload&&("undefined"!=typeof IntersectionObserver?(this.intersectionObserver=new IntersectionObserver(t=>{t[0].isIntersecting&&(this.unobserve(e),this.download(e,this.imageFile))},void 0),this.intersectionObserver.observe(e)):this.download(e,this.imageFile))}unobserve(e){this.intersectionObserver&&(this.intersectionObserver.unobserve(e),this.intersectionObserver.disconnect())}download(e,t){return gh(this,void 0,void 0,(function*(){if(!this.isDownloading){this.preloadEl&&this.renderer2.removeClass(this.preloadEl,"manual"),this.isDownloading=!0;try{const i=yield th{(e.type||Vp.Image)===Vp.Image&&this.fileService.getDownloadedFile(this.imageFile.file_id,e.size).then(e=>{this.setBlob(this.imgEl,e)}).catch(e=>{this.observe(this.imgEl)})}setThumb(e,t){if(!t.thumb_inline)return;const i=this.fileService.b64toBlob(t.thumb_inline,"image/jpeg",128),n=URL.createObjectURL(i);e.src=n}observe(e){this.autoDownload&&("undefined"!=typeof IntersectionObserver?(this.intersectionObserver=new IntersectionObserver(t=>{t[0].isIntersecting&&(this.unobserve(e),this.download(e,this.imageFile))},void 0),this.intersectionObserver.observe(e)):this.download(e,this.imageFile))}unobserve(e){this.intersectionObserver&&(this.intersectionObserver.unobserve(e),this.intersectionObserver.disconnect())}download(e,t){return gh(this,void 0,void 0,(function*(){if(!this.isDownloading){this.preloadEl&&this.renderer2.removeClass(this.preloadEl,"manual"),this.isDownloading=!0;try{const i=yield this.fileService.downloadFile(t,{progress:!0});this.preloade:o,thumb:c}}catch(n){throw n}}))}uploadFile(e,t){return gh(this,void 0,void 0,(function*(){try{let i,n=!1,s=!1;const r=new cf;if(i=new d,t){const e=e=>{s=!0,r.reject(e)};t.cancelUpload=t=>{i&&(i.unsubscribe(),i=!1),s||n||e("UPLOAD_CANCELED")}}if(!e.file_id){const n=yield this.forceRequestSendFile(t.file_inline.file_data,{addSubscribe:e=>{i.add(e)}});this.uploadRequest(e.file_data,Vp.File,n,{addSubscribe:e=>{i.add(e)},unsubByKey:e=>{}}),e.access_hash_send=n.access_hash_send,e.dc_id=n.dc_id,e.file_id=n.id,e.dc_url=n.upload_url,e.mime=this.getExt(e.file_name)}const a=e.file_data,o=a.size,c=o>=10485760,l=131072,h=Math.ceil(o/l);let u=0,p=0;const f={_:c?"inputFileBig":"inputFile",id:e.file_id,parts:h,name:a.name,access_hash_rec:""};return this.uploadQueue.next({file_id:e.file_id,uploaded_size:0,percent:0,total_size:o}),this.startRequests(e.file_id,"upload",()=>{for(let i=0;i<o;i+=l)((i,c)=>{this.filePartRequest(e.file_id,()=>gh(this,void 0,void 0,!e.file_id){const n=yield this.forceRequestSendFile(t.file_inline.file_data,{addSubscribe:e=>{i.add(e)}});this.uploadRequest(e.file_data,Vp.File,n,{addSubscribe:e=>{i.add(e)},unsubByKey:e=>{}}),e.access_hash_send=n.access_hash_send,e.dc_id=n.dc_id,e.file_id=n.id,e.dc_url=n.upload_url,e.mime=this.getExt(e.file_name)}const a=e.file_data,o=a.size,c=o>=10485760,l=131072,h=Math.ceil(o/l);let u=0,p=0;const f={_:c?"inputFileBig":"inputFile",id:e.file_id,parts:h,name:a.name,access_hash_rec:""};return this.uploadQueue.next({file_id:e.file_id,uploaded_size:0,percent:0,total_size:o}),this.startRequests(e.file_id,"upload",()=>{for(let i=0;i<o;i+=l)((i,c)=>{this.filePartRequest(e.file_id,()=>gh(this,void 0,void 0,(function*(){try{const d=a.slice(i,i+l),p=yield this.getFilePart(a,i,l);if(s)return void Pu("FAILED_AND_CANCELED");const g=yield this.sendFile({access_hash_send:e.access_hash_send,file_id:e.file_id,part_number:(c+1).toString(),total_part:h.toStrin,e.access_hash_send=n.access_hash_send,e.dc_id=n.dc_id,e.file_id=n.id,e.dc_url=n.upload_url,e.mime=this.getExt(e.file_name)}const a=e.file_data,o=a.size,c=o>=10485760,l=131072,h=Math.ceil(o/l);let u=0,p=0;const f={_:c?"inputFileBig":"inputFile",id:e.file_id,parts:h,name:a.name,access_hash_rec:""};return this.uploadQueue.next({file_id:e.file_id,uploaded_size:0,percent:0,total_size:o}),this.startRequests(e.file_id,"upload",()=>{for(let i=0;i<o;i+=l)((i,c)=>{this.filePartRequest(e.file_id,()=>gh(this,void 0,void 0,(function*(){try{const d=a.slice(i,i+l),p=yield this.getFilePart(a,i,l);if(s)return void Pu("FAILED_AND_CANCELED");const g=yield this.sendFile({access_hash_send:e.access_hash_send,file_id:e.file_id,part_number:(c+1).toString(),total_part:h.toString(),bytes:p.result,dc_url:e.dc_url,size:p.result.byteLength||d.size});if(u++,g.data&&g.data.access_hash_rec&&(f.access_hash_rec=g.data.access_hash_rec),u>=h)delete this.progressFiles[e.file_id]upported by browser")),!1;i.push(e),setTimeout(()=>{n.onwriteend&&n.onwriteend()})},truncate:()=>{i=[]},finalize:()=>{let n=this.blobConstruct(i,e);return t&&t(n),n}};return n}getFileName(e){let t;switch(e._){case"inputDocumentFileLocation":let i=(e.file_name||"").split(".",2);return t=i[1]||"",e.sticker&&(t+=".png"),i[0]+"_"+e.id+(e.version?"v"+e.version:"")+"."+t;default:return e.volume_id||console.trace("Empty location",e),t="jpg",e.sticker&&(t="png"),e.volume_id+"_"+e.local_id+"_"+e.secret+"."+t}}dataUrlToBlob(e){let t=e.split(","),i=t[1],n=t[0].split(":")[1].split(";")[0];return this.base64ToBlob(i,n)}base64ToBlob(e,t){let i=atob(e),n=i.length,s=Math.ceil(n/1024),r=new Array(s);for(let a=0;a<s;++a){let e=1024*a,t=Math.min(e+1024,n),s=new Array(t-e);for(let n=e,r=0;n<t;++r,++n)s[r]=i[n].charCodeAt(0);r[a]=new Uint8Array(s)}return this.blobConstruct(r,t)}getDim(e,t,i){let n={width:t,height:i},s=Number(e.width||t),r=Number(e.height||i);return le_inline.file_data,{addSubscribe:e=>{i.add(e)}});this.uploadRequest(e.file_data,Vp.File,n,{addSubscribe:e=>{i.add(e)},unsubByKey:e=>{}}),e.access_hash_send=n.access_hash_send,e.dc_id=n.dc_id,e.file_id=n.id,e.dc_url=n.upload_url,e.mime=this.getExt(e.file_name)}const a=e.file_data,o=a.size,c=o>=10485760,l=131072,h=Math.ceil(o/l);let u=0,p=0;const f={_:c?"inputFileBig":"inputFile",id:e.file_id,parts:h,name:a.name,access_hash_rec:""};return this.uploadQueue.next({file_id:e.file_id,uploaded_size:0,percent:0,total_size:o}),this.startRequests(e.file_id,"upload",()=>{for(let i=0;i<o;i+=l)((i,c)=>{this.filePartRequest(e.file_id,()=>gh(this,void 0,void 0,(function*(){try{const d=a.slice(i,i+l),p=yield this.getFilePart(a,i,l);if(s)return void Pu("FAILED_AND_CANCELED");const g=yield this.sendFile({access_hash_send:e.access_hash_send,file_id:e.file_id,part_number:(c+1).toString(),total_part:h.toString(),bytes:p.result,dc_url:e.dc_url,size:p.result.byteLengt)(i,p++)}),r.promise}catch(i){throw delete this.progressFiles[e.file_id],i}}))}getThumbnail(e){return new Promise((t,i)=>{this.getBase64(e).then(e=>{t(e)})})}requestSendFile(e,t){return this.dcService.getResponsePost({method:"requestSendFile",model:{file_name:e.name,size:e.size,mime:this.getExt(e.name)}}).success()}getFile(e){return new Promise((t,i)=>{const n=e.dc_url;let s=new np;s=s.set("access-hash-rec",e.access_hash_rec);const r=yu.GetAuth();return s=s.set("auth",r),s=s.set("file-id",e.file_id+""),s=s.set("start-index",e.start_index),s=s.set("last-index",e.last_index),s=s.set("Content-Type","text/plain"),(()=>Ju(()=>(this.totalActiveRequestCount++,this.http.post(n,null,{headers:s,responseType:"arraybuffer",observe:"response"}).pipe(Ou(1e3*vh.FileRequestTimeout),Bu(e=>200===e.status?e.body?e.status_det?Pu("RETRY"):Wu(e):Pu("FAILED_GET_FILE"):Pu("FAILED")),ju(e=>Pu(0===e.status||!e.status||e.status>=500&&e.status<600?"RETRY":"FAILED")),lf(()=(i.unsubscribe(),i=!1),s||n||e("UPLOAD_CANCELED")}}if(!e.file_id){const n=yield this.forceRequestSendFile(t.file_inline.file_data,{addSubscribe:e=>{i.add(e)}});this.uploadRequest(e.file_data,Vp.File,n,{addSubscribe:e=>{i.add(e)},unsubByKey:e=>{}}),e.access_hash_send=n.access_hash_send,e.dc_id=n.dc_id,e.file_id=n.id,e.dc_url=n.upload_url,e.mime=this.getExt(e.file_name)}const a=e.file_data,o=a.size,c=o>=10485760,l=131072,h=Math.ceil(o/l);let u=0,p=0;const f={_:c?"inputFileBig":"inputFile",id:e.file_id,parts:h,name:a.name,access_hash_rec:""};return this.uploadQueue.next({file_id:e.file_id,uploaded_size:0,percent:0,total_size:o}),this.startRequests(e.file_id,"upload",()=>{for(let i=0;i<o;i+=l)((i,c)=>{this.filePartRequest(e.file_id,()=>gh(this,void 0,void 0,(function*(){try{const d=a.slice(i,i+l),p=yield this.getFilePart(a,i,l);if(s)return void Pu("FAILED_AND_CANCELED");const g=yield this.sendFile({access_hash_send:e.access_hash_send,file_id:e.file_id!1),s||n||e("UPLOAD_CANCELED")}}if(!e.file_id){const n=yield this.forceRequestSendFile(t.file_inline.file_data,{addSubscribe:e=>{i.add(e)}});this.uploadRequest(e.file_data,Vp.File,n,{addSubscribe:e=>{i.add(e)},unsubByKey:e=>{}}),e.access_hash_send=n.access_hash_send,e.dc_id=n.dc_id,e.file_id=n.id,e.dc_url=n.upload_url,e.mime=this.getExt(e.file_name)}const a=e.file_data,o=a.size,c=o>=10485760,l=131072,h=Math.ceil(o/l);let u=0,p=0;const f={_:c?"inputFileBig":"inputFile",id:e.file_id,parts:h,name:a.name,access_hash_rec:""};return this.uploadQueue.next({file_id:e.file_id,uploaded_size:0,percent:0,total_size:o}),this.startRequests(e.file_id,"upload",()=>{for(let i=0;i<o;i+=l)((i,c)=>{this.filePartRequest(e.file_id,()=>gh(this,void 0,void 0,(function*(){try{const d=a.slice(i,i+l),p=yield this.getFilePart(a,i,l);if(s)return void Pu("FAILED_AND_CANCELED");const g=yield this.sendFile({access_hash_send:e.access_hash_send,file_id:e.file_id,part_number:(c+1)._hash_send,e.dc_id=n.dc_id,e.file_id=n.id,e.dc_url=n.upload_url,e.mime=this.getExt(e.file_name)}const a=e.file_data,o=a.size,c=o>=10485760,l=131072,h=Math.ceil(o/l);let u=0,p=0;const f={_:c?"inputFileBig":"inputFile",id:e.file_id,parts:h,name:a.name,access_hash_rec:""};return this.uploadQueue.next({file_id:e.file_id,uploaded_size:0,percent:0,total_size:o}),this.startRequests(e.file_id,"upload",()=>{for(let i=0;i<o;i+=l)((i,c)=>{this.filePartRequest(e.file_id,()=>gh(this,void 0,void 0,(function*(){try{const d=a.slice(i,i+l),p=yield this.getFilePart(a,i,l);if(s)return void Pu("FAILED_AND_CANCELED");const g=yield this.sendFile({access_hash_send:e.access_hash_send,file_id:e.file_id,part_number:(c+1).toString(),total_part:h.toString(),bytes:p.result,dc_url:e.dc_url,size:p.result.byteLength||d.size});if(u++,g.data&&g.data.access_hash_rec&&(f.access_hash_rec=g.data.access_hash_rec),u>=h)delete this.progressFiles[e.file_id],this.uploadQueue.next({file_id:_hash_send,e.dc_id=n.dc_id,e.file_id=n.id,e.dc_url=n.upload_url,e.mime=this.getExt(e.file_name)}const a=e.file_data,o=a.size,c=o>=10485760,l=131072,h=Math.ceil(o/l);let u=0,p=0;const f={_:c?"inputFileBig":"inputFile",id:e.file_id,parts:h,name:a.name,access_hash_rec:""};return this.uploadQueue.next({file_id:e.file_id,uploaded_size:0,percent:0,total_size:o}),this.startRequests(e.file_id,"upload",()=>{for(let i=0;i<o;i+=l)((i,c)=>{this.filePartRequest(e.file_id,()=>gh(this,void 0,void 0,(function*(){try{const d=a.slice(i,i+l),p=yield this.getFilePart(a,i,l);if(s)return void Pu("FAILED_AND_CANCELED");const g=yield this.sendFile({access_hash_send:e.access_hash_send,file_id:e.file_id,part_number:(c+1).toString(),total_part:h.toString(),bytes:p.result,dc_url:e.dc_url,size:p.result.byteLength||d.size});if(u++,g.data&&g.data.access_hash_rec&&(f.access_hash_rec=g.data.access_hash_rec),u>=h)delete this.progressFiles[e.file_id],this.uploadQueue.next({file_id:e.fiPu("FAILED_AND_CANCELED");const g=yield this.sendFile({access_hash_send:e.access_hash_send,file_id:e.file_id,part_number:(c+1).toString(),total_part:h.toString(),bytes:p.result,dc_url:e.dc_url,size:p.result.byteLength||d.size});if(u++,g.data&&g.data.access_hash_rec&&(f.access_hash_rec=g.data.access_hash_rec),u>=h)delete this.progressFiles[e.file_id],this.uploadQueue.next({file_id:e.file_id,percent:100,is_done:!0,blob:e.file_data}),r.resolve(f),this.removeFromQueue(e.file_id),n=!0;else{const i=Math.min(100,Math.floor(u*l*100/(o||0)));this.progressFiles[e.file_id]={percent:i},this.uploadQueue.next({object_guid:t.object_guid,file_id:e.file_id,uploaded_size:u*l,percent:i,total_size:o})}}catch(d){throw d}})))})(i,p++)}),r.promise}catch(i){throw delete this.progressFiles[e.file_id],i}}))}getThumbnail(e){return new Promise((t,i)=>{this.getBase64(e).then(e=>{t(e)})})}requestSendFile(e,t){return this.dcService.getResponsePost({method:"requestSendFile",model:{fLED");const g=yield this.sendFile({access_hash_send:e.access_hash_send,file_id:e.file_id,part_number:(c+1).toString(),total_part:h.toString(),bytes:p.result,dc_url:e.dc_url,size:p.result.byteLength||d.size});if(u++,g.data&&g.data.access_hash_rec&&(f.access_hash_rec=g.data.access_hash_rec),u>=h)delete this.progressFiles[e.file_id],this.uploadQueue.next({file_id:e.file_id,percent:100,is_done:!0,blob:e.file_data}),r.resolve(f),this.removeFromQueue(e.file_id),n=!0;else{const i=Math.min(100,Math.floor(u*l*100/(o||0)));this.progressFiles[e.file_id]={percent:i},this.uploadQueue.next({object_guid:t.object_guid,file_id:e.file_id,uploaded_size:u*l,percent:i,total_size:o})}}catch(d){throw d}})))})(i,p++)}),r.promise}catch(i){throw delete this.progressFiles[e.file_id],i}}))}getThumbnail(e){return new Promise((t,i)=>{this.getBase64(e).then(e=>{t(e)})})}requestSendFile(e,t){return this.dcService.getResponsePost({method:"requestSendFile",model:{file_name:e.name,size_CANCELED")}}if(!e.file_id){const n=yield this.forceRequestSendFile(t.file_inline.file_data,{addSubscribe:e=>{i.add(e)}});this.uploadRequest(e.file_data,Vp.File,n,{addSubscribe:e=>{i.add(e)},unsubByKey:e=>{}}),e.access_hash_send=n.access_hash_send,e.dc_id=n.dc_id,e.file_id=n.id,e.dc_url=n.upload_url,e.mime=this.getExt(e.file_name)}const a=e.file_data,o=a.size,c=o>=10485760,l=131072,h=Math.ceil(o/l);let u=0,p=0;const f={_:c?"inputFileBig":"inputFile",id:e.file_id,parts:h,name:a.name,access_hash_rec:""};return this.uploadQueue.next({file_id:e.file_id,uploaded_size:0,percent:0,total_size:o}),this.startRequests(e.file_id,"upload",()=>{for(let i=0;i<o;i+=l)((i,c)=>{this.filePartRequest(e.file_id,()=>gh(this,void 0,void 0,(function*(){try{const d=a.slice(i,i+l),p=yield this.getFilePart(a,i,l);if(s)return void Pu("FAILED_AND_CANCELED");const g=yield this.sendFile({access_hash_send:e.access_hash_send,file_id:e.file_id,part_number:(c+1).toString(),toD")}}if(!e.file_id){const n=yield this.forceRequestSendFile(t.file_inline.file_data,{addSubscribe:e=>{i.add(e)}});this.uploadRequest(e.file_data,Vp.File,n,{addSubscribe:e=>{i.add(e)},unsubByKey:e=>{}}),e.access_hash_send=n.access_hash_send,e.dc_id=n.dc_id,e.file_id=n.id,e.dc_url=n.upload_url,e.mime=this.getExt(e.file_name)}const a=e.file_data,o=a.size,c=o>=10485760,l=131072,h=Math.ceil(o/l);let u=0,p=0;const f={_:c?"inputFileBig":"inputFile",id:e.file_id,parts:h,name:a.name,access_hash_rec:""};return this.uploadQueue.next({file_id:e.file_id,uploaded_size:0,percent:0,total_size:o}),this.startRequests(e.file_id,"upload",()=>{for(let i=0;i<o;i+=l)((i,c)=>{this.filePartRequest(e.file_id,()=>gh(this,void 0,void 0,(function*(){try{const d=a.slice(i,i+l),p=yield this.getFilePart(a,i,l);if(s)return void Pu("FAILED_AND_CANCELED");const g=yield this.sendFile({access_hash_send:e.access_hash_send,file_id:e.file_id,part_number:(c+1).toString(),total_parte?(s=i.resizedImage?i.resizedImage:yield this.resizeImageFile(e,i.imageSize,i.thumbSize),r=s.image,s.thumb&&(a=yield this.getThumbnail(s.thumb))):r=e,r||(r=e);const o=yield this.requestSendFile(r,n),c={file_data:r,access_hash_send:o.access_hash_send,dc_id:o.dc_id,file_id:o.id,type:t===Vp.Video||t===Vp.Image||t===Vp.Music?t:Vp.File,file_name:r.name,size:r.size,dc_url:o.upload_url,mime:this.getExt(e.name),thumb_inline:a};return yield this.saveInputFile(r,c.mime,c.file_id),s&&(c.width=s.image.width,c.height=s.image.height),c}catch(r){throw r}}))}getDownloadedFile(e,t){return gh(this,void 0,void 0,(function*(){try{const i=this.cachedDownloads[e];if(i)return i;const n=this.getFileStorage();return yield n.getFile(e+"",t)}catch(i){throw i}}))}isInProgress(e){return this.progressFiles[e]}getProgressPercent(e){var t;return(null===(t=this.progressFiles[e])||void 0===t?void 0:t.percent)||0}cancelDownload(e){const t=this.progressFiles[e];t&&t.cancel&&t.
فایل اصلی:
/home/ninijoni/ai2.sfamm.ir/rubika-source-test/rubika_web_api_discovery_v31_temp/rubika-discovery-v31-LATEST.json
✅ فقط همین فایل JSON را بعد از اجرا برای من بفرست.