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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
#!/usr/bin/env python3
"""
Updater script for the news app which allows multiple feeds to be updated at
once to speed up the update process. Built in cron has to be disabled in the
news config, see the README.rst file in the top directory for more information.
"""
__author__ = 'Bernhard Posselt'
__copyright__ = 'Copyright 2012-2014, Bernhard Posselt'
__license__ = 'AGPL3+'
__maintainer__ = 'Bernhard Posselt'
__email__ = 'dev@bernhard-posselt.com'
import os
import sys
import argparse
import configparser
from owncloud_news_updater.updater import WebUpdater, ConsoleUpdater
def main():
parser = argparse.ArgumentParser()
parser.add_argument('--testrun',
help='Run update only once, DO NOT use this in a cron job, only \
recommended for testing', action='store_true')
parser.add_argument('--threads', '-t',
help='How many feeds should be fetched in parallel, defaults to 10',
default=10,
type=int)
parser.add_argument('--timeout', '-s',
help='Maximum number of seconds for updating a feed, \
defaults to 5 minutes',
default=5*60,
type=int)
parser.add_argument('--interval', '-i',
help='Update interval between fetching the next round of \
updates in seconds, defaults to 15 minutes. The update timespan \
will be subtracted from the interval.',
default=15*60,
type=int)
parser.add_argument('--loglevel', '-l',
help='Log granularity, info will log all urls and received data, error \
will only log errors',
default='error',
choices=['info', 'error'])
parser.add_argument('--config', '-c',
help='Path to config file where all parameters except can be defined \
as key values pair. An example is in bin/example_config.ini')
parser.add_argument('--user', '-u',
help='Admin username to log into ownCloud. Must be specified on the \
command line or in the config file if the updater should update over \
HTTP')
parser.add_argument('--password', '-p',
help='Admin password to log into ownCloud if the updater should update \
over HTTP')
parser.add_argument('url',
help='The URL or absolute path to the directory where owncloud is \
installed. Must be specified on the command line or in the config \
file. If the URL starts with http:// or https://, a user and password \
are required. Otherwise updater tries to use the console based API \
which was added in 8.1.0',
nargs='?')
args = parser.parse_args()
# read config file if given
if args.config:
config = configparser.ConfigParser()
files = config.read(args.config)
if len(files) <= 0:
print('Error: could not find config file %s' % args.config)
exit(1)
config_values = config['updater']
if 'user' in config_values:
args.user = config_values['user']
if 'password' in config_values:
args.password = config_values['password']
if 'testrun' in config_values:
args.testrun = config_values.getboolean('testrun')
if 'threads' in config_values:
args.threads = int(config_values['threads'])
if 'interval' in config_values:
args.interval = int(config_values['interval'])
if 'url' in config_values:
args.url = config_values['url']
if 'loglevel' in config_values:
args.loglevel = config_values['loglevel']
if not args.url:
_exit('No url or directory given')
# if url starts with a /, the console based API will be used
isWeb = args.url.startswith('http://') or args.url.startswith('https://')
# url and user must be specified either from the command line or in the
# config file
if isWeb and not args.user:
_exit(parser, 'Web API requires a user')
if not isWeb and not os.path.isabs(args.url):
_exit(parser, ('Absolute path to ownCloud installation required, given '
'%s') % args.url)
if not isWeb and not os.path.isdir(args.url):
_exit(parser, '%s is not a directory' % args.url)
# create the updater and run the threads
if isWeb:
updater = WebUpdater(args.url, args.threads, args.interval,
args.testrun, args.user, args.password,
args.timeout, args.loglevel)
else:
updater = ConsoleUpdater(args.url, args.threads, args.interval,
args.testrun, args.loglevel)
updater.run()
def _exit(parser, message):
print(message, file=sys.stderr)
parser.print_help()
exit(1)
if __name__ == '__main__':
if sys.version_info < (3, 0):
print('Python 3.0 or higher is required to run this script')
else:
main()
|
