offcloud2_folk/logic_cache.py at master · 8ei/offcloud2_folk · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
# -*- coding: utf-8 -*-
#########################################################
# python
import os
import traceback
import time
import threading
import json
import datetime

# third-party
from sqlalchemy import desc
from sqlalchemy import or_, and_, func, not_

# sjva 공용
from framework import db, scheduler, path_app_root, SystemModelSetting
from framework.job import Job
from framework.util import Util
from framework.common.rss import RssUtil
from tool_base import ToolBaseNotify

# 패키지
from .plugin import logger, package_name
from .model import ModelSetting, ModelOffcloud2Account, ModelOffcloud2Job,  ModelOffcloud2Item, ModelOffcloud2Cache
from .offcloud_api import Offcloud
#########################################################


class LogicCache(object):

    @staticmethod
    def process_telegram_data(data):
        try:
            logger.debug('receive data')
            logger.debug(data)
            type_list = ModelSetting.get('cache_save_type_list').split('|')
            type_list = Util.get_list_except_empty(type_list)
            if len(type_list) == 0 or data['t'] in type_list:
                ret = ModelOffcloud2Cache.add(data)
                if ret is not None:
                    logger.debug('Offcloud2 %s append' % ret.name)
                    if ModelSetting.get_bool('cache_receive_info_send_telegram'):
                        msg = '😉 Offcloud2 캐쉬 정보 수신\n'
                        msg += 'Type : %s\n' % data['t']
                        msg += '%s\n' % data['n']
                        from system.model import ModelSetting as SystemModelSetting
                        ddns = SystemModelSetting.get('ddns')
                        url = '%s/%s/api/cache_download?id=%s' % (ddns, package_name, ret.id)
                        if SystemModelSetting.get_bool('auth_use_apikey'):
                            url += '&apikey=%s' % SystemModelSetting.get('auth_apikey')
                        msg += '➕ 리모트 다운로드 추가\n<%s>' % url
                        ToolBaseNotify.send_message(msg, message_id='offcloud2_cache_receive')
        except Exception as e:
            logger.error(e)
            logger.error(traceback.format_exc())


    @staticmethod
    def cache_download(req):
        try:
            apikey = ModelSetting.get('apikey')
            h = db.session.query(ModelOffcloud2Cache).filter_by(id=req.args.get('id')).first().magnet

            if len(h) == 40:
                h = 'magnet:?xt=urn:btih:' + h

            username = ModelSetting.get('default_username')
            entity = ModelOffcloud2Account.get(username)
            if entity is not None:
                remoteOptionId = entity.option_id
            else:
                return 'not exist username'
            folder_id = ModelSetting.get('default_folder_id')
            ret = Offcloud.add_remote_by_magnet(apikey, h, remoteOptionId, folder_id)
            return ret
        except Exception as e:
            logger.debug('Exception:%s', e)
            logger.debug(traceback.format_exc())
            return str(e)