keet-cli / deobfuscated / contract / reactions.js

const _0x35b51a=(function(){let _0x2bd7bc=!![];return function(_0x50980b,_0x33d358){const _0x58d6b2=_0x2bd7bc?function(){if(_0x33d358){const _0x504921=_0x33d358.apply(_0x50980b,arguments);return _0x33d358=null,_0x504921;}}:function(){};return _0x2bd7bc=![],_0x58d6b2;};}()),_0x39925e=_0x35b51a(this,function(){_0xdbbcba={_0xcc10e7:0xe},_0x5d8978={_0x536861:0x351};return _0x39925e.toString().search("(((.+)+)+)+$").toString().constructor(_0x39925e).search("(((.+)+)+)+$");});
_0x39925e();
const REGISTER_ROUTES=require('./registration'),{
  isMemberActive,getMemberForDeviceKey}
=require('./query');
const {
  reactionStats}
=require('./stats'),{
  KeetContractError}
=require('./errors');
async function handleAddReaction({header:_0x994d5d,oplog:_0x26a872,reaction:_0x3c7bfc},{db:_0x33ad04,writer:_0x2a9496}){
  _0xd46926={
    _0x534192:0x107},_0x17be08={
    _0x54b87a:0x74},[_0x258a64,_0x49b788,_0x4073f0]=await Promise.all([getMemberForDeviceKey(_0x33ad04,_0x2a9496.key),_0x33ad04.get("@keet/chat-by-message-id",{'oplog':_0x26a872}),_0x33ad04.get("@keet/threads",{'id':0x0})]);
  if(!isMemberActive(_0x258a64)||!_0x49b788||_0x258a64.status.isMuted||!_0x3c7bfc)return;
  const _0x32590e=await _0x33ad04.get("@keet/reactions",{'id':_0x49b788.id,'sender':_0x258a64.key,'reaction':_0x3c7bfc});
  if(_0x32590e)throw KeetContractError.ABORT();
  const _0x2262cb={
    'id':_0x49b788.id,'sender':_0x258a64.key,'clock':_0x4073f0.stats.chat.clock,'reaction':_0x3c7bfc}
  ;
  await _0x33ad04.insert("@keet/reactions",_0x2262cb),await reactionStats(_0x33ad04,_0x4073f0,_0x2262cb,null,_0x994d5d.timestamp);
}
async function handleRemoveReaction({header:_0x45cf63,oplog:_0x2dd807,reaction:_0x9a0f97},{db:_0x6d8be2,writer:_0x118b87}){
  _0x4dbcd8={
    _0x4791cb:0x272},[_0x31ad06,_0x155141,_0x422ae6]=await Promise.all([getMemberForDeviceKey(_0x6d8be2,_0x118b87.key),_0x6d8be2.get("@keet/chat-by-message-id",{'oplog':_0x2dd807}),_0x6d8be2.get("@keet/threads",{'id':0x0})]);
  if(!isMemberActive(_0x31ad06)||!_0x155141||_0x31ad06.status.isMuted)return;
  const _0x181ac3=await _0x6d8be2.get("@keet/reactions",{'id':_0x155141.id,'sender':_0x31ad06.key,'reaction':_0x9a0f97});
  if(!_0x181ac3)throw KeetContractError.ABORT();
  await _0x6d8be2.delete("@keet/reactions",_0x181ac3),await reactionStats(_0x6d8be2,_0x422ae6,null,_0x181ac3,_0x45cf63.timestamp);
}
function registerRoutes(_0x178419){
  _0x557826={
    _0x4f23e5:0x12a}
  ;
  _0x178419.add("@keet/add-reaction",handleAddReaction),_0x178419.add("@keet/remove-reaction",handleRemoveReaction);
}
module.exports={
  [REGISTER_ROUTES]:registerRoutes}
;